28 #define LISTENER_BACKPRESSURE_SHIFT 0
32 #define LISTENER_EXPECT_BACKPRESSURE_SHIFT 7
49 int64_t seq_id, int16_t timeout_sec,
int *notify_fd);
53 uint16_t *backpressure);
bool Listener_HoldResponse(struct listener *l, int fd, int64_t seq_id, int16_t timeout_sec, int *notify_fd)
The client is about to start a write, the listener should hold on to the response (with timeout) if i...
Per-socket connection context.
bool Listener_ExpectResponse(struct listener *l, boxed_msg *box, uint16_t *backpressure)
The client has finished a write, the listener should expect a response.
void Listener_Free(struct listener *l)
Free the listener, which must already be shut down.
struct listener * Listener_Init(struct bus *b, struct bus_config *cfg)
Initialize the listener.
bool Listener_Shutdown(struct listener *l, int *notify_fd)
Shut down the listener.
bool Listener_AddSocket(struct listener *l, connection_info *ci, int *notify_fd)
Add/remove sockets' metadata from internal info.
bool Listener_RemoveSocket(struct listener *l, int fd, int *notify_fd)