ppp_tty.c revision 1.33.2.5 1 1.33.2.5 skrll /* $NetBSD: ppp_tty.c,v 1.33.2.5 2005/11/10 14:10:33 skrll Exp $ */
2 1.11 christos /* Id: ppp_tty.c,v 1.3 1996/07/01 01:04:11 paulus Exp */
3 1.1 paulus
4 1.1 paulus /*
5 1.1 paulus * ppp_tty.c - Point-to-Point Protocol (PPP) driver for asynchronous
6 1.1 paulus * tty devices.
7 1.1 paulus *
8 1.31 itojun * Copyright (c) 1984-2000 Carnegie Mellon University. All rights reserved.
9 1.1 paulus *
10 1.31 itojun * Redistribution and use in source and binary forms, with or without
11 1.31 itojun * modification, are permitted provided that the following conditions
12 1.31 itojun * are met:
13 1.31 itojun *
14 1.31 itojun * 1. Redistributions of source code must retain the above copyright
15 1.31 itojun * notice, this list of conditions and the following disclaimer.
16 1.31 itojun *
17 1.31 itojun * 2. Redistributions in binary form must reproduce the above copyright
18 1.31 itojun * notice, this list of conditions and the following disclaimer in
19 1.31 itojun * the documentation and/or other materials provided with the
20 1.31 itojun * distribution.
21 1.31 itojun *
22 1.31 itojun * 3. The name "Carnegie Mellon University" must not be used to
23 1.31 itojun * endorse or promote products derived from this software without
24 1.31 itojun * prior written permission. For permission or any legal
25 1.31 itojun * details, please contact
26 1.31 itojun * Office of Technology Transfer
27 1.31 itojun * Carnegie Mellon University
28 1.31 itojun * 5000 Forbes Avenue
29 1.31 itojun * Pittsburgh, PA 15213-3890
30 1.31 itojun * (412) 268-4387, fax: (412) 268-7395
31 1.31 itojun * tech-transfer (at) andrew.cmu.edu
32 1.31 itojun *
33 1.31 itojun * 4. Redistributions of any form whatsoever must retain the following
34 1.31 itojun * acknowledgment:
35 1.31 itojun * "This product includes software developed by Computing Services
36 1.31 itojun * at Carnegie Mellon University (http://www.cmu.edu/computing/)."
37 1.31 itojun *
38 1.31 itojun * CARNEGIE MELLON UNIVERSITY DISCLAIMS ALL WARRANTIES WITH REGARD TO
39 1.31 itojun * THIS SOFTWARE, INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY
40 1.31 itojun * AND FITNESS, IN NO EVENT SHALL CARNEGIE MELLON UNIVERSITY BE LIABLE
41 1.31 itojun * FOR ANY SPECIAL, INDIRECT OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
42 1.31 itojun * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN
43 1.31 itojun * AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING
44 1.31 itojun * OUT OF OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
45 1.1 paulus *
46 1.1 paulus * Based on:
47 1.1 paulus * @(#)if_sl.c 7.6.1.2 (Berkeley) 2/15/89
48 1.1 paulus *
49 1.1 paulus * Copyright (c) 1987 Regents of the University of California.
50 1.1 paulus * All rights reserved.
51 1.1 paulus *
52 1.1 paulus * Redistribution and use in source and binary forms are permitted
53 1.1 paulus * provided that the above copyright notice and this paragraph are
54 1.1 paulus * duplicated in all such forms and that any documentation,
55 1.1 paulus * advertising materials, and other materials related to such
56 1.1 paulus * distribution and use acknowledge that the software was developed
57 1.1 paulus * by the University of California, Berkeley. The name of the
58 1.1 paulus * University may not be used to endorse or promote products derived
59 1.1 paulus * from this software without specific prior written permission.
60 1.1 paulus * THIS SOFTWARE IS PROVIDED ``AS IS'' AND WITHOUT ANY EXPRESS OR
61 1.1 paulus * IMPLIED WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED
62 1.1 paulus * WARRANTIES OF MERCHANTIBILITY AND FITNESS FOR A PARTICULAR PURPOSE.
63 1.1 paulus *
64 1.1 paulus * Serial Line interface
65 1.1 paulus *
66 1.1 paulus * Rick Adams
67 1.1 paulus * Center for Seismic Studies
68 1.1 paulus * 1300 N 17th Street, Suite 1450
69 1.1 paulus * Arlington, Virginia 22209
70 1.1 paulus * (703)276-7900
71 1.1 paulus * rick (at) seismo.ARPA
72 1.1 paulus * seismo!rick
73 1.1 paulus *
74 1.1 paulus * Pounded on heavily by Chris Torek (chris (at) mimsy.umd.edu, umcp-cs!chris).
75 1.1 paulus * Converted to 4.3BSD Beta by Chris Torek.
76 1.1 paulus * Other changes made at Berkeley, based in part on code by Kirk Smith.
77 1.1 paulus *
78 1.1 paulus * Converted to 4.3BSD+ 386BSD by Brad Parker (brad (at) cayman.com)
79 1.1 paulus * Added VJ tcp header compression; more unified ioctls
80 1.1 paulus *
81 1.1 paulus * Extensively modified by Paul Mackerras (paulus (at) cs.anu.edu.au).
82 1.1 paulus * Cleaned up a lot of the mbuf-related code to fix bugs that
83 1.1 paulus * caused system crashes and packet corruption. Changed pppstart
84 1.11 christos * so that it doesn't just give up with a "collision" if the whole
85 1.1 paulus * packet doesn't fit in the output ring buffer.
86 1.1 paulus *
87 1.1 paulus * Added priority queueing for interactive IP packets, following
88 1.1 paulus * the model of if_sl.c, plus hooks for bpf.
89 1.1 paulus * Paul Mackerras (paulus (at) cs.anu.edu.au).
90 1.1 paulus */
91 1.1 paulus
92 1.1 paulus /* from if_sl.c,v 1.11 84/10/04 12:54:47 rick Exp */
93 1.1 paulus /* from NetBSD: if_ppp.c,v 1.15.2.2 1994/07/28 05:17:58 cgd Exp */
94 1.27 lukem
95 1.27 lukem #include <sys/cdefs.h>
96 1.33.2.5 skrll __KERNEL_RCSID(0, "$NetBSD: ppp_tty.c,v 1.33.2.5 2005/11/10 14:10:33 skrll Exp $");
97 1.1 paulus
98 1.1 paulus #include "ppp.h"
99 1.1 paulus
100 1.15 christos #include "opt_ppp.h"
101 1.1 paulus #define VJC
102 1.1 paulus #define PPP_COMPRESS
103 1.1 paulus
104 1.1 paulus #include <sys/param.h>
105 1.1 paulus #include <sys/proc.h>
106 1.1 paulus #include <sys/mbuf.h>
107 1.1 paulus #include <sys/dkstat.h>
108 1.1 paulus #include <sys/socket.h>
109 1.1 paulus #include <sys/ioctl.h>
110 1.1 paulus #include <sys/file.h>
111 1.1 paulus #include <sys/tty.h>
112 1.1 paulus #include <sys/kernel.h>
113 1.1 paulus #include <sys/conf.h>
114 1.1 paulus #include <sys/vnode.h>
115 1.4 christos #include <sys/systm.h>
116 1.1 paulus
117 1.1 paulus #include <net/if.h>
118 1.1 paulus #include <net/if_types.h>
119 1.1 paulus
120 1.1 paulus #ifdef VJC
121 1.1 paulus #include <netinet/in.h>
122 1.1 paulus #include <netinet/in_systm.h>
123 1.1 paulus #include <netinet/ip.h>
124 1.1 paulus #include <net/slcompress.h>
125 1.1 paulus #endif
126 1.1 paulus
127 1.16 thorpej #include "bpfilter.h"
128 1.16 thorpej #if NBPFILTER > 0 || defined(PPP_FILTER)
129 1.5 paulus #include <net/bpf.h>
130 1.11 christos #endif
131 1.1 paulus #include <net/ppp_defs.h>
132 1.1 paulus #include <net/if_ppp.h>
133 1.1 paulus #include <net/if_pppvar.h>
134 1.1 paulus
135 1.1 paulus int pppopen __P((dev_t dev, struct tty *tp));
136 1.1 paulus int pppclose __P((struct tty *tp, int flag));
137 1.1 paulus int pppread __P((struct tty *tp, struct uio *uio, int flag));
138 1.1 paulus int pppwrite __P((struct tty *tp, struct uio *uio, int flag));
139 1.1 paulus int ppptioctl __P((struct tty *tp, u_long cmd, caddr_t data, int flag,
140 1.1 paulus struct proc *));
141 1.1 paulus int pppinput __P((int c, struct tty *tp));
142 1.14 sommerfe int pppstart __P((struct tty *tp));
143 1.1 paulus
144 1.18 christos static void ppprcvframe __P((struct ppp_softc *sc, struct mbuf *m));
145 1.1 paulus static u_int16_t pppfcs __P((u_int16_t fcs, u_char *cp, int len));
146 1.18 christos static void pppsyncstart __P((struct ppp_softc *sc));
147 1.1 paulus static void pppasyncstart __P((struct ppp_softc *));
148 1.1 paulus static void pppasyncctlp __P((struct ppp_softc *));
149 1.1 paulus static void pppasyncrelinq __P((struct ppp_softc *));
150 1.1 paulus static void ppp_timeout __P((void *));
151 1.1 paulus static void pppgetm __P((struct ppp_softc *sc));
152 1.1 paulus static void pppdumpb __P((u_char *b, int l));
153 1.1 paulus static void ppplogchar __P((struct ppp_softc *, int));
154 1.18 christos static void pppdumpframe __P((struct ppp_softc *sc, struct mbuf* m,
155 1.18 christos int xmit));
156 1.1 paulus
157 1.1 paulus /*
158 1.1 paulus * Some useful mbuf macros not in mbuf.h.
159 1.1 paulus */
160 1.1 paulus #define M_IS_CLUSTER(m) ((m)->m_flags & M_EXT)
161 1.1 paulus
162 1.1 paulus #define M_DATASTART(m) \
163 1.1 paulus (M_IS_CLUSTER(m) ? (m)->m_ext.ext_buf : \
164 1.1 paulus (m)->m_flags & M_PKTHDR ? (m)->m_pktdat : (m)->m_dat)
165 1.1 paulus
166 1.1 paulus #define M_DATASIZE(m) \
167 1.1 paulus (M_IS_CLUSTER(m) ? (m)->m_ext.ext_size : \
168 1.1 paulus (m)->m_flags & M_PKTHDR ? MHLEN: MLEN)
169 1.1 paulus
170 1.1 paulus /*
171 1.1 paulus * Does c need to be escaped?
172 1.1 paulus */
173 1.1 paulus #define ESCAPE_P(c) (sc->sc_asyncmap[(c) >> 5] & (1 << ((c) & 0x1F)))
174 1.1 paulus
175 1.1 paulus /*
176 1.1 paulus * Procedures for using an async tty interface for PPP.
177 1.1 paulus */
178 1.1 paulus
179 1.1 paulus /* This is a NetBSD-1.0 or later kernel. */
180 1.1 paulus #define CCOUNT(q) ((q)->c_cc)
181 1.1 paulus
182 1.11 christos #define PPP_LOWAT 100 /* Process more output when < LOWAT on queue */
183 1.1 paulus #define PPP_HIWAT 400 /* Don't start a new packet if HIWAT on que */
184 1.1 paulus
185 1.1 paulus /*
186 1.1 paulus * Line specific open routine for async tty devices.
187 1.1 paulus * Attach the given tty to the first available ppp unit.
188 1.1 paulus * Called from device open routine or ttioctl.
189 1.1 paulus */
190 1.1 paulus /* ARGSUSED */
191 1.1 paulus int
192 1.1 paulus pppopen(dev, tp)
193 1.1 paulus dev_t dev;
194 1.20 augustss struct tty *tp;
195 1.1 paulus {
196 1.1 paulus struct proc *p = curproc; /* XXX */
197 1.20 augustss struct ppp_softc *sc;
198 1.4 christos int error, s;
199 1.1 paulus
200 1.4 christos if ((error = suser(p->p_ucred, &p->p_acflag)) != 0)
201 1.1 paulus return (error);
202 1.1 paulus
203 1.1 paulus s = spltty();
204 1.1 paulus
205 1.24 enami if (tp->t_linesw->l_no == PPPDISC) {
206 1.1 paulus sc = (struct ppp_softc *) tp->t_sc;
207 1.1 paulus if (sc != NULL && sc->sc_devp == (void *) tp) {
208 1.1 paulus splx(s);
209 1.1 paulus return (0);
210 1.1 paulus }
211 1.1 paulus }
212 1.1 paulus
213 1.1 paulus if ((sc = pppalloc(p->p_pid)) == NULL) {
214 1.1 paulus splx(s);
215 1.1 paulus return ENXIO;
216 1.1 paulus }
217 1.1 paulus
218 1.1 paulus if (sc->sc_relinq)
219 1.1 paulus (*sc->sc_relinq)(sc); /* get previous owner to relinquish the unit */
220 1.1 paulus
221 1.16 thorpej #if NBPFILTER > 0
222 1.16 thorpej /* Switch DLT to PPP-over-serial. */
223 1.22 thorpej bpf_change_type(&sc->sc_if, DLT_PPP_SERIAL, PPP_HDRLEN);
224 1.16 thorpej #endif
225 1.16 thorpej
226 1.1 paulus sc->sc_ilen = 0;
227 1.1 paulus sc->sc_m = NULL;
228 1.26 thorpej memset(sc->sc_asyncmap, 0, sizeof(sc->sc_asyncmap));
229 1.1 paulus sc->sc_asyncmap[0] = 0xffffffff;
230 1.1 paulus sc->sc_asyncmap[3] = 0x60000000;
231 1.1 paulus sc->sc_rasyncmap = 0;
232 1.1 paulus sc->sc_devp = (void *) tp;
233 1.1 paulus sc->sc_start = pppasyncstart;
234 1.1 paulus sc->sc_ctlp = pppasyncctlp;
235 1.1 paulus sc->sc_relinq = pppasyncrelinq;
236 1.1 paulus sc->sc_outm = NULL;
237 1.1 paulus pppgetm(sc);
238 1.1 paulus sc->sc_if.if_flags |= IFF_RUNNING;
239 1.3 mycroft sc->sc_if.if_baudrate = tp->t_ospeed;
240 1.1 paulus
241 1.1 paulus tp->t_sc = (caddr_t) sc;
242 1.1 paulus ttyflush(tp, FREAD | FWRITE);
243 1.1 paulus
244 1.1 paulus splx(s);
245 1.1 paulus return (0);
246 1.1 paulus }
247 1.1 paulus
248 1.1 paulus /*
249 1.1 paulus * Line specific close routine, called from device close routine
250 1.1 paulus * and from ttioctl.
251 1.1 paulus * Detach the tty from the ppp unit.
252 1.1 paulus * Mimics part of ttyclose().
253 1.1 paulus */
254 1.1 paulus int
255 1.1 paulus pppclose(tp, flag)
256 1.1 paulus struct tty *tp;
257 1.1 paulus int flag;
258 1.1 paulus {
259 1.20 augustss struct ppp_softc *sc;
260 1.1 paulus int s;
261 1.1 paulus
262 1.1 paulus s = spltty();
263 1.5 paulus ttyflush(tp, FREAD|FWRITE);
264 1.21 itojun tp->t_linesw = linesw[0]; /* default line discipline */
265 1.1 paulus sc = (struct ppp_softc *) tp->t_sc;
266 1.1 paulus if (sc != NULL) {
267 1.1 paulus tp->t_sc = NULL;
268 1.1 paulus if (tp == (struct tty *) sc->sc_devp) {
269 1.1 paulus pppasyncrelinq(sc);
270 1.1 paulus pppdealloc(sc);
271 1.1 paulus }
272 1.1 paulus }
273 1.1 paulus splx(s);
274 1.1 paulus return 0;
275 1.1 paulus }
276 1.1 paulus
277 1.1 paulus /*
278 1.1 paulus * Relinquish the interface unit to another device.
279 1.1 paulus */
280 1.1 paulus static void
281 1.1 paulus pppasyncrelinq(sc)
282 1.1 paulus struct ppp_softc *sc;
283 1.1 paulus {
284 1.1 paulus int s;
285 1.16 thorpej
286 1.17 tron #if NBPFILTER > 0
287 1.16 thorpej /* Change DLT to back none. */
288 1.22 thorpej bpf_change_type(&sc->sc_if, DLT_NULL, 0);
289 1.17 tron #endif
290 1.1 paulus
291 1.1 paulus s = spltty();
292 1.1 paulus if (sc->sc_outm) {
293 1.1 paulus m_freem(sc->sc_outm);
294 1.1 paulus sc->sc_outm = NULL;
295 1.1 paulus }
296 1.1 paulus if (sc->sc_m) {
297 1.1 paulus m_freem(sc->sc_m);
298 1.1 paulus sc->sc_m = NULL;
299 1.1 paulus }
300 1.1 paulus if (sc->sc_flags & SC_TIMEOUT) {
301 1.19 thorpej callout_stop(&sc->sc_timo_ch);
302 1.1 paulus sc->sc_flags &= ~SC_TIMEOUT;
303 1.1 paulus }
304 1.1 paulus splx(s);
305 1.1 paulus }
306 1.1 paulus
307 1.1 paulus /*
308 1.1 paulus * Line specific (tty) read routine.
309 1.1 paulus */
310 1.1 paulus int
311 1.1 paulus pppread(tp, uio, flag)
312 1.20 augustss struct tty *tp;
313 1.1 paulus struct uio *uio;
314 1.1 paulus int flag;
315 1.1 paulus {
316 1.20 augustss struct ppp_softc *sc = (struct ppp_softc *)tp->t_sc;
317 1.1 paulus struct mbuf *m, *m0;
318 1.20 augustss int s;
319 1.1 paulus int error = 0;
320 1.1 paulus
321 1.1 paulus if (sc == NULL)
322 1.1 paulus return 0;
323 1.1 paulus /*
324 1.1 paulus * Loop waiting for input, checking that nothing disasterous
325 1.1 paulus * happens in the meantime.
326 1.1 paulus */
327 1.1 paulus s = spltty();
328 1.1 paulus for (;;) {
329 1.24 enami if (tp != (struct tty *) sc->sc_devp ||
330 1.21 itojun tp->t_linesw->l_no != PPPDISC) {
331 1.1 paulus splx(s);
332 1.1 paulus return 0;
333 1.1 paulus }
334 1.1 paulus if (sc->sc_inq.ifq_head != NULL)
335 1.1 paulus break;
336 1.1 paulus if ((tp->t_state & TS_CARR_ON) == 0 && (tp->t_cflag & CLOCAL) == 0
337 1.1 paulus && (tp->t_state & TS_ISOPEN)) {
338 1.1 paulus splx(s);
339 1.1 paulus return 0; /* end of file */
340 1.1 paulus }
341 1.1 paulus if (tp->t_state & TS_ASYNC || flag & IO_NDELAY) {
342 1.1 paulus splx(s);
343 1.1 paulus return (EWOULDBLOCK);
344 1.1 paulus }
345 1.1 paulus error = ttysleep(tp, (caddr_t)&tp->t_rawq, TTIPRI|PCATCH, ttyin, 0);
346 1.1 paulus if (error) {
347 1.1 paulus splx(s);
348 1.1 paulus return error;
349 1.1 paulus }
350 1.1 paulus }
351 1.1 paulus
352 1.1 paulus /* Pull place-holder byte out of canonical queue */
353 1.1 paulus getc(&tp->t_canq);
354 1.1 paulus
355 1.1 paulus /* Get the packet from the input queue */
356 1.1 paulus IF_DEQUEUE(&sc->sc_inq, m0);
357 1.1 paulus splx(s);
358 1.1 paulus
359 1.1 paulus for (m = m0; m && uio->uio_resid; m = m->m_next)
360 1.4 christos if ((error = uiomove(mtod(m, u_char *), m->m_len, uio)) != 0)
361 1.1 paulus break;
362 1.1 paulus m_freem(m0);
363 1.1 paulus return (error);
364 1.1 paulus }
365 1.1 paulus
366 1.1 paulus /*
367 1.1 paulus * Line specific (tty) write routine.
368 1.1 paulus */
369 1.1 paulus int
370 1.1 paulus pppwrite(tp, uio, flag)
371 1.20 augustss struct tty *tp;
372 1.1 paulus struct uio *uio;
373 1.1 paulus int flag;
374 1.1 paulus {
375 1.20 augustss struct ppp_softc *sc = (struct ppp_softc *)tp->t_sc;
376 1.33.2.5 skrll struct mbuf *m, *m0;
377 1.1 paulus struct sockaddr dst;
378 1.1 paulus int len, error;
379 1.1 paulus
380 1.1 paulus if ((tp->t_state & TS_CARR_ON) == 0 && (tp->t_cflag & CLOCAL) == 0)
381 1.1 paulus return 0; /* wrote 0 bytes */
382 1.24 enami if (tp->t_linesw->l_no != PPPDISC)
383 1.1 paulus return (EINVAL);
384 1.1 paulus if (sc == NULL || tp != (struct tty *) sc->sc_devp)
385 1.1 paulus return EIO;
386 1.1 paulus if (uio->uio_resid > sc->sc_if.if_mtu + PPP_HDRLEN ||
387 1.1 paulus uio->uio_resid < PPP_HDRLEN)
388 1.1 paulus return (EMSGSIZE);
389 1.33.2.5 skrll
390 1.33.2.5 skrll MGETHDR(m0, M_WAIT, MT_DATA);
391 1.33.2.5 skrll if (m0 == NULL)
392 1.33.2.5 skrll return ENOBUFS;
393 1.33.2.5 skrll
394 1.33.2.5 skrll m0->m_len = 0;
395 1.33.2.5 skrll m0->m_pkthdr.len = uio->uio_resid;
396 1.33.2.5 skrll m0->m_pkthdr.rcvif = NULL;
397 1.33.2.5 skrll
398 1.33.2.5 skrll if (uio->uio_resid >= MCLBYTES / 2)
399 1.33.2.5 skrll MCLGET(m0, M_DONTWAIT);
400 1.33.2.5 skrll
401 1.33.2.5 skrll for (m = m0; uio->uio_resid;) {
402 1.1 paulus len = M_TRAILINGSPACE(m);
403 1.1 paulus if (len > uio->uio_resid)
404 1.1 paulus len = uio->uio_resid;
405 1.4 christos if ((error = uiomove(mtod(m, u_char *), len, uio)) != 0) {
406 1.1 paulus m_freem(m0);
407 1.1 paulus return (error);
408 1.1 paulus }
409 1.1 paulus m->m_len = len;
410 1.33.2.5 skrll
411 1.33.2.5 skrll if (uio->uio_resid == 0)
412 1.33.2.5 skrll break;
413 1.33.2.5 skrll
414 1.33.2.5 skrll MGET(m->m_next, M_WAIT, MT_DATA);
415 1.33.2.5 skrll if (m->m_next == NULL) {
416 1.33.2.5 skrll m_freem(m0);
417 1.33.2.5 skrll return ENOBUFS;
418 1.33.2.5 skrll }
419 1.33.2.5 skrll m = m->m_next;
420 1.33.2.5 skrll m->m_len = 0;
421 1.1 paulus }
422 1.1 paulus dst.sa_family = AF_UNSPEC;
423 1.1 paulus bcopy(mtod(m0, u_char *), dst.sa_data, PPP_HDRLEN);
424 1.33.2.5 skrll m_adj(m0, PPP_HDRLEN);
425 1.11 christos return ((*sc->sc_if.if_output)(&sc->sc_if, m0, &dst, (struct rtentry *)0));
426 1.1 paulus }
427 1.1 paulus
428 1.1 paulus /*
429 1.1 paulus * Line specific (tty) ioctl routine.
430 1.1 paulus * This discipline requires that tty device drivers call
431 1.1 paulus * the line specific l_ioctl routine from their ioctl routines.
432 1.1 paulus */
433 1.1 paulus /* ARGSUSED */
434 1.1 paulus int
435 1.1 paulus ppptioctl(tp, cmd, data, flag, p)
436 1.1 paulus struct tty *tp;
437 1.1 paulus u_long cmd;
438 1.1 paulus caddr_t data;
439 1.1 paulus int flag;
440 1.1 paulus struct proc *p;
441 1.1 paulus {
442 1.1 paulus struct ppp_softc *sc = (struct ppp_softc *) tp->t_sc;
443 1.1 paulus int error, s;
444 1.1 paulus
445 1.1 paulus if (sc == NULL || tp != (struct tty *) sc->sc_devp)
446 1.30 atatat return (EPASSTHROUGH);
447 1.1 paulus
448 1.1 paulus error = 0;
449 1.1 paulus switch (cmd) {
450 1.18 christos case TIOCRCVFRAME:
451 1.18 christos ppprcvframe(sc,*((struct mbuf **)data));
452 1.18 christos break;
453 1.33.2.4 skrll
454 1.1 paulus case PPPIOCSASYNCMAP:
455 1.4 christos if ((error = suser(p->p_ucred, &p->p_acflag)) != 0)
456 1.1 paulus break;
457 1.1 paulus sc->sc_asyncmap[0] = *(u_int *)data;
458 1.1 paulus break;
459 1.1 paulus
460 1.1 paulus case PPPIOCGASYNCMAP:
461 1.1 paulus *(u_int *)data = sc->sc_asyncmap[0];
462 1.1 paulus break;
463 1.1 paulus
464 1.1 paulus case PPPIOCSRASYNCMAP:
465 1.4 christos if ((error = suser(p->p_ucred, &p->p_acflag)) != 0)
466 1.1 paulus break;
467 1.1 paulus sc->sc_rasyncmap = *(u_int *)data;
468 1.1 paulus break;
469 1.1 paulus
470 1.1 paulus case PPPIOCGRASYNCMAP:
471 1.1 paulus *(u_int *)data = sc->sc_rasyncmap;
472 1.1 paulus break;
473 1.1 paulus
474 1.1 paulus case PPPIOCSXASYNCMAP:
475 1.4 christos if ((error = suser(p->p_ucred, &p->p_acflag)) != 0)
476 1.1 paulus break;
477 1.1 paulus s = spltty();
478 1.1 paulus bcopy(data, sc->sc_asyncmap, sizeof(sc->sc_asyncmap));
479 1.1 paulus sc->sc_asyncmap[1] = 0; /* mustn't escape 0x20 - 0x3f */
480 1.1 paulus sc->sc_asyncmap[2] &= ~0x40000000; /* mustn't escape 0x5e */
481 1.1 paulus sc->sc_asyncmap[3] |= 0x60000000; /* must escape 0x7d, 0x7e */
482 1.1 paulus splx(s);
483 1.1 paulus break;
484 1.1 paulus
485 1.1 paulus case PPPIOCGXASYNCMAP:
486 1.1 paulus bcopy(sc->sc_asyncmap, data, sizeof(sc->sc_asyncmap));
487 1.1 paulus break;
488 1.1 paulus
489 1.1 paulus default:
490 1.1 paulus error = pppioctl(sc, cmd, data, flag, p);
491 1.1 paulus if (error == 0 && cmd == PPPIOCSMRU)
492 1.1 paulus pppgetm(sc);
493 1.1 paulus }
494 1.1 paulus
495 1.1 paulus return error;
496 1.1 paulus }
497 1.1 paulus
498 1.18 christos /* receive a complete ppp frame from device in synchronous
499 1.18 christos * hdlc mode. caller gives up ownership of mbuf
500 1.18 christos */
501 1.18 christos static void
502 1.18 christos ppprcvframe(sc, m)
503 1.18 christos struct ppp_softc *sc;
504 1.18 christos struct mbuf *m;
505 1.18 christos {
506 1.18 christos int len, s;
507 1.18 christos struct mbuf *n;
508 1.18 christos u_char hdr[4];
509 1.18 christos int hlen,count;
510 1.33.2.4 skrll
511 1.18 christos for (n=m,len=0;n != NULL;n = n->m_next)
512 1.18 christos len += n->m_len;
513 1.18 christos if (len==0) {
514 1.18 christos m_freem(m);
515 1.18 christos return;
516 1.18 christos }
517 1.33.2.4 skrll
518 1.18 christos /* extract PPP header from mbuf chain (1 to 4 bytes) */
519 1.18 christos for (n=m,hlen=0;n!=NULL && hlen<sizeof(hdr);n=n->m_next) {
520 1.18 christos count = (sizeof(hdr)-hlen) < n->m_len ?
521 1.18 christos sizeof(hdr)-hlen : n->m_len;
522 1.18 christos bcopy(mtod(n,u_char*),&hdr[hlen],count);
523 1.18 christos hlen+=count;
524 1.18 christos }
525 1.33.2.4 skrll
526 1.18 christos s = spltty();
527 1.33.2.4 skrll
528 1.18 christos /* if AFCF compressed then prepend AFCF */
529 1.18 christos if (hdr[0] != PPP_ALLSTATIONS) {
530 1.18 christos if (sc->sc_flags & SC_REJ_COMP_AC) {
531 1.18 christos if (sc->sc_flags & SC_DEBUG)
532 1.18 christos printf(
533 1.18 christos "%s: garbage received: 0x%x (need 0xFF)\n",
534 1.18 christos sc->sc_if.if_xname, hdr[0]);
535 1.18 christos goto bail;
536 1.18 christos }
537 1.33.2.4 skrll M_PREPEND(m,2,M_DONTWAIT);
538 1.18 christos if (m==NULL) {
539 1.18 christos splx(s);
540 1.18 christos return;
541 1.18 christos }
542 1.18 christos hdr[3] = hdr[1];
543 1.18 christos hdr[2] = hdr[0];
544 1.18 christos hdr[0] = PPP_ALLSTATIONS;
545 1.18 christos hdr[1] = PPP_UI;
546 1.18 christos len += 2;
547 1.18 christos }
548 1.18 christos
549 1.18 christos /* if protocol field compressed, add MSB of protocol field = 0 */
550 1.18 christos if (hdr[2] & 1) {
551 1.18 christos /* a compressed protocol */
552 1.33.2.4 skrll M_PREPEND(m,1,M_DONTWAIT);
553 1.18 christos if (m==NULL) {
554 1.18 christos splx(s);
555 1.18 christos return;
556 1.18 christos }
557 1.18 christos hdr[3] = hdr[2];
558 1.18 christos hdr[2] = 0;
559 1.18 christos len++;
560 1.33.2.4 skrll }
561 1.33.2.4 skrll
562 1.18 christos /* valid LSB of protocol field has bit0 set */
563 1.18 christos if (!(hdr[3] & 1)) {
564 1.18 christos if (sc->sc_flags & SC_DEBUG)
565 1.18 christos printf("%s: bad protocol %x\n", sc->sc_if.if_xname,
566 1.18 christos (hdr[2] << 8) + hdr[3]);
567 1.18 christos goto bail;
568 1.18 christos }
569 1.33.2.4 skrll
570 1.18 christos /* packet beyond configured mru? */
571 1.18 christos if (len > sc->sc_mru + PPP_HDRLEN) {
572 1.18 christos if (sc->sc_flags & SC_DEBUG)
573 1.18 christos printf("%s: packet too big\n", sc->sc_if.if_xname);
574 1.18 christos goto bail;
575 1.18 christos }
576 1.33.2.4 skrll
577 1.18 christos /* add expanded 4 byte header to mbuf chain */
578 1.18 christos for (n=m,hlen=0;n!=NULL && hlen<sizeof(hdr);n=n->m_next) {
579 1.18 christos count = (sizeof(hdr)-hlen) < n->m_len ?
580 1.18 christos sizeof(hdr)-hlen : n->m_len;
581 1.18 christos bcopy(&hdr[hlen],mtod(n,u_char*),count);
582 1.18 christos hlen+=count;
583 1.18 christos }
584 1.33.2.4 skrll
585 1.18 christos /* if_ppp.c requires the PPP header and IP header */
586 1.18 christos /* to be contiguous */
587 1.18 christos count = len < MHLEN ? len : MHLEN;
588 1.18 christos if (m->m_len < count) {
589 1.18 christos m = m_pullup(m,count);
590 1.18 christos if (m==NULL)
591 1.18 christos goto bail;
592 1.18 christos }
593 1.33.2.4 skrll
594 1.18 christos sc->sc_stats.ppp_ibytes += len;
595 1.33.2.4 skrll
596 1.18 christos if (sc->sc_flags & SC_LOG_RAWIN)
597 1.18 christos pppdumpframe(sc,m,0);
598 1.33.2.4 skrll
599 1.18 christos ppppktin(sc, m, 0);
600 1.18 christos splx(s);
601 1.18 christos return;
602 1.33.2.4 skrll bail:
603 1.18 christos m_freem(m);
604 1.18 christos splx(s);
605 1.18 christos }
606 1.18 christos
607 1.1 paulus /*
608 1.1 paulus * FCS lookup table as calculated by genfcstab.
609 1.1 paulus */
610 1.23 jdolecek static const u_int16_t fcstab[256] = {
611 1.1 paulus 0x0000, 0x1189, 0x2312, 0x329b, 0x4624, 0x57ad, 0x6536, 0x74bf,
612 1.1 paulus 0x8c48, 0x9dc1, 0xaf5a, 0xbed3, 0xca6c, 0xdbe5, 0xe97e, 0xf8f7,
613 1.1 paulus 0x1081, 0x0108, 0x3393, 0x221a, 0x56a5, 0x472c, 0x75b7, 0x643e,
614 1.1 paulus 0x9cc9, 0x8d40, 0xbfdb, 0xae52, 0xdaed, 0xcb64, 0xf9ff, 0xe876,
615 1.1 paulus 0x2102, 0x308b, 0x0210, 0x1399, 0x6726, 0x76af, 0x4434, 0x55bd,
616 1.1 paulus 0xad4a, 0xbcc3, 0x8e58, 0x9fd1, 0xeb6e, 0xfae7, 0xc87c, 0xd9f5,
617 1.1 paulus 0x3183, 0x200a, 0x1291, 0x0318, 0x77a7, 0x662e, 0x54b5, 0x453c,
618 1.1 paulus 0xbdcb, 0xac42, 0x9ed9, 0x8f50, 0xfbef, 0xea66, 0xd8fd, 0xc974,
619 1.1 paulus 0x4204, 0x538d, 0x6116, 0x709f, 0x0420, 0x15a9, 0x2732, 0x36bb,
620 1.1 paulus 0xce4c, 0xdfc5, 0xed5e, 0xfcd7, 0x8868, 0x99e1, 0xab7a, 0xbaf3,
621 1.1 paulus 0x5285, 0x430c, 0x7197, 0x601e, 0x14a1, 0x0528, 0x37b3, 0x263a,
622 1.1 paulus 0xdecd, 0xcf44, 0xfddf, 0xec56, 0x98e9, 0x8960, 0xbbfb, 0xaa72,
623 1.1 paulus 0x6306, 0x728f, 0x4014, 0x519d, 0x2522, 0x34ab, 0x0630, 0x17b9,
624 1.1 paulus 0xef4e, 0xfec7, 0xcc5c, 0xddd5, 0xa96a, 0xb8e3, 0x8a78, 0x9bf1,
625 1.1 paulus 0x7387, 0x620e, 0x5095, 0x411c, 0x35a3, 0x242a, 0x16b1, 0x0738,
626 1.1 paulus 0xffcf, 0xee46, 0xdcdd, 0xcd54, 0xb9eb, 0xa862, 0x9af9, 0x8b70,
627 1.1 paulus 0x8408, 0x9581, 0xa71a, 0xb693, 0xc22c, 0xd3a5, 0xe13e, 0xf0b7,
628 1.1 paulus 0x0840, 0x19c9, 0x2b52, 0x3adb, 0x4e64, 0x5fed, 0x6d76, 0x7cff,
629 1.1 paulus 0x9489, 0x8500, 0xb79b, 0xa612, 0xd2ad, 0xc324, 0xf1bf, 0xe036,
630 1.1 paulus 0x18c1, 0x0948, 0x3bd3, 0x2a5a, 0x5ee5, 0x4f6c, 0x7df7, 0x6c7e,
631 1.1 paulus 0xa50a, 0xb483, 0x8618, 0x9791, 0xe32e, 0xf2a7, 0xc03c, 0xd1b5,
632 1.1 paulus 0x2942, 0x38cb, 0x0a50, 0x1bd9, 0x6f66, 0x7eef, 0x4c74, 0x5dfd,
633 1.1 paulus 0xb58b, 0xa402, 0x9699, 0x8710, 0xf3af, 0xe226, 0xd0bd, 0xc134,
634 1.1 paulus 0x39c3, 0x284a, 0x1ad1, 0x0b58, 0x7fe7, 0x6e6e, 0x5cf5, 0x4d7c,
635 1.1 paulus 0xc60c, 0xd785, 0xe51e, 0xf497, 0x8028, 0x91a1, 0xa33a, 0xb2b3,
636 1.1 paulus 0x4a44, 0x5bcd, 0x6956, 0x78df, 0x0c60, 0x1de9, 0x2f72, 0x3efb,
637 1.1 paulus 0xd68d, 0xc704, 0xf59f, 0xe416, 0x90a9, 0x8120, 0xb3bb, 0xa232,
638 1.1 paulus 0x5ac5, 0x4b4c, 0x79d7, 0x685e, 0x1ce1, 0x0d68, 0x3ff3, 0x2e7a,
639 1.1 paulus 0xe70e, 0xf687, 0xc41c, 0xd595, 0xa12a, 0xb0a3, 0x8238, 0x93b1,
640 1.1 paulus 0x6b46, 0x7acf, 0x4854, 0x59dd, 0x2d62, 0x3ceb, 0x0e70, 0x1ff9,
641 1.1 paulus 0xf78f, 0xe606, 0xd49d, 0xc514, 0xb1ab, 0xa022, 0x92b9, 0x8330,
642 1.1 paulus 0x7bc7, 0x6a4e, 0x58d5, 0x495c, 0x3de3, 0x2c6a, 0x1ef1, 0x0f78
643 1.1 paulus };
644 1.1 paulus
645 1.1 paulus /*
646 1.1 paulus * Calculate a new FCS given the current FCS and the new data.
647 1.1 paulus */
648 1.1 paulus static u_int16_t
649 1.1 paulus pppfcs(fcs, cp, len)
650 1.20 augustss u_int16_t fcs;
651 1.20 augustss u_char *cp;
652 1.20 augustss int len;
653 1.1 paulus {
654 1.1 paulus while (len--)
655 1.1 paulus fcs = PPP_FCS(fcs, *cp++);
656 1.1 paulus return (fcs);
657 1.1 paulus }
658 1.1 paulus
659 1.18 christos /* This gets called at splsoftnet from pppasyncstart at various times
660 1.18 christos * when there is data ready to be sent.
661 1.18 christos */
662 1.18 christos static void
663 1.18 christos pppsyncstart(sc)
664 1.18 christos struct ppp_softc *sc;
665 1.18 christos {
666 1.18 christos struct tty *tp = (struct tty *) sc->sc_devp;
667 1.18 christos struct mbuf *m, *n;
668 1.32 gehenna const struct cdevsw *cdev;
669 1.18 christos int len;
670 1.33.2.4 skrll
671 1.18 christos for(m = sc->sc_outm;;) {
672 1.18 christos if (m == NULL) {
673 1.18 christos m = ppp_dequeue(sc); /* get new packet */
674 1.18 christos if (m == NULL)
675 1.18 christos break; /* no more packets */
676 1.18 christos if (sc->sc_flags & SC_DEBUG)
677 1.18 christos pppdumpframe(sc,m,1);
678 1.18 christos }
679 1.18 christos for(n=m,len=0;n!=NULL;n=n->m_next)
680 1.18 christos len += n->m_len;
681 1.33.2.4 skrll
682 1.18 christos /* call device driver IOCTL to transmit a frame */
683 1.32 gehenna cdev = cdevsw_lookup(tp->t_dev);
684 1.32 gehenna if (cdev == NULL ||
685 1.32 gehenna (*cdev->d_ioctl)(tp->t_dev, TIOCXMTFRAME, (caddr_t)&m,
686 1.32 gehenna 0, 0)) {
687 1.18 christos /* busy or error, set as current packet */
688 1.18 christos sc->sc_outm = m;
689 1.18 christos break;
690 1.18 christos }
691 1.18 christos sc->sc_outm = m = NULL;
692 1.18 christos sc->sc_stats.ppp_obytes += len;
693 1.18 christos }
694 1.18 christos }
695 1.18 christos
696 1.1 paulus /*
697 1.11 christos * This gets called at splsoftnet from if_ppp.c at various times
698 1.11 christos * when there is data ready to be sent.
699 1.1 paulus */
700 1.1 paulus static void
701 1.1 paulus pppasyncstart(sc)
702 1.20 augustss struct ppp_softc *sc;
703 1.1 paulus {
704 1.20 augustss struct tty *tp = (struct tty *) sc->sc_devp;
705 1.20 augustss struct mbuf *m;
706 1.20 augustss int len;
707 1.20 augustss u_char *start, *stop, *cp;
708 1.4 christos int n, ndone, done, idle;
709 1.1 paulus struct mbuf *m2;
710 1.11 christos int s;
711 1.1 paulus
712 1.18 christos if (sc->sc_flags & SC_SYNC){
713 1.18 christos pppsyncstart(sc);
714 1.18 christos return;
715 1.18 christos }
716 1.33.2.4 skrll
717 1.1 paulus idle = 0;
718 1.1 paulus while (CCOUNT(&tp->t_outq) < PPP_HIWAT) {
719 1.1 paulus /*
720 1.1 paulus * See if we have an existing packet partly sent.
721 1.1 paulus * If not, get a new packet and start sending it.
722 1.1 paulus */
723 1.1 paulus m = sc->sc_outm;
724 1.1 paulus if (m == NULL) {
725 1.1 paulus /*
726 1.1 paulus * Get another packet to be sent.
727 1.1 paulus */
728 1.1 paulus m = ppp_dequeue(sc);
729 1.1 paulus if (m == NULL) {
730 1.1 paulus idle = 1;
731 1.1 paulus break;
732 1.1 paulus }
733 1.1 paulus
734 1.1 paulus /*
735 1.1 paulus * The extra PPP_FLAG will start up a new packet, and thus
736 1.1 paulus * will flush any accumulated garbage. We do this whenever
737 1.1 paulus * the line may have been idle for some time.
738 1.1 paulus */
739 1.1 paulus if (CCOUNT(&tp->t_outq) == 0) {
740 1.5 paulus ++sc->sc_stats.ppp_obytes;
741 1.1 paulus (void) putc(PPP_FLAG, &tp->t_outq);
742 1.1 paulus }
743 1.1 paulus
744 1.1 paulus /* Calculate the FCS for the first mbuf's worth. */
745 1.1 paulus sc->sc_outfcs = pppfcs(PPP_INITFCS, mtod(m, u_char *), m->m_len);
746 1.1 paulus }
747 1.1 paulus
748 1.1 paulus for (;;) {
749 1.1 paulus start = mtod(m, u_char *);
750 1.1 paulus len = m->m_len;
751 1.1 paulus stop = start + len;
752 1.1 paulus while (len > 0) {
753 1.1 paulus /*
754 1.1 paulus * Find out how many bytes in the string we can
755 1.1 paulus * handle without doing something special.
756 1.1 paulus */
757 1.1 paulus for (cp = start; cp < stop; cp++)
758 1.1 paulus if (ESCAPE_P(*cp))
759 1.1 paulus break;
760 1.1 paulus n = cp - start;
761 1.1 paulus if (n) {
762 1.1 paulus /* NetBSD (0.9 or later), 4.3-Reno or similar. */
763 1.1 paulus ndone = n - b_to_q(start, n, &tp->t_outq);
764 1.1 paulus len -= ndone;
765 1.1 paulus start += ndone;
766 1.5 paulus sc->sc_stats.ppp_obytes += ndone;
767 1.1 paulus
768 1.1 paulus if (ndone < n)
769 1.1 paulus break; /* packet doesn't fit */
770 1.1 paulus }
771 1.1 paulus /*
772 1.1 paulus * If there are characters left in the mbuf,
773 1.11 christos * the first one must be special.
774 1.1 paulus * Put it out in a different form.
775 1.1 paulus */
776 1.1 paulus if (len) {
777 1.11 christos s = spltty();
778 1.12 christos if (putc(PPP_ESCAPE, &tp->t_outq)) {
779 1.12 christos splx(s);
780 1.1 paulus break;
781 1.12 christos }
782 1.1 paulus if (putc(*start ^ PPP_TRANS, &tp->t_outq)) {
783 1.1 paulus (void) unputc(&tp->t_outq);
784 1.11 christos splx(s);
785 1.1 paulus break;
786 1.1 paulus }
787 1.11 christos splx(s);
788 1.5 paulus sc->sc_stats.ppp_obytes += 2;
789 1.1 paulus start++;
790 1.1 paulus len--;
791 1.1 paulus }
792 1.1 paulus }
793 1.1 paulus
794 1.1 paulus /*
795 1.1 paulus * If we didn't empty this mbuf, remember where we're up to.
796 1.1 paulus * If we emptied the last mbuf, try to add the FCS and closing
797 1.1 paulus * flag, and if we can't, leave sc_outm pointing to m, but with
798 1.1 paulus * m->m_len == 0, to remind us to output the FCS and flag later.
799 1.1 paulus */
800 1.1 paulus done = len == 0;
801 1.1 paulus if (done && m->m_next == NULL) {
802 1.1 paulus u_char *p, *q;
803 1.1 paulus int c;
804 1.1 paulus u_char endseq[8];
805 1.1 paulus
806 1.1 paulus /*
807 1.1 paulus * We may have to escape the bytes in the FCS.
808 1.1 paulus */
809 1.1 paulus p = endseq;
810 1.1 paulus c = ~sc->sc_outfcs & 0xFF;
811 1.1 paulus if (ESCAPE_P(c)) {
812 1.1 paulus *p++ = PPP_ESCAPE;
813 1.1 paulus *p++ = c ^ PPP_TRANS;
814 1.1 paulus } else
815 1.1 paulus *p++ = c;
816 1.1 paulus c = (~sc->sc_outfcs >> 8) & 0xFF;
817 1.1 paulus if (ESCAPE_P(c)) {
818 1.1 paulus *p++ = PPP_ESCAPE;
819 1.1 paulus *p++ = c ^ PPP_TRANS;
820 1.1 paulus } else
821 1.1 paulus *p++ = c;
822 1.1 paulus *p++ = PPP_FLAG;
823 1.1 paulus
824 1.1 paulus /*
825 1.1 paulus * Try to output the FCS and flag. If the bytes
826 1.1 paulus * don't all fit, back out.
827 1.1 paulus */
828 1.11 christos s = spltty();
829 1.1 paulus for (q = endseq; q < p; ++q)
830 1.1 paulus if (putc(*q, &tp->t_outq)) {
831 1.1 paulus done = 0;
832 1.1 paulus for (; q > endseq; --q)
833 1.1 paulus unputc(&tp->t_outq);
834 1.1 paulus break;
835 1.1 paulus }
836 1.11 christos splx(s);
837 1.11 christos if (done)
838 1.11 christos sc->sc_stats.ppp_obytes += q - endseq;
839 1.1 paulus }
840 1.1 paulus
841 1.1 paulus if (!done) {
842 1.1 paulus /* remember where we got to */
843 1.1 paulus m->m_data = start;
844 1.1 paulus m->m_len = len;
845 1.1 paulus break;
846 1.1 paulus }
847 1.1 paulus
848 1.1 paulus /* Finished with this mbuf; free it and move on. */
849 1.1 paulus MFREE(m, m2);
850 1.1 paulus m = m2;
851 1.1 paulus if (m == NULL) {
852 1.1 paulus /* Finished a packet */
853 1.1 paulus break;
854 1.1 paulus }
855 1.1 paulus sc->sc_outfcs = pppfcs(sc->sc_outfcs, mtod(m, u_char *), m->m_len);
856 1.1 paulus }
857 1.1 paulus
858 1.1 paulus /*
859 1.11 christos * If m == NULL, we have finished a packet.
860 1.11 christos * If m != NULL, we've either done as much work this time
861 1.11 christos * as we need to, or else we've filled up the output queue.
862 1.1 paulus */
863 1.1 paulus sc->sc_outm = m;
864 1.1 paulus if (m)
865 1.1 paulus break;
866 1.1 paulus }
867 1.1 paulus
868 1.11 christos /* Call pppstart to start output again if necessary. */
869 1.11 christos s = spltty();
870 1.14 sommerfe pppstart(tp);
871 1.11 christos
872 1.11 christos /*
873 1.11 christos * This timeout is needed for operation on a pseudo-tty,
874 1.11 christos * because the pty code doesn't call pppstart after it has
875 1.11 christos * drained the t_outq.
876 1.11 christos */
877 1.11 christos if (!idle && (sc->sc_flags & SC_TIMEOUT) == 0) {
878 1.19 thorpej callout_reset(&sc->sc_timo_ch, 1, ppp_timeout, sc);
879 1.11 christos sc->sc_flags |= SC_TIMEOUT;
880 1.11 christos }
881 1.11 christos
882 1.11 christos splx(s);
883 1.11 christos }
884 1.11 christos
885 1.11 christos /*
886 1.11 christos * This gets called when a received packet is placed on
887 1.11 christos * the inq, at splsoftnet.
888 1.11 christos */
889 1.11 christos static void
890 1.11 christos pppasyncctlp(sc)
891 1.11 christos struct ppp_softc *sc;
892 1.11 christos {
893 1.11 christos struct tty *tp;
894 1.11 christos int s;
895 1.11 christos
896 1.11 christos /* Put a placeholder byte in canq for ttselect()/ttnread(). */
897 1.11 christos s = spltty();
898 1.11 christos tp = (struct tty *) sc->sc_devp;
899 1.11 christos putc(0, &tp->t_canq);
900 1.11 christos ttwakeup(tp);
901 1.11 christos splx(s);
902 1.11 christos }
903 1.11 christos
904 1.11 christos /*
905 1.11 christos * Start output on async tty interface. If the transmit queue
906 1.11 christos * has drained sufficiently, arrange for pppasyncstart to be
907 1.11 christos * called later at splsoftnet.
908 1.11 christos * Called at spltty or higher.
909 1.11 christos */
910 1.11 christos int
911 1.14 sommerfe pppstart(tp)
912 1.20 augustss struct tty *tp;
913 1.11 christos {
914 1.20 augustss struct ppp_softc *sc = (struct ppp_softc *) tp->t_sc;
915 1.11 christos
916 1.1 paulus /*
917 1.1 paulus * If there is stuff in the output queue, send it now.
918 1.1 paulus * We are being called in lieu of ttstart and must do what it would.
919 1.1 paulus */
920 1.1 paulus if (tp->t_oproc != NULL)
921 1.1 paulus (*tp->t_oproc)(tp);
922 1.1 paulus
923 1.1 paulus /*
924 1.11 christos * If the transmit queue has drained and the tty has not hung up
925 1.11 christos * or been disconnected from the ppp unit, then tell if_ppp.c that
926 1.11 christos * we need more output.
927 1.1 paulus */
928 1.14 sommerfe if ((CCOUNT(&tp->t_outq) >= PPP_LOWAT)
929 1.14 sommerfe && ((sc == NULL) || (sc->sc_flags & SC_TIMEOUT)))
930 1.13 christos return 0;
931 1.29 itojun #ifdef ALTQ
932 1.29 itojun /*
933 1.29 itojun * if ALTQ is enabled, don't invoke NETISR_PPP.
934 1.29 itojun * pppintr() could loop without doing anything useful
935 1.29 itojun * under rate-limiting.
936 1.29 itojun */
937 1.29 itojun if (ALTQ_IS_ENABLED(&sc->sc_if.if_snd))
938 1.29 itojun return 0;
939 1.29 itojun #endif
940 1.13 christos if (!((tp->t_state & TS_CARR_ON) == 0 && (tp->t_cflag & CLOCAL) == 0)
941 1.11 christos && sc != NULL && tp == (struct tty *) sc->sc_devp) {
942 1.11 christos ppp_restart(sc);
943 1.1 paulus }
944 1.1 paulus
945 1.1 paulus return 0;
946 1.1 paulus }
947 1.1 paulus
948 1.1 paulus /*
949 1.1 paulus * Timeout routine - try to start some more output.
950 1.1 paulus */
951 1.1 paulus static void
952 1.1 paulus ppp_timeout(x)
953 1.1 paulus void *x;
954 1.1 paulus {
955 1.1 paulus struct ppp_softc *sc = (struct ppp_softc *) x;
956 1.1 paulus struct tty *tp = (struct tty *) sc->sc_devp;
957 1.1 paulus int s;
958 1.1 paulus
959 1.1 paulus s = spltty();
960 1.1 paulus sc->sc_flags &= ~SC_TIMEOUT;
961 1.14 sommerfe pppstart(tp);
962 1.1 paulus splx(s);
963 1.1 paulus }
964 1.1 paulus
965 1.1 paulus /*
966 1.1 paulus * Allocate enough mbuf to handle current MRU.
967 1.1 paulus */
968 1.1 paulus static void
969 1.1 paulus pppgetm(sc)
970 1.20 augustss struct ppp_softc *sc;
971 1.1 paulus {
972 1.1 paulus struct mbuf *m, **mp;
973 1.1 paulus int len;
974 1.1 paulus
975 1.1 paulus mp = &sc->sc_m;
976 1.1 paulus for (len = sc->sc_mru + PPP_HDRLEN + PPP_FCSLEN; len > 0; ){
977 1.1 paulus if ((m = *mp) == NULL) {
978 1.1 paulus MGETHDR(m, M_DONTWAIT, MT_DATA);
979 1.1 paulus if (m == NULL)
980 1.1 paulus break;
981 1.1 paulus *mp = m;
982 1.1 paulus MCLGET(m, M_DONTWAIT);
983 1.1 paulus }
984 1.1 paulus len -= M_DATASIZE(m);
985 1.1 paulus mp = &m->m_next;
986 1.1 paulus }
987 1.1 paulus }
988 1.1 paulus
989 1.1 paulus /*
990 1.1 paulus * tty interface receiver interrupt.
991 1.1 paulus */
992 1.23 jdolecek static const unsigned paritytab[8] = {
993 1.1 paulus 0x96696996, 0x69969669, 0x69969669, 0x96696996,
994 1.1 paulus 0x69969669, 0x96696996, 0x96696996, 0x69969669
995 1.1 paulus };
996 1.1 paulus
997 1.1 paulus int
998 1.1 paulus pppinput(c, tp)
999 1.1 paulus int c;
1000 1.20 augustss struct tty *tp;
1001 1.1 paulus {
1002 1.20 augustss struct ppp_softc *sc;
1003 1.1 paulus struct mbuf *m;
1004 1.32 gehenna const struct cdevsw *cdev;
1005 1.1 paulus int ilen, s;
1006 1.1 paulus
1007 1.1 paulus sc = (struct ppp_softc *) tp->t_sc;
1008 1.1 paulus if (sc == NULL || tp != (struct tty *) sc->sc_devp)
1009 1.1 paulus return 0;
1010 1.1 paulus
1011 1.1 paulus ++tk_nin;
1012 1.5 paulus ++sc->sc_stats.ppp_ibytes;
1013 1.1 paulus
1014 1.1 paulus if (c & TTY_FE) {
1015 1.1 paulus /* framing error or overrun on this char - abort packet */
1016 1.1 paulus if (sc->sc_flags & SC_DEBUG)
1017 1.10 christos printf("%s: bad char %x\n", sc->sc_if.if_xname, c);
1018 1.1 paulus goto flush;
1019 1.1 paulus }
1020 1.1 paulus
1021 1.1 paulus c &= 0xff;
1022 1.1 paulus
1023 1.5 paulus /*
1024 1.5 paulus * Handle software flow control of output.
1025 1.5 paulus */
1026 1.5 paulus if (tp->t_iflag & IXON) {
1027 1.5 paulus if (c == tp->t_cc[VSTOP] && tp->t_cc[VSTOP] != _POSIX_VDISABLE) {
1028 1.5 paulus if ((tp->t_state & TS_TTSTOP) == 0) {
1029 1.5 paulus tp->t_state |= TS_TTSTOP;
1030 1.32 gehenna cdev = cdevsw_lookup(tp->t_dev);
1031 1.32 gehenna if (cdev != NULL)
1032 1.32 gehenna (*cdev->d_stop)(tp, 0);
1033 1.5 paulus }
1034 1.5 paulus return 0;
1035 1.5 paulus }
1036 1.5 paulus if (c == tp->t_cc[VSTART] && tp->t_cc[VSTART] != _POSIX_VDISABLE) {
1037 1.5 paulus tp->t_state &= ~TS_TTSTOP;
1038 1.5 paulus if (tp->t_oproc != NULL)
1039 1.5 paulus (*tp->t_oproc)(tp);
1040 1.5 paulus return 0;
1041 1.5 paulus }
1042 1.5 paulus }
1043 1.5 paulus
1044 1.11 christos s = spltty();
1045 1.1 paulus if (c & 0x80)
1046 1.1 paulus sc->sc_flags |= SC_RCV_B7_1;
1047 1.1 paulus else
1048 1.1 paulus sc->sc_flags |= SC_RCV_B7_0;
1049 1.1 paulus if (paritytab[c >> 5] & (1 << (c & 0x1F)))
1050 1.1 paulus sc->sc_flags |= SC_RCV_ODDP;
1051 1.1 paulus else
1052 1.1 paulus sc->sc_flags |= SC_RCV_EVNP;
1053 1.11 christos splx(s);
1054 1.1 paulus
1055 1.33.2.1 skrll ppplogchar(sc, c);
1056 1.1 paulus
1057 1.1 paulus if (c == PPP_FLAG) {
1058 1.1 paulus ilen = sc->sc_ilen;
1059 1.1 paulus sc->sc_ilen = 0;
1060 1.1 paulus
1061 1.33.2.4 skrll if ((sc->sc_flags & SC_LOG_RAWIN) && sc->sc_rawin.count > 0)
1062 1.1 paulus ppplogchar(sc, -1);
1063 1.1 paulus
1064 1.1 paulus /*
1065 1.1 paulus * If SC_ESCAPED is set, then we've seen the packet
1066 1.1 paulus * abort sequence "}~".
1067 1.1 paulus */
1068 1.1 paulus if (sc->sc_flags & (SC_FLUSH | SC_ESCAPED)
1069 1.4 christos || (ilen > 0 && sc->sc_fcs != PPP_GOODFCS)) {
1070 1.11 christos s = spltty();
1071 1.1 paulus sc->sc_flags |= SC_PKTLOST; /* note the dropped packet */
1072 1.1 paulus if ((sc->sc_flags & (SC_FLUSH | SC_ESCAPED)) == 0){
1073 1.1 paulus if (sc->sc_flags & SC_DEBUG)
1074 1.10 christos printf("%s: bad fcs %x\n", sc->sc_if.if_xname,
1075 1.9 christos sc->sc_fcs);
1076 1.1 paulus sc->sc_if.if_ierrors++;
1077 1.5 paulus sc->sc_stats.ppp_ierrors++;
1078 1.1 paulus } else
1079 1.1 paulus sc->sc_flags &= ~(SC_FLUSH | SC_ESCAPED);
1080 1.1 paulus splx(s);
1081 1.1 paulus return 0;
1082 1.1 paulus }
1083 1.1 paulus
1084 1.1 paulus if (ilen < PPP_HDRLEN + PPP_FCSLEN) {
1085 1.1 paulus if (ilen) {
1086 1.1 paulus if (sc->sc_flags & SC_DEBUG)
1087 1.10 christos printf("%s: too short (%d)\n", sc->sc_if.if_xname, ilen);
1088 1.11 christos s = spltty();
1089 1.1 paulus sc->sc_if.if_ierrors++;
1090 1.5 paulus sc->sc_stats.ppp_ierrors++;
1091 1.1 paulus sc->sc_flags |= SC_PKTLOST;
1092 1.11 christos splx(s);
1093 1.1 paulus }
1094 1.1 paulus return 0;
1095 1.1 paulus }
1096 1.1 paulus
1097 1.1 paulus /*
1098 1.1 paulus * Remove FCS trailer. Somewhat painful...
1099 1.1 paulus */
1100 1.1 paulus ilen -= 2;
1101 1.1 paulus if (--sc->sc_mc->m_len == 0) {
1102 1.1 paulus for (m = sc->sc_m; m->m_next != sc->sc_mc; m = m->m_next)
1103 1.1 paulus ;
1104 1.1 paulus sc->sc_mc = m;
1105 1.1 paulus }
1106 1.1 paulus sc->sc_mc->m_len--;
1107 1.1 paulus
1108 1.1 paulus /* excise this mbuf chain */
1109 1.1 paulus m = sc->sc_m;
1110 1.1 paulus sc->sc_m = sc->sc_mc->m_next;
1111 1.1 paulus sc->sc_mc->m_next = NULL;
1112 1.1 paulus
1113 1.1 paulus ppppktin(sc, m, sc->sc_flags & SC_PKTLOST);
1114 1.11 christos if (sc->sc_flags & SC_PKTLOST) {
1115 1.11 christos s = spltty();
1116 1.11 christos sc->sc_flags &= ~SC_PKTLOST;
1117 1.11 christos splx(s);
1118 1.11 christos }
1119 1.1 paulus
1120 1.1 paulus pppgetm(sc);
1121 1.1 paulus return 0;
1122 1.1 paulus }
1123 1.1 paulus
1124 1.1 paulus if (sc->sc_flags & SC_FLUSH) {
1125 1.1 paulus if (sc->sc_flags & SC_LOG_FLUSH)
1126 1.1 paulus ppplogchar(sc, c);
1127 1.1 paulus return 0;
1128 1.1 paulus }
1129 1.1 paulus
1130 1.11 christos if (c < 0x20 && (sc->sc_rasyncmap & (1 << c)))
1131 1.1 paulus return 0;
1132 1.1 paulus
1133 1.11 christos s = spltty();
1134 1.1 paulus if (sc->sc_flags & SC_ESCAPED) {
1135 1.1 paulus sc->sc_flags &= ~SC_ESCAPED;
1136 1.1 paulus c ^= PPP_TRANS;
1137 1.1 paulus } else if (c == PPP_ESCAPE) {
1138 1.1 paulus sc->sc_flags |= SC_ESCAPED;
1139 1.1 paulus splx(s);
1140 1.1 paulus return 0;
1141 1.1 paulus }
1142 1.11 christos splx(s);
1143 1.1 paulus
1144 1.1 paulus /*
1145 1.1 paulus * Initialize buffer on first octet received.
1146 1.1 paulus * First octet could be address or protocol (when compressing
1147 1.1 paulus * address/control).
1148 1.1 paulus * Second octet is control.
1149 1.1 paulus * Third octet is first or second (when compressing protocol)
1150 1.1 paulus * octet of protocol.
1151 1.1 paulus * Fourth octet is second octet of protocol.
1152 1.1 paulus */
1153 1.1 paulus if (sc->sc_ilen == 0) {
1154 1.1 paulus /* reset the first input mbuf */
1155 1.1 paulus if (sc->sc_m == NULL) {
1156 1.1 paulus pppgetm(sc);
1157 1.1 paulus if (sc->sc_m == NULL) {
1158 1.1 paulus if (sc->sc_flags & SC_DEBUG)
1159 1.10 christos printf("%s: no input mbufs!\n", sc->sc_if.if_xname);
1160 1.1 paulus goto flush;
1161 1.1 paulus }
1162 1.1 paulus }
1163 1.1 paulus m = sc->sc_m;
1164 1.1 paulus m->m_len = 0;
1165 1.1 paulus m->m_data = M_DATASTART(sc->sc_m);
1166 1.1 paulus sc->sc_mc = m;
1167 1.1 paulus sc->sc_mp = mtod(m, char *);
1168 1.1 paulus sc->sc_fcs = PPP_INITFCS;
1169 1.1 paulus if (c != PPP_ALLSTATIONS) {
1170 1.1 paulus if (sc->sc_flags & SC_REJ_COMP_AC) {
1171 1.1 paulus if (sc->sc_flags & SC_DEBUG)
1172 1.10 christos printf("%s: garbage received: 0x%x (need 0xFF)\n",
1173 1.9 christos sc->sc_if.if_xname, c);
1174 1.1 paulus goto flush;
1175 1.1 paulus }
1176 1.1 paulus *sc->sc_mp++ = PPP_ALLSTATIONS;
1177 1.1 paulus *sc->sc_mp++ = PPP_UI;
1178 1.1 paulus sc->sc_ilen += 2;
1179 1.1 paulus m->m_len += 2;
1180 1.1 paulus }
1181 1.1 paulus }
1182 1.1 paulus if (sc->sc_ilen == 1 && c != PPP_UI) {
1183 1.1 paulus if (sc->sc_flags & SC_DEBUG)
1184 1.10 christos printf("%s: missing UI (0x3), got 0x%x\n",
1185 1.9 christos sc->sc_if.if_xname, c);
1186 1.1 paulus goto flush;
1187 1.1 paulus }
1188 1.1 paulus if (sc->sc_ilen == 2 && (c & 1) == 1) {
1189 1.1 paulus /* a compressed protocol */
1190 1.1 paulus *sc->sc_mp++ = 0;
1191 1.1 paulus sc->sc_ilen++;
1192 1.1 paulus sc->sc_mc->m_len++;
1193 1.1 paulus }
1194 1.1 paulus if (sc->sc_ilen == 3 && (c & 1) == 0) {
1195 1.1 paulus if (sc->sc_flags & SC_DEBUG)
1196 1.10 christos printf("%s: bad protocol %x\n", sc->sc_if.if_xname,
1197 1.9 christos (sc->sc_mp[-1] << 8) + c);
1198 1.1 paulus goto flush;
1199 1.1 paulus }
1200 1.1 paulus
1201 1.1 paulus /* packet beyond configured mru? */
1202 1.1 paulus if (++sc->sc_ilen > sc->sc_mru + PPP_HDRLEN + PPP_FCSLEN) {
1203 1.1 paulus if (sc->sc_flags & SC_DEBUG)
1204 1.10 christos printf("%s: packet too big\n", sc->sc_if.if_xname);
1205 1.1 paulus goto flush;
1206 1.1 paulus }
1207 1.1 paulus
1208 1.1 paulus /* is this mbuf full? */
1209 1.1 paulus m = sc->sc_mc;
1210 1.1 paulus if (M_TRAILINGSPACE(m) <= 0) {
1211 1.1 paulus if (m->m_next == NULL) {
1212 1.1 paulus pppgetm(sc);
1213 1.1 paulus if (m->m_next == NULL) {
1214 1.1 paulus if (sc->sc_flags & SC_DEBUG)
1215 1.10 christos printf("%s: too few input mbufs!\n", sc->sc_if.if_xname);
1216 1.1 paulus goto flush;
1217 1.1 paulus }
1218 1.1 paulus }
1219 1.1 paulus sc->sc_mc = m = m->m_next;
1220 1.1 paulus m->m_len = 0;
1221 1.1 paulus m->m_data = M_DATASTART(m);
1222 1.1 paulus sc->sc_mp = mtod(m, char *);
1223 1.1 paulus }
1224 1.1 paulus
1225 1.1 paulus ++m->m_len;
1226 1.1 paulus *sc->sc_mp++ = c;
1227 1.1 paulus sc->sc_fcs = PPP_FCS(sc->sc_fcs, c);
1228 1.1 paulus return 0;
1229 1.1 paulus
1230 1.1 paulus flush:
1231 1.1 paulus if (!(sc->sc_flags & SC_FLUSH)) {
1232 1.11 christos s = spltty();
1233 1.1 paulus sc->sc_if.if_ierrors++;
1234 1.5 paulus sc->sc_stats.ppp_ierrors++;
1235 1.1 paulus sc->sc_flags |= SC_FLUSH;
1236 1.11 christos splx(s);
1237 1.1 paulus if (sc->sc_flags & SC_LOG_FLUSH)
1238 1.1 paulus ppplogchar(sc, c);
1239 1.1 paulus }
1240 1.1 paulus return 0;
1241 1.1 paulus }
1242 1.1 paulus
1243 1.1 paulus #define MAX_DUMP_BYTES 128
1244 1.1 paulus
1245 1.1 paulus static void
1246 1.1 paulus ppplogchar(sc, c)
1247 1.1 paulus struct ppp_softc *sc;
1248 1.1 paulus int c;
1249 1.1 paulus {
1250 1.33.2.1 skrll if (c >= 0) {
1251 1.33.2.1 skrll sc->sc_rawin.buf[sc->sc_rawin_start++] = c;
1252 1.33.2.1 skrll if (sc->sc_rawin.count < sizeof(sc->sc_rawin.buf))
1253 1.33.2.1 skrll sc->sc_rawin.count++;
1254 1.33.2.1 skrll }
1255 1.33.2.1 skrll if (sc->sc_rawin_start >= sizeof(sc->sc_rawin.buf)
1256 1.33.2.1 skrll || (c < 0 && sc->sc_rawin_start > 0)) {
1257 1.33.2.1 skrll if (sc->sc_flags & (SC_LOG_FLUSH|SC_LOG_RAWIN)) {
1258 1.33.2.1 skrll printf("%s input: ", sc->sc_if.if_xname);
1259 1.33.2.1 skrll pppdumpb(sc->sc_rawin.buf, sc->sc_rawin_start);
1260 1.33.2.1 skrll }
1261 1.33.2.1 skrll if (c < 0)
1262 1.33.2.1 skrll sc->sc_rawin.count = 0;
1263 1.33.2.1 skrll sc->sc_rawin_start = 0;
1264 1.1 paulus }
1265 1.1 paulus }
1266 1.1 paulus
1267 1.1 paulus static void
1268 1.1 paulus pppdumpb(b, l)
1269 1.1 paulus u_char *b;
1270 1.1 paulus int l;
1271 1.1 paulus {
1272 1.33.2.5 skrll char bf[3*MAX_DUMP_BYTES+4];
1273 1.33.2.5 skrll char *bp = bf;
1274 1.1 paulus
1275 1.1 paulus while (l--) {
1276 1.33.2.5 skrll if (bp >= bf + sizeof(bf) - 3) {
1277 1.1 paulus *bp++ = '>';
1278 1.1 paulus break;
1279 1.1 paulus }
1280 1.33.2.5 skrll *bp++ = hexdigits[*b >> 4]; /* convert byte to ascii hex */
1281 1.33.2.5 skrll *bp++ = hexdigits[*b++ & 0xf];
1282 1.1 paulus *bp++ = ' ';
1283 1.1 paulus }
1284 1.1 paulus
1285 1.1 paulus *bp = 0;
1286 1.33.2.5 skrll printf("%s\n", bf);
1287 1.18 christos }
1288 1.18 christos
1289 1.18 christos static void
1290 1.18 christos pppdumpframe(sc, m, xmit)
1291 1.18 christos struct ppp_softc *sc;
1292 1.18 christos struct mbuf* m;
1293 1.18 christos int xmit;
1294 1.18 christos {
1295 1.18 christos int i,lcount,copycount,count;
1296 1.18 christos char lbuf[16];
1297 1.18 christos char *data;
1298 1.33.2.4 skrll
1299 1.18 christos if (m == NULL)
1300 1.18 christos return;
1301 1.33.2.4 skrll
1302 1.18 christos for(count=m->m_len,data=mtod(m,char*);m != NULL;) {
1303 1.18 christos /* build a line of output */
1304 1.18 christos for(lcount=0;lcount < sizeof(lbuf);lcount += copycount) {
1305 1.18 christos if (!count) {
1306 1.18 christos m = m->m_next;
1307 1.18 christos if (m == NULL)
1308 1.18 christos break;
1309 1.18 christos count = m->m_len;
1310 1.18 christos data = mtod(m,char*);
1311 1.18 christos }
1312 1.18 christos copycount = (count > sizeof(lbuf)-lcount) ?
1313 1.18 christos sizeof(lbuf)-lcount : count;
1314 1.18 christos bcopy(data,&lbuf[lcount],copycount);
1315 1.18 christos data += copycount;
1316 1.18 christos count -= copycount;
1317 1.18 christos }
1318 1.18 christos
1319 1.33.2.4 skrll /* output line (hex 1st, then ascii) */
1320 1.18 christos printf("%s %s:", sc->sc_if.if_xname,
1321 1.18 christos xmit ? "output" : "input ");
1322 1.18 christos for(i=0;i<lcount;i++)
1323 1.18 christos printf("%02x ",(u_char)lbuf[i]);
1324 1.18 christos for(;i<sizeof(lbuf);i++)
1325 1.18 christos printf(" ");
1326 1.18 christos for(i=0;i<lcount;i++)
1327 1.33.2.4 skrll printf("%c",(lbuf[i] >= 040 &&
1328 1.18 christos lbuf[i] <= 0176) ? lbuf[i] : '.');
1329 1.18 christos printf("\n");
1330 1.18 christos }
1331 1.1 paulus }
1332