Lines Matching refs:mpsc_queue_chain_t
38 static mpsc_queue_chain_t
45 mpsc_queue_restore_batch(mpsc_queue_head_t q, mpsc_queue_chain_t first, in mpsc_queue_restore_batch()
46 mpsc_queue_chain_t last) in mpsc_queue_restore_batch()
48 mpsc_queue_chain_t head = os_atomic_load(&q->mpqh_head.mpqc_next, relaxed); in mpsc_queue_restore_batch()
64 mpsc_queue_chain_t
65 mpsc_queue_dequeue_batch(mpsc_queue_head_t q, mpsc_queue_chain_t *tail_out, in mpsc_queue_dequeue_batch()
68 mpsc_queue_chain_t head, tail; in mpsc_queue_dequeue_batch()
103 mpsc_queue_chain_t
104 mpsc_queue_batch_next(mpsc_queue_chain_t cur, mpsc_queue_chain_t tail) in mpsc_queue_batch_next()
106 mpsc_queue_chain_t elm = NULL; in mpsc_queue_batch_next()
121 static void _mpsc_daemon_queue_enqueue(mpsc_daemon_queue_t, mpsc_queue_chain_t);
232 mpsc_daemon_queue_nested_invoke(mpsc_queue_chain_t elm, in mpsc_daemon_queue_nested_invoke()
267 mpsc_queue_chain_t head, cur, tail; in _mpsc_daemon_queue_drain()
372 _mpsc_daemon_queue_enqueue(mpsc_daemon_queue_t dq, mpsc_queue_chain_t elm) in _mpsc_daemon_queue_enqueue()
393 mpsc_daemon_enqueue(mpsc_daemon_queue_t dq, mpsc_queue_chain_t elm, in mpsc_daemon_enqueue()