Lines Matching refs:cpr
220 txg_thread_enter(tx_state_t *tx, callb_cpr_t *cpr) in txg_thread_enter() argument
222 CALLB_CPR_INIT(cpr, &tx->tx_sync_lock, callb_generic_cpr, FTAG); in txg_thread_enter()
227 txg_thread_exit(tx_state_t *tx, callb_cpr_t *cpr, kthread_t **tpp) in txg_thread_exit() argument
233 CALLB_CPR_EXIT(cpr); /* drops &tx->tx_sync_lock */ in txg_thread_exit()
238 txg_thread_wait(tx_state_t *tx, callb_cpr_t *cpr, kcondvar_t *cv, clock_t time) in txg_thread_wait() argument
240 CALLB_CPR_SAFE_BEGIN(cpr); in txg_thread_wait()
248 CALLB_CPR_SAFE_END(cpr, &tx->tx_sync_lock); in txg_thread_wait()
451 callb_cpr_t cpr; in txg_sync_thread() local
454 txg_thread_enter(tx, &cpr); in txg_sync_thread()
475 txg_thread_wait(tx, &cpr, &tx->tx_sync_more_cv, timer); in txg_sync_thread()
488 txg_thread_wait(tx, &cpr, &tx->tx_quiesce_done_cv, 0); in txg_sync_thread()
492 txg_thread_exit(tx, &cpr, &tx->tx_sync_thread); in txg_sync_thread()
530 callb_cpr_t cpr; in txg_quiesce_thread() local
532 txg_thread_enter(tx, &cpr); in txg_quiesce_thread()
547 txg_thread_wait(tx, &cpr, &tx->tx_quiesce_more_cv, 0); in txg_quiesce_thread()
550 txg_thread_exit(tx, &cpr, &tx->tx_quiesce_thread); in txg_quiesce_thread()