diff options
author | William R. Otte <wotte@dre.vanderbilt.edu> | 2006-07-24 15:50:11 +0000 |
---|---|---|
committer | William R. Otte <wotte@dre.vanderbilt.edu> | 2006-07-24 15:50:11 +0000 |
commit | 6b846cf03c0bcbd8c276cb0af61a181e5f98eaae (patch) | |
tree | da50d054f9c761c3f6a5923f6979e93306c56d68 /ace/IOStream_T.inl | |
parent | 0e555b9150d38e3b3473ba325b56db2642e6352b (diff) | |
download | ATCD-6b846cf03c0bcbd8c276cb0af61a181e5f98eaae.tar.gz |
Repo restructuring
Diffstat (limited to 'ace/IOStream_T.inl')
-rw-r--r-- | ace/IOStream_T.inl | 121 |
1 files changed, 0 insertions, 121 deletions
diff --git a/ace/IOStream_T.inl b/ace/IOStream_T.inl deleted file mode 100644 index 73e00fa7bbf..00000000000 --- a/ace/IOStream_T.inl +++ /dev/null @@ -1,121 +0,0 @@ -// -*- C++ -*- -// -// $Id$ - -#include "ace/Handle_Set.h" -#include "ace/OS_NS_errno.h" -#include "ace/OS_NS_sys_select.h" - -ACE_BEGIN_VERSIONED_NAMESPACE_DECL - -template <class STREAM> ACE_INLINE int -ACE_IOStream<STREAM>::eof (void) const -{ - // Get the timeout value of the streambuf - ACE_Time_Value *timeout = this->streambuf_->recv_timeout (0); - - // Reset the timeout value of the streambuf. - (void) this->streambuf_->recv_timeout (timeout); - - char c; - int rval = this->streambuf_->recv_n (&c, - sizeof c, - MSG_PEEK, - timeout); - - // Timeout, not an eof - if (this->streambuf_->timeout()) - return 0; - - // No timeout, got enough data: not eof - if (rval == sizeof(char)) - return 0; - - // No timeout, not enough data: definately eof - return 1; -} - -template <class STREAM> ACE_INLINE -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) - : STREAM (source), - peer_ (dest) -{ -} - -template <class STREAM> ACE_INLINE ssize_t -ACE_SOCK_Dgram_SC<STREAM>::send_n (char *buf, - 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) -{ - 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) -{ - 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 - } - } - - int rval = STREAM::recv (buf, len, peer_, flags); -#if defined (ACE_WIN32) - if (rval == SOCKET_ERROR) - if (::WSAGetLastError () == WSAEMSGSIZE) - if (ACE_BIT_ENABLED (flags, MSG_PEEK)) - rval = len; -#endif /* ACE_WIN32 */ - return rval < len ? rval : len; -} - -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) -{ - int rval = this->recv (buf, len, flags, tv); - return rval; -} - -template <class STREAM> ACE_INLINE int -ACE_SOCK_Dgram_SC<STREAM>::get_remote_addr (ACE_INET_Addr &addr) const -{ - addr = peer_; - return 0; -} - -ACE_END_VERSIONED_NAMESPACE_DECL |