dep/ACE_wrappers/ace/MEM_Stream.inl

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