Lines Matching refs:mpsc_daemon_queue_t

119 static void _mpsc_daemon_queue_drain(mpsc_daemon_queue_t, thread_t);
120 static void _mpsc_daemon_queue_enqueue(mpsc_daemon_queue_t, mpsc_queue_chain_t);
125 _mpsc_daemon_queue_init(mpsc_daemon_queue_t dq, mpsc_daemon_init_options_t flags) in _mpsc_daemon_queue_init()
135 mpsc_daemon_queue_t dq = param; in _mpsc_queue_thread_continue()
156 _mpsc_queue_thread_wakeup(mpsc_daemon_queue_t dq) in _mpsc_queue_thread_wakeup()
162 _mpsc_daemon_queue_init_with_thread(mpsc_daemon_queue_t dq, in _mpsc_daemon_queue_init_with_thread()
187 mpsc_daemon_queue_init_with_thread(mpsc_daemon_queue_t dq, in mpsc_daemon_queue_init_with_thread()
201 _mpsc_daemon_queue_drain((mpsc_daemon_queue_t)arg0, NULL); in _mpsc_queue_thread_call_drain()
205 _mpsc_queue_thread_call_wakeup(mpsc_daemon_queue_t dq) in _mpsc_queue_thread_call_wakeup()
211 mpsc_daemon_queue_init_with_thread_call(mpsc_daemon_queue_t dq, in mpsc_daemon_queue_init_with_thread_call()
230 __unused mpsc_daemon_queue_t tq) in mpsc_daemon_queue_nested_invoke()
232 mpsc_daemon_queue_t dq; in mpsc_daemon_queue_nested_invoke()
238 _mpsc_daemon_queue_nested_wakeup(mpsc_daemon_queue_t dq) in _mpsc_daemon_queue_nested_wakeup()
244 mpsc_daemon_queue_init_with_target(mpsc_daemon_queue_t dq, in mpsc_daemon_queue_init_with_target()
245 mpsc_daemon_invoke_fn_t invoke, mpsc_daemon_queue_t target, in mpsc_daemon_queue_init_with_target()
261 _mpsc_daemon_queue_drain(mpsc_daemon_queue_t dq, thread_t self) in _mpsc_daemon_queue_drain()
350 _mpsc_daemon_queue_wakeup(mpsc_daemon_queue_t dq) in _mpsc_daemon_queue_wakeup()
369 _mpsc_daemon_queue_enqueue(mpsc_daemon_queue_t dq, mpsc_queue_chain_t elm) in _mpsc_daemon_queue_enqueue()
390 mpsc_daemon_enqueue(mpsc_daemon_queue_t dq, mpsc_queue_chain_t elm, in mpsc_daemon_enqueue()
405 mpsc_daemon_queue_activate(mpsc_daemon_queue_t dq) in mpsc_daemon_queue_activate()
417 mpsc_daemon_queue_cancel_and_wait(mpsc_daemon_queue_t dq) in mpsc_daemon_queue_cancel_and_wait()
478 thread_deallocate_daemon_register_queue(mpsc_daemon_queue_t dq, in thread_deallocate_daemon_register_queue()