Lines Matching refs:wqp
2547 queue_t *wqp = stp->sd_wrq; in strput() local
2561 if (!canputnext(wqp) && !(flags & MSG_IGNFLOW)) { in strput()
2566 if (!(flags & MSG_IGNFLOW) && !bcanputnext(wqp, pri)) { in strput()
2606 putnext(wqp, mp); in strput()
2609 putnext(wqp, mp); in strput()
2641 error = rwnext(wqp, &uiod); in strput()
2665 if (!canputnext(wqp) && !(flags & MSG_IGNFLOW)) { in strput()
2670 if (!bcanputnext(wqp, pri) && !(flags & MSG_IGNFLOW)) { in strput()
2677 if ((error = struioget(wqp, mp, &uiod, 0)) != 0) { in strput()
2689 putnext(wqp, mp); in strput()
2692 putnext(wqp, mp); in strput()
2729 struct queue *wqp; in strwrite_common() local
2757 wqp = stp->sd_wrq; in strwrite_common()
2768 TRACE_1(TR_FAC_STREAMS_FR, TR_STRWRITE_IN, "strwrite in:q %p", wqp); in strwrite_common()
2778 wqp, 0, ERANGE); in strwrite_common()
2784 wqp, 1, ERANGE); in strwrite_common()
2839 if (canputnext(wqp)) { in strwrite_common()
2845 "strwrite wait:q %p wait", wqp); in strwrite_common()
2856 "strwrite wake:q %p awakes", wqp); in strwrite_common()
2865 "strwrite resid:q %p uiop %p", wqp, uiop); in strwrite_common()
2888 "strwrite out:q %p out %d error %d", wqp, 2, error); in strwrite_common()
7731 queue_t *wqp; in strputmsg() local
7743 wqp = stp->sd_wrq; in strputmsg()
7875 if (bcanputnext(wqp, pri)) { in strputmsg()
7935 queue_t *wqp; in kstrputmsg() local
7941 wqp = stp->sd_wrq; in kstrputmsg()
8110 if (bcanputnext(wqp, pri)) { in kstrputmsg()