Lines Matching refs:sq_flags
478 EQUIV(sq->sq_head, (sq->sq_flags & SQ_MESSAGES)); \
492 sq->sq_flags |= SQ_MESSAGES; \
534 ASSERT((sq->sq_flags & SQ_MESSAGES) != 0); \
560 sq->sq_flags &= ~SQ_MESSAGES; \
565 (sq->sq_flags & SQ_QUEUED) == 0); \
816 ASSERT(sq->sq_flags == 0); in syncq_destructor()
1695 sq->sq_flags |= SQ_WANTWAKEUP; in wait_syncq()
1717 sq->sq_flags |= SQ_WANTWAKEUP; in wait_q_syncq()
1868 if (!(passyncq->sq_flags & SQ_BLOCKED)) in mlink_file()
1903 if (!(passyncq->sq_flags & SQ_BLOCKED)) in mlink_file()
2105 sq->sq_flags |= SQ_WANTWAKEUP; in munlink()
2111 if (!(passyncq->sq_flags & SQ_BLOCKED)) { in munlink()
2183 sq->sq_flags |= SQ_WANTWAKEUP; in munlink()
2568 ASSERT((sq->sq_flags & ~SQ_TYPES_IN_FLAGS) == 0); in setq()
2572 sq->sq_flags = (sqtype & SQ_TYPES_IN_FLAGS); in setq()
2603 sq->sq_flags = rq->q_syncq->sq_flags; in setq()
2627 ASSERT((rq->q_syncq->sq_flags & SQ_TYPES_IN_FLAGS) == in setq()
2629 ASSERT((wq->q_syncq->sq_flags & SQ_TYPES_IN_FLAGS) == in setq()
2666 sq->sq_flags = sqtype & SQ_TYPES_IN_FLAGS; in hold_dm()
3394 sq->sq_flags = 0; in allocq()
3819 sq->sq_flags |= SQ_WANTWAKEUP; in wait_sq_svc()
4661 sq->sq_flags |= SQ_WANTWAKEUP; in strlock()
4875 if (sq->sq_flags & SQ_WANTWAKEUP) { in removeq()
4876 sq->sq_flags &= ~SQ_WANTWAKEUP; in removeq()
4883 if (wsq->sq_flags & SQ_WANTWAKEUP) { in removeq()
4884 wsq->sq_flags &= ~SQ_WANTWAKEUP; in removeq()
4907 if (sq->sq_flags & SQ_WANTWAKEUP) { in removeq()
4908 sq->sq_flags &= ~SQ_WANTWAKEUP; in removeq()
4947 if (qp->q_syncqmsgs != 0 || (qp->q_syncq->sq_flags & SQ_EVENTS)) in removeq()
4950 (wqp->q_syncq->sq_flags & SQ_EVENTS)) in removeq()
5030 while ((sq->sq_flags & flag) || in blocksq()
5032 sq->sq_flags |= SQ_WANTWAKEUP; in blocksq()
5044 sq->sq_flags |= flag; in blocksq()
5077 ASSERT(sq->sq_flags & resetflag); in unblocksq()
5078 flags = sq->sq_flags & ~resetflag; in unblocksq()
5079 sq->sq_flags = flags; in unblocksq()
5085 sq->sq_flags = flags; in unblocksq()
5111 ASSERT(sq->sq_flags & resetflag); in dropsq()
5112 flags = sq->sq_flags & ~resetflag; in dropsq()
5117 sq->sq_flags = flags; in dropsq()
5136 flags = sq->sq_flags; in emptysq()
5342 return ((q->q_syncq->sq_flags & SQ_FROZEN) != 0); in frozenstr()
5395 flags = sq->sq_flags; in entersq()
5414 sq->sq_flags = flags | SQ_WANTWAKEUP; in entersq()
5424 flags = sq->sq_flags; in entersq()
5450 flags = sq->sq_flags; in entersq()
5469 sq->sq_flags = flags | SQ_WANTWAKEUP; in entersq()
5472 flags = sq->sq_flags; in entersq()
5481 sq->sq_flags |= SQ_EXCL; in entersq()
5515 flags = sq->sq_flags; in leavesq()
5536 sq->sq_flags = flags & ~SQ_EXCL; in leavesq()
5549 sq->sq_flags = flags & ~SQ_EXCL; in leavesq()
5590 flags = sq->sq_flags; in releaseq()
5596 sq->sq_flags = flags; in releaseq()
5681 sq->sq_flags = 0; in free_syncq()
5737 while (outer->sq_flags & flags) { in outer_enter()
5738 outer->sq_flags |= SQ_WANTWAKEUP; in outer_enter()
5742 ASSERT(!(outer->sq_flags & SQ_WRITER)); in outer_enter()
5743 outer->sq_flags |= SQ_WRITER; in outer_enter()
5756 sq->sq_flags |= SQ_WRITER; in outer_enter()
5783 sq->sq_flags |= SQ_WANTWAKEUP; in outer_enter()
5800 if (outer->sq_flags & (flags & ~SQ_WRITER)) { in outer_enter()
5834 flags = outer->sq_flags; in outer_exit()
5835 ASSERT(outer->sq_flags & SQ_WRITER); in outer_exit()
5838 flags = outer->sq_flags; in outer_exit()
5850 ASSERT(!(outer->sq_flags & SQ_QUEUED)); in outer_exit()
5853 outer->sq_flags = flags; in outer_exit()
5858 flags = outer->sq_flags; in outer_exit()
5864 outer->sq_flags = flags; in outer_exit()
5888 ASSERT(outer->sq_flags & SQ_BLOCKED); in outer_insert()
5889 ASSERT(!(outer->sq_flags & SQ_WRITER)); in outer_insert()
5918 ASSERT(outer->sq_flags & SQ_BLOCKED); in outer_remove()
5919 ASSERT(!(outer->sq_flags & SQ_WRITER)); in outer_remove()
5953 outer->sq_flags |= SQ_EVENTS; in queue_writer()
5959 ASSERT(outer->sq_flags & SQ_EVENTS); in queue_writer()
5991 flags = outer->sq_flags; in qwriter_outer()
6011 osq->sq_flags |= SQ_WRITER; in qwriter_outer()
6020 osq->sq_flags |= SQ_WRITER; in qwriter_outer()
6023 ASSERT(osq->sq_flags & SQ_WRITER); in qwriter_outer()
6056 sq->sq_flags |= SQ_WRITER; in qwriter_outer()
6073 outer->sq_flags = flags; in qwriter_outer()
6079 ASSERT(outer->sq_flags & SQ_WRITER); in qwriter_outer()
6080 flags = outer->sq_flags; in qwriter_outer()
6086 outer->sq_flags = flags; in qwriter_outer()
6090 outer->sq_flags = flags; in qwriter_outer()
6118 ASSERT(!(outer->sq_flags & SQ_MESSAGES)); in write_now()
6119 ASSERT((outer->sq_flags & SQ_EVENTS)); in write_now()
6124 outer->sq_flags &= ~SQ_EVENTS; in write_now()
6176 uint16_t flags = sq->sq_flags; in sq_run_events()
6201 ASSERT(sq->sq_flags & SQ_EVENTS); in sq_run_events()
6218 sq->sq_flags &= ~SQ_EVENTS; in sq_run_events()
6231 flags = sq->sq_flags; in sq_run_events()
6235 ASSERT(!(sq->sq_flags & SQ_EVENTS)); in sq_run_events()
6245 sq->sq_flags = flags; in sq_run_events()
6272 sq->sq_flags |= SQ_EVENTS; in sqfill_events()
6276 ASSERT(sq->sq_flags & SQ_EVENTS); in sqfill_events()
6314 ASSERT((sq->sq_flags & SQ_EXCL) == 0); in sqfill_events()
6315 sq->sq_flags |= SQ_EXCL; in sqfill_events()
6333 sq->sq_flags &= ~SQ_EXCL; in sqfill_events()
6338 ASSERT(!(sq->sq_flags & SQ_EXCL)); in sqfill_events()
6347 if (!(sq->sq_flags & SQ_STAYAWAY) && (sq->sq_flags & SQ_QUEUED)) in sqfill_events()
6375 uint16_t flags = sq->sq_flags; in drain_syncq()
6420 sq->sq_flags = flags; in drain_syncq()
6446 sq->sq_flags |= SQ_EXCL; in drain_syncq()
6463 while ((flags = sq->sq_flags) & SQ_QUEUED) { in drain_syncq()
6478 ASSERT(sq->sq_flags & SQ_EVENTS); in drain_syncq()
6489 sq->sq_flags = flags | SQ_EXCL; in drain_syncq()
6503 ASSERT(sq->sq_flags & SQ_EXCL); in drain_syncq()
6504 sq->sq_flags &= ~SQ_EXCL; in drain_syncq()
6511 ASSERT((sq->sq_flags & SQ_EXCL) || (type & SQ_CIPUT)); in drain_syncq()
6516 ASSERT(!(sq->sq_flags & SQ_EVENTS)); in drain_syncq()
6564 flags = sq->sq_flags; in drain_syncq()
6596 sq->sq_flags = flags; in drain_syncq()
6662 ASSERT((sq->sq_flags & (SQ_EXCL|SQ_CIPUT))); in qdrain_syncq()
6663 ASSERT(!((sq->sq_type & SQ_CIPUT) && (sq->sq_flags & SQ_EXCL))); in qdrain_syncq()
6664 ASSERT((sq->sq_type & SQ_CIPUT) || (sq->sq_flags & SQ_EXCL)); in qdrain_syncq()
6727 if (sq->sq_flags & (SQ_STAYAWAY | SQ_EVENTS)) { in qdrain_syncq()
6794 if ((sq->sq_type & SQ_CIPUT) && (sq->sq_flags & SQ_EXCL)) { in qdrain_syncq()
6796 sq->sq_flags &= ~SQ_EXCL; in qdrain_syncq()
6807 (sq->sq_flags & (SQ_STAYAWAY | SQ_EVENTS))); in qdrain_syncq()
6917 ASSERT(sq->sq_flags & SQ_QUEUED); in qfill_syncq()
6965 ASSERT(sq->sq_flags & SQ_EVENTS); in flush_syncq()
6985 sq->sq_flags &= ~SQ_EVENTS; in flush_syncq()
7040 if ((qp != NULL) && (sq->sq_flags & SQ_WANTWAKEUP)) { in flush_syncq()
7041 sq->sq_flags &= ~SQ_WANTWAKEUP; in flush_syncq()
7070 if (sq->sq_flags & SQ_WANTWAKEUP) { in flush_syncq()
7071 sq->sq_flags &= ~SQ_WANTWAKEUP; in flush_syncq()
7201 ASSERT(sq->sq_flags & SQ_EVENTS); in propagate_syncq()
7220 sq->sq_flags &= ~SQ_EVENTS; in propagate_syncq()
7229 flags = sq->sq_flags; in propagate_syncq()
7236 sq->sq_flags = flags; in propagate_syncq()
7270 sq->sq_flags |= SQ_EXCL; in qwriter_inner()
7394 while ((sq->sq_flags & waitflags) || (!(type & SQ_CICB) &&count != 0)) { in qcallbwrapper()
7411 sq->sq_flags |= SQ_WANTWAKEUP; in qcallbwrapper()
7427 sq->sq_flags |= SQ_EXCL; in qcallbwrapper()
7471 uint16_t flags = sq->sq_flags; in putnext_tail()
7488 sq->sq_flags = flags; in putnext_tail()
7815 if (sq->sq_flags & SQ_BLOCKED) in pass_wput()