generic-library/libzmq
1
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2024-12-12 18:40:27 +01:00
Code Issues Projects Releases Wiki Activity

make ZMQ_STREAM_NOTIFY also control disconnect notificatons

Browse Source
This commit is contained in:
KIU Shueng Chuan 2015-07-24 05:12:11 +08:00
parent ec5592db1f
commit 518b939f31
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
doc/zmq_setsockopt.txt
View File

@ -716,11 +716,11 @@ Default value:: -1 (infinite)
Applicable socket types:: all Applicable socket types:: all
ZMQ_STREAM_NOTIFY: send connect notifications ZMQ_STREAM_NOTIFY: send connect and disconnect notifications
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
Enables connect notifications on a STREAM socket, when set to 1. By default a Enables connect and disconnect notifications on a STREAM socket, when set
STREAM socket does not notify new connections. When notifications are enabled, to 1. When notifications are enabled, the socket delivers a zero-length
it delivers a zero-length message to signal new client connections. message when a peer connects or disconnects.
[horizontal] [horizontal]
Option value type:: int Option value type:: int

2
src/stream_engine.cpp
View File

@ -965,7 +965,7 @@ int zmq::stream_engine_t::write_subscription_msg (msg_t *msg_)
void zmq::stream_engine_t::error (error_reason_t reason) void zmq::stream_engine_t::error (error_reason_t reason)
{ {
if (options.raw_socket) { if (options.raw_socket && options.raw_notify) {
// For raw sockets, send a final 0-length message to the application // For raw sockets, send a final 0-length message to the application
// so that it knows the peer has been disconnected. // so that it knows the peer has been disconnected.
msg_t terminator; msg_t terminator;