Lines Matching refs:aq_flags
67 int aq_flags; /* Queue flags */ member
179 alq->aq_flags &= ~AQ_ACTIVE; in ald_deactivate()
268 alq->aq_flags |= AQ_SHUTDOWN; in alq_shutdown()
275 if (!(alq->aq_flags & AQ_ACTIVE) && HAS_PENDING_DATA(alq)) { in alq_shutdown()
276 alq->aq_flags |= AQ_ACTIVE; in alq_shutdown()
285 while (alq->aq_flags & AQ_ACTIVE) { in alq_shutdown()
286 alq->aq_flags |= AQ_WANTED; in alq_shutdown()
357 alq->aq_flags |= AQ_FLUSHING; in alq_doio()
384 alq->aq_flags &= ~AQ_FLUSHING; in alq_doio()
409 if (alq->aq_flags & AQ_WANTED) { in alq_doio()
410 alq->aq_flags &= ~AQ_WANTED; in alq_doio()
470 alq->aq_flags |= AQ_ORDERED; in alq_open_flags()
493 (*alqp)->aq_flags |= AQ_LEGACY; in alq_open()
533 alq->aq_flags & AQ_SHUTDOWN || in alq_writen()
534 (((flags & ALQ_NOWAIT) || (!(alq->aq_flags & AQ_ACTIVE) && in alq_writen()
544 if (alq->aq_flags & AQ_ORDERED && alq->aq_waiters > 0) { in alq_writen()
559 while (alq->aq_freebytes < len && !(alq->aq_flags & AQ_SHUTDOWN)) { in alq_writen()
562 alq->aq_flags |= AQ_WANTED; in alq_writen()
576 if (alq->aq_waiters > 0 && !(alq->aq_flags & AQ_ORDERED) && in alq_writen()
577 alq->aq_freebytes < len && !(alq->aq_flags & AQ_WANTED)) in alq_writen()
591 if (alq->aq_flags & AQ_ORDERED) in alq_writen()
599 if (alq->aq_flags & AQ_SHUTDOWN) { in alq_writen()
638 if (!(alq->aq_flags & AQ_ACTIVE) && !(flags & ALQ_NOACTIVATE)) { in alq_writen()
639 alq->aq_flags |= AQ_ACTIVE; in alq_writen()
665 KASSERT((alq->aq_flags & AQ_LEGACY), in alq_write()
729 alq->aq_flags & AQ_SHUTDOWN || in alq_getn()
730 (((flags & ALQ_NOWAIT) || (!(alq->aq_flags & AQ_ACTIVE) && in alq_getn()
740 if (alq->aq_flags & AQ_ORDERED && alq->aq_waiters > 0) { in alq_getn()
755 while (contigbytes < len && !(alq->aq_flags & AQ_SHUTDOWN)) { in alq_getn()
758 alq->aq_flags |= AQ_WANTED; in alq_getn()
777 if (alq->aq_waiters > 0 && !(alq->aq_flags & AQ_ORDERED) && in alq_getn()
778 contigbytes < len && !(alq->aq_flags & AQ_WANTED)) in alq_getn()
792 if (alq->aq_flags & AQ_ORDERED) in alq_getn()
800 if (alq->aq_flags & AQ_SHUTDOWN) { in alq_getn()
821 KASSERT((alq->aq_flags & AQ_LEGACY), in alq_get()
835 if (!(alq->aq_flags & AQ_ACTIVE) && in alq_post_flags()
837 alq->aq_flags |= AQ_ACTIVE; in alq_post_flags()
864 if (alq->aq_flags & AQ_ORDERED) in alq_post_flags()
896 if (HAS_PENDING_DATA(alq) && !(alq->aq_flags & AQ_FLUSHING)) { in alq_flush()
897 if (alq->aq_flags & AQ_ACTIVE) in alq_flush()