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

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