diff options
author | levine <levine@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 1997-11-27 02:50:17 +0000 |
---|---|---|
committer | levine <levine@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 1997-11-27 02:50:17 +0000 |
commit | 9fa2de6abb6de7681f79686ea0c101a841d8cedb (patch) | |
tree | b2add2297817171d9e2ff8c320455a13f571a281 /ace/IOStream_T.i | |
parent | 75cba8e56ccbf4df650e04f19cd56e72e31b0e58 (diff) | |
download | ATCD-9fa2de6abb6de7681f79686ea0c101a841d8cedb.tar.gz |
(recv) affects WIN32 only: fixed typo, ACE_BIT_ENABLED instead of ACE_BIT_ENTABLED
Diffstat (limited to 'ace/IOStream_T.i')
-rw-r--r-- | ace/IOStream_T.i | 78 |
1 files changed, 39 insertions, 39 deletions
diff --git a/ace/IOStream_T.i b/ace/IOStream_T.i index a1073534c44..ba0d2e5ea70 100644 --- a/ace/IOStream_T.i +++ b/ace/IOStream_T.i @@ -8,33 +8,33 @@ ACE_Streambuf_T<STREAM>::send (char *buf, ssize_t len) template <class STREAM> ssize_t ACE_Streambuf_T<STREAM>::recv (char *buf, - ssize_t len, - ACE_Time_Value *tv) + ssize_t len, + ACE_Time_Value *tv) { return this->recv (buf, len, 0, tv); } template <class STREAM> ssize_t ACE_Streambuf_T<STREAM>::recv (char *buf, - ssize_t len, - int flags, - ACE_Time_Value * tv) + ssize_t len, + int flags, + ACE_Time_Value * tv) { ssize_t rval = peer_->recv (buf, len, flags, tv); return rval; } template <class STREAM> ssize_t -ACE_Streambuf_T<STREAM>::recv_n (char *buf, - ssize_t len, - int flags, - ACE_Time_Value *tv) +ACE_Streambuf_T<STREAM>::recv_n (char *buf, + ssize_t len, + int flags, + ACE_Time_Value *tv) { ssize_t rval = peer_->recv_n (buf, len, flags, tv); return rval; } -template <class STREAM> ACE_HANDLE +template <class STREAM> ACE_HANDLE ACE_Streambuf_T<STREAM>::get_handle (void) { return peer_ ? peer_->get_handle () : 0; @@ -47,7 +47,7 @@ ACE_SOCK_Dgram_SC<STREAM>::ACE_SOCK_Dgram_SC (void) template <class STREAM> ACE_INLINE ACE_SOCK_Dgram_SC<STREAM>::ACE_SOCK_Dgram_SC (STREAM &source, - ACE_INET_Addr &dest) + ACE_INET_Addr &dest) : STREAM (source), peer_ (dest) { @@ -55,62 +55,62 @@ ACE_SOCK_Dgram_SC<STREAM>::ACE_SOCK_Dgram_SC (STREAM &source, template <class STREAM> ACE_INLINE ssize_t ACE_SOCK_Dgram_SC<STREAM>::send_n (char *buf, - ssize_t len) + ssize_t len) { return STREAM::send (buf, len, peer_); } template <class STREAM> ACE_INLINE ssize_t ACE_SOCK_Dgram_SC<STREAM>::recv (char *buf, - ssize_t len, - ACE_Time_Value *tv) + ssize_t len, + ACE_Time_Value *tv) { return recv (buf, len, 0, tv); } -template <class STREAM> ACE_INLINE ssize_t -ACE_SOCK_Dgram_SC<STREAM>::recv (char *buf, - ssize_t len, - int flags, - ACE_Time_Value *tv) +template <class STREAM> ACE_INLINE ssize_t +ACE_SOCK_Dgram_SC<STREAM>::recv (char *buf, + ssize_t len, + int flags, + ACE_Time_Value *tv) { if (tv != 0) { ACE_HANDLE handle = this->get_handle (); ACE_Handle_Set handle_set; - + handle_set.set_bit (handle); - + switch (ACE_OS::select (int (handle) + 1, - (fd_set *) handle_set, // read_fds. - (fd_set *) 0, // write_fds. - (fd_set *) 0, // exception_fds. - tv)) - { - case 0: - errno = ETIME; - case -1: - return -1; - default: - ; // Do the 'recv' below - } + (fd_set *) handle_set, // read_fds. + (fd_set *) 0, // write_fds. + (fd_set *) 0, // exception_fds. + tv)) + { + case 0: + errno = ETIME; + case -1: + return -1; + default: + ; // Do the 'recv' below + } } int rval = STREAM::recv (buf, len, peer_, flags); #if defined (ACE_WIN32) if (rval == SOCKET_ERROR) if (::WSAGetLastError () == WSAEMSGSIZE) - if (ACE_BIT_ENTABLED (flags, MSG_PEEK)) - rval = len; + if (ACE_BIT_ENABLED (flags, MSG_PEEK)) + rval = len; #endif /* ACE_WIN32 */ return rval < len ? rval : len; } -template <class STREAM> ACE_INLINE ssize_t +template <class STREAM> ACE_INLINE ssize_t ACE_SOCK_Dgram_SC<STREAM>::recv_n (char *buf, - ssize_t len, - int flags, - ACE_Time_Value *tv) + ssize_t len, + int flags, + ACE_Time_Value *tv) { int rval = this->recv (buf, len, flags, tv); return rval; |