SOCK_Stream.i Source File

00001 /* -*- C++ -*- */
00002 // $Id: SOCK_Stream.i,v 1.1.1.4 2003/02/21 18:36:32 chad Exp $
00003 
00004 #include "ace/SOCK_Stream.h"
00005 
00006 ASYS_INLINE
00007 ACE_SOCK_Stream::ACE_SOCK_Stream (void)
00008 {
00009   // ACE_TRACE ("ACE_SOCK_Stream::ACE_SOCK_Stream");
00010 }
00011 
00012 ASYS_INLINE
00013 ACE_SOCK_Stream::ACE_SOCK_Stream (ACE_HANDLE h)
00014 {
00015   // ACE_TRACE ("ACE_SOCK_Stream::ACE_SOCK_Stream");
00016   this->set_handle (h);
00017 }
00018 
00019 ASYS_INLINE
00020 ACE_SOCK_Stream::~ACE_SOCK_Stream (void)
00021 {
00022   // ACE_TRACE ("ACE_SOCK_Stream::~ACE_SOCK_Stream");
00023 }
00024 
00025 ASYS_INLINE int
00026 ACE_SOCK_Stream::close_reader (void)
00027 {
00028   ACE_TRACE ("ACE_SOCK_Stream::close_reader");
00029   if (this->get_handle () != ACE_INVALID_HANDLE)
00030     return ACE_OS::shutdown (this->get_handle (), ACE_SHUTDOWN_READ);
00031   else
00032     return 0;
00033 }
00034 
00035 // Shut down just the writing end of a ACE_SOCK.
00036 
00037 ASYS_INLINE int
00038 ACE_SOCK_Stream::close_writer (void)
00039 {
00040   ACE_TRACE ("ACE_SOCK_Stream::close_writer");
00041   if (this->get_handle () != ACE_INVALID_HANDLE)
00042     return ACE_OS::shutdown (this->get_handle (), ACE_SHUTDOWN_WRITE);
00043   else
00044     return 0;
00045 }
00046 
00047 ASYS_INLINE ssize_t
00048 ACE_SOCK_Stream::recv_n (void *buf,
00049                          size_t len,
00050                          int flags,
00051                          const ACE_Time_Value *timeout,
00052                          size_t *bytes_transferred) const
00053 {
00054   ACE_TRACE ("ACE_SOCK_Stream::recv_n");
00055   return ACE::recv_n (this->get_handle (),
00056                       buf,
00057                       len,
00058                       flags,
00059                       timeout,
00060                       bytes_transferred);
00061 }
00062 
00063 ASYS_INLINE ssize_t
00064 ACE_SOCK_Stream::recv_n (void *buf,
00065                          size_t len,
00066                          const ACE_Time_Value *timeout,
00067                          size_t *bytes_transferred) const
00068 {
00069   ACE_TRACE ("ACE_SOCK_Stream::recv_n");
00070   return ACE::recv_n (this->get_handle (),
00071                       buf,
00072                       len,
00073                       timeout,
00074                       bytes_transferred);
00075 }
00076 
00077 ASYS_INLINE ssize_t
00078 ACE_SOCK_Stream::recvv_n (iovec iov[],
00079                           int n,
00080                           const ACE_Time_Value *timeout,
00081                           size_t *bytes_transferred) const
00082 {
00083   ACE_TRACE ("ACE_SOCK_Stream::recvv_n");
00084   return ACE::recvv_n (this->get_handle (),
00085                        iov,
00086                        n,
00087                        timeout,
00088                        bytes_transferred);
00089 }
00090 
00091 ASYS_INLINE ssize_t
00092 ACE_SOCK_Stream::send_n (const void *buf,
00093                          size_t len,
00094                          int flags,
00095                          const ACE_Time_Value *timeout,
00096                          size_t *bytes_transferred) const
00097 {
00098   ACE_TRACE ("ACE_SOCK_Stream::send_n");
00099   return ACE::send_n (this->get_handle (),
00100                       buf,
00101                       len,
00102                       flags,
00103                       timeout,
00104                       bytes_transferred);
00105 }
00106 
00107 ASYS_INLINE ssize_t
00108 ACE_SOCK_Stream::send_n (const void *buf,
00109                          size_t len,
00110                          const ACE_Time_Value *timeout,
00111                          size_t *bytes_transferred) const
00112 {
00113   ACE_TRACE ("ACE_SOCK_Stream::send_n");
00114   return ACE::send_n (this->get_handle (),
00115                       buf,
00116                       len,
00117                       timeout,
00118                       bytes_transferred);
00119 }
00120 
00121 ASYS_INLINE ssize_t
00122 ACE_SOCK_Stream::sendv_n (const iovec iov[],
00123                           int n,
00124                           const ACE_Time_Value *timeout,
00125                           size_t *bytes_transferred) const
00126 {
00127   ACE_TRACE ("ACE_SOCK_Stream::sendv_n");
00128   return ACE::sendv_n (this->get_handle (),
00129                        iov,
00130                        n,
00131                        timeout,
00132                        bytes_transferred);
00133 }
00134 
00135 ASYS_INLINE ssize_t
00136 ACE_SOCK_Stream::send_n (const ACE_Message_Block *message_block,
00137                          const ACE_Time_Value *timeout,
00138                          size_t *bytes_transferred) const
00139 {
00140   ACE_TRACE ("ACE_SOCK_Stream::send_n");
00141   return ACE::send_n (this->get_handle (),
00142                       message_block,
00143                       timeout,
00144                       bytes_transferred);
00145 }
00146 
00147 ASYS_INLINE ssize_t
00148 ACE_SOCK_Stream::send_urg (const void *ptr,
00149                            size_t len,
00150                            const ACE_Time_Value *timeout) const
00151 {
00152   ACE_TRACE ("ACE_SOCK_Stream::send_urg");
00153   return ACE::send (this->get_handle (),
00154                     ptr,
00155                     len,
00156                     MSG_OOB,
00157                     timeout);
00158 }
00159 
00160 ASYS_INLINE ssize_t
00161 ACE_SOCK_Stream::recv_urg (void *ptr,
00162                            size_t len,
00163                            const ACE_Time_Value *timeout) const
00164 {
00165   ACE_TRACE ("ACE_SOCK_Stream::recv_urg");
00166   return ACE::recv (this->get_handle (),
00167                     ptr,
00168                     len,
00169                     MSG_OOB,
00170                     timeout);
00171 }