Lines Matching refs:q

254 OTHERQ(queue_t *q)  in OTHERQ()  argument
256 return (_OTHERQ(q)); in OTHERQ()
263 RD(queue_t *q) in RD() argument
265 return (_RD(q)); in RD()
273 SAMESTR(queue_t *q) in SAMESTR() argument
275 return (_SAMESTR(q)); in SAMESTR()
282 WR(queue_t *q) in WR() argument
284 return (_WR(q)); in WR()
481 bcanputnext(queue_t *q, unsigned char band) in bcanputnext() argument
485 claimstr(q); in bcanputnext()
486 ret = bcanput(q->q_next, band); in bcanputnext()
487 releasestr(q); in bcanputnext()
492 canputnext(queue_t *q) in canputnext() argument
494 queue_t *qofsq = q; in canputnext()
495 struct stdata *stp = STREAM(q); in canputnext()
499 "canputnext?:%p\n", q); in canputnext()
509 q = q->q_next->q_nfsrv; in canputnext()
510 ASSERT(q != NULL); in canputnext()
513 ASSERT(STRMATED(q->q_stream) || STREAM(q) == STREAM(qofsq)); in canputnext()
515 if (!(q->q_flag & QFULL)) { in canputnext()
518 "canputnext:%p %d", q, 1); in canputnext()
532 mutex_enter(QLOCK(q)); in canputnext()
533 if (q->q_flag & QFULL) { in canputnext()
534 q->q_flag |= QWANTW; in canputnext()
535 mutex_exit(QLOCK(q)); in canputnext()
537 "canputnext:%p %d", q, 0); in canputnext()
542 mutex_exit(QLOCK(q)); in canputnext()
543 TRACE_2(TR_FAC_STREAMS_FR, TR_CANPUTNEXT_OUT, "canputnext:%p %d", q, 1); in canputnext()
566 qprocson(queue_t *q) in qprocson() argument
568 ASSERT(q->q_flag & QREADR); in qprocson()
573 if ((q->q_next == NULL && WR(q)->q_next == NULL) || in qprocson()
574 (q->q_flag & _QINSERTING)) in qprocson()
575 insertq(STREAM(q), q); in qprocson()
596 qprocsoff(queue_t *q) in qprocsoff() argument
598 ASSERT(q->q_flag & QREADR); in qprocsoff()
599 if (q->q_flag & QWCLOSE) { in qprocsoff()
603 disable_svc(q); in qprocsoff()
604 removeq(q); in qprocsoff()
626 freezestr(queue_t *q) in freezestr() argument
628 struct stdata *stp = STREAM(q); in freezestr()
634 claimstr(RD(q)); in freezestr()
636 strblock(q); in freezestr()
639 for (q = stp->sd_wrq; q != NULL; q = SAMESTR(q) ? q->q_next : NULL) { in freezestr()
640 mutex_enter(QLOCK(q)); in freezestr()
641 mutex_enter(QLOCK(RD(q))); in freezestr()
651 unfreezestr(queue_t *q) in unfreezestr() argument
653 struct stdata *stp = STREAM(q); in unfreezestr()
663 strunblock(q); in unfreezestr()
664 releasestr(RD(q)); in unfreezestr()
690 qwait_sig(queue_t *q) in qwait_sig() argument
705 sq = q->q_syncq; in qwait_sig()
803 qwait(queue_t *q) in qwait() argument
817 sq = q->q_syncq; in qwait()
905 qwait_rw(queue_t *q) in qwait_rw() argument
919 sq = q->q_syncq; in qwait_rw()
980 qwriter(queue_t *q, mblk_t *mp, void (*func)(), int perim) in qwriter() argument
983 qwriter_inner(q, mp, func); in qwriter()
985 qwriter_outer(q, mp, func); in qwriter()
994 qtimeout(queue_t *q, void (*func)(void *), void *arg, clock_t tim) in qtimeout() argument
1000 sq = q->q_syncq; in qtimeout()
1023 qbufcall(queue_t *q, size_t size, uint_t pri, void (*func)(void *), void *arg) in qbufcall() argument
1029 sq = q->q_syncq; in qbufcall()
1065 quntimeout(queue_t *q, timeout_id_t id) in quntimeout() argument
1067 syncq_t *sq = q->q_syncq; in quntimeout()
1103 qunbufcall(queue_t *q, bufcall_id_t id) in qunbufcall() argument
1105 syncq_t *sq = q->q_syncq; in qunbufcall()
1177 qassociate(queue_t *q, int instance) in qassociate() argument
1184 ddi_assoc_queue_with_devi(q, NULL); in qassociate()
1188 vp = STREAM(q)->sd_vnode; in qassociate()
1195 ddi_assoc_queue_with_devi(q, dip); in qassociate()