Corrects ypipe initialization when conflate is NOT enabled.

Fixes LIBZMQ-584
This commit is contained in:
Eric Cornelius 2014-01-15 18:08:45 -05:00
parent 526847b73b
commit 589fa57afa

View File

@ -481,10 +481,10 @@ void zmq::pipe_t::hiccup ()
// Create new inpipe. // Create new inpipe.
if (conflate) if (conflate)
inpipe = new (std::nothrow) inpipe = new (std::nothrow)
ypipe_t <msg_t, message_pipe_granularity> (); ypipe_conflate_t <msg_t, message_pipe_granularity> ();
else else
inpipe = new (std::nothrow) inpipe = new (std::nothrow)
ypipe_conflate_t <msg_t> (); ypipe_t <msg_t> ();
alloc_assert (inpipe); alloc_assert (inpipe);
in_active = true; in_active = true;