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