Lines Matching refs:auk_queue

485 	mutex_enter(&(kctx->auk_queue.lock));  in setpolicy()
488 (kctx->auk_queue.cnt >= kctx->auk_queue.hiwater))) in setpolicy()
489 cv_broadcast(&(kctx->auk_queue.write_cv)); in setpolicy()
491 mutex_exit(&(kctx->auk_queue.lock)); in setpolicy()
690 mutex_enter(&(kctx->auk_queue.lock)); in getqctrl()
691 STRUCT_FSET(qctrl, aq_hiwater, kctx->auk_queue.hiwater); in getqctrl()
692 STRUCT_FSET(qctrl, aq_lowater, kctx->auk_queue.lowater); in getqctrl()
693 STRUCT_FSET(qctrl, aq_bufsz, kctx->auk_queue.bufsz); in getqctrl()
694 STRUCT_FSET(qctrl, aq_delay, kctx->auk_queue.delay); in getqctrl()
695 mutex_exit(&(kctx->auk_queue.lock)); in getqctrl()
747 mutex_enter(&(kctx->auk_queue.lock)); in setqctrl()
748 kctx->auk_queue.hiwater = qctrl_tmp.aq_hiwater; in setqctrl()
749 kctx->auk_queue.lowater = qctrl_tmp.aq_lowater; in setqctrl()
750 kctx->auk_queue.bufsz = qctrl_tmp.aq_bufsz; in setqctrl()
751 kctx->auk_queue.delay = qctrl_tmp.aq_delay; in setqctrl()
753 if (kctx->auk_queue.rd_block && in setqctrl()
754 kctx->auk_queue.cnt > kctx->auk_queue.lowater) in setqctrl()
755 cv_broadcast(&(kctx->auk_queue.read_cv)); in setqctrl()
757 if (kctx->auk_queue.wt_block && in setqctrl()
758 kctx->auk_queue.cnt < kctx->auk_queue.hiwater) in setqctrl()
759 cv_broadcast(&(kctx->auk_queue.write_cv)); in setqctrl()
761 mutex_exit(&(kctx->auk_queue.lock)); in setqctrl()
1096 mutex_enter(&(kctx->auk_queue.lock)); in setcond()
1097 if (kctx->auk_queue.wt_block) in setcond()
1098 cv_broadcast(&(kctx->auk_queue.write_cv)); in setcond()
1101 cv_broadcast(&(kctx->auk_queue.read_cv)); in setcond()
1103 mutex_exit(&(kctx->auk_queue.lock)); in setcond()