From d36d9a378a9f3c561f2ae7849cee907c59d33b72 Mon Sep 17 00:00:00 2001 From: Martin Sustrik Date: Sun, 27 Mar 2011 19:41:32 +0200 Subject: Comments improvement related to fairness while reading/writing large messages Signed-off-by: Martin Sustrik --- src/zmq_engine.cpp | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) (limited to 'src') diff --git a/src/zmq_engine.cpp b/src/zmq_engine.cpp index da9d18c..725ba96 100644 --- a/src/zmq_engine.cpp +++ b/src/zmq_engine.cpp @@ -110,6 +110,9 @@ void zmq::zmq_engine_t::in_event () if (!insize) { // Retrieve the buffer and read as much data as possible. + // Note that buffer can be arbitrarily large. However, we assume + // the underlying TCP layer has fixed buffer size and thus the + // number of bytes read will be always limited. decoder.get_buffer (&inpos, &insize); insize = tcp_socket.read (inpos, insize); @@ -179,7 +182,10 @@ void zmq::zmq_engine_t::out_event () } // If there are any data to write in write buffer, write as much as - // possible to the socket. + // possible to the socket. Note that amount of data to write can be + // arbitratily large. However, we assume that underlying TCP layer has + // limited transmission buffer and thus the actual number of bytes + // written should be reasonably modest. int nbytes = tcp_socket.write (outpos, outsize); // Handle problems with the connection. -- cgit v1.2.3