diff options
Diffstat (limited to 'src/xrep.cpp')
| -rw-r--r-- | src/xrep.cpp | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/src/xrep.cpp b/src/xrep.cpp index df74302..fae376b 100644 --- a/src/xrep.cpp +++ b/src/xrep.cpp @@ -81,6 +81,11 @@ void zmq::xrep_t::xrevive (class reader_t *pipe_) fq.revive (pipe_); } +void zmq::xrep_t::xrevive (class writer_t *pipe_) +{ + zmq_not_implemented (); +} + int zmq::xrep_t::xsetsockopt (int option_, const void *optval_, size_t optvallen_) { @@ -111,7 +116,8 @@ int zmq::xrep_t::xsend (zmq_msg_t *msg_, int flags_) } // Push message to the selected pipe. - it->second->write (msg_); + bool written = it->second->write (msg_); + zmq_assert (written); it->second->flush (); // Detach the message from the data buffer. |