summaryrefslogtreecommitdiff
path: root/src/dist.hpp
diff options
context:
space:
mode:
authorMartin Lucina <martin@lucina.net>2012-01-23 08:53:57 +0100
committerMartin Lucina <martin@lucina.net>2012-01-23 08:53:57 +0100
commitb593ea30833ad5dcacb9076c988aec31b0cf26ec (patch)
tree3d0c6f1dadfa2d947cf23f6109bb27b01ab202af /src/dist.hpp
parentcbaa7cfa93893876e4fd8794b6ea39f4d245b6b5 (diff)
Imported Upstream version 2.1.7upstream/2.1.7
Diffstat (limited to 'src/dist.hpp')
-rw-r--r--src/dist.hpp20
1 files changed, 9 insertions, 11 deletions
diff --git a/src/dist.hpp b/src/dist.hpp
index ad9767a..45aaf90 100644
--- a/src/dist.hpp
+++ b/src/dist.hpp
@@ -56,24 +56,22 @@ namespace zmq
// Put the message to all active pipes.
void distribute (zmq_msg_t *msg_, int flags_);
- // Plug in all the delayed pipes.
- void clear_new_pipes ();
-
// List of outbound pipes.
typedef array_t <class writer_t> pipes_t;
pipes_t pipes;
- // List of new pipes that were not yet inserted into 'pipes' list.
- // These pipes are moves to 'pipes' list once the current multipart
- // message is fully sent. This way we avoid sending incomplete messages
- // to peers.
- typedef std::vector <class writer_t*> new_pipes_t;
- new_pipes_t new_pipes;
-
// Number of active pipes. All the active pipes are located at the
- // beginning of the pipes array.
+ // beginning of the pipes array. These are the pipes the messages
+ // can be sent to at the moment.
pipes_t::size_type active;
+ // Number of pipes eligible for sending messages to. This includes all
+ // the active pipes plus all the pipes that we can in theory send
+ // messages to (the HWM is not yet reached), but sending a message
+ // to them would result in partial message being delivered, ie. message
+ // with initial parts missing.
+ pipes_t::size_type eligible;
+
// True if last we are in the middle of a multipart message.
bool more;