Searched refs:msgqueue (Results 1 – 2 of 2) sorted by relevance
117 dt_msg_queue_submit(env->msgqueue, buf, len_buf); in dt_send()293 env->msgqueue = dt_msg_queue_create(base); in dt_init()294 if(!env->msgqueue) { in dt_init()298 if(!dt_io_thread_register_queue(env->dtio, env->msgqueue)) { in dt_init()300 dt_msg_queue_delete(env->msgqueue); in dt_init()301 env->msgqueue = NULL; in dt_init()310 dt_io_thread_unregister_queue(env->dtio, env->msgqueue); in dt_deinit()311 dt_msg_queue_delete(env->msgqueue); in dt_deinit()
53 struct dt_msg_queue* msgqueue; member