Searched refs:waitq_type (Results 1 – 7 of 7) sorted by relevance
402 if (waitq_type(waitq) != WQT_QUEUE) { in waitq_is_global()413 switch (waitq_type(wq)) { in waitq_empty()520 if (waitq_type(waitq) == WQT_PORT) { in waitq_get_safeq()539 if (waitq_type(safeq) == WQT_TURNSTILE) { in waitq_thread_insert()599 if (waitq_type(wq) == WQT_TURNSTILE) { in waitq_thread_remove()1134 if (waitq_type(safeq) == WQT_TURNSTILE) { in do_waitq_select_n_locked_queue()1179 waitq_type_t wq_type = waitq_type(waitq); in do_waitq_select_n_locked_sets()1299 switch (waitq_type(waitq)) { in waitq_is_preposted_set()1325 switch (waitq_type(waitq)) { in waitq_assert_wait64_locked()1412 if (waitq_type(safeq) == WQT_TURNSTILE && wait_result == THREAD_WAITING) { in waitq_assert_wait64_locked()[all …]
336 waitq_type(waitq_t wq) in waitq_type() function338 return wq.wq_q->waitq_type; in waitq_type()368 switch (waitq_type(wq)) { in waitq_preposts()380 switch (waitq_type(waitq)) { in waitq_irq_safe()
1996 switch (waitq_type(waitq)) { in thread_get_waiting_turnstile()2052 switch (waitq_type(waitq)) { in thread_get_update_flags_for_turnstile_propagation_stoppage()
1675 assert(waitq_type(waitq) == WQT_TURNSTILE); in kdp_sleep_with_inheritor_find_owner()
992 if (waitq_type(waitq) == WQT_PORT_SET) { in ipc_mqueue_receive_on_thread_and_unlock()1025 } else if (waitq_type(waitq) == WQT_PORT) { in ipc_mqueue_receive_on_thread_and_unlock()1031 panic("Unknown waitq type (%p/0x%x)", waitq, waitq_type(waitq)); in ipc_mqueue_receive_on_thread_and_unlock()1102 if (waitq_type(waitq) == WQT_PORT) { in ipc_mqueue_receive_on_thread_and_unlock()
3265 if (waitq_type(&port->ip_waitq) == WQT_PORT) { in ipc_port_finalize()3309 assert(waitq_type(waitq) == WQT_TURNSTILE); in kdp_mqueue_send_find_owner()3390 if (waitq_type(waitq) == WQT_PORT_SET) { in kdp_mqueue_recv_find_owner()3402 } else if (waitq_type(waitq) == WQT_PORT) { in kdp_mqueue_recv_find_owner()
30 self._ty = unsigned(self._wq.waitq_type) & 0x7