Deleted Added
full compact
pty.c (85844) pty.c (90831)
1/*
2 * Copyright (c) 1982, 1986, 1989, 1993
3 * The Regents of the University of California. All rights reserved.
4 *
5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions
7 * are met:
8 * 1. Redistributions of source code must retain the above copyright
9 * notice, this list of conditions and the following disclaimer.
10 * 2. Redistributions in binary form must reproduce the above copyright
11 * notice, this list of conditions and the following disclaimer in the
12 * documentation and/or other materials provided with the distribution.
13 * 3. All advertising materials mentioning features or use of this software
14 * must display the following acknowledgement:
15 * This product includes software developed by the University of
16 * California, Berkeley and its contributors.
17 * 4. Neither the name of the University nor the names of its contributors
18 * may be used to endorse or promote products derived from this software
19 * without specific prior written permission.
20 *
21 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
22 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
23 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
24 * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
25 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
26 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
27 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
28 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
29 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
30 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
31 * SUCH DAMAGE.
32 *
33 * @(#)tty_pty.c 8.4 (Berkeley) 2/20/95
1/*
2 * Copyright (c) 1982, 1986, 1989, 1993
3 * The Regents of the University of California. All rights reserved.
4 *
5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions
7 * are met:
8 * 1. Redistributions of source code must retain the above copyright
9 * notice, this list of conditions and the following disclaimer.
10 * 2. Redistributions in binary form must reproduce the above copyright
11 * notice, this list of conditions and the following disclaimer in the
12 * documentation and/or other materials provided with the distribution.
13 * 3. All advertising materials mentioning features or use of this software
14 * must display the following acknowledgement:
15 * This product includes software developed by the University of
16 * California, Berkeley and its contributors.
17 * 4. Neither the name of the University nor the names of its contributors
18 * may be used to endorse or promote products derived from this software
19 * without specific prior written permission.
20 *
21 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
22 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
23 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
24 * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
25 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
26 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
27 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
28 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
29 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
30 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
31 * SUCH DAMAGE.
32 *
33 * @(#)tty_pty.c 8.4 (Berkeley) 2/20/95
34 * $FreeBSD: head/sys/kern/tty_pty.c 85844 2001-11-01 20:56:57Z rwatson $
34 * $FreeBSD: head/sys/kern/tty_pty.c 90831 2002-02-18 06:07:11Z dillon $
35 */
36
37/*
38 * Pseudo-teletype Driver
39 * (Actually two drivers, requiring two entries in 'cdevsw')
40 */
41#include "opt_compat.h"
42#include <sys/param.h>
43#include <sys/systm.h>
44#if defined(COMPAT_43) || defined(COMPAT_SUNOS)
45#include <sys/ioctl_compat.h>
46#endif
47#include <sys/proc.h>
48#include <sys/tty.h>
49#include <sys/conf.h>
50#include <sys/fcntl.h>
51#include <sys/poll.h>
52#include <sys/kernel.h>
53#include <sys/vnode.h>
54#include <sys/signalvar.h>
55#include <sys/malloc.h>
56
57static MALLOC_DEFINE(M_PTY, "ptys", "pty data structures");
58
59static void ptsstart __P((struct tty *tp));
60static void ptsstop __P((struct tty *tp, int rw));
61static void ptcwakeup __P((struct tty *tp, int flag));
62static dev_t ptyinit __P((dev_t cdev));
63
64static d_open_t ptsopen;
65static d_close_t ptsclose;
66static d_read_t ptsread;
67static d_write_t ptswrite;
68static d_ioctl_t ptyioctl;
69static d_open_t ptcopen;
70static d_close_t ptcclose;
71static d_read_t ptcread;
72static d_write_t ptcwrite;
73static d_poll_t ptcpoll;
74
75#define CDEV_MAJOR_S 5
76static struct cdevsw pts_cdevsw = {
77 /* open */ ptsopen,
78 /* close */ ptsclose,
79 /* read */ ptsread,
80 /* write */ ptswrite,
81 /* ioctl */ ptyioctl,
82 /* poll */ ttypoll,
83 /* mmap */ nommap,
84 /* strategy */ nostrategy,
85 /* name */ "pts",
86 /* maj */ CDEV_MAJOR_S,
87 /* dump */ nodump,
88 /* psize */ nopsize,
89 /* flags */ D_TTY | D_KQFILTER,
90 /* kqfilter */ ttykqfilter,
91};
92
93#define CDEV_MAJOR_C 6
94static struct cdevsw ptc_cdevsw = {
95 /* open */ ptcopen,
96 /* close */ ptcclose,
97 /* read */ ptcread,
98 /* write */ ptcwrite,
99 /* ioctl */ ptyioctl,
100 /* poll */ ptcpoll,
101 /* mmap */ nommap,
102 /* strategy */ nostrategy,
103 /* name */ "ptc",
104 /* maj */ CDEV_MAJOR_C,
105 /* dump */ nodump,
106 /* psize */ nopsize,
107 /* flags */ D_TTY | D_KQFILTER,
108 /* kqfilter */ ttykqfilter,
109};
110
111#define BUFSIZ 100 /* Chunk size iomoved to/from user */
112
113struct pt_ioctl {
114 int pt_flags;
115 struct selinfo pt_selr, pt_selw;
116 u_char pt_send;
117 u_char pt_ucntl;
118 struct tty pt_tty;
119 dev_t devs, devc;
120 struct prison *pt_prison;
121};
122
123#define PF_PKT 0x08 /* packet mode */
124#define PF_STOPPED 0x10 /* user told stopped */
125#define PF_REMOTE 0x20 /* remote and flow controlled input */
126#define PF_NOSTOP 0x40
127#define PF_UCNTL 0x80 /* user control mode */
128
129static char *names = "pqrsPQRS";
130/*
131 * This function creates and initializes a pts/ptc pair
132 *
133 * pts == /dev/tty[pqrsPQRS][0123456789abcdefghijklmnopqrstuv]
134 * ptc == /dev/pty[pqrsPQRS][0123456789abcdefghijklmnopqrstuv]
135 *
136 * XXX: define and add mapping of upper minor bits to allow more
137 * than 256 ptys.
138 */
139static dev_t
140ptyinit(dev_t devc)
141{
142 dev_t devs;
143 struct pt_ioctl *pt;
144 int n;
145
146 n = minor(devc);
147 /* For now we only map the lower 8 bits of the minor */
148 if (n & ~0xff)
149 return (NODEV);
150
151 devc->si_flags &= ~SI_CHEAPCLONE;
152
153 pt = malloc(sizeof(*pt), M_PTY, M_WAITOK | M_ZERO);
154 pt->devs = devs = make_dev(&pts_cdevsw, n,
155 UID_ROOT, GID_WHEEL, 0666, "tty%c%r", names[n / 32], n % 32);
156 pt->devc = devc;
157
158 devs->si_drv1 = devc->si_drv1 = pt;
159 devs->si_tty = devc->si_tty = &pt->pt_tty;
160 pt->pt_tty.t_dev = devs;
161 ttyregister(&pt->pt_tty);
162 return (devc);
163}
164
165/*ARGSUSED*/
166static int
167ptsopen(dev, flag, devtype, td)
168 dev_t dev;
169 int flag, devtype;
170 struct thread *td;
171{
172 struct proc *p = td->td_proc;
173 register struct tty *tp;
174 int error;
175 struct pt_ioctl *pti;
176
177 if (!dev->si_drv1)
178 return(ENXIO);
179 pti = dev->si_drv1;
180 tp = dev->si_tty;
181 if ((tp->t_state & TS_ISOPEN) == 0) {
182 ttychars(tp); /* Set up default chars */
183 tp->t_iflag = TTYDEF_IFLAG;
184 tp->t_oflag = TTYDEF_OFLAG;
185 tp->t_lflag = TTYDEF_LFLAG;
186 tp->t_cflag = TTYDEF_CFLAG;
187 tp->t_ispeed = tp->t_ospeed = TTYDEF_SPEED;
188 } else if (tp->t_state & TS_XCLUDE && suser_xxx(p->p_ucred, NULL, 0)) {
189 return (EBUSY);
190 } else if (pti->pt_prison != p->p_ucred->cr_prison) {
191 return (EBUSY);
192 }
193 if (tp->t_oproc) /* Ctrlr still around. */
194 (void)(*linesw[tp->t_line].l_modem)(tp, 1);
195 while ((tp->t_state & TS_CARR_ON) == 0) {
196 if (flag&FNONBLOCK)
197 break;
198 error = ttysleep(tp, TSA_CARR_ON(tp), TTIPRI | PCATCH,
199 "ptsopn", 0);
200 if (error)
201 return (error);
202 }
203 error = (*linesw[tp->t_line].l_open)(dev, tp);
204 if (error == 0)
205 ptcwakeup(tp, FREAD|FWRITE);
206 return (error);
207}
208
209static int
210ptsclose(dev, flag, mode, td)
211 dev_t dev;
212 int flag, mode;
213 struct thread *td;
214{
215 register struct tty *tp;
216 int err;
217
218 tp = dev->si_tty;
219 err = (*linesw[tp->t_line].l_close)(tp, flag);
220 ptsstop(tp, FREAD|FWRITE);
221 (void) ttyclose(tp);
222 return (err);
223}
224
225static int
226ptsread(dev, uio, flag)
227 dev_t dev;
228 struct uio *uio;
229 int flag;
230{
231 struct thread *td = curthread;
232 struct proc *p = td->td_proc;
233 register struct tty *tp = dev->si_tty;
234 register struct pt_ioctl *pti = dev->si_drv1;
235 int error = 0;
236
237again:
238 if (pti->pt_flags & PF_REMOTE) {
239 while (isbackground(p, tp)) {
240 if (SIGISMEMBER(p->p_sigignore, SIGTTIN) ||
241 SIGISMEMBER(p->p_sigmask, SIGTTIN) ||
242 p->p_pgrp->pg_jobc == 0 || p->p_flag & P_PPWAIT)
243 return (EIO);
244 pgsignal(p->p_pgrp, SIGTTIN, 1);
245 error = ttysleep(tp, &lbolt, TTIPRI | PCATCH, "ptsbg",
246 0);
247 if (error)
248 return (error);
249 }
250 if (tp->t_canq.c_cc == 0) {
251 if (flag & IO_NDELAY)
252 return (EWOULDBLOCK);
253 error = ttysleep(tp, TSA_PTS_READ(tp), TTIPRI | PCATCH,
254 "ptsin", 0);
255 if (error)
256 return (error);
257 goto again;
258 }
259 while (tp->t_canq.c_cc > 1 && uio->uio_resid > 0)
260 if (ureadc(getc(&tp->t_canq), uio) < 0) {
261 error = EFAULT;
262 break;
263 }
264 if (tp->t_canq.c_cc == 1)
265 (void) getc(&tp->t_canq);
266 if (tp->t_canq.c_cc)
267 return (error);
268 } else
269 if (tp->t_oproc)
270 error = (*linesw[tp->t_line].l_read)(tp, uio, flag);
271 ptcwakeup(tp, FWRITE);
272 return (error);
273}
274
275/*
276 * Write to pseudo-tty.
277 * Wakeups of controlling tty will happen
278 * indirectly, when tty driver calls ptsstart.
279 */
280static int
281ptswrite(dev, uio, flag)
282 dev_t dev;
283 struct uio *uio;
284 int flag;
285{
286 register struct tty *tp;
287
288 tp = dev->si_tty;
289 if (tp->t_oproc == 0)
290 return (EIO);
291 return ((*linesw[tp->t_line].l_write)(tp, uio, flag));
292}
293
294/*
295 * Start output on pseudo-tty.
296 * Wake up process selecting or sleeping for input from controlling tty.
297 */
298static void
299ptsstart(tp)
300 struct tty *tp;
301{
302 register struct pt_ioctl *pti = tp->t_dev->si_drv1;
303
304 if (tp->t_state & TS_TTSTOP)
305 return;
306 if (pti->pt_flags & PF_STOPPED) {
307 pti->pt_flags &= ~PF_STOPPED;
308 pti->pt_send = TIOCPKT_START;
309 }
310 ptcwakeup(tp, FREAD);
311}
312
313static void
314ptcwakeup(tp, flag)
315 struct tty *tp;
316 int flag;
317{
318 struct pt_ioctl *pti = tp->t_dev->si_drv1;
319
320 if (flag & FREAD) {
321 selwakeup(&pti->pt_selr);
322 wakeup(TSA_PTC_READ(tp));
323 }
324 if (flag & FWRITE) {
325 selwakeup(&pti->pt_selw);
326 wakeup(TSA_PTC_WRITE(tp));
327 }
328}
329
330static int
331ptcopen(dev, flag, devtype, td)
332 dev_t dev;
333 int flag, devtype;
334 struct thread *td;
335{
336 struct proc *p = td->td_proc;
337 register struct tty *tp;
338 struct pt_ioctl *pti;
339
340 if (!dev->si_drv1)
341 ptyinit(dev);
342 if (!dev->si_drv1)
343 return(ENXIO);
344 tp = dev->si_tty;
345 if (tp->t_oproc)
346 return (EIO);
347 tp->t_timeout = -1;
348 tp->t_oproc = ptsstart;
349 tp->t_stop = ptsstop;
350 (void)(*linesw[tp->t_line].l_modem)(tp, 1);
351 tp->t_lflag &= ~EXTPROC;
352 pti = dev->si_drv1;
353 pti->pt_prison = p->p_ucred->cr_prison;
354 pti->pt_flags = 0;
355 pti->pt_send = 0;
356 pti->pt_ucntl = 0;
357 return (0);
358}
359
360static int
361ptcclose(dev, flags, fmt, td)
362 dev_t dev;
363 int flags;
364 int fmt;
365 struct thread *td;
366{
367 register struct tty *tp;
368
369 tp = dev->si_tty;
370 (void)(*linesw[tp->t_line].l_modem)(tp, 0);
371
372 /*
373 * XXX MDMBUF makes no sense for ptys but would inhibit the above
374 * l_modem(). CLOCAL makes sense but isn't supported. Special
375 * l_modem()s that ignore carrier drop make no sense for ptys but
376 * may be in use because other parts of the line discipline make
377 * sense for ptys. Recover by doing everything that a normal
378 * ttymodem() would have done except for sending a SIGHUP.
379 */
380 if (tp->t_state & TS_ISOPEN) {
381 tp->t_state &= ~(TS_CARR_ON | TS_CONNECTED);
382 tp->t_state |= TS_ZOMBIE;
383 ttyflush(tp, FREAD | FWRITE);
384 }
385
386 tp->t_oproc = 0; /* mark closed */
387 return (0);
388}
389
390static int
391ptcread(dev, uio, flag)
392 dev_t dev;
393 struct uio *uio;
394 int flag;
395{
396 register struct tty *tp = dev->si_tty;
397 struct pt_ioctl *pti = dev->si_drv1;
398 char buf[BUFSIZ];
399 int error = 0, cc;
400
401 /*
402 * We want to block until the slave
403 * is open, and there's something to read;
404 * but if we lost the slave or we're NBIO,
405 * then return the appropriate error instead.
406 */
407 for (;;) {
408 if (tp->t_state&TS_ISOPEN) {
409 if (pti->pt_flags&PF_PKT && pti->pt_send) {
410 error = ureadc((int)pti->pt_send, uio);
411 if (error)
412 return (error);
413 if (pti->pt_send & TIOCPKT_IOCTL) {
414 cc = min(uio->uio_resid,
415 sizeof(tp->t_termios));
416 uiomove((caddr_t)&tp->t_termios, cc,
417 uio);
418 }
419 pti->pt_send = 0;
420 return (0);
421 }
422 if (pti->pt_flags&PF_UCNTL && pti->pt_ucntl) {
423 error = ureadc((int)pti->pt_ucntl, uio);
424 if (error)
425 return (error);
426 pti->pt_ucntl = 0;
427 return (0);
428 }
429 if (tp->t_outq.c_cc && (tp->t_state&TS_TTSTOP) == 0)
430 break;
431 }
432 if ((tp->t_state & TS_CONNECTED) == 0)
433 return (0); /* EOF */
434 if (flag & IO_NDELAY)
435 return (EWOULDBLOCK);
436 error = tsleep(TSA_PTC_READ(tp), TTIPRI | PCATCH, "ptcin", 0);
437 if (error)
438 return (error);
439 }
440 if (pti->pt_flags & (PF_PKT|PF_UCNTL))
441 error = ureadc(0, uio);
442 while (uio->uio_resid > 0 && error == 0) {
443 cc = q_to_b(&tp->t_outq, buf, min(uio->uio_resid, BUFSIZ));
444 if (cc <= 0)
445 break;
446 error = uiomove(buf, cc, uio);
447 }
448 ttwwakeup(tp);
449 return (error);
450}
451
452static void
453ptsstop(tp, flush)
454 register struct tty *tp;
455 int flush;
456{
457 struct pt_ioctl *pti = tp->t_dev->si_drv1;
458 int flag;
459
460 /* note: FLUSHREAD and FLUSHWRITE already ok */
461 if (flush == 0) {
462 flush = TIOCPKT_STOP;
463 pti->pt_flags |= PF_STOPPED;
464 } else
465 pti->pt_flags &= ~PF_STOPPED;
466 pti->pt_send |= flush;
467 /* change of perspective */
468 flag = 0;
469 if (flush & FREAD)
470 flag |= FWRITE;
471 if (flush & FWRITE)
472 flag |= FREAD;
473 ptcwakeup(tp, flag);
474}
475
476static int
477ptcpoll(dev, events, td)
478 dev_t dev;
479 int events;
480 struct thread *td;
481{
482 register struct tty *tp = dev->si_tty;
483 struct pt_ioctl *pti = dev->si_drv1;
484 int revents = 0;
485 int s;
486
487 if ((tp->t_state & TS_CONNECTED) == 0)
488 return (seltrue(dev, events, td) | POLLHUP);
489
490 /*
491 * Need to block timeouts (ttrstart).
492 */
493 s = spltty();
494
495 if (events & (POLLIN | POLLRDNORM))
496 if ((tp->t_state & TS_ISOPEN) &&
497 ((tp->t_outq.c_cc && (tp->t_state & TS_TTSTOP) == 0) ||
498 ((pti->pt_flags & PF_PKT) && pti->pt_send) ||
499 ((pti->pt_flags & PF_UCNTL) && pti->pt_ucntl)))
500 revents |= events & (POLLIN | POLLRDNORM);
501
502 if (events & (POLLOUT | POLLWRNORM))
503 if (tp->t_state & TS_ISOPEN &&
504 ((pti->pt_flags & PF_REMOTE) ?
505 (tp->t_canq.c_cc == 0) :
506 ((tp->t_rawq.c_cc + tp->t_canq.c_cc < TTYHOG - 2) ||
35 */
36
37/*
38 * Pseudo-teletype Driver
39 * (Actually two drivers, requiring two entries in 'cdevsw')
40 */
41#include "opt_compat.h"
42#include <sys/param.h>
43#include <sys/systm.h>
44#if defined(COMPAT_43) || defined(COMPAT_SUNOS)
45#include <sys/ioctl_compat.h>
46#endif
47#include <sys/proc.h>
48#include <sys/tty.h>
49#include <sys/conf.h>
50#include <sys/fcntl.h>
51#include <sys/poll.h>
52#include <sys/kernel.h>
53#include <sys/vnode.h>
54#include <sys/signalvar.h>
55#include <sys/malloc.h>
56
57static MALLOC_DEFINE(M_PTY, "ptys", "pty data structures");
58
59static void ptsstart __P((struct tty *tp));
60static void ptsstop __P((struct tty *tp, int rw));
61static void ptcwakeup __P((struct tty *tp, int flag));
62static dev_t ptyinit __P((dev_t cdev));
63
64static d_open_t ptsopen;
65static d_close_t ptsclose;
66static d_read_t ptsread;
67static d_write_t ptswrite;
68static d_ioctl_t ptyioctl;
69static d_open_t ptcopen;
70static d_close_t ptcclose;
71static d_read_t ptcread;
72static d_write_t ptcwrite;
73static d_poll_t ptcpoll;
74
75#define CDEV_MAJOR_S 5
76static struct cdevsw pts_cdevsw = {
77 /* open */ ptsopen,
78 /* close */ ptsclose,
79 /* read */ ptsread,
80 /* write */ ptswrite,
81 /* ioctl */ ptyioctl,
82 /* poll */ ttypoll,
83 /* mmap */ nommap,
84 /* strategy */ nostrategy,
85 /* name */ "pts",
86 /* maj */ CDEV_MAJOR_S,
87 /* dump */ nodump,
88 /* psize */ nopsize,
89 /* flags */ D_TTY | D_KQFILTER,
90 /* kqfilter */ ttykqfilter,
91};
92
93#define CDEV_MAJOR_C 6
94static struct cdevsw ptc_cdevsw = {
95 /* open */ ptcopen,
96 /* close */ ptcclose,
97 /* read */ ptcread,
98 /* write */ ptcwrite,
99 /* ioctl */ ptyioctl,
100 /* poll */ ptcpoll,
101 /* mmap */ nommap,
102 /* strategy */ nostrategy,
103 /* name */ "ptc",
104 /* maj */ CDEV_MAJOR_C,
105 /* dump */ nodump,
106 /* psize */ nopsize,
107 /* flags */ D_TTY | D_KQFILTER,
108 /* kqfilter */ ttykqfilter,
109};
110
111#define BUFSIZ 100 /* Chunk size iomoved to/from user */
112
113struct pt_ioctl {
114 int pt_flags;
115 struct selinfo pt_selr, pt_selw;
116 u_char pt_send;
117 u_char pt_ucntl;
118 struct tty pt_tty;
119 dev_t devs, devc;
120 struct prison *pt_prison;
121};
122
123#define PF_PKT 0x08 /* packet mode */
124#define PF_STOPPED 0x10 /* user told stopped */
125#define PF_REMOTE 0x20 /* remote and flow controlled input */
126#define PF_NOSTOP 0x40
127#define PF_UCNTL 0x80 /* user control mode */
128
129static char *names = "pqrsPQRS";
130/*
131 * This function creates and initializes a pts/ptc pair
132 *
133 * pts == /dev/tty[pqrsPQRS][0123456789abcdefghijklmnopqrstuv]
134 * ptc == /dev/pty[pqrsPQRS][0123456789abcdefghijklmnopqrstuv]
135 *
136 * XXX: define and add mapping of upper minor bits to allow more
137 * than 256 ptys.
138 */
139static dev_t
140ptyinit(dev_t devc)
141{
142 dev_t devs;
143 struct pt_ioctl *pt;
144 int n;
145
146 n = minor(devc);
147 /* For now we only map the lower 8 bits of the minor */
148 if (n & ~0xff)
149 return (NODEV);
150
151 devc->si_flags &= ~SI_CHEAPCLONE;
152
153 pt = malloc(sizeof(*pt), M_PTY, M_WAITOK | M_ZERO);
154 pt->devs = devs = make_dev(&pts_cdevsw, n,
155 UID_ROOT, GID_WHEEL, 0666, "tty%c%r", names[n / 32], n % 32);
156 pt->devc = devc;
157
158 devs->si_drv1 = devc->si_drv1 = pt;
159 devs->si_tty = devc->si_tty = &pt->pt_tty;
160 pt->pt_tty.t_dev = devs;
161 ttyregister(&pt->pt_tty);
162 return (devc);
163}
164
165/*ARGSUSED*/
166static int
167ptsopen(dev, flag, devtype, td)
168 dev_t dev;
169 int flag, devtype;
170 struct thread *td;
171{
172 struct proc *p = td->td_proc;
173 register struct tty *tp;
174 int error;
175 struct pt_ioctl *pti;
176
177 if (!dev->si_drv1)
178 return(ENXIO);
179 pti = dev->si_drv1;
180 tp = dev->si_tty;
181 if ((tp->t_state & TS_ISOPEN) == 0) {
182 ttychars(tp); /* Set up default chars */
183 tp->t_iflag = TTYDEF_IFLAG;
184 tp->t_oflag = TTYDEF_OFLAG;
185 tp->t_lflag = TTYDEF_LFLAG;
186 tp->t_cflag = TTYDEF_CFLAG;
187 tp->t_ispeed = tp->t_ospeed = TTYDEF_SPEED;
188 } else if (tp->t_state & TS_XCLUDE && suser_xxx(p->p_ucred, NULL, 0)) {
189 return (EBUSY);
190 } else if (pti->pt_prison != p->p_ucred->cr_prison) {
191 return (EBUSY);
192 }
193 if (tp->t_oproc) /* Ctrlr still around. */
194 (void)(*linesw[tp->t_line].l_modem)(tp, 1);
195 while ((tp->t_state & TS_CARR_ON) == 0) {
196 if (flag&FNONBLOCK)
197 break;
198 error = ttysleep(tp, TSA_CARR_ON(tp), TTIPRI | PCATCH,
199 "ptsopn", 0);
200 if (error)
201 return (error);
202 }
203 error = (*linesw[tp->t_line].l_open)(dev, tp);
204 if (error == 0)
205 ptcwakeup(tp, FREAD|FWRITE);
206 return (error);
207}
208
209static int
210ptsclose(dev, flag, mode, td)
211 dev_t dev;
212 int flag, mode;
213 struct thread *td;
214{
215 register struct tty *tp;
216 int err;
217
218 tp = dev->si_tty;
219 err = (*linesw[tp->t_line].l_close)(tp, flag);
220 ptsstop(tp, FREAD|FWRITE);
221 (void) ttyclose(tp);
222 return (err);
223}
224
225static int
226ptsread(dev, uio, flag)
227 dev_t dev;
228 struct uio *uio;
229 int flag;
230{
231 struct thread *td = curthread;
232 struct proc *p = td->td_proc;
233 register struct tty *tp = dev->si_tty;
234 register struct pt_ioctl *pti = dev->si_drv1;
235 int error = 0;
236
237again:
238 if (pti->pt_flags & PF_REMOTE) {
239 while (isbackground(p, tp)) {
240 if (SIGISMEMBER(p->p_sigignore, SIGTTIN) ||
241 SIGISMEMBER(p->p_sigmask, SIGTTIN) ||
242 p->p_pgrp->pg_jobc == 0 || p->p_flag & P_PPWAIT)
243 return (EIO);
244 pgsignal(p->p_pgrp, SIGTTIN, 1);
245 error = ttysleep(tp, &lbolt, TTIPRI | PCATCH, "ptsbg",
246 0);
247 if (error)
248 return (error);
249 }
250 if (tp->t_canq.c_cc == 0) {
251 if (flag & IO_NDELAY)
252 return (EWOULDBLOCK);
253 error = ttysleep(tp, TSA_PTS_READ(tp), TTIPRI | PCATCH,
254 "ptsin", 0);
255 if (error)
256 return (error);
257 goto again;
258 }
259 while (tp->t_canq.c_cc > 1 && uio->uio_resid > 0)
260 if (ureadc(getc(&tp->t_canq), uio) < 0) {
261 error = EFAULT;
262 break;
263 }
264 if (tp->t_canq.c_cc == 1)
265 (void) getc(&tp->t_canq);
266 if (tp->t_canq.c_cc)
267 return (error);
268 } else
269 if (tp->t_oproc)
270 error = (*linesw[tp->t_line].l_read)(tp, uio, flag);
271 ptcwakeup(tp, FWRITE);
272 return (error);
273}
274
275/*
276 * Write to pseudo-tty.
277 * Wakeups of controlling tty will happen
278 * indirectly, when tty driver calls ptsstart.
279 */
280static int
281ptswrite(dev, uio, flag)
282 dev_t dev;
283 struct uio *uio;
284 int flag;
285{
286 register struct tty *tp;
287
288 tp = dev->si_tty;
289 if (tp->t_oproc == 0)
290 return (EIO);
291 return ((*linesw[tp->t_line].l_write)(tp, uio, flag));
292}
293
294/*
295 * Start output on pseudo-tty.
296 * Wake up process selecting or sleeping for input from controlling tty.
297 */
298static void
299ptsstart(tp)
300 struct tty *tp;
301{
302 register struct pt_ioctl *pti = tp->t_dev->si_drv1;
303
304 if (tp->t_state & TS_TTSTOP)
305 return;
306 if (pti->pt_flags & PF_STOPPED) {
307 pti->pt_flags &= ~PF_STOPPED;
308 pti->pt_send = TIOCPKT_START;
309 }
310 ptcwakeup(tp, FREAD);
311}
312
313static void
314ptcwakeup(tp, flag)
315 struct tty *tp;
316 int flag;
317{
318 struct pt_ioctl *pti = tp->t_dev->si_drv1;
319
320 if (flag & FREAD) {
321 selwakeup(&pti->pt_selr);
322 wakeup(TSA_PTC_READ(tp));
323 }
324 if (flag & FWRITE) {
325 selwakeup(&pti->pt_selw);
326 wakeup(TSA_PTC_WRITE(tp));
327 }
328}
329
330static int
331ptcopen(dev, flag, devtype, td)
332 dev_t dev;
333 int flag, devtype;
334 struct thread *td;
335{
336 struct proc *p = td->td_proc;
337 register struct tty *tp;
338 struct pt_ioctl *pti;
339
340 if (!dev->si_drv1)
341 ptyinit(dev);
342 if (!dev->si_drv1)
343 return(ENXIO);
344 tp = dev->si_tty;
345 if (tp->t_oproc)
346 return (EIO);
347 tp->t_timeout = -1;
348 tp->t_oproc = ptsstart;
349 tp->t_stop = ptsstop;
350 (void)(*linesw[tp->t_line].l_modem)(tp, 1);
351 tp->t_lflag &= ~EXTPROC;
352 pti = dev->si_drv1;
353 pti->pt_prison = p->p_ucred->cr_prison;
354 pti->pt_flags = 0;
355 pti->pt_send = 0;
356 pti->pt_ucntl = 0;
357 return (0);
358}
359
360static int
361ptcclose(dev, flags, fmt, td)
362 dev_t dev;
363 int flags;
364 int fmt;
365 struct thread *td;
366{
367 register struct tty *tp;
368
369 tp = dev->si_tty;
370 (void)(*linesw[tp->t_line].l_modem)(tp, 0);
371
372 /*
373 * XXX MDMBUF makes no sense for ptys but would inhibit the above
374 * l_modem(). CLOCAL makes sense but isn't supported. Special
375 * l_modem()s that ignore carrier drop make no sense for ptys but
376 * may be in use because other parts of the line discipline make
377 * sense for ptys. Recover by doing everything that a normal
378 * ttymodem() would have done except for sending a SIGHUP.
379 */
380 if (tp->t_state & TS_ISOPEN) {
381 tp->t_state &= ~(TS_CARR_ON | TS_CONNECTED);
382 tp->t_state |= TS_ZOMBIE;
383 ttyflush(tp, FREAD | FWRITE);
384 }
385
386 tp->t_oproc = 0; /* mark closed */
387 return (0);
388}
389
390static int
391ptcread(dev, uio, flag)
392 dev_t dev;
393 struct uio *uio;
394 int flag;
395{
396 register struct tty *tp = dev->si_tty;
397 struct pt_ioctl *pti = dev->si_drv1;
398 char buf[BUFSIZ];
399 int error = 0, cc;
400
401 /*
402 * We want to block until the slave
403 * is open, and there's something to read;
404 * but if we lost the slave or we're NBIO,
405 * then return the appropriate error instead.
406 */
407 for (;;) {
408 if (tp->t_state&TS_ISOPEN) {
409 if (pti->pt_flags&PF_PKT && pti->pt_send) {
410 error = ureadc((int)pti->pt_send, uio);
411 if (error)
412 return (error);
413 if (pti->pt_send & TIOCPKT_IOCTL) {
414 cc = min(uio->uio_resid,
415 sizeof(tp->t_termios));
416 uiomove((caddr_t)&tp->t_termios, cc,
417 uio);
418 }
419 pti->pt_send = 0;
420 return (0);
421 }
422 if (pti->pt_flags&PF_UCNTL && pti->pt_ucntl) {
423 error = ureadc((int)pti->pt_ucntl, uio);
424 if (error)
425 return (error);
426 pti->pt_ucntl = 0;
427 return (0);
428 }
429 if (tp->t_outq.c_cc && (tp->t_state&TS_TTSTOP) == 0)
430 break;
431 }
432 if ((tp->t_state & TS_CONNECTED) == 0)
433 return (0); /* EOF */
434 if (flag & IO_NDELAY)
435 return (EWOULDBLOCK);
436 error = tsleep(TSA_PTC_READ(tp), TTIPRI | PCATCH, "ptcin", 0);
437 if (error)
438 return (error);
439 }
440 if (pti->pt_flags & (PF_PKT|PF_UCNTL))
441 error = ureadc(0, uio);
442 while (uio->uio_resid > 0 && error == 0) {
443 cc = q_to_b(&tp->t_outq, buf, min(uio->uio_resid, BUFSIZ));
444 if (cc <= 0)
445 break;
446 error = uiomove(buf, cc, uio);
447 }
448 ttwwakeup(tp);
449 return (error);
450}
451
452static void
453ptsstop(tp, flush)
454 register struct tty *tp;
455 int flush;
456{
457 struct pt_ioctl *pti = tp->t_dev->si_drv1;
458 int flag;
459
460 /* note: FLUSHREAD and FLUSHWRITE already ok */
461 if (flush == 0) {
462 flush = TIOCPKT_STOP;
463 pti->pt_flags |= PF_STOPPED;
464 } else
465 pti->pt_flags &= ~PF_STOPPED;
466 pti->pt_send |= flush;
467 /* change of perspective */
468 flag = 0;
469 if (flush & FREAD)
470 flag |= FWRITE;
471 if (flush & FWRITE)
472 flag |= FREAD;
473 ptcwakeup(tp, flag);
474}
475
476static int
477ptcpoll(dev, events, td)
478 dev_t dev;
479 int events;
480 struct thread *td;
481{
482 register struct tty *tp = dev->si_tty;
483 struct pt_ioctl *pti = dev->si_drv1;
484 int revents = 0;
485 int s;
486
487 if ((tp->t_state & TS_CONNECTED) == 0)
488 return (seltrue(dev, events, td) | POLLHUP);
489
490 /*
491 * Need to block timeouts (ttrstart).
492 */
493 s = spltty();
494
495 if (events & (POLLIN | POLLRDNORM))
496 if ((tp->t_state & TS_ISOPEN) &&
497 ((tp->t_outq.c_cc && (tp->t_state & TS_TTSTOP) == 0) ||
498 ((pti->pt_flags & PF_PKT) && pti->pt_send) ||
499 ((pti->pt_flags & PF_UCNTL) && pti->pt_ucntl)))
500 revents |= events & (POLLIN | POLLRDNORM);
501
502 if (events & (POLLOUT | POLLWRNORM))
503 if (tp->t_state & TS_ISOPEN &&
504 ((pti->pt_flags & PF_REMOTE) ?
505 (tp->t_canq.c_cc == 0) :
506 ((tp->t_rawq.c_cc + tp->t_canq.c_cc < TTYHOG - 2) ||
507 (tp->t_canq.c_cc == 0 && (tp->t_iflag & ICANON)))))
507 (tp->t_canq.c_cc == 0 && (tp->t_lflag & ICANON)))))
508 revents |= events & (POLLOUT | POLLWRNORM);
509
510 if (events & POLLHUP)
511 if ((tp->t_state & TS_CARR_ON) == 0)
512 revents |= POLLHUP;
513
514 if (revents == 0) {
515 if (events & (POLLIN | POLLRDNORM))
516 selrecord(td, &pti->pt_selr);
517
518 if (events & (POLLOUT | POLLWRNORM))
519 selrecord(td, &pti->pt_selw);
520 }
521 splx(s);
522
523 return (revents);
524}
525
526static int
527ptcwrite(dev, uio, flag)
528 dev_t dev;
529 register struct uio *uio;
530 int flag;
531{
532 register struct tty *tp = dev->si_tty;
533 register u_char *cp = 0;
534 register int cc = 0;
535 u_char locbuf[BUFSIZ];
536 int cnt = 0;
537 struct pt_ioctl *pti = dev->si_drv1;
538 int error = 0;
539
540again:
541 if ((tp->t_state&TS_ISOPEN) == 0)
542 goto block;
543 if (pti->pt_flags & PF_REMOTE) {
544 if (tp->t_canq.c_cc)
545 goto block;
546 while ((uio->uio_resid > 0 || cc > 0) &&
547 tp->t_canq.c_cc < TTYHOG - 1) {
548 if (cc == 0) {
549 cc = min(uio->uio_resid, BUFSIZ);
550 cc = min(cc, TTYHOG - 1 - tp->t_canq.c_cc);
551 cp = locbuf;
552 error = uiomove((caddr_t)cp, cc, uio);
553 if (error)
554 return (error);
555 /* check again for safety */
556 if ((tp->t_state & TS_ISOPEN) == 0) {
557 /* adjust as usual */
558 uio->uio_resid += cc;
559 return (EIO);
560 }
561 }
562 if (cc > 0) {
563 cc = b_to_q((char *)cp, cc, &tp->t_canq);
564 /*
565 * XXX we don't guarantee that the canq size
566 * is >= TTYHOG, so the above b_to_q() may
567 * leave some bytes uncopied. However, space
568 * is guaranteed for the null terminator if
569 * we don't fail here since (TTYHOG - 1) is
570 * not a multiple of CBSIZE.
571 */
572 if (cc > 0)
573 break;
574 }
575 }
576 /* adjust for data copied in but not written */
577 uio->uio_resid += cc;
578 (void) putc(0, &tp->t_canq);
579 ttwakeup(tp);
580 wakeup(TSA_PTS_READ(tp));
581 return (0);
582 }
583 while (uio->uio_resid > 0 || cc > 0) {
584 if (cc == 0) {
585 cc = min(uio->uio_resid, BUFSIZ);
586 cp = locbuf;
587 error = uiomove((caddr_t)cp, cc, uio);
588 if (error)
589 return (error);
590 /* check again for safety */
591 if ((tp->t_state & TS_ISOPEN) == 0) {
592 /* adjust for data copied in but not written */
593 uio->uio_resid += cc;
594 return (EIO);
595 }
596 }
597 while (cc > 0) {
598 if ((tp->t_rawq.c_cc + tp->t_canq.c_cc) >= TTYHOG - 2 &&
508 revents |= events & (POLLOUT | POLLWRNORM);
509
510 if (events & POLLHUP)
511 if ((tp->t_state & TS_CARR_ON) == 0)
512 revents |= POLLHUP;
513
514 if (revents == 0) {
515 if (events & (POLLIN | POLLRDNORM))
516 selrecord(td, &pti->pt_selr);
517
518 if (events & (POLLOUT | POLLWRNORM))
519 selrecord(td, &pti->pt_selw);
520 }
521 splx(s);
522
523 return (revents);
524}
525
526static int
527ptcwrite(dev, uio, flag)
528 dev_t dev;
529 register struct uio *uio;
530 int flag;
531{
532 register struct tty *tp = dev->si_tty;
533 register u_char *cp = 0;
534 register int cc = 0;
535 u_char locbuf[BUFSIZ];
536 int cnt = 0;
537 struct pt_ioctl *pti = dev->si_drv1;
538 int error = 0;
539
540again:
541 if ((tp->t_state&TS_ISOPEN) == 0)
542 goto block;
543 if (pti->pt_flags & PF_REMOTE) {
544 if (tp->t_canq.c_cc)
545 goto block;
546 while ((uio->uio_resid > 0 || cc > 0) &&
547 tp->t_canq.c_cc < TTYHOG - 1) {
548 if (cc == 0) {
549 cc = min(uio->uio_resid, BUFSIZ);
550 cc = min(cc, TTYHOG - 1 - tp->t_canq.c_cc);
551 cp = locbuf;
552 error = uiomove((caddr_t)cp, cc, uio);
553 if (error)
554 return (error);
555 /* check again for safety */
556 if ((tp->t_state & TS_ISOPEN) == 0) {
557 /* adjust as usual */
558 uio->uio_resid += cc;
559 return (EIO);
560 }
561 }
562 if (cc > 0) {
563 cc = b_to_q((char *)cp, cc, &tp->t_canq);
564 /*
565 * XXX we don't guarantee that the canq size
566 * is >= TTYHOG, so the above b_to_q() may
567 * leave some bytes uncopied. However, space
568 * is guaranteed for the null terminator if
569 * we don't fail here since (TTYHOG - 1) is
570 * not a multiple of CBSIZE.
571 */
572 if (cc > 0)
573 break;
574 }
575 }
576 /* adjust for data copied in but not written */
577 uio->uio_resid += cc;
578 (void) putc(0, &tp->t_canq);
579 ttwakeup(tp);
580 wakeup(TSA_PTS_READ(tp));
581 return (0);
582 }
583 while (uio->uio_resid > 0 || cc > 0) {
584 if (cc == 0) {
585 cc = min(uio->uio_resid, BUFSIZ);
586 cp = locbuf;
587 error = uiomove((caddr_t)cp, cc, uio);
588 if (error)
589 return (error);
590 /* check again for safety */
591 if ((tp->t_state & TS_ISOPEN) == 0) {
592 /* adjust for data copied in but not written */
593 uio->uio_resid += cc;
594 return (EIO);
595 }
596 }
597 while (cc > 0) {
598 if ((tp->t_rawq.c_cc + tp->t_canq.c_cc) >= TTYHOG - 2 &&
599 (tp->t_canq.c_cc > 0 || !(tp->t_iflag&ICANON))) {
599 (tp->t_canq.c_cc > 0 || !(tp->t_lflag&ICANON))) {
600 wakeup(TSA_HUP_OR_INPUT(tp));
601 goto block;
602 }
603 (*linesw[tp->t_line].l_rint)(*cp++, tp);
604 cnt++;
605 cc--;
606 }
607 cc = 0;
608 }
609 return (0);
610block:
611 /*
612 * Come here to wait for slave to open, for space
613 * in outq, or space in rawq, or an empty canq.
614 */
615 if ((tp->t_state & TS_CONNECTED) == 0) {
616 /* adjust for data copied in but not written */
617 uio->uio_resid += cc;
618 return (EIO);
619 }
620 if (flag & IO_NDELAY) {
621 /* adjust for data copied in but not written */
622 uio->uio_resid += cc;
623 if (cnt == 0)
624 return (EWOULDBLOCK);
625 return (0);
626 }
627 error = tsleep(TSA_PTC_WRITE(tp), TTOPRI | PCATCH, "ptcout", 0);
628 if (error) {
629 /* adjust for data copied in but not written */
630 uio->uio_resid += cc;
631 return (error);
632 }
633 goto again;
634}
635
636/*ARGSUSED*/
637static int
638ptyioctl(dev, cmd, data, flag, td)
639 dev_t dev;
640 u_long cmd;
641 caddr_t data;
642 int flag;
643 struct thread *td;
644{
645 register struct tty *tp = dev->si_tty;
646 register struct pt_ioctl *pti = dev->si_drv1;
647 register u_char *cc = tp->t_cc;
648 int stop, error;
649
650 if (devsw(dev)->d_open == ptcopen) {
651 switch (cmd) {
652
653 case TIOCGPGRP:
654 /*
655 * We avoid calling ttioctl on the controller since,
656 * in that case, tp must be the controlling terminal.
657 */
658 *(int *)data = tp->t_pgrp ? tp->t_pgrp->pg_id : 0;
659 return (0);
660
661 case TIOCPKT:
662 if (*(int *)data) {
663 if (pti->pt_flags & PF_UCNTL)
664 return (EINVAL);
665 pti->pt_flags |= PF_PKT;
666 } else
667 pti->pt_flags &= ~PF_PKT;
668 return (0);
669
670 case TIOCUCNTL:
671 if (*(int *)data) {
672 if (pti->pt_flags & PF_PKT)
673 return (EINVAL);
674 pti->pt_flags |= PF_UCNTL;
675 } else
676 pti->pt_flags &= ~PF_UCNTL;
677 return (0);
678
679 case TIOCREMOTE:
680 if (*(int *)data)
681 pti->pt_flags |= PF_REMOTE;
682 else
683 pti->pt_flags &= ~PF_REMOTE;
684 ttyflush(tp, FREAD|FWRITE);
685 return (0);
686 }
687
688 /*
689 * The rest of the ioctls shouldn't be called until
690 * the slave is open.
691 */
692 if ((tp->t_state & TS_ISOPEN) == 0)
693 return (EAGAIN);
694
695 switch (cmd) {
696#ifdef COMPAT_43
697 case TIOCSETP:
698 case TIOCSETN:
699#endif
700 case TIOCSETD:
701 case TIOCSETA:
702 case TIOCSETAW:
703 case TIOCSETAF:
704 /*
705 * IF CONTROLLER STTY THEN MUST FLUSH TO PREVENT A HANG.
706 * ttywflush(tp) will hang if there are characters in
707 * the outq.
708 */
709 ndflush(&tp->t_outq, tp->t_outq.c_cc);
710 break;
711
712 case TIOCSIG:
713 if (*(unsigned int *)data >= NSIG ||
714 *(unsigned int *)data == 0)
715 return(EINVAL);
716 if ((tp->t_lflag&NOFLSH) == 0)
717 ttyflush(tp, FREAD|FWRITE);
718 pgsignal(tp->t_pgrp, *(unsigned int *)data, 1);
719 if ((*(unsigned int *)data == SIGINFO) &&
720 ((tp->t_lflag&NOKERNINFO) == 0))
721 ttyinfo(tp);
722 return(0);
723 }
724 }
725 if (cmd == TIOCEXT) {
726 /*
727 * When the EXTPROC bit is being toggled, we need
728 * to send an TIOCPKT_IOCTL if the packet driver
729 * is turned on.
730 */
731 if (*(int *)data) {
732 if (pti->pt_flags & PF_PKT) {
733 pti->pt_send |= TIOCPKT_IOCTL;
734 ptcwakeup(tp, FREAD);
735 }
736 tp->t_lflag |= EXTPROC;
737 } else {
738 if ((tp->t_lflag & EXTPROC) &&
739 (pti->pt_flags & PF_PKT)) {
740 pti->pt_send |= TIOCPKT_IOCTL;
741 ptcwakeup(tp, FREAD);
742 }
743 tp->t_lflag &= ~EXTPROC;
744 }
745 return(0);
746 }
747 error = (*linesw[tp->t_line].l_ioctl)(tp, cmd, data, flag, td);
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
806
807static void ptc_drvinit __P((void *unused));
808
809static void pty_clone __P((void *arg, char *name, int namelen, dev_t *dev));
810
811static void
812pty_clone(arg, name, namelen, dev)
813 void *arg;
814 char *name;
815 int namelen;
816 dev_t *dev;
817{
818 int u;
819
820 if (*dev != NODEV)
821 return;
822 if (bcmp(name, "pty", 3) != 0)
823 return;
824 if (name[5] != '\0')
825 return;
826 switch (name[3]) {
827 case 'p': u = 0; break;
828 case 'q': u = 32; break;
829 case 'r': u = 64; break;
830 case 's': u = 96; break;
831 case 'P': u = 128; break;
832 case 'Q': u = 160; break;
833 case 'R': u = 192; break;
834 case 'S': u = 224; break;
835 default: return;
836 }
837 if (name[4] >= '0' && name[4] <= '9')
838 u += name[4] - '0';
839 else if (name[4] >= 'a' && name[4] <= 'v')
840 u += name[4] - 'a' + 10;
841 else
842 return;
843 *dev = make_dev(&ptc_cdevsw, u,
844 UID_ROOT, GID_WHEEL, 0666, "pty%c%r", names[u / 32], u % 32);
845 (*dev)->si_flags |= SI_CHEAPCLONE;
846 return;
847}
848
849static void
850ptc_drvinit(unused)
851 void *unused;
852{
853 EVENTHANDLER_REGISTER(dev_clone, pty_clone, 0, 1000);
854 cdevsw_add(&pts_cdevsw);
855 cdevsw_add(&ptc_cdevsw);
856}
857
858SYSINIT(ptcdev,SI_SUB_DRIVERS,SI_ORDER_MIDDLE+CDEV_MAJOR_C,ptc_drvinit,NULL)
600 wakeup(TSA_HUP_OR_INPUT(tp));
601 goto block;
602 }
603 (*linesw[tp->t_line].l_rint)(*cp++, tp);
604 cnt++;
605 cc--;
606 }
607 cc = 0;
608 }
609 return (0);
610block:
611 /*
612 * Come here to wait for slave to open, for space
613 * in outq, or space in rawq, or an empty canq.
614 */
615 if ((tp->t_state & TS_CONNECTED) == 0) {
616 /* adjust for data copied in but not written */
617 uio->uio_resid += cc;
618 return (EIO);
619 }
620 if (flag & IO_NDELAY) {
621 /* adjust for data copied in but not written */
622 uio->uio_resid += cc;
623 if (cnt == 0)
624 return (EWOULDBLOCK);
625 return (0);
626 }
627 error = tsleep(TSA_PTC_WRITE(tp), TTOPRI | PCATCH, "ptcout", 0);
628 if (error) {
629 /* adjust for data copied in but not written */
630 uio->uio_resid += cc;
631 return (error);
632 }
633 goto again;
634}
635
636/*ARGSUSED*/
637static int
638ptyioctl(dev, cmd, data, flag, td)
639 dev_t dev;
640 u_long cmd;
641 caddr_t data;
642 int flag;
643 struct thread *td;
644{
645 register struct tty *tp = dev->si_tty;
646 register struct pt_ioctl *pti = dev->si_drv1;
647 register u_char *cc = tp->t_cc;
648 int stop, error;
649
650 if (devsw(dev)->d_open == ptcopen) {
651 switch (cmd) {
652
653 case TIOCGPGRP:
654 /*
655 * We avoid calling ttioctl on the controller since,
656 * in that case, tp must be the controlling terminal.
657 */
658 *(int *)data = tp->t_pgrp ? tp->t_pgrp->pg_id : 0;
659 return (0);
660
661 case TIOCPKT:
662 if (*(int *)data) {
663 if (pti->pt_flags & PF_UCNTL)
664 return (EINVAL);
665 pti->pt_flags |= PF_PKT;
666 } else
667 pti->pt_flags &= ~PF_PKT;
668 return (0);
669
670 case TIOCUCNTL:
671 if (*(int *)data) {
672 if (pti->pt_flags & PF_PKT)
673 return (EINVAL);
674 pti->pt_flags |= PF_UCNTL;
675 } else
676 pti->pt_flags &= ~PF_UCNTL;
677 return (0);
678
679 case TIOCREMOTE:
680 if (*(int *)data)
681 pti->pt_flags |= PF_REMOTE;
682 else
683 pti->pt_flags &= ~PF_REMOTE;
684 ttyflush(tp, FREAD|FWRITE);
685 return (0);
686 }
687
688 /*
689 * The rest of the ioctls shouldn't be called until
690 * the slave is open.
691 */
692 if ((tp->t_state & TS_ISOPEN) == 0)
693 return (EAGAIN);
694
695 switch (cmd) {
696#ifdef COMPAT_43
697 case TIOCSETP:
698 case TIOCSETN:
699#endif
700 case TIOCSETD:
701 case TIOCSETA:
702 case TIOCSETAW:
703 case TIOCSETAF:
704 /*
705 * IF CONTROLLER STTY THEN MUST FLUSH TO PREVENT A HANG.
706 * ttywflush(tp) will hang if there are characters in
707 * the outq.
708 */
709 ndflush(&tp->t_outq, tp->t_outq.c_cc);
710 break;
711
712 case TIOCSIG:
713 if (*(unsigned int *)data >= NSIG ||
714 *(unsigned int *)data == 0)
715 return(EINVAL);
716 if ((tp->t_lflag&NOFLSH) == 0)
717 ttyflush(tp, FREAD|FWRITE);
718 pgsignal(tp->t_pgrp, *(unsigned int *)data, 1);
719 if ((*(unsigned int *)data == SIGINFO) &&
720 ((tp->t_lflag&NOKERNINFO) == 0))
721 ttyinfo(tp);
722 return(0);
723 }
724 }
725 if (cmd == TIOCEXT) {
726 /*
727 * When the EXTPROC bit is being toggled, we need
728 * to send an TIOCPKT_IOCTL if the packet driver
729 * is turned on.
730 */
731 if (*(int *)data) {
732 if (pti->pt_flags & PF_PKT) {
733 pti->pt_send |= TIOCPKT_IOCTL;
734 ptcwakeup(tp, FREAD);
735 }
736 tp->t_lflag |= EXTPROC;
737 } else {
738 if ((tp->t_lflag & EXTPROC) &&
739 (pti->pt_flags & PF_PKT)) {
740 pti->pt_send |= TIOCPKT_IOCTL;
741 ptcwakeup(tp, FREAD);
742 }
743 tp->t_lflag &= ~EXTPROC;
744 }
745 return(0);
746 }
747 error = (*linesw[tp->t_line].l_ioctl)(tp, cmd, data, flag, td);
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
806
807static void ptc_drvinit __P((void *unused));
808
809static void pty_clone __P((void *arg, char *name, int namelen, dev_t *dev));
810
811static void
812pty_clone(arg, name, namelen, dev)
813 void *arg;
814 char *name;
815 int namelen;
816 dev_t *dev;
817{
818 int u;
819
820 if (*dev != NODEV)
821 return;
822 if (bcmp(name, "pty", 3) != 0)
823 return;
824 if (name[5] != '\0')
825 return;
826 switch (name[3]) {
827 case 'p': u = 0; break;
828 case 'q': u = 32; break;
829 case 'r': u = 64; break;
830 case 's': u = 96; break;
831 case 'P': u = 128; break;
832 case 'Q': u = 160; break;
833 case 'R': u = 192; break;
834 case 'S': u = 224; break;
835 default: return;
836 }
837 if (name[4] >= '0' && name[4] <= '9')
838 u += name[4] - '0';
839 else if (name[4] >= 'a' && name[4] <= 'v')
840 u += name[4] - 'a' + 10;
841 else
842 return;
843 *dev = make_dev(&ptc_cdevsw, u,
844 UID_ROOT, GID_WHEEL, 0666, "pty%c%r", names[u / 32], u % 32);
845 (*dev)->si_flags |= SI_CHEAPCLONE;
846 return;
847}
848
849static void
850ptc_drvinit(unused)
851 void *unused;
852{
853 EVENTHANDLER_REGISTER(dev_clone, pty_clone, 0, 1000);
854 cdevsw_add(&pts_cdevsw);
855 cdevsw_add(&ptc_cdevsw);
856}
857
858SYSINIT(ptcdev,SI_SUB_DRIVERS,SI_ORDER_MIDDLE+CDEV_MAJOR_C,ptc_drvinit,NULL)