Lines Matching defs:sq
3754 syncq_t *sq;
3801 sq = qp->q_syncq;
3802 mutex_enter(SQLOCK(sq));
3804 count = sq->sq_count;
3805 flags = sq->sq_flags;
3806 ASSERT(sq->sq_ciputctrl == NULL || (flags & SQ_CIPUT));
3813 mutex_exit(SQLOCK(sq));
3821 sq->sq_flags = flags | SQ_WANTWAKEUP;
3822 cv_wait(&sq->sq_wait, SQLOCK(sq));
3823 count = sq->sq_count;
3824 flags = sq->sq_flags;
3833 mutex_exit(SQLOCK(sq));
3838 sq->sq_flags = flags | SQ_EXCL;
3839 sq->sq_count = count + 1;
3840 ASSERT(sq->sq_count != 0); /* Wraparound */
3849 mutex_exit(SQLOCK(sq));
3877 * safe to call rwnext_exit and reacquire SQLOCK(sq).
3881 mutex_enter(SQLOCK(sq));
3882 flags = sq->sq_flags;
3883 ASSERT(sq->sq_count != 0);
3884 sq->sq_count--;
3886 putnext_tail(sq, qp, flags);
3905 * sq->sq_count == 0);
3918 sq->sq_flags = flags & ~SQ_EXCL;
3919 if (sq->sq_flags & SQ_WANTWAKEUP) {
3920 sq->sq_flags &= ~SQ_WANTWAKEUP;
3921 cv_broadcast(&sq->sq_wait);
3923 mutex_exit(SQLOCK(sq));
3942 syncq_t *sq;
3966 sq = qp->q_syncq;
3967 mutex_enter(SQLOCK(sq));
3969 count = sq->sq_count;
3970 flags = sq->sq_flags;
3971 ASSERT(sq->sq_ciputctrl == NULL || (flags & SQ_CIPUT));
3977 sq->sq_flags = flags | SQ_WANTWAKEUP;
3978 cv_wait(&sq->sq_wait, SQLOCK(sq));
3979 count = sq->sq_count;
3980 flags = sq->sq_flags;
3984 sq->sq_flags = flags | SQ_EXCL;
3985 sq->sq_count = count + 1;
3986 ASSERT(sq->sq_count != 0); /* Wraparound */
3987 mutex_exit(SQLOCK(sq));
3991 mutex_enter(SQLOCK(sq));
3992 flags = sq->sq_flags;
3993 ASSERT(sq->sq_count != 0);
3994 sq->sq_count--;
3996 putnext_tail(sq, qp, flags);
4022 * sq->sq_count == 0);
4035 sq->sq_flags = flags & ~SQ_EXCL;
4036 mutex_exit(SQLOCK(sq));
4064 syncq_t *sq = q->q_syncq;
4068 ASSERT(sq != NULL);
4074 if (!(sq->sq_type & SQ_CIPUT))
4078 if (sq->sq_ciputctrl == NULL) {
4081 mutex_enter(SQLOCK(sq));
4082 if (sq->sq_ciputctrl != NULL) {
4083 mutex_exit(SQLOCK(sq));
4086 ASSERT(sq->sq_nciputctrl == 0);
4087 sq->sq_nciputctrl = n_ciputctrl - 1;
4095 sq->sq_ciputctrl = cip;
4096 mutex_exit(SQLOCK(sq));
4099 ASSERT(sq->sq_nciputctrl == n_ciputctrl - 1);
4104 ASSERT(sq == q->q_syncq);
4108 ASSERT(sq != q->q_syncq);
4109 sq = q->q_syncq;
4110 ASSERT(sq->sq_type & SQ_CIPUT);