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

/darwin-on-arm/xnu/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 queue_init(&wq->wq_queue);
235 hw_lock_init(&wq->wq_interlock);
254 wait_queue_t wq; local
257 wq = (wait_queue_t) zalloc(_wait_queue_zone);
258 if (wq != WAIT_QUEUE_NULL) {
259 ret = wait_queue_init(wq, polic
224 wait_queue_init( wait_queue_t wq, int policy) argument
276 wait_queue_free( wait_queue_t wq) argument
485 wait_queue_member_locked( wait_queue_t wq, wait_queue_set_t wq_set) argument
522 wait_queue_member( wait_queue_t wq, wait_queue_set_t wq_set) argument
554 wait_queue_link_internal( wait_queue_t wq, wait_queue_set_t wq_set, wait_queue_link_t wql) argument
621 wait_queue_link_noalloc( wait_queue_t wq, wait_queue_set_t wq_set, wait_queue_link_t wql) argument
640 wait_queue_link( wait_queue_t wq, wait_queue_set_t wq_set) argument
685 wait_queue_unlink_locked( wait_queue_t wq, wait_queue_set_t wq_set, wait_queue_link_t wql) argument
717 wait_queue_unlink_nofree( wait_queue_t wq, wait_queue_set_t wq_set, wait_queue_link_t *wqlp) argument
770 wait_queue_unlink( wait_queue_t wq, wait_queue_set_t wq_set) argument
827 wait_queue_unlink_all_nofree_locked( wait_queue_t wq, queue_t links) argument
870 wait_queue_unlink_all_nofree( wait_queue_t wq, queue_t links) argument
899 wait_queue_unlink_all_locked( wait_queue_t wq, queue_t links) argument
946 wait_queue_unlink_all( wait_queue_t wq) argument
999 wait_queue_t wq; local
1055 wait_queue_t wq; local
1114 wait_queue_t wq; local
1163 wait_queue_assert_wait64_locked( wait_queue_t wq, event64_t event, wait_interrupt_t interruptible, uint64_t deadline, thread_t thread) argument
1234 wait_queue_assert_wait( wait_queue_t wq, event_t event, wait_interrupt_t interruptible, uint64_t deadline) argument
1268 wait_queue_assert_wait64( wait_queue_t wq, event64_t event, wait_interrupt_t interruptible, uint64_t deadline) argument
1306 _wait_queue_select64_all( wait_queue_t wq, event64_t event, queue_t wake_queue) argument
1379 wait_queue_wakeup64_all_locked( wait_queue_t wq, event64_t event, wait_result_t result, boolean_t unlock) argument
1431 wait_queue_wakeup_all( wait_queue_t wq, event_t event, wait_result_t result) argument
1468 wait_queue_wakeup64_all( wait_queue_t wq, event64_t event, wait_result_t result) argument
1504 _wait_queue_select64_one( wait_queue_t wq, event64_t event) argument
1622 _wait_queue_select64_thread( wait_queue_t wq, event64_t event, thread_t thread) argument
1689 wait_queue_wakeup64_identity_locked( wait_queue_t wq, event64_t event, wait_result_t result, boolean_t unlock) argument
1727 wait_queue_wakeup64_one_locked( wait_queue_t wq, event64_t event, wait_result_t result, boolean_t unlock) argument
1765 wait_queue_wakeup_one( wait_queue_t wq, event_t event, wait_result_t result, int priority) argument
1817 wait_queue_wakeup64_one( wait_queue_t wq, event64_t event, wait_result_t result) argument
1868 wait_queue_wakeup64_thread_locked( wait_queue_t wq, event64_t event, thread_t thread, wait_result_t result, boolean_t unlock) argument
1916 wait_queue_wakeup_thread( wait_queue_t wq, event_t event, thread_t thread, wait_result_t result) argument
1965 wait_queue_wakeup64_thread( wait_queue_t wq, event64_t event, thread_t thread, wait_result_t result) argument
[all...]
H A Dwait_queue.h142 #define wait_queue_is_queue(wq) \
143 ((wq)->wq_type == _WAIT_QUEUE_inited)
148 #define wait_queue_is_valid(wq) \
149 (((wq)->wq_type & ~1) == _WAIT_QUEUE_inited)
151 #define wait_queue_empty(wq) (queue_empty(&(wq)->wq_queue))
153 #define wait_queue_held(wq) (hw_lock_held(&(wq)->wq_interlock))
154 #define wait_queue_lock_try(wq) (hw_lock_try(&(wq)
169 wait_queue_lock(wait_queue_t wq) argument
189 wait_queue_unlock(wait_queue_t wq) argument
[all...]
H A Dsync_lock.c545 wait_queue_t wq = &ulock->wait_queue; local
550 wait_queue_lock(wq);
551 wqthread = wait_queue_wakeup64_identity_locked(wq,
622 wait_queue_t wq = &ulock->wait_queue; local
630 wait_queue_lock(wq);
632 wq,
760 wait_queue_t wq = &ulock->wait_queue; local
767 if (wait_queue_wakeup64_thread(wq,
H A Dsched_prim.c1127 register wait_queue_t wq; local
1137 wq = &wait_queues[index];
1138 return wait_queue_assert_wait(wq, event, interruptible, 0);
1494 wait_queue_t wq = thread->wait_queue; local
1501 if (wq != WAIT_QUEUE_NULL) {
1502 if (wait_queue_lock_try(wq)) {
1503 wait_queue_pull_thread_locked(wq, thread, TRUE);
1511 if (wq != thread->wait_queue)
1521 panic("clear_wait_internal: deadlock: thread=%p, wq=%p, cpu=%d\n",
1522 thread, wq, cpu_numbe
1579 register wait_queue_t wq; local
[all...]
/darwin-on-arm/xnu/bsd/kern/
H A Dpthread_synch.c127 static boolean_t workqueue_run_nextreq(proc_t p, struct workqueue *wq, thread_t th, boolean_t force_oc,
130 static boolean_t workqueue_run_one(proc_t p, struct workqueue *wq, boolean_t overcommit, int priority);
140 static boolean_t workqueue_addnewthread(struct workqueue *wq, boolean_t oc_thread);
552 workqueue_interval_timer_start(struct workqueue *wq) argument
556 if (wq->wq_timer_interval == 0)
557 wq->wq_timer_interval = wq_stalled_window_usecs;
559 wq->wq_timer_interval = wq->wq_timer_interval * 2;
561 if (wq->wq_timer_interval > wq_max_timer_interval_usecs)
562 wq
626 workqueue_add_timer(struct workqueue *wq, __unused int param1) argument
787 struct workqueue *wq; local
884 struct workqueue *wq; local
949 struct workqueue *wq; local
1015 workqueue_addnewthread(struct workqueue *wq, boolean_t oc_thread) argument
1138 struct workqueue * wq; local
1257 struct workqueue *wq; local
1377 struct workqueue * wq; local
1431 struct workqueue * wq; local
1493 workqueue_run_one(proc_t p, struct workqueue *wq, boolean_t overcommit, int priority) argument
1526 workqueue_run_nextreq(proc_t p, struct workqueue *wq, thread_t thread, boolean_t force_oc, boolean_t overcommit, int oc_prio, int oc_affinity) argument
2296 struct workqueue * wq; local
[all...]
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.c2456 knote_link_wait_queue(struct knote *kn, struct wait_queue *wq, wait_queue_link_t wql) argument
2461 kr = wait_queue_link_noalloc(wq, kq->kq_wqs, wql);
2480 knote_unlink_wait_queue(struct knote *kn, struct wait_queue *wq, wait_queue_link_t *wqlp) argument
2485 kr = wait_queue_unlink_nofree(wq, kq->kq_wqs, wqlp);
H A Dpthread_support.c397 #define KSYN_WQ_WAITING 8 /* threads waiting for this wq to be available */
477 int ksyn_wqfind(user_addr_t mutex, uint32_t mgen, uint32_t ugen, uint32_t rw_wc, uint64_t tid, int flags, int wqtype , ksyn_wait_queue_t * wq);
2003 /* drops the wq lock */
2787 /* wait for the wq to be free */
2872 /* wait for the wq to be free */
/darwin-on-arm/xnu/bsd/sys/
H A Devent.h423 extern int knote_link_wait_queue(struct knote *kn, struct wait_queue *wq, wait_queue_link_t wql);
424 extern int knote_unlink_wait_queue(struct knote *kn, struct wait_queue *wq, wait_queue_link_t *wqlp);

Completed in 109 milliseconds