3party/libzmq
0
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2025-03-19 09:53:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add connector.close() back

Browse Source 
Needed if session->push() ever fails
This commit is contained in:
Thomas Rodgers 2015-02-18 11:17:41 -06:00
parent bbecdf397e
commit 5e60f18d3a
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/stream_engine.cpp
View File

@ -210,6 +210,7 @@ void zmq::stream_engine_t::plug (io_thread_t *io_thread_,
connector.set_metadata(metadata); connector.set_metadata(metadata);
push_msg_to_session (&connector); push_msg_to_session (&connector);
session->flush (); session->flush ();
connector.close();
} }
else { else {
// start optional timer, to prevent handshake hanging on no input // start optional timer, to prevent handshake hanging on no input