generic-library/libzmq
1
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2025-10-26 18:42:43 +01:00
Code Issues Projects Releases Wiki Activity

Add STREAM connect notification.

Browse Source 
Adjust test cases to connection notification.
Increase error checking in test cases.
This commit is contained in:
Goswin von Brederlow
2014-01-17 23:21:42 +01:00
parent 53d0199e50
commit afb24b53e6
3 changed files with 174 additions and 48 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/stream_engine.cpp
View File

@@ -177,6 +177,14 @@ void zmq::stream_engine_t::plug (io_thread_t *io_thread_,
read_msg = &stream_engine_t::pull_msg_from_session;
write_msg = &stream_engine_t::push_msg_to_session;
// For raw sockets, send an initial 0-length message to the
// application so that it knows a peer has connected.
msg_t connector;
connector.init();
int rc = (this->*write_msg) (&connector);
connector.close();
session->flush ();
}
else {
// Send the 'length' and 'flags' fields of the identity message.