ACE/ace/FILE_IO.inl

   1 // -*- C++ -*-
   2 #include "ace/ACE.h"
   3 #include "ace/OS_NS_sys_uio.h"
   4 #include "ace/OS_NS_unistd.h"
   5
   6 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
   7
   8 ACE_INLINE ssize_t
   9 ACE_FILE_IO::sendv_n (const iovec iov[], int n) const
  10 {
  11   ACE_TRACE ("ACE_FILE_IO::sendv_n");
  12   return ACE::writev_n (this->get_handle (),
  13                         iov,
  14                         n);
  15 }
  16
  17 ACE_INLINE ssize_t
  18 ACE_FILE_IO::send_n (const ACE_Message_Block *message_block,
  19                      const ACE_Time_Value *timeout,
  20                      size_t *bytes_transferred)
  21 {
  22   ACE_TRACE ("ACE_FILE_IO::send_n");
  23   ACE_UNUSED_ARG (timeout);
  24   return ACE::write_n (this->get_handle (),
  25                       message_block,
  26                       bytes_transferred);
  27 }
  28
  29 // Recv an n byte message from the file.
  30
  31 ACE_INLINE ssize_t
  32 ACE_FILE_IO::recvv_n (iovec iov[], int n) const
  33 {
  34   ACE_TRACE ("ACE_FILE_IO::recvv_n");
  35   // @@ Carlos, can you please update this to call the
  36   // new ACE::recvv_n() method that you write?
  37   return ACE_OS::readv (this->get_handle (),
  38                         iov,
  39                         n);
  40 }
  41
  42 // Send an <iovec> of size <n> to the file.
  43
  44 ACE_INLINE ssize_t
  45 ACE_FILE_IO::sendv (const iovec iov[], int n) const
  46 {
  47   ACE_TRACE ("ACE_FILE_IO::sendv");
  48   return ACE_OS::writev (this->get_handle (), iov, n);
  49 }
  50
  51 // Send exactly N bytes from BUF to this file.  Keeping trying until
  52 // this many bytes are sent.
  53
  54 ACE_INLINE ssize_t
  55 ACE_FILE_IO::send_n (const void *buf, size_t n) const
  56 {
  57   ACE_TRACE ("ACE_FILE_IO::send_n");
  58   return ACE::write_n (this->get_handle (), buf, n);
  59 }
  60
  61 // Receive exactly N bytes from this file into BUF.  Keep trying until
  62 // this many bytes are received.
  63
  64 ACE_INLINE ssize_t
  65 ACE_FILE_IO::recv_n (void *buf, size_t n) const
  66 {
  67   ACE_TRACE ("ACE_FILE_IO::recv_n");
  68   return ACE::read_n (this->get_handle (), buf, n);
  69 }
  70
  71 ACE_INLINE ssize_t
  72 ACE_FILE_IO::send (const void *buf, size_t n) const
  73 {
  74   ACE_TRACE ("ACE_FILE_IO::send");
  75   return ACE_OS::write (this->get_handle (), buf, n);
  76 }
  77
  78 ACE_INLINE ssize_t
  79 ACE_FILE_IO::recv (void *buf, size_t n) const
  80 {
  81   ACE_TRACE ("ACE_FILE_IO::recv");
  82   return ACE_OS::read (this->get_handle (), buf, n);
  83 }
  84
  85 ACE_INLINE ssize_t
  86 ACE_FILE_IO::send (const iovec iov[], int n) const
  87 {
  88   ACE_TRACE ("ACE_FILE_IO::send");
  89   return ACE_OS::writev (this->get_handle (), iov, n);
  90 }
  91
  92 ACE_INLINE ssize_t
  93 ACE_FILE_IO::recv (iovec iov[], int n) const
  94 {
  95   ACE_TRACE ("ACE_FILE_IO::recv");
  96   return ACE_OS::readv (this->get_handle (), iov, n);
  97 }
  98
  99 #if defined (ACE_HAS_STREAM_PIPES)
 100 ACE_INLINE ssize_t
 101 ACE_FILE_IO::recv (ACE_Str_Buf *cntl, ACE_Str_Buf *data, int *band, int *flags) const
 102 {
 103   ACE_TRACE ("ACE_FILE_IO::recv");
 104   return ACE_OS::getpmsg (this->get_handle (), (strbuf *) cntl, (strbuf *) data, band, flags);
 105 }
 106
 107 ACE_INLINE ssize_t
 108 ACE_FILE_IO::send (const ACE_Str_Buf *cntl, const ACE_Str_Buf *data, int band, int flags) const
 109 {
 110   ACE_TRACE ("ACE_FILE_IO::send");
 111   return ACE_OS::putpmsg (this->get_handle (), (strbuf *) cntl, (strbuf *) data, band, flags);
 112 }
 113
 114 ACE_INLINE ssize_t
 115 ACE_FILE_IO::recv (ACE_Str_Buf *cntl, ACE_Str_Buf *data, int *flags) const
 116 {
 117   ACE_TRACE ("ACE_FILE_IO::recv");
 118   return ACE_OS::getmsg (this->get_handle (), (strbuf *) cntl, (strbuf *) data, flags);
 119 }
 120
 121 ACE_INLINE ssize_t
 122 ACE_FILE_IO::send (const ACE_Str_Buf *cntl, const ACE_Str_Buf *data, int flags) const
 123 {
 124   ACE_TRACE ("ACE_FILE_IO::send");
 125   return ACE_OS::putmsg (this->get_handle (), (strbuf *) cntl, (strbuf *) data, flags);
 126 }
 127
 128 ACE_INLINE ssize_t
 129 ACE_FILE_IO::send (const void *buf, size_t n,
 130                    ACE_OVERLAPPED *overlapped) const
 131 {
 132   ACE_TRACE ("ACE_FILE_IO::send");
 133   return ACE_OS::write (this->get_handle (),
 134                         buf, n,
 135                         overlapped);
 136 }
 137
 138 ACE_INLINE ssize_t
 139 ACE_FILE_IO::recv (void *buf, size_t n,
 140                    ACE_OVERLAPPED *overlapped) const
 141 {
 142   ACE_TRACE ("ACE_FILE_IO::recv");
 143   return ACE_OS::read (this->get_handle (), buf, n,
 144                        overlapped);
 145 }
 146
 147 #endif /* ACE_HAS_STREAM_PIPES */
 148
 149 ACE_END_VERSIONED_NAMESPACE_DECL