ACE/examples/Service_Configurator/IPC-tests/server/Handle_L_Stream.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_time.h"
   6 #include "ace/OS_NS_unistd.h"
   7
   8 ACE_INLINE
   9 Handle_L_Stream::~Handle_L_Stream ()
  10 {
  11 }
  12
  13 ACE_INLINE
  14 Handle_L_Stream::Handle_L_Stream ()
  15 {
  16   if (Handle_L_Stream::login_name == 0) {
  17 #if !defined(ACE_LACKS_CUSERID)
  18     Handle_L_Stream::login_name = ACE_OS::cuserid (Handle_L_Stream::login);
  19 #else
  20     Handle_L_Stream::login[0] = '.';
  21     Handle_L_Stream::login[1] = '\0';
  22     Handle_L_Stream::login_name = Handle_L_Stream::login;
  23 #endif
  24   }
  25 }
  26
  27 ACE_INLINE int
  28 Handle_L_Stream::open (const ACE_UNIX_Addr &suas,
  29                        int async)
  30 {
  31   if (this->ACE_LSOCK_Acceptor::open (suas) == -1)
  32     return -1;
  33   else if (async && this->ACE_LSOCK_Acceptor::enable (ACE_SIGIO) == -1)
  34     return -1;
  35   else
  36     return 0;
  37 }
  38
  39 ACE_INLINE int
  40 Handle_L_Stream::info (ACE_TCHAR **strp, size_t length) const
  41 {
  42   ACE_TCHAR buf[BUFSIZ];
  43   ACE_UNIX_Addr sa;
  44
  45   if (this->get_local_addr (sa) == -1)
  46     return -1;
  47
  48   ACE_OS::strcpy (buf, ACE_TEXT_CHAR_TO_TCHAR (sa.get_path_name ()));
  49   ACE_OS::strcat (buf, ACE_TEXT (" # tests local ACE_Stream\n"));
  50
  51   if (*strp == 0 && (*strp = ACE_OS::strdup (buf)) == 0)
  52     return -1;
  53   else
  54     ACE_OS::strncpy (*strp, buf, length);
  55   return ACE_OS::strlen (buf);
  56 }
  57
  58 ACE_INLINE int
  59 Handle_L_Stream::init (int argc, ACE_TCHAR *argv[])
  60 {
  61   ACE_UNIX_Addr sus;
  62   const ACE_TCHAR *r = Handle_L_Stream::DEFAULT_RENDEZVOUS;
  63   ACE_Get_Opt get_opt (argc, argv, ACE_TEXT ("r:"), 0);
  64
  65   for (int c; (c = get_opt ()) != -1; )
  66     switch (c)
  67       {
  68       case 'r':
  69         r = get_opt.opt_arg ();
  70         break;
  71       default:
  72         break;
  73       }
  74
  75   ACE_OS::strncpy (this->rendezvous, r, MAXPATHLEN);
  76   ACE_OS::unlink (this->rendezvous);
  77   sus.set (this->rendezvous);
  78
  79   if (this->open (sus) == -1)
  80     ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("open")), -1);
  81   else if (ACE_Reactor::instance ()->register_handler (this, ACE_Event_Handler::ACCEPT_MASK) == -1)
  82     ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"),
  83                        ACE_TEXT ("registering service with ACE_Reactor")), -1);
  84   return 0;
  85 }
  86
  87 ACE_INLINE int
  88 Handle_L_Stream::fini ()
  89 {
  90   return ACE_Reactor::instance ()->remove_handler
  91     (this, ACE_Event_Handler::ACCEPT_MASK);
  92 }
  93
  94 ACE_INLINE ACE_HANDLE
  95 Handle_L_Stream::get_handle () const
  96 {
  97   return ACE_LSOCK_Acceptor::get_handle ();
  98 }
  99
 100 ACE_INLINE int
 101 Handle_L_Stream::handle_input (ACE_HANDLE)
 102 {
 103   ACE_LSOCK_Stream new_local_stream;
 104   ACE_UNIX_Addr sa;
 105   ACE_HANDLE handle = ACE_INVALID_HANDLE;
 106   char buf[BUFSIZ];
 107
 108   if (this->accept (new_local_stream, &sa) == -1)
 109     return -1;
 110   else if (new_local_stream.recv_handle (handle) == -1)
 111     return -1;
 112   else
 113     ACE_DEBUG ((LM_INFO,
 114                 ACE_TEXT ("received file descriptor %d on ACE_Stream %s\n"),
 115                 handle, sa.get_path_name ()));
 116
 117   ACE_OS::puts ("----------------------------------------");
 118
 119   for (;;)
 120     {
 121       ssize_t n = ACE_OS::read (handle, buf, sizeof buf);
 122
 123       if (n <= 0)
 124         break;
 125
 126       ACE_OS::write (ACE_STDOUT, buf, n);
 127     }
 128
 129   ACE_OS::puts ("----------------------------------------");
 130
 131   time_t t = ACE_OS::time (0L);
 132   ACE_TCHAR *cs = ACE_OS::ctime (&t);
 133
 134   if (new_local_stream.send (4,
 135                              Handle_L_Stream::login_name,
 136                              ACE_OS::strlen (Handle_L_Stream::login_name),
 137                              ACE_TEXT_ALWAYS_CHAR (cs),
 138                              ACE_OS::strlen (cs)) == -1)
 139     return -1;
 140   else if (ACE_OS::close (handle) == -1)
 141     return -1;
 142   else if (new_local_stream.close () == -1)
 143     return -1;
 144   else
 145     return 0;
 146 }
 147
 148 ACE_INLINE int
 149 Handle_L_Stream::handle_close (ACE_HANDLE, ACE_Reactor_Mask)
 150 {
 151   this->ACE_LSOCK_Acceptor::close ();
 152   return ACE_OS::unlink (this->rendezvous);
 153 }