Home | History | Annotate | Line # | Download | only in net
if_ppp.c revision 1.37
      1  1.37  christos /*	$NetBSD: if_ppp.c,v 1.37 1997/03/12 20:26:50 christos Exp $	*/
      2  1.37  christos /*	Id: if_ppp.c,v 1.6 1997/03/04 03:33:00 paulus Exp 	*/
      3  1.14       cgd 
      4   1.1   deraadt /*
      5   1.1   deraadt  * if_ppp.c - Point-to-Point Protocol (PPP) Asynchronous driver.
      6   1.1   deraadt  *
      7   1.1   deraadt  * Copyright (c) 1989 Carnegie Mellon University.
      8   1.1   deraadt  * All rights reserved.
      9   1.1   deraadt  *
     10   1.1   deraadt  * Redistribution and use in source and binary forms are permitted
     11   1.1   deraadt  * provided that the above copyright notice and this paragraph are
     12   1.1   deraadt  * duplicated in all such forms and that any documentation,
     13   1.1   deraadt  * advertising materials, and other materials related to such
     14   1.1   deraadt  * distribution and use acknowledge that the software was developed
     15   1.1   deraadt  * by Carnegie Mellon University.  The name of the
     16   1.1   deraadt  * University may not be used to endorse or promote products derived
     17   1.1   deraadt  * from this software without specific prior written permission.
     18   1.1   deraadt  * THIS SOFTWARE IS PROVIDED ``AS IS'' AND WITHOUT ANY EXPRESS OR
     19   1.1   deraadt  * IMPLIED WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED
     20   1.1   deraadt  * WARRANTIES OF MERCHANTIBILITY AND FITNESS FOR A PARTICULAR PURPOSE.
     21   1.1   deraadt  *
     22   1.1   deraadt  * Drew D. Perkins
     23   1.1   deraadt  * Carnegie Mellon University
     24   1.1   deraadt  * 4910 Forbes Ave.
     25   1.1   deraadt  * Pittsburgh, PA 15213
     26   1.1   deraadt  * (412) 268-8576
     27   1.1   deraadt  * ddp (at) andrew.cmu.edu
     28   1.1   deraadt  *
     29   1.1   deraadt  * Based on:
     30   1.1   deraadt  *	@(#)if_sl.c	7.6.1.2 (Berkeley) 2/15/89
     31   1.1   deraadt  *
     32   1.1   deraadt  * Copyright (c) 1987 Regents of the University of California.
     33   1.1   deraadt  * All rights reserved.
     34   1.1   deraadt  *
     35   1.1   deraadt  * Redistribution and use in source and binary forms are permitted
     36   1.1   deraadt  * provided that the above copyright notice and this paragraph are
     37   1.1   deraadt  * duplicated in all such forms and that any documentation,
     38   1.1   deraadt  * advertising materials, and other materials related to such
     39   1.1   deraadt  * distribution and use acknowledge that the software was developed
     40   1.1   deraadt  * by the University of California, Berkeley.  The name of the
     41   1.1   deraadt  * University may not be used to endorse or promote products derived
     42   1.1   deraadt  * from this software without specific prior written permission.
     43   1.1   deraadt  * THIS SOFTWARE IS PROVIDED ``AS IS'' AND WITHOUT ANY EXPRESS OR
     44   1.1   deraadt  * IMPLIED WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED
     45   1.1   deraadt  * WARRANTIES OF MERCHANTIBILITY AND FITNESS FOR A PARTICULAR PURPOSE.
     46   1.1   deraadt  *
     47   1.1   deraadt  * Serial Line interface
     48   1.1   deraadt  *
     49   1.1   deraadt  * Rick Adams
     50   1.1   deraadt  * Center for Seismic Studies
     51   1.1   deraadt  * 1300 N 17th Street, Suite 1450
     52   1.1   deraadt  * Arlington, Virginia 22209
     53   1.1   deraadt  * (703)276-7900
     54   1.1   deraadt  * rick (at) seismo.ARPA
     55   1.1   deraadt  * seismo!rick
     56   1.1   deraadt  *
     57   1.1   deraadt  * Pounded on heavily by Chris Torek (chris (at) mimsy.umd.edu, umcp-cs!chris).
     58   1.1   deraadt  * Converted to 4.3BSD Beta by Chris Torek.
     59   1.1   deraadt  * Other changes made at Berkeley, based in part on code by Kirk Smith.
     60   1.1   deraadt  *
     61   1.1   deraadt  * Converted to 4.3BSD+ 386BSD by Brad Parker (brad (at) cayman.com)
     62   1.1   deraadt  * Added VJ tcp header compression; more unified ioctls
     63   1.1   deraadt  *
     64   1.1   deraadt  * Extensively modified by Paul Mackerras (paulus (at) cs.anu.edu.au).
     65   1.1   deraadt  * Cleaned up a lot of the mbuf-related code to fix bugs that
     66   1.1   deraadt  * caused system crashes and packet corruption.  Changed pppstart
     67   1.1   deraadt  * so that it doesn't just give up with a collision if the whole
     68   1.1   deraadt  * packet doesn't fit in the output ring buffer.
     69   1.1   deraadt  *
     70   1.2    paulus  * Added priority queueing for interactive IP packets, following
     71   1.2    paulus  * the model of if_sl.c, plus hooks for bpf.
     72   1.2    paulus  * Paul Mackerras (paulus (at) cs.anu.edu.au).
     73   1.1   deraadt  */
     74   1.1   deraadt 
     75   1.2    paulus /* from if_sl.c,v 1.11 84/10/04 12:54:47 rick Exp */
     76  1.22    paulus /* from NetBSD: if_ppp.c,v 1.15.2.2 1994/07/28 05:17:58 cgd Exp */
     77   1.2    paulus 
     78   1.1   deraadt #include "ppp.h"
     79   1.1   deraadt #if NPPP > 0
     80   1.1   deraadt 
     81   1.1   deraadt #define VJC
     82  1.22    paulus #define PPP_COMPRESS
     83   1.1   deraadt 
     84   1.5   mycroft #include <sys/param.h>
     85   1.5   mycroft #include <sys/proc.h>
     86   1.5   mycroft #include <sys/mbuf.h>
     87   1.5   mycroft #include <sys/socket.h>
     88   1.5   mycroft #include <sys/ioctl.h>
     89   1.5   mycroft #include <sys/kernel.h>
     90  1.28  christos #include <sys/systm.h>
     91  1.29    paulus #include <sys/time.h>
     92  1.29    paulus #include <sys/malloc.h>
     93  1.22    paulus 
     94   1.5   mycroft #include <net/if.h>
     95   1.5   mycroft #include <net/if_types.h>
     96   1.5   mycroft #include <net/netisr.h>
     97   1.5   mycroft #include <net/route.h>
     98  1.37  christos #ifdef PPP_FILTER
     99  1.29    paulus #include <net/bpf.h>
    100  1.37  christos #endif
    101   1.5   mycroft 
    102   1.1   deraadt #if INET
    103   1.5   mycroft #include <netinet/in.h>
    104   1.5   mycroft #include <netinet/in_systm.h>
    105   1.5   mycroft #include <netinet/in_var.h>
    106   1.5   mycroft #include <netinet/ip.h>
    107   1.1   deraadt #endif
    108   1.1   deraadt 
    109   1.2    paulus #include "bpfilter.h"
    110   1.2    paulus #if NBPFILTER > 0
    111   1.5   mycroft #include <sys/time.h>
    112   1.5   mycroft #include <net/bpf.h>
    113   1.2    paulus #endif
    114   1.2    paulus 
    115   1.1   deraadt #ifdef VJC
    116   1.8    paulus #include <net/slcompress.h>
    117   1.1   deraadt #endif
    118   1.1   deraadt 
    119  1.22    paulus #include <net/ppp_defs.h>
    120   1.8    paulus #include <net/if_ppp.h>
    121  1.22    paulus #include <net/if_pppvar.h>
    122   1.6       cgd #include <machine/cpu.h>
    123   1.1   deraadt 
    124  1.22    paulus #ifdef PPP_COMPRESS
    125  1.22    paulus #define PACKETPTR	struct mbuf *
    126  1.22    paulus #include <net/ppp-comp.h>
    127  1.22    paulus #endif
    128   1.1   deraadt 
    129  1.37  christos static int	pppsioctl __P((struct ifnet *, u_long, caddr_t));
    130  1.37  christos static int	pppoutput __P((struct ifnet *, struct mbuf *,
    131  1.37  christos 			       struct sockaddr *, struct rtentry *));
    132  1.22    paulus static void	ppp_requeue __P((struct ppp_softc *));
    133  1.28  christos static void	ppp_ccp __P((struct ppp_softc *, struct mbuf *m, int rcvd));
    134  1.22    paulus static void	ppp_ccp_closed __P((struct ppp_softc *));
    135  1.22    paulus static void	ppp_inproc __P((struct ppp_softc *, struct mbuf *));
    136  1.22    paulus static void	pppdumpm __P((struct mbuf *m0));
    137   1.1   deraadt 
    138   1.1   deraadt /*
    139   1.1   deraadt  * Some useful mbuf macros not in mbuf.h.
    140   1.1   deraadt  */
    141  1.22    paulus #define M_IS_CLUSTER(m)	((m)->m_flags & M_EXT)
    142  1.22    paulus 
    143   1.1   deraadt #define M_DATASTART(m)	\
    144  1.22    paulus 	(M_IS_CLUSTER(m) ? (m)->m_ext.ext_buf : \
    145   1.1   deraadt 	    (m)->m_flags & M_PKTHDR ? (m)->m_pktdat : (m)->m_dat)
    146   1.1   deraadt 
    147   1.1   deraadt #define M_DATASIZE(m)	\
    148  1.22    paulus 	(M_IS_CLUSTER(m) ? (m)->m_ext.ext_size : \
    149   1.1   deraadt 	    (m)->m_flags & M_PKTHDR ? MHLEN: MLEN)
    150   1.1   deraadt 
    151   1.1   deraadt /*
    152  1.22    paulus  * We steal two bits in the mbuf m_flags, to mark high-priority packets
    153  1.22    paulus  * for output, and received packets following lost/corrupted packets.
    154   1.2    paulus  */
    155  1.22    paulus #define M_HIGHPRI	0x2000	/* output packet for sc_fastq */
    156  1.22    paulus #define M_ERRMARK	0x4000	/* steal a bit in mbuf m_flags */
    157  1.22    paulus 
    158   1.2    paulus 
    159  1.22    paulus #ifdef PPP_COMPRESS
    160   1.2    paulus /*
    161  1.22    paulus  * List of compressors we know about.
    162  1.22    paulus  * We leave some space so maybe we can modload compressors.
    163   1.2    paulus  */
    164  1.22    paulus 
    165  1.22    paulus extern struct compressor ppp_bsd_compress;
    166  1.29    paulus extern struct compressor ppp_deflate;
    167  1.22    paulus 
    168  1.22    paulus struct compressor *ppp_compressors[8] = {
    169  1.30    paulus #if DO_BSD_COMPRESS && defined(PPP_BSDCOMP)
    170  1.22    paulus     &ppp_bsd_compress,
    171  1.22    paulus #endif
    172  1.30    paulus #if DO_DEFLATE && defined(PPP_DEFLATE)
    173  1.29    paulus     &ppp_deflate,
    174  1.29    paulus #endif
    175  1.22    paulus     NULL
    176  1.22    paulus };
    177  1.22    paulus #endif /* PPP_COMPRESS */
    178   1.2    paulus 
    179  1.37  christos 
    180   1.2    paulus /*
    181   1.1   deraadt  * Called from boot code to establish ppp interfaces.
    182   1.1   deraadt  */
    183   1.1   deraadt void
    184   1.1   deraadt pppattach()
    185   1.1   deraadt {
    186   1.1   deraadt     register struct ppp_softc *sc;
    187   1.1   deraadt     register int i = 0;
    188   1.1   deraadt 
    189   1.1   deraadt     for (sc = ppp_softc; i < NPPP; sc++) {
    190  1.31   thorpej 	sc->sc_unit = i;	/* XXX */
    191  1.35  christos 	sprintf(sc->sc_if.if_xname, "ppp%d", i++);
    192  1.31   thorpej 	sc->sc_if.if_softc = sc;
    193   1.1   deraadt 	sc->sc_if.if_mtu = PPP_MTU;
    194  1.29    paulus 	sc->sc_if.if_flags = IFF_POINTOPOINT | IFF_MULTICAST;
    195   1.1   deraadt 	sc->sc_if.if_type = IFT_PPP;
    196   1.7   deraadt 	sc->sc_if.if_hdrlen = PPP_HDRLEN;
    197  1.22    paulus 	sc->sc_if.if_ioctl = pppsioctl;
    198   1.1   deraadt 	sc->sc_if.if_output = pppoutput;
    199   1.1   deraadt 	sc->sc_if.if_snd.ifq_maxlen = IFQ_MAXLEN;
    200   1.1   deraadt 	sc->sc_inq.ifq_maxlen = IFQ_MAXLEN;
    201   1.2    paulus 	sc->sc_fastq.ifq_maxlen = IFQ_MAXLEN;
    202  1.22    paulus 	sc->sc_rawq.ifq_maxlen = IFQ_MAXLEN;
    203   1.1   deraadt 	if_attach(&sc->sc_if);
    204   1.2    paulus #if NBPFILTER > 0
    205   1.7   deraadt 	bpfattach(&sc->sc_bpf, &sc->sc_if, DLT_PPP, PPP_HDRLEN);
    206   1.2    paulus #endif
    207   1.1   deraadt     }
    208   1.1   deraadt }
    209   1.1   deraadt 
    210   1.1   deraadt /*
    211   1.8    paulus  * Allocate a ppp interface unit and initialize it.
    212   1.8    paulus  */
    213   1.8    paulus struct ppp_softc *
    214   1.8    paulus pppalloc(pid)
    215   1.8    paulus     pid_t pid;
    216   1.8    paulus {
    217  1.22    paulus     int nppp, i;
    218   1.8    paulus     struct ppp_softc *sc;
    219   1.8    paulus 
    220   1.8    paulus     for (nppp = 0, sc = ppp_softc; nppp < NPPP; nppp++, sc++)
    221   1.8    paulus 	if (sc->sc_xfer == pid) {
    222   1.8    paulus 	    sc->sc_xfer = 0;
    223  1.22    paulus 	    return sc;
    224  1.22    paulus 	}
    225  1.22    paulus     for (nppp = 0, sc = ppp_softc; nppp < NPPP; nppp++, sc++)
    226  1.22    paulus 	if (sc->sc_devp == NULL)
    227   1.8    paulus 	    break;
    228   1.8    paulus     if (nppp >= NPPP)
    229   1.8    paulus 	return NULL;
    230   1.8    paulus 
    231   1.8    paulus     sc->sc_flags = 0;
    232   1.8    paulus     sc->sc_mru = PPP_MRU;
    233  1.22    paulus     sc->sc_relinq = NULL;
    234  1.29    paulus     bzero((char *)&sc->sc_stats, sizeof(sc->sc_stats));
    235   1.8    paulus #ifdef VJC
    236  1.29    paulus     MALLOC(sc->sc_comp, struct slcompress *, sizeof(struct slcompress),
    237  1.29    paulus 	   M_DEVBUF, M_NOWAIT);
    238  1.29    paulus     if (sc->sc_comp)
    239  1.29    paulus 	sl_compress_init(sc->sc_comp, -1);
    240   1.8    paulus #endif
    241  1.22    paulus #ifdef PPP_COMPRESS
    242  1.22    paulus     sc->sc_xc_state = NULL;
    243  1.22    paulus     sc->sc_rc_state = NULL;
    244  1.22    paulus #endif /* PPP_COMPRESS */
    245  1.22    paulus     for (i = 0; i < NUM_NP; ++i)
    246  1.22    paulus 	sc->sc_npmode[i] = NPMODE_ERROR;
    247  1.22    paulus     sc->sc_npqueue = NULL;
    248  1.22    paulus     sc->sc_npqtail = &sc->sc_npqueue;
    249  1.22    paulus     sc->sc_last_sent = sc->sc_last_recv = time.tv_sec;
    250   1.8    paulus 
    251   1.8    paulus     return sc;
    252   1.8    paulus }
    253   1.8    paulus 
    254   1.8    paulus /*
    255  1.22    paulus  * Deallocate a ppp unit.  Must be called at splsoftnet or higher.
    256   1.8    paulus  */
    257  1.22    paulus void
    258   1.8    paulus pppdealloc(sc)
    259   1.8    paulus     struct ppp_softc *sc;
    260   1.8    paulus {
    261   1.8    paulus     struct mbuf *m;
    262   1.8    paulus 
    263   1.8    paulus     if_down(&sc->sc_if);
    264  1.22    paulus     sc->sc_if.if_flags &= ~(IFF_UP|IFF_RUNNING);
    265   1.8    paulus     sc->sc_devp = NULL;
    266   1.8    paulus     sc->sc_xfer = 0;
    267   1.8    paulus     for (;;) {
    268  1.22    paulus 	IF_DEQUEUE(&sc->sc_rawq, m);
    269  1.22    paulus 	if (m == NULL)
    270  1.22    paulus 	    break;
    271  1.22    paulus 	m_freem(m);
    272  1.22    paulus     }
    273  1.22    paulus     for (;;) {
    274   1.8    paulus 	IF_DEQUEUE(&sc->sc_inq, m);
    275   1.8    paulus 	if (m == NULL)
    276   1.8    paulus 	    break;
    277   1.8    paulus 	m_freem(m);
    278   1.8    paulus     }
    279   1.8    paulus     for (;;) {
    280   1.8    paulus 	IF_DEQUEUE(&sc->sc_fastq, m);
    281   1.8    paulus 	if (m == NULL)
    282   1.8    paulus 	    break;
    283   1.8    paulus 	m_freem(m);
    284   1.8    paulus     }
    285  1.22    paulus     while ((m = sc->sc_npqueue) != NULL) {
    286  1.22    paulus 	sc->sc_npqueue = m->m_nextpkt;
    287  1.22    paulus 	m_freem(m);
    288   1.1   deraadt     }
    289  1.22    paulus     if (sc->sc_togo != NULL) {
    290  1.22    paulus 	m_freem(sc->sc_togo);
    291  1.22    paulus 	sc->sc_togo = NULL;
    292  1.22    paulus     }
    293  1.22    paulus #ifdef PPP_COMPRESS
    294  1.22    paulus     ppp_ccp_closed(sc);
    295  1.22    paulus     sc->sc_xc_state = NULL;
    296  1.22    paulus     sc->sc_rc_state = NULL;
    297  1.22    paulus #endif /* PPP_COMPRESS */
    298  1.37  christos #ifdef PPP_FILTER
    299  1.29    paulus     if (sc->sc_pass_filt.bf_insns != 0) {
    300  1.29    paulus 	FREE(sc->sc_pass_filt.bf_insns, M_DEVBUF);
    301  1.29    paulus 	sc->sc_pass_filt.bf_insns = 0;
    302  1.29    paulus 	sc->sc_pass_filt.bf_len = 0;
    303  1.29    paulus     }
    304  1.29    paulus     if (sc->sc_active_filt.bf_insns != 0) {
    305  1.29    paulus 	FREE(sc->sc_active_filt.bf_insns, M_DEVBUF);
    306  1.29    paulus 	sc->sc_active_filt.bf_insns = 0;
    307  1.29    paulus 	sc->sc_active_filt.bf_len = 0;
    308  1.29    paulus     }
    309  1.37  christos #endif /* PPP_FILTER */
    310  1.29    paulus #ifdef VJC
    311  1.29    paulus     if (sc->sc_comp != 0) {
    312  1.29    paulus 	FREE(sc->sc_comp, M_DEVBUF);
    313  1.29    paulus 	sc->sc_comp = 0;
    314  1.29    paulus     }
    315  1.29    paulus #endif
    316   1.1   deraadt }
    317   1.1   deraadt 
    318   1.1   deraadt /*
    319  1.22    paulus  * Ioctl routine for generic ppp devices.
    320   1.1   deraadt  */
    321   1.1   deraadt int
    322  1.22    paulus pppioctl(sc, cmd, data, flag, p)
    323  1.22    paulus     struct ppp_softc *sc;
    324  1.20       cgd     u_long cmd;
    325   1.1   deraadt     caddr_t data;
    326  1.20       cgd     int flag;
    327   1.8    paulus     struct proc *p;
    328   1.1   deraadt {
    329  1.22    paulus     int s, error, flags, mru, nb, npx;
    330  1.22    paulus     struct ppp_option_data *odp;
    331  1.22    paulus     struct compressor **cp;
    332  1.22    paulus     struct npioctl *npi;
    333  1.22    paulus     time_t t;
    334  1.37  christos #ifdef PPP_FILTER
    335  1.29    paulus     struct bpf_program *bp, *nbp;
    336  1.29    paulus     struct bpf_insn *newcode, *oldcode;
    337  1.29    paulus     int newcodelen;
    338  1.37  christos #endif /* PPP_FILTER */
    339  1.22    paulus #ifdef	PPP_COMPRESS
    340  1.22    paulus     u_char ccp_option[CCP_MAX_OPTION_LENGTH];
    341  1.22    paulus #endif
    342   1.8    paulus 
    343   1.1   deraadt     switch (cmd) {
    344   1.1   deraadt     case FIONREAD:
    345   1.1   deraadt 	*(int *)data = sc->sc_inq.ifq_len;
    346   1.1   deraadt 	break;
    347   1.1   deraadt 
    348   1.1   deraadt     case PPPIOCGUNIT:
    349  1.31   thorpej 	*(int *)data = sc->sc_unit;	/* XXX */
    350   1.1   deraadt 	break;
    351   1.1   deraadt 
    352   1.1   deraadt     case PPPIOCGFLAGS:
    353   1.1   deraadt 	*(u_int *)data = sc->sc_flags;
    354   1.1   deraadt 	break;
    355   1.1   deraadt 
    356   1.1   deraadt     case PPPIOCSFLAGS:
    357  1.28  christos 	if ((error = suser(p->p_ucred, &p->p_acflag)) != 0)
    358   1.1   deraadt 	    return (error);
    359   1.2    paulus 	flags = *(int *)data & SC_MASK;
    360  1.22    paulus 	s = splsoftnet();
    361  1.22    paulus #ifdef PPP_COMPRESS
    362  1.22    paulus 	if (sc->sc_flags & SC_CCP_OPEN && !(flags & SC_CCP_OPEN))
    363  1.22    paulus 	    ppp_ccp_closed(sc);
    364  1.22    paulus #endif
    365  1.36   mycroft 	splimp();
    366   1.2    paulus 	sc->sc_flags = (sc->sc_flags & ~SC_MASK) | flags;
    367   1.1   deraadt 	splx(s);
    368   1.1   deraadt 	break;
    369   1.1   deraadt 
    370   1.2    paulus     case PPPIOCSMRU:
    371  1.28  christos 	if ((error = suser(p->p_ucred, &p->p_acflag)) != 0)
    372   1.2    paulus 	    return (error);
    373   1.2    paulus 	mru = *(int *)data;
    374  1.22    paulus 	if (mru >= PPP_MRU && mru <= PPP_MAXMRU)
    375   1.2    paulus 	    sc->sc_mru = mru;
    376   1.2    paulus 	break;
    377   1.2    paulus 
    378   1.2    paulus     case PPPIOCGMRU:
    379   1.2    paulus 	*(int *)data = sc->sc_mru;
    380   1.2    paulus 	break;
    381   1.2    paulus 
    382   1.8    paulus #ifdef VJC
    383   1.8    paulus     case PPPIOCSMAXCID:
    384  1.28  christos 	if ((error = suser(p->p_ucred, &p->p_acflag)) != 0)
    385   1.8    paulus 	    return (error);
    386  1.29    paulus 	if (sc->sc_comp) {
    387  1.29    paulus 	    s = splsoftnet();
    388  1.29    paulus 	    sl_compress_init(sc->sc_comp, *(int *)data);
    389  1.29    paulus 	    splx(s);
    390  1.29    paulus 	}
    391   1.8    paulus 	break;
    392   1.8    paulus #endif
    393   1.8    paulus 
    394   1.8    paulus     case PPPIOCXFERUNIT:
    395  1.28  christos 	if ((error = suser(p->p_ucred, &p->p_acflag)) != 0)
    396   1.8    paulus 	    return (error);
    397   1.8    paulus 	sc->sc_xfer = p->p_pid;
    398   1.8    paulus 	break;
    399   1.8    paulus 
    400  1.22    paulus #ifdef PPP_COMPRESS
    401  1.22    paulus     case PPPIOCSCOMPRESS:
    402  1.28  christos 	if ((error = suser(p->p_ucred, &p->p_acflag)) != 0)
    403  1.22    paulus 	    return (error);
    404  1.22    paulus 	odp = (struct ppp_option_data *) data;
    405  1.22    paulus 	nb = odp->length;
    406  1.22    paulus 	if (nb > sizeof(ccp_option))
    407  1.22    paulus 	    nb = sizeof(ccp_option);
    408  1.28  christos 	if ((error = copyin(odp->ptr, ccp_option, nb)) != 0)
    409  1.22    paulus 	    return (error);
    410  1.22    paulus 	if (ccp_option[1] < 2)	/* preliminary check on the length byte */
    411  1.22    paulus 	    return (EINVAL);
    412  1.22    paulus 	for (cp = ppp_compressors; *cp != NULL; ++cp)
    413  1.22    paulus 	    if ((*cp)->compress_proto == ccp_option[0]) {
    414  1.22    paulus 		/*
    415  1.22    paulus 		 * Found a handler for the protocol - try to allocate
    416  1.22    paulus 		 * a compressor or decompressor.
    417  1.22    paulus 		 */
    418  1.22    paulus 		error = 0;
    419  1.22    paulus 		if (odp->transmit) {
    420  1.22    paulus 		    s = splsoftnet();
    421  1.22    paulus 		    if (sc->sc_xc_state != NULL)
    422  1.22    paulus 			(*sc->sc_xcomp->comp_free)(sc->sc_xc_state);
    423  1.22    paulus 		    sc->sc_xcomp = *cp;
    424  1.22    paulus 		    sc->sc_xc_state = (*cp)->comp_alloc(ccp_option, nb);
    425  1.22    paulus 		    if (sc->sc_xc_state == NULL) {
    426  1.22    paulus 			if (sc->sc_flags & SC_DEBUG)
    427  1.35  christos 			    printf("%s: comp_alloc failed\n",
    428  1.34  christos 				sc->sc_if.if_xname);
    429  1.22    paulus 			error = ENOBUFS;
    430  1.22    paulus 		    }
    431  1.36   mycroft 		    splimp();
    432  1.22    paulus 		    sc->sc_flags &= ~SC_COMP_RUN;
    433  1.22    paulus 		    splx(s);
    434  1.22    paulus 		} else {
    435  1.22    paulus 		    s = splsoftnet();
    436  1.22    paulus 		    if (sc->sc_rc_state != NULL)
    437  1.22    paulus 			(*sc->sc_rcomp->decomp_free)(sc->sc_rc_state);
    438  1.22    paulus 		    sc->sc_rcomp = *cp;
    439  1.22    paulus 		    sc->sc_rc_state = (*cp)->decomp_alloc(ccp_option, nb);
    440  1.22    paulus 		    if (sc->sc_rc_state == NULL) {
    441  1.22    paulus 			if (sc->sc_flags & SC_DEBUG)
    442  1.35  christos 			    printf("%s: decomp_alloc failed\n",
    443  1.34  christos 				sc->sc_if.if_xname);
    444  1.22    paulus 			error = ENOBUFS;
    445  1.22    paulus 		    }
    446  1.36   mycroft 		    splimp();
    447  1.22    paulus 		    sc->sc_flags &= ~SC_DECOMP_RUN;
    448  1.22    paulus 		    splx(s);
    449  1.22    paulus 		}
    450  1.22    paulus 		return (error);
    451  1.22    paulus 	    }
    452  1.22    paulus 	if (sc->sc_flags & SC_DEBUG)
    453  1.35  christos 	    printf("%s: no compressor for [%x %x %x], %x\n",
    454  1.34  christos 		sc->sc_if.if_xname, ccp_option[0], ccp_option[1],
    455  1.34  christos 		ccp_option[2], nb);
    456  1.22    paulus 	return (EINVAL);	/* no handler found */
    457  1.22    paulus #endif /* PPP_COMPRESS */
    458  1.22    paulus 
    459  1.22    paulus     case PPPIOCGNPMODE:
    460  1.22    paulus     case PPPIOCSNPMODE:
    461  1.22    paulus 	npi = (struct npioctl *) data;
    462  1.22    paulus 	switch (npi->protocol) {
    463  1.22    paulus 	case PPP_IP:
    464  1.22    paulus 	    npx = NP_IP;
    465  1.22    paulus 	    break;
    466  1.22    paulus 	default:
    467  1.22    paulus 	    return EINVAL;
    468  1.22    paulus 	}
    469  1.22    paulus 	if (cmd == PPPIOCGNPMODE) {
    470  1.22    paulus 	    npi->mode = sc->sc_npmode[npx];
    471  1.22    paulus 	} else {
    472  1.28  christos 	    if ((error = suser(p->p_ucred, &p->p_acflag)) != 0)
    473  1.22    paulus 		return (error);
    474  1.22    paulus 	    if (npi->mode != sc->sc_npmode[npx]) {
    475  1.22    paulus 		s = splsoftnet();
    476  1.22    paulus 		sc->sc_npmode[npx] = npi->mode;
    477  1.22    paulus 		if (npi->mode != NPMODE_QUEUE) {
    478  1.22    paulus 		    ppp_requeue(sc);
    479  1.22    paulus 		    (*sc->sc_start)(sc);
    480  1.22    paulus 		}
    481  1.22    paulus 		splx(s);
    482  1.22    paulus 	    }
    483  1.22    paulus 	}
    484  1.22    paulus 	break;
    485  1.22    paulus 
    486  1.22    paulus     case PPPIOCGIDLE:
    487  1.22    paulus 	s = splsoftnet();
    488  1.22    paulus 	t = time.tv_sec;
    489  1.22    paulus 	((struct ppp_idle *)data)->xmit_idle = t - sc->sc_last_sent;
    490  1.22    paulus 	((struct ppp_idle *)data)->recv_idle = t - sc->sc_last_recv;
    491  1.22    paulus 	splx(s);
    492  1.22    paulus 	break;
    493  1.22    paulus 
    494  1.37  christos #ifdef PPP_FILTER
    495  1.29    paulus     case PPPIOCSPASS:
    496  1.29    paulus     case PPPIOCSACTIVE:
    497  1.29    paulus 	nbp = (struct bpf_program *) data;
    498  1.29    paulus 	if ((unsigned) nbp->bf_len > BPF_MAXINSNS)
    499  1.29    paulus 	    return EINVAL;
    500  1.29    paulus 	newcodelen = nbp->bf_len * sizeof(struct bpf_insn);
    501  1.29    paulus 	if (newcodelen != 0) {
    502  1.29    paulus 	    MALLOC(newcode, struct bpf_insn *, newcodelen, M_DEVBUF, M_WAITOK);
    503  1.29    paulus 	    if (newcode == 0) {
    504  1.29    paulus 		return EINVAL;		/* or sumpin */
    505  1.29    paulus 	    }
    506  1.29    paulus 	    if ((error = copyin((caddr_t)nbp->bf_insns, (caddr_t)newcode,
    507  1.29    paulus 			       newcodelen)) != 0) {
    508  1.29    paulus 		FREE(newcode, M_DEVBUF);
    509  1.29    paulus 		return error;
    510  1.29    paulus 	    }
    511  1.29    paulus 	    if (!bpf_validate(newcode, nbp->bf_len)) {
    512  1.29    paulus 		FREE(newcode, M_DEVBUF);
    513  1.29    paulus 		return EINVAL;
    514  1.29    paulus 	    }
    515  1.29    paulus 	} else
    516  1.29    paulus 	    newcode = 0;
    517  1.29    paulus 	bp = (cmd == PPPIOCSPASS)? &sc->sc_pass_filt: &sc->sc_active_filt;
    518  1.29    paulus 	oldcode = bp->bf_insns;
    519  1.29    paulus 	s = splimp();
    520  1.29    paulus 	bp->bf_len = nbp->bf_len;
    521  1.29    paulus 	bp->bf_insns = newcode;
    522  1.29    paulus 	splx(s);
    523  1.29    paulus 	if (oldcode != 0)
    524  1.29    paulus 	    FREE(oldcode, M_DEVBUF);
    525  1.29    paulus 	break;
    526  1.37  christos #endif
    527  1.29    paulus 
    528   1.1   deraadt     default:
    529   1.1   deraadt 	return (-1);
    530   1.1   deraadt     }
    531   1.1   deraadt     return (0);
    532   1.1   deraadt }
    533   1.1   deraadt 
    534   1.1   deraadt /*
    535  1.22    paulus  * Process an ioctl request to the ppp network interface.
    536   1.1   deraadt  */
    537  1.37  christos static int
    538  1.22    paulus pppsioctl(ifp, cmd, data)
    539  1.22    paulus     register struct ifnet *ifp;
    540  1.22    paulus     u_long cmd;
    541  1.22    paulus     caddr_t data;
    542  1.22    paulus {
    543  1.37  christos     register struct proc *p = curproc;	/* XXX */
    544  1.31   thorpej     register struct ppp_softc *sc = ifp->if_softc;
    545  1.22    paulus     register struct ifaddr *ifa = (struct ifaddr *)data;
    546  1.22    paulus     register struct ifreq *ifr = (struct ifreq *)data;
    547  1.22    paulus     struct ppp_stats *psp;
    548  1.22    paulus #ifdef	PPP_COMPRESS
    549  1.22    paulus     struct ppp_comp_stats *pcp;
    550  1.22    paulus #endif
    551  1.22    paulus     int s = splimp(), error = 0;
    552  1.22    paulus 
    553  1.22    paulus     switch (cmd) {
    554  1.22    paulus     case SIOCSIFFLAGS:
    555  1.22    paulus 	if ((ifp->if_flags & IFF_RUNNING) == 0)
    556  1.22    paulus 	    ifp->if_flags &= ~IFF_UP;
    557  1.22    paulus 	break;
    558  1.22    paulus 
    559  1.22    paulus     case SIOCSIFADDR:
    560  1.22    paulus 	if (ifa->ifa_addr->sa_family != AF_INET)
    561  1.22    paulus 	    error = EAFNOSUPPORT;
    562  1.22    paulus 	break;
    563  1.22    paulus 
    564  1.22    paulus     case SIOCSIFDSTADDR:
    565  1.22    paulus 	if (ifa->ifa_addr->sa_family != AF_INET)
    566  1.22    paulus 	    error = EAFNOSUPPORT;
    567  1.22    paulus 	break;
    568  1.22    paulus 
    569  1.22    paulus     case SIOCSIFMTU:
    570  1.37  christos 	if ((error = suser(p->p_ucred, &p->p_acflag)) != 0)
    571  1.37  christos 	    break;
    572  1.22    paulus 	sc->sc_if.if_mtu = ifr->ifr_mtu;
    573  1.22    paulus 	break;
    574  1.22    paulus 
    575  1.37  christos     case SIOCGIFMTU:
    576  1.37  christos 	ifr->ifr_mtu = sc->sc_if.if_mtu;
    577  1.37  christos 	break;
    578  1.37  christos 
    579  1.29    paulus     case SIOCADDMULTI:
    580  1.29    paulus     case SIOCDELMULTI:
    581  1.29    paulus 	if (ifr == 0) {
    582  1.29    paulus 	    error = EAFNOSUPPORT;
    583  1.29    paulus 	    break;
    584  1.29    paulus 	}
    585  1.29    paulus 	switch(ifr->ifr_addr.sa_family) {
    586  1.29    paulus #ifdef INET
    587  1.29    paulus 	case AF_INET:
    588  1.29    paulus 	    break;
    589  1.29    paulus #endif
    590  1.29    paulus 	default:
    591  1.29    paulus 	    error = EAFNOSUPPORT;
    592  1.29    paulus 	    break;
    593  1.29    paulus 	}
    594  1.29    paulus 	break;
    595  1.29    paulus 
    596  1.22    paulus     case SIOCGPPPSTATS:
    597  1.22    paulus 	psp = &((struct ifpppstatsreq *) data)->stats;
    598  1.22    paulus 	bzero(psp, sizeof(*psp));
    599  1.29    paulus 	psp->p = sc->sc_stats;
    600  1.29    paulus #if defined(VJC) && !defined(SL_NO_STATS)
    601  1.29    paulus 	if (sc->sc_comp) {
    602  1.29    paulus 	    psp->vj.vjs_packets = sc->sc_comp->sls_packets;
    603  1.29    paulus 	    psp->vj.vjs_compressed = sc->sc_comp->sls_compressed;
    604  1.29    paulus 	    psp->vj.vjs_searches = sc->sc_comp->sls_searches;
    605  1.29    paulus 	    psp->vj.vjs_misses = sc->sc_comp->sls_misses;
    606  1.29    paulus 	    psp->vj.vjs_uncompressedin = sc->sc_comp->sls_uncompressedin;
    607  1.29    paulus 	    psp->vj.vjs_compressedin = sc->sc_comp->sls_compressedin;
    608  1.29    paulus 	    psp->vj.vjs_errorin = sc->sc_comp->sls_errorin;
    609  1.29    paulus 	    psp->vj.vjs_tossed = sc->sc_comp->sls_tossed;
    610  1.29    paulus 	}
    611  1.22    paulus #endif /* VJC */
    612  1.22    paulus 	break;
    613  1.22    paulus 
    614  1.22    paulus #ifdef PPP_COMPRESS
    615  1.22    paulus     case SIOCGPPPCSTATS:
    616  1.22    paulus 	pcp = &((struct ifpppcstatsreq *) data)->stats;
    617  1.22    paulus 	bzero(pcp, sizeof(*pcp));
    618  1.22    paulus 	if (sc->sc_xc_state != NULL)
    619  1.22    paulus 	    (*sc->sc_xcomp->comp_stat)(sc->sc_xc_state, &pcp->c);
    620  1.22    paulus 	if (sc->sc_rc_state != NULL)
    621  1.22    paulus 	    (*sc->sc_rcomp->decomp_stat)(sc->sc_rc_state, &pcp->d);
    622  1.22    paulus 	break;
    623  1.22    paulus #endif /* PPP_COMPRESS */
    624   1.1   deraadt 
    625  1.22    paulus     default:
    626  1.22    paulus 	error = EINVAL;
    627  1.22    paulus     }
    628  1.22    paulus     splx(s);
    629  1.22    paulus     return (error);
    630   1.1   deraadt }
    631   1.1   deraadt 
    632   1.1   deraadt /*
    633   1.1   deraadt  * Queue a packet.  Start transmission if not active.
    634   1.1   deraadt  * Packet is placed in Information field of PPP frame.
    635   1.1   deraadt  */
    636   1.1   deraadt int
    637   1.9   mycroft pppoutput(ifp, m0, dst, rtp)
    638   1.1   deraadt     struct ifnet *ifp;
    639   1.1   deraadt     struct mbuf *m0;
    640   1.1   deraadt     struct sockaddr *dst;
    641   1.9   mycroft     struct rtentry *rtp;
    642   1.1   deraadt {
    643  1.31   thorpej     register struct ppp_softc *sc = ifp->if_softc;
    644   1.2    paulus     int protocol, address, control;
    645   1.2    paulus     u_char *cp;
    646   1.2    paulus     int s, error;
    647   1.2    paulus     struct ip *ip;
    648   1.2    paulus     struct ifqueue *ifq;
    649  1.22    paulus     enum NPmode mode;
    650  1.37  christos     int len;
    651  1.29    paulus     struct mbuf *m;
    652   1.1   deraadt 
    653   1.8    paulus     if (sc->sc_devp == NULL || (ifp->if_flags & IFF_RUNNING) == 0
    654  1.28  christos 	|| ((ifp->if_flags & IFF_UP) == 0 && dst->sa_family != AF_UNSPEC)) {
    655   1.1   deraadt 	error = ENETDOWN;	/* sort of */
    656   1.1   deraadt 	goto bad;
    657   1.1   deraadt     }
    658   1.1   deraadt 
    659   1.1   deraadt     /*
    660   1.1   deraadt      * Compute PPP header.
    661   1.1   deraadt      */
    662  1.22    paulus     m0->m_flags &= ~M_HIGHPRI;
    663   1.1   deraadt     switch (dst->sa_family) {
    664   1.1   deraadt #ifdef INET
    665   1.1   deraadt     case AF_INET:
    666  1.22    paulus 	address = PPP_ALLSTATIONS;
    667  1.22    paulus 	control = PPP_UI;
    668   1.1   deraadt 	protocol = PPP_IP;
    669  1.22    paulus 	mode = sc->sc_npmode[NP_IP];
    670  1.22    paulus 
    671   1.2    paulus 	/*
    672  1.22    paulus 	 * If this packet has the "low delay" bit set in the IP header,
    673  1.22    paulus 	 * put it on the fastq instead.
    674   1.2    paulus 	 */
    675  1.22    paulus 	ip = mtod(m0, struct ip *);
    676  1.22    paulus 	if (ip->ip_tos & IPTOS_LOWDELAY)
    677  1.22    paulus 	    m0->m_flags |= M_HIGHPRI;
    678   1.1   deraadt 	break;
    679   1.1   deraadt #endif
    680   1.1   deraadt     case AF_UNSPEC:
    681  1.22    paulus 	address = PPP_ADDRESS(dst->sa_data);
    682  1.22    paulus 	control = PPP_CONTROL(dst->sa_data);
    683  1.22    paulus 	protocol = PPP_PROTOCOL(dst->sa_data);
    684  1.22    paulus 	mode = NPMODE_PASS;
    685   1.1   deraadt 	break;
    686   1.1   deraadt     default:
    687  1.35  christos 	printf("%s: af%d not supported\n", ifp->if_xname, dst->sa_family);
    688   1.1   deraadt 	error = EAFNOSUPPORT;
    689   1.1   deraadt 	goto bad;
    690   1.1   deraadt     }
    691   1.1   deraadt 
    692   1.1   deraadt     /*
    693  1.22    paulus      * Drop this packet, or return an error, if necessary.
    694  1.22    paulus      */
    695  1.22    paulus     if (mode == NPMODE_ERROR) {
    696  1.22    paulus 	error = ENETDOWN;
    697  1.22    paulus 	goto bad;
    698  1.22    paulus     }
    699  1.22    paulus     if (mode == NPMODE_DROP) {
    700  1.22    paulus 	error = 0;
    701  1.22    paulus 	goto bad;
    702  1.22    paulus     }
    703  1.22    paulus 
    704  1.22    paulus     /*
    705   1.1   deraadt      * Add PPP header.  If no space in first mbuf, allocate another.
    706   1.2    paulus      * (This assumes M_LEADINGSPACE is always 0 for a cluster mbuf.)
    707   1.1   deraadt      */
    708   1.7   deraadt     if (M_LEADINGSPACE(m0) < PPP_HDRLEN) {
    709   1.7   deraadt 	m0 = m_prepend(m0, PPP_HDRLEN, M_DONTWAIT);
    710   1.1   deraadt 	if (m0 == 0) {
    711   1.1   deraadt 	    error = ENOBUFS;
    712   1.1   deraadt 	    goto bad;
    713   1.1   deraadt 	}
    714   1.1   deraadt 	m0->m_len = 0;
    715   1.1   deraadt     } else
    716   1.7   deraadt 	m0->m_data -= PPP_HDRLEN;
    717   1.1   deraadt 
    718   1.1   deraadt     cp = mtod(m0, u_char *);
    719   1.2    paulus     *cp++ = address;
    720   1.2    paulus     *cp++ = control;
    721   1.2    paulus     *cp++ = protocol >> 8;
    722   1.1   deraadt     *cp++ = protocol & 0xff;
    723   1.7   deraadt     m0->m_len += PPP_HDRLEN;
    724   1.1   deraadt 
    725  1.29    paulus     len = 0;
    726  1.29    paulus     for (m = m0; m != 0; m = m->m_next)
    727  1.29    paulus 	len += m->m_len;
    728  1.29    paulus 
    729   1.8    paulus     if (sc->sc_flags & SC_LOG_OUTPKT) {
    730  1.35  christos 	printf("%s output: ", ifp->if_xname);
    731  1.22    paulus 	pppdumpm(m0);
    732   1.1   deraadt     }
    733   1.1   deraadt 
    734  1.29    paulus     if ((protocol & 0x8000) == 0) {
    735  1.37  christos #ifdef PPP_FILTER
    736  1.37  christos 	/*
    737  1.37  christos 	 * Apply the pass and active filters to the packet,
    738  1.37  christos 	 * but only if it is a data packet.
    739  1.37  christos 	 */
    740  1.29    paulus 	*mtod(m0, u_char *) = 1;	/* indicates outbound */
    741  1.29    paulus 	if (sc->sc_pass_filt.bf_insns != 0
    742  1.29    paulus 	    && bpf_filter(sc->sc_pass_filt.bf_insns, (u_char *) m0,
    743  1.29    paulus 			  len, 0) == 0) {
    744  1.29    paulus 	    error = 0;		/* drop this packet */
    745  1.29    paulus 	    goto bad;
    746  1.29    paulus 	}
    747  1.29    paulus 
    748  1.29    paulus 	/*
    749  1.29    paulus 	 * Update the time we sent the most recent packet.
    750  1.29    paulus 	 */
    751  1.29    paulus 	if (sc->sc_active_filt.bf_insns == 0
    752  1.29    paulus 	    || bpf_filter(sc->sc_active_filt.bf_insns, (u_char *) m0, len, 0))
    753  1.29    paulus 	    sc->sc_last_sent = time.tv_sec;
    754  1.29    paulus 
    755  1.29    paulus 	*mtod(m0, u_char *) = address;
    756  1.37  christos #else
    757  1.37  christos 	/*
    758  1.37  christos 	 * Update the time we sent the most recent packet.
    759  1.37  christos 	 */
    760  1.37  christos 	sc->sc_last_sent = time.tv_sec;
    761  1.37  christos #endif /* PPP_FILTER */
    762  1.29    paulus     }
    763  1.29    paulus 
    764   1.2    paulus #if NBPFILTER > 0
    765  1.22    paulus     /*
    766  1.22    paulus      * See if bpf wants to look at the packet.
    767  1.22    paulus      */
    768   1.2    paulus     if (sc->sc_bpf)
    769   1.2    paulus 	bpf_mtap(sc->sc_bpf, m0);
    770   1.2    paulus #endif
    771   1.2    paulus 
    772   1.2    paulus     /*
    773   1.2    paulus      * Put the packet on the appropriate queue.
    774   1.2    paulus      */
    775  1.22    paulus     s = splsoftnet();
    776  1.22    paulus     if (mode == NPMODE_QUEUE) {
    777  1.22    paulus 	/* XXX we should limit the number of packets on this queue */
    778  1.22    paulus 	*sc->sc_npqtail = m0;
    779  1.22    paulus 	m0->m_nextpkt = NULL;
    780  1.22    paulus 	sc->sc_npqtail = &m0->m_nextpkt;
    781  1.22    paulus     } else {
    782  1.22    paulus 	ifq = (m0->m_flags & M_HIGHPRI)? &sc->sc_fastq: &ifp->if_snd;
    783  1.29    paulus 	if (IF_QFULL(ifq) && dst->sa_family != AF_UNSPEC) {
    784  1.22    paulus 	    IF_DROP(ifq);
    785  1.22    paulus 	    splx(s);
    786  1.22    paulus 	    sc->sc_if.if_oerrors++;
    787  1.29    paulus 	    sc->sc_stats.ppp_oerrors++;
    788  1.22    paulus 	    error = ENOBUFS;
    789  1.22    paulus 	    goto bad;
    790  1.22    paulus 	}
    791  1.22    paulus 	IF_ENQUEUE(ifq, m0);
    792  1.22    paulus 	(*sc->sc_start)(sc);
    793   1.1   deraadt     }
    794  1.24   mycroft     ifp->if_lastchange = time;
    795  1.29    paulus     ifp->if_opackets++;
    796  1.29    paulus     ifp->if_obytes += len;
    797   1.8    paulus 
    798   1.1   deraadt     splx(s);
    799   1.1   deraadt     return (0);
    800   1.1   deraadt 
    801   1.1   deraadt bad:
    802   1.1   deraadt     m_freem(m0);
    803   1.1   deraadt     return (error);
    804   1.1   deraadt }
    805   1.1   deraadt 
    806   1.1   deraadt /*
    807  1.22    paulus  * After a change in the NPmode for some NP, move packets from the
    808  1.22    paulus  * npqueue to the send queue or the fast queue as appropriate.
    809  1.22    paulus  * Should be called at splsoftnet.
    810   1.8    paulus  */
    811  1.22    paulus static void
    812  1.22    paulus ppp_requeue(sc)
    813   1.8    paulus     struct ppp_softc *sc;
    814   1.8    paulus {
    815  1.22    paulus     struct mbuf *m, **mpp;
    816  1.22    paulus     struct ifqueue *ifq;
    817  1.22    paulus     enum NPmode mode;
    818   1.8    paulus 
    819  1.22    paulus     for (mpp = &sc->sc_npqueue; (m = *mpp) != NULL; ) {
    820  1.22    paulus 	switch (PPP_PROTOCOL(mtod(m, u_char *))) {
    821  1.22    paulus 	case PPP_IP:
    822  1.22    paulus 	    mode = sc->sc_npmode[NP_IP];
    823  1.22    paulus 	    break;
    824  1.22    paulus 	default:
    825  1.22    paulus 	    mode = NPMODE_PASS;
    826  1.22    paulus 	}
    827   1.8    paulus 
    828  1.22    paulus 	switch (mode) {
    829  1.22    paulus 	case NPMODE_PASS:
    830  1.22    paulus 	    /*
    831  1.22    paulus 	     * This packet can now go on one of the queues to be sent.
    832  1.22    paulus 	     */
    833  1.22    paulus 	    *mpp = m->m_nextpkt;
    834  1.22    paulus 	    m->m_nextpkt = NULL;
    835  1.22    paulus 	    ifq = (m->m_flags & M_HIGHPRI)? &sc->sc_fastq: &sc->sc_if.if_snd;
    836  1.22    paulus 	    if (IF_QFULL(ifq)) {
    837  1.22    paulus 		IF_DROP(ifq);
    838  1.22    paulus 		sc->sc_if.if_oerrors++;
    839  1.29    paulus 		sc->sc_stats.ppp_oerrors++;
    840  1.22    paulus 	    } else
    841  1.22    paulus 		IF_ENQUEUE(ifq, m);
    842  1.22    paulus 	    break;
    843   1.8    paulus 
    844  1.22    paulus 	case NPMODE_DROP:
    845  1.22    paulus 	case NPMODE_ERROR:
    846  1.22    paulus 	    *mpp = m->m_nextpkt;
    847  1.22    paulus 	    m_freem(m);
    848  1.22    paulus 	    break;
    849  1.22    paulus 
    850  1.22    paulus 	case NPMODE_QUEUE:
    851  1.22    paulus 	    mpp = &m->m_nextpkt;
    852  1.22    paulus 	    break;
    853  1.22    paulus 	}
    854  1.22    paulus     }
    855  1.22    paulus     sc->sc_npqtail = mpp;
    856  1.22    paulus }
    857  1.22    paulus 
    858  1.22    paulus /*
    859  1.37  christos  * Transmitter has finished outputting some stuff;
    860  1.37  christos  * remember to call sc->sc_start later at splsoftnet.
    861  1.22    paulus  */
    862  1.37  christos void
    863  1.37  christos ppp_restart(sc)
    864  1.22    paulus     struct ppp_softc *sc;
    865  1.22    paulus {
    866  1.36   mycroft     int s = splimp();
    867  1.22    paulus 
    868  1.22    paulus     sc->sc_flags &= ~SC_TBUSY;
    869  1.22    paulus     schednetisr(NETISR_PPP);
    870  1.22    paulus     splx(s);
    871  1.22    paulus }
    872  1.22    paulus 
    873  1.22    paulus /*
    874  1.37  christos  * Get a packet to send.  This procedure is intended to be called at
    875  1.37  christos  * splsoftnet, since it may involve time-consuming operations such as
    876  1.37  christos  * applying VJ compression, packet compression, address/control and/or
    877  1.37  christos  * protocol field compression to the packet.
    878  1.22    paulus  */
    879  1.37  christos struct mbuf *
    880  1.37  christos ppp_dequeue(sc)
    881  1.22    paulus     struct ppp_softc *sc;
    882  1.22    paulus {
    883  1.22    paulus     struct mbuf *m, *mp;
    884  1.22    paulus     u_char *cp;
    885  1.22    paulus     int address, control, protocol;
    886  1.22    paulus 
    887  1.22    paulus     /*
    888  1.22    paulus      * Grab a packet to send: first try the fast queue, then the
    889  1.22    paulus      * normal queue.
    890  1.22    paulus      */
    891  1.22    paulus     IF_DEQUEUE(&sc->sc_fastq, m);
    892  1.22    paulus     if (m == NULL)
    893  1.22    paulus 	IF_DEQUEUE(&sc->sc_if.if_snd, m);
    894  1.22    paulus     if (m == NULL)
    895  1.37  christos 	return NULL;
    896  1.22    paulus 
    897  1.29    paulus     ++sc->sc_stats.ppp_opackets;
    898  1.29    paulus 
    899  1.22    paulus     /*
    900  1.22    paulus      * Extract the ppp header of the new packet.
    901  1.22    paulus      * The ppp header will be in one mbuf.
    902  1.22    paulus      */
    903  1.22    paulus     cp = mtod(m, u_char *);
    904  1.22    paulus     address = PPP_ADDRESS(cp);
    905  1.22    paulus     control = PPP_CONTROL(cp);
    906  1.22    paulus     protocol = PPP_PROTOCOL(cp);
    907  1.22    paulus 
    908  1.22    paulus     switch (protocol) {
    909  1.22    paulus     case PPP_IP:
    910  1.22    paulus #ifdef VJC
    911  1.22    paulus 	/*
    912  1.22    paulus 	 * If the packet is a TCP/IP packet, see if we can compress it.
    913  1.22    paulus 	 */
    914  1.29    paulus 	if ((sc->sc_flags & SC_COMP_TCP) && sc->sc_comp != NULL) {
    915  1.22    paulus 	    struct ip *ip;
    916  1.22    paulus 	    int type;
    917  1.13    paulus 
    918  1.13    paulus 	    mp = m;
    919  1.13    paulus 	    ip = (struct ip *) (cp + PPP_HDRLEN);
    920  1.13    paulus 	    if (mp->m_len <= PPP_HDRLEN) {
    921  1.13    paulus 		mp = mp->m_next;
    922  1.13    paulus 		if (mp == NULL)
    923  1.13    paulus 		    break;
    924  1.13    paulus 		ip = mtod(mp, struct ip *);
    925  1.13    paulus 	    }
    926  1.13    paulus 	    /* this code assumes the IP/TCP header is in one non-shared mbuf */
    927  1.13    paulus 	    if (ip->ip_p == IPPROTO_TCP) {
    928  1.29    paulus 		type = sl_compress_tcp(mp, ip, sc->sc_comp,
    929  1.13    paulus 				       !(sc->sc_flags & SC_NO_TCP_CCID));
    930  1.13    paulus 		switch (type) {
    931  1.13    paulus 		case TYPE_UNCOMPRESSED_TCP:
    932  1.13    paulus 		    protocol = PPP_VJC_UNCOMP;
    933  1.13    paulus 		    break;
    934  1.13    paulus 		case TYPE_COMPRESSED_TCP:
    935  1.13    paulus 		    protocol = PPP_VJC_COMP;
    936  1.13    paulus 		    cp = mtod(m, u_char *);
    937  1.13    paulus 		    cp[0] = address;	/* header has moved */
    938  1.13    paulus 		    cp[1] = control;
    939  1.13    paulus 		    cp[2] = 0;
    940  1.13    paulus 		    break;
    941  1.13    paulus 		}
    942  1.13    paulus 		cp[3] = protocol;	/* update protocol in PPP header */
    943   1.8    paulus 	    }
    944   1.8    paulus 	}
    945   1.8    paulus #endif	/* VJC */
    946  1.22    paulus 	break;
    947  1.22    paulus 
    948  1.22    paulus #ifdef PPP_COMPRESS
    949  1.22    paulus     case PPP_CCP:
    950  1.22    paulus 	ppp_ccp(sc, m, 0);
    951  1.22    paulus 	break;
    952  1.22    paulus #endif	/* PPP_COMPRESS */
    953  1.22    paulus     }
    954  1.22    paulus 
    955  1.22    paulus #ifdef PPP_COMPRESS
    956  1.22    paulus     if (protocol != PPP_LCP && protocol != PPP_CCP
    957  1.22    paulus 	&& sc->sc_xc_state && (sc->sc_flags & SC_COMP_RUN)) {
    958  1.29    paulus 	struct mbuf *mcomp = NULL;
    959  1.22    paulus 	int slen, clen;
    960  1.22    paulus 
    961  1.22    paulus 	slen = 0;
    962  1.22    paulus 	for (mp = m; mp != NULL; mp = mp->m_next)
    963  1.22    paulus 	    slen += mp->m_len;
    964  1.22    paulus 	clen = (*sc->sc_xcomp->compress)
    965  1.37  christos 	    (sc->sc_xc_state, &mcomp, m, slen, sc->sc_if.if_mtu + PPP_HDRLEN);
    966  1.22    paulus 	if (mcomp != NULL) {
    967  1.37  christos 	    if (sc->sc_flags & SC_CCP_UP) {
    968  1.37  christos 		/* Send the compressed packet instead of the original. */
    969  1.37  christos 		m_freem(m);
    970  1.37  christos 		m = mcomp;
    971  1.37  christos 		cp = mtod(m, u_char *);
    972  1.37  christos 		protocol = cp[3];
    973  1.37  christos 	    } else {
    974  1.37  christos 		/* Can't transmit compressed packets until CCP is up. */
    975  1.37  christos 		m_freem(mcomp);
    976  1.37  christos 	    }
    977  1.22    paulus 	}
    978   1.8    paulus     }
    979  1.22    paulus #endif	/* PPP_COMPRESS */
    980   1.8    paulus 
    981   1.8    paulus     /*
    982   1.8    paulus      * Compress the address/control and protocol, if possible.
    983   1.8    paulus      */
    984   1.8    paulus     if (sc->sc_flags & SC_COMP_AC && address == PPP_ALLSTATIONS &&
    985   1.8    paulus 	control == PPP_UI && protocol != PPP_ALLSTATIONS &&
    986   1.8    paulus 	protocol != PPP_LCP) {
    987   1.8    paulus 	/* can compress address/control */
    988   1.8    paulus 	m->m_data += 2;
    989   1.8    paulus 	m->m_len -= 2;
    990   1.8    paulus     }
    991   1.8    paulus     if (sc->sc_flags & SC_COMP_PROT && protocol < 0xFF) {
    992   1.8    paulus 	/* can compress protocol */
    993   1.8    paulus 	if (mtod(m, u_char *) == cp) {
    994   1.8    paulus 	    cp[2] = cp[1];	/* move address/control up */
    995   1.8    paulus 	    cp[1] = cp[0];
    996   1.8    paulus 	}
    997   1.8    paulus 	++m->m_data;
    998   1.8    paulus 	--m->m_len;
    999   1.8    paulus     }
   1000   1.8    paulus 
   1001  1.37  christos     return m;
   1002  1.37  christos }
   1003  1.37  christos 
   1004  1.37  christos /*
   1005  1.37  christos  * Software interrupt routine, called at splsoftnet.
   1006  1.37  christos  */
   1007  1.37  christos void
   1008  1.37  christos pppintr()
   1009  1.37  christos {
   1010  1.37  christos     struct ppp_softc *sc;
   1011  1.37  christos     int i, s, s2;
   1012  1.37  christos     struct mbuf *m;
   1013  1.37  christos 
   1014  1.37  christos     sc = ppp_softc;
   1015  1.37  christos     s = splsoftnet();
   1016  1.37  christos     for (i = 0; i < NPPP; ++i, ++sc) {
   1017  1.37  christos 	if (!(sc->sc_flags & SC_TBUSY)
   1018  1.37  christos 	    && (sc->sc_if.if_snd.ifq_head || sc->sc_fastq.ifq_head)) {
   1019  1.37  christos 	    s2 = splimp();
   1020  1.37  christos 	    sc->sc_flags |= SC_TBUSY;
   1021  1.37  christos 	    splx(s2);
   1022  1.37  christos 	    (*sc->sc_start)(sc);
   1023  1.37  christos 	}
   1024  1.37  christos 	for (;;) {
   1025  1.37  christos 	    s2 = splimp();
   1026  1.37  christos 	    IF_DEQUEUE(&sc->sc_rawq, m);
   1027  1.37  christos 	    splx(s2);
   1028  1.37  christos 	    if (m == NULL)
   1029  1.37  christos 		break;
   1030  1.37  christos 	    ppp_inproc(sc, m);
   1031  1.37  christos 	}
   1032  1.37  christos     }
   1033  1.37  christos     splx(s);
   1034   1.8    paulus }
   1035   1.8    paulus 
   1036  1.22    paulus #ifdef PPP_COMPRESS
   1037   1.8    paulus /*
   1038  1.22    paulus  * Handle a CCP packet.  `rcvd' is 1 if the packet was received,
   1039  1.22    paulus  * 0 if it is about to be transmitted.
   1040   1.8    paulus  */
   1041  1.28  christos static void
   1042  1.22    paulus ppp_ccp(sc, m, rcvd)
   1043  1.22    paulus     struct ppp_softc *sc;
   1044  1.22    paulus     struct mbuf *m;
   1045  1.22    paulus     int rcvd;
   1046   1.8    paulus {
   1047  1.22    paulus     u_char *dp, *ep;
   1048  1.22    paulus     struct mbuf *mp;
   1049  1.22    paulus     int slen, s;
   1050   1.8    paulus 
   1051  1.22    paulus     /*
   1052  1.22    paulus      * Get a pointer to the data after the PPP header.
   1053  1.22    paulus      */
   1054  1.22    paulus     if (m->m_len <= PPP_HDRLEN) {
   1055  1.22    paulus 	mp = m->m_next;
   1056  1.22    paulus 	if (mp == NULL)
   1057  1.22    paulus 	    return;
   1058  1.22    paulus 	dp = (mp != NULL)? mtod(mp, u_char *): NULL;
   1059  1.22    paulus     } else {
   1060  1.22    paulus 	mp = m;
   1061  1.22    paulus 	dp = mtod(mp, u_char *) + PPP_HDRLEN;
   1062  1.22    paulus     }
   1063   1.8    paulus 
   1064  1.22    paulus     ep = mtod(mp, u_char *) + mp->m_len;
   1065  1.22    paulus     if (dp + CCP_HDRLEN > ep)
   1066   1.8    paulus 	return;
   1067  1.22    paulus     slen = CCP_LENGTH(dp);
   1068  1.22    paulus     if (dp + slen > ep) {
   1069  1.22    paulus 	if (sc->sc_flags & SC_DEBUG)
   1070  1.35  christos 	    printf("if_ppp/ccp: not enough data in mbuf (%p+%x > %p+%x)\n",
   1071  1.34  christos 		dp, slen, mtod(mp, u_char *), mp->m_len);
   1072   1.8    paulus 	return;
   1073   1.8    paulus     }
   1074   1.1   deraadt 
   1075  1.22    paulus     switch (CCP_CODE(dp)) {
   1076  1.22    paulus     case CCP_CONFREQ:
   1077  1.22    paulus     case CCP_TERMREQ:
   1078  1.22    paulus     case CCP_TERMACK:
   1079  1.22    paulus 	/* CCP must be going down - disable compression */
   1080  1.22    paulus 	if (sc->sc_flags & SC_CCP_UP) {
   1081  1.36   mycroft 	    s = splimp();
   1082  1.22    paulus 	    sc->sc_flags &= ~(SC_CCP_UP | SC_COMP_RUN | SC_DECOMP_RUN);
   1083  1.22    paulus 	    splx(s);
   1084   1.1   deraadt 	}
   1085  1.22    paulus 	break;
   1086   1.1   deraadt 
   1087  1.22    paulus     case CCP_CONFACK:
   1088  1.22    paulus 	if (sc->sc_flags & SC_CCP_OPEN && !(sc->sc_flags & SC_CCP_UP)
   1089  1.22    paulus 	    && slen >= CCP_HDRLEN + CCP_OPT_MINLEN
   1090  1.22    paulus 	    && slen >= CCP_OPT_LENGTH(dp + CCP_HDRLEN) + CCP_HDRLEN) {
   1091  1.22    paulus 	    if (!rcvd) {
   1092  1.22    paulus 		/* we're agreeing to send compressed packets. */
   1093  1.22    paulus 		if (sc->sc_xc_state != NULL
   1094  1.22    paulus 		    && (*sc->sc_xcomp->comp_init)
   1095  1.22    paulus 			(sc->sc_xc_state, dp + CCP_HDRLEN, slen - CCP_HDRLEN,
   1096  1.31   thorpej 			 sc->sc_unit, 0, sc->sc_flags & SC_DEBUG)) {
   1097  1.36   mycroft 		    s = splimp();
   1098  1.22    paulus 		    sc->sc_flags |= SC_COMP_RUN;
   1099  1.22    paulus 		    splx(s);
   1100  1.22    paulus 		}
   1101  1.22    paulus 	    } else {
   1102  1.22    paulus 		/* peer is agreeing to send compressed packets. */
   1103  1.22    paulus 		if (sc->sc_rc_state != NULL
   1104  1.22    paulus 		    && (*sc->sc_rcomp->decomp_init)
   1105  1.22    paulus 			(sc->sc_rc_state, dp + CCP_HDRLEN, slen - CCP_HDRLEN,
   1106  1.31   thorpej 			 sc->sc_unit, 0, sc->sc_mru,
   1107  1.22    paulus 			 sc->sc_flags & SC_DEBUG)) {
   1108  1.36   mycroft 		    s = splimp();
   1109  1.22    paulus 		    sc->sc_flags |= SC_DECOMP_RUN;
   1110  1.22    paulus 		    sc->sc_flags &= ~(SC_DC_ERROR | SC_DC_FERROR);
   1111  1.22    paulus 		    splx(s);
   1112  1.22    paulus 		}
   1113   1.1   deraadt 	    }
   1114   1.1   deraadt 	}
   1115  1.22    paulus 	break;
   1116   1.1   deraadt 
   1117  1.22    paulus     case CCP_RESETACK:
   1118  1.22    paulus 	if (sc->sc_flags & SC_CCP_UP) {
   1119  1.22    paulus 	    if (!rcvd) {
   1120  1.22    paulus 		if (sc->sc_xc_state && (sc->sc_flags & SC_COMP_RUN))
   1121  1.22    paulus 		    (*sc->sc_xcomp->comp_reset)(sc->sc_xc_state);
   1122  1.22    paulus 	    } else {
   1123  1.22    paulus 		if (sc->sc_rc_state && (sc->sc_flags & SC_DECOMP_RUN)) {
   1124  1.22    paulus 		    (*sc->sc_rcomp->decomp_reset)(sc->sc_rc_state);
   1125  1.36   mycroft 		    s = splimp();
   1126  1.22    paulus 		    sc->sc_flags &= ~SC_DC_ERROR;
   1127  1.22    paulus 		    splx(s);
   1128   1.1   deraadt 		}
   1129   1.1   deraadt 	    }
   1130   1.2    paulus 	}
   1131  1.22    paulus 	break;
   1132   1.1   deraadt     }
   1133   1.1   deraadt }
   1134   1.1   deraadt 
   1135   1.1   deraadt /*
   1136  1.22    paulus  * CCP is down; free (de)compressor state if necessary.
   1137   1.1   deraadt  */
   1138  1.22    paulus static void
   1139  1.22    paulus ppp_ccp_closed(sc)
   1140  1.22    paulus     struct ppp_softc *sc;
   1141   1.1   deraadt {
   1142  1.22    paulus     if (sc->sc_xc_state) {
   1143  1.22    paulus 	(*sc->sc_xcomp->comp_free)(sc->sc_xc_state);
   1144  1.22    paulus 	sc->sc_xc_state = NULL;
   1145  1.22    paulus     }
   1146  1.22    paulus     if (sc->sc_rc_state) {
   1147  1.22    paulus 	(*sc->sc_rcomp->decomp_free)(sc->sc_rc_state);
   1148  1.22    paulus 	sc->sc_rc_state = NULL;
   1149   1.1   deraadt     }
   1150   1.1   deraadt }
   1151  1.22    paulus #endif /* PPP_COMPRESS */
   1152   1.1   deraadt 
   1153   1.1   deraadt /*
   1154   1.8    paulus  * PPP packet input routine.
   1155  1.13    paulus  * The caller has checked and removed the FCS and has inserted
   1156  1.13    paulus  * the address/control bytes and the protocol high byte if they
   1157  1.22    paulus  * were omitted.
   1158  1.22    paulus  */
   1159  1.22    paulus void
   1160  1.22    paulus ppppktin(sc, m, lost)
   1161  1.22    paulus     struct ppp_softc *sc;
   1162  1.22    paulus     struct mbuf *m;
   1163  1.22    paulus     int lost;
   1164  1.22    paulus {
   1165  1.36   mycroft     int s = splimp();
   1166  1.22    paulus 
   1167  1.22    paulus     if (lost)
   1168  1.22    paulus 	m->m_flags |= M_ERRMARK;
   1169  1.22    paulus     IF_ENQUEUE(&sc->sc_rawq, m);
   1170  1.22    paulus     schednetisr(NETISR_PPP);
   1171  1.22    paulus     splx(s);
   1172  1.22    paulus }
   1173  1.22    paulus 
   1174  1.22    paulus /*
   1175  1.22    paulus  * Process a received PPP packet, doing decompression as necessary.
   1176  1.22    paulus  * Should be called at splsoftnet.
   1177   1.1   deraadt  */
   1178   1.1   deraadt #define COMPTYPE(proto)	((proto) == PPP_VJC_COMP? TYPE_COMPRESSED_TCP: \
   1179   1.1   deraadt 			 TYPE_UNCOMPRESSED_TCP)
   1180   1.1   deraadt 
   1181  1.22    paulus static void
   1182  1.22    paulus ppp_inproc(sc, m)
   1183   1.8    paulus     struct ppp_softc *sc;
   1184   1.8    paulus     struct mbuf *m;
   1185   1.8    paulus {
   1186  1.24   mycroft     struct ifnet *ifp = &sc->sc_if;
   1187   1.8    paulus     struct ifqueue *inq;
   1188  1.29    paulus     int s, ilen, xlen, proto, rv;
   1189  1.13    paulus     u_char *cp, adrs, ctrl;
   1190  1.29    paulus     struct mbuf *mp, *dmp = NULL;
   1191  1.22    paulus     u_char *iphdr;
   1192  1.22    paulus     u_int hlen;
   1193   1.8    paulus 
   1194  1.29    paulus     sc->sc_stats.ppp_ipackets++;
   1195  1.22    paulus 
   1196  1.22    paulus     if (sc->sc_flags & SC_LOG_INPKT) {
   1197  1.29    paulus 	ilen = 0;
   1198  1.27        pk 	for (mp = m; mp != NULL; mp = mp->m_next)
   1199  1.29    paulus 	    ilen += mp->m_len;
   1200  1.35  christos 	printf("%s: got %d bytes\n", ifp->if_xname, ilen);
   1201  1.22    paulus 	pppdumpm(m);
   1202  1.22    paulus     }
   1203   1.8    paulus 
   1204  1.13    paulus     cp = mtod(m, u_char *);
   1205  1.22    paulus     adrs = PPP_ADDRESS(cp);
   1206  1.22    paulus     ctrl = PPP_CONTROL(cp);
   1207  1.22    paulus     proto = PPP_PROTOCOL(cp);
   1208  1.22    paulus 
   1209  1.22    paulus     if (m->m_flags & M_ERRMARK) {
   1210  1.22    paulus 	m->m_flags &= ~M_ERRMARK;
   1211  1.36   mycroft 	s = splimp();
   1212  1.22    paulus 	sc->sc_flags |= SC_VJ_RESET;
   1213  1.22    paulus 	splx(s);
   1214  1.22    paulus     }
   1215  1.22    paulus 
   1216  1.22    paulus #ifdef PPP_COMPRESS
   1217  1.22    paulus     /*
   1218  1.22    paulus      * Decompress this packet if necessary, update the receiver's
   1219  1.22    paulus      * dictionary, or take appropriate action on a CCP packet.
   1220  1.22    paulus      */
   1221  1.22    paulus     if (proto == PPP_COMP && sc->sc_rc_state && (sc->sc_flags & SC_DECOMP_RUN)
   1222  1.22    paulus 	&& !(sc->sc_flags & SC_DC_ERROR) && !(sc->sc_flags & SC_DC_FERROR)) {
   1223  1.22    paulus 	/* decompress this packet */
   1224  1.22    paulus 	rv = (*sc->sc_rcomp->decompress)(sc->sc_rc_state, m, &dmp);
   1225  1.22    paulus 	if (rv == DECOMP_OK) {
   1226  1.22    paulus 	    m_freem(m);
   1227  1.22    paulus 	    if (dmp == NULL) {
   1228  1.22    paulus 		/* no error, but no decompressed packet produced */
   1229  1.22    paulus 		return;
   1230  1.22    paulus 	    }
   1231  1.22    paulus 	    m = dmp;
   1232  1.22    paulus 	    cp = mtod(m, u_char *);
   1233  1.22    paulus 	    proto = PPP_PROTOCOL(cp);
   1234  1.22    paulus 
   1235  1.22    paulus 	} else {
   1236  1.22    paulus 	    /*
   1237  1.22    paulus 	     * An error has occurred in decompression.
   1238  1.22    paulus 	     * Pass the compressed packet up to pppd, which may take
   1239  1.22    paulus 	     * CCP down or issue a Reset-Req.
   1240  1.22    paulus 	     */
   1241  1.22    paulus 	    if (sc->sc_flags & SC_DEBUG)
   1242  1.35  christos 		printf("%s: decompress failed %d\n", ifp->if_xname, rv);
   1243  1.36   mycroft 	    s = splimp();
   1244  1.22    paulus 	    sc->sc_flags |= SC_VJ_RESET;
   1245  1.22    paulus 	    if (rv == DECOMP_ERROR)
   1246  1.22    paulus 		sc->sc_flags |= SC_DC_ERROR;
   1247  1.22    paulus 	    else
   1248  1.22    paulus 		sc->sc_flags |= SC_DC_FERROR;
   1249  1.22    paulus 	    splx(s);
   1250  1.22    paulus 	}
   1251  1.22    paulus 
   1252  1.22    paulus     } else {
   1253  1.22    paulus 	if (sc->sc_rc_state && (sc->sc_flags & SC_DECOMP_RUN)) {
   1254  1.22    paulus 	    (*sc->sc_rcomp->incomp)(sc->sc_rc_state, m);
   1255  1.22    paulus 	}
   1256  1.22    paulus 	if (proto == PPP_CCP) {
   1257  1.22    paulus 	    ppp_ccp(sc, m, 1);
   1258  1.22    paulus 	}
   1259  1.22    paulus     }
   1260  1.22    paulus #endif
   1261  1.27        pk 
   1262  1.27        pk     ilen = 0;
   1263  1.27        pk     for (mp = m; mp != NULL; mp = mp->m_next)
   1264  1.27        pk 	ilen += mp->m_len;
   1265   1.8    paulus 
   1266   1.8    paulus #ifdef VJC
   1267  1.22    paulus     if (sc->sc_flags & SC_VJ_RESET) {
   1268  1.22    paulus 	/*
   1269  1.22    paulus 	 * If we've missed a packet, we must toss subsequent compressed
   1270  1.22    paulus 	 * packets which don't have an explicit connection ID.
   1271  1.22    paulus 	 */
   1272  1.29    paulus 	if (sc->sc_comp)
   1273  1.29    paulus 	    sl_uncompress_tcp(NULL, 0, TYPE_ERROR, sc->sc_comp);
   1274  1.36   mycroft 	s = splimp();
   1275  1.22    paulus 	sc->sc_flags &= ~SC_VJ_RESET;
   1276  1.22    paulus 	splx(s);
   1277  1.22    paulus     }
   1278  1.22    paulus 
   1279   1.8    paulus     /*
   1280   1.8    paulus      * See if we have a VJ-compressed packet to uncompress.
   1281   1.8    paulus      */
   1282  1.22    paulus     if (proto == PPP_VJC_COMP) {
   1283  1.29    paulus 	if ((sc->sc_flags & SC_REJ_COMP_TCP) || sc->sc_comp == 0)
   1284  1.22    paulus 	    goto bad;
   1285  1.22    paulus 
   1286  1.22    paulus 	xlen = sl_uncompress_tcp_core(cp + PPP_HDRLEN, m->m_len - PPP_HDRLEN,
   1287  1.22    paulus 				      ilen - PPP_HDRLEN, TYPE_COMPRESSED_TCP,
   1288  1.29    paulus 				      sc->sc_comp, &iphdr, &hlen);
   1289   1.8    paulus 
   1290  1.22    paulus 	if (xlen <= 0) {
   1291   1.8    paulus 	    if (sc->sc_flags & SC_DEBUG)
   1292  1.35  christos 		printf("%s: VJ uncompress failed on type comp\n",
   1293  1.34  christos 		    ifp->if_xname);
   1294  1.22    paulus 	    goto bad;
   1295  1.17    paulus 	}
   1296  1.17    paulus 
   1297  1.22    paulus 	/* Copy the PPP and IP headers into a new mbuf. */
   1298  1.22    paulus 	MGETHDR(mp, M_DONTWAIT, MT_DATA);
   1299  1.22    paulus 	if (mp == NULL)
   1300  1.22    paulus 	    goto bad;
   1301  1.22    paulus 	mp->m_len = 0;
   1302  1.22    paulus 	mp->m_next = NULL;
   1303  1.22    paulus 	if (hlen + PPP_HDRLEN > MHLEN) {
   1304  1.22    paulus 	    MCLGET(mp, M_DONTWAIT);
   1305  1.22    paulus 	    if (M_TRAILINGSPACE(mp) < hlen + PPP_HDRLEN) {
   1306  1.22    paulus 		m_freem(mp);
   1307  1.22    paulus 		goto bad;	/* lose if big headers and no clusters */
   1308  1.22    paulus 	    }
   1309   1.8    paulus 	}
   1310  1.22    paulus 	cp = mtod(mp, u_char *);
   1311  1.22    paulus 	cp[0] = adrs;
   1312  1.22    paulus 	cp[1] = ctrl;
   1313  1.22    paulus 	cp[2] = 0;
   1314  1.22    paulus 	cp[3] = PPP_IP;
   1315  1.22    paulus 	proto = PPP_IP;
   1316  1.22    paulus 	bcopy(iphdr, cp + PPP_HDRLEN, hlen);
   1317  1.22    paulus 	mp->m_len = hlen + PPP_HDRLEN;
   1318  1.22    paulus 
   1319  1.22    paulus 	/*
   1320  1.22    paulus 	 * Trim the PPP and VJ headers off the old mbuf
   1321  1.22    paulus 	 * and stick the new and old mbufs together.
   1322  1.22    paulus 	 */
   1323  1.22    paulus 	m->m_data += PPP_HDRLEN + xlen;
   1324  1.22    paulus 	m->m_len -= PPP_HDRLEN + xlen;
   1325  1.22    paulus 	if (m->m_len <= M_TRAILINGSPACE(mp)) {
   1326  1.22    paulus 	    bcopy(mtod(m, u_char *), mtod(mp, u_char *) + mp->m_len, m->m_len);
   1327  1.22    paulus 	    mp->m_len += m->m_len;
   1328  1.22    paulus 	    MFREE(m, mp->m_next);
   1329  1.22    paulus 	} else
   1330  1.22    paulus 	    mp->m_next = m;
   1331  1.22    paulus 	m = mp;
   1332  1.22    paulus 	ilen += hlen - xlen;
   1333   1.8    paulus 
   1334  1.22    paulus     } else if (proto == PPP_VJC_UNCOMP) {
   1335  1.29    paulus 	if ((sc->sc_flags & SC_REJ_COMP_TCP) || sc->sc_comp == 0)
   1336  1.22    paulus 	    goto bad;
   1337  1.22    paulus 
   1338  1.22    paulus 	xlen = sl_uncompress_tcp_core(cp + PPP_HDRLEN, m->m_len - PPP_HDRLEN,
   1339  1.22    paulus 				      ilen - PPP_HDRLEN, TYPE_UNCOMPRESSED_TCP,
   1340  1.29    paulus 				      sc->sc_comp, &iphdr, &hlen);
   1341   1.8    paulus 
   1342  1.22    paulus 	if (xlen < 0) {
   1343   1.8    paulus 	    if (sc->sc_flags & SC_DEBUG)
   1344  1.35  christos 		printf("%s: VJ uncompress failed on type uncomp\n",
   1345  1.34  christos 		    ifp->if_xname);
   1346  1.22    paulus 	    goto bad;
   1347   1.8    paulus 	}
   1348   1.8    paulus 
   1349   1.8    paulus 	proto = PPP_IP;
   1350  1.13    paulus 	cp[3] = PPP_IP;
   1351   1.8    paulus     }
   1352   1.8    paulus #endif /* VJC */
   1353   1.8    paulus 
   1354  1.13    paulus     /*
   1355  1.13    paulus      * If the packet will fit in a header mbuf, don't waste a
   1356  1.13    paulus      * whole cluster on it.
   1357  1.13    paulus      */
   1358  1.22    paulus     if (ilen <= MHLEN && M_IS_CLUSTER(m)) {
   1359  1.13    paulus 	MGETHDR(mp, M_DONTWAIT, MT_DATA);
   1360  1.13    paulus 	if (mp != NULL) {
   1361  1.13    paulus 	    m_copydata(m, 0, ilen, mtod(mp, caddr_t));
   1362  1.13    paulus 	    m_freem(m);
   1363  1.13    paulus 	    m = mp;
   1364  1.13    paulus 	    m->m_len = ilen;
   1365  1.13    paulus 	}
   1366   1.8    paulus     }
   1367   1.8    paulus     m->m_pkthdr.len = ilen;
   1368  1.24   mycroft     m->m_pkthdr.rcvif = ifp;
   1369   1.8    paulus 
   1370  1.29    paulus     if ((proto & 0x8000) == 0) {
   1371  1.37  christos #ifdef PPP_FILTER
   1372  1.37  christos 	/*
   1373  1.37  christos 	 * See whether we want to pass this packet, and
   1374  1.37  christos 	 * if it counts as link activity.
   1375  1.37  christos 	 */
   1376  1.29    paulus 	adrs = *mtod(m, u_char *);	/* save address field */
   1377  1.29    paulus 	*mtod(m, u_char *) = 0;		/* indicate inbound */
   1378  1.29    paulus 	if (sc->sc_pass_filt.bf_insns != 0
   1379  1.29    paulus 	    && bpf_filter(sc->sc_pass_filt.bf_insns, (u_char *) m,
   1380  1.29    paulus 			  ilen, 0) == 0) {
   1381  1.29    paulus 	    /* drop this packet */
   1382  1.29    paulus 	    m_freem(m);
   1383  1.29    paulus 	    return;
   1384  1.29    paulus 	}
   1385  1.29    paulus 	if (sc->sc_active_filt.bf_insns == 0
   1386  1.29    paulus 	    || bpf_filter(sc->sc_active_filt.bf_insns, (u_char *) m, ilen, 0))
   1387  1.29    paulus 	    sc->sc_last_recv = time.tv_sec;
   1388  1.29    paulus 
   1389  1.29    paulus 	*mtod(m, u_char *) = adrs;
   1390  1.37  christos #else
   1391  1.37  christos 	/*
   1392  1.37  christos 	 * Record the time that we received this packet.
   1393  1.37  christos 	 */
   1394  1.37  christos 	sc->sc_last_recv = time.tv_sec;
   1395  1.37  christos #endif /* PPP_FILTER */
   1396  1.29    paulus     }
   1397  1.29    paulus 
   1398   1.8    paulus #if NBPFILTER > 0
   1399   1.8    paulus     /* See if bpf wants to look at the packet. */
   1400   1.8    paulus     if (sc->sc_bpf)
   1401   1.8    paulus 	bpf_mtap(sc->sc_bpf, m);
   1402   1.8    paulus #endif
   1403   1.8    paulus 
   1404  1.22    paulus     rv = 0;
   1405   1.8    paulus     switch (proto) {
   1406   1.8    paulus #ifdef INET
   1407   1.8    paulus     case PPP_IP:
   1408   1.8    paulus 	/*
   1409   1.8    paulus 	 * IP packet - take off the ppp header and pass it up to IP.
   1410   1.8    paulus 	 */
   1411  1.24   mycroft 	if ((ifp->if_flags & IFF_UP) == 0
   1412  1.22    paulus 	    || sc->sc_npmode[NP_IP] != NPMODE_PASS) {
   1413   1.8    paulus 	    /* interface is down - drop the packet. */
   1414   1.8    paulus 	    m_freem(m);
   1415  1.22    paulus 	    return;
   1416   1.8    paulus 	}
   1417   1.8    paulus 	m->m_pkthdr.len -= PPP_HDRLEN;
   1418   1.8    paulus 	m->m_data += PPP_HDRLEN;
   1419   1.8    paulus 	m->m_len -= PPP_HDRLEN;
   1420   1.8    paulus 	schednetisr(NETISR_IP);
   1421   1.8    paulus 	inq = &ipintrq;
   1422   1.8    paulus 	break;
   1423   1.8    paulus #endif
   1424   1.8    paulus 
   1425   1.8    paulus     default:
   1426   1.8    paulus 	/*
   1427   1.8    paulus 	 * Some other protocol - place on input queue for read().
   1428   1.8    paulus 	 */
   1429   1.8    paulus 	inq = &sc->sc_inq;
   1430   1.8    paulus 	rv = 1;
   1431   1.8    paulus 	break;
   1432   1.8    paulus     }
   1433   1.8    paulus 
   1434   1.8    paulus     /*
   1435   1.8    paulus      * Put the packet on the appropriate input queue.
   1436   1.8    paulus      */
   1437  1.36   mycroft     s = splimp();
   1438   1.8    paulus     if (IF_QFULL(inq)) {
   1439   1.8    paulus 	IF_DROP(inq);
   1440  1.22    paulus 	splx(s);
   1441   1.8    paulus 	if (sc->sc_flags & SC_DEBUG)
   1442  1.35  christos 	    printf("%s: input queue full\n", ifp->if_xname);
   1443  1.24   mycroft 	ifp->if_iqdrops++;
   1444  1.22    paulus 	goto bad;
   1445  1.22    paulus     }
   1446  1.22    paulus     IF_ENQUEUE(inq, m);
   1447   1.8    paulus     splx(s);
   1448  1.29    paulus     ifp->if_ipackets++;
   1449  1.29    paulus     ifp->if_ibytes += ilen;
   1450  1.29    paulus     ifp->if_lastchange = time;
   1451   1.1   deraadt 
   1452  1.22    paulus     if (rv)
   1453  1.22    paulus 	(*sc->sc_ctlp)(sc);
   1454   1.1   deraadt 
   1455   1.1   deraadt     return;
   1456   1.1   deraadt 
   1457  1.22    paulus  bad:
   1458  1.22    paulus     m_freem(m);
   1459  1.22    paulus     sc->sc_if.if_ierrors++;
   1460  1.29    paulus     sc->sc_stats.ppp_ierrors++;
   1461   1.1   deraadt }
   1462   1.1   deraadt 
   1463   1.1   deraadt #define MAX_DUMP_BYTES	128
   1464   1.1   deraadt 
   1465   1.1   deraadt static void
   1466  1.22    paulus pppdumpm(m0)
   1467   1.1   deraadt     struct mbuf *m0;
   1468   1.1   deraadt {
   1469   1.8    paulus     char buf[3*MAX_DUMP_BYTES+4];
   1470   1.1   deraadt     char *bp = buf;
   1471   1.1   deraadt     struct mbuf *m;
   1472   1.1   deraadt     static char digits[] = "0123456789abcdef";
   1473   1.1   deraadt 
   1474  1.22    paulus     for (m = m0; m; m = m->m_next) {
   1475   1.1   deraadt 	int l = m->m_len;
   1476   1.1   deraadt 	u_char *rptr = (u_char *)m->m_data;
   1477   1.1   deraadt 
   1478   1.1   deraadt 	while (l--) {
   1479   1.1   deraadt 	    if (bp > buf + sizeof(buf) - 4)
   1480   1.1   deraadt 		goto done;
   1481   1.1   deraadt 	    *bp++ = digits[*rptr >> 4]; /* convert byte to ascii hex */
   1482   1.1   deraadt 	    *bp++ = digits[*rptr++ & 0xf];
   1483   1.1   deraadt 	}
   1484   1.1   deraadt 
   1485   1.1   deraadt 	if (m->m_next) {
   1486   1.1   deraadt 	    if (bp > buf + sizeof(buf) - 3)
   1487   1.1   deraadt 		goto done;
   1488   1.1   deraadt 	    *bp++ = '|';
   1489   1.8    paulus 	} else
   1490   1.8    paulus 	    *bp++ = ' ';
   1491   1.1   deraadt     }
   1492   1.1   deraadt done:
   1493  1.22    paulus     if (m)
   1494   1.1   deraadt 	*bp++ = '>';
   1495   1.1   deraadt     *bp = 0;
   1496  1.35  christos     printf("%s\n", buf);
   1497   1.1   deraadt }
   1498   1.1   deraadt 
   1499   1.1   deraadt #endif	/* NPPP > 0 */
   1500