diff options
author | Martin Sustrik <sustrik@250bpm.com> | 2011-05-26 11:30:25 +0200 |
---|---|---|
committer | Martin Sustrik <sustrik@250bpm.com> | 2011-05-26 11:30:25 +0200 |
commit | 718885fdcd7af797f940078ca8c22aebab93c8bb (patch) | |
tree | 33d0d96a5d122338ee8eaddc44fd138b5f6d0651 /src/pipe.cpp | |
parent | 87a6490b39c44e8f9c521f6ccea14f800a712d3f (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.cpp | 3 |
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 |