Home
last modified time | relevance | path

Searched refs:mpsc_queue_chain_t (Results 1 – 11 of 11) sorted by relevance

/xnu-8020.140.41/osfmk/kern/
H A Dmpsc_queue.h56 } *mpsc_queue_chain_t; typedef
176 #define MPSC_QUEUE_NOTQUEUED_MARKER ((mpsc_queue_chain_t)~0ul)
214 static inline mpsc_queue_chain_t
215 __mpsc_queue_append_update_tail(mpsc_queue_head_t q, mpsc_queue_chain_t elm) in __mpsc_queue_append_update_tail()
238 __mpsc_queue_append_was_empty(mpsc_queue_head_t q, mpsc_queue_chain_t prev) in __mpsc_queue_append_was_empty()
265 __mpsc_queue_append_update_prev(mpsc_queue_chain_t prev, mpsc_queue_chain_t elm) in __mpsc_queue_append_update_prev()
295 mpsc_queue_append_list(mpsc_queue_head_t q, mpsc_queue_chain_t first, in mpsc_queue_append_list()
296 mpsc_queue_chain_t last) in mpsc_queue_append_list()
298 mpsc_queue_chain_t prev = __mpsc_queue_append_update_tail(q, last); in mpsc_queue_append_list()
316 mpsc_queue_append(mpsc_queue_head_t q, mpsc_queue_chain_t elm) in mpsc_queue_append()
[all …]
H A Dmpsc_queue.c37 static mpsc_queue_chain_t
44 mpsc_queue_restore_batch(mpsc_queue_head_t q, mpsc_queue_chain_t first, in mpsc_queue_restore_batch()
45 mpsc_queue_chain_t last) in mpsc_queue_restore_batch()
47 mpsc_queue_chain_t head = os_atomic_load(&q->mpqh_head.mpqc_next, relaxed); in mpsc_queue_restore_batch()
63 mpsc_queue_chain_t
64 mpsc_queue_dequeue_batch(mpsc_queue_head_t q, mpsc_queue_chain_t *tail_out, in mpsc_queue_dequeue_batch()
67 mpsc_queue_chain_t head, tail; in mpsc_queue_dequeue_batch()
102 mpsc_queue_chain_t
103 mpsc_queue_batch_next(mpsc_queue_chain_t cur, mpsc_queue_chain_t tail) in mpsc_queue_batch_next()
105 mpsc_queue_chain_t elm = NULL; in mpsc_queue_batch_next()
[all …]
H A Dtest_mpsc_queue.c48 mpsc_test_pingpong_invoke(mpsc_queue_chain_t elm, mpsc_daemon_queue_t dq) in mpsc_test_pingpong_invoke()
H A Dcore_analytics.c106 core_analytics_event_queue_invoke(mpsc_queue_chain_t e, mpsc_daemon_queue_t queue __unused) in core_analytics_event_queue_invoke()
H A Dthread_group.c91 static void thread_group_deallocate_queue_invoke(mpsc_queue_chain_t e,
599 thread_group_deallocate_queue_invoke(mpsc_queue_chain_t e, __assert_only mpsc_daemon_queue_t dq) in thread_group_deallocate_queue_invoke()
H A Dhazard.c486 hazard_deallocate_queue_invoke(mpsc_queue_chain_t e, in hazard_deallocate_queue_invoke()
H A Dwork_interval.c453 work_interval_deallocate_queue_invoke(mpsc_queue_chain_t e, in work_interval_deallocate_queue_invoke()
H A Dthread.c850 thread_exception_queue_invoke(mpsc_queue_chain_t elm, in thread_exception_queue_invoke()
934 thread_terminate_queue_invoke(mpsc_queue_chain_t e, in thread_terminate_queue_invoke()
1043 thread_deallocate_queue_invoke(mpsc_queue_chain_t e, in thread_deallocate_queue_invoke()
1120 thread_stack_queue_invoke(mpsc_queue_chain_t elm, in thread_stack_queue_invoke()
H A Dturnstile.c774 turnstile_deallocate_queue_invoke(mpsc_queue_chain_t e, in turnstile_deallocate_queue_invoke()
/xnu-8020.140.41/osfmk/ipc/
H A Dipc_object.c166 ipc_object_deallocate_queue_invoke(mpsc_queue_chain_t e, in ipc_object_deallocate_queue_invoke()
/xnu-8020.140.41/bsd/pthread/
H A Dpthread_workqueue.c1978 workq_deallocate_queue_invoke(mpsc_queue_chain_t e, in workq_deallocate_queue_invoke()