Problem: intermittent memory leak for req/rep send/recv. zeromq#2602 …

…Solution: memory leak fixed.
hangzhou123 · Jun 27, 2017 · 6935573 · 6935573
1 parent a3550e6
commit 6935573
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;