diff options
Diffstat (limited to 'src/p2p.cpp')
| -rw-r--r-- | src/p2p.cpp | 10 |
1 files changed, 1 insertions, 9 deletions
diff --git a/src/p2p.cpp b/src/p2p.cpp index f81c6c4..3f63d81 100644 --- a/src/p2p.cpp +++ b/src/p2p.cpp @@ -100,8 +100,7 @@ int zmq::p2p_t::xsend (zmq_msg_t *msg_, int flags_) return -1; } - if (!(flags_ & ZMQ_NOFLUSH)) - outpipe->flush (); + outpipe->flush (); // Detach the original message from the data buffer. int rc = zmq_msg_init (msg_); @@ -110,13 +109,6 @@ int zmq::p2p_t::xsend (zmq_msg_t *msg_, int flags_) return 0; } -int zmq::p2p_t::xflush () -{ - if (outpipe) - outpipe->flush (); - return 0; -} - int zmq::p2p_t::xrecv (zmq_msg_t *msg_, int flags_) { // Deallocate old content of the message. |