ACE/examples/Service_Configurator/IPC-tests/server/Handle_L_CODgram.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_CODgram::Handle_L_CODgram ()
   9 {
  10 }
  11
  12 ACE_INLINE int
  13 Handle_L_CODgram::open (const ACE_UNIX_Addr &suad, int async)
  14 {
  15   if (this->ACE_LSOCK_CODgram::open (ACE_Addr::sap_any, suad) == -1)
  16     return -1;
  17   else if (async && this->ACE_LSOCK_CODgram::enable (ACE_SIGIO) == -1)
  18     return -1;
  19   else
  20     return 0;
  21 }
  22
  23 ACE_INLINE int
  24 Handle_L_CODgram::info (ACE_TCHAR **strp, size_t length) const
  25 {
  26   ACE_TCHAR      buf[BUFSIZ];
  27   ACE_UNIX_Addr sa;
  28
  29   if (ACE_LSOCK_CODgram::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 connected 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_CODgram::init (int argc, ACE_TCHAR *argv[])
  44 {
  45   ACE_UNIX_Addr  sucd;
  46   ACE_Get_Opt    get_opt (argc, argv, ACE_TEXT ("r:"), 0);
  47   const ACE_TCHAR *r = Handle_L_CODgram::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   sucd.set (this->rendezvous);
  62   if (this->open (sucd) == -1)
  63     ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("open")), -1);
  64   else if (ACE_Reactor::instance ()->register_handler (this, ACE_Event_Handler::ACCEPT_MASK) == -1)
  65     ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"),
  66                        ACE_TEXT ("registering service with ACE_Reactor")),
  67                       -1);
  68   return 0;
  69 }
  70
  71 ACE_INLINE int
  72 Handle_L_CODgram::fini()
  73 {
  74   return ACE_Reactor::instance ()->remove_handler
  75     (this, ACE_Event_Handler::ACCEPT_MASK);
  76 }
  77
  78 ACE_INLINE ACE_HANDLE
  79 Handle_L_CODgram::get_handle () const
  80 {
  81   return ACE_LSOCK_CODgram::get_handle ();
  82 }
  83
  84 ACE_INLINE int
  85 Handle_L_CODgram::handle_input (ACE_HANDLE)
  86 {
  87   ACE_HANDLE handle = ACE_INVALID_HANDLE;
  88   char buf[BUFSIZ];
  89
  90   if (this->recv_handle (handle) == -1)
  91     return -1;
  92   else
  93     ACE_DEBUG ((LM_INFO, ACE_TEXT ("received handle (%d)\n"), handle));
  94
  95   ACE_OS::puts ("----------------------------------------");
  96
  97   for (;;)
  98     {
  99       ssize_t n = ACE_OS::read (handle, buf, sizeof buf);
 100
 101       if (n <= 0)
 102         break;
 103
 104       ACE_OS::write (ACE_STDOUT, buf, n);
 105     }
 106
 107   ACE_OS::puts ("----------------------------------------");
 108
 109   if (ACE_OS::close (handle) == -1)
 110     return -1;
 111
 112   return 0;
 113 }
 114
 115 ACE_INLINE int
 116 Handle_L_CODgram::handle_close (ACE_HANDLE, ACE_Reactor_Mask)
 117 {
 118   this->ACE_LSOCK_CODgram::close ();
 119   return ACE_OS::unlink (this->rendezvous);
 120 }