Searched refs:auk_queue (Results 1 – 5 of 5) sorted by relevance
68 kctx->auk_queue.hiwater = AQ_HIWATER; in au_zone_init()69 kctx->auk_queue.lowater = AQ_LOWATER; in au_zone_init()70 kctx->auk_queue.bufsz = AQ_BUFSZ; in au_zone_init()71 kctx->auk_queue.buflen = AQ_BUFSZ; in au_zone_init()72 kctx->auk_queue.delay = AQ_DELAY; in au_zone_init()112 mutex_enter(&(kctx->auk_queue.lock)); in au_zone_shutdown()114 mutex_exit(&(kctx->auk_queue.lock)); in au_zone_shutdown()133 mutex_enter(&(kctx->auk_queue.lock)); in au_zone_destroy()134 if (kctx->auk_queue.head != NULL) { in au_zone_destroy()135 au_free_rec(kctx->auk_queue.head); in au_zone_destroy()[all …]
374 if (!dontblock && (kctx->auk_queue.cnt >= kctx->auk_queue.hiwater) && in au_enqueue()392 if (kctx->auk_queue.head) in au_enqueue()397 kctx->auk_queue.tail = m; in au_enqueue()400 kctx->auk_queue.lowater && kctx->auk_queue.rd_block) in au_enqueue()435 kctx->auk_queue.cnt -= n; in au_dequeue()442 if (kctx->auk_queue.cnt <= kctx->auk_queue.lowater && in au_dequeue()485 kctx->auk_queue.cnt > kctx->auk_queue.lowater) in audit_sync_block()493 cv_wait(&(kctx->auk_queue.write_cv), &(kctx->auk_queue.lock)); in audit_sync_block()495 } while (kctx->auk_queue.cnt >= kctx->auk_queue.hiwater); in audit_sync_block()513 if (kctx->auk_queue.cnt >= kctx->auk_queue.hiwater) { in audit_async_block()[all …]
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()[all …]
302 struct audit_queue auk_queue; member
485 mutex_enter(&(kctx->auk_queue.lock)); in setpolicy()488 (kctx->auk_queue.cnt >= kctx->auk_queue.hiwater))) in setpolicy()491 mutex_exit(&(kctx->auk_queue.lock)); in setpolicy()690 mutex_enter(&(kctx->auk_queue.lock)); in getqctrl()695 mutex_exit(&(kctx->auk_queue.lock)); in getqctrl()753 if (kctx->auk_queue.rd_block && in setqctrl()754 kctx->auk_queue.cnt > kctx->auk_queue.lowater) in setqctrl()757 if (kctx->auk_queue.wt_block && in setqctrl()758 kctx->auk_queue.cnt < kctx->auk_queue.hiwater) in setqctrl()761 mutex_exit(&(kctx->auk_queue.lock)); in setqctrl()[all …]