Lines Matching refs:te_rq
576 queue_t *te_rq; /* stream read queue */
1188 ASSERT(tep->te_rq == NULL);
1500 tep->te_rq = rq;
1671 tep->te_rq = NULL;
1959 ((peer_rq = peer_tep->te_rq) != NULL) &&
3008 putnext(tep->te_rq, dimp);
3290 putnext(peer_tep->te_rq, cimp);
3299 putnext(tep->te_rq, confmp);
3634 (void) putnextctl1(acc_ep->te_rq, M_FLUSH, FLUSHR);
3664 putnext(acc_ep->te_rq, dimp);
3819 acc_ep->te_wq->q_next = cl_ep->te_rq;
3820 cl_ep->te_wq->q_next = acc_ep->te_rq;
3838 putnext(cl_ep->te_rq, ccmp);
4130 (void) putnextctl1(peer_tep->te_rq, M_FLUSH, FLUSHRW);
4143 putnext(peer_tep->te_rq, dimp);
4308 putnext(tep->te_rq, ackmp);
4367 putnext(tep->te_rq, ackmp);
4404 putnext(tep->te_rq, ackmp);
4567 peer_rq = peer_tep->te_rq;
4733 peer_rq = peer_tep->te_rq;
4857 peer_rq = peer_tep->te_rq;
4980 } else if (tep->te_rq != NULL)
5155 ASSERT(peer_tep->te_rq != NULL);
5162 if (!canputnext(peer_tep->te_rq) && !(tep->te_closing)) {
5322 putnext(peer_tep->te_rq, mp);
5582 putnext(cl_tep->te_rq, d_mp);
5652 putnext(srv_tep->te_rq, d_mp);
5693 putnext(peer_tep->te_rq, d_mp);
5746 flushq(tep->te_rq, FLUSHDATA);
5747 (void) putnextctl1(tep->te_rq, M_FLUSH, FLUSHRW);
5759 putnext(tep->te_rq, d_mp);
5911 ASSERT(tep->te_rq->q_first == NULL);
5923 putnext(tep->te_rq, mp);
5932 putnext(tep->te_rq, mp);
5937 putnext(tep->te_rq, mp);
5941 putnext(tep->te_rq, mp);
6024 (void) putnextctl1(tep->te_rq, M_ERROR, error);