dep/ACE_wrappers/ace/DEV_IO.inl

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