diff options
Diffstat (limited to 'ACE/ace/Pipe.inl')
| -rw-r--r-- | ACE/ace/Pipe.inl | 188 |
1 files changed, 188 insertions, 0 deletions
diff --git a/ACE/ace/Pipe.inl b/ACE/ace/Pipe.inl new file mode 100644 index 00000000000..17b532ed632 --- /dev/null +++ b/ACE/ace/Pipe.inl @@ -0,0 +1,188 @@ +// -*- C++ -*- +// +// $Id$ + +#include "ace/Global_Macros.h" +#include "ace/ACE.h" + +ACE_BEGIN_VERSIONED_NAMESPACE_DECL + +ACE_INLINE +ACE_Pipe::~ACE_Pipe (void) +{ + ACE_TRACE ("ACE_Pipe::~ACE_Pipe"); + // Notice that the destructor doesn't close the handles for you. +} + +ACE_INLINE ACE_HANDLE +ACE_Pipe::read_handle (void) const +{ + ACE_TRACE ("ACE_Pipe::read_handle"); + return this->handles_[0]; +} + +ACE_INLINE ACE_HANDLE +ACE_Pipe::write_handle (void) const +{ + ACE_TRACE ("ACE_Pipe::write_handle"); + return this->handles_[1]; +} + +ACE_INLINE ssize_t +ACE_Pipe::sendv_n (const iovec iov[], int n) const +{ + ACE_TRACE ("ACE_Pipe::sendv_n"); +#if defined (ACE_WIN32) + return ACE::sendv_n (this->write_handle (), + iov, + n); +#else + return ACE::writev_n (this->write_handle (), + iov, + n); +#endif /* ACE_WIN32 */ +} + +ACE_INLINE ssize_t +ACE_Pipe::send_n (const ACE_Message_Block *message_block, + const ACE_Time_Value *timeout, + size_t *bytes_transferred) +{ + ACE_TRACE ("ACE_Pipe::send_n"); +#if defined (ACE_WIN32) + return ACE::send_n (this->write_handle (), + message_block, + timeout, + bytes_transferred); +#else + ACE_UNUSED_ARG (timeout); + return ACE::write_n (this->write_handle (), + message_block, + bytes_transferred); +#endif /* ACE_WIN32 */ +} + +// Recv an n byte message from the file. + +ACE_INLINE ssize_t +ACE_Pipe::recvv_n (iovec iov[], int n) const +{ + ACE_TRACE ("ACE_Pipe::recvv_n"); + // @@ Carlos, can you please update this to call the + // new ACE::recvv_n() method that you write? +#if defined (ACE_WIN32) + return ACE_OS::sendv (this->read_handle (), + iov, + n); +#else + return ACE_OS::readv (this->read_handle (), + iov, + n); +#endif /* ACE_WIN32 */ +} + +// Send an <iovec> of size <n> to the file. + +ACE_INLINE ssize_t +ACE_Pipe::sendv (const iovec iov[], int n) const +{ + ACE_TRACE ("ACE_Pipe::sendv"); +#if defined (ACE_WIN32) + return ACE_OS::sendv (this->write_handle (), iov, n); +#else + return ACE_OS::writev (this->write_handle (), iov, n); +#endif /* ACE_WIN32 */ +} + +// Send exactly N bytes from BUF to this file. Keeping trying until +// this many bytes are sent. + +ACE_INLINE ssize_t +ACE_Pipe::send_n (const void *buf, size_t n) const +{ + ACE_TRACE ("ACE_Pipe::send_n"); +#if defined (ACE_WIN32) + return ACE::send_n (this->write_handle (), buf, n); +#else + return ACE::write_n (this->write_handle (), buf, n); +#endif /* ACE_WIN32 */ +} + +// Receive exactly N bytes from this file into BUF. Keep trying until +// this many bytes are received. + +ACE_INLINE ssize_t +ACE_Pipe::recv_n (void *buf, size_t n) const +{ + ACE_TRACE ("ACE_Pipe::recv_n"); +#if defined (ACE_WIN32) + return ACE::recv_n (this->read_handle (), buf, n); +#else + return ACE::read_n (this->read_handle (), buf, n); +#endif /* ACE_WIN32 */ +} + +ACE_INLINE ssize_t +ACE_Pipe::send (const void *buf, size_t n) const +{ + ACE_TRACE ("ACE_Pipe::send"); +#if defined (ACE_WIN32) + return ACE_OS::send (this->write_handle (), static_cast <const char *> (buf), n); +#else + return ACE_OS::write (this->write_handle (), static_cast <const char *> (buf), n); +#endif /* ACE_WIN32 */ +} + +ACE_INLINE ssize_t +ACE_Pipe::recv (void *buf, size_t n) const +{ + ACE_TRACE ("ACE_Pipe::recv"); +#if defined (ACE_WIN32) + return ACE_OS::recv (this->read_handle (), static_cast <char *> (buf), n); +#else + return ACE_OS::read (this->read_handle (), static_cast <char *> (buf), n); +#endif /* ACE_WIN32 */ +} + +ACE_INLINE ssize_t +ACE_Pipe::send (const iovec iov[], int n) const +{ + ACE_TRACE ("ACE_Pipe::send"); +#if defined (ACE_WIN32) + return ACE_OS::sendv (this->write_handle (), iov, n); +#else + return ACE_OS::writev (this->write_handle (), iov, n); +#endif /* ACE_WIN32 */ +} + +ACE_INLINE ssize_t +ACE_Pipe::recv (iovec iov[], int n) const +{ + ACE_TRACE ("ACE_Pipe::recv"); +#if defined (ACE_WIN32) + return ACE_OS::recvv (this->read_handle (), iov, n); +#else + return ACE_OS::readv (this->read_handle (), iov, n); +#endif /* ACE_WIN32 */ +} + +ACE_INLINE ssize_t +ACE_Pipe::send (const void *buf, size_t n, + ACE_OVERLAPPED *overlapped) const +{ + ACE_TRACE ("ACE_Pipe::send"); + return ACE_OS::write (this->write_handle (), + static_cast <const char *> (buf), n, + overlapped); +} + +ACE_INLINE ssize_t +ACE_Pipe::recv (void *buf, size_t n, + ACE_OVERLAPPED *overlapped) const +{ + ACE_TRACE ("ACE_Pipe::recv"); + return ACE_OS::read (this->read_handle (), static_cast <char *> (buf), n, + overlapped); +} + +ACE_END_VERSIONED_NAMESPACE_DECL |