diff options
-rw-r--r-- | src/pair.cpp | 14 |
1 files changed, 9 insertions, 5 deletions
diff --git a/src/pair.cpp b/src/pair.cpp index f5df59f..89f949d 100644 --- a/src/pair.cpp +++ b/src/pair.cpp @@ -84,13 +84,17 @@ void zmq::pair_t::terminated (class writer_t *pipe_) void zmq::pair_t::process_term () { - zmq_assert (inpipe && outpipe); - terminating = true; - register_term_acks (2); - inpipe->terminate (); - outpipe->terminate (); + if (inpipe) { + register_term_acks (1); + inpipe->terminate (); + } + + if (outpipe) { + register_term_acks (1); + outpipe->terminate (); + } socket_base_t::process_term (); } |