20 #ifndef LISTENER_TASK_H
21 #define LISTENER_TASK_H
bool ListenerTask_GrowReadBuf(listener *l, size_t nsize)
Grow the listener's read buffer to NSIZE.
Record in table for partially processed messages.
void ListenerTask_ReleaseRXInfo(listener *l, struct rx_info_t *info)
Release an INFO to the listener's info pool.
A queue message, with a command in the tagged union.
void ListenerTask_ReleaseMsg(listener *l, listener_msg *msg)
Release a message to the listener's message pool.
void ListenerTask_DumpRXInfoTable(listener *l)
Dump the RX info table.
void * ListenerTask_MainLoop(void *arg)
Listener's main loop – function pointer for pthread start function.
void ListenerTask_NotifyMessageFailure(listener *l, rx_info_t *info, bus_send_status_t status)
Notify the client that the event in INFO has failed with STATUS.
uint16_t ListenerTask_GetBackpressure(struct listener *l)
Get the current backpressure from the listener.
void ListenerTask_AttemptDelivery(listener *l, struct rx_info_t *info)
Attempt delivery of the message boxed in INFO.