diff options
| -rw-r--r-- | src/xrep.cpp | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/src/xrep.cpp b/src/xrep.cpp index fae376b..48546d9 100644 --- a/src/xrep.cpp +++ b/src/xrep.cpp @@ -83,7 +83,6 @@ void zmq::xrep_t::xrevive (class reader_t *pipe_) void zmq::xrep_t::xrevive (class writer_t *pipe_) { - zmq_not_implemented (); } int zmq::xrep_t::xsetsockopt (int option_, const void *optval_, @@ -116,8 +115,11 @@ int zmq::xrep_t::xsend (zmq_msg_t *msg_, int flags_) } // Push message to the selected pipe. - bool written = it->second->write (msg_); - zmq_assert (written); + if (!it->second->write (msg_)) { + errno = EAGAIN; + return -1; + } + it->second->flush (); // Detach the message from the data buffer. |