From ef049efe2ec56bb0ff5395ba8cba6e1722922e43 Mon Sep 17 00:00:00 2001 From: Martin Sustrik Date: Tue, 5 Jan 2010 14:45:10 +0100 Subject: perf tests modified to reflect change in subscription format --- src/zmq_engine.cpp | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) (limited to 'src/zmq_engine.cpp') diff --git a/src/zmq_engine.cpp b/src/zmq_engine.cpp index 40cedfb..a79c0bd 100644 --- a/src/zmq_engine.cpp +++ b/src/zmq_engine.cpp @@ -102,9 +102,11 @@ void zmq::zmq_engine_t::in_event () // Stop polling for input if we got stuck. if (processed < insize) { - zmq_assert (false); - // TODO: This may happen is queue limits are implemented. - // reset_pollin (handle); + + // This may happen if queue limits are implemented or when + // init object reads all required information from the socket + // and rejects to read more data. + reset_pollin (handle); } // Flush all messages the decoder may have produced. -- cgit v1.2.3