Lines Matching refs:ts_blocked

122 	struct threadqueue ts_blocked[2];	/* (c + q) Blocked threads. */  member
351 TAILQ_REMOVE(&ts->ts_blocked[queue], td, td_lockq); in turnstile_adjust_thread()
352 TAILQ_FOREACH(td1, &ts->ts_blocked[queue], td_lockq) { in turnstile_adjust_thread()
359 TAILQ_INSERT_TAIL(&ts->ts_blocked[queue], td, td_lockq); in turnstile_adjust_thread()
468 if (td == TAILQ_FIRST(&ts->ts_blocked[td->td_tsqueue]) && in turnstile_adjust()
503 MPASS(TAILQ_EMPTY(&ts->ts_blocked[TS_EXCLUSIVE_QUEUE])); in turnstile_dtor()
504 MPASS(TAILQ_EMPTY(&ts->ts_blocked[TS_SHARED_QUEUE])); in turnstile_dtor()
519 TAILQ_INIT(&ts->ts_blocked[TS_EXCLUSIVE_QUEUE]); in turnstile_init()
520 TAILQ_INIT(&ts->ts_blocked[TS_SHARED_QUEUE]); in turnstile_init()
690 std = TAILQ_FIRST(&ts->ts_blocked[TS_SHARED_QUEUE]); in turnstile_first_waiter()
691 xtd = TAILQ_FIRST(&ts->ts_blocked[TS_EXCLUSIVE_QUEUE]); in turnstile_first_waiter()
770 KASSERT(TAILQ_EMPTY(&ts->ts_blocked[TS_EXCLUSIVE_QUEUE]), in turnstile_wait()
772 KASSERT(TAILQ_EMPTY(&ts->ts_blocked[TS_SHARED_QUEUE]), in turnstile_wait()
778 TAILQ_INSERT_TAIL(&ts->ts_blocked[queue], td, td_lockq); in turnstile_wait()
782 TAILQ_FOREACH(td1, &ts->ts_blocked[queue], td_lockq) in turnstile_wait()
789 TAILQ_INSERT_TAIL(&ts->ts_blocked[queue], td, td_lockq); in turnstile_wait()
844 td = TAILQ_FIRST(&ts->ts_blocked[queue]); in turnstile_signal()
847 TAILQ_REMOVE(&ts->ts_blocked[queue], td, td_lockq); in turnstile_signal()
856 empty = TAILQ_EMPTY(&ts->ts_blocked[TS_EXCLUSIVE_QUEUE]) && in turnstile_signal()
857 TAILQ_EMPTY(&ts->ts_blocked[TS_SHARED_QUEUE]); in turnstile_signal()
901 TAILQ_CONCAT(&ts->ts_pending, &ts->ts_blocked[queue], td_lockq); in turnstile_broadcast()
965 if (TAILQ_EMPTY(&ts->ts_blocked[TS_EXCLUSIVE_QUEUE]) && in turnstile_unpend()
966 TAILQ_EMPTY(&ts->ts_blocked[TS_SHARED_QUEUE])) in turnstile_unpend()
1034 MPASS(!TAILQ_EMPTY(&ts->ts_blocked[TS_EXCLUSIVE_QUEUE]) || in turnstile_disown()
1035 !TAILQ_EMPTY(&ts->ts_blocked[TS_SHARED_QUEUE])); in turnstile_disown()
1075 return (TAILQ_FIRST(&ts->ts_blocked[queue])); in turnstile_head()
1090 return (TAILQ_EMPTY(&ts->ts_blocked[queue])); in turnstile_empty()
1157 print_queue(&ts->ts_blocked[TS_SHARED_QUEUE], "Shared Waiters", "\t"); in DB_SHOW_COMMAND()
1158 print_queue(&ts->ts_blocked[TS_EXCLUSIVE_QUEUE], "Exclusive Waiters", in DB_SHOW_COMMAND()
1299 TAILQ_FOREACH(td, &ts->ts_blocked[TS_EXCLUSIVE_QUEUE], td_lockq) in print_waiters()
1301 TAILQ_FOREACH(td, &ts->ts_blocked[TS_SHARED_QUEUE], td_lockq) in print_waiters()