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/session.hpp | |
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/session.hpp')
-rw-r--r-- | src/session.hpp | 10 |
1 files changed, 3 insertions, 7 deletions
diff --git a/src/session.hpp b/src/session.hpp index f1564d8..8bca735 100644 --- a/src/session.hpp +++ b/src/session.hpp @@ -59,10 +59,6 @@ namespace zmq protected: - // This function allows to shut down the session even though - // there are messages pending. - void terminate (); - // Two events for the derived session type. Attached is triggered // when session is attached to a peer. The function can reject the new // peer by returning false. Detached is triggered at the beginning of @@ -105,9 +101,9 @@ namespace zmq // is still in the in pipe. bool incomplete_in; - // If true the termination process is already underway, ie. term ack - // for the pipe was already registered etc. - bool terminating; + // True if termination have been suspended to push the pending + // messages to the network. + bool pending; // The protocol I/O engine connected to the session. struct i_engine *engine; |