ACE VERSION: 5.5<br> HOST MACHINE and OPERATING SYSTEM:<br> Linux 2.6.9 Kernel.CentOS4.2 (32bit)<br> COMPILER NAME AND VERSION (AND PATCHLEVEL):<br> gcc version 3.4.4 20050721 (Red Hat 3.4.4-2)<br> THE $ACE_ROOT/ace/config.h FILE: #include "ace/config-linux.h"<br> THE $ACE_ROOT/include/makeinclude/platform_macros.GNU FILE:platform_linux.GNU<br> <br> CONTENTS OF $ACE_ROOT/bin/MakeProjectCreator/config/default.rel<br> // This is the default relative definitions. Wildcards are acceptable.<br> //<br> // The first column is the name for which we create a relative definition.<br> // The second (optional) column is the value to build up if it isn't defined<br> // as an environmenment variable.<br> *_ROOT<br> TAO_ROOT, $ACE_ROOT/TAO<br> CIAO_ROOT, $TAO_ROOT/CIAO<br>
<br> AREA/CLASS/EXAMPLE AFFECTED:ACE_Select_Reactor<br> DOES THE PROBLEM AFFECT:<br> COMPILATION? NO<br> LINKING? NO<br> EXECUTION? YES<br> OTHER (please specify)? <br> SYNOPSIS:<br> A simple, syncronous ACE::recv_n in hadle_input( ) followed by a simple ACE::send_n( ) sendng data does not work for me<br> DESCRIPTION:<br> I'm building a simple echo test program.<br> I have an ACE_Select_Reactor listening in a port waiting data to be sent by telnet, for example. The reactor is registered for READ events. When telnet client connects, I write eight bytes in terminal. ACE_Reactors calls handle_input() , who tries to read the 8 bytes, and then (still inside
handle_input() ) it does a schedule_cancel( ) on read events, and a schedule_wakeup for WRITE events. I think ACE_Reactor should call handle_ouput( ) , but it is never called, so I can send the answer to the client. Only handle_input( ) gets called.<br> The idea is to control when I want to be notified for read or write in my Event Handler, because my protocol needs to exchange some packets syncronously in the right order. Is there any kind of read priorization over send outpur in the way ACE_reactor manage events? <br> <br> REPEAT BY:<br> See test program<br> <br> SAMPLE FIX/WORKAROUND: ?<br> <br> My program is:<br> <br> #include "ace/ACE.h"<br> #include "ace/INET_Addr.h"<br> #include "ace/SOCK_Acceptor.h"<br> #include "ace/Reactor.h"<br> #include "ace/Acceptor.h"<br> #include "ace/Select_Reactor.h"<br> #include "ace/Svc_Handler.h"<br> #include "ace/SOCK_Stream.h"<br> <br> // Test program
to read 8 bytes, then echo them to the client<br> // To test, compila the program,boot it,and do a telnet to 127.0.0.1 7020 port and send exactly 8 bytes<br> // I have tryed also writng a simple sockets program that sends exactly 8 bytes<br> // <br> <br> class MyEH : public ACE_Svc_Handler<ACE_SOCK_STREAM, ACE_NULL_SYNCH><br> {<br> public:<br> // Will wait 8 bytes,then answer to the client with them<br> MyEH (): m_iLenData(8),m_iReceived(0){}<br> <br> int open(void *p);<br> int handle_input (ACE_HANDLE fd = ACE_INVALID_HANDLE);<br> int handle_output (ACE_HANDLE fd = ACE_INVALID_HANDLE);<br> int handle_close (ACE_HANDLE handle,<br> ACE_Reactor_Mask close_mask);<br> <br> char
m_pBuffer[256];<br> int m_iLenData;<br> int m_iReceived;<br> };<br> <br> int MyEH::open (void *p)<br> {<br> ACE_TCHAR peer_name[MAXHOSTNAMELEN];<br> ACE_INET_Addr peer_addr;<br> <br> if (this->peer().get_remote_addr (peer_addr) == 0 &&<br> peer_addr.addr_to_string (peer_name, MAXHOSTNAMELEN) == 0)<br> printf("New incoming connection from %s\n",peer_name);<br> <br> if (reactor ()->register_handler (this, ACE_Event_Handler::READ_MASK ) == -1)<br> printf("Read_Handler::open, cannot register handler\n");<br> <br> //peer().enable(ACE_NONBLOCK);<br> <br> return 0;<br> }<br> int MyEH::handle_input (ACE_HANDLE h)<br> {<br> size_t result;<br> <br> printf("\nrecv(%d)
HEADER waiting %d bytes\n",h,m_iLenData - m_iReceived);<br> result = ACE::recv_n (h,&m_pBuffer[m_iReceived],m_iLenData - m_iReceived);<br> if(result<=0)<br> { <br> if(errno == EWOULDBLOCK)<br> {<br> printf("WOULDBLOCK\n");<br> return 0;<br> }<br> return -1;<br> }<br> <br> m_iReceived+= result;<br> <br> if(m_iReceived == m_iLenData)<br> {<br> m_pBuffer[m_iReceived] = 0;<br> <br>
printf("recv(%d) DATA %d %s\n",h,m_iReceived,m_pBuffer);<br> <br> m_iLenData = 8; // nest time,receive 8 again<br> m_iReceived = 0;<br> }<br> else <br> return result;<br> <br> printf("Received %d bytes.Setting IO\n",m_iReceived);<br> <br> if (ACE_Reactor::instance ()->cancel_wakeup (this, ACE_Event_Handler::READ_MASK) == -1)<br> return -1;<br> printf("Input for %d disabled\n",h);<br> if (ACE_Reactor::instance ()->schedule_wakeup (this, ACE_Event_Handler::WRITE_MASK) == -1)<br> return -1;
<br> printf("Output for %d enabled\n",h);<br> <br> return result;<br> }<br> <br> int MyEH::handle_output (ACE_HANDLE h)<br> {<br> printf("\nhandle_output(%d) called\n",h);<br> <br> int rc = ACE::send_n(h,m_pBuffer,strlen(m_pBuffer));<br> if (rc <= 0)<br> printf("Error header send\n");<br> else <br> printf("HEADER %s sent %d\n",m_pBuffer,rc);<br> <br> printf("handle_output() %d\n",rc);<br> <br> if (ACE_Reactor::instance ()->cancel_wakeup (this, ACE_Event_Handler::WRITE_MASK) != -1) <br> printf("Ouput for %d
disabled\n",get_handle());<br> if (ACE_Reactor::instance ()->schedule_wakeup (this, ACE_Event_Handler::READ_MASK) == -1)<br> return -1; <br> printf("Input for %d enabled\n",get_handle());<br> <br> return rc;<br> }<br> <br> int MyEH::handle_close (ACE_HANDLE,ACE_Reactor_Mask)<br> {<br> printf("Close\n");<br> this->reactor ()->end_reactor_event_loop ();<br> delete this;<br> <br> return 0;<br> }<br> <br> typedef ACE_Acceptor<MyEH, ACE_SOCK_ACCEPTOR> MyAcceptor;<br> <br> int main (int, ACE_TCHAR *[])<br> {<br> ACE_Select_Reactor select_reactor;<br> ACE_Reactor reactor ((ACE_Reactor_Impl *)&select_reactor);<br> <br> ACE_INET_Addr
listenAddress("127.0.0.1:7020");<br> MyAcceptor acceptor;<br> <br> acceptor.reactor (ACE_Reactor::instance (&reactor));<br> if (acceptor.open (listenAddress) == -1)<br> {<br> printf("Listen error\n");<br> exit(0); <br> }<br> else<br> {<br> printf("Working...\n");<br> }<br> <br> reactor.run_reactor_event_loop ();<br> <br> return 0;<br> }<p> 
<hr size=1>Be a better sports nut! Let your teams follow you
with Yahoo Mobile. <a href="http://us.rd.yahoo.com/evt=51731/*http://mobile.yahoo.com/sports;_ylt=At9_qDKvtAbMuh1G1SQtBI7ntAcJ
">Try it now.</a>