zeromq / libzmq

75%

LAST BUILD ON BRANCH master

branch: SELECT

CHANGE BRANCH

x

• No branch selected
• add-unittests-mtrie
• ci
• dev1
• fix-install-cmake-config-on-mingw
• fix_ctx_get
• jemc-relicense
• latest_release
• libera
• make-failing-test-not-hang
• master
• no-allocation-sends
• p-stable-poller
• patch-1
• pre_reformat
• refs/tags/v4.3.5
• revert-1975-master
• revert-2572-rep_leak
• revert-2974-static_init_gcc
• rp42-fix-windows-mt-build
• secpolicy
• show-ref
• tmp_obs_release_branch
• v4.0.2-test
• v4.2.0
• v4.2.0-rc1
• v4.2.1
• v4.2.2
• v4.2.3
• v4.2.4
• v4.2.5
• v4.3.0
• v4.3.1
• v4.3.2
• v4.3.2-win
• v4.3.3
• v4.3.4
• vsock
• zap-domain-docs

Build # 20882548110

Build Type

push

github

Committed by bluca

Commit Message

problem: no API to disconnect a specific peer by routing id

Background: JeroMQ added disconnectPeer(routingId) to allow dropping a single peer connection. In libzmq there was no C API to disconnect a single connection by its routing id; applications had to tear down entire endpoints or sockets. This also created divergence between JeroMQ and libzmq for the PEER/SERVER patterns.

solution: introduce a virtual xdisconnect_peer on socket_base_t and a public socket_base_t::disconnect_peer that delegates to it. Implement xdisconnect_peer in server_t to look up the outbound pipe by routing id and terminate it, which removes it from bookkeeping via xpipe_terminated. Expose a new DRAFT C API zmq_disconnect_peer(void*, uint32_t) that always calls socket_base_t::disconnect_peer (matching JeroMQ pattern of calling the socket regardless of type); unsupported types return ENOTSUP. This brings libzmq to feature parity with JeroMQ’s commit 57de9b8 (Peer support disconnect).

API: add draft function zmq_disconnect_peer(void *socket, uint32_t routing_id). For ZMQ_SERVER and ZMQ_PEER this disconnects that specific connection; subsequent sends to that routing id fail with EHOSTUNREACH until a new connection is formed. Other socket types return ENOTSUP. The method is thread-safe when using thread-safe sockets.

Tests: add tests/test_peer_disconnect.cpp which creates two ZMQ_PEER sockets, exchanges a message to learn the remote routing id, calls zmq_disconnect_peer on the bound side, and verifies sending back fails with EHOSTUNREACH. Hook the test into Makefile.am under ENABLE_DRAFTS.

Docs: add doc/zmq_disconnect_peer.adoc manpage; link it from doc/zmq_socket.adoc; include it in doc/Makefile.am MAN3 so it is built and installed. Note the draft status (requires --enable-drafts).

Implementation notes: the server_t override simply terminates the matched pipe; removal from maps happens in xpipe_terminated. The C shim intentionally does not gate by socket type and relies on... (continued)

Run Details

14842 of 19797 relevant lines covered (74.97%)

31518.59 hits per line