diff options
Diffstat (limited to 'src/zmq_engine.cpp')
-rw-r--r-- | src/zmq_engine.cpp | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/src/zmq_engine.cpp b/src/zmq_engine.cpp index cfc87a7..b568993 100644 --- a/src/zmq_engine.cpp +++ b/src/zmq_engine.cpp @@ -101,8 +101,11 @@ void zmq::zmq_engine_t::in_event () insize -= processed; // Stop polling for input if we got stuck. - if (processed < insize) - reset_pollin (handle); + if (processed < insize) { + zmq_assert (false); + // TODO: This may happen is queue limits are implemented. + // reset_pollin (handle); + } // Flush all messages the decoder may have produced. inout->flush (); |