ZMQ_HWM split into ZMQ_SNDHWM and ZMQ_RCVHWM

These new options allow to control the maximum size of the
inbound and outbound message pipe separately.

Signed-off-by: Martin Sustrik <sustrik@250bpm.com>

1 files changed, 4 insertions, 2 deletions

diff --git a/src/session.cpp b/src/session.cpp
index 176f0ef..5f970cc 100644
--- a/src/session.cpp
+++ b/src/session.cpp
@@ -247,11 +247,13 @@ void zmq::session_t::process_attach (i_engine *engine_,
 
         //  Create the pipes, as required.
         if (options.requires_in) {
-            create_pipe (socket, this, options.hwm, &socket_reader, &out_pipe);
+            create_pipe (socket, this, options.rcvhwm, &socket_reader,
+                &out_pipe);
             out_pipe->set_event_sink (this);
         }
         if (options.requires_out) {
-            create_pipe (this, socket, options.hwm, &in_pipe, &socket_writer);
+            create_pipe (this, socket, options.sndhwm, &in_pipe,
+                &socket_writer);
             in_pipe->set_event_sink (this);
         }