Lines Matching refs:wq_set
83 wait_queue_set_t wq_set);
327 wait_queue_set_t wq_set)
333 if (!wait_queue_is_set(wq_set))
337 wqs_lock(wq_set);
338 q = &wq_set->wqs_preposts;
343 wqs_unlock(wq_set);
363 wait_queue_set_t wq_set;
365 wq_set = (wait_queue_set_t) zalloc(_wait_queue_set_zone);
366 if (wq_set != WAIT_QUEUE_SET_NULL) {
369 ret = wait_queue_set_init(wq_set, policy);
371 zfree(_wait_queue_set_zone, wq_set);
372 wq_set = WAIT_QUEUE_SET_NULL;
375 return wq_set;
387 wait_queue_set_t wq_set)
389 if (!wait_queue_is_set(wq_set))
392 if (!queue_empty(&wq_set->wqs_wait_queue.wq_queue))
395 zfree(_wait_queue_set_zone, wq_set);
487 wait_queue_set_t wq_set)
493 assert(wait_queue_is_set(wq_set));
504 if (wql->wql_setqueue == wq_set)
524 wait_queue_set_t wq_set)
529 if (!wait_queue_is_set(wq_set))
534 ret = wait_queue_member_locked(wq, wq_set);
556 wait_queue_set_t wq_set,
563 if (!wait_queue_is_valid(wq) || !wait_queue_is_set(wq_set))
579 ((wait_queue_link_t)wq_element)->wql_setqueue == wq_set) {
591 wqs_lock(wq_set);
593 WAIT_QUEUE_SET_CHECK(wq_set);
601 wql->wql_setqueue = wq_set;
602 queue_enter(&wq_set->wqs_setlinks, wql, wait_queue_link_t, wql_setlinks);
604 wqs_unlock(wq_set);
623 wait_queue_set_t wq_set,
627 return wait_queue_link_internal(wq, wq_set, wql);
642 wait_queue_set_t wq_set)
652 ret = wait_queue_link_internal(wq, wq_set, wql);
687 wait_queue_set_t wq_set,
691 assert(wait_queue_held(&wq_set->wqs_wait_queue));
696 queue_remove(&wq_set->wqs_setlinks, wql, wait_queue_link_t, wql_setlinks);
698 queue_t ppq = &wq_set->wqs_preposts;
704 WAIT_QUEUE_SET_CHECK(wq_set);
719 wait_queue_set_t wq_set,
727 if (!wait_queue_is_valid(wq) || !wait_queue_is_set(wq_set)) {
742 if (wql->wql_setqueue == wq_set) {
744 wqs_lock(wq_set);
745 wait_queue_unlink_locked(wq, wq_set, wql);
746 wqs_unlock(wq_set);
772 wait_queue_set_t wq_set)
779 if (!wait_queue_is_valid(wq) || !wait_queue_is_set(wq_set)) {
794 if (wql->wql_setqueue == wq_set) {
798 wqs_lock(wq_set);
799 wait_queue_unlink_locked(wq, wq_set, wql);
800 wqs_unlock(wq_set);
833 wait_queue_set_t wq_set;
849 wq_set = wql->wql_setqueue;
850 wqs_lock(wq_set);
851 wait_queue_unlink_locked(wq, wq_set, wql);
852 wqs_unlock(wq_set);
905 wait_queue_set_t wq_set;
922 wq_set = wql->wql_setqueue;
923 wqs_lock(wq_set);
924 wait_queue_unlink_locked(wq, wq_set, wql);
925 wqs_unlock(wq_set);
977 wait_queue_set_t wq_set)
979 return wait_queue_set_unlink_all(wq_set);
995 wait_queue_set_t wq_set,
1003 if (!wait_queue_is_set(wq_set)) {
1009 wqs_lock(wq_set);
1012 q = &wq_set->wqs_setlinks;
1016 WAIT_QUEUE_SET_LINK_CHECK(wq_set, wql);
1019 wait_queue_unlink_locked(wq, wq_set, wql);
1024 wqs_unlock(wq_set);
1032 wait_queue_unlink_all_nofree_locked(&wq_set->wqs_wait_queue, links);
1034 wqs_unlock(wq_set);
1052 wait_queue_set_t wq_set)
1061 if (!wait_queue_is_set(wq_set)) {
1069 wqs_lock(wq_set);
1072 q = &wq_set->wqs_setlinks;
1076 WAIT_QUEUE_SET_LINK_CHECK(wq_set, wql);
1082 wait_queue_unlink_locked(wq, wq_set, wql);
1088 wqs_unlock(wq_set);
1097 wait_queue_unlink_all_locked(&wq_set->wqs_wait_queue, links);
1099 wqs_unlock(wq_set);
1111 wait_queue_set_t wq_set,
1117 assert(wait_queue_is_set(wq_set));
1121 wqs_lock(wq_set);
1123 WAIT_QUEUE_SET_CHECK(wq_set);
1130 WAIT_QUEUE_SET_LINK_CHECK(wq_set, wql);
1135 wait_queue_unlink_locked(wq, wq_set, wql);
1138 wqs_unlock(wq_set);
1145 wqs_unlock(wq_set);