Lines Matching refs:wqp
2548 queue_t *wqp = stp->sd_wrq; in strput() local
2562 if (!canputnext(wqp) && !(flags & MSG_IGNFLOW)) { in strput()
2567 if (!(flags & MSG_IGNFLOW) && !bcanputnext(wqp, pri)) { in strput()
2607 putnext(wqp, mp); in strput()
2610 putnext(wqp, mp); in strput()
2642 error = rwnext(wqp, &uiod); in strput()
2666 if (!canputnext(wqp) && !(flags & MSG_IGNFLOW)) { in strput()
2671 if (!bcanputnext(wqp, pri) && !(flags & MSG_IGNFLOW)) { in strput()
2678 if ((error = struioget(wqp, mp, &uiod, 0)) != 0) { in strput()
2690 putnext(wqp, mp); in strput()
2693 putnext(wqp, mp); in strput()
2730 struct queue *wqp; in strwrite_common() local
2758 wqp = stp->sd_wrq; in strwrite_common()
2769 TRACE_1(TR_FAC_STREAMS_FR, TR_STRWRITE_IN, "strwrite in:q %p", wqp); in strwrite_common()
2779 wqp, 0, ERANGE); in strwrite_common()
2785 wqp, 1, ERANGE); in strwrite_common()
2840 if (canputnext(wqp)) { in strwrite_common()
2846 "strwrite wait:q %p wait", wqp); in strwrite_common()
2857 "strwrite wake:q %p awakes", wqp); in strwrite_common()
2866 "strwrite resid:q %p uiop %p", wqp, uiop); in strwrite_common()
2889 "strwrite out:q %p out %d error %d", wqp, 2, error); in strwrite_common()
7732 queue_t *wqp; in strputmsg() local
7744 wqp = stp->sd_wrq; in strputmsg()
7876 if (bcanputnext(wqp, pri)) { in strputmsg()
7936 queue_t *wqp; in kstrputmsg() local
7942 wqp = stp->sd_wrq; in kstrputmsg()
8111 if (bcanputnext(wqp, pri)) { in kstrputmsg()