summaryrefslogtreecommitdiff
path: root/src/zmq_engine.cpp
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@250bpm.com>2010-12-17 16:30:42 +0100
committerMartin Sustrik <sustrik@250bpm.com>2010-12-17 16:30:42 +0100
commitd15e881ea02232c3e875699b3c25f43ad2fd093c (patch)
tree9b555e2e484f2830a0654f0d6ab443a5e7e93f1d /src/zmq_engine.cpp
parentb19ee99bb1a2b19a6bf78c7fa2159a85aa608a10 (diff)
unplugged engine tries to manipulate the pollset -- fixed
Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
Diffstat (limited to 'src/zmq_engine.cpp')
-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.