summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authornanbor <nanbor@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>1999-01-13 03:30:04 +0000
committernanbor <nanbor@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>1999-01-13 03:30:04 +0000
commit930ab588cc17c9bed2cc2af5111c283441d1280e (patch)
tree4500369f6bcb693ed597ed7455b01a92c71d2073
parentc3ad594ff4b48e6f5291abefa82ca4defa778032 (diff)
downloadATCD-930ab588cc17c9bed2cc2af5111c283441d1280e.tar.gz
Moved recvv_n/sendv_n around
-rw-r--r--ace/SOCK_IO.h10
-rw-r--r--ace/SOCK_IO.i20
-rw-r--r--ace/SOCK_Stream.h10
-rw-r--r--ace/SOCK_Stream.i41
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);
}
-