Searched refs:msgqueue (Results 1 – 2 of 2) sorted by relevance
117 dt_msg_queue_submit(env->msgqueue, buf, len_buf); in dt_send()281 env->msgqueue = dt_msg_queue_create(base); in dt_init()282 if(!env->msgqueue) { in dt_init()286 if(!dt_io_thread_register_queue(env->dtio, env->msgqueue)) { in dt_init()288 dt_msg_queue_delete(env->msgqueue); in dt_init()289 env->msgqueue = NULL; in dt_init()298 dt_io_thread_unregister_queue(env->dtio, env->msgqueue); in dt_deinit()299 dt_msg_queue_delete(env->msgqueue); in dt_deinit()
53 struct dt_msg_queue* msgqueue; member