Lines Matching defs:wq_set
81 wait_queue_set_t wq_set);
88 wait_queue_set_t wq_set);
201 wait_queue_set_t wq_set)
203 if (!wait_queue_is_set(wq_set))
206 wqs_lock(wq_set);
207 wq_set->wqs_refcount = 0;
208 wqs_unlock(wq_set);
227 wait_queue_set_t wq_set;
229 wq_set = (wait_queue_set_t) kalloc(sizeof(struct wait_queue_set));
230 if (wq_set != WAIT_QUEUE_SET_NULL) {
233 ret = wait_queue_set_init(wq_set, policy);
235 kfree(wq_set, sizeof(struct wait_queue_set));
236 wq_set = WAIT_QUEUE_SET_NULL;
239 return wq_set;
251 wait_queue_set_t wq_set)
253 if (!wait_queue_is_set(wq_set))
256 if (!queue_empty(&wq_set->wqs_wait_queue.wq_queue))
259 kfree(wq_set, sizeof(struct wait_queue_set));
347 wait_queue_set_t wq_set)
353 assert(wait_queue_is_set(wq_set));
363 if (wql->wql_setqueue == wq_set)
383 wait_queue_set_t wq_set)
388 if (!wait_queue_is_set(wq_set))
393 ret = wait_queue_member_locked(wq, wq_set);
413 wait_queue_set_t wq_set,
420 if (!wait_queue_is_queue(wq) || !wait_queue_is_set(wq_set))
435 ((wait_queue_link_t)wq_element)->wql_setqueue == wq_set) {
447 wqs_lock(wq_set);
449 WAIT_QUEUE_SET_CHECK(wq_set);
453 wql->wql_setqueue = wq_set;
454 queue_enter(&wq_set->wqs_setlinks, wql, wait_queue_link_t, wql_setlinks);
457 wqs_unlock(wq_set);
476 wait_queue_set_t wq_set)
485 ret = wait_queue_link_noalloc(wq, wq_set, wql);
501 wait_queue_set_t wq_set,
505 assert(wait_queue_held(&wq_set->wqs_wait_queue));
510 queue_remove(&wq_set->wqs_setlinks, wql, wait_queue_link_t, wql_setlinks);
514 WAIT_QUEUE_SET_CHECK(wq_set);
528 wait_queue_set_t wq_set)
535 if (!wait_queue_is_queue(wq) || !wait_queue_is_set(wq_set)) {
548 if (wql->wql_setqueue == wq_set) {
549 wqs_lock(wq_set);
550 wait_queue_unlink_locked(wq, wq_set, wql);
551 wqs_unlock(wq_set);
581 wait_queue_set_t wq_set;
607 wq_set = wql->wql_setqueue;
608 wqs_lock(wq_set);
609 wait_queue_unlink_locked(wq, wq_set, wql);
610 wqs_unlock(wq_set);
635 wait_queue_set_t wq_set;
661 wq_set = wql->wql_setqueue;
662 wqs_lock(wq_set);
663 wait_queue_unlink_locked(wq, wq_set, wql);
664 wqs_unlock(wq_set);
692 wait_queue_set_t wq_set)
699 if (!wait_queue_is_set(wq_set)) {
705 wqs_lock(wq_set);
707 q = &wq_set->wqs_setlinks;
711 WAIT_QUEUE_SET_LINK_CHECK(wq_set, wql);
714 wait_queue_unlink_locked(wq, wq_set, wql);
718 wqs_unlock(wq_set);
724 wqs_unlock(wq_set);
733 wait_queue_set_t wq_set)
735 return wait_queue_set_unlink_all_nofree(wq_set);
749 wait_queue_set_t wq_set)
758 if (!wait_queue_is_set(wq_set)) {
766 wqs_lock(wq_set);
768 q = &wq_set->wqs_setlinks;
772 WAIT_QUEUE_SET_LINK_CHECK(wq_set, wql);
775 wait_queue_unlink_locked(wq, wq_set, wql);
780 wqs_unlock(wq_set);
786 wqs_unlock(wq_set);
823 wait_queue_set_t wq_set = wql->wql_setqueue;
825 wqs_lock(wq_set);
826 wait_queue_unlink_locked(wq, wq_set, wql);
827 wqs_unlock(wq_set);
831 *wq_setp = wq_set;