Searched refs:msgqueue (Results 1 – 2 of 2) sorted by relevance
117 dt_msg_queue_submit(env->msgqueue, buf, len_buf); in dt_send()312 env->msgqueue = dt_msg_queue_create(base); in dt_init()313 if(!env->msgqueue) { in dt_init()317 if(!dt_io_thread_register_queue(env->dtio, env->msgqueue)) { in dt_init()319 dt_msg_queue_delete(env->msgqueue); in dt_init()320 env->msgqueue = NULL; in dt_init()329 dt_io_thread_unregister_queue(env->dtio, env->msgqueue); in dt_deinit()330 dt_msg_queue_delete(env->msgqueue); in dt_deinit()
53 struct dt_msg_queue* msgqueue; member