diff options
Diffstat (limited to 'examples/Reactor/Dgram/Dgram.cpp')
-rw-r--r-- | examples/Reactor/Dgram/Dgram.cpp | 182 |
1 files changed, 0 insertions, 182 deletions
diff --git a/examples/Reactor/Dgram/Dgram.cpp b/examples/Reactor/Dgram/Dgram.cpp deleted file mode 100644 index 33e306c4af4..00000000000 --- a/examples/Reactor/Dgram/Dgram.cpp +++ /dev/null @@ -1,182 +0,0 @@ -// $Id$ - -// Exercise the ACE_SOCK_Dgram wrapper along with the ACE_Reactor. -// This test simply ping-pongs datagrams back and forth between the -// parent and child process. - -#include "ace/Reactor.h" -#include "ace/SOCK_Dgram.h" -#include "ace/INET_Addr.h" - -// Port used to receive for dgrams. -static u_short port1; - -class Dgram_Endpoint : public ACE_Event_Handler -{ -public: - Dgram_Endpoint (const ACE_INET_Addr &local_addr); - - // = Hook methods inherited from the <ACE_Event_Handler>. - virtual ACE_HANDLE get_handle (void) const; - virtual int handle_input (ACE_HANDLE handle); - virtual int handle_timeout (const ACE_Time_Value & tv, - const void *arg = 0); - virtual int handle_close (ACE_HANDLE handle, - ACE_Reactor_Mask close_mask); - - int send (const char *buf, size_t len, const ACE_INET_Addr &); - // Send the <buf> to the peer. - -private: - ACE_SOCK_Dgram endpoint_; - // Wrapper for sending/receiving dgrams. -}; - -int -Dgram_Endpoint::send (const char *buf, size_t len, const ACE_INET_Addr &addr) -{ - return this->endpoint_.send (buf, len, addr); -} - -Dgram_Endpoint::Dgram_Endpoint (const ACE_INET_Addr &local_addr) - : endpoint_ (local_addr) -{ -} - -ACE_HANDLE -Dgram_Endpoint::get_handle (void) const -{ - return this->endpoint_.get_handle (); -} - -int -Dgram_Endpoint::handle_close (ACE_HANDLE handle, - ACE_Reactor_Mask) -{ - ACE_UNUSED_ARG (handle); - - this->endpoint_.close (); - return 0; -} - -int -Dgram_Endpoint::handle_input (ACE_HANDLE) -{ - char buf[BUFSIZ]; - ACE_INET_Addr from_addr; - - ACE_DEBUG ((LM_DEBUG, "(%P|%t) activity occurred on handle %d!\n", - this->endpoint_.get_handle ())); - - ssize_t n = this->endpoint_.recv (buf, sizeof buf, from_addr); - - if (n == -1) - ACE_ERROR ((LM_ERROR, "%p\n", "handle_input")); - else - ACE_DEBUG ((LM_DEBUG, "(%P|%t) buf of size %d = %*s\n", n, n, buf)); - - return 0; -} - -int -Dgram_Endpoint::handle_timeout (const ACE_Time_Value &, - const void *) -{ - ACE_DEBUG ((LM_DEBUG, "(%P|%t) timed out for endpoint\n")); - return 0; -} - -static int -run_test (u_short localport, - const char *remotehost, - u_short remoteport) -{ - ACE_INET_Addr remote_addr (remoteport, - remotehost); - ACE_INET_Addr local_addr (localport); - - Dgram_Endpoint endpoint (local_addr); - - // Read data from other side. - if (ACE_Reactor::instance ()->register_handler - (&endpoint, ACE_Event_Handler::READ_MASK) == -1) - ACE_ERROR_RETURN ((LM_ERROR, - "ACE_Reactor::register_handler"), - -1); - - char buf[BUFSIZ]; - ACE_OS::strcpy (buf, "Data to transmit"); - size_t len = ACE_OS::strlen (buf); - - if (localport == port1) - { - ACE_DEBUG ((LM_DEBUG, "(%P|%t) sending data\n")); - - for (size_t i = 0; i < 20; i++) - { - endpoint.send (buf, len, remote_addr); - ACE_DEBUG ((LM_DEBUG, "(%P|%t) .\n")); - ACE_OS::sleep (1); - } - } - - for (int i = 0; i < 40; i++) - { - // Wait up to 4 seconds for data. - ACE_Time_Value tv (4, 0); - - if (ACE_Reactor::instance ()->handle_events (tv) <= 0) - ACE_ERROR_RETURN ((LM_DEBUG, - "(%P|%t) %p\n", - "handle_events"), - -1); - - ACE_DEBUG ((LM_DEBUG, - "(%P|%t) return from handle events\n")); - - endpoint.send (buf, len, remote_addr); - - ACE_DEBUG ((LM_DEBUG, - "(%P|%t) .\n")); - } - - if (ACE_Reactor::instance ()->remove_handler - (&endpoint, ACE_Event_Handler::READ_MASK) == -1) - ACE_ERROR_RETURN ((LM_ERROR, - "ACE_Reactor::remove_handler"), - -1); - - ACE_DEBUG ((LM_DEBUG, "(%P|%t) exiting\n")); - - return 0; -} - -int -main (int argc, char *argv[]) -{ - // Estabish call backs and socket names. - - port1 = argc > 1 ? ACE_OS::atoi (argv[1]) : ACE_DEFAULT_SERVER_PORT; - const char *remotehost = argc > 2 ? argv[2] : ACE_DEFAULT_SERVER_HOST; - const u_short port2 = argc > 3 ? ACE_OS::atoi (argv[3]) : port1 + 1; - - ACE_DEBUG ((LM_DEBUG, - "(%P|%t) local port = %d, remote host = %s, remote port = %d\n", - port1, remotehost, port2)); - - switch (ACE_OS::fork (argv[0])) - { - case -1: - return -1; - - case 0: - run_test (port1, remotehost, port2); - break; - - default: - run_test (port2, remotehost, port1); - break; - } - - return 0; -} |