ZMQ_NOFLUSH and zmq_flush obsoleted

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.