summaryrefslogtreecommitdiff
path: root/src/pipe.cpp
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@250bpm.com>2011-05-26 11:30:25 +0200
committerMartin Sustrik <sustrik@250bpm.com>2011-05-26 11:30:25 +0200
commit718885fdcd7af797f940078ca8c22aebab93c8bb (patch)
tree33d0d96a5d122338ee8eaddc44fd138b5f6d0651 /src/pipe.cpp
parent87a6490b39c44e8f9c521f6ccea14f800a712d3f (diff)
Pending messages are delivered even if connection doesn't exist yet
Bug in previous refactoring fixed. Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
Diffstat (limited to 'src/pipe.cpp')
-rw-r--r--src/pipe.cpp3
1 files changed, 2 insertions, 1 deletions
diff --git a/src/pipe.cpp b/src/pipe.cpp
index 73e5aae..48fc3e5 100644
--- a/src/pipe.cpp
+++ b/src/pipe.cpp
@@ -216,11 +216,12 @@ void zmq::pipe_t::process_pipe_term ()
if (!delay) {
state = terminating;
send_pipe_term_ack (peer);
+ return;
}
else {
state = pending;
+ return;
}
- return;
}
// Delimiter happened to arrive before the term command. Now we have the