ACE/ace/DEV_IO.inl

   1 // -*- C++ -*-
   2 #include "ace/OS_NS_sys_uio.h"
   3 #include "ace/OS_NS_unistd.h"
   4 #include "ace/OS_Memory.h"
   5
   6 #include "ace/ACE.h"
   7
   8 // Send exactly N bytes from BUF to this device.  Keeping trying until
   9 // this many bytes are sent.
  10
  11 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
  12
  13 ACE_INLINE ssize_t
  14 ACE_DEV_IO::send_n (const void *buf, size_t n) const
  15 {
  16   ACE_TRACE ("ACE_DEV_IO::send_n");
  17   return ACE::write_n (this->get_handle (), buf, n);
  18 }
  19
  20 // Receive exactly N bytes from this file into BUF.  Keep trying until
  21 // this many bytes are received.
  22
  23 ACE_INLINE ssize_t
  24 ACE_DEV_IO::recv_n (void *buf,
  25                     size_t n,
  26                     const ACE_Time_Value *timeout,
  27                     size_t *bytes_transferred) const
  28 {
  29   ACE_TRACE ("ACE_DEV_IO::recv_n");
  30 #if defined (ACE_WIN32)
  31   ACE_UNUSED_ARG (timeout);
  32
  33   return ACE::read_n (this->get_handle (),
  34                       buf,
  35                       n,
  36                       bytes_transferred);
  37 #else
  38   return ACE::recv_n (this->get_handle (),
  39                       buf,
  40                       n,
  41                       timeout,
  42                       bytes_transferred);
  43 #endif /*ACE_WIN32*/
  44 }
  45
  46 ACE_INLINE ssize_t
  47 ACE_DEV_IO::send (const void *buf, size_t n) const
  48 {
  49   ACE_TRACE ("ACE_DEV_IO::send");
  50   return ACE_OS::write (this->get_handle (), (const char *) buf, n);
  51 }
  52
  53 ACE_INLINE ssize_t
  54 ACE_DEV_IO::recv (void *buf, size_t n) const
  55 {
  56   ACE_TRACE ("ACE_DEV_IO::recv");
  57   return ACE_OS::read (this->get_handle (), (char *) buf, n);
  58 }
  59
  60 ACE_INLINE ssize_t
  61 ACE_DEV_IO::send (const iovec iov[], size_t n) const
  62 {
  63   ACE_TRACE ("ACE_DEV_IO::send");
  64   return ACE_OS::writev (this->get_handle (), iov, static_cast<int> (n));
  65 }
  66
  67 ACE_INLINE ssize_t
  68 ACE_DEV_IO::recv (iovec iov[], size_t n) const
  69 {
  70   ACE_TRACE ("ACE_DEV_IO::recv");
  71   return ACE_OS::readv (this->get_handle (), iov, static_cast<int> (n));
  72 }
  73
  74 ACE_INLINE ssize_t
  75 ACE_DEV_IO::send (const void *buf, size_t n,
  76                   ACE_OVERLAPPED *overlapped) const
  77 {
  78   ACE_TRACE ("ACE_DEV_IO::send");
  79   return ACE_OS::write (this->get_handle (),
  80                         (const char *) buf, n,
  81                         overlapped);
  82 }
  83
  84 ACE_INLINE ssize_t
  85 ACE_DEV_IO::recv (void *buf, size_t n,
  86                   ACE_OVERLAPPED *overlapped) const
  87 {
  88   ACE_TRACE ("ACE_DEV_IO::recv");
  89   return ACE_OS::read (this->get_handle (), (char *) buf, n,
  90                        overlapped);
  91 }
  92
  93 #if defined (ACE_HAS_STREAM_PIPES)
  94 ACE_INLINE ssize_t
  95 ACE_DEV_IO::recv (ACE_Str_Buf *cntl, ACE_Str_Buf *data, int *band, int *flags) const
  96 {
  97   ACE_TRACE ("ACE_DEV_IO::recv");
  98   return ACE_OS::getpmsg (this->get_handle (), (strbuf *) cntl, (strbuf *) data, band, flags);
  99 }
 100
 101 ACE_INLINE ssize_t
 102 ACE_DEV_IO::send (const ACE_Str_Buf *cntl, const ACE_Str_Buf *data, int band, int flags) const
 103 {
 104   ACE_TRACE ("ACE_DEV_IO::send");
 105   return ACE_OS::putpmsg (this->get_handle (), (strbuf *) cntl, (strbuf *) data, band, flags);
 106 }
 107
 108 ACE_INLINE ssize_t
 109 ACE_DEV_IO::recv (ACE_Str_Buf *cntl, ACE_Str_Buf *data, int *flags) const
 110 {
 111   ACE_TRACE ("ACE_DEV_IO::recv");
 112   return ACE_OS::getmsg (this->get_handle (), (strbuf *) cntl, (strbuf *) data, flags);
 113 }
 114
 115 ACE_INLINE ssize_t
 116 ACE_DEV_IO::send (const ACE_Str_Buf *cntl, const ACE_Str_Buf *data, int flags) const
 117 {
 118   ACE_TRACE ("ACE_DEV_IO::send");
 119   return ACE_OS::putmsg (this->get_handle (), (strbuf *) cntl, (strbuf *) data, flags);
 120 }
 121 #endif /* ACE_HAS_STREAM_PIPES */
 122
 123 ACE_END_VERSIONED_NAMESPACE_DECL