• Andre Caron's avatar
    Adds support for detecting ZMQ_STREAM disconnections. · 17651b92
    Andre Caron authored
    When a ZMQ_STREAM socket connection is broken (intentionally, via `shutdown()`
    or accidentally via client crash or network failure), there is no way for the
    application to dertermine that it should drop per-connection data (such as
    buffers).
    
    This contribution makes sure the application receives a 0-length message to
    notify it that the connection has been broken.  This is symmetric with the
    process of closing the connection from within the application (where the
    application sends a 0-length message to tell ZeroMQ to close the connection).
    
    Conflicts:
    	CMakeLists.txt
    17651b92
Name
Last commit
Last update
..
Makefile.am Loading commit data...
test_abstract_ipc.cpp Loading commit data...
test_conflate.cpp Loading commit data...
test_connect_delay_tipc.cpp Loading commit data...
test_connect_resolve.cpp Loading commit data...
test_ctx_destroy.cpp Loading commit data...
test_ctx_options.cpp Loading commit data...
test_diffserv.cpp Loading commit data...
test_disconnect_inproc.cpp Loading commit data...
test_filter_ipc.cpp Loading commit data...
test_fork.cpp Loading commit data...
test_hwm.cpp Loading commit data...
test_immediate.cpp Loading commit data...
test_inproc_connect.cpp Loading commit data...
test_invalid_rep.cpp Loading commit data...
test_iov.cpp Loading commit data...
test_ipc_wildcard.cpp Loading commit data...
test_issue_566.cpp Loading commit data...
test_last_endpoint.cpp Loading commit data...
test_many_sockets.cpp Loading commit data...
test_monitor.cpp Loading commit data...
test_msg_flags.cpp Loading commit data...
test_pair_inproc.cpp Loading commit data...
test_pair_ipc.cpp Loading commit data...
test_pair_tcp.cpp Loading commit data...
test_pair_tipc.cpp Loading commit data...
test_probe_router.cpp Loading commit data...
test_proxy.cpp Loading commit data...
test_req_correlate.cpp Loading commit data...
test_req_relaxed.cpp Loading commit data...
test_reqrep_device.cpp Loading commit data...
test_reqrep_device_tipc.cpp Loading commit data...
test_reqrep_inproc.cpp Loading commit data...
test_reqrep_ipc.cpp Loading commit data...
test_reqrep_tcp.cpp Loading commit data...
test_reqrep_tipc.cpp Loading commit data...
test_resource.cpp Loading commit data...
test_router_handover.cpp Loading commit data...
test_router_mandatory.cpp Loading commit data...
test_router_mandatory_tipc.cpp Loading commit data...
test_security_curve.cpp Loading commit data...
test_security_null.cpp Loading commit data...
test_security_plain.cpp Loading commit data...
test_shutdown_stress.cpp Loading commit data...
test_shutdown_stress_tipc.cpp Loading commit data...
test_spec_dealer.cpp Loading commit data...
test_spec_pushpull.cpp Loading commit data...
test_spec_rep.cpp Loading commit data...
test_spec_req.cpp Loading commit data...
test_spec_router.cpp Loading commit data...
test_srcfd.cpp Loading commit data...
test_stream.cpp Loading commit data...
test_stream_disconnect_notifications.cpp Loading commit data...
test_stream_empty.cpp Loading commit data...
test_sub_forward.cpp Loading commit data...
test_sub_forward_tipc.cpp Loading commit data...
test_system.cpp Loading commit data...
test_term_endpoint.cpp Loading commit data...
test_term_endpoint_tipc.cpp Loading commit data...
test_timeo.cpp Loading commit data...
testutil.hpp Loading commit data...