dep/ACE_wrappers/ace/LSOCK_Stream.cpp

   1 // $Id: LSOCK_Stream.cpp 80826 2008-03-04 14:51:23Z wotte $
   2
   3 #include "ace/LSOCK_Stream.h"
   4 #if !defined (ACE_LACKS_UNIX_DOMAIN_SOCKETS)
   5
   6 #include "ace/Log_Msg.h"
   7 #include "ace/OS_NS_sys_socket.h"
   8
   9 ACE_RCSID(ace, LSOCK_Stream, "$Id: LSOCK_Stream.cpp 80826 2008-03-04 14:51:23Z wotte $")
  10
  11 #if !defined (__ACE_INLINE__)
  12 #include "ace/LSOCK_Stream.inl"
  13 #endif /* __ACE_INLINE__ */
  14
  15 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
  16
  17 ACE_ALLOC_HOOK_DEFINE(ACE_LSOCK_Stream)
  18
  19 int
  20 ACE_LSOCK_Stream::get_local_addr (ACE_Addr &addr) const
  21 {
  22   ACE_TRACE ("ACE_LSOCK_Stream::get_local_addr");
  23
  24   // Perform the downcast since <addr> had better be an
  25   // <ACE_UNIX_Addr>.
  26   ACE_UNIX_Addr *rhs_unix_addr = dynamic_cast<ACE_UNIX_Addr *> (&addr);
  27   ACE_UNIX_Addr lhs_unix_addr;
  28
  29   if (rhs_unix_addr == 0)
  30     return -1;
  31   else if (ACE_SOCK::get_local_addr (lhs_unix_addr) == -1)
  32     return -1;
  33   else
  34     {
  35       *rhs_unix_addr = lhs_unix_addr;
  36       return 0;
  37     }
  38 }
  39
  40 int
  41 ACE_LSOCK_Stream::get_remote_addr (ACE_Addr &addr) const
  42 {
  43   ACE_TRACE ("ACE_LSOCK_Stream::get_remote_addr");
  44
  45   return this->get_local_addr (addr);
  46 }
  47
  48 void
  49 ACE_LSOCK_Stream::dump (void) const
  50 {
  51   ACE_TRACE ("ACE_LSOCK_Stream::dump");
  52
  53   ACE_DEBUG ((LM_DEBUG, ACE_BEGIN_DUMP, this));
  54   ACE_SOCK_Stream::dump ();
  55   ACE_LSOCK::dump ();
  56   ACE_DEBUG ((LM_DEBUG, ACE_END_DUMP));
  57 }
  58
  59 #if defined (ACE_HAS_MSG)
  60
  61 // Send a readv-style vector of buffers, along with an open I/O
  62 // handle.
  63
  64 ssize_t
  65 ACE_LSOCK_Stream::send_msg (const iovec iov[],
  66                             size_t n,
  67                             ACE_HANDLE handle)
  68 {
  69   ACE_TRACE ("ACE_LSOCK_Stream::send_msg");
  70   msghdr send_msg;
  71 #if defined (ACE_HAS_4_4BSD_SENDMSG_RECVMSG)
  72   char cmsgbuf[ACE_BSD_CONTROL_MSG_LEN];
  73   cmsghdr *cmsgptr = (cmsghdr *) cmsgbuf;
  74 #endif /* ACE_HAS_4_4BSD_SENDMSG_RECVMSG */
  75
  76   send_msg.msg_iov = const_cast <iovec *> (iov);
  77   send_msg.msg_iovlen = n;
  78   send_msg.msg_name = 0;
  79   send_msg.msg_namelen = 0;
  80
  81 #if defined (ACE_HAS_4_4BSD_SENDMSG_RECVMSG)
  82   cmsgptr->cmsg_level = SOL_SOCKET;
  83   cmsgptr->cmsg_type = SCM_RIGHTS;
  84   cmsgptr->cmsg_len = sizeof cmsgbuf;
  85   send_msg.msg_control = cmsgbuf;
  86   send_msg.msg_controllen = sizeof cmsgbuf;
  87   *(ACE_HANDLE *) CMSG_DATA (cmsgptr) = handle;
  88   send_msg.msg_flags = 0 ;
  89 #else
  90   send_msg.msg_accrights    = (char *) &handle;
  91   send_msg.msg_accrightslen = sizeof handle;
  92 #endif /* ACE_HAS_4_4BSD_SENDMSG_RECVMSG */
  93
  94   return ACE_OS::sendmsg (this->ACE_SOCK_Stream::get_handle (),
  95                           &send_msg, 0);
  96 }
  97
  98 // Read a readv-style vector of buffers, along with an open I/O
  99 // handle.
 100
 101 ssize_t
 102 ACE_LSOCK_Stream::recv_msg (iovec iov[],
 103                             size_t n,
 104                             ACE_HANDLE &handle)
 105 {
 106   ACE_TRACE ("ACE_LSOCK_Stream::recv_msg");
 107   msghdr recv_msg;
 108 #if defined (ACE_HAS_4_4BSD_SENDMSG_RECVMSG)
 109   char cmsgbuf[ACE_BSD_CONTROL_MSG_LEN];
 110   cmsghdr *cmsgptr = (cmsghdr *) cmsgbuf;
 111 #endif /* ACE_HAS_4_4BSD_SENDMSG_RECVMSG */
 112
 113   recv_msg.msg_iov = (iovec *) iov;
 114   recv_msg.msg_iovlen = n;
 115   recv_msg.msg_name = 0;
 116   recv_msg.msg_namelen = 0;
 117
 118 #if defined (ACE_HAS_4_4BSD_SENDMSG_RECVMSG)
 119   recv_msg.msg_control = cmsgbuf;
 120   recv_msg.msg_controllen = sizeof cmsgbuf;
 121   ssize_t result = ACE_OS::recvmsg (this->ACE_SOCK_Stream::get_handle (),
 122                                     &recv_msg, 0);
 123   handle = *(ACE_HANDLE*) CMSG_DATA (cmsgptr) ;
 124   return result;
 125 #else
 126   recv_msg.msg_accrights = (char *) &handle;
 127   recv_msg.msg_accrightslen = sizeof handle;
 128
 129   return ACE_OS::recvmsg (this->ACE_SOCK_Stream::get_handle (),
 130                           &recv_msg, 0);
 131 #endif /* ACE_HAS_4_4BSD_SENDMSG_RECVMSG */
 132 }
 133 #endif /* ACE_HAS_MSG */
 134
 135 ACE_END_VERSIONED_NAMESPACE_DECL
 136
 137 #endif /* ACE_LACKS_UNIX_DOMAIN_SOCKETS */