ACE/examples/Service_Configurator/IPC-tests/server/Handle_L_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_L_Dgram::Handle_L_Dgram ()
   9 {
  10 }
  11
  12 ACE_INLINE int
  13 Handle_L_Dgram::open (const ACE_UNIX_Addr &suad, int async)
  14 {
  15   if (this->ACE_LSOCK_Dgram::open (suad) == -1)
  16     return -1;
  17   else if (async && this->ACE_LSOCK_Dgram::enable (ACE_SIGIO) == -1)
  18     return -1;
  19   else
  20     return 0;
  21 }
  22
  23 ACE_INLINE int
  24 Handle_L_Dgram::info (ACE_TCHAR **strp, size_t length) const
  25 {
  26   ACE_TCHAR      buf[BUFSIZ];
  27   ACE_UNIX_Addr sa;
  28
  29   if (this->ACE_LSOCK_Dgram::get_local_addr (sa) == -1)
  30     return -1;
  31
  32   ACE_OS::strcpy (buf, ACE_TEXT_CHAR_TO_TCHAR (sa.get_path_name ()));
  33   ACE_OS::strcat (buf, ACE_TEXT (" # tests local datagram\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_L_Dgram::init (int argc, ACE_TCHAR *argv[])
  44 {
  45   ACE_UNIX_Addr  sudg;
  46   ACE_Get_Opt    get_opt (argc, argv, ACE_TEXT ("r:"), 0);
  47   const ACE_TCHAR *r = Handle_L_Dgram::DEFAULT_RENDEZVOUS;
  48
  49   for (int c; (c = get_opt ()) != -1; )
  50     switch (c)
  51       {
  52       case 'r':
  53         r = get_opt.opt_arg ();
  54         break;
  55       default:
  56         break;
  57       }
  58
  59   ACE_OS::strncpy (this->rendezvous, r, MAXPATHLEN);
  60   ACE_OS::unlink (this->rendezvous);
  61   sudg.set (this->rendezvous);
  62   if (this->open (sudg) == -1)
  63     ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("open")), -1);
  64   else if (ACE_Reactor::instance ()->register_handler (this,
  65                                                        ACE_Event_Handler::ACCEPT_MASK) == -1)
  66     ACE_ERROR_RETURN ((LM_ERROR,
  67                        ACE_TEXT ("%p\n"),
  68                        ACE_TEXT ("registering service with ACE_Reactor")),
  69                       -1);
  70   return 0;
  71 }
  72
  73 ACE_INLINE int
  74 Handle_L_Dgram::fini ()
  75 {
  76   return ACE_Reactor::instance ()->remove_handler (this, ACE_Event_Handler::ACCEPT_MASK);
  77 }
  78
  79 ACE_INLINE int
  80 Handle_L_Dgram::get_handle () const
  81 {
  82   return this->ACE_LSOCK_Dgram::get_handle ();
  83 }
  84
  85 ACE_INLINE int
  86 Handle_L_Dgram::handle_input (int)
  87 {
  88   ACE_UNIX_Addr sa;
  89   char buf[8 * 1024]; /* 8 k buffer */
  90   int n;
  91
  92   if ((n = this->recv (buf, sizeof buf, sa)) == -1)
  93     return -1;
  94   else
  95     ACE_DEBUG ((LM_INFO, ACE_TEXT ("received datagram from %s\n"),
  96                 sa.get_path_name ()));
  97
  98   ACE_OS::puts ("----------------------------------------");
  99   ACE_OS::write (ACE_STDOUT, buf, n);
 100
 101   if (buf[n - 1] != '\n')
 102     putchar ('\n');
 103
 104   ACE_OS::puts ("----------------------------------------");
 105
 106   return 0;
 107 }
 108
 109 ACE_INLINE int
 110 Handle_L_Dgram::handle_close (int, ACE_Reactor_Mask)
 111 {
 112   this->ACE_LSOCK_Dgram::close ();
 113   return ACE_OS::unlink (this->rendezvous);
 114 }