diff options
| -rw-r--r-- | src/xrep.cpp | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/xrep.cpp b/src/xrep.cpp index 5406a0b..7f0da4d 100644 --- a/src/xrep.cpp +++ b/src/xrep.cpp @@ -184,9 +184,11 @@ int zmq::xrep_t::xsend (zmq_msg_t *msg_, int flags_) int rc = zmq_msg_init (&empty); zmq_assert (rc == 0); if (!current_out->check_write (&empty)) { + it->second.active = false; + more_out = false; + current_out = NULL; rc = zmq_msg_close (&empty); zmq_assert (rc == 0); - it->second.active = false; errno = EAGAIN; return -1; } |