Searched refs:dt_msg_queue (Results 1 – 4 of 4) sorted by relevance
60 struct dt_msg_queue { struct240 struct dt_msg_queue* queue;248 struct dt_msg_queue* dt_msg_queue_create(struct comm_base* base);255 void dt_msg_queue_delete(struct dt_msg_queue* mq);269 void dt_msg_queue_submit(struct dt_msg_queue* mq, void* buf, size_t len);304 struct dt_msg_queue* mq);312 struct dt_msg_queue* mq);
45 struct dt_msg_queue;53 struct dt_msg_queue* msgqueue;
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()[all …]