Lines Matching defs:q
195 /* 160 */ 'p', 'q', 'r', 's', 't', 'u', 'v', 'w',
344 /* 160 */ 'p', 'q', 'r', 's', 't', 'u', 'v', 'w',
628 open_ioctl(queue_t *q, uint_t cmd)
635 id = qbufcall(q, sizeof (struct iocblk), BPRI_MED,
637 retv = qwait_sig(q);
638 qunbufcall(q, id);
646 open_mblk(queue_t *q, size_t len)
653 id = qbufcall(q, len, BPRI_MED, dummy_callback, NULL);
654 retv = qwait_sig(q);
655 qunbufcall(q, id);
667 ldtermopen(queue_t *q, dev_t *devp, int oflag, int sflag, cred_t *crp)
676 if (q->q_ptr != NULL) {
719 q->q_ptr = (caddr_t)tp;
720 WR(q)->q_ptr = (caddr_t)tp;
736 qprocson(q);
743 if ((qryp = open_ioctl(q, MC_CANONQUERY)) == NULL)
751 wq = OTHERQ(q);
755 if ((qryp = open_ioctl(q, TCSBRK)) == NULL)
758 if ((bp = open_mblk(q, sizeof (int))) == NULL)
773 if ((qryp = open_ioctl(q, MC_POSIXQUERY)) == NULL)
780 if ((bp = open_mblk(q, sizeof (struct stroptions))) == NULL)
791 if ((bp = open_mblk(q, sizeof (struct stroptions))) == NULL)
800 putnext(q, bp);
805 qprocsoff(q);
806 q->q_ptr = NULL;
807 WR(q)->q_ptr = NULL;
831 ldtermclose(queue_t *q, int cflag, cred_t *crp)
833 ldtermstd_state_t *tp = (ldtermstd_state_t *)q->q_ptr;
843 (void) quntimeout(q, tp->t_vtid);
850 qunbufcall(q, tp->t_wbufcid);
863 putnext(q, bp);
882 if (!putq(WR(q), bp))
883 putnext(WR(q), bp);
893 cltimer.id = qtimeout(q, drain_timed_out, &cltimer,
903 if (qwait_sig(q) == 0)
907 (void) quntimeout(q, cltimer.id);
915 qprocsoff(q);
925 q->q_ptr = NULL;
934 ldtermrput(queue_t *q, mblk_t *mp)
938 queue_t *wrq = WR(q); /* write queue of ldterm mod */
939 queue_t *nextq = q->q_next; /* queue below us */
947 tp = (ldtermstd_state_t *)q->q_ptr;
967 (void) putq(q, mp);
978 putnext(q, mp);
983 ldterm_ioctl_reply(q, mp);
1015 putnext(q, mp);
1019 putnext(q, mp);
1038 ldterm_dosig(q, SIGINT, '\0', M_PCSIG, FLUSHRW);
1054 putnext(q, mp);
1067 putnext(q, mp);
1085 putnext(q, mp);
1152 putnext(q, mp); /* In case anyone else has to see it */
1161 flushband(q, *(mp->b_rptr + 1), FLUSHDATA);
1163 flushq(q, FLUSHDATA);
1178 putnext(q, mp); /* pass it on */
1185 !(tp->t_state & TS_IFBLOCK) && q->q_count <= TTXOLO) {
1202 !(tp->t_state & TS_IFBLOCK) && q->q_count <= TTXOLO) {
1213 (void) putq(q, mp);
1332 ldterm_dosig(q, SIGINT, c,
1337 ldterm_dosig(q, SIGQUIT, c,
1349 ldterm_dosig(q, SIGTSTP, c,
1355 ldterm_dosig(q, SIGTSTP, c,
1366 ldterm_dosig(q, SIGINFO, '\0',
1434 if (q->q_first != NULL || !bcanputnext(q, mp->b_band) ||
1436 (void) putq(q, mp);
1438 (void) ldtermrmsg(q, mp);
1451 q->q_count >= TTXOHI) {
1468 ldtermrsrv(queue_t *q)
1473 tp = (ldtermstd_state_t *)q->q_ptr;
1482 DEBUG5(("RESCAN WAS SET; put back in q\n"));
1484 (void) putbq(q, tp->t_message);
1500 while ((mp = getq(q)) != NULL) {
1501 if (!ldtermrmsg(q, mp))
1510 !(tp->t_state & TS_IFBLOCK) && q->q_count <= TTXOLO) {
1512 (void) putctl(WR(q), M_STARTI);
1522 ldtermrmsg(queue_t *q, mblk_t *mp)
1534 tp = (ldtermstd_state_t *)q->q_ptr;
1536 if (mp->b_datap->db_type <= QPCTL && !bcanputnext(q, mp->b_band)) {
1555 if (canputnext(WR(q)))
1556 ldterm_outchar(CTRL('g'), WR(q), 4, tp);
1560 (void) putctl1(q, M_FLUSH, FLUSHR);
1563 (void) putbq(q, mp);
1571 putnext(q, mp); /* pass it on */
1578 flushq(q, FLUSHDATA);
1604 (void) putnextctl(WR(q), M_START);
1612 (void) putnextctl1(q, M_FLUSH, FLUSHW);
1620 (void) putctl1(WR(q), M_FLUSH, FLUSHR);
1626 /* (void) putnextctl1(q, M_PCSIG, SIGCONT); */
1627 putnext(q, mp);
1636 ldterm_ioctl_reply(q, mp);
1654 putnext(q, mp);
1684 bpt, ebsize, q, tp, &dofree)) ==
1694 (void) putbq(q, bp);
1698 bpt = ldterm_dononcanon(bp, bpt, ebsize, q, tp);
1712 if (canputnext(WR(q)))
1713 putnext(WR(q), tp->t_echomp);
1731 ldterm_docanon(uchar_t c, mblk_t *bpt, size_t ebsize, queue_t *q,
1734 queue_t *wrq = WR(q);
1876 ldterm_msg_upstream(q, tp);
1877 if (!canputnext(q)) {
2009 ldterm_msg_upstream(q, tp);
2103 * cleanly as possible. q is the write queue for tp. Most of this
2109 ldterm_rubout(uchar_t c, queue_t *q, size_t ebsize, ldtermstd_state_t *tp)
2130 ldterm_reprint(q, ebsize, tp);
2141 ldterm_outstring(RUBOUT1, 3, q, ebsize,
2143 ldterm_outstring(RUBOUT1, 3, q, ebsize, tp);
2153 ldterm_outstring(RUBOUT2, 6, q, ebsize,
2167 ldterm_reprint(q, ebsize, tp);
2172 ldterm_outchar('\b', q, ebsize, tp);
2182 ldterm_outchar('\\', q, ebsize, tp);
2185 (void) ldterm_echo(c, q, ebsize, tp);
2187 (void) ldterm_echo(tp->t_modes.c_cc[VERASE], q, ebsize, tp);
2385 ldterm_erase(queue_t *q, size_t ebsize, ldtermstd_state_t *tp)
2390 ldterm_rubout((unsigned char) c, q, ebsize, tp);
2402 ldterm_werase(queue_t *q, size_t ebsize, ldtermstd_state_t *tp)
2410 ldterm_rubout((unsigned char) c, q, ebsize, tp);
2418 ldterm_rubout((unsigned char) c, q, ebsize, tp);
2448 ldterm_csi_werase(queue_t *q, size_t ebsize, ldtermstd_state_t *tp)
2466 ldterm_rubout((unsigned char) c, q, ebsize, tp);
2500 ldterm_rubout((unsigned char) c, q, ebsize, tp);
2519 ldterm_rubout(' ', q, ebsize, tp);
2544 ldterm_kill(queue_t *q, size_t ebsize, ldtermstd_state_t *tp)
2568 ldterm_rubout((unsigned char) c, q,
2586 ldterm_rubout(' ', q, ebsize,
2595 ldterm_rubout((unsigned char) c, q, ebsize, tp);
2600 (void) ldterm_echo(tp->t_modes.c_cc[VKILL], q, ebsize, tp);
2602 (void) ldterm_echo('\n', q, ebsize, tp);
2622 ldterm_reprint(queue_t *q, size_t ebsize, ldtermstd_state_t *tp)
2628 (void) ldterm_echo(tp->t_modes.c_cc[VREPRINT], q, ebsize, tp);
2629 ldterm_outchar('\n', q, ebsize, tp);
2635 (void) ldterm_echo(*readp++, q, ebsize, tp);
2645 * Non canonical processing. Called with q locked from ldtermrsrv.
2649 ldterm_dononcanon(mblk_t *bp, mblk_t *bpt, size_t ebsize, queue_t *q,
2652 queue_t *wrq = WR(q);
2804 vmin_satisfied(q, tp, 1);
2815 vmin_satisfied(q, tp, 1);
2825 vmin_satisfied(q, tp, 1);
2827 vmin_settimer(q);
2834 vmin_satisfied(q, tp, 1);
2851 ldterm_echo(uchar_t c, queue_t *q, size_t ebsize, ldtermstd_state_t *tp)
2867 ldterm_outchar('^', q, ebsize, tp);
2874 ldterm_outchar('^', q, ebsize, tp);
2878 ldterm_outchar(c, q, ebsize, tp);
2884 ldterm_outchar(c, q, ebsize, tp);
2895 ldterm_outchar(uchar_t c, queue_t *q, size_t bsize, ldtermstd_state_t *tp)
2914 mp = ldterm_output_msg(q, mp, &tp->t_echomp, tp, bsize, 1);
2950 ldterm_outstring(uchar_t *cp, int len, queue_t *q, size_t bsize,
2954 ldterm_outchar(*cp++, q, bsize, tp);
2982 ldterm_msg_upstream(queue_t *q, ldtermstd_state_t *tp)
2990 putnext(q, tp->t_message);
3019 queue_t *q = addr;
3022 tp = (ldtermstd_state_t *)q->q_ptr;
3027 enableok(q);
3028 qenable(q);
3039 ldtermwput(queue_t *q, mblk_t *mp)
3044 tp = (ldtermstd_state_t *)q->q_ptr;
3074 flushband(q, *(mp->b_rptr + 1),
3077 flushq(q, FLUSHDATA);
3080 putnext(q, mp);
3088 vmin_satisfied(RD(q), tp, 0);
3131 vmin_satisfied(RD(q),
3142 vmin_satisfied(RD(q),
3145 vmin_settimer(RD(q));
3156 vmin_satisfied(RD(q),
3170 vmin_satisfied(RD(q),
3173 vmin_settimer(RD(q));
3180 vmin_satisfied(RD(q), tp, 1);
3190 putnext(q, mp);
3195 putnext(q, mp);
3204 if (q->q_first != NULL || !bcanputnext(q, mp->b_band)) {
3230 (void) ldtermwmsg(q, mp);
3234 (void) putq(q, mp);
3241 (void) ldtermwmsg(q, mp);
3249 ldtermwsrv(queue_t *q)
3258 while ((mp = getq(q)) != NULL) {
3264 if (!bcanputnext(q, mp->b_band)) {
3265 (void) putbq(q, mp);
3268 if (!ldtermwmsg(q, mp)) {
3293 ldtermwmsg(queue_t *q, mblk_t *mp)
3299 tp = (ldtermstd_state_t *)q->q_ptr;
3304 ldterm_do_ioctl(q, mp);
3328 residmp = ldterm_output_msg(q, mp, &omp,
3337 putnext(q, mp);
3342 putnext(q, mp); /* pass it through unmolested */
3357 noenable(q);
3364 (void) putbq(q, residmp);
3374 qunbufcall(q, tp->t_wbufcid);
3375 tp->t_wbufcid = qbufcall(q, size, BPRI_MED, ldterm_wenable, q);
3386 ldterm_output_msg(queue_t *q, mblk_t *imp, mblk_t **omp,
3935 putnext(q, *omp);
3947 putnext(q, bp);
3989 ldterm_flush_output(uchar_t c, queue_t *q, ldtermstd_state_t *tp)
3995 flushq(q, FLUSHDATA); /* flush our write queue */
3997 (void) putnextctl1(q, M_FLUSH, FLUSHW);
3999 (void) ldterm_echo(c, q, 1, tp);
4001 ldterm_reprint(q, EBSIZE, tp);
4003 putnext(q, tp->t_echomp);
4016 ldterm_dosig(queue_t *q, int sig, uchar_t c, int mtype, int mode)
4018 ldtermstd_state_t *tp = (ldtermstd_state_t *)q->q_ptr;
4029 (void) putnextctl1(q, mtype, sig);
4036 flushq(q, FLUSHDATA);
4037 (void) putnextctl1(WR(q), M_FLUSH, mode);
4039 (void) putnextctl(WR(q), M_STARTI);
4044 flushq(WR(q), FLUSHDATA);
4057 (void) putnextctl1(q, M_FLUSH, FLUSHW);
4059 (void) putnextctl(WR(q), M_START);
4067 (void) putnextctl1(q, mtype, sig);
4071 (void) ldterm_echo(c, WR(q), 4, tp);
4072 putnext(WR(q), tp->t_echomp);
4085 ldterm_do_ioctl(queue_t *q, mblk_t *mp)
4098 tp = (ldtermstd_state_t *)q->q_ptr;
4115 miocnak(q, mp, 0, error);
4132 qenable(RD(q));
4145 if (chgstropts(&oldmodes, tp, RD(q)) == (-1)) {
4146 miocnak(q, mp, 0, EAGAIN);
4172 miocnak(q, mp, 0, error);
4197 if (chgstropts(&oldmodes, tp, RD(q)) == (-1)) {
4198 miocnak(q, mp, 0, EAGAIN);
4219 miocnak(q, mp, 0, error);
4226 (void) putnextctl1(q, M_FLUSH, FLUSHR);
4227 (void) putctl1(RD(q), M_FLUSH, FLUSHR);
4229 flushq(q, FLUSHDATA);
4232 (void) putnextctl1(RD(q), M_FLUSH, FLUSHW);
4233 (void) putnextctl1(q, M_FLUSH, FLUSHW);
4235 flushq(q, FLUSHDATA);
4237 (void) putnextctl1(q, M_FLUSH, FLUSHRW);
4239 (void) putnextctl1(RD(q), M_FLUSH, FLUSHRW);
4241 miocnak(q, mp, 0, EINVAL);
4246 miocack(q, mp, 0, 0);
4252 miocnak(q, mp, 0, error);
4259 (void) putnextctl(q, M_STOP);
4266 (void) putnextctl(q, M_START);
4272 (void) putnextctl(q, M_STOPI);
4277 (void) putnextctl(q, M_STARTI);
4282 miocnak(q, mp, 0, EINVAL);
4287 miocack(q, mp, 0, 0);
4321 miocnak(q, mp, 0, error);
4347 miocnak(q, mp, 0, ERANGE);
4392 miocnak(q, mp, 0, ENOSR);
4471 miocnak(q, mp, 0, ENOSR);
4476 miocnak(q, mp, 0, ENOSR);
4492 putnext(q, dmp);
4498 miocack(q, mp, 0, 0);
4505 miocnak(q, mp, 0, error);
4511 miocack(q, mp, EUCSIZE, 0);
4517 miocnak(q, mp, 0, error);
4527 miocnak(q, mp, 0, ERANGE);
4536 miocnak(q, mp, 0, ERANGE);
4547 miocnak(q, mp, 0, ERANGE);
4567 miocnak(q, mp, 0, ERANGE);
4594 miocnak(q, mp, 0, ERANGE);
4606 miocnak(q, mp, 0, ERANGE);
4619 miocnak(q, mp, 0, ENOSR);
4723 miocack(q, mp, 0, 0);
4729 miocnak(q, mp, 0, error);
4761 miocack(q, mp, sizeof (ldterm_cs_data_user_t), 0);
4770 putnext(q, mp);
4780 chgstropts(struct termios *oldmodep, ldtermstd_state_t *tp, queue_t *q)
4807 vmin_satisfied(q, tp, 0);
4832 putnext(q, bp);
4844 ldterm_ioctl_reply(queue_t *q, mblk_t *mp)
4850 tp = (ldtermstd_state_t *)q->q_ptr;
4897 putnext(q, mp);
4907 vmin_satisfied(queue_t *q, ldtermstd_state_t *tp, int sendup)
4909 ASSERT(q);
4912 (void) quntimeout(q, tp->t_vtid);
4920 if ((!q->q_first) ||
4921 (q->q_first->b_datap->db_type != M_DATA) ||
4923 ldterm_msg_upstream(q, tp);
4935 vmin_settimer(queue_t *q)
4939 tp = (ldtermstd_state_t *)q->q_ptr;
4961 (void) quntimeout(q, tp->t_vtid);
4964 tp->t_vtid = qtimeout(q, vmin_timed_out, q,
4976 queue_t *q = arg;
4979 tp = (ldtermstd_state_t *)q->q_ptr;
4984 vmin_satisfied(q, tp, 1);
5030 ldterm_csi_erase(queue_t *q, size_t ebsize, ldtermstd_state_t *tp)
5089 ldterm_rubout(' ', q, ebsize, tp);