dep/ACE_wrappers/ace/SOCK_SEQPACK_Association.inl

   1 // -*- C++ -*-
   2 //
   3 // $Id: SOCK_SEQPACK_Association.inl 80826 2008-03-04 14:51:23Z wotte $
   4
   5 #include "ace/SOCK_SEQPACK_Association.h"
   6 #include "ace/OS_NS_sys_socket.h"
   7
   8 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
   9
  10 ACE_INLINE
  11 ACE_SOCK_SEQPACK_Association::ACE_SOCK_SEQPACK_Association (void)
  12 {
  13   // ACE_TRACE ("ACE_SOCK_SEQPACK_Association::ACE_SOCK_SEQPACK_Association");
  14 }
  15
  16 ACE_INLINE
  17 ACE_SOCK_SEQPACK_Association::ACE_SOCK_SEQPACK_Association (ACE_HANDLE h)
  18 {
  19   // ACE_TRACE ("ACE_SOCK_SEQPACK_Association::ACE_SOCK_SEQPACK_Association");
  20   this->set_handle (h);
  21 }
  22
  23 ACE_INLINE
  24 ACE_SOCK_SEQPACK_Association::~ACE_SOCK_SEQPACK_Association (void)
  25 {
  26   // ACE_TRACE ("ACE_SOCK_SEQPACK_Association::~ACE_SOCK_SEQPACK_Association");
  27 }
  28
  29 ACE_INLINE int
  30 ACE_SOCK_SEQPACK_Association::close_reader (void)
  31 {
  32   ACE_TRACE ("ACE_SOCK_SEQPACK_Association::close_reader");
  33   if (this->get_handle () != ACE_INVALID_HANDLE)
  34     return ACE_OS::shutdown (this->get_handle (), ACE_SHUTDOWN_READ);
  35   else
  36     return 0;
  37 }
  38
  39 // Shut down just the writing end of a ACE_SOCK.
  40
  41 ACE_INLINE int
  42 ACE_SOCK_SEQPACK_Association::close_writer (void)
  43 {
  44   ACE_TRACE ("ACE_SOCK_SEQPACK_Association::close_writer");
  45   if (this->get_handle () != ACE_INVALID_HANDLE)
  46     return ACE_OS::shutdown (this->get_handle (), ACE_SHUTDOWN_WRITE);
  47   else
  48     return 0;
  49 }
  50
  51 ACE_INLINE ssize_t
  52 ACE_SOCK_SEQPACK_Association::recv_n (void *buf,
  53                          size_t len,
  54                          int flags,
  55                          const ACE_Time_Value *timeout,
  56                          size_t *bytes_transferred) const
  57 {
  58   ACE_TRACE ("ACE_SOCK_SEQPACK_Association::recv_n");
  59   return ACE::recv_n (this->get_handle (),
  60                       buf,
  61                       len,
  62                       flags,
  63                       timeout,
  64                       bytes_transferred);
  65 }
  66
  67 ACE_INLINE ssize_t
  68 ACE_SOCK_SEQPACK_Association::recv_n (void *buf,
  69                          size_t len,
  70                          const ACE_Time_Value *timeout,
  71                          size_t *bytes_transferred) const
  72 {
  73   ACE_TRACE ("ACE_SOCK_SEQPACK_Association::recv_n");
  74   return ACE::recv_n (this->get_handle (),
  75                       buf,
  76                       len,
  77                       timeout,
  78                       bytes_transferred);
  79 }
  80
  81 ACE_INLINE ssize_t
  82 ACE_SOCK_SEQPACK_Association::recvv_n (iovec iov[],
  83                                        int n,
  84                                        const ACE_Time_Value *timeout,
  85                                        size_t *bytes_transferred) const
  86 {
  87   ACE_TRACE ("ACE_SOCK_SEQPACK_Association::recvv_n");
  88   return ACE::recvv_n (this->get_handle (),
  89                        iov,
  90                        n,
  91                        timeout,
  92                        bytes_transferred);
  93 }
  94
  95 ACE_INLINE ssize_t
  96 ACE_SOCK_SEQPACK_Association::send_n (const void *buf,
  97                          size_t len,
  98                          int flags,
  99                          const ACE_Time_Value *timeout,
 100                          size_t *bytes_transferred) const
 101 {
 102   ACE_TRACE ("ACE_SOCK_SEQPACK_Association::send_n");
 103   return ACE::send_n (this->get_handle (),
 104                       buf,
 105                       len,
 106                       flags,
 107                       timeout,
 108                       bytes_transferred);
 109 }
 110
 111 ACE_INLINE ssize_t
 112 ACE_SOCK_SEQPACK_Association::send_n (const void *buf,
 113                          size_t len,
 114                          const ACE_Time_Value *timeout,
 115                          size_t *bytes_transferred) const
 116 {
 117   ACE_TRACE ("ACE_SOCK_SEQPACK_Association::send_n");
 118   return ACE::send_n (this->get_handle (),
 119                       buf,
 120                       len,
 121                       timeout,
 122                       bytes_transferred);
 123 }
 124
 125 ACE_INLINE ssize_t
 126 ACE_SOCK_SEQPACK_Association::sendv_n (const iovec iov[],
 127                                        int n,
 128                                        const ACE_Time_Value *timeout,
 129                                        size_t *bytes_transferred) const
 130 {
 131   ACE_TRACE ("ACE_SOCK_SEQPACK_Association::sendv_n");
 132   return ACE::sendv_n (this->get_handle (),
 133                        iov,
 134                        n,
 135                        timeout,
 136                        bytes_transferred);
 137 }
 138
 139 ACE_INLINE ssize_t
 140 ACE_SOCK_SEQPACK_Association::send_n (const ACE_Message_Block *message_block,
 141                          const ACE_Time_Value *timeout,
 142                          size_t *bytes_transferred) const
 143 {
 144   ACE_TRACE ("ACE_SOCK_SEQPACK_Association::send_n");
 145   return ACE::send_n (this->get_handle (),
 146                       message_block,
 147                       timeout,
 148                       bytes_transferred);
 149 }
 150
 151 ACE_INLINE ssize_t
 152 ACE_SOCK_SEQPACK_Association::send_urg (const void *ptr,
 153                            size_t len,
 154                            const ACE_Time_Value *timeout) const
 155 {
 156   ACE_TRACE ("ACE_SOCK_SEQPACK_Association::send_urg");
 157   return ACE::send (this->get_handle (),
 158                     ptr,
 159                     len,
 160                     MSG_OOB,
 161                     timeout);
 162 }
 163
 164 ACE_INLINE ssize_t
 165 ACE_SOCK_SEQPACK_Association::recv_urg (void *ptr,
 166                            size_t len,
 167                            const ACE_Time_Value *timeout) const
 168 {
 169   ACE_TRACE ("ACE_SOCK_SEQPACK_Association::recv_urg");
 170   return ACE::recv (this->get_handle (),
 171                     ptr,
 172                     len,
 173                     MSG_OOB,
 174                     timeout);
 175 }
 176
 177 ACE_END_VERSIONED_NAMESPACE_DECL