diff options
Diffstat (limited to 'src/zmq_engine.cpp')
| -rw-r--r-- | src/zmq_engine.cpp | 8 |
1 files changed, 5 insertions, 3 deletions
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. |