Skip to main content

Module control_socket

Module control_socket 

Source
Expand description

Shared broker control socket dispatch for Hello and admin frames.

The v1 broker uses one local socket for both client Hello negotiation and admin verbs. This module keeps the bounded synchronous serve helpers aligned with that contract while the long-lived daemon loop is still being built.

Enums§

ControlSocketConnectionLimit
Connection limit for a broker control-socket accept loop.
ControlSocketError
Errors raised while dispatching a shared broker control socket frame.
ControlSocketReply
Result of handling one control socket connection.

Functions§

handle_control_connection_with_peer_policy
Handle one already-accepted broker control connection.
handle_control_connection_with_peer_policy_and_fd_guard
Handle one already-accepted broker control connection, refusing Hello frames with ERROR_FD_PRESSURE while fd_guard reports a demotion (#390). Admin frames are always served so status can surface the demoted state.
serve_control_socket_connections_with_limit_and_policy
Run a broker control-socket accept loop that dispatches Hello and admin frames on the same endpoint.
serve_control_socket_connections_with_limit_policy_and_post_hello
Run a broker control-socket accept loop with a post-Hello connection hook.
serve_control_socket_connections_with_limit_policy_post_hello_and_fd_guard
Run a broker control-socket accept loop with fd-pressure self-demotion (#390).
serve_control_socket_connections_with_policy
Run a bounded local-socket accept loop that dispatches Hello and admin frames on the same endpoint.