summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@250bpm.com>2010-10-01 18:46:32 +0200
committerMartin Sustrik <sustrik@250bpm.com>2010-10-01 18:46:32 +0200
commit2142b8918a0cea79c79c8ed8ce5652148abe4a39 (patch)
tree436feaf91b18a319b13e298e496d34de504cc904 /src
parent1a6cd59e8b423cdf3a4f4f854b37c5e0693baef6 (diff)
issue 92 -- Assertion failed: inpipe && outpipe (pair.cpp:86) -- fixed
Diffstat (limited to 'src')
-rw-r--r--src/pair.cpp14
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 ();
}