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