Lines Matching full:notifier

43         if (!ossl_rio_notifier_init(&rtor->notifier))  in ossl_quic_reactor_init()
47 ossl_rio_notifier_cleanup(&rtor->notifier); in ossl_quic_reactor_init()
65 ossl_rio_notifier_cleanup(&rtor->notifier); in ossl_quic_reactor_cleanup()
159 return rtor->have_notifier ? &rtor->notifier : NULL; in ossl_quic_reactor_get0_notifier()
245 /* Check for notifier FD readability. */ in poll_two_fds()
424 * When this happens, we need to wake those threads using the notifier. in rtor_notify_other_threads()
426 * enters block_until_pred) due to the notifier FD becoming readable. in rtor_notify_other_threads()
427 * Therefore, signal the notifier, and use a CV to detect when all other in rtor_notify_other_threads()
435 /* Signal the notifier to wake up all threads. */ in rtor_notify_other_threads()
437 ossl_rio_notifier_signal(&rtor->notifier); in rtor_notify_other_threads()
444 * unsignalling the notifier. in rtor_notify_other_threads()
469 = (rtor->have_notifier ? ossl_rio_notifier_as_fd(&rtor->notifier) in ossl_quic_reactor_block_until_pred()
504 * we cannot unsignal the notifier until all threads have had an in ossl_quic_reactor_block_until_pred()
516 * sees that cur_blocking_waiters > 0 and signals the notifier in ossl_quic_reactor_block_until_pred()
521 * Notifier is still signalled, so T3 immediately wakes again in ossl_quic_reactor_block_until_pred()
524 * T1, T2 are also woken by the notifier but never see in ossl_quic_reactor_block_until_pred()
525 * cur_blocking_waiters drop to 0, so never unsignal the notifier. in ossl_quic_reactor_block_until_pred()
528 * notifier: in ossl_quic_reactor_block_until_pred()
531 * allowed to exit due to the notifier being signalled. in ossl_quic_reactor_block_until_pred()
534 * cur_blocking_waiters to 0 unsignals the notifier and is then in ossl_quic_reactor_block_until_pred()
576 ossl_rio_notifier_unsignal(&rtor->notifier); in ossl_quic_reactor_leave_blocking_section()