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

   1 // -*- C++ -*-
   2
   3 #include "ace/SPIPE_Stream.h"
   4
   5 #if defined (ACE_HAS_STREAM_PIPES)
   6
   7 #include "ace/Reactor.h"
   8 #include "ace/Get_Opt.h"
   9 #include "ace/OS_NS_stdio.h"
  10 #include "ace/OS_NS_unistd.h"
  11 #include "ace/OS_NS_string.h"
  12
  13
  14 ACE_INLINE
  15 Handle_L_SPIPE::Handle_L_SPIPE ()
  16 {
  17 }
  18
  19 ACE_INLINE int
  20 Handle_L_SPIPE::open (const ACE_SPIPE_Addr &rendezvous_spipe)
  21 {
  22   if (this->ACE_SPIPE_Acceptor::open (rendezvous_spipe) == -1)
  23     return -1;
  24   else
  25     return 0;
  26 }
  27
  28 ACE_INLINE int
  29 Handle_L_SPIPE::info (ACE_TCHAR **strp, size_t length) const
  30 {
  31   ACE_TCHAR      buf[BUFSIZ];
  32   ACE_SPIPE_Addr sa;
  33
  34   if (ACE_SPIPE_Acceptor::get_local_addr (sa) == -1)
  35     return -1;
  36
  37   ACE_OS::strcpy (buf, sa.get_path_name ());
  38   ACE_OS::strcat (buf, ACE_TEXT (" # tests local STREAM pipe\n"));
  39
  40   if (*strp == 0 && (*strp = ACE_OS::strdup (buf)) == 0)
  41     return -1;
  42   else
  43     ACE_OS::strncpy (*strp, buf, length);
  44   return ACE_OS::strlen (buf);
  45 }
  46
  47 ACE_INLINE int
  48 Handle_L_SPIPE::init (int argc, ACE_TCHAR *argv[])
  49 {
  50   ACE_SPIPE_Addr susp;
  51   const ACE_TCHAR *rendezvous = Handle_L_SPIPE::DEFAULT_RENDEZVOUS;
  52   ACE_Get_Opt    get_opt (argc, argv, ACE_TEXT ("r:"), 0);
  53
  54   for (int c; (c = get_opt ()) != -1; )
  55      switch (c)
  56        {
  57        case 'r':
  58          rendezvous = get_opt.opt_arg ();
  59          break;
  60        default:
  61          break;
  62        }
  63
  64   ACE_OS::unlink (rendezvous);
  65   susp.set (rendezvous);
  66   if (this->open (susp) == -1)
  67     ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("open")), -1);
  68   else if (ACE_Reactor::instance ()->register_handler
  69            (this, ACE_Event_Handler::ACCEPT_MASK) == -1)
  70     ACE_ERROR_RETURN ((LM_ERROR,
  71                        ACE_TEXT ("%p\n"),
  72                        ACE_TEXT ("registering service with ACE_Reactor")),
  73                       -1);
  74   return 0;
  75 }
  76
  77 ACE_INLINE int
  78 Handle_L_SPIPE::fini ()
  79 {
  80   return ACE_Reactor::instance ()->remove_handler
  81     (this, ACE_Event_Handler::ACCEPT_MASK);
  82 }
  83
  84 ACE_INLINE int
  85 Handle_L_SPIPE::get_handle () const
  86 {
  87   return ACE_SPIPE::get_handle();
  88 }
  89
  90 ACE_INLINE int
  91 Handle_L_SPIPE::handle_input (int)
  92 {
  93   ACE_SPIPE_Stream new_spipe;
  94   char     buf[PIPE_BUF];
  95   ACE_Str_Buf  msg (buf, 0, sizeof buf);
  96   int      flags = 0;
  97
  98   /* Accept communication requests */
  99   if (this->ACE_SPIPE_Acceptor::accept (new_spipe) == -1)
 100     return -1;
 101   else
 102     {
 103       ACE_SPIPE_Addr sa;
 104
 105       new_spipe.get_remote_addr (sa);
 106
 107       ACE_DEBUG ((LM_INFO,
 108                   ACE_TEXT ("accepted request from %s (gid = %d, uid = %d)\n"),
 109                   sa.get_path_name (), sa.group_id (), sa.user_id ()));
 110     }
 111
 112   while (new_spipe.recv ((ACE_Str_Buf *) 0, &msg, &flags) >= 0)
 113     if (msg.len != 0)
 114       ACE_OS::write (ACE_STDOUT, (const char *) msg.buf, (int) msg.len);
 115     else
 116       break;
 117
 118   if (new_spipe.close () == -1)
 119     return -1;
 120   return 0;
 121 }
 122
 123 ACE_INLINE int
 124 Handle_L_SPIPE::handle_close (int, ACE_Reactor_Mask)
 125 {
 126   return this->ACE_SPIPE_Acceptor::remove ();
 127 }
 128 #endif /* ACE_HAS_STREAM_PIPES */