Lines Matching refs:sq_flags
482 EQUIV(sq->sq_head, (sq->sq_flags & SQ_MESSAGES)); \
496 sq->sq_flags |= SQ_MESSAGES; \
538 ASSERT((sq->sq_flags & SQ_MESSAGES) != 0); \
564 sq->sq_flags &= ~SQ_MESSAGES; \
569 (sq->sq_flags & SQ_QUEUED) == 0); \
820 ASSERT(sq->sq_flags == 0); in syncq_destructor()
1699 sq->sq_flags |= SQ_WANTWAKEUP; in wait_syncq()
1721 sq->sq_flags |= SQ_WANTWAKEUP; in wait_q_syncq()
1872 if (!(passyncq->sq_flags & SQ_BLOCKED)) in mlink_file()
1963 if (!(passyncq->sq_flags & SQ_BLOCKED)) in mlink_file()
2119 sq->sq_flags |= SQ_WANTWAKEUP; in munlink()
2125 if (!(passyncq->sq_flags & SQ_BLOCKED)) { in munlink()
2197 sq->sq_flags |= SQ_WANTWAKEUP; in munlink()
2593 ASSERT((sq->sq_flags & ~SQ_TYPES_IN_FLAGS) == 0); in setq()
2597 sq->sq_flags = (sqtype & SQ_TYPES_IN_FLAGS); in setq()
2628 sq->sq_flags = rq->q_syncq->sq_flags; in setq()
2652 ASSERT((rq->q_syncq->sq_flags & SQ_TYPES_IN_FLAGS) == in setq()
2654 ASSERT((wq->q_syncq->sq_flags & SQ_TYPES_IN_FLAGS) == in setq()
2691 sq->sq_flags = sqtype & SQ_TYPES_IN_FLAGS; in hold_dm()
3419 sq->sq_flags = 0; in allocq()
3844 sq->sq_flags |= SQ_WANTWAKEUP; in wait_sq_svc()
4686 sq->sq_flags |= SQ_WANTWAKEUP; in strlock()
4900 if (sq->sq_flags & SQ_WANTWAKEUP) { in removeq()
4901 sq->sq_flags &= ~SQ_WANTWAKEUP; in removeq()
4908 if (wsq->sq_flags & SQ_WANTWAKEUP) { in removeq()
4909 wsq->sq_flags &= ~SQ_WANTWAKEUP; in removeq()
4932 if (sq->sq_flags & SQ_WANTWAKEUP) { in removeq()
4933 sq->sq_flags &= ~SQ_WANTWAKEUP; in removeq()
4972 if (qp->q_syncqmsgs != 0 || (qp->q_syncq->sq_flags & SQ_EVENTS)) in removeq()
4975 (wqp->q_syncq->sq_flags & SQ_EVENTS)) in removeq()
5055 while ((sq->sq_flags & flag) || in blocksq()
5057 sq->sq_flags |= SQ_WANTWAKEUP; in blocksq()
5069 sq->sq_flags |= flag; in blocksq()
5102 ASSERT(sq->sq_flags & resetflag); in unblocksq()
5103 flags = sq->sq_flags & ~resetflag; in unblocksq()
5104 sq->sq_flags = flags; in unblocksq()
5110 sq->sq_flags = flags; in unblocksq()
5136 ASSERT(sq->sq_flags & resetflag); in dropsq()
5137 flags = sq->sq_flags & ~resetflag; in dropsq()
5142 sq->sq_flags = flags; in dropsq()
5161 flags = sq->sq_flags; in emptysq()
5367 return ((q->q_syncq->sq_flags & SQ_FROZEN) != 0); in frozenstr()
5420 flags = sq->sq_flags; in entersq()
5439 sq->sq_flags = flags | SQ_WANTWAKEUP; in entersq()
5449 flags = sq->sq_flags; in entersq()
5475 flags = sq->sq_flags; in entersq()
5494 sq->sq_flags = flags | SQ_WANTWAKEUP; in entersq()
5497 flags = sq->sq_flags; in entersq()
5506 sq->sq_flags |= SQ_EXCL; in entersq()
5540 flags = sq->sq_flags; in leavesq()
5561 sq->sq_flags = flags & ~SQ_EXCL; in leavesq()
5574 sq->sq_flags = flags & ~SQ_EXCL; in leavesq()
5615 flags = sq->sq_flags; in releaseq()
5621 sq->sq_flags = flags; in releaseq()
5706 sq->sq_flags = 0; in free_syncq()
5762 while (outer->sq_flags & flags) { in outer_enter()
5763 outer->sq_flags |= SQ_WANTWAKEUP; in outer_enter()
5767 ASSERT(!(outer->sq_flags & SQ_WRITER)); in outer_enter()
5768 outer->sq_flags |= SQ_WRITER; in outer_enter()
5781 sq->sq_flags |= SQ_WRITER; in outer_enter()
5808 sq->sq_flags |= SQ_WANTWAKEUP; in outer_enter()
5825 if (outer->sq_flags & (flags & ~SQ_WRITER)) { in outer_enter()
5859 flags = outer->sq_flags; in outer_exit()
5860 ASSERT(outer->sq_flags & SQ_WRITER); in outer_exit()
5863 flags = outer->sq_flags; in outer_exit()
5875 ASSERT(!(outer->sq_flags & SQ_QUEUED)); in outer_exit()
5878 outer->sq_flags = flags; in outer_exit()
5883 flags = outer->sq_flags; in outer_exit()
5889 outer->sq_flags = flags; in outer_exit()
5913 ASSERT(outer->sq_flags & SQ_BLOCKED); in outer_insert()
5914 ASSERT(!(outer->sq_flags & SQ_WRITER)); in outer_insert()
5943 ASSERT(outer->sq_flags & SQ_BLOCKED); in outer_remove()
5944 ASSERT(!(outer->sq_flags & SQ_WRITER)); in outer_remove()
5978 outer->sq_flags |= SQ_EVENTS; in queue_writer()
5984 ASSERT(outer->sq_flags & SQ_EVENTS); in queue_writer()
6016 flags = outer->sq_flags; in qwriter_outer()
6036 osq->sq_flags |= SQ_WRITER; in qwriter_outer()
6045 osq->sq_flags |= SQ_WRITER; in qwriter_outer()
6048 ASSERT(osq->sq_flags & SQ_WRITER); in qwriter_outer()
6081 sq->sq_flags |= SQ_WRITER; in qwriter_outer()
6098 outer->sq_flags = flags; in qwriter_outer()
6104 ASSERT(outer->sq_flags & SQ_WRITER); in qwriter_outer()
6105 flags = outer->sq_flags; in qwriter_outer()
6111 outer->sq_flags = flags; in qwriter_outer()
6115 outer->sq_flags = flags; in qwriter_outer()
6143 ASSERT(!(outer->sq_flags & SQ_MESSAGES)); in write_now()
6144 ASSERT((outer->sq_flags & SQ_EVENTS)); in write_now()
6149 outer->sq_flags &= ~SQ_EVENTS; in write_now()
6201 uint16_t flags = sq->sq_flags; in sq_run_events()
6226 ASSERT(sq->sq_flags & SQ_EVENTS); in sq_run_events()
6243 sq->sq_flags &= ~SQ_EVENTS; in sq_run_events()
6256 flags = sq->sq_flags; in sq_run_events()
6260 ASSERT(!(sq->sq_flags & SQ_EVENTS)); in sq_run_events()
6270 sq->sq_flags = flags; in sq_run_events()
6297 sq->sq_flags |= SQ_EVENTS; in sqfill_events()
6301 ASSERT(sq->sq_flags & SQ_EVENTS); in sqfill_events()
6339 ASSERT((sq->sq_flags & SQ_EXCL) == 0); in sqfill_events()
6340 sq->sq_flags |= SQ_EXCL; in sqfill_events()
6358 sq->sq_flags &= ~SQ_EXCL; in sqfill_events()
6363 ASSERT(!(sq->sq_flags & SQ_EXCL)); in sqfill_events()
6372 if (!(sq->sq_flags & SQ_STAYAWAY) && (sq->sq_flags & SQ_QUEUED)) in sqfill_events()
6400 uint16_t flags = sq->sq_flags; in drain_syncq()
6445 sq->sq_flags = flags; in drain_syncq()
6471 sq->sq_flags |= SQ_EXCL; in drain_syncq()
6488 while ((flags = sq->sq_flags) & SQ_QUEUED) { in drain_syncq()
6503 ASSERT(sq->sq_flags & SQ_EVENTS); in drain_syncq()
6514 sq->sq_flags = flags | SQ_EXCL; in drain_syncq()
6528 ASSERT(sq->sq_flags & SQ_EXCL); in drain_syncq()
6529 sq->sq_flags &= ~SQ_EXCL; in drain_syncq()
6536 ASSERT((sq->sq_flags & SQ_EXCL) || (type & SQ_CIPUT)); in drain_syncq()
6541 ASSERT(!(sq->sq_flags & SQ_EVENTS)); in drain_syncq()
6589 flags = sq->sq_flags; in drain_syncq()
6621 sq->sq_flags = flags; in drain_syncq()
6687 ASSERT((sq->sq_flags & (SQ_EXCL|SQ_CIPUT))); in qdrain_syncq()
6688 ASSERT(!((sq->sq_type & SQ_CIPUT) && (sq->sq_flags & SQ_EXCL))); in qdrain_syncq()
6689 ASSERT((sq->sq_type & SQ_CIPUT) || (sq->sq_flags & SQ_EXCL)); in qdrain_syncq()
6752 if (sq->sq_flags & (SQ_STAYAWAY | SQ_EVENTS)) { in qdrain_syncq()
6819 if ((sq->sq_type & SQ_CIPUT) && (sq->sq_flags & SQ_EXCL)) { in qdrain_syncq()
6821 sq->sq_flags &= ~SQ_EXCL; in qdrain_syncq()
6832 (sq->sq_flags & (SQ_STAYAWAY | SQ_EVENTS))); in qdrain_syncq()
6942 ASSERT(sq->sq_flags & SQ_QUEUED); in qfill_syncq()
6990 ASSERT(sq->sq_flags & SQ_EVENTS); in flush_syncq()
7010 sq->sq_flags &= ~SQ_EVENTS; in flush_syncq()
7065 if ((qp != NULL) && (sq->sq_flags & SQ_WANTWAKEUP)) { in flush_syncq()
7066 sq->sq_flags &= ~SQ_WANTWAKEUP; in flush_syncq()
7095 if (sq->sq_flags & SQ_WANTWAKEUP) { in flush_syncq()
7096 sq->sq_flags &= ~SQ_WANTWAKEUP; in flush_syncq()
7226 ASSERT(sq->sq_flags & SQ_EVENTS); in propagate_syncq()
7245 sq->sq_flags &= ~SQ_EVENTS; in propagate_syncq()
7254 flags = sq->sq_flags; in propagate_syncq()
7261 sq->sq_flags = flags; in propagate_syncq()
7295 sq->sq_flags |= SQ_EXCL; in qwriter_inner()
7419 while ((sq->sq_flags & waitflags) || (!(type & SQ_CICB) &&count != 0)) { in qcallbwrapper()
7436 sq->sq_flags |= SQ_WANTWAKEUP; in qcallbwrapper()
7452 sq->sq_flags |= SQ_EXCL; in qcallbwrapper()
7496 uint16_t flags = sq->sq_flags; in putnext_tail()
7513 sq->sq_flags = flags; in putnext_tail()
7847 if (sq->sq_flags & SQ_BLOCKED) in pass_wput()