diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/xrep.cpp | 16 |
1 files changed, 15 insertions, 1 deletions
diff --git a/src/xrep.cpp b/src/xrep.cpp index 422b0c0..5406a0b 100644 --- a/src/xrep.cpp +++ b/src/xrep.cpp @@ -177,8 +177,22 @@ int zmq::xrep_t::xsend (zmq_msg_t *msg_, int flags_) blob_t identity ((unsigned char*) zmq_msg_data (msg_), zmq_msg_size (msg_)); outpipes_t::iterator it = outpipes.find (identity); - if (it != outpipes.end ()) + + if (it != outpipes.end ()) { current_out = it->second.writer; + zmq_msg_t empty; + int rc = zmq_msg_init (&empty); + zmq_assert (rc == 0); + if (!current_out->check_write (&empty)) { + rc = zmq_msg_close (&empty); + zmq_assert (rc == 0); + it->second.active = false; + errno = EAGAIN; + return -1; + } + rc = zmq_msg_close (&empty); + zmq_assert (rc == 0); + } } int rc = zmq_msg_close (msg_); |