ZMQII-62: zmq_close after sending message via P2P socket fails

b0ee6b0c · Martin Sustrik · bbaa494f · b0ee6b0c
Commit b0ee6b0c authored Feb 07, 2010 by Martin Sustrik
Hide whitespace changes
Inline Side-by-side

Showing with 5 additions and 0 deletions

p2p.cpp src/p2p.cpp +5 -0

No files found.
--- a/src/p2p.cpp
+++ b/src/p2p.cpp
@@ -93,6 +93,11 @@ int zmq::p2p_t::xsend (zmq_msg_t *msg_, int flags_)
    outpipe->write (msg_);
    if (!(flags_ & ZMQ_NOFLUSH))
        outpipe->flush ();
+    //  Detach the original message from the data buffer.
+    int rc = zmq_msg_init (msg_);
+    zmq_assert (rc == 0);
    return 0;
 }