Lines Matching refs:wq
1526 queue_t *wq = tep->te_wq;
1529 ASSERT(wq == WR(rq));
1622 rq->q_ptr = wq->q_ptr = NULL;
1717 tl_wput(queue_t *wq, mblk_t *mp)
1719 tl_endpt_t *tep = (tl_endpt_t *)wq->q_ptr;
1731 tl_merror(wq, mp, EPROTO);
1749 miocnak(wq, mp, 0, EINVAL);
1759 flushq(wq, FLUSHALL);
1763 flushq(RD(wq), FLUSHALL);
1764 qreply(wq, mp);
1775 tl_merror(wq, mp, EPROTO);
1792 tl_optmgmt(wq, mp);
1800 tl_merror(wq, mp, EPROTO);
1803 tl_conn_req(wq, mp);
1814 tl_merror(wq, mp, EPROTO);
1817 if ((tep->te_state == TS_IDLE) && !wq->q_first) {
1828 if (wq->q_first != NULL) {
1846 tl_merror(wq, mp, EPROTO);
1860 tl_merror(wq, mp, EPROTO);
1983 tl_wsrv(queue_t *wq)
1985 tl_endpt_t *tep = (tl_endpt_t *)wq->q_ptr;
1987 while ((wq->q_first != NULL) && !tep->te_nowsrv) {
2016 queue_t *wq = tep->te_wq;
2018 ASSERT(wq != NULL);
2019 while (!tep->te_nowsrv && (mp = getq(wq)) != NULL) {
2208 queue_t *wq = tep->te_wq;
2230 miocnak(wq, mp, 0, EINVAL);
2240 miocnak(wq, mp, 0, error);
2244 miocnak(wq, mp, 0, EINVAL);
2253 miocack(wq, mp, 0, 0);
2258 miocnak(wq, mp, 0, EINVAL);
2271 tl_error_ack(queue_t *wq, mblk_t *mp, t_scalar_t tli_err,
2281 tl_merror(wq, NULL, ENOSR);
2292 qreply(wq, ackmp);
2303 tl_ok_ack(queue_t *wq, mblk_t *mp, t_scalar_t type)
2310 tl_merror(wq, NULL, ENOMEM);
2317 (void) qreply(wq, ackmp);
2343 queue_t *wq = tep->te_wq;
2602 tl_memrecover(wq, mp, basize);
2626 (void) qreply(wq, bamp);
2636 tl_memrecover(wq, mp, sizeof (struct T_error_ack));
2640 tl_error_ack(wq, ackmp, tli_err, unix_err, save_prim_type);
2650 queue_t *wq;
2658 wq = tep->te_wq;
2665 tl_memrecover(wq, mp, sizeof (struct T_error_ack));
2682 tl_error_ack(wq, ackmp, TOUTSTATE, 0, T_UNBIND_REQ);
2692 (void) putnextctl1(RD(wq), M_FLUSH, FLUSHRW);
2709 tl_ok_ack(wq, ackmp, T_UNBIND_REQ);
2725 tl_optmgmt(queue_t *wq, mblk_t *mp)
2732 tep = (tl_endpt_t *)wq->q_ptr;
2745 tl_error_ack(wq, mp, TSYSERR, EINVAL, prim->type);
2766 tl_memrecover(wq, mp, sizeof (struct T_error_ack));
2770 tl_error_ack(wq, ackmp, TOUTSTATE, 0, T_SVR4_OPTMGMT_REQ);
2779 svr4_optcom_req(wq, mp, cr, &tl_opt_obj);
2782 tpi_optcom_req(wq, mp, cr, &tl_opt_obj);
2794 tl_conn_req(queue_t *wq, mblk_t *mp)
2796 tl_endpt_t *tep = (tl_endpt_t *)wq->q_ptr;
2822 tl_memrecover(wq, mp, sizeof (struct T_error_ack));
2835 tl_error_ack(wq, ackmp, TOUTSTATE, 0, T_CONN_REQ);
2848 tl_error_ack(wq, ackmp, TSYSERR, EINVAL, T_CONN_REQ);
2867 tl_error_ack(wq, ackmp, TSYSERR, EINVAL, T_CONN_REQ);
2877 tl_error_ack(wq, ackmp, TSYSERR, EINVAL, T_CONN_REQ);
2889 tl_error_ack(wq, ackmp, TSYSERR, EINVAL, T_CONN_REQ);
2901 tl_error_ack(wq, ackmp, TBADADDR, 0, T_CONN_REQ);
2926 tl_error_ack(wq, ackmp, TBADOPT, 0, T_CONN_REQ);
2938 tl_error_ack(wq, ackmp, TOUTSTATE, 0, T_CONN_REQ);
2987 tl_merror(wq, NULL, ENOSR);
3037 queue_t *wq;
3061 wq = tep->te_wq;
3080 tl_error_ack(wq, mp, TSYSERR, ECONNREFUSED, T_CONN_REQ);
3122 tl_memrecover(wq, mp, size);
3146 tl_memrecover(wq, mp, mp->b_wptr - mp->b_rptr);
3165 tl_memrecover(wq, mp, size);
3182 tl_memrecover(wq, indmp, sizeof (*tip));
3209 tl_ok_ack(wq, ackmp, T_CONN_REQ);
3222 tl_merror(wq, indmp, ENOMEM);
3288 noenable(wq);
3317 queue_t *wq;
3340 wq = tep->te_wq;
3350 tl_memrecover(wq, mp, sizeof (struct T_error_ack));
3369 tl_error_ack(wq, ackmp, TOUTSTATE, 0, prim);
3382 tl_error_ack(wq, ackmp, TSYSERR, EINVAL, prim);
3391 tl_error_ack(wq, ackmp, TSYSERR, EINVAL, prim);
3402 tl_error_ack(wq, ackmp, TBADOPT, 0, prim);
3415 tl_error_ack(wq, ackmp, TBADSEQ, 0, prim);
3429 tl_error_ack(wq, ackmp, TBADF, 0, prim);
3441 tl_error_ack(wq, ackmp, TBADF, 0, prim);
3459 tl_error_ack(wq, ackmp, TOUTSTATE, 0, prim);
3475 tl_error_ack(wq, ackmp, TBADF, 0, prim);
3493 tl_error_ack(wq, ackmp, TBADSEQ, 0, prim);
3594 tl_memrecover(wq, mp, size);
3620 tl_ok_ack(wq, ackmp, prim);
3631 tl_merror(wq, respmp, ENOMEM);
3673 tl_ok_ack(wq, ackmp, prim);
3707 tl_ok_ack(wq, ackmp, prim);
3711 tl_merror(wq, respmp, ENOMEM);
3799 tl_ok_ack(wq, ackmp, prim);
3849 queue_t *wq;
3874 wq = tep->te_wq;
3884 tl_memrecover(wq, mp, sizeof (struct T_error_ack));
3905 tl_error_ack(wq, ackmp, TOUTSTATE, 0, T_DISCON_REQ);
3920 tl_error_ack(wq, ackmp, TSYSERR, EINVAL, T_DISCON_REQ);
3940 tl_error_ack(wq, ackmp, TBADSEQ, 0, T_DISCON_REQ);
3960 tl_memrecover(wq, mp, size);
3983 (void) putnextctl1(RD(wq), M_FLUSH, FLUSHRW);
3986 tl_ok_ack(wq, ackmp, T_DISCON_REQ);
4001 tl_merror(wq, respmp, ENOMEM);
4032 tl_merror(wq, respmp, ENOMEM);
4090 tl_merror(wq, respmp, ENOMEM);
4166 queue_t *wq;
4176 wq = tep->te_wq;
4199 tl_memrecover(wq, mp, ack_sz);
4222 (void) qreply(wq, ackmp);
4389 queue_t *wq = tep->te_wq;
4401 tl_merror(wq, mp, EPROTO);
4427 tl_merror(wq, mp, EPROTO);
4438 tl_merror(wq, mp, EPROTO);
4466 tl_merror(wq, mp, EPROTO);
4522 tl_merror(wq, mp, EPROTO);
4590 queue_t *wq = tep->te_wq;
4601 tl_merror(wq, mp, EPROTO);
4640 tl_merror(wq, mp, EPROTO);
4689 tl_merror(wq, mp, EPROTO);
4754 queue_t *wq = tep->te_wq;
4765 tl_merror(wq, mp, EPROTO);
4813 tl_merror(wq, mp, EPROTO);
4878 tl_uderr(queue_t *wq, mblk_t *mp, t_scalar_t err)
4890 tep = (tl_endpt_t *)wq->q_ptr;
4908 tl_memrecover(wq, mp, err_sz);
4945 qreply(wq, err_mp);
4951 queue_t *wq = tep->te_wq;
4953 if (!tep->te_closing && (wq->q_first != NULL)) {
4972 queue_t *wq = tep->te_wq;
4995 tl_merror(wq, mp, EPROTO);
5011 tl_merror(wq, mp, EINVAL);
5032 tl_error_ack(wq, mp, TSYSERR, EINVAL, T_UNITDATA_REQ);
5042 tl_error_ack(wq, mp, TSYSERR, EINVAL, T_UNITDATA_REQ);
5058 tl_merror(wq, mp, EINVAL);
5067 tl_uderr(wq, mp, EPROTO);
5110 tl_uderr(wq, mp, ECONNRESET);
5126 tl_uderr(wq, mp, EPROTO);
5199 tl_memrecover(wq, mp, ui_sz);
5905 tl_merror(queue_t *wq, mblk_t *mp, int error)
5907 tl_endpt_t *tep = (tl_endpt_t *)wq->q_ptr;
5922 flushq(wq, FLUSHALL);
5947 qreply(wq, mp);
5996 tl_default_opt(queue_t *wq, int level, int name, uchar_t *ptr)
6004 tl_get_opt(queue_t *wq, int level, int name, uchar_t *ptr)
6010 tep = (tl_endpt_t *)wq->q_ptr;
6052 queue_t *wq,
6066 tep = (tl_endpt_t *)wq->q_ptr;
6130 queue_t *wq = arg;
6131 tl_endpt_t *tep = (tl_endpt_t *)wq->q_ptr;
6137 enableok(wq);
6142 qenable(wq);
6148 queue_t *wq = arg;
6149 tl_endpt_t *tep = (tl_endpt_t *)wq->q_ptr;
6156 enableok(wq);
6161 qenable(wq);
6165 tl_memrecover(queue_t *wq, mblk_t *mp, size_t size)
6169 tep = (tl_endpt_t *)wq->q_ptr;
6175 noenable(wq);
6177 (void) insq(wq, wq->q_first, mp);
6181 "tl_memrecover:recover %p pending", (void *)wq));
6185 if (!(tep->te_bufcid = qbufcall(wq, size, BPRI_MED, tl_buffer, wq))) {
6186 tep->te_timoutid = qtimeout(wq, tl_timer, wq,