Initial revision

1 files changed, 110 insertions, 0 deletions

diff --git a/ace/SPIPE_Addr.cpp b/ace/SPIPE_Addr.cpp
new file mode 100644
index 00000000000..09bbc573c7a
--- /dev/null
+++ b/ace/SPIPE_Addr.cpp
@@ -0,0 +1,110 @@
+// SPIPE_Addr.cpp
+// $Id$
+
+#define ACE_BUILD_DLL
+#include "ace/SPIPE_Addr.h"
+
+#if !defined (__ACE_INLINE__)
+#include "ace/SPIPE_Addr.i"
+#endif /* __ACE_INLINE__ */
+
+ACE_ALLOC_HOOK_DEFINE(ACE_SPIPE_Addr)
+
+void
+ACE_SPIPE_Addr::dump (void) const
+{
+}
+
+// Set a pointer to the address.
+void 
+ACE_SPIPE_Addr::set_addr (void *addr, int len)
+{
+  ACE_TRACE ("ACE_SPIPE_Addr::set_addr");
+
+  this->ACE_Addr::base_set (AF_SPIPE, len);
+  ACE_OS::memcpy ((void *) &this->SPIPE_addr_,
+		  (void *) addr, 
+		  len);
+}
+
+// Do nothing constructor. 
+
+ACE_SPIPE_Addr::ACE_SPIPE_Addr (void)
+  : ACE_Addr (AF_SPIPE, sizeof this->SPIPE_addr_)
+{
+  (void) ACE_OS::memset ((void *) &this->SPIPE_addr_, 0, 
+			 sizeof this->SPIPE_addr_);
+}
+
+// Transform the string into the current addressing format.
+
+int
+ACE_SPIPE_Addr::string_to_addr (LPCTSTR addr)
+{
+  return this->set (addr);
+}
+
+/* Copy constructor. */
+
+ACE_SPIPE_Addr::ACE_SPIPE_Addr (const ACE_SPIPE_Addr &sa)
+  : ACE_Addr (AF_SPIPE,
+	      sizeof this->SPIPE_addr_.gid_ + sizeof this->SPIPE_addr_.uid_
+	      + ACE_OS::strlen (this->SPIPE_addr_.rendezvous_) + 1)
+{
+  (void) ACE_OS::memcpy ((void *) &this->SPIPE_addr_, (void *)
+			 &sa.SPIPE_addr_, sa.get_size ()); 
+}
+
+int
+ACE_SPIPE_Addr::set (LPCTSTR addr,
+		     gid_t gid, 
+		     uid_t uid)
+{
+  int len = sizeof (this->SPIPE_addr_.uid_);
+  len += sizeof(this->SPIPE_addr_.gid_);
+
+#if defined (ACE_WIN32)
+  char *colonp = ACE_OS::strchr (addr, ':');
+  char temp[BUFSIZ] ;
+
+  if (colonp == 0) // Assume it's a port number.
+    {
+      ACE_OS::strcpy(temp, "\\\\.\\pipe\\") ;
+      ACE_OS::strcat(temp, addr) ;
+    }
+  else
+    {
+      ACE_OS::strcpy(temp, "\\\\") ;
+      *colonp = '\0';
+      if (ACE_OS::strcmp(addr, "localhost") == 0)
+	ACE_OS::strcat(temp, ".") ; // change localhost to .
+      else
+	ACE_OS::strcat(temp, addr) ;
+      ACE_OS::strcat(temp, "\\pipe\\"    ) ;
+      ACE_OS::strcat(temp, colonp+1) ;
+    }
+
+  this->ACE_Addr::base_set (AF_SPIPE, 
+			    ACE_OS::strlen (temp) + len);
+  ACE_OS::strcpy(this->SPIPE_addr_.rendezvous_, temp) ;
+
+#else
+  this->ACE_Addr::base_set (AF_SPIPE, ACE_OS::strlen (addr) + len);
+  ACE_OS::strncpy (this->SPIPE_addr_.rendezvous_, addr,
+		   sizeof this->SPIPE_addr_.rendezvous_);
+#endif
+
+  this->SPIPE_addr_.gid_ = gid == 0 ? ACE_OS::getgid () : gid;
+  this->SPIPE_addr_.uid_ = uid == 0 ? ACE_OS::getuid () : uid;
+  return 0;
+}
+
+// Create a ACE_Addr from a ACE_SPIPE pathname. 
+
+ACE_SPIPE_Addr::ACE_SPIPE_Addr (LPCTSTR addr,
+				gid_t gid, 
+				uid_t uid)
+{
+  this->set (addr, gid, uid);
+}
+