Searched refs:wq (Results 1 - 6 of 6) sorted by relevance

/xnu-2782.1.97/osfmk/kern/
H A Dwait_queue.c82 wait_queue_t wq,
225 wait_queue_t wq,
232 wq->wq_fifo = ((policy & SYNC_POLICY_REVERSED) == 0);
233 wq->wq_type = _WAIT_QUEUE_inited;
234 wq->wq_eventmask = 0;
235 queue_init(&wq->wq_queue);
236 hw_lock_init(&wq->wq_interlock);
255 wait_queue_t wq; local
258 wq = (wait_queue_t) zalloc(_wait_queue_zone);
259 if (wq !
224 wait_queue_init( wait_queue_t wq, int policy) argument
277 wait_queue_free( wait_queue_t wq) argument
483 wait_queue_global( wait_queue_t wq) argument
502 wait_queue_member_locked( wait_queue_t wq, wait_queue_set_t wq_set) argument
539 wait_queue_member( wait_queue_t wq, wait_queue_set_t wq_set) argument
571 wait_queue_link_internal( wait_queue_t wq, wait_queue_set_t wq_set, wait_queue_link_t wql) argument
638 wait_queue_link_noalloc( wait_queue_t wq, wait_queue_set_t wq_set, wait_queue_link_t wql) argument
657 wait_queue_link( wait_queue_t wq, wait_queue_set_t wq_set) argument
702 wait_queue_unlink_locked( wait_queue_t wq, wait_queue_set_t wq_set, wait_queue_link_t wql) argument
734 wait_queue_unlink_nofree( wait_queue_t wq, wait_queue_set_t wq_set, wait_queue_link_t *wqlp) argument
787 wait_queue_unlink( wait_queue_t wq, wait_queue_set_t wq_set) argument
844 wait_queue_unlink_all_nofree_locked( wait_queue_t wq, queue_t links) argument
887 wait_queue_unlink_all_nofree( wait_queue_t wq, queue_t links) argument
916 wait_queue_unlink_all_locked( wait_queue_t wq, queue_t links) argument
963 wait_queue_unlink_all( wait_queue_t wq) argument
1016 wait_queue_t wq; local
1072 wait_queue_t wq; local
1131 wait_queue_t wq; local
1180 wait_queue_assert_wait64_locked( wait_queue_t wq, event64_t event, wait_interrupt_t interruptible, wait_timeout_urgency_t urgency, uint64_t deadline, uint64_t leeway, thread_t thread) argument
1255 wait_queue_assert_wait( wait_queue_t wq, event_t event, wait_interrupt_t interruptible, uint64_t deadline) argument
1294 wait_queue_assert_wait_with_leeway( wait_queue_t wq, event_t event, wait_interrupt_t interruptible, wait_timeout_urgency_t urgency, uint64_t deadline, uint64_t leeway) argument
1332 wait_queue_assert_wait64( wait_queue_t wq, event64_t event, wait_interrupt_t interruptible, uint64_t deadline) argument
1369 wait_queue_assert_wait64_with_leeway( wait_queue_t wq, event64_t event, wait_interrupt_t interruptible, wait_timeout_urgency_t urgency, uint64_t deadline, uint64_t leeway) argument
1411 _wait_queue_select64_all( wait_queue_t wq, event64_t event, queue_t wake_queue) argument
1504 wait_queue_wakeup64_all_locked( wait_queue_t wq, event64_t event, wait_result_t result, boolean_t unlock) argument
1556 wait_queue_wakeup_all( wait_queue_t wq, event_t event, wait_result_t result) argument
1593 wait_queue_wakeup64_all( wait_queue_t wq, event64_t event, wait_result_t result) argument
1629 _wait_queue_select64_one( wait_queue_t wq, event64_t event) argument
1800 _wait_queue_select64_thread( wait_queue_t wq, event64_t event, thread_t thread) argument
1869 wait_queue_wakeup64_identity_locked( wait_queue_t wq, event64_t event, wait_result_t result, boolean_t unlock) argument
1907 wait_queue_wakeup64_one_locked( wait_queue_t wq, event64_t event, wait_result_t result, boolean_t unlock) argument
1945 wait_queue_wakeup_one( wait_queue_t wq, event_t event, wait_result_t result, int priority) argument
1997 wait_queue_wakeup64_one( wait_queue_t wq, event64_t event, wait_result_t result) argument
2048 wait_queue_wakeup64_thread_locked( wait_queue_t wq, event64_t event, thread_t thread, wait_result_t result, boolean_t unlock) argument
2096 wait_queue_wakeup_thread( wait_queue_t wq, event_t event, thread_t thread, wait_result_t result) argument
2144 wait_queue_wakeup64_thread( wait_queue_t wq, event64_t event, thread_t thread, wait_result_t result) argument
[all...]
H A Dwait_queue.h156 #define wait_queue_is_queue(wq) \
157 ((wq)->wq_type == _WAIT_QUEUE_inited)
162 #define wait_queue_is_valid(wq) \
163 (((wq)->wq_type & ~1) == _WAIT_QUEUE_inited)
165 #define wait_queue_empty(wq) (queue_empty(&(wq)->wq_queue))
167 #define wait_queue_held(wq) (hw_lock_held(&(wq)->wq_interlock))
168 #define wait_queue_lock_try(wq) (hw_lock_try(&(wq)
183 wait_queue_lock(wait_queue_t wq) argument
204 wait_queue_unlock(wait_queue_t wq) argument
[all...]
H A Dsched_prim.c1158 register wait_queue_t wq; local
1169 wq = &wait_queues[index];
1170 return wait_queue_assert_wait(wq, event, interruptible, 0);
1580 wait_queue_t wq = thread->wait_queue; local
1587 if (wq != WAIT_QUEUE_NULL) {
1588 if (wait_queue_lock_try(wq)) {
1589 wait_queue_pull_thread_locked(wq, thread, TRUE);
1597 if (wq != thread->wait_queue)
1607 panic("clear_wait_internal: deadlock: thread=%p, wq=%p, cpu=%d\n",
1608 thread, wq, cpu_numbe
1665 register wait_queue_t wq; local
[all...]
/xnu-2782.1.97/bsd/kern/
H A Dkern_aio.c196 static void aio_workq_init(aio_workq_t wq);
197 static void aio_workq_lock_spin(aio_workq_t wq);
198 static void aio_workq_unlock(aio_workq_t wq);
199 static lck_mtx_t* aio_workq_mutex(aio_workq_t wq);
301 aio_workq_init(aio_workq_t wq) argument
303 TAILQ_INIT(&wq->aioq_entries);
304 wq->aioq_count = 0;
305 lck_mtx_init(&wq->aioq_mtx, aio_queue_lock_grp, aio_lock_attr);
306 wq->aioq_waitq = wait_queue_alloc(SYNC_POLICY_FIFO);
479 aio_workq_lock_spin(aio_workq_t wq) argument
485 aio_workq_unlock(aio_workq_t wq) argument
491 aio_workq_mutex(aio_workq_t wq) argument
[all...]
H A Dkern_event.c2597 knote_link_wait_queue(struct knote *kn, struct wait_queue *wq, wait_queue_link_t wql) argument
2602 kr = wait_queue_link_noalloc(wq, kq->kq_wqs, wql);
2621 knote_unlink_wait_queue(struct knote *kn, struct wait_queue *wq, wait_queue_link_t *wqlp) argument
2626 kr = wait_queue_unlink_nofree(wq, kq->kq_wqs, wqlp);
/xnu-2782.1.97/bsd/sys/
H A Devent.h473 extern int knote_link_wait_queue(struct knote *kn, struct wait_queue *wq, wait_queue_link_t wql);
474 extern int knote_unlink_wait_queue(struct knote *kn, struct wait_queue *wq, wait_queue_link_t *wqlp);

Completed in 38 milliseconds