ACE/ace/MEM_Stream.inl

   1 // -*- C++ -*-
   2 #include "ace/MEM_Stream.h"
   3 #include "ace/OS_NS_sys_socket.h"
   4
   5 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
   6
   7 ACE_INLINE
   8 ACE_MEM_Stream::ACE_MEM_Stream ()
   9 {
  10   // ACE_TRACE ("ACE_MEM_Stream::ACE_MEM_Stream");
  11 }
  12
  13 ACE_INLINE
  14 ACE_MEM_Stream::ACE_MEM_Stream (ACE_HANDLE h)
  15 {
  16   // ACE_TRACE ("ACE_MEM_Stream::ACE_MEM_Stream");
  17   this->set_handle (h);
  18 }
  19
  20 ACE_INLINE
  21 ACE_MEM_Stream::~ACE_MEM_Stream ()
  22 {
  23   // ACE_TRACE ("ACE_MEM_Stream::~ACE_MEM_Stream");
  24 }
  25
  26 ACE_INLINE int
  27 ACE_MEM_Stream::close_reader ()
  28 {
  29   ACE_TRACE ("ACE_MEM_Stream::close_reader");
  30   if (this->get_handle () != ACE_INVALID_HANDLE)
  31     return ACE_OS::shutdown (this->get_handle (), ACE_SHUTDOWN_READ);
  32   else
  33     return 0;
  34 }
  35
  36 // Shut down just the writing end of a ACE_SOCK.
  37
  38 ACE_INLINE int
  39 ACE_MEM_Stream::close_writer ()
  40 {
  41   ACE_TRACE ("ACE_MEM_Stream::close_writer");
  42   if (this->get_handle () != ACE_INVALID_HANDLE)
  43     return ACE_OS::shutdown (this->get_handle (), ACE_SHUTDOWN_WRITE);
  44   else
  45     return 0;
  46 }
  47
  48 ACE_INLINE ssize_t
  49 ACE_MEM_Stream::send_n (const void *buf, size_t n)
  50 {
  51   return this->send (buf, n);
  52 }
  53
  54
  55 ACE_INLINE ssize_t
  56 ACE_MEM_Stream::recv_n (void *buf, size_t n)
  57 {
  58   return this->recv (buf, n);
  59 }
  60
  61 ACE_INLINE ssize_t
  62 ACE_MEM_Stream::send_n (const void *buf, size_t n, int flags)
  63 {
  64   return this->send (buf, n, flags);
  65 }
  66
  67 ACE_INLINE ssize_t
  68 ACE_MEM_Stream::recv_n (void *buf, size_t n, int flags)
  69 {
  70   return this->recv (buf, n, flags);
  71 }
  72
  73 ACE_END_VERSIONED_NAMESPACE_DECL