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