Lines Matching refs:mpsc_daemon_queue_t
134 static void _mpsc_daemon_queue_drain(mpsc_daemon_queue_t, thread_t);
135 static void _mpsc_daemon_queue_enqueue(mpsc_daemon_queue_t, mpsc_queue_chain_t);
140 _mpsc_daemon_queue_init(mpsc_daemon_queue_t dq, mpsc_daemon_init_options_t flags) in _mpsc_daemon_queue_init()
150 mpsc_daemon_queue_t dq = param; in _mpsc_queue_thread_continue()
171 _mpsc_queue_thread_wakeup(mpsc_daemon_queue_t dq) in _mpsc_queue_thread_wakeup()
177 _mpsc_daemon_queue_init_with_thread(mpsc_daemon_queue_t dq, in _mpsc_daemon_queue_init_with_thread()
202 mpsc_daemon_queue_init_with_thread(mpsc_daemon_queue_t dq, in mpsc_daemon_queue_init_with_thread()
216 _mpsc_daemon_queue_drain((mpsc_daemon_queue_t)arg0, NULL); in _mpsc_queue_thread_call_drain()
220 _mpsc_queue_thread_call_wakeup(mpsc_daemon_queue_t dq) in _mpsc_queue_thread_call_wakeup()
226 mpsc_daemon_queue_init_with_thread_call(mpsc_daemon_queue_t dq, in mpsc_daemon_queue_init_with_thread_call()
245 __unused mpsc_daemon_queue_t tq) in mpsc_daemon_queue_nested_invoke()
247 mpsc_daemon_queue_t dq; in mpsc_daemon_queue_nested_invoke()
253 _mpsc_daemon_queue_nested_wakeup(mpsc_daemon_queue_t dq) in _mpsc_daemon_queue_nested_wakeup()
259 mpsc_daemon_queue_init_with_target(mpsc_daemon_queue_t dq, in mpsc_daemon_queue_init_with_target()
260 mpsc_daemon_invoke_fn_t invoke, mpsc_daemon_queue_t target, in mpsc_daemon_queue_init_with_target()
276 _mpsc_daemon_queue_drain(mpsc_daemon_queue_t dq, thread_t self) in _mpsc_daemon_queue_drain()
365 _mpsc_daemon_queue_wakeup(mpsc_daemon_queue_t dq) in _mpsc_daemon_queue_wakeup()
384 _mpsc_daemon_queue_enqueue(mpsc_daemon_queue_t dq, mpsc_queue_chain_t elm) in _mpsc_daemon_queue_enqueue()
405 mpsc_daemon_enqueue(mpsc_daemon_queue_t dq, mpsc_queue_chain_t elm, in mpsc_daemon_enqueue()
420 mpsc_daemon_queue_activate(mpsc_daemon_queue_t dq) in mpsc_daemon_queue_activate()
432 mpsc_daemon_queue_cancel_and_wait(mpsc_daemon_queue_t dq) in mpsc_daemon_queue_cancel_and_wait()
493 thread_deallocate_daemon_register_queue(mpsc_daemon_queue_t dq, in thread_deallocate_daemon_register_queue()