void tube_close_write(struct tube *tube)
void tube_callback_type(struct tube *, uint8_t *, size_t, int, void *)
struct tube_res_list * next
void tube_remove_bg_listen(struct tube *tube)
int tube_handle_listen(struct comm_point *c, void *arg, int error, struct comm_reply *reply_info)
int tube_setup_bg_write(struct tube *tube, struct comm_base *base)
int tube_write_msg(struct tube *tube, uint8_t *buf, uint32_t len, int nonblock)
int tube_read_fd(struct tube *tube)
int tube_read_msg(struct tube *tube, uint8_t **buf, uint32_t *len, int nonblock)
int tube_queue_item(struct tube *tube, uint8_t *msg, size_t len)
void tube_handle_signal(int fd, short events, void *arg)
struct comm_point * res_com
int tube_handle_write(struct comm_point *c, void *arg, int error, struct comm_reply *reply_info)
struct tube_res_list * res_last
struct tube_res_list * res_list
void tube_delete(struct tube *tube)
int tube_poll(struct tube *tube)
int tube_wait(struct tube *tube)
tube_callback_type * listen_cb
void tube_close_read(struct tube *tube)
struct comm_point * listen_com
error
Tracks LMDB error codes.
struct tube * tube_create(void)
void tube_remove_bg_write(struct tube *tube)
int tube_setup_bg_listen(struct tube *tube, struct comm_base *base, tube_callback_type *cb, void *arg)