osfmk/kern/wait_queue.c

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);