Searched refs:dt_msg_queue (Results 1 – 3 of 3) 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);
44 struct dt_msg_queue;52 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()191 dt_msg_queue_start_timer(struct dt_msg_queue* mq, int wakeupnow) in dt_msg_queue_start_timer()230 dt_msg_queue_submit(struct dt_msg_queue* mq, void* buf, size_t len) in dt_msg_queue_submit()449 struct dt_msg_queue* mq) in dt_io_thread_register_queue()464 struct dt_msg_queue* mq) in dt_io_thread_unregister_queue()489 static int dt_msg_queue_pop(struct dt_msg_queue* mq, void** buf, in dt_msg_queue_pop()[all …]