Lines Matching refs:wqp
2619 queue_t *wqp = stp->sd_wrq; in strput() local
2633 if (!canputnext(wqp) && !(flags & MSG_IGNFLOW)) { in strput()
2638 if (!(flags & MSG_IGNFLOW) && !bcanputnext(wqp, pri)) { in strput()
2678 putnext(wqp, mp); in strput()
2681 putnext(wqp, mp); in strput()
2719 error = rwnext(wqp, &uiod); in strput()
2747 if (!canputnext(wqp) && !(flags & MSG_IGNFLOW)) { in strput()
2754 if (!bcanputnext(wqp, pri) && !(flags & MSG_IGNFLOW)) { in strput()
2763 if ((error = struioget(wqp, mp, &uiod, 0)) != 0) { in strput()
2777 putnext(wqp, mp); in strput()
2780 putnext(wqp, mp); in strput()
2819 struct queue *wqp; in strwrite_common() local
2847 wqp = stp->sd_wrq; in strwrite_common()
2858 TRACE_1(TR_FAC_STREAMS_FR, TR_STRWRITE_IN, "strwrite in:q %p", wqp); in strwrite_common()
2868 wqp, 0, ERANGE); in strwrite_common()
2874 wqp, 1, ERANGE); in strwrite_common()
2929 if (canputnext(wqp)) { in strwrite_common()
2935 "strwrite wait:q %p wait", wqp); in strwrite_common()
2946 "strwrite wake:q %p awakes", wqp); in strwrite_common()
2955 "strwrite resid:q %p uiop %p", wqp, uiop); in strwrite_common()
2978 "strwrite out:q %p out %d error %d", wqp, 2, error); in strwrite_common()
7857 queue_t *wqp; in strputmsg() local
7869 wqp = stp->sd_wrq; in strputmsg()
8001 if (bcanputnext(wqp, pri)) { in strputmsg()
8061 queue_t *wqp; in kstrputmsg() local
8067 wqp = stp->sd_wrq; in kstrputmsg()
8236 if (bcanputnext(wqp, pri)) { in kstrputmsg()