sys/kern/subr_turnstile.c

110  * Each turnstile contains three lists of threads.  The two ts_blocked lists
123 	struct threadqueue ts_blocked[2];	/* (c + q) Blocked threads. */
329 		TAILQ_REMOVE(&ts->ts_blocked[queue], td, td_lockq);
330 		TAILQ_FOREACH(td1, &ts->ts_blocked[queue], td_lockq) {
337 			TAILQ_INSERT_TAIL(&ts->ts_blocked[queue], td, td_lockq);
445 	if (td == TAILQ_FIRST(&ts->ts_blocked[td->td_tsqueue]) &&
480 	MPASS(TAILQ_EMPTY(&ts->ts_blocked[TS_EXCLUSIVE_QUEUE]));
481 	MPASS(TAILQ_EMPTY(&ts->ts_blocked[TS_SHARED_QUEUE]));
496 	TAILQ_INIT(&ts->ts_blocked[TS_EXCLUSIVE_QUEUE]);
497 	TAILQ_INIT(&ts->ts_blocked[TS_SHARED_QUEUE]);
626 	std = TAILQ_FIRST(&ts->ts_blocked[TS_SHARED_QUEUE]);
627 	xtd = TAILQ_FIRST(&ts->ts_blocked[TS_EXCLUSIVE_QUEUE]);
706 		KASSERT(TAILQ_EMPTY(&ts->ts_blocked[TS_EXCLUSIVE_QUEUE]),
708 		KASSERT(TAILQ_EMPTY(&ts->ts_blocked[TS_SHARED_QUEUE]),
714 		TAILQ_INSERT_TAIL(&ts->ts_blocked[queue], td, td_lockq);
718 		TAILQ_FOREACH(td1, &ts->ts_blocked[queue], td_lockq)
725 			TAILQ_INSERT_TAIL(&ts->ts_blocked[queue], td, td_lockq);
781 	td = TAILQ_FIRST(&ts->ts_blocked[queue]);
784 	TAILQ_REMOVE(&ts->ts_blocked[queue], td, td_lockq);
793 	empty = TAILQ_EMPTY(&ts->ts_blocked[TS_EXCLUSIVE_QUEUE]) &&
794 	    TAILQ_EMPTY(&ts->ts_blocked[TS_SHARED_QUEUE]);
838 	TAILQ_CONCAT(&ts->ts_pending, &ts->ts_blocked[queue], td_lockq);
885 	if (TAILQ_EMPTY(&ts->ts_blocked[TS_EXCLUSIVE_QUEUE]) &&
886 	    TAILQ_EMPTY(&ts->ts_blocked[TS_SHARED_QUEUE]))
960 	MPASS(!TAILQ_EMPTY(&ts->ts_blocked[TS_EXCLUSIVE_QUEUE]) ||
961 	    !TAILQ_EMPTY(&ts->ts_blocked[TS_SHARED_QUEUE]));
1006 	return (TAILQ_FIRST(&ts->ts_blocked[queue]));
1021 	return (TAILQ_EMPTY(&ts->ts_blocked[queue]));
1089 	print_queue(&ts->ts_blocked[TS_SHARED_QUEUE], "Shared Waiters", "\t");
1090 	print_queue(&ts->ts_blocked[TS_EXCLUSIVE_QUEUE], "Exclusive Waiters",
1279 	TAILQ_FOREACH(td, &ts->ts_blocked[TS_EXCLUSIVE_QUEUE], td_lockq)
1281 	TAILQ_FOREACH(td, &ts->ts_blocked[TS_SHARED_QUEUE], td_lockq)