diff options
author | Martin Sustrik <sustrik@250bpm.com> | 2011-03-24 16:47:33 +0100 |
---|---|---|
committer | Martin Sustrik <sustrik@250bpm.com> | 2011-03-24 16:47:33 +0100 |
commit | bc4a1ce3345f4e5904e4b13c618f90def21256a5 (patch) | |
tree | 0e95c952f0a5464f5edb515e7d16644e76515a85 /src/session.cpp | |
parent | 507718ee1a56e376c06389c513de3868297fec35 (diff) |
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>
Diffstat (limited to 'src/session.cpp')
-rw-r--r-- | src/session.cpp | 6 |
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); } |