diff options
author | nanbor <nanbor@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 1999-01-13 03:30:04 +0000 |
---|---|---|
committer | nanbor <nanbor@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 1999-01-13 03:30:04 +0000 |
commit | 930ab588cc17c9bed2cc2af5111c283441d1280e (patch) | |
tree | 4500369f6bcb693ed597ed7455b01a92c71d2073 /ace | |
parent | c3ad594ff4b48e6f5291abefa82ca4defa778032 (diff) | |
download | ATCD-930ab588cc17c9bed2cc2af5111c283441d1280e.tar.gz |
Moved recvv_n/sendv_n around
Diffstat (limited to 'ace')
-rw-r--r-- | ace/SOCK_IO.h | 10 | ||||
-rw-r--r-- | ace/SOCK_IO.i | 20 | ||||
-rw-r--r-- | ace/SOCK_Stream.h | 10 | ||||
-rw-r--r-- | ace/SOCK_Stream.i | 41 |
4 files changed, 40 insertions, 41 deletions
diff --git a/ace/SOCK_IO.h b/ace/SOCK_IO.h index 91049ef6b53..7b504342197 100644 --- a/ace/SOCK_IO.h +++ b/ace/SOCK_IO.h @@ -70,16 +70,6 @@ public: // returns the number of bytes read. The caller is responsible for // deleting the member in the <iov_base> field of <io_vec>. - ssize_t sendv_n (const iovec iov[], - size_t n) const; - // Send an <iovec> of size <n> to the connected socket (uses - // <ACE::sendv_n>). Will block until all bytes are sent or an error - // occurs. - - ssize_t recvv_n (iovec iov[], - size_t n) const; - // Receive an <iovec> of size <n> to the connected socket. - ssize_t send (const void *buf, size_t n, int flags, diff --git a/ace/SOCK_IO.i b/ace/SOCK_IO.i index b26e1219ccb..95cd76282b5 100644 --- a/ace/SOCK_IO.i +++ b/ace/SOCK_IO.i @@ -69,26 +69,6 @@ ACE_SOCK_IO::sendv (const iovec iov[], size_t n) const } ASYS_INLINE ssize_t -ACE_SOCK_IO::sendv_n (const iovec iov[], size_t n) const -{ - ACE_TRACE ("ACE_SOCK_IO::sendv_n"); - return ACE::sendv_n (this->get_handle (), - iov, - n); -} - -// Recv an n byte message from the connected socket. - -ASYS_INLINE ssize_t -ACE_SOCK_IO::recvv_n (iovec iov[], size_t n) const -{ - ACE_TRACE ("ACE_SOCK_IO::recvv_n"); - // @@ Carlos, can you please update this to call the - // new ACE::recvv_n() method that you write? - return ACE_OS::recvv (this->get_handle (), iov, n); -} - -ASYS_INLINE ssize_t ACE_SOCK_IO::send (const void *buf, size_t n, ACE_OVERLAPPED *overlapped) const { diff --git a/ace/SOCK_Stream.h b/ace/SOCK_Stream.h index 0409f34e56b..1e1982a8ebe 100644 --- a/ace/SOCK_Stream.h +++ b/ace/SOCK_Stream.h @@ -80,6 +80,16 @@ public: // <recv_n> return <len> (i.e., the number of bytes requested to be // read). + ssize_t sendv_n (const iovec iov[], + size_t n) const; + // Send an <iovec> of size <n> to the connected socket (uses + // <ACE::sendv_n>). Will block until all bytes are sent or an error + // occurs. + + ssize_t recvv_n (iovec iov[], + size_t n) const; + // Receive an <iovec> of size <n> to the connected socket. + // = Send/receive an ``urgent'' character (see TCP specs...). ssize_t send_urg (void *ptr, int len = sizeof (char)); ssize_t recv_urg (void *ptr, int len = sizeof (char)); diff --git a/ace/SOCK_Stream.i b/ace/SOCK_Stream.i index f5053269e33..bef8d5c9c82 100644 --- a/ace/SOCK_Stream.i +++ b/ace/SOCK_Stream.i @@ -34,7 +34,7 @@ ACE_SOCK_Stream::close_reader (void) return 0; } -// Shut down just the writing end of a ACE_SOCK. +// Shut down just the writing end of a ACE_SOCK. ASYS_INLINE int ACE_SOCK_Stream::close_writer (void) @@ -46,7 +46,7 @@ ACE_SOCK_Stream::close_writer (void) return 0; } -ASYS_INLINE ssize_t +ASYS_INLINE ssize_t ACE_SOCK_Stream::send_n (const void *buf, size_t len, int flags, const ACE_Time_Value *timeout) { @@ -54,8 +54,8 @@ ACE_SOCK_Stream::send_n (const void *buf, size_t len, int flags, return ACE::send_n (this->get_handle (), buf, len, flags, timeout); } -ASYS_INLINE ssize_t -ACE_SOCK_Stream::recv_n (void *buf, size_t len, int flags, +ASYS_INLINE ssize_t +ACE_SOCK_Stream::recv_n (void *buf, size_t len, int flags, const ACE_Time_Value *timeout) { ACE_TRACE ("ACE_SOCK_Stream::recv_n"); @@ -72,8 +72,8 @@ ACE_SOCK_Stream::recv_n (void *buf, int buf_size, int flags) const return ACE::recv_n (this->get_handle (), buf, buf_size, flags); } -// Send exactly N bytes from <buf> to <handle>. Keeping trying -// until this many bytes are sent. +// Send exactly N bytes from <buf> to <handle>. Keeping trying +// until this many bytes are sent. ASYS_INLINE ssize_t ACE_SOCK_Stream::send_n (const void *buf, int buf_size, int flags) const @@ -82,8 +82,8 @@ ACE_SOCK_Stream::send_n (const void *buf, int buf_size, int flags) const return ACE::send_n (this->get_handle (), buf, buf_size, flags); } -// Receive exactly BUF_SIZE bytes from file descriptor -// into BUF. Keep trying until this many bytes are received. +// Receive exactly BUF_SIZE bytes from file descriptor +// into BUF. Keep trying until this many bytes are received. ASYS_INLINE ssize_t ACE_SOCK_Stream::recv_n (void *buf, int buf_size) const @@ -102,17 +102,36 @@ ACE_SOCK_Stream::send_n (const void *buf, int buf_size) const return ACE::send_n (this->get_handle (), buf, buf_size); } -ASYS_INLINE ssize_t +ASYS_INLINE ssize_t +ACE_SOCK_Stream::sendv_n (const iovec iov[], size_t n) const +{ + ACE_TRACE ("ACE_SOCK_Stream::sendv_n"); + return ACE::sendv_n (this->get_handle (), + iov, + n); +} + +// Recv an n byte message from the connected socket. + +ASYS_INLINE ssize_t +ACE_SOCK_Stream::recvv_n (iovec iov[], size_t n) const +{ + ACE_TRACE ("ACE_SOCK_Stream::recvv_n"); + // @@ Carlos, can you please update this to call the + // new ACE::recvv_n() method that you write? + return ACE_OS::recvv (this->get_handle (), iov, n); +} + +ASYS_INLINE ssize_t ACE_SOCK_Stream::send_urg (void *ptr, int len) { ACE_TRACE ("ACE_SOCK_Stream::send_urg"); return ACE_OS::send (this->get_handle (), (char *) ptr, len, MSG_OOB); } -ASYS_INLINE ssize_t +ASYS_INLINE ssize_t ACE_SOCK_Stream::recv_urg (void *ptr, int len) { ACE_TRACE ("ACE_SOCK_Stream::recv_urg"); return ACE_OS::recv (this->get_handle (), (char *) ptr, len, MSG_OOB); } - |