Searched refs:msgqueue (Results 1 – 2 of 2) sorted by relevance
92 dt_msg_queue_submit(env->msgqueue, buf, len_buf); in dt_send()249 env->msgqueue = dt_msg_queue_create(base); in dt_init()250 if(!env->msgqueue) { in dt_init()254 if(!dt_io_thread_register_queue(env->dtio, env->msgqueue)) { in dt_init()256 dt_msg_queue_delete(env->msgqueue); in dt_init()257 env->msgqueue = NULL; in dt_init()266 dt_io_thread_unregister_queue(env->dtio, env->msgqueue); in dt_deinit()267 dt_msg_queue_delete(env->msgqueue); in dt_deinit()
52 struct dt_msg_queue* msgqueue; member