35 */
36
37/*
38 * Pseudo-teletype Driver
39 * (Actually two drivers, requiring two entries in 'cdevsw')
40 */
41#include "pty.h" /* XXX */
42#include "opt_compat.h"
43#include "opt_devfs.h"
44
45#include <sys/param.h>
46#include <sys/systm.h>
47#if defined(COMPAT_43) || defined(COMPAT_SUNOS)
48#include <sys/ioctl_compat.h>
49#endif
50#include <sys/proc.h>
51#include <sys/tty.h>
52#include <sys/conf.h>
53#include <sys/fcntl.h>
54#include <sys/poll.h>
55#include <sys/kernel.h>
56#include <sys/vnode.h>
57#include <sys/signalvar.h>
58
59#ifdef DEVFS
60#include <sys/devfsext.h>
61#endif /*DEVFS*/
62
63#ifdef notyet
64static void ptyattach __P((int n));
65#endif
66static void ptsstart __P((struct tty *tp));
67static void ptcwakeup __P((struct tty *tp, int flag));
68
69static d_open_t ptsopen;
70static d_close_t ptsclose;
71static d_read_t ptsread;
72static d_write_t ptswrite;
73static d_ioctl_t ptyioctl;
74static d_stop_t ptsstop;
75static d_devtotty_t ptydevtotty;
76static d_open_t ptcopen;
77static d_close_t ptcclose;
78static d_read_t ptcread;
79static d_write_t ptcwrite;
80static d_poll_t ptcpoll;
81
82#define CDEV_MAJOR_S 5
83static struct cdevsw pts_cdevsw = {
84 ptsopen, ptsclose, ptsread, ptswrite,
85 ptyioctl, ptsstop, nullreset, ptydevtotty,
86 ttpoll, nommap, NULL, "pts",
87 NULL, -1, nodump, nopsize,
88 D_TTY,
89};
90
91#define CDEV_MAJOR_C 6
92static struct cdevsw ptc_cdevsw = {
93 ptcopen, ptcclose, ptcread, ptcwrite,
94 ptyioctl, nullstop, nullreset, ptydevtotty,
95 ptcpoll, nommap, NULL, "ptc",
96 NULL, -1, nodump, nopsize,
97 D_TTY,
98};
99
100#if NPTY == 1
101#undef NPTY
102#define NPTY 32 /* crude XXX */
103#warning You have only one pty defined, redefining to 32.
104#endif
105
106#ifdef DEVFS
107#define MAXUNITS (8 * 32)
108static void *devfs_token_pts[MAXUNITS];
109static void *devfs_token_ptc[MAXUNITS];
110static const char jnames[] = "pqrsPQRS";
111#if NPTY > MAXUNITS
112#undef NPTY
113#define NPTY MAXUNITS
114#warning Can't have more than 256 pty's with DEVFS defined.
115#endif
116#endif
117
118#define BUFSIZ 100 /* Chunk size iomoved to/from user */
119
120/*
121 * pts == /dev/tty[pqrsPQRS][0123456789abcdefghijklmnopqrstuv]
122 * ptc == /dev/pty[pqrsPQRS][0123456789abcdefghijklmnopqrstuv]
123 */
124static struct tty pt_tty[NPTY]; /* XXX */
125static struct pt_ioctl {
126 int pt_flags;
127 struct selinfo pt_selr, pt_selw;
128 u_char pt_send;
129 u_char pt_ucntl;
130} pt_ioctl[NPTY]; /* XXX */
131static int npty = NPTY; /* for pstat -t */
132
133#define PF_PKT 0x08 /* packet mode */
134#define PF_STOPPED 0x10 /* user told stopped */
135#define PF_REMOTE 0x20 /* remote and flow controlled input */
136#define PF_NOSTOP 0x40
137#define PF_UCNTL 0x80 /* user control mode */
138
139#ifdef notyet
140/*
141 * Establish n (or default if n is 1) ptys in the system.
142 *
143 * XXX cdevsw & pstat require the array `pty[]' to be an array
144 */
145static void
146ptyattach(n)
147 int n;
148{
149 char *mem;
150 register u_long ntb;
151#define DEFAULT_NPTY 32
152
153 /* maybe should allow 0 => none? */
154 if (n <= 1)
155 n = DEFAULT_NPTY;
156 ntb = n * sizeof(struct tty);
157 mem = malloc(ntb + ALIGNBYTES + n * sizeof(struct pt_ioctl),
158 M_DEVBUF, M_WAITOK);
159 pt_tty = (struct tty *)mem;
160 mem = (char *)ALIGN(mem + ntb);
161 pt_ioctl = (struct pt_ioctl *)mem;
162 npty = n;
163}
164#endif
165
166/*ARGSUSED*/
167static int
168ptsopen(dev, flag, devtype, p)
169 dev_t dev;
170 int flag, devtype;
171 struct proc *p;
172{
173 register struct tty *tp;
174 int error;
175
176 if (minor(dev) >= npty)
177 return (ENXIO);
178 tp = &pt_tty[minor(dev)];
179 if ((tp->t_state & TS_ISOPEN) == 0) {
180 ttychars(tp); /* Set up default chars */
181 tp->t_iflag = TTYDEF_IFLAG;
182 tp->t_oflag = TTYDEF_OFLAG;
183 tp->t_lflag = TTYDEF_LFLAG;
184 tp->t_cflag = TTYDEF_CFLAG;
185 tp->t_ispeed = tp->t_ospeed = TTYDEF_SPEED;
186 } else if (tp->t_state & TS_XCLUDE && suser(p))
187 return (EBUSY);
188 if (tp->t_oproc) /* Ctrlr still around. */
189 (void)(*linesw[tp->t_line].l_modem)(tp, 1);
190 while ((tp->t_state & TS_CARR_ON) == 0) {
191 if (flag&FNONBLOCK)
192 break;
193 error = ttysleep(tp, TSA_CARR_ON(tp), TTIPRI | PCATCH,
194 "ptsopn", 0);
195 if (error)
196 return (error);
197 }
198 error = (*linesw[tp->t_line].l_open)(dev, tp);
199 if (error == 0)
200 ptcwakeup(tp, FREAD|FWRITE);
201 return (error);
202}
203
204static int
205ptsclose(dev, flag, mode, p)
206 dev_t dev;
207 int flag, mode;
208 struct proc *p;
209{
210 register struct tty *tp;
211 int err;
212
213 tp = &pt_tty[minor(dev)];
214 err = (*linesw[tp->t_line].l_close)(tp, flag);
215 ptsstop(tp, FREAD|FWRITE);
216 (void) ttyclose(tp);
217 return (err);
218}
219
220static int
221ptsread(dev, uio, flag)
222 dev_t dev;
223 struct uio *uio;
224 int flag;
225{
226 struct proc *p = curproc;
227 register struct tty *tp = &pt_tty[minor(dev)];
228 register struct pt_ioctl *pti = &pt_ioctl[minor(dev)];
229 int error = 0;
230
231again:
232 if (pti->pt_flags & PF_REMOTE) {
233 while (isbackground(p, tp)) {
234 if ((p->p_sigignore & sigmask(SIGTTIN)) ||
235 (p->p_sigmask & sigmask(SIGTTIN)) ||
236 p->p_pgrp->pg_jobc == 0 ||
237 p->p_flag & P_PPWAIT)
238 return (EIO);
239 pgsignal(p->p_pgrp, SIGTTIN, 1);
240 error = ttysleep(tp, &lbolt, TTIPRI | PCATCH, "ptsbg",
241 0);
242 if (error)
243 return (error);
244 }
245 if (tp->t_canq.c_cc == 0) {
246 if (flag & IO_NDELAY)
247 return (EWOULDBLOCK);
248 error = ttysleep(tp, TSA_PTS_READ(tp), TTIPRI | PCATCH,
249 "ptsin", 0);
250 if (error)
251 return (error);
252 goto again;
253 }
254 while (tp->t_canq.c_cc > 1 && uio->uio_resid > 0)
255 if (ureadc(getc(&tp->t_canq), uio) < 0) {
256 error = EFAULT;
257 break;
258 }
259 if (tp->t_canq.c_cc == 1)
260 (void) getc(&tp->t_canq);
261 if (tp->t_canq.c_cc)
262 return (error);
263 } else
264 if (tp->t_oproc)
265 error = (*linesw[tp->t_line].l_read)(tp, uio, flag);
266 ptcwakeup(tp, FWRITE);
267 return (error);
268}
269
270/*
271 * Write to pseudo-tty.
272 * Wakeups of controlling tty will happen
273 * indirectly, when tty driver calls ptsstart.
274 */
275static int
276ptswrite(dev, uio, flag)
277 dev_t dev;
278 struct uio *uio;
279 int flag;
280{
281 register struct tty *tp;
282
283 tp = &pt_tty[minor(dev)];
284 if (tp->t_oproc == 0)
285 return (EIO);
286 return ((*linesw[tp->t_line].l_write)(tp, uio, flag));
287}
288
289/*
290 * Start output on pseudo-tty.
291 * Wake up process selecting or sleeping for input from controlling tty.
292 */
293static void
294ptsstart(tp)
295 struct tty *tp;
296{
297 register struct pt_ioctl *pti = &pt_ioctl[minor(tp->t_dev)];
298
299 if (tp->t_state & TS_TTSTOP)
300 return;
301 if (pti->pt_flags & PF_STOPPED) {
302 pti->pt_flags &= ~PF_STOPPED;
303 pti->pt_send = TIOCPKT_START;
304 }
305 ptcwakeup(tp, FREAD);
306}
307
308static void
309ptcwakeup(tp, flag)
310 struct tty *tp;
311 int flag;
312{
313 struct pt_ioctl *pti = &pt_ioctl[minor(tp->t_dev)];
314
315 if (flag & FREAD) {
316 selwakeup(&pti->pt_selr);
317 wakeup(TSA_PTC_READ(tp));
318 }
319 if (flag & FWRITE) {
320 selwakeup(&pti->pt_selw);
321 wakeup(TSA_PTC_WRITE(tp));
322 }
323}
324
325static int
326ptcopen(dev, flag, devtype, p)
327 dev_t dev;
328 int flag, devtype;
329 struct proc *p;
330{
331 register struct tty *tp;
332 struct pt_ioctl *pti;
333
334 if (minor(dev) >= npty)
335 return (ENXIO);
336 tp = &pt_tty[minor(dev)];
337 if (tp->t_oproc)
338 return (EIO);
339 tp->t_oproc = ptsstart;
340#ifdef sun4c
341 tp->t_stop = ptsstop;
342#endif
343 (void)(*linesw[tp->t_line].l_modem)(tp, 1);
344 tp->t_lflag &= ~EXTPROC;
345 pti = &pt_ioctl[minor(dev)];
346 pti->pt_flags = 0;
347 pti->pt_send = 0;
348 pti->pt_ucntl = 0;
349 return (0);
350}
351
352static int
353ptcclose(dev, flags, fmt, p)
354 dev_t dev;
355 int flags;
356 int fmt;
357 struct proc *p;
358{
359 register struct tty *tp;
360
361 tp = &pt_tty[minor(dev)];
362 (void)(*linesw[tp->t_line].l_modem)(tp, 0);
363
364 /*
365 * XXX MDMBUF makes no sense for ptys but would inhibit the above
366 * l_modem(). CLOCAL makes sense but isn't supported. Special
367 * l_modem()s that ignore carrier drop make no sense for ptys but
368 * may be in use because other parts of the line discipline make
369 * sense for ptys. Recover by doing everything that a normal
370 * ttymodem() would have done except for sending a SIGHUP.
371 */
372 if (tp->t_state & TS_ISOPEN) {
373 tp->t_state &= ~(TS_CARR_ON | TS_CONNECTED);
374 tp->t_state |= TS_ZOMBIE;
375 ttyflush(tp, FREAD | FWRITE);
376 }
377
378 tp->t_oproc = 0; /* mark closed */
379 return (0);
380}
381
382static int
383ptcread(dev, uio, flag)
384 dev_t dev;
385 struct uio *uio;
386 int flag;
387{
388 register struct tty *tp = &pt_tty[minor(dev)];
389 struct pt_ioctl *pti = &pt_ioctl[minor(dev)];
390 char buf[BUFSIZ];
391 int error = 0, cc;
392
393 /*
394 * We want to block until the slave
395 * is open, and there's something to read;
396 * but if we lost the slave or we're NBIO,
397 * then return the appropriate error instead.
398 */
399 for (;;) {
400 if (tp->t_state&TS_ISOPEN) {
401 if (pti->pt_flags&PF_PKT && pti->pt_send) {
402 error = ureadc((int)pti->pt_send, uio);
403 if (error)
404 return (error);
405 if (pti->pt_send & TIOCPKT_IOCTL) {
406 cc = min(uio->uio_resid,
407 sizeof(tp->t_termios));
408 uiomove((caddr_t)&tp->t_termios, cc,
409 uio);
410 }
411 pti->pt_send = 0;
412 return (0);
413 }
414 if (pti->pt_flags&PF_UCNTL && pti->pt_ucntl) {
415 error = ureadc((int)pti->pt_ucntl, uio);
416 if (error)
417 return (error);
418 pti->pt_ucntl = 0;
419 return (0);
420 }
421 if (tp->t_outq.c_cc && (tp->t_state&TS_TTSTOP) == 0)
422 break;
423 }
424 if ((tp->t_state & TS_CONNECTED) == 0)
425 return (0); /* EOF */
426 if (flag & IO_NDELAY)
427 return (EWOULDBLOCK);
428 error = tsleep(TSA_PTC_READ(tp), TTIPRI | PCATCH, "ptcin", 0);
429 if (error)
430 return (error);
431 }
432 if (pti->pt_flags & (PF_PKT|PF_UCNTL))
433 error = ureadc(0, uio);
434 while (uio->uio_resid > 0 && error == 0) {
435 cc = q_to_b(&tp->t_outq, buf, min(uio->uio_resid, BUFSIZ));
436 if (cc <= 0)
437 break;
438 error = uiomove(buf, cc, uio);
439 }
440 ttwwakeup(tp);
441 return (error);
442}
443
444static void
445ptsstop(tp, flush)
446 register struct tty *tp;
447 int flush;
448{
449 struct pt_ioctl *pti = &pt_ioctl[minor(tp->t_dev)];
450 int flag;
451
452 /* note: FLUSHREAD and FLUSHWRITE already ok */
453 if (flush == 0) {
454 flush = TIOCPKT_STOP;
455 pti->pt_flags |= PF_STOPPED;
456 } else
457 pti->pt_flags &= ~PF_STOPPED;
458 pti->pt_send |= flush;
459 /* change of perspective */
460 flag = 0;
461 if (flush & FREAD)
462 flag |= FWRITE;
463 if (flush & FWRITE)
464 flag |= FREAD;
465 ptcwakeup(tp, flag);
466}
467
468static int
469ptcpoll(dev, events, p)
470 dev_t dev;
471 int events;
472 struct proc *p;
473{
474 register struct tty *tp = &pt_tty[minor(dev)];
475 struct pt_ioctl *pti = &pt_ioctl[minor(dev)];
476 int revents = 0;
477 int s;
478
479 if ((tp->t_state & TS_CONNECTED) == 0)
480 return (seltrue(dev, events, p) | POLLHUP);
481
482 /*
483 * Need to block timeouts (ttrstart).
484 */
485 s = spltty();
486
487 if (events & (POLLIN | POLLRDNORM))
488 if ((tp->t_state & TS_ISOPEN) &&
489 ((tp->t_outq.c_cc && (tp->t_state & TS_TTSTOP) == 0) ||
490 ((pti->pt_flags & PF_PKT) && pti->pt_send) ||
491 ((pti->pt_flags & PF_UCNTL) && pti->pt_ucntl)))
492 revents |= events & (POLLIN | POLLRDNORM);
493
494 if (events & (POLLOUT | POLLWRNORM))
495 if (tp->t_state & TS_ISOPEN &&
496 ((pti->pt_flags & PF_REMOTE) ?
497 (tp->t_canq.c_cc == 0) :
498 ((tp->t_rawq.c_cc + tp->t_canq.c_cc < TTYHOG - 2) ||
499 (tp->t_canq.c_cc == 0 && (tp->t_iflag & ICANON)))))
500 revents |= events & (POLLOUT | POLLWRNORM);
501
502 if (events & POLLHUP)
503 if ((tp->t_state & TS_CARR_ON) == 0)
504 revents |= POLLHUP;
505
506 if (revents == 0) {
507 if (events & (POLLIN | POLLRDNORM))
508 selrecord(p, &pti->pt_selr);
509
510 if (events & (POLLOUT | POLLWRNORM))
511 selrecord(p, &pti->pt_selw);
512 }
513 splx(s);
514
515 return (revents);
516}
517
518static int
519ptcwrite(dev, uio, flag)
520 dev_t dev;
521 register struct uio *uio;
522 int flag;
523{
524 register struct tty *tp = &pt_tty[minor(dev)];
525 register u_char *cp = 0;
526 register int cc = 0;
527 u_char locbuf[BUFSIZ];
528 int cnt = 0;
529 struct pt_ioctl *pti = &pt_ioctl[minor(dev)];
530 int error = 0;
531
532again:
533 if ((tp->t_state&TS_ISOPEN) == 0)
534 goto block;
535 if (pti->pt_flags & PF_REMOTE) {
536 if (tp->t_canq.c_cc)
537 goto block;
538 while ((uio->uio_resid > 0 || cc > 0) &&
539 tp->t_canq.c_cc < TTYHOG - 1) {
540 if (cc == 0) {
541 cc = min(uio->uio_resid, BUFSIZ);
542 cc = min(cc, TTYHOG - 1 - tp->t_canq.c_cc);
543 cp = locbuf;
544 error = uiomove((caddr_t)cp, cc, uio);
545 if (error)
546 return (error);
547 /* check again for safety */
548 if ((tp->t_state & TS_ISOPEN) == 0) {
549 /* adjust as usual */
550 uio->uio_resid += cc;
551 return (EIO);
552 }
553 }
554 if (cc > 0) {
555 cc = b_to_q((char *)cp, cc, &tp->t_canq);
556 /*
557 * XXX we don't guarantee that the canq size
558 * is >= TTYHOG, so the above b_to_q() may
559 * leave some bytes uncopied. However, space
560 * is guaranteed for the null terminator if
561 * we don't fail here since (TTYHOG - 1) is
562 * not a multiple of CBSIZE.
563 */
564 if (cc > 0)
565 break;
566 }
567 }
568 /* adjust for data copied in but not written */
569 uio->uio_resid += cc;
570 (void) putc(0, &tp->t_canq);
571 ttwakeup(tp);
572 wakeup(TSA_PTS_READ(tp));
573 return (0);
574 }
575 while (uio->uio_resid > 0 || cc > 0) {
576 if (cc == 0) {
577 cc = min(uio->uio_resid, BUFSIZ);
578 cp = locbuf;
579 error = uiomove((caddr_t)cp, cc, uio);
580 if (error)
581 return (error);
582 /* check again for safety */
583 if ((tp->t_state & TS_ISOPEN) == 0) {
584 /* adjust for data copied in but not written */
585 uio->uio_resid += cc;
586 return (EIO);
587 }
588 }
589 while (cc > 0) {
590 if ((tp->t_rawq.c_cc + tp->t_canq.c_cc) >= TTYHOG - 2 &&
591 (tp->t_canq.c_cc > 0 || !(tp->t_iflag&ICANON))) {
592 wakeup(TSA_HUP_OR_INPUT(tp));
593 goto block;
594 }
595 (*linesw[tp->t_line].l_rint)(*cp++, tp);
596 cnt++;
597 cc--;
598 }
599 cc = 0;
600 }
601 return (0);
602block:
603 /*
604 * Come here to wait for slave to open, for space
605 * in outq, or space in rawq, or an empty canq.
606 */
607 if ((tp->t_state & TS_CONNECTED) == 0) {
608 /* adjust for data copied in but not written */
609 uio->uio_resid += cc;
610 return (EIO);
611 }
612 if (flag & IO_NDELAY) {
613 /* adjust for data copied in but not written */
614 uio->uio_resid += cc;
615 if (cnt == 0)
616 return (EWOULDBLOCK);
617 return (0);
618 }
619 error = tsleep(TSA_PTC_WRITE(tp), TTOPRI | PCATCH, "ptcout", 0);
620 if (error) {
621 /* adjust for data copied in but not written */
622 uio->uio_resid += cc;
623 return (error);
624 }
625 goto again;
626}
627
628static struct tty *
629ptydevtotty(dev)
630 dev_t dev;
631{
632 if (minor(dev) >= npty)
633 return (NULL);
634
635 return &pt_tty[minor(dev)];
636}
637
638/*ARGSUSED*/
639static int
640ptyioctl(dev, cmd, data, flag, p)
641 dev_t dev;
642 u_long cmd;
643 caddr_t data;
644 int flag;
645 struct proc *p;
646{
647 register struct tty *tp = &pt_tty[minor(dev)];
648 register struct pt_ioctl *pti = &pt_ioctl[minor(dev)];
649 register u_char *cc = tp->t_cc;
650 int stop, error;
651
| 35 */
36
37/*
38 * Pseudo-teletype Driver
39 * (Actually two drivers, requiring two entries in 'cdevsw')
40 */
41#include "pty.h" /* XXX */
42#include "opt_compat.h"
43#include "opt_devfs.h"
44
45#include <sys/param.h>
46#include <sys/systm.h>
47#if defined(COMPAT_43) || defined(COMPAT_SUNOS)
48#include <sys/ioctl_compat.h>
49#endif
50#include <sys/proc.h>
51#include <sys/tty.h>
52#include <sys/conf.h>
53#include <sys/fcntl.h>
54#include <sys/poll.h>
55#include <sys/kernel.h>
56#include <sys/vnode.h>
57#include <sys/signalvar.h>
58
59#ifdef DEVFS
60#include <sys/devfsext.h>
61#endif /*DEVFS*/
62
63#ifdef notyet
64static void ptyattach __P((int n));
65#endif
66static void ptsstart __P((struct tty *tp));
67static void ptcwakeup __P((struct tty *tp, int flag));
68
69static d_open_t ptsopen;
70static d_close_t ptsclose;
71static d_read_t ptsread;
72static d_write_t ptswrite;
73static d_ioctl_t ptyioctl;
74static d_stop_t ptsstop;
75static d_devtotty_t ptydevtotty;
76static d_open_t ptcopen;
77static d_close_t ptcclose;
78static d_read_t ptcread;
79static d_write_t ptcwrite;
80static d_poll_t ptcpoll;
81
82#define CDEV_MAJOR_S 5
83static struct cdevsw pts_cdevsw = {
84 ptsopen, ptsclose, ptsread, ptswrite,
85 ptyioctl, ptsstop, nullreset, ptydevtotty,
86 ttpoll, nommap, NULL, "pts",
87 NULL, -1, nodump, nopsize,
88 D_TTY,
89};
90
91#define CDEV_MAJOR_C 6
92static struct cdevsw ptc_cdevsw = {
93 ptcopen, ptcclose, ptcread, ptcwrite,
94 ptyioctl, nullstop, nullreset, ptydevtotty,
95 ptcpoll, nommap, NULL, "ptc",
96 NULL, -1, nodump, nopsize,
97 D_TTY,
98};
99
100#if NPTY == 1
101#undef NPTY
102#define NPTY 32 /* crude XXX */
103#warning You have only one pty defined, redefining to 32.
104#endif
105
106#ifdef DEVFS
107#define MAXUNITS (8 * 32)
108static void *devfs_token_pts[MAXUNITS];
109static void *devfs_token_ptc[MAXUNITS];
110static const char jnames[] = "pqrsPQRS";
111#if NPTY > MAXUNITS
112#undef NPTY
113#define NPTY MAXUNITS
114#warning Can't have more than 256 pty's with DEVFS defined.
115#endif
116#endif
117
118#define BUFSIZ 100 /* Chunk size iomoved to/from user */
119
120/*
121 * pts == /dev/tty[pqrsPQRS][0123456789abcdefghijklmnopqrstuv]
122 * ptc == /dev/pty[pqrsPQRS][0123456789abcdefghijklmnopqrstuv]
123 */
124static struct tty pt_tty[NPTY]; /* XXX */
125static struct pt_ioctl {
126 int pt_flags;
127 struct selinfo pt_selr, pt_selw;
128 u_char pt_send;
129 u_char pt_ucntl;
130} pt_ioctl[NPTY]; /* XXX */
131static int npty = NPTY; /* for pstat -t */
132
133#define PF_PKT 0x08 /* packet mode */
134#define PF_STOPPED 0x10 /* user told stopped */
135#define PF_REMOTE 0x20 /* remote and flow controlled input */
136#define PF_NOSTOP 0x40
137#define PF_UCNTL 0x80 /* user control mode */
138
139#ifdef notyet
140/*
141 * Establish n (or default if n is 1) ptys in the system.
142 *
143 * XXX cdevsw & pstat require the array `pty[]' to be an array
144 */
145static void
146ptyattach(n)
147 int n;
148{
149 char *mem;
150 register u_long ntb;
151#define DEFAULT_NPTY 32
152
153 /* maybe should allow 0 => none? */
154 if (n <= 1)
155 n = DEFAULT_NPTY;
156 ntb = n * sizeof(struct tty);
157 mem = malloc(ntb + ALIGNBYTES + n * sizeof(struct pt_ioctl),
158 M_DEVBUF, M_WAITOK);
159 pt_tty = (struct tty *)mem;
160 mem = (char *)ALIGN(mem + ntb);
161 pt_ioctl = (struct pt_ioctl *)mem;
162 npty = n;
163}
164#endif
165
166/*ARGSUSED*/
167static int
168ptsopen(dev, flag, devtype, p)
169 dev_t dev;
170 int flag, devtype;
171 struct proc *p;
172{
173 register struct tty *tp;
174 int error;
175
176 if (minor(dev) >= npty)
177 return (ENXIO);
178 tp = &pt_tty[minor(dev)];
179 if ((tp->t_state & TS_ISOPEN) == 0) {
180 ttychars(tp); /* Set up default chars */
181 tp->t_iflag = TTYDEF_IFLAG;
182 tp->t_oflag = TTYDEF_OFLAG;
183 tp->t_lflag = TTYDEF_LFLAG;
184 tp->t_cflag = TTYDEF_CFLAG;
185 tp->t_ispeed = tp->t_ospeed = TTYDEF_SPEED;
186 } else if (tp->t_state & TS_XCLUDE && suser(p))
187 return (EBUSY);
188 if (tp->t_oproc) /* Ctrlr still around. */
189 (void)(*linesw[tp->t_line].l_modem)(tp, 1);
190 while ((tp->t_state & TS_CARR_ON) == 0) {
191 if (flag&FNONBLOCK)
192 break;
193 error = ttysleep(tp, TSA_CARR_ON(tp), TTIPRI | PCATCH,
194 "ptsopn", 0);
195 if (error)
196 return (error);
197 }
198 error = (*linesw[tp->t_line].l_open)(dev, tp);
199 if (error == 0)
200 ptcwakeup(tp, FREAD|FWRITE);
201 return (error);
202}
203
204static int
205ptsclose(dev, flag, mode, p)
206 dev_t dev;
207 int flag, mode;
208 struct proc *p;
209{
210 register struct tty *tp;
211 int err;
212
213 tp = &pt_tty[minor(dev)];
214 err = (*linesw[tp->t_line].l_close)(tp, flag);
215 ptsstop(tp, FREAD|FWRITE);
216 (void) ttyclose(tp);
217 return (err);
218}
219
220static int
221ptsread(dev, uio, flag)
222 dev_t dev;
223 struct uio *uio;
224 int flag;
225{
226 struct proc *p = curproc;
227 register struct tty *tp = &pt_tty[minor(dev)];
228 register struct pt_ioctl *pti = &pt_ioctl[minor(dev)];
229 int error = 0;
230
231again:
232 if (pti->pt_flags & PF_REMOTE) {
233 while (isbackground(p, tp)) {
234 if ((p->p_sigignore & sigmask(SIGTTIN)) ||
235 (p->p_sigmask & sigmask(SIGTTIN)) ||
236 p->p_pgrp->pg_jobc == 0 ||
237 p->p_flag & P_PPWAIT)
238 return (EIO);
239 pgsignal(p->p_pgrp, SIGTTIN, 1);
240 error = ttysleep(tp, &lbolt, TTIPRI | PCATCH, "ptsbg",
241 0);
242 if (error)
243 return (error);
244 }
245 if (tp->t_canq.c_cc == 0) {
246 if (flag & IO_NDELAY)
247 return (EWOULDBLOCK);
248 error = ttysleep(tp, TSA_PTS_READ(tp), TTIPRI | PCATCH,
249 "ptsin", 0);
250 if (error)
251 return (error);
252 goto again;
253 }
254 while (tp->t_canq.c_cc > 1 && uio->uio_resid > 0)
255 if (ureadc(getc(&tp->t_canq), uio) < 0) {
256 error = EFAULT;
257 break;
258 }
259 if (tp->t_canq.c_cc == 1)
260 (void) getc(&tp->t_canq);
261 if (tp->t_canq.c_cc)
262 return (error);
263 } else
264 if (tp->t_oproc)
265 error = (*linesw[tp->t_line].l_read)(tp, uio, flag);
266 ptcwakeup(tp, FWRITE);
267 return (error);
268}
269
270/*
271 * Write to pseudo-tty.
272 * Wakeups of controlling tty will happen
273 * indirectly, when tty driver calls ptsstart.
274 */
275static int
276ptswrite(dev, uio, flag)
277 dev_t dev;
278 struct uio *uio;
279 int flag;
280{
281 register struct tty *tp;
282
283 tp = &pt_tty[minor(dev)];
284 if (tp->t_oproc == 0)
285 return (EIO);
286 return ((*linesw[tp->t_line].l_write)(tp, uio, flag));
287}
288
289/*
290 * Start output on pseudo-tty.
291 * Wake up process selecting or sleeping for input from controlling tty.
292 */
293static void
294ptsstart(tp)
295 struct tty *tp;
296{
297 register struct pt_ioctl *pti = &pt_ioctl[minor(tp->t_dev)];
298
299 if (tp->t_state & TS_TTSTOP)
300 return;
301 if (pti->pt_flags & PF_STOPPED) {
302 pti->pt_flags &= ~PF_STOPPED;
303 pti->pt_send = TIOCPKT_START;
304 }
305 ptcwakeup(tp, FREAD);
306}
307
308static void
309ptcwakeup(tp, flag)
310 struct tty *tp;
311 int flag;
312{
313 struct pt_ioctl *pti = &pt_ioctl[minor(tp->t_dev)];
314
315 if (flag & FREAD) {
316 selwakeup(&pti->pt_selr);
317 wakeup(TSA_PTC_READ(tp));
318 }
319 if (flag & FWRITE) {
320 selwakeup(&pti->pt_selw);
321 wakeup(TSA_PTC_WRITE(tp));
322 }
323}
324
325static int
326ptcopen(dev, flag, devtype, p)
327 dev_t dev;
328 int flag, devtype;
329 struct proc *p;
330{
331 register struct tty *tp;
332 struct pt_ioctl *pti;
333
334 if (minor(dev) >= npty)
335 return (ENXIO);
336 tp = &pt_tty[minor(dev)];
337 if (tp->t_oproc)
338 return (EIO);
339 tp->t_oproc = ptsstart;
340#ifdef sun4c
341 tp->t_stop = ptsstop;
342#endif
343 (void)(*linesw[tp->t_line].l_modem)(tp, 1);
344 tp->t_lflag &= ~EXTPROC;
345 pti = &pt_ioctl[minor(dev)];
346 pti->pt_flags = 0;
347 pti->pt_send = 0;
348 pti->pt_ucntl = 0;
349 return (0);
350}
351
352static int
353ptcclose(dev, flags, fmt, p)
354 dev_t dev;
355 int flags;
356 int fmt;
357 struct proc *p;
358{
359 register struct tty *tp;
360
361 tp = &pt_tty[minor(dev)];
362 (void)(*linesw[tp->t_line].l_modem)(tp, 0);
363
364 /*
365 * XXX MDMBUF makes no sense for ptys but would inhibit the above
366 * l_modem(). CLOCAL makes sense but isn't supported. Special
367 * l_modem()s that ignore carrier drop make no sense for ptys but
368 * may be in use because other parts of the line discipline make
369 * sense for ptys. Recover by doing everything that a normal
370 * ttymodem() would have done except for sending a SIGHUP.
371 */
372 if (tp->t_state & TS_ISOPEN) {
373 tp->t_state &= ~(TS_CARR_ON | TS_CONNECTED);
374 tp->t_state |= TS_ZOMBIE;
375 ttyflush(tp, FREAD | FWRITE);
376 }
377
378 tp->t_oproc = 0; /* mark closed */
379 return (0);
380}
381
382static int
383ptcread(dev, uio, flag)
384 dev_t dev;
385 struct uio *uio;
386 int flag;
387{
388 register struct tty *tp = &pt_tty[minor(dev)];
389 struct pt_ioctl *pti = &pt_ioctl[minor(dev)];
390 char buf[BUFSIZ];
391 int error = 0, cc;
392
393 /*
394 * We want to block until the slave
395 * is open, and there's something to read;
396 * but if we lost the slave or we're NBIO,
397 * then return the appropriate error instead.
398 */
399 for (;;) {
400 if (tp->t_state&TS_ISOPEN) {
401 if (pti->pt_flags&PF_PKT && pti->pt_send) {
402 error = ureadc((int)pti->pt_send, uio);
403 if (error)
404 return (error);
405 if (pti->pt_send & TIOCPKT_IOCTL) {
406 cc = min(uio->uio_resid,
407 sizeof(tp->t_termios));
408 uiomove((caddr_t)&tp->t_termios, cc,
409 uio);
410 }
411 pti->pt_send = 0;
412 return (0);
413 }
414 if (pti->pt_flags&PF_UCNTL && pti->pt_ucntl) {
415 error = ureadc((int)pti->pt_ucntl, uio);
416 if (error)
417 return (error);
418 pti->pt_ucntl = 0;
419 return (0);
420 }
421 if (tp->t_outq.c_cc && (tp->t_state&TS_TTSTOP) == 0)
422 break;
423 }
424 if ((tp->t_state & TS_CONNECTED) == 0)
425 return (0); /* EOF */
426 if (flag & IO_NDELAY)
427 return (EWOULDBLOCK);
428 error = tsleep(TSA_PTC_READ(tp), TTIPRI | PCATCH, "ptcin", 0);
429 if (error)
430 return (error);
431 }
432 if (pti->pt_flags & (PF_PKT|PF_UCNTL))
433 error = ureadc(0, uio);
434 while (uio->uio_resid > 0 && error == 0) {
435 cc = q_to_b(&tp->t_outq, buf, min(uio->uio_resid, BUFSIZ));
436 if (cc <= 0)
437 break;
438 error = uiomove(buf, cc, uio);
439 }
440 ttwwakeup(tp);
441 return (error);
442}
443
444static void
445ptsstop(tp, flush)
446 register struct tty *tp;
447 int flush;
448{
449 struct pt_ioctl *pti = &pt_ioctl[minor(tp->t_dev)];
450 int flag;
451
452 /* note: FLUSHREAD and FLUSHWRITE already ok */
453 if (flush == 0) {
454 flush = TIOCPKT_STOP;
455 pti->pt_flags |= PF_STOPPED;
456 } else
457 pti->pt_flags &= ~PF_STOPPED;
458 pti->pt_send |= flush;
459 /* change of perspective */
460 flag = 0;
461 if (flush & FREAD)
462 flag |= FWRITE;
463 if (flush & FWRITE)
464 flag |= FREAD;
465 ptcwakeup(tp, flag);
466}
467
468static int
469ptcpoll(dev, events, p)
470 dev_t dev;
471 int events;
472 struct proc *p;
473{
474 register struct tty *tp = &pt_tty[minor(dev)];
475 struct pt_ioctl *pti = &pt_ioctl[minor(dev)];
476 int revents = 0;
477 int s;
478
479 if ((tp->t_state & TS_CONNECTED) == 0)
480 return (seltrue(dev, events, p) | POLLHUP);
481
482 /*
483 * Need to block timeouts (ttrstart).
484 */
485 s = spltty();
486
487 if (events & (POLLIN | POLLRDNORM))
488 if ((tp->t_state & TS_ISOPEN) &&
489 ((tp->t_outq.c_cc && (tp->t_state & TS_TTSTOP) == 0) ||
490 ((pti->pt_flags & PF_PKT) && pti->pt_send) ||
491 ((pti->pt_flags & PF_UCNTL) && pti->pt_ucntl)))
492 revents |= events & (POLLIN | POLLRDNORM);
493
494 if (events & (POLLOUT | POLLWRNORM))
495 if (tp->t_state & TS_ISOPEN &&
496 ((pti->pt_flags & PF_REMOTE) ?
497 (tp->t_canq.c_cc == 0) :
498 ((tp->t_rawq.c_cc + tp->t_canq.c_cc < TTYHOG - 2) ||
499 (tp->t_canq.c_cc == 0 && (tp->t_iflag & ICANON)))))
500 revents |= events & (POLLOUT | POLLWRNORM);
501
502 if (events & POLLHUP)
503 if ((tp->t_state & TS_CARR_ON) == 0)
504 revents |= POLLHUP;
505
506 if (revents == 0) {
507 if (events & (POLLIN | POLLRDNORM))
508 selrecord(p, &pti->pt_selr);
509
510 if (events & (POLLOUT | POLLWRNORM))
511 selrecord(p, &pti->pt_selw);
512 }
513 splx(s);
514
515 return (revents);
516}
517
518static int
519ptcwrite(dev, uio, flag)
520 dev_t dev;
521 register struct uio *uio;
522 int flag;
523{
524 register struct tty *tp = &pt_tty[minor(dev)];
525 register u_char *cp = 0;
526 register int cc = 0;
527 u_char locbuf[BUFSIZ];
528 int cnt = 0;
529 struct pt_ioctl *pti = &pt_ioctl[minor(dev)];
530 int error = 0;
531
532again:
533 if ((tp->t_state&TS_ISOPEN) == 0)
534 goto block;
535 if (pti->pt_flags & PF_REMOTE) {
536 if (tp->t_canq.c_cc)
537 goto block;
538 while ((uio->uio_resid > 0 || cc > 0) &&
539 tp->t_canq.c_cc < TTYHOG - 1) {
540 if (cc == 0) {
541 cc = min(uio->uio_resid, BUFSIZ);
542 cc = min(cc, TTYHOG - 1 - tp->t_canq.c_cc);
543 cp = locbuf;
544 error = uiomove((caddr_t)cp, cc, uio);
545 if (error)
546 return (error);
547 /* check again for safety */
548 if ((tp->t_state & TS_ISOPEN) == 0) {
549 /* adjust as usual */
550 uio->uio_resid += cc;
551 return (EIO);
552 }
553 }
554 if (cc > 0) {
555 cc = b_to_q((char *)cp, cc, &tp->t_canq);
556 /*
557 * XXX we don't guarantee that the canq size
558 * is >= TTYHOG, so the above b_to_q() may
559 * leave some bytes uncopied. However, space
560 * is guaranteed for the null terminator if
561 * we don't fail here since (TTYHOG - 1) is
562 * not a multiple of CBSIZE.
563 */
564 if (cc > 0)
565 break;
566 }
567 }
568 /* adjust for data copied in but not written */
569 uio->uio_resid += cc;
570 (void) putc(0, &tp->t_canq);
571 ttwakeup(tp);
572 wakeup(TSA_PTS_READ(tp));
573 return (0);
574 }
575 while (uio->uio_resid > 0 || cc > 0) {
576 if (cc == 0) {
577 cc = min(uio->uio_resid, BUFSIZ);
578 cp = locbuf;
579 error = uiomove((caddr_t)cp, cc, uio);
580 if (error)
581 return (error);
582 /* check again for safety */
583 if ((tp->t_state & TS_ISOPEN) == 0) {
584 /* adjust for data copied in but not written */
585 uio->uio_resid += cc;
586 return (EIO);
587 }
588 }
589 while (cc > 0) {
590 if ((tp->t_rawq.c_cc + tp->t_canq.c_cc) >= TTYHOG - 2 &&
591 (tp->t_canq.c_cc > 0 || !(tp->t_iflag&ICANON))) {
592 wakeup(TSA_HUP_OR_INPUT(tp));
593 goto block;
594 }
595 (*linesw[tp->t_line].l_rint)(*cp++, tp);
596 cnt++;
597 cc--;
598 }
599 cc = 0;
600 }
601 return (0);
602block:
603 /*
604 * Come here to wait for slave to open, for space
605 * in outq, or space in rawq, or an empty canq.
606 */
607 if ((tp->t_state & TS_CONNECTED) == 0) {
608 /* adjust for data copied in but not written */
609 uio->uio_resid += cc;
610 return (EIO);
611 }
612 if (flag & IO_NDELAY) {
613 /* adjust for data copied in but not written */
614 uio->uio_resid += cc;
615 if (cnt == 0)
616 return (EWOULDBLOCK);
617 return (0);
618 }
619 error = tsleep(TSA_PTC_WRITE(tp), TTOPRI | PCATCH, "ptcout", 0);
620 if (error) {
621 /* adjust for data copied in but not written */
622 uio->uio_resid += cc;
623 return (error);
624 }
625 goto again;
626}
627
628static struct tty *
629ptydevtotty(dev)
630 dev_t dev;
631{
632 if (minor(dev) >= npty)
633 return (NULL);
634
635 return &pt_tty[minor(dev)];
636}
637
638/*ARGSUSED*/
639static int
640ptyioctl(dev, cmd, data, flag, p)
641 dev_t dev;
642 u_long cmd;
643 caddr_t data;
644 int flag;
645 struct proc *p;
646{
647 register struct tty *tp = &pt_tty[minor(dev)];
648 register struct pt_ioctl *pti = &pt_ioctl[minor(dev)];
649 register u_char *cc = tp->t_cc;
650 int stop, error;
651
|
747 error = (*linesw[tp->t_line].l_ioctl)(tp, cmd, data, flag, p);
748 if (error == ENOIOCTL)
749 error = ttioctl(tp, cmd, data, flag);
750 if (error == ENOIOCTL) {
751 if (pti->pt_flags & PF_UCNTL &&
752 (cmd & ~0xff) == UIOCCMD(0)) {
753 if (cmd & 0xff) {
754 pti->pt_ucntl = (u_char)cmd;
755 ptcwakeup(tp, FREAD);
756 }
757 return (0);
758 }
759 error = ENOTTY;
760 }
761 /*
762 * If external processing and packet mode send ioctl packet.
763 */
764 if ((tp->t_lflag&EXTPROC) && (pti->pt_flags & PF_PKT)) {
765 switch(cmd) {
766 case TIOCSETA:
767 case TIOCSETAW:
768 case TIOCSETAF:
769#ifdef COMPAT_43
770 case TIOCSETP:
771 case TIOCSETN:
772#endif
773#if defined(COMPAT_43) || defined(COMPAT_SUNOS)
774 case TIOCSETC:
775 case TIOCSLTC:
776 case TIOCLBIS:
777 case TIOCLBIC:
778 case TIOCLSET:
779#endif
780 pti->pt_send |= TIOCPKT_IOCTL;
781 ptcwakeup(tp, FREAD);
782 default:
783 break;
784 }
785 }
786 stop = (tp->t_iflag & IXON) && CCEQ(cc[VSTOP], CTRL('s'))
787 && CCEQ(cc[VSTART], CTRL('q'));
788 if (pti->pt_flags & PF_NOSTOP) {
789 if (stop) {
790 pti->pt_send &= ~TIOCPKT_NOSTOP;
791 pti->pt_send |= TIOCPKT_DOSTOP;
792 pti->pt_flags &= ~PF_NOSTOP;
793 ptcwakeup(tp, FREAD);
794 }
795 } else {
796 if (!stop) {
797 pti->pt_send &= ~TIOCPKT_DOSTOP;
798 pti->pt_send |= TIOCPKT_NOSTOP;
799 pti->pt_flags |= PF_NOSTOP;
800 ptcwakeup(tp, FREAD);
801 }
802 }
803 return (error);
804}
805
806static int ptc_devsw_installed;
807
808static void ptc_drvinit __P((void *unused));
809static void
810ptc_drvinit(unused)
811 void *unused;
812{
813#ifdef DEVFS
814 int i,j,k;
815#endif
816 dev_t dev;
817
818 if( ! ptc_devsw_installed ) {
819 dev = makedev(CDEV_MAJOR_S, 0);
820 cdevsw_add(&dev, &pts_cdevsw, NULL);
821 dev = makedev(CDEV_MAJOR_C, 0);
822 cdevsw_add(&dev, &ptc_cdevsw, NULL);
823 ptc_devsw_installed = 1;
824#ifdef DEVFS
825 for ( i = 0 ; i<NPTY ; i++ ) {
826 j = i / 32;
827 k = i % 32;
828 devfs_token_pts[i] =
829 devfs_add_devswf(&pts_cdevsw,i,
830 DV_CHR,0,0,0666,
831 "tty%c%r",jnames[j],k);
832 devfs_token_ptc[i] =
833 devfs_add_devswf(&ptc_cdevsw,i,
834 DV_CHR,0,0,0666,
835 "pty%c%r",jnames[j],k);
836 }
837#endif
838 }
839}
840
841SYSINIT(ptcdev,SI_SUB_DRIVERS,SI_ORDER_MIDDLE+CDEV_MAJOR_C,ptc_drvinit,NULL)
| 749 error = (*linesw[tp->t_line].l_ioctl)(tp, cmd, data, flag, p);
750 if (error == ENOIOCTL)
751 error = ttioctl(tp, cmd, data, flag);
752 if (error == ENOIOCTL) {
753 if (pti->pt_flags & PF_UCNTL &&
754 (cmd & ~0xff) == UIOCCMD(0)) {
755 if (cmd & 0xff) {
756 pti->pt_ucntl = (u_char)cmd;
757 ptcwakeup(tp, FREAD);
758 }
759 return (0);
760 }
761 error = ENOTTY;
762 }
763 /*
764 * If external processing and packet mode send ioctl packet.
765 */
766 if ((tp->t_lflag&EXTPROC) && (pti->pt_flags & PF_PKT)) {
767 switch(cmd) {
768 case TIOCSETA:
769 case TIOCSETAW:
770 case TIOCSETAF:
771#ifdef COMPAT_43
772 case TIOCSETP:
773 case TIOCSETN:
774#endif
775#if defined(COMPAT_43) || defined(COMPAT_SUNOS)
776 case TIOCSETC:
777 case TIOCSLTC:
778 case TIOCLBIS:
779 case TIOCLBIC:
780 case TIOCLSET:
781#endif
782 pti->pt_send |= TIOCPKT_IOCTL;
783 ptcwakeup(tp, FREAD);
784 default:
785 break;
786 }
787 }
788 stop = (tp->t_iflag & IXON) && CCEQ(cc[VSTOP], CTRL('s'))
789 && CCEQ(cc[VSTART], CTRL('q'));
790 if (pti->pt_flags & PF_NOSTOP) {
791 if (stop) {
792 pti->pt_send &= ~TIOCPKT_NOSTOP;
793 pti->pt_send |= TIOCPKT_DOSTOP;
794 pti->pt_flags &= ~PF_NOSTOP;
795 ptcwakeup(tp, FREAD);
796 }
797 } else {
798 if (!stop) {
799 pti->pt_send &= ~TIOCPKT_DOSTOP;
800 pti->pt_send |= TIOCPKT_NOSTOP;
801 pti->pt_flags |= PF_NOSTOP;
802 ptcwakeup(tp, FREAD);
803 }
804 }
805 return (error);
806}
807
808static int ptc_devsw_installed;
809
810static void ptc_drvinit __P((void *unused));
811static void
812ptc_drvinit(unused)
813 void *unused;
814{
815#ifdef DEVFS
816 int i,j,k;
817#endif
818 dev_t dev;
819
820 if( ! ptc_devsw_installed ) {
821 dev = makedev(CDEV_MAJOR_S, 0);
822 cdevsw_add(&dev, &pts_cdevsw, NULL);
823 dev = makedev(CDEV_MAJOR_C, 0);
824 cdevsw_add(&dev, &ptc_cdevsw, NULL);
825 ptc_devsw_installed = 1;
826#ifdef DEVFS
827 for ( i = 0 ; i<NPTY ; i++ ) {
828 j = i / 32;
829 k = i % 32;
830 devfs_token_pts[i] =
831 devfs_add_devswf(&pts_cdevsw,i,
832 DV_CHR,0,0,0666,
833 "tty%c%r",jnames[j],k);
834 devfs_token_ptc[i] =
835 devfs_add_devswf(&ptc_cdevsw,i,
836 DV_CHR,0,0,0666,
837 "pty%c%r",jnames[j],k);
838 }
839#endif
840 }
841}
842
843SYSINIT(ptcdev,SI_SUB_DRIVERS,SI_ORDER_MIDDLE+CDEV_MAJOR_C,ptc_drvinit,NULL)
|