osfmk/kern/wait_queue.c

83 			wait_queue_set_t	wq_set);
328         wait_queue_set_t wq_set)
334 	if (!wait_queue_is_set(wq_set))
338 	wqs_lock(wq_set);
339 	q = &wq_set->wqs_preposts;
344 	wqs_unlock(wq_set);
364 	wait_queue_set_t wq_set;
366 	wq_set = (wait_queue_set_t) zalloc(_wait_queue_set_zone);
367 	if (wq_set != WAIT_QUEUE_SET_NULL) {
370 		ret = wait_queue_set_init(wq_set, policy);
372 			zfree(_wait_queue_set_zone, wq_set);
373 			wq_set = WAIT_QUEUE_SET_NULL;
376 	return wq_set;
388 	wait_queue_set_t wq_set)
390 	if (!wait_queue_is_set(wq_set))
393 	if (!queue_empty(&wq_set->wqs_wait_queue.wq_queue))
396 	zfree(_wait_queue_set_zone, wq_set);
504 	wait_queue_set_t wq_set)
510 	assert(wait_queue_is_set(wq_set));
521 			if (wql->wql_setqueue == wq_set)
541 	wait_queue_set_t wq_set)
546 	if (!wait_queue_is_set(wq_set))
551 	ret = wait_queue_member_locked(wq, wq_set);
573 	wait_queue_set_t wq_set,
580 	if (!wait_queue_is_valid(wq) || !wait_queue_is_set(wq_set))
596 		    ((wait_queue_link_t)wq_element)->wql_setqueue == wq_set) {
608 	wqs_lock(wq_set);
610 	WAIT_QUEUE_SET_CHECK(wq_set);
618 	wql->wql_setqueue = wq_set;
619 	queue_enter(&wq_set->wqs_setlinks, wql, wait_queue_link_t, wql_setlinks);
621 	wqs_unlock(wq_set);
640 	wait_queue_set_t wq_set,
644 	return wait_queue_link_internal(wq, wq_set, wql);
659 	wait_queue_set_t wq_set)
669 	ret = wait_queue_link_internal(wq, wq_set, wql);
704 	wait_queue_set_t wq_set,
708 	assert(wait_queue_held(&wq_set->wqs_wait_queue));
713 	queue_remove(&wq_set->wqs_setlinks, wql, wait_queue_link_t, wql_setlinks);
715 		queue_t ppq = &wq_set->wqs_preposts;
721 	WAIT_QUEUE_SET_CHECK(wq_set);
736 	wait_queue_set_t wq_set,
744 	if (!wait_queue_is_valid(wq) || !wait_queue_is_set(wq_set)) {
759 			if (wql->wql_setqueue == wq_set) {
761 				wqs_lock(wq_set);
762 				wait_queue_unlink_locked(wq, wq_set, wql);
763 				wqs_unlock(wq_set);
789 	wait_queue_set_t wq_set)
796 	if (!wait_queue_is_valid(wq) || !wait_queue_is_set(wq_set)) {
811 			if (wql->wql_setqueue == wq_set) {
815 				wqs_lock(wq_set);
816 				wait_queue_unlink_locked(wq, wq_set, wql);
817 				wqs_unlock(wq_set);
850 	wait_queue_set_t wq_set;
866 			wq_set = wql->wql_setqueue;
867 			wqs_lock(wq_set);
868 			wait_queue_unlink_locked(wq, wq_set, wql);
869 			wqs_unlock(wq_set);
922 	wait_queue_set_t wq_set;
939 			wq_set = wql->wql_setqueue;
940 			wqs_lock(wq_set);
941 			wait_queue_unlink_locked(wq, wq_set, wql);
942 			wqs_unlock(wq_set);
994 	wait_queue_set_t	wq_set)
996 	return wait_queue_set_unlink_all(wq_set);
1012 	wait_queue_set_t wq_set,
1020 	if (!wait_queue_is_set(wq_set)) {
1026 	wqs_lock(wq_set);
1029 	q = &wq_set->wqs_setlinks;
1033 		WAIT_QUEUE_SET_LINK_CHECK(wq_set, wql);
1036 			wait_queue_unlink_locked(wq, wq_set, wql);
1041 			wqs_unlock(wq_set);
1049 	wait_queue_unlink_all_nofree_locked(&wq_set->wqs_wait_queue, links);
1051 	wqs_unlock(wq_set);
1069 	wait_queue_set_t wq_set)
1078 	if (!wait_queue_is_set(wq_set)) {
1086 	wqs_lock(wq_set);
1089 	q = &wq_set->wqs_setlinks;
1093 		WAIT_QUEUE_SET_LINK_CHECK(wq_set, wql);
1099 			wait_queue_unlink_locked(wq, wq_set, wql);
1105 			wqs_unlock(wq_set);
1114 	wait_queue_unlink_all_locked(&wq_set->wqs_wait_queue, links);
1116 	wqs_unlock(wq_set);
1128 	wait_queue_set_t wq_set,
1134 	assert(wait_queue_is_set(wq_set));
1138 	wqs_lock(wq_set);
1140 	WAIT_QUEUE_SET_CHECK(wq_set);
1147 	WAIT_QUEUE_SET_LINK_CHECK(wq_set, wql);
1152 		wait_queue_unlink_locked(wq, wq_set, wql);
1155 		wqs_unlock(wq_set);
1162 	wqs_unlock(wq_set);