Lines Matching defs:q
131 * q->q_ptr, then it's stable.
352 queue_t *q,
362 ASSERT(q != NULL);
364 if (q->q_ptr) {
378 q->q_ptr = (caddr_t)tp;
379 WR(q)->q_ptr = (caddr_t)tp;
382 tilogp("timodopen: Allocated for q %lx\n", (uintptr_t)q);
385 qprocson(q);
387 tp->tim_provinfo = tpi_findprov(q);
413 driverq = WR(q);
438 putnext(q, bp);
446 queue_t *q = arg;
447 struct tim_tim *tp = (struct tim_tim *)q->q_ptr;
451 if (q->q_flag & QREADR) {
458 enableok(q);
459 qenable(q);
465 queue_t *q = arg;
466 struct tim_tim *tp = (struct tim_tim *)q->q_ptr;
470 if (q->q_flag & QREADR) {
477 enableok(q);
478 qenable(q);
488 queue_t *q,
496 ASSERT(q != NULL);
498 tp = (struct tim_tim *)q->q_ptr;
499 q->q_ptr = NULL;
504 tilogp("timodclose: Entered for q %lx\n", (uintptr_t)q);
506 qprocsoff(q);
514 qunbufcall(q, tp->tim_wbufcid);
518 qunbufcall(q, tp->tim_rbufcid);
522 (void) quntimeout(q, tp->tim_wtimoutid);
526 (void) quntimeout(q, tp->tim_rtimoutid);
531 (void) quntimeout(q, tp->tim_tcap_timoutid);
551 q->q_ptr = WR(q)->q_ptr = NULL;
571 timodrput(queue_t *q, mblk_t *mp)
579 if (q->q_first != 0 && mp->b_datap->db_type < QPCTL) {
580 (void) putq(q, mp);
591 if (bcanputnext(q, mp->b_band))
592 putnext(q, mp);
594 (void) putq(q, mp);
600 bcanputnext(q, mp->b_band)) {
601 putnext(q, mp);
603 (void) putq(q, mp);
612 if (bcanputnext(q, mp->b_band))
613 putnext(q, mp);
615 (void) putq(q, mp);
618 (void) timodrproc(q, mp);
623 (void) timodrproc(q, mp);
640 timodrsrv(queue_t *q)
645 ASSERT(q != NULL);
647 tp = (struct tim_tim *)q->q_ptr;
651 while ((mp = getq(q)) != NULL) {
652 if (timodrproc(q, mp)) {
668 timodprocessinfo(queue_t *q, struct tim_tim *tp, struct T_info_ack *tia)
671 (void) strqset(q, QMAXPSZ, 0, tia->TIDU_size);
672 (void) strqset(OTHERQ(q), QMAXPSZ, 0, tia->TIDU_size);
681 timodrproc(queue_t *q, mblk_t *mp)
690 tp = (struct tim_tim *)q->q_ptr;
694 putnext(q, mp);
729 (void) quntimeout(q, tp->tim_tcap_timoutid);
733 putnext(q, mp);
736 if (!bcanputnext(q, mp->b_band)) {
737 (void) putbq(q, mp);
740 putnext(q, mp);
761 !bcanputnext(q, mp->b_band)) {
762 (void) putbq(q, mp);
765 putnext(q, mp);
774 audit_sock(T_UNITDATA_IND, q, mp, TIMOD_ID);
775 putnext(q, mp);
782 putnext(q, mp);
796 putnext(q, mp);
798 tim_send_ioc_error_ack(q, tp, mp);
800 putnext(q, mp);
807 putnext(q, mp);
858 tim_recover(q, mp,
883 tim_send_reply(q, mp, tp, pptr->ok_ack.CORRECT_prim);
893 putnext(q, mp);
903 putnext(q, mp);
914 putnext(q, mp);
925 tim_recover(q, mp,
941 tim_ioctl_send_reply(q, tp->tim_iocsave, mp);
959 putnext(q, mp);
962 tim_ioctl_send_reply(q, tp->tim_iocsave, mp);
978 putnext(q, mp);
985 timodprocessinfo(q, tp, tia);
1000 putnext(q, mp);
1023 putnext(q, mp);
1052 tim_ioctl_send_reply(q, tp->tim_iocsave, mp);
1075 putnext(q, mp);
1107 tim_send_ioc_error_ack(q, tp, mp);
1150 if (ti_expind_on_rdqueues(q)) {
1164 tim_ioctl_send_reply(q, tp->tim_iocsave, mp);
1173 putnext(q, mp);
1178 tim_send_reply(q, mp, tp, T_ADDR_REQ);
1194 tim_recover(q, mp,
1200 audit_sock(T_CONN_IND, q, mp, TIMOD_ID);
1201 putnext(q, mp);
1217 putnext(q, mp);
1225 if (q->q_first != 0)
1229 putnext(q, mp);
1254 putnext(q, mp);
1268 putnext(q, mp);
1277 if (!bcanputnext(q, mp->b_band)) {
1278 (void) putbq(q, mp);
1281 putnext(q, mp);
1288 putnext(q, mp);
1302 (void) quntimeout(q, tp->tim_tcap_timoutid);
1309 timodprocessinfo(q, tp, &tca->INFO_ack);
1311 tim_send_reply(q, mp, tp, T_CAPABILITY_REQ);
1323 flushband(q, *(mp->b_rptr + 1), FLUSHDATA);
1325 flushq(q, FLUSHDATA);
1327 putnext(q, mp);
1401 putnext(q, mp);
1428 if (ti_doname(WR(q), mp) != DONAME_CONT) {
1434 putnext(q, mp);
1450 timodwput(queue_t *q, mblk_t *mp)
1462 if (q->q_first != 0 && mp->b_datap->db_type < QPCTL) {
1467 (void) putq(q, mp);
1476 (void) putq(q, mp);
1487 tp = (struct tim_tim *)q->q_ptr;
1492 if ((tmp = tim_filladdr(q, mp, B_FALSE)) == NULL) {
1493 (void) putq(q, mp);
1499 if (bcanputnext(q, mp->b_band))
1500 putnext(q, mp);
1502 (void) putq(q, mp);
1509 tp = (struct tim_tim *)q->q_ptr;
1514 tmp = tim_filladdr(q, mp, B_FALSE);
1516 (void) putq(q, mp);
1522 if (bcanputnext(q, mp->b_band))
1523 putnext(q, mp);
1525 (void) putq(q, mp);
1530 if (bcanputnext(q, mp->b_band))
1531 putnext(q, mp);
1533 (void) putq(q, mp);
1536 (void) timodwproc(q, mp);
1541 (void) timodwproc(q, mp);
1556 timodwsrv(queue_t *q)
1560 ASSERT(q != NULL);
1561 if (q->q_ptr == NULL)
1564 while ((mp = getq(q)) != NULL) {
1565 if (timodwproc(q, mp)) {
1580 timodwproc(queue_t *q, mblk_t *mp)
1589 tp = (struct tim_tim *)q->q_ptr;
1593 putnext(q, mp);
1598 if ((tmp = tim_filladdr(q, mp, B_TRUE)) == NULL) {
1604 if (!bcanputnext(q, mp->b_band)) {
1605 (void) putbq(q, mp);
1608 putnext(q, mp);
1629 (void) putbq(q, mp);
1631 if (!(q->q_flag & QWANTR))
1632 tim_ioctl_retry(q);
1638 putnext(q, mp);
1643 miocnak(q, mp, 0, ENOTSUP);
1662 miocack(q, mp, sizeof (*kp), 0);
1664 miocnak(q, mp, 0, ENOTCONN);
1681 miocnak(q, mp, 0, error);
1684 tim_send_ioctl_tpi_msg(q, mp, tp, iocbp);
1691 miocnak(q, mp, 0, error);
1695 tim_send_ioctl_tpi_msg(q, mp, tp, iocbp);
1705 miocnak(q, mp, 0, error);
1728 miocnak(q, mp, 0, ENOMEM);
1730 tim_answer_ti_sync(q, mp, tp,
1764 tim_send_ioctl_tpi_msg(q, mp, tp, iocbp);
1774 miocnak(q, mp, 0, error);
1786 miocnak(q, mp, 0, EPROTO);
1793 tim_send_ioctl_tpi_msg(q, mp, tp, iocbp);
1811 tp->tim_tcap_timoutid = qtimeout(q,
1812 tim_tcap_timer, q, tim_tcap_wait * hz);
1813 tim_send_ioctl_tpi_msg(q, mp, tp, iocbp);
1837 tim_send_ioctl_tpi_msg(q, mp, tp,
1854 miocnak(q, mp, 0, ENOMEM);
1862 tim_ioctl_send_reply(q, mp, tcsr_mp);
1889 putnext(q, mp);
1899 putnext(q, mp);
1904 tim_recover(q, mp, msgsize(mp));
1914 putnext(q, tmp);
1922 if (ti_doname(q, mp) != DONAME_CONT) {
1926 putnext(q, mp);
1932 merror(q, mp, EPROTO);
1939 putnext(q, mp);
1947 if (!bcanputnext(q, mp->b_band)) {
1948 (void) putbq(q, mp);
1951 putnext(q, mp);
1956 tmp = tim_filladdr(q, mp, B_TRUE);
1964 audit_sock(T_UNITDATA_REQ, q, mp, TIMOD_ID);
1965 if (!bcanputnext(q, mp->b_band)) {
1966 (void) putbq(q, mp);
1969 putnext(q, mp);
1980 merror(q, mp, EPROTO);
1987 merror(q, mp, EPROTO);
2000 tim_recover(q, mp,
2018 audit_sock(T_CONN_REQ, q, mp, TIMOD_ID);
2019 putnext(q, mp);
2032 merror(q, mp, EPROTO);
2049 tim_recover(q, mp, msgsize(mp));
2075 putnext(q, mp);
2085 merror(q, mp, EPROTO);
2111 putnext(q, mp);
2122 putnext(q, mp);
2132 putnext(q, mp);
2142 flushband(q, *(mp->b_rptr + 1), FLUSHDATA);
2144 flushq(q, FLUSHDATA);
2146 putnext(q, mp);
2214 queue_t *q, /* queue message arrived at */
2223 struct tim_tim *tp = q->q_ptr;
2232 miocnak(q, mp, 0, EINVAL);
2237 miocnak(q, mp, 0, EINVAL);
2250 qreply(q, mp);
2261 miocnak(q, mp, 0, EINVAL);
2286 miocnak(q, mp, 0, ENAMETOOLONG);
2300 miocnak(q, mp, 0, ENAMETOOLONG);
2330 tim_ioctl_send_reply(q, mp, NULL);
2341 miocnak(q, mp, 0, EAGAIN);
2355 qreply(q, mp);
2372 miocnak(q, mp, 0, EAGAIN);
2390 qreply(q, mp);
2410 tim_filladdr(queue_t *q, mblk_t *mp, boolean_t dorecover)
2418 tp = (struct tim_tim *)q->q_ptr;
2479 tim_recover(q, mp,
2538 tim_recover(queue_t *q, mblk_t *mp, t_scalar_t size)
2544 tp = (struct tim_tim *)q->q_ptr;
2551 noenable(q);
2552 (void) putbq(q, mp);
2557 if (q->q_flag & QREADR) {
2564 if (!(bid = qbufcall(RD(q), (size_t)size, BPRI_MED, tim_buffer, q))) {
2565 tid = qtimeout(RD(q), tim_timer, q, TIMWAIT);
2566 if (q->q_flag & QREADR)
2571 if (q->q_flag & QREADR)
2584 tim_ioctl_retry(queue_t *q)
2588 tp = (struct tim_tim *)q->q_ptr;
2596 tp->tim_wtimoutid = qtimeout(RD(q), tim_timer, q, TIMIOCWAIT);
2609 queue_t *q;
2611 q = rq;
2616 claimstr(q);
2635 releasestr(q); /* decrement sd_refcnt */
2643 releasestr(q);
2650 queue_t *q = (queue_t *)q_ptr;
2651 struct tim_tim *tp = (struct tim_tim *)q->q_ptr;
2658 tim_tcap_genreply(q, tp);
2667 tim_tcap_genreply(queue_t *q, struct tim_tim *tp)
2674 ASSERT(tp == (struct tim_tim *)q->q_ptr);
2690 (void) quntimeout(q, tp->tim_tcap_timoutid);
2703 putnext(WR(q), tirmp);
2711 miocnak(q, mp, 0, ENOMEM);
2724 tim_ioctl_send_reply(q, mp, ackmp);
2736 miocnak(q, mp, 0, ENOMEM);
2743 tim_ioctl_send_reply(queue_t *q, mblk_t *ioc_mp, mblk_t *mp)
2747 ASSERT(q != NULL && ioc_mp != NULL);
2776 putnext(RD(q), ioc_mp);
2783 tim_send_ioc_error_ack(queue_t *q, struct tim_tim *tp, mblk_t *mp)
2796 q = RD(q);
2801 putnext(q, mp);
2806 tim_tcap_genreply(q, tp);
2820 putnext(q, mp);
2843 putnext(q, tp->tim_iocsave);
2858 tim_send_reply(queue_t *q, mblk_t *mp, struct tim_tim *tp, t_scalar_t prim)
2860 ASSERT(mp != NULL && q != NULL && tp != NULL);
2861 ASSERT(q == RD(q));
2867 putnext(q, mp);
2870 tim_ioctl_send_reply(q, tp->tim_iocsave, mp);
2882 tim_answer_ti_sync(queue_t *q, mblk_t *mp, struct tim_tim *tp,
2887 ASSERT(q != NULL && q == WR(q) && ackmp != NULL);
2902 miocnak(q, mp, 0, EINVAL);
2910 ti_expind_on_rdqueues(RD(q))) {
2918 tim_ioctl_send_reply(q, mp, ackmp);
2930 tim_send_ioctl_tpi_msg(queue_t *q, mblk_t *mp, struct tim_tim *tp,
2936 ASSERT(q != NULL && mp != NULL && tp != NULL);
2937 ASSERT(q == WR(q));
2969 putnext(q, tmp);