Lines Matching refs:te_rq

575 	queue_t		*te_rq;		/* stream read queue */  member
1187 ASSERT(tep->te_rq == NULL); in tl_free()
1499 tep->te_rq = rq; in tl_open()
1670 tep->te_rq = NULL; in tl_close_ser()
1958 ((peer_rq = peer_tep->te_rq) != NULL) && in tl_wput_data_ser()
3007 putnext(tep->te_rq, dimp); in tl_conn_req()
3289 putnext(peer_tep->te_rq, cimp); in tl_conn_req_ser()
3298 putnext(tep->te_rq, confmp); in tl_conn_req_ser()
3633 (void) putnextctl1(acc_ep->te_rq, M_FLUSH, FLUSHR); in tl_conn_res()
3663 putnext(acc_ep->te_rq, dimp); in tl_conn_res()
3818 acc_ep->te_wq->q_next = cl_ep->te_rq; in tl_conn_res()
3819 cl_ep->te_wq->q_next = acc_ep->te_rq; in tl_conn_res()
3837 putnext(cl_ep->te_rq, ccmp); in tl_conn_res()
4129 (void) putnextctl1(peer_tep->te_rq, M_FLUSH, FLUSHRW); in tl_discon_req()
4142 putnext(peer_tep->te_rq, dimp); in tl_discon_req()
4307 putnext(tep->te_rq, ackmp); in tl_connected_cots_addr_req()
4366 putnext(tep->te_rq, ackmp); in tl_capability_req()
4403 putnext(tep->te_rq, ackmp); in tl_info_req()
4566 peer_rq = peer_tep->te_rq; in tl_data()
4732 peer_rq = peer_tep->te_rq; in tl_exdata()
4856 peer_rq = peer_tep->te_rq; in tl_ordrel()
4979 } else if (tep->te_rq != NULL) in tl_unitdata_ser()
5154 ASSERT(peer_tep->te_rq != NULL); in tl_unitdata()
5161 if (!canputnext(peer_tep->te_rq) && !(tep->te_closing)) { in tl_unitdata()
5271 putnext(peer_tep->te_rq, mp); in tl_unitdata()
5531 putnext(cl_tep->te_rq, d_mp); in tl_co_unconnect()
5601 putnext(srv_tep->te_rq, d_mp); in tl_co_unconnect()
5642 putnext(peer_tep->te_rq, d_mp); in tl_co_unconnect()
5695 flushq(tep->te_rq, FLUSHDATA); in tl_discon_ind()
5696 (void) putnextctl1(tep->te_rq, M_FLUSH, FLUSHRW); in tl_discon_ind()
5708 putnext(tep->te_rq, d_mp); in tl_discon_ind()
5860 ASSERT(tep->te_rq->q_first == NULL); in tl_icon_sendmsgs()
5872 putnext(tep->te_rq, mp); in tl_icon_sendmsgs()
5881 putnext(tep->te_rq, mp); in tl_icon_sendmsgs()
5886 putnext(tep->te_rq, mp); in tl_icon_sendmsgs()
5890 putnext(tep->te_rq, mp); in tl_icon_sendmsgs()
5973 (void) putnextctl1(tep->te_rq, M_ERROR, error); in tl_merror()