20 #ifndef LISTENER_INTERNAL_TYPES_H
21 #define LISTENER_INTERNAL_TYPES_H
29 #define DEFAULT_READ_BUF_SIZE (1024L * 1024L)
35 #define INCOMING_MSG_PIPE_ID 0
39 #define INCOMING_MSG_PIPE 1
83 #define LISTENER_TASK_TIMEOUT_DELAY 100
122 #define MAX_PENDING_MESSAGES (1024)
125 #define MAX_QUEUE_MESSAGES (32)
129 #define INFINITE_DELAY (-1)
132 #define LISTENER_NO_FD (-1)
133 #define LISTENER_SHUTDOWN_COMPLETE_FD (-2)
#define MAX_QUEUE_MESSAGES
Max number of unprocessed queue messages.
Record in table for partially processed messages.
struct rx_info_t::@12::@13 hold
listener_msg * msg_freelist
struct pollfd fds[1000+1]
Tracked file descriptors, for polling.
struct listener_msg::@6::@7 add_socket
int64_t largest_seq_id_seen
A queue message, with a command in the tagged union.
connection_info * fd_info[1000]
The connection info, corresponding to the the file descriptors tracked in l->fds. ...
bus_unpack_cb_res_t result
struct listener_msg::@6::@10 expect
struct listener_msg * next
struct listener_msg::@6::@9 hold
rx_info_t * rx_info_freelist
uint16_t tracked_fds
FDs currently tracked by listener.
rx_info_t rx_info[(1024)]
Per-socket connection context.
uint16_t rx_info_max_used
#define MAX_FDS
Max number of sockets to monitor.
struct rx_info_t::@12::@14 expect
bool error_occured
Flag indicating post-poll handling is necessary.
struct listener_msg::@6::@11 shutdown
uint16_t inactive_fds
File descriptors that are inactive due to errors, but have not yet been explicitly removed/closed by ...
struct listener_msg::@6::@8 remove_socket
size_t upstream_backpressure
#define MAX_PENDING_MESSAGES