Lines Matching refs:te_wq
576 queue_t *te_wq; /* stream write queue */ member
691 (void) putbq((x)->te_wq, mp); \
694 #define TL_QENABLE(x) { (x)->te_nowsrv = B_FALSE; qenable((x)->te_wq); }
695 #define TL_PUTQ(x, mp) { (x)->te_nowsrv = B_FALSE; (void)putq((x)->te_wq, mp); }
1188 ASSERT(tep->te_wq == NULL); in tl_free()
1500 tep->te_wq = WR(rq); in tl_open()
1531 queue_t *wq = tep->te_wq; in tl_close()
1621 tep->te_wq = NULL; in tl_close()
1651 if (tep->te_wq->q_first && (IS_CLTS(tep) || IS_COTSORD(tep))) { in tl_close_ser()
1665 tep->te_wq->q_next = NULL; in tl_close_ser()
1667 peer_tep->te_wq->q_next = NULL; in tl_close_ser()
1954 (tep->te_wq != NULL) && in tl_wput_data_ser()
1955 (tep->te_wq->q_first == NULL) && in tl_wput_data_ser()
1968 if ((tep->te_wq != NULL) && in tl_wput_data_ser()
2025 queue_t *wq = tep->te_wq; in tl_wsrv_ser()
2136 tl_merror(tep->te_wq, mp, EPROTO); in tl_do_proto()
2144 tl_merror(tep->te_wq, mp, EPROTO); in tl_do_proto()
2152 tl_merror(tep->te_wq, mp, EPROTO); in tl_do_proto()
2160 tl_merror(tep->te_wq, mp, EPROTO); in tl_do_proto()
2168 tl_merror(tep->te_wq, mp, EPROTO); in tl_do_proto()
2176 tl_merror(tep->te_wq, mp, EPROTO); in tl_do_proto()
2184 tl_merror(tep->te_wq, mp, EPROTO); in tl_do_proto()
2191 tl_merror(tep->te_wq, mp, EPROTO); in tl_do_proto()
2217 queue_t *wq = tep->te_wq; in tl_do_ioctl()
2352 queue_t *wq = tep->te_wq; in tl_bind()
2667 wq = tep->te_wq; in tl_unbind()
2991 tl_ok_ack(tep->te_wq, ackmp, T_CONN_REQ); in tl_conn_req()
3070 wq = tep->te_wq; in tl_conn_req_ser()
3349 wq = tep->te_wq; 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()
3828 enableok(cl_ep->te_wq); in tl_conn_res()
3883 wq = tep->te_wq; in tl_discon_req()
4019 enableok(peer_tep->te_wq); in tl_discon_req()
4164 tep->te_wq->q_next = NULL; in tl_discon_req()
4165 peer_tep->te_wq->q_next = NULL; in tl_discon_req()
4196 wq = tep->te_wq; in tl_addr_req()
4268 tl_error_ack(tep->te_wq, mp, TSYSERR, ECONNRESET, T_ADDR_REQ); in tl_connected_cots_addr_req()
4282 tl_memrecover(tep->te_wq, mp, ack_sz); in tl_connected_cots_addr_req()
4348 tl_memrecover(tep->te_wq, mp, in tl_capability_req()
4391 tl_memrecover(tep->te_wq, mp, sizeof (struct T_info_ack)); in tl_info_req()
4413 queue_t *wq = tep->te_wq; in tl_data()
4589 tl_merror(peer_tep->te_wq, mp, EPROTO); in tl_data()
4614 queue_t *wq = tep->te_wq; in tl_exdata()
4755 tl_merror(peer_tep->te_wq, mp, EPROTO); in tl_exdata()
4778 queue_t *wq = tep->te_wq; in tl_ordrel()
4879 tl_merror(peer_tep->te_wq, mp, EPROTO); in tl_ordrel()
4975 queue_t *wq = tep->te_wq; in tl_unitdata_ser()
4996 queue_t *wq = tep->te_wq; in tl_unitdata()
5526 enableok(cl_tep->te_wq); in tl_co_unconnect()