From 0f6f7276e32c01ccfe86fb76741a52ac6ffc87af Mon Sep 17 00:00:00 2001 From: Martin Sustrik Date: Mon, 23 May 2011 20:30:01 +0200 Subject: Move the pipe termination code to socket_base_t So far, the pipe termination code was spread among socket type classes, fair queuer, load balancer, etc. This patch moves all the associated logic to a single place. Signed-off-by: Martin Sustrik --- src/pipe.cpp | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'src/pipe.cpp') diff --git a/src/pipe.cpp b/src/pipe.cpp index fb03042..3d0c0a6 100644 --- a/src/pipe.cpp +++ b/src/pipe.cpp @@ -108,7 +108,7 @@ bool zmq::pipe_t::check_read () // If pipe_term was already received but wasn't processed because // of pending messages, we can ack it now. - if (terminating) + if (term_recvd) send_pipe_term_ack (peer); return false; @@ -133,7 +133,7 @@ bool zmq::pipe_t::read (msg_t *msg_) // If pipe_term was already received but wasn't processed because // of pending messages, we can ack it now. - if (terminating) + if (term_recvd) send_pipe_term_ack (peer); return false; -- cgit v1.2.3