summaryrefslogtreecommitdiff
path: root/ace/IOStream_T.i
diff options
context:
space:
mode:
authorlevine <levine@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>1997-11-27 02:50:17 +0000
committerlevine <levine@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>1997-11-27 02:50:17 +0000
commit9fa2de6abb6de7681f79686ea0c101a841d8cedb (patch)
treeb2add2297817171d9e2ff8c320455a13f571a281 /ace/IOStream_T.i
parent75cba8e56ccbf4df650e04f19cd56e72e31b0e58 (diff)
downloadATCD-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.i78
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;