summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/zmq_engine.cpp3
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.