Lines Matching refs:wq
1531 queue_t *wq = tep->te_wq; in tl_close() local
1534 ASSERT(wq == WR(rq)); in tl_close()
1627 rq->q_ptr = wq->q_ptr = NULL; in tl_close()
1722 tl_wput(queue_t *wq, mblk_t *mp) in tl_wput() argument
1724 tl_endpt_t *tep = (tl_endpt_t *)wq->q_ptr; in tl_wput()
1736 tl_merror(wq, mp, EPROTO); in tl_wput()
1754 miocnak(wq, mp, 0, EINVAL); in tl_wput()
1764 flushq(wq, FLUSHALL); in tl_wput()
1768 flushq(RD(wq), FLUSHALL); in tl_wput()
1769 qreply(wq, mp); in tl_wput()
1780 tl_merror(wq, mp, EPROTO); in tl_wput()
1797 tl_optmgmt(wq, mp); in tl_wput()
1805 tl_merror(wq, mp, EPROTO); in tl_wput()
1808 tl_conn_req(wq, mp); in tl_wput()
1819 tl_merror(wq, mp, EPROTO); in tl_wput()
1822 if ((tep->te_state == TS_IDLE) && !wq->q_first) { in tl_wput()
1833 if (wq->q_first != NULL) { in tl_wput()
1851 tl_merror(wq, mp, EPROTO); in tl_wput()
1869 tl_merror(wq, mp, EPROTO); in tl_wput()
1992 tl_wsrv(queue_t *wq) in tl_wsrv() argument
1994 tl_endpt_t *tep = (tl_endpt_t *)wq->q_ptr; in tl_wsrv()
1996 while ((wq->q_first != NULL) && !tep->te_nowsrv) { in tl_wsrv()
2025 queue_t *wq = tep->te_wq; in tl_wsrv_ser() local
2027 ASSERT(wq != NULL); in tl_wsrv_ser()
2028 while (!tep->te_nowsrv && (mp = getq(wq)) != NULL) { in tl_wsrv_ser()
2217 queue_t *wq = tep->te_wq; in tl_do_ioctl() local
2239 miocnak(wq, mp, 0, EINVAL); in tl_do_ioctl()
2249 miocnak(wq, mp, 0, error); in tl_do_ioctl()
2253 miocnak(wq, mp, 0, EINVAL); in tl_do_ioctl()
2262 miocack(wq, mp, 0, 0); in tl_do_ioctl()
2267 miocnak(wq, mp, 0, EINVAL); in tl_do_ioctl()
2280 tl_error_ack(queue_t *wq, mblk_t *mp, t_scalar_t tli_err, in tl_error_ack() argument
2290 tl_merror(wq, NULL, ENOSR); in tl_error_ack()
2301 qreply(wq, ackmp); in tl_error_ack()
2312 tl_ok_ack(queue_t *wq, mblk_t *mp, t_scalar_t type) in tl_ok_ack() argument
2319 tl_merror(wq, NULL, ENOMEM); in tl_ok_ack()
2326 (void) qreply(wq, ackmp); in tl_ok_ack()
2352 queue_t *wq = tep->te_wq; in tl_bind() local
2611 tl_memrecover(wq, mp, basize); in tl_bind()
2635 (void) qreply(wq, bamp); in tl_bind()
2645 tl_memrecover(wq, mp, sizeof (struct T_error_ack)); in tl_bind()
2649 tl_error_ack(wq, ackmp, tli_err, unix_err, save_prim_type); in tl_bind()
2659 queue_t *wq; in tl_unbind() local
2667 wq = tep->te_wq; in tl_unbind()
2674 tl_memrecover(wq, mp, sizeof (struct T_error_ack)); in tl_unbind()
2691 tl_error_ack(wq, ackmp, TOUTSTATE, 0, T_UNBIND_REQ); in tl_unbind()
2701 (void) putnextctl1(RD(wq), M_FLUSH, FLUSHRW); in tl_unbind()
2718 tl_ok_ack(wq, ackmp, T_UNBIND_REQ); in tl_unbind()
2734 tl_optmgmt(queue_t *wq, mblk_t *mp) in tl_optmgmt() argument
2741 tep = (tl_endpt_t *)wq->q_ptr; in tl_optmgmt()
2754 tl_error_ack(wq, mp, TSYSERR, EINVAL, prim->type); in tl_optmgmt()
2775 tl_memrecover(wq, mp, sizeof (struct T_error_ack)); in tl_optmgmt()
2779 tl_error_ack(wq, ackmp, TOUTSTATE, 0, T_SVR4_OPTMGMT_REQ); in tl_optmgmt()
2788 svr4_optcom_req(wq, mp, cr, &tl_opt_obj); in tl_optmgmt()
2791 tpi_optcom_req(wq, mp, cr, &tl_opt_obj); in tl_optmgmt()
2803 tl_conn_req(queue_t *wq, mblk_t *mp) in tl_conn_req() argument
2805 tl_endpt_t *tep = (tl_endpt_t *)wq->q_ptr; in tl_conn_req()
2831 tl_memrecover(wq, mp, sizeof (struct T_error_ack)); in tl_conn_req()
2844 tl_error_ack(wq, ackmp, TOUTSTATE, 0, T_CONN_REQ); in tl_conn_req()
2857 tl_error_ack(wq, ackmp, TSYSERR, EINVAL, T_CONN_REQ); in tl_conn_req()
2876 tl_error_ack(wq, ackmp, TSYSERR, EINVAL, T_CONN_REQ); in tl_conn_req()
2886 tl_error_ack(wq, ackmp, TSYSERR, EINVAL, T_CONN_REQ); in tl_conn_req()
2898 tl_error_ack(wq, ackmp, TSYSERR, EINVAL, T_CONN_REQ); in tl_conn_req()
2910 tl_error_ack(wq, ackmp, TBADADDR, 0, T_CONN_REQ); in tl_conn_req()
2935 tl_error_ack(wq, ackmp, TBADOPT, 0, T_CONN_REQ); in tl_conn_req()
2947 tl_error_ack(wq, ackmp, TOUTSTATE, 0, T_CONN_REQ); in tl_conn_req()
2996 tl_merror(wq, NULL, ENOSR); in tl_conn_req()
3046 queue_t *wq; in tl_conn_req_ser() local
3070 wq = tep->te_wq; in tl_conn_req_ser()
3089 tl_error_ack(wq, mp, TSYSERR, ECONNREFUSED, T_CONN_REQ); in tl_conn_req_ser()
3131 tl_memrecover(wq, mp, size); in tl_conn_req_ser()
3155 tl_memrecover(wq, mp, mp->b_wptr - mp->b_rptr); in tl_conn_req_ser()
3174 tl_memrecover(wq, mp, size); in tl_conn_req_ser()
3191 tl_memrecover(wq, indmp, sizeof (*tip)); in tl_conn_req_ser()
3218 tl_ok_ack(wq, ackmp, T_CONN_REQ); in tl_conn_req_ser()
3231 tl_merror(wq, indmp, ENOMEM); in tl_conn_req_ser()
3297 noenable(wq); in tl_conn_req_ser()
3326 queue_t *wq; in tl_conn_res() local
3349 wq = tep->te_wq; in tl_conn_res()
3359 tl_memrecover(wq, mp, sizeof (struct T_error_ack)); in tl_conn_res()
3378 tl_error_ack(wq, ackmp, TOUTSTATE, 0, prim); in tl_conn_res()
3391 tl_error_ack(wq, ackmp, TSYSERR, EINVAL, prim); in tl_conn_res()
3400 tl_error_ack(wq, ackmp, TSYSERR, EINVAL, prim); in tl_conn_res()
3411 tl_error_ack(wq, ackmp, TBADOPT, 0, prim); in tl_conn_res()
3424 tl_error_ack(wq, ackmp, TBADSEQ, 0, prim); in tl_conn_res()
3438 tl_error_ack(wq, ackmp, TBADF, 0, prim); in tl_conn_res()
3450 tl_error_ack(wq, ackmp, TBADF, 0, prim); in tl_conn_res()
3468 tl_error_ack(wq, ackmp, TOUTSTATE, 0, prim); in tl_conn_res()
3484 tl_error_ack(wq, ackmp, TBADF, 0, prim); in tl_conn_res()
3502 tl_error_ack(wq, ackmp, TBADSEQ, 0, prim); in tl_conn_res()
3603 tl_memrecover(wq, mp, size); in tl_conn_res()
3629 tl_ok_ack(wq, ackmp, prim); in tl_conn_res()
3640 tl_merror(wq, respmp, ENOMEM); in tl_conn_res()
3682 tl_ok_ack(wq, ackmp, prim); in tl_conn_res()
3716 tl_ok_ack(wq, ackmp, prim); in tl_conn_res()
3720 tl_merror(wq, respmp, ENOMEM); in tl_conn_res()
3808 tl_ok_ack(wq, ackmp, prim); in tl_conn_res()
3858 queue_t *wq; in tl_discon_req() local
3883 wq = tep->te_wq; in tl_discon_req()
3893 tl_memrecover(wq, mp, sizeof (struct T_error_ack)); in tl_discon_req()
3914 tl_error_ack(wq, ackmp, TOUTSTATE, 0, T_DISCON_REQ); in tl_discon_req()
3929 tl_error_ack(wq, ackmp, TSYSERR, EINVAL, T_DISCON_REQ); in tl_discon_req()
3949 tl_error_ack(wq, ackmp, TBADSEQ, 0, T_DISCON_REQ); in tl_discon_req()
3969 tl_memrecover(wq, mp, size); in tl_discon_req()
3992 (void) putnextctl1(RD(wq), M_FLUSH, FLUSHRW); in tl_discon_req()
3995 tl_ok_ack(wq, ackmp, T_DISCON_REQ); in tl_discon_req()
4010 tl_merror(wq, respmp, ENOMEM); in tl_discon_req()
4041 tl_merror(wq, respmp, ENOMEM); in tl_discon_req()
4099 tl_merror(wq, respmp, ENOMEM); in tl_discon_req()
4186 queue_t *wq; in tl_addr_req() local
4196 wq = tep->te_wq; in tl_addr_req()
4219 tl_memrecover(wq, mp, ack_sz); in tl_addr_req()
4242 (void) qreply(wq, ackmp); in tl_addr_req()
4413 queue_t *wq = tep->te_wq; in tl_data() local
4425 tl_merror(wq, mp, EPROTO); in tl_data()
4451 tl_merror(wq, mp, EPROTO); in tl_data()
4462 tl_merror(wq, mp, EPROTO); in tl_data()
4490 tl_merror(wq, mp, EPROTO); in tl_data()
4546 tl_merror(wq, mp, EPROTO); in tl_data()
4614 queue_t *wq = tep->te_wq; in tl_exdata() local
4625 tl_merror(wq, mp, EPROTO); in tl_exdata()
4664 tl_merror(wq, mp, EPROTO); in tl_exdata()
4713 tl_merror(wq, mp, EPROTO); in tl_exdata()
4778 queue_t *wq = tep->te_wq; in tl_ordrel() local
4789 tl_merror(wq, mp, EPROTO); in tl_ordrel()
4837 tl_merror(wq, mp, EPROTO); in tl_ordrel()
4902 tl_uderr(queue_t *wq, mblk_t *mp, t_scalar_t err) in tl_uderr() argument
4914 tep = (tl_endpt_t *)wq->q_ptr; in tl_uderr()
4932 tl_memrecover(wq, mp, err_sz); in tl_uderr()
4969 qreply(wq, err_mp); in tl_uderr()
4975 queue_t *wq = tep->te_wq; in tl_unitdata_ser() local
4977 if (!tep->te_closing && (wq->q_first != NULL)) { in tl_unitdata_ser()
4996 queue_t *wq = tep->te_wq; in tl_unitdata() local
5019 tl_merror(wq, mp, EPROTO); in tl_unitdata()
5035 tl_merror(wq, mp, EINVAL); in tl_unitdata()
5056 tl_error_ack(wq, mp, TSYSERR, EINVAL, T_UNITDATA_REQ); in tl_unitdata()
5066 tl_error_ack(wq, mp, TSYSERR, EINVAL, T_UNITDATA_REQ); in tl_unitdata()
5082 tl_merror(wq, mp, EINVAL); in tl_unitdata()
5091 tl_uderr(wq, mp, EPROTO); in tl_unitdata()
5134 tl_uderr(wq, mp, ECONNRESET); in tl_unitdata()
5150 tl_uderr(wq, mp, EPROTO); in tl_unitdata()
5223 tl_memrecover(wq, mp, ui_sz); in tl_unitdata()
5929 tl_merror(queue_t *wq, mblk_t *mp, int error) in tl_merror() argument
5931 tl_endpt_t *tep = (tl_endpt_t *)wq->q_ptr; in tl_merror()
5946 flushq(wq, FLUSHALL); in tl_merror()
5971 qreply(wq, mp); in tl_merror()
6020 tl_default_opt(queue_t *wq, int level, int name, uchar_t *ptr) in tl_default_opt() argument
6028 tl_get_opt(queue_t *wq, int level, int name, uchar_t *ptr) in tl_get_opt() argument
6034 tep = (tl_endpt_t *)wq->q_ptr; in tl_get_opt()
6076 queue_t *wq, in tl_set_opt() argument
6090 tep = (tl_endpt_t *)wq->q_ptr; in tl_set_opt()
6154 queue_t *wq = arg; in tl_timer() local
6155 tl_endpt_t *tep = (tl_endpt_t *)wq->q_ptr; in tl_timer()
6161 enableok(wq); in tl_timer()
6166 qenable(wq); in tl_timer()
6172 queue_t *wq = arg; in tl_buffer() local
6173 tl_endpt_t *tep = (tl_endpt_t *)wq->q_ptr; in tl_buffer()
6180 enableok(wq); in tl_buffer()
6185 qenable(wq); in tl_buffer()
6189 tl_memrecover(queue_t *wq, mblk_t *mp, size_t size) in tl_memrecover() argument
6193 tep = (tl_endpt_t *)wq->q_ptr; in tl_memrecover()
6199 noenable(wq); in tl_memrecover()
6201 (void) insq(wq, wq->q_first, mp); in tl_memrecover()
6205 "tl_memrecover:recover %p pending", (void *)wq)); in tl_memrecover()
6209 if (!(tep->te_bufcid = qbufcall(wq, size, BPRI_MED, tl_buffer, wq))) { in tl_memrecover()
6210 tep->te_timoutid = qtimeout(wq, tl_timer, wq, in tl_memrecover()