Merge pull request #2609 from bjovke/my_work

Problem: intermittent memory leak for req/rep send/recv. #2602 Solution: memory leak fixed.
zeromq · Jun 27, 2017 · 33038da · 33038da
2 parents a3550e6 + 6935573
commit 33038da
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/pipe.cpp b/src/pipe.cpp
@@ -410,6 +410,8 @@ void zmq::pipe_t::terminate (bool delay_)
     //  There are still pending messages available, but the user calls
     //  'terminate'. We can act as if all the pending messages were read.
     else if (state == waiting_for_delimiter && !delay) {
+        //  Drop any unfinished outbound messages.
+        rollback ();
         outpipe = NULL;
         send_pipe_term_ack (peer);
         state = term_ack_sent;