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