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