ACE/examples/Service_Configurator/IPC-tests/server/Handle_R_Dgram.inl

   1 /* -*- C++ -*- */
   2 #include "ace/Get_Opt.h"
   3 #include "ace/OS_NS_stdio.h"
   4 #include "ace/OS_NS_string.h"
   5 #include "ace/OS_NS_unistd.h"
   6
   7 ACE_INLINE
   8 Handle_R_Dgram::Handle_R_Dgram ()
   9 {
  10 }
  11
  12 ACE_INLINE int
  13 Handle_R_Dgram::open (const ACE_INET_Addr &r, int async)
  14 {
  15   if (this->ACE_SOCK_Dgram::open (r) == -1)
  16     return -1;
  17   else if (async && this->ACE_SOCK_Dgram::enable (ACE_SIGIO) == -1)
  18     return -1;
  19   else
  20     return 0;
  21 }
  22
  23 ACE_INLINE int
  24 Handle_R_Dgram::info (ACE_TCHAR **strp, size_t length) const
  25 {
  26   ACE_TCHAR buf[BUFSIZ];
  27   ACE_INET_Addr sa;
  28
  29   if (this->get_local_addr (sa) == -1)
  30     return -1;
  31
  32   ACE_OS::sprintf (buf, ACE_TEXT ("%d/"), sa.get_port_number ());
  33   ACE_OS::strcat (buf, ACE_TEXT ("udp # tests remote dgram\n"));
  34
  35   if (*strp == 0 && (*strp = ACE_OS::strdup (buf)) == 0)
  36     return -1;
  37   else
  38     ACE_OS::strncpy (*strp, buf, length);
  39   return ACE_OS::strlen (buf);
  40 }
  41
  42 ACE_INLINE int
  43 Handle_R_Dgram::init (int argc, ACE_TCHAR *argv[])
  44 {
  45   ACE_INET_Addr sidg (Handle_R_Dgram::DEFAULT_PORT);
  46   ACE_Get_Opt get_opt (argc, argv, ACE_TEXT ("p:"), 0);
  47
  48   for (int c; (c = get_opt ()) != -1; )
  49     switch (c)
  50       {
  51       case 'p':
  52         sidg.set (ACE_OS::atoi (get_opt.opt_arg ()));
  53         break;
  54       default:
  55         break;
  56       }
  57
  58   if (this->open (sidg) == -1)
  59     ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("open")), -1);
  60   else if (ACE_Reactor::instance ()->register_handler (this, ACE_Event_Handler::ACCEPT_MASK) == -1)
  61     ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"),
  62                        ACE_TEXT ("registering service with ACE_Reactor")), -1);
  63   return 0;
  64 }
  65
  66 ACE_INLINE int
  67 Handle_R_Dgram::fini ()
  68 {
  69   return ACE_Reactor::instance ()->remove_handler
  70     (this, ACE_Event_Handler::ACCEPT_MASK);
  71 }
  72
  73 ACE_INLINE ACE_HANDLE
  74 Handle_R_Dgram::get_handle () const
  75 {
  76   return ACE_SOCK_Dgram::get_handle ();
  77 }
  78
  79 ACE_INLINE int
  80 Handle_R_Dgram::handle_input (ACE_HANDLE)
  81 {
  82   ACE_INET_Addr sa;
  83   char buf[8 * 1024]; /* 8 k buffer */
  84   ssize_t n = this->recv (buf, sizeof buf, sa);
  85
  86   if (n == -1)
  87     return -1;
  88   else
  89     ACE_DEBUG ((LM_INFO,
  90                 ACE_TEXT ("received datagram from host %C on port %d\n"),
  91                 sa.get_host_name (), sa.get_port_number ()));
  92
  93   ACE_OS::puts ("----------------------------------------");
  94   ACE_OS::write (ACE_STDOUT, buf, n);
  95
  96   if (buf[n - 1] != '\n')
  97     putchar ('\n');
  98
  99   ACE_OS::puts ("----------------------------------------");
 100
 101   return 0;
 102 }
 103
 104 ACE_INLINE int
 105 Handle_R_Dgram::handle_close (ACE_HANDLE, ACE_Reactor_Mask)
 106 {
 107   return this->ACE_SOCK_Dgram::close ();
 108 }