summaryrefslogtreecommitdiff
path: root/src/session.cpp
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@250bpm.com>2010-05-25 15:03:57 +0200
committerMartin Sustrik <sustrik@250bpm.com>2010-05-25 15:03:57 +0200
commit8408ae066dce123fc93e4f53dbadb1f60b7f2e8a (patch)
tree414194ee2bb2cf5eb0937ffb872e27c5e8656e03 /src/session.cpp
parentf34a468a263c7b4013a267297ee7f121e12dfb9d (diff)
LWM is computed rather than explicitly specified by user
Diffstat (limited to 'src/session.cpp')
-rw-r--r--src/session.cpp6
1 files changed, 2 insertions, 4 deletions
diff --git a/src/session.cpp b/src/session.cpp
index 792d763..3cd27fb 100644
--- a/src/session.cpp
+++ b/src/session.cpp
@@ -265,8 +265,7 @@ void zmq::session_t::process_attach (i_engine *engine_,
writer_t *socket_writer = NULL;
if (options.requires_in && !out_pipe) {
- pipe_t *pipe = new (std::nothrow) pipe_t (owner, this,
- options.hwm, options.lwm);
+ pipe_t *pipe = new (std::nothrow) pipe_t (owner, this, options.hwm);
zmq_assert (pipe);
out_pipe = &pipe->writer;
out_pipe->set_endpoint (this);
@@ -274,8 +273,7 @@ void zmq::session_t::process_attach (i_engine *engine_,
}
if (options.requires_out && !in_pipe) {
- pipe_t *pipe = new (std::nothrow) pipe_t (this, owner,
- options.hwm, options.lwm);
+ pipe_t *pipe = new (std::nothrow) pipe_t (this, owner, options.hwm);
zmq_assert (pipe);
in_pipe = &pipe->reader;
in_pipe->set_endpoint (this);