diff options
| -rw-r--r-- | src/zmq_engine.cpp | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/zmq_engine.cpp b/src/zmq_engine.cpp index c9a1d9f..dde9c4b 100644 --- a/src/zmq_engine.cpp +++ b/src/zmq_engine.cpp @@ -133,7 +133,8 @@ void zmq::zmq_engine_t::in_event () // This may happen if queue limits are in effect or when // init object reads all required information from the socket // and rejects to read more data. - reset_pollin (handle); + if (plugged) + reset_pollin (handle); } // Adjust the buffer. |