Lines Matching refs:dt_msg_queue
103 struct dt_msg_queue*
106 struct dt_msg_queue* mq = calloc(1, sizeof(*mq)); in dt_msg_queue_create()
123 dt_msg_queue_clear(struct dt_msg_queue* mq) in dt_msg_queue_clear()
139 dt_msg_queue_delete(struct dt_msg_queue* mq) in dt_msg_queue_delete()
178 struct dt_msg_queue* mq = (struct dt_msg_queue*)arg; in mq_wakeup_cb()
188 dt_msg_queue_start_timer(struct dt_msg_queue* mq, int wakeupnow) in dt_msg_queue_start_timer()
235 dt_msg_queue_submit(struct dt_msg_queue* mq, void* buf, size_t len) in dt_msg_queue_submit()
455 struct dt_msg_queue* mq) in dt_io_thread_register_queue()
470 struct dt_msg_queue* mq) in dt_io_thread_unregister_queue()
495 static int dt_msg_queue_pop(struct dt_msg_queue* mq, void** buf, in dt_msg_queue_pop()
518 struct dt_msg_queue* mq) in dtio_find_in_queue()