ACE/ace/SPIPE_Addr.cpp

   1 #include "ace/SPIPE_Addr.h"
   2 #include "ace/OS_NS_string.h"
   3 #include "ace/OS_NS_unistd.h"
   4 #include "ace/os_include/sys/os_socket.h"
   5
   6 #if !defined (__ACE_INLINE__)
   7 #include "ace/SPIPE_Addr.inl"
   8 #endif /* __ACE_INLINE__ */
   9
  10 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
  11
  12 ACE_ALLOC_HOOK_DEFINE(ACE_SPIPE_Addr)
  13
  14 void
  15 ACE_SPIPE_Addr::dump () const
  16 {
  17 }
  18
  19 // Set a pointer to the address.
  20 void
  21 ACE_SPIPE_Addr::set_addr (const void *addr, int len)
  22 {
  23   ACE_TRACE ("ACE_SPIPE_Addr::set_addr");
  24
  25   this->ACE_Addr::base_set (AF_SPIPE, len);
  26   ACE_OS::memcpy (&this->SPIPE_addr_, addr, len);
  27 }
  28
  29 // Return the address.
  30 void *
  31 ACE_SPIPE_Addr::get_addr () const
  32 {
  33   return (void *) &this->SPIPE_addr_;
  34 }
  35
  36 // Do nothing constructor.
  37 ACE_SPIPE_Addr::ACE_SPIPE_Addr ()
  38   : ACE_Addr (AF_SPIPE, sizeof this->SPIPE_addr_)
  39 {
  40   (void) ACE_OS::memset ((void *) &this->SPIPE_addr_,
  41                          0,
  42                          sizeof this->SPIPE_addr_);
  43 }
  44
  45 int
  46 ACE_SPIPE_Addr::addr_to_string (ACE_TCHAR *s, size_t len) const
  47 {
  48   ACE_OS::strsncpy (s,
  49                     this->SPIPE_addr_.rendezvous_,
  50                     len);
  51   return 0;
  52 }
  53
  54 // Transform the string into the current addressing format.
  55 int
  56 ACE_SPIPE_Addr::string_to_addr (const ACE_TCHAR *addr)
  57 {
  58   return this->set (addr);
  59 }
  60
  61 int
  62 ACE_SPIPE_Addr::set (const ACE_SPIPE_Addr &sa)
  63 {
  64   this->base_set (sa.get_type (), sa.get_size ());
  65
  66   if (sa.get_type () == AF_ANY)
  67     (void) ACE_OS::memset ((void *) &this->SPIPE_addr_,
  68                            0,
  69                            sizeof this->SPIPE_addr_);
  70   else
  71     (void) ACE_OS::memcpy ((void *) &this->SPIPE_addr_, (void *)
  72                            &sa.SPIPE_addr_,
  73                            sa.get_size ());
  74   return 0;
  75 }
  76
  77 // Copy constructor.
  78 ACE_SPIPE_Addr::ACE_SPIPE_Addr (const ACE_SPIPE_Addr &sa)
  79   : ACE_Addr (AF_SPIPE, sizeof this->SPIPE_addr_)
  80 {
  81   this->set (sa);
  82 }
  83
  84 int
  85 ACE_SPIPE_Addr::set (const ACE_TCHAR *addr,
  86                      gid_t gid,
  87                      uid_t uid)
  88 {
  89   int len = sizeof (this->SPIPE_addr_.uid_);
  90   len += sizeof (this->SPIPE_addr_.gid_);
  91
  92 #if defined (ACE_WIN32)
  93   const ACE_TCHAR *colonp = ACE_OS::strchr (addr, ':');
  94   ACE_TCHAR temp[BUFSIZ];
  95
  96   if (colonp == 0) // Assume it's a local name.
  97     {
  98       ACE_OS::strcpy (temp, ACE_TEXT ( "\\\\.\\pipe\\"));
  99       ACE_OS::strcat (temp, addr);
 100     }
 101   else
 102     {
 103       if (ACE_OS::strncmp (addr,
 104                            ACE_TEXT ("localhost"),
 105                            ACE_OS::strlen ("localhost")) == 0)
 106         // change "localhost" to "."
 107         ACE_OS::strcpy (temp, ACE_TEXT ("\\\\."));
 108       else
 109         {
 110           ACE_OS::strcpy (temp, ACE_TEXT ("\\\\"));
 111
 112           ACE_TCHAR *t;
 113
 114           // We need to allocate a duplicate so that we can write a
 115           // NUL character into it.
 116           ACE_ALLOCATOR_RETURN (t, ACE_OS::strdup (addr), -1);
 117
 118           t[colonp - addr] = ACE_TEXT ('\0');
 119           ACE_OS::strcat (temp, t);
 120
 121           ACE_OS::free (t);
 122         }
 123
 124       ACE_OS::strcat (temp, ACE_TEXT ("\\pipe\\"));
 125       ACE_OS::strcat (temp, colonp + 1);
 126     }
 127   len += static_cast<int> (ACE_OS::strlen (temp));
 128   this->ACE_Addr::base_set (AF_SPIPE, len);
 129
 130   ACE_OS::strcpy (this->SPIPE_addr_.rendezvous_, temp);
 131 #else
 132   this->ACE_Addr::base_set (AF_SPIPE,
 133                             ACE_OS::strlen (addr) + 1 + len);
 134   ACE_OS::strsncpy (this->SPIPE_addr_.rendezvous_,
 135                     addr,
 136                     sizeof this->SPIPE_addr_.rendezvous_);
 137 #endif /* ACE_WIN32 */
 138   this->SPIPE_addr_.gid_ = gid == 0 ? ACE_OS::getgid () : gid;
 139   this->SPIPE_addr_.uid_ = uid == 0 ? ACE_OS::getuid () : uid;
 140   return 0;
 141 }
 142
 143 // Create a ACE_Addr from a ACE_SPIPE pathname.
 144 ACE_SPIPE_Addr::ACE_SPIPE_Addr (const ACE_TCHAR *addr,
 145                                 gid_t gid,
 146                                 uid_t uid)
 147   : ACE_Addr (AF_SPIPE, sizeof this->SPIPE_addr_)
 148 {
 149   this->set (addr, gid, uid);
 150 }
 151
 152 ACE_END_VERSIONED_NAMESPACE_DECL