Symbol: dt_msg_queue
sbin/unwind/libunbound/dnstap/dnstap.h
45
struct dt_msg_queue;
sbin/unwind/libunbound/dnstap/dnstap.h
53
struct dt_msg_queue* msgqueue;
usr.sbin/unbound/dnstap/dnstap.h
45
struct dt_msg_queue;
usr.sbin/unbound/dnstap/dnstap.h
53
struct dt_msg_queue* msgqueue;
usr.sbin/unbound/dnstap/dtstream.c
103
struct dt_msg_queue*
usr.sbin/unbound/dnstap/dtstream.c
106
struct dt_msg_queue* mq = calloc(1, sizeof(*mq));
usr.sbin/unbound/dnstap/dtstream.c
123
dt_msg_queue_clear(struct dt_msg_queue* mq)
usr.sbin/unbound/dnstap/dtstream.c
139
dt_msg_queue_delete(struct dt_msg_queue* mq)
usr.sbin/unbound/dnstap/dtstream.c
178
struct dt_msg_queue* mq = (struct dt_msg_queue*)arg;
usr.sbin/unbound/dnstap/dtstream.c
188
dt_msg_queue_start_timer(struct dt_msg_queue* mq, int wakeupnow)
usr.sbin/unbound/dnstap/dtstream.c
235
dt_msg_queue_submit(struct dt_msg_queue* mq, void* buf, size_t len)
usr.sbin/unbound/dnstap/dtstream.c
455
struct dt_msg_queue* mq)
usr.sbin/unbound/dnstap/dtstream.c
470
struct dt_msg_queue* mq)
usr.sbin/unbound/dnstap/dtstream.c
495
static int dt_msg_queue_pop(struct dt_msg_queue* mq, void** buf,
usr.sbin/unbound/dnstap/dtstream.c
518
struct dt_msg_queue* mq)
usr.sbin/unbound/dnstap/dtstream.h
240
struct dt_msg_queue* queue;
usr.sbin/unbound/dnstap/dtstream.h
248
struct dt_msg_queue* dt_msg_queue_create(struct comm_base* base);
usr.sbin/unbound/dnstap/dtstream.h
255
void dt_msg_queue_delete(struct dt_msg_queue* mq);
usr.sbin/unbound/dnstap/dtstream.h
269
void dt_msg_queue_submit(struct dt_msg_queue* mq, void* buf, size_t len);
usr.sbin/unbound/dnstap/dtstream.h
304
struct dt_msg_queue* mq);
usr.sbin/unbound/dnstap/dtstream.h
312
struct dt_msg_queue* mq);