Lines Matching refs:auk_queue
398 mutex_enter(&(((au_kcontext_t *)kctx)->auk_queue.lock)); in audit_dont_stop()
399 cv_broadcast(&(((au_kcontext_t *)kctx)->auk_queue.write_cv)); in audit_dont_stop()
400 mutex_exit(&(((au_kcontext_t *)kctx)->auk_queue.lock)); in audit_dont_stop()
418 if (((au_kcontext_t *)kctx)->auk_queue.cnt && in au_queue_kick()
419 ((au_kcontext_t *)kctx)->auk_queue.rd_block) in au_queue_kick()
420 cv_broadcast(&((au_kcontext_t *)kctx)->auk_queue.read_cv); in au_queue_kick()
424 ((au_kcontext_t *)kctx)->auk_queue.delay); in au_queue_kick()
444 (void) timeout(au_queue_kick, kctx, kctx->auk_queue.delay); in au_output_thread()
453 mutex_enter(&(kctx->auk_queue.lock)); in au_output_thread()
454 while (kctx->auk_queue.head == NULL) { in au_output_thread()
456 if (kctx->auk_queue.wt_block) { in au_output_thread()
458 auk_queue.write_cv)); in au_output_thread()
461 kctx->auk_queue.rd_block = 1; in au_output_thread()
464 cv_wait(&(kctx->auk_queue.read_cv), in au_output_thread()
465 &(kctx->auk_queue.lock)); in au_output_thread()
466 kctx->auk_queue.rd_block = 0; in au_output_thread()
469 mutex_exit(&(kctx->auk_queue.lock)); in au_output_thread()
474 kctx->auk_queue.rd_block = 0; in au_output_thread()
476 mutex_exit(&(kctx->auk_queue.lock)); in au_output_thread()