diff options
-rw-r--r-- | src/xrep.cpp | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/xrep.cpp b/src/xrep.cpp index b8ad735..68b9d1b 100644 --- a/src/xrep.cpp +++ b/src/xrep.cpp @@ -95,6 +95,8 @@ void zmq::xrep_t::terminated (reader_t *pipe_) inpipes.erase (it); if (terminating) unregister_term_ack (); + if (current_in >= inpipes.size ()) + current_in = 0; return; } } |