int(* except_cb)(struct osmo_fd *fd)
call-back in case qeueue has exceptions.
Definition: write_queue.h:50
Osmocom message buffer.
Definition: msgb.h:35
int osmo_wqueue_bfd_cb(struct osmo_fd *fd, unsigned int what)
Select loop function for write queue handling.
Definition: write_queue.c:43
void osmo_wqueue_clear(struct osmo_wqueue *queue)
Clear a osmo_wqueue.
Definition: write_queue.c:128
write queue instance
Definition: write_queue.h:34
void osmo_wqueue_init(struct osmo_wqueue *queue, int max_length)
Initialize a osmo_wqueue structure.
Definition: write_queue.c:92
int(* read_cb)(struct osmo_fd *fd)
call-back in case qeueue is readable.
Definition: write_queue.h:46
struct llist_head msg_queue
actual linked list implementing the queue
Definition: write_queue.h:43
(double) linked list header structure
Definition: linuxlist.h:46
unsigned int max_length
maximum length of write queue
Definition: write_queue.h:38
struct osmo_fd bfd
osmocom file descriptor
Definition: write_queue.h:36
unsigned int current_length
current length of write queue
Definition: write_queue.h:40
Structure representing a file dsecriptor.
Definition: select.h:28
int osmo_wqueue_enqueue(struct osmo_wqueue *queue, struct msgb *data)
Enqueue a new Message buffers into a write queue.
Definition: write_queue.c:108
int fd
actual operating-system level file decriptor
Definition: select.h:32
int(* write_cb)(struct osmo_fd *fd, struct msgb *msg)
call-back in case qeueue is writable.
Definition: write_queue.h:48