Lines Matching refs:wq
1604 queue_t *wq = tep->te_wq; in tl_close() local
1607 ASSERT(wq == WR(rq)); in tl_close()
1700 rq->q_ptr = wq->q_ptr = NULL; in tl_close()
1795 tl_wput(queue_t *wq, mblk_t *mp) in tl_wput() argument
1797 tl_endpt_t *tep = (tl_endpt_t *)wq->q_ptr; in tl_wput()
1809 tl_merror(wq, mp, EPROTO); in tl_wput()
1827 miocnak(wq, mp, 0, EINVAL); in tl_wput()
1837 flushq(wq, FLUSHALL); in tl_wput()
1841 flushq(RD(wq), FLUSHALL); in tl_wput()
1842 qreply(wq, mp); in tl_wput()
1853 tl_merror(wq, mp, EPROTO); in tl_wput()
1870 tl_optmgmt(wq, mp); in tl_wput()
1878 tl_merror(wq, mp, EPROTO); in tl_wput()
1881 tl_conn_req(wq, mp); in tl_wput()
1892 tl_merror(wq, mp, EPROTO); in tl_wput()
1895 if ((tep->te_state == TS_IDLE) && !wq->q_first) { in tl_wput()
1906 if (wq->q_first != NULL) { in tl_wput()
1924 tl_merror(wq, mp, EPROTO); in tl_wput()
1942 tl_merror(wq, mp, EPROTO); in tl_wput()
2067 tl_wsrv(queue_t *wq) in tl_wsrv() argument
2069 tl_endpt_t *tep = (tl_endpt_t *)wq->q_ptr; in tl_wsrv()
2071 while ((wq->q_first != NULL) && !tep->te_nowsrv) { in tl_wsrv()
2101 queue_t *wq = tep->te_wq; in tl_wsrv_ser() local
2103 ASSERT(wq != NULL); in tl_wsrv_ser()
2104 while (!tep->te_nowsrv && (mp = getq(wq)) != NULL) { in tl_wsrv_ser()
2294 queue_t *wq = tep->te_wq; in tl_do_ioctl() local
2316 miocnak(wq, mp, 0, EINVAL); in tl_do_ioctl()
2326 miocnak(wq, mp, 0, error); in tl_do_ioctl()
2330 miocnak(wq, mp, 0, EINVAL); in tl_do_ioctl()
2339 miocack(wq, mp, 0, 0); in tl_do_ioctl()
2344 miocnak(wq, mp, 0, EINVAL); in tl_do_ioctl()
2357 tl_error_ack(queue_t *wq, mblk_t *mp, t_scalar_t tli_err, in tl_error_ack() argument
2367 tl_merror(wq, NULL, ENOSR); in tl_error_ack()
2378 qreply(wq, ackmp); in tl_error_ack()
2389 tl_ok_ack(queue_t *wq, mblk_t *mp, t_scalar_t type) in tl_ok_ack() argument
2396 tl_merror(wq, NULL, ENOMEM); in tl_ok_ack()
2403 (void) qreply(wq, ackmp); in tl_ok_ack()
2429 queue_t *wq = tep->te_wq; in tl_bind() local
2700 tl_memrecover(wq, mp, basize); in tl_bind()
2724 (void) qreply(wq, bamp); in tl_bind()
2734 tl_memrecover(wq, mp, sizeof (struct T_error_ack)); in tl_bind()
2738 tl_error_ack(wq, ackmp, tli_err, unix_err, save_prim_type); in tl_bind()
2748 queue_t *wq; in tl_unbind() local
2756 wq = tep->te_wq; in tl_unbind()
2763 tl_memrecover(wq, mp, sizeof (struct T_error_ack)); in tl_unbind()
2780 tl_error_ack(wq, ackmp, TOUTSTATE, 0, T_UNBIND_REQ); in tl_unbind()
2790 (void) putnextctl1(RD(wq), M_FLUSH, FLUSHRW); in tl_unbind()
2807 tl_ok_ack(wq, ackmp, T_UNBIND_REQ); in tl_unbind()
2823 tl_optmgmt(queue_t *wq, mblk_t *mp) in tl_optmgmt() argument
2830 tep = (tl_endpt_t *)wq->q_ptr; in tl_optmgmt()
2843 tl_error_ack(wq, mp, TSYSERR, EINVAL, prim->type); in tl_optmgmt()
2864 tl_memrecover(wq, mp, sizeof (struct T_error_ack)); in tl_optmgmt()
2868 tl_error_ack(wq, ackmp, TOUTSTATE, 0, T_SVR4_OPTMGMT_REQ); in tl_optmgmt()
2877 svr4_optcom_req(wq, mp, cr, &tl_opt_obj); in tl_optmgmt()
2880 tpi_optcom_req(wq, mp, cr, &tl_opt_obj); in tl_optmgmt()
2892 tl_conn_req(queue_t *wq, mblk_t *mp) in tl_conn_req() argument
2894 tl_endpt_t *tep = (tl_endpt_t *)wq->q_ptr; in tl_conn_req()
2920 tl_memrecover(wq, mp, sizeof (struct T_error_ack)); in tl_conn_req()
2933 tl_error_ack(wq, ackmp, TOUTSTATE, 0, T_CONN_REQ); in tl_conn_req()
2946 tl_error_ack(wq, ackmp, TSYSERR, EINVAL, T_CONN_REQ); in tl_conn_req()
2965 tl_error_ack(wq, ackmp, TSYSERR, EINVAL, T_CONN_REQ); in tl_conn_req()
2975 tl_error_ack(wq, ackmp, TSYSERR, EINVAL, T_CONN_REQ); in tl_conn_req()
2987 tl_error_ack(wq, ackmp, TSYSERR, EINVAL, T_CONN_REQ); in tl_conn_req()
2999 tl_error_ack(wq, ackmp, TBADADDR, 0, T_CONN_REQ); in tl_conn_req()
3024 tl_error_ack(wq, ackmp, TBADOPT, 0, T_CONN_REQ); in tl_conn_req()
3036 tl_error_ack(wq, ackmp, TOUTSTATE, 0, T_CONN_REQ); in tl_conn_req()
3085 tl_merror(wq, NULL, ENOSR); in tl_conn_req()
3135 queue_t *wq; in tl_conn_req_ser() local
3159 wq = tep->te_wq; in tl_conn_req_ser()
3178 tl_error_ack(wq, mp, TSYSERR, ECONNREFUSED, T_CONN_REQ); in tl_conn_req_ser()
3220 tl_memrecover(wq, mp, size); in tl_conn_req_ser()
3244 tl_memrecover(wq, mp, mp->b_wptr - mp->b_rptr); in tl_conn_req_ser()
3263 tl_memrecover(wq, mp, size); in tl_conn_req_ser()
3280 tl_memrecover(wq, indmp, sizeof (*tip)); in tl_conn_req_ser()
3307 tl_ok_ack(wq, ackmp, T_CONN_REQ); in tl_conn_req_ser()
3320 tl_merror(wq, indmp, ENOMEM); in tl_conn_req_ser()
3386 noenable(wq); in tl_conn_req_ser()
3415 queue_t *wq; in tl_conn_res() local
3438 wq = tep->te_wq; in tl_conn_res()
3448 tl_memrecover(wq, mp, sizeof (struct T_error_ack)); in tl_conn_res()
3467 tl_error_ack(wq, ackmp, TOUTSTATE, 0, prim); in tl_conn_res()
3480 tl_error_ack(wq, ackmp, TSYSERR, EINVAL, prim); in tl_conn_res()
3489 tl_error_ack(wq, ackmp, TSYSERR, EINVAL, prim); in tl_conn_res()
3500 tl_error_ack(wq, ackmp, TBADOPT, 0, prim); in tl_conn_res()
3513 tl_error_ack(wq, ackmp, TBADSEQ, 0, prim); in tl_conn_res()
3527 tl_error_ack(wq, ackmp, TBADF, 0, prim); in tl_conn_res()
3539 tl_error_ack(wq, ackmp, TBADF, 0, prim); in tl_conn_res()
3557 tl_error_ack(wq, ackmp, TOUTSTATE, 0, prim); in tl_conn_res()
3573 tl_error_ack(wq, ackmp, TBADF, 0, prim); in tl_conn_res()
3591 tl_error_ack(wq, ackmp, TBADSEQ, 0, prim); in tl_conn_res()
3692 tl_memrecover(wq, mp, size); in tl_conn_res()
3719 tl_ok_ack(wq, ackmp, prim); in tl_conn_res()
3730 tl_merror(wq, respmp, ENOMEM); in tl_conn_res()
3772 tl_ok_ack(wq, ackmp, prim); in tl_conn_res()
3806 tl_ok_ack(wq, ackmp, prim); in tl_conn_res()
3810 tl_merror(wq, respmp, ENOMEM); in tl_conn_res()
3898 tl_ok_ack(wq, ackmp, prim); in tl_conn_res()
3948 queue_t *wq; in tl_discon_req() local
3973 wq = tep->te_wq; in tl_discon_req()
3983 tl_memrecover(wq, mp, sizeof (struct T_error_ack)); in tl_discon_req()
4004 tl_error_ack(wq, ackmp, TOUTSTATE, 0, T_DISCON_REQ); in tl_discon_req()
4019 tl_error_ack(wq, ackmp, TSYSERR, EINVAL, T_DISCON_REQ); in tl_discon_req()
4039 tl_error_ack(wq, ackmp, TBADSEQ, 0, T_DISCON_REQ); in tl_discon_req()
4059 tl_memrecover(wq, mp, size); in tl_discon_req()
4083 (void) putnextctl1(RD(wq), M_FLUSH, FLUSHRW); in tl_discon_req()
4086 tl_ok_ack(wq, ackmp, T_DISCON_REQ); in tl_discon_req()
4101 tl_merror(wq, respmp, ENOMEM); in tl_discon_req()
4132 tl_merror(wq, respmp, ENOMEM); in tl_discon_req()
4190 tl_merror(wq, respmp, ENOMEM); in tl_discon_req()
4277 queue_t *wq; in tl_addr_req() local
4287 wq = tep->te_wq; in tl_addr_req()
4310 tl_memrecover(wq, mp, ack_sz); in tl_addr_req()
4333 (void) qreply(wq, ackmp); in tl_addr_req()
4504 queue_t *wq = tep->te_wq; in tl_data() local
4516 tl_merror(wq, mp, EPROTO); in tl_data()
4542 tl_merror(wq, mp, EPROTO); in tl_data()
4553 tl_merror(wq, mp, EPROTO); in tl_data()
4581 tl_merror(wq, mp, EPROTO); in tl_data()
4637 tl_merror(wq, mp, EPROTO); in tl_data()
4705 queue_t *wq = tep->te_wq; in tl_exdata() local
4716 tl_merror(wq, mp, EPROTO); in tl_exdata()
4755 tl_merror(wq, mp, EPROTO); in tl_exdata()
4804 tl_merror(wq, mp, EPROTO); in tl_exdata()
4869 queue_t *wq = tep->te_wq; in tl_ordrel() local
4880 tl_merror(wq, mp, EPROTO); in tl_ordrel()
4928 tl_merror(wq, mp, EPROTO); in tl_ordrel()
4993 tl_uderr(queue_t *wq, mblk_t *mp, t_scalar_t err) in tl_uderr() argument
5005 tep = (tl_endpt_t *)wq->q_ptr; in tl_uderr()
5023 tl_memrecover(wq, mp, err_sz); in tl_uderr()
5060 qreply(wq, err_mp); in tl_uderr()
5066 queue_t *wq = tep->te_wq; in tl_unitdata_ser() local
5068 if (!tep->te_closing && (wq->q_first != NULL)) { in tl_unitdata_ser()
5089 queue_t *wq = tep->te_wq; in tl_unitdata() local
5112 tl_merror(wq, mp, EPROTO); in tl_unitdata()
5128 tl_merror(wq, mp, EINVAL); in tl_unitdata()
5149 tl_error_ack(wq, mp, TSYSERR, EINVAL, T_UNITDATA_REQ); in tl_unitdata()
5159 tl_error_ack(wq, mp, TSYSERR, EINVAL, T_UNITDATA_REQ); in tl_unitdata()
5175 tl_merror(wq, mp, EINVAL); in tl_unitdata()
5184 tl_uderr(wq, mp, EPROTO); in tl_unitdata()
5227 tl_uderr(wq, mp, ECONNRESET); in tl_unitdata()
5243 tl_uderr(wq, mp, EPROTO); in tl_unitdata()
5361 tl_uderr(wq, mp, EPROTO); in tl_unitdata()
5371 tl_memrecover(wq, mp, ui_sz); in tl_unitdata()
6078 tl_merror(queue_t *wq, mblk_t *mp, int error) in tl_merror() argument
6080 tl_endpt_t *tep = (tl_endpt_t *)wq->q_ptr; in tl_merror()
6095 flushq(wq, FLUSHALL); in tl_merror()
6120 qreply(wq, mp); in tl_merror()
6169 tl_default_opt(queue_t *wq, int level, int name, uchar_t *ptr) in tl_default_opt() argument
6177 tl_get_opt(queue_t *wq, int level, int name, uchar_t *ptr) in tl_get_opt() argument
6183 tep = (tl_endpt_t *)wq->q_ptr; in tl_get_opt()
6224 tl_set_opt(queue_t *wq, uint_t mgmt_flags, int level, int name, uint_t inlen, in tl_set_opt() argument
6231 tep = (tl_endpt_t *)wq->q_ptr; in tl_set_opt()
6295 queue_t *wq = arg; in tl_timer() local
6296 tl_endpt_t *tep = (tl_endpt_t *)wq->q_ptr; in tl_timer()
6302 enableok(wq); in tl_timer()
6307 qenable(wq); in tl_timer()
6313 queue_t *wq = arg; in tl_buffer() local
6314 tl_endpt_t *tep = (tl_endpt_t *)wq->q_ptr; in tl_buffer()
6321 enableok(wq); in tl_buffer()
6326 qenable(wq); in tl_buffer()
6330 tl_memrecover(queue_t *wq, mblk_t *mp, size_t size) in tl_memrecover() argument
6334 tep = (tl_endpt_t *)wq->q_ptr; in tl_memrecover()
6340 noenable(wq); in tl_memrecover()
6342 (void) insq(wq, wq->q_first, mp); in tl_memrecover()
6346 "tl_memrecover:recover %p pending", (void *)wq)); in tl_memrecover()
6350 tep->te_bufcid = qbufcall(wq, size, BPRI_MED, tl_buffer, wq); in tl_memrecover()
6352 tep->te_timoutid = qtimeout(wq, tl_timer, wq, in tl_memrecover()