Home | History | Annotate | Line # | Download | only in net
if_ppp.c revision 1.93
      1  1.93        he /*	$NetBSD: if_ppp.c,v 1.93 2004/12/05 13:32:03 he 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.78    itojun  * Copyright (c) 1984-2000 Carnegie Mellon University. All rights reserved.
      8   1.1   deraadt  *
      9  1.78    itojun  * Redistribution and use in source and binary forms, with or without
     10  1.78    itojun  * modification, are permitted provided that the following conditions
     11  1.78    itojun  * are met:
     12  1.78    itojun  *
     13  1.78    itojun  * 1. Redistributions of source code must retain the above copyright
     14  1.78    itojun  *    notice, this list of conditions and the following disclaimer.
     15  1.78    itojun  *
     16  1.78    itojun  * 2. Redistributions in binary form must reproduce the above copyright
     17  1.78    itojun  *    notice, this list of conditions and the following disclaimer in
     18  1.78    itojun  *    the documentation and/or other materials provided with the
     19  1.78    itojun  *    distribution.
     20  1.78    itojun  *
     21  1.78    itojun  * 3. The name "Carnegie Mellon University" must not be used to
     22  1.78    itojun  *    endorse or promote products derived from this software without
     23  1.78    itojun  *    prior written permission. For permission or any legal
     24  1.78    itojun  *    details, please contact
     25  1.78    itojun  *      Office of Technology Transfer
     26  1.78    itojun  *      Carnegie Mellon University
     27  1.78    itojun  *      5000 Forbes Avenue
     28  1.78    itojun  *      Pittsburgh, PA  15213-3890
     29  1.78    itojun  *      (412) 268-4387, fax: (412) 268-7395
     30  1.78    itojun  *      tech-transfer (at) andrew.cmu.edu
     31  1.78    itojun  *
     32  1.78    itojun  * 4. Redistributions of any form whatsoever must retain the following
     33  1.78    itojun  *    acknowledgment:
     34  1.78    itojun  *    "This product includes software developed by Computing Services
     35  1.78    itojun  *     at Carnegie Mellon University (http://www.cmu.edu/computing/)."
     36  1.78    itojun  *
     37  1.78    itojun  * CARNEGIE MELLON UNIVERSITY DISCLAIMS ALL WARRANTIES WITH REGARD TO
     38  1.78    itojun  * THIS SOFTWARE, INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY
     39  1.78    itojun  * AND FITNESS, IN NO EVENT SHALL CARNEGIE MELLON UNIVERSITY BE LIABLE
     40  1.78    itojun  * FOR ANY SPECIAL, INDIRECT OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
     41  1.78    itojun  * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN
     42  1.78    itojun  * AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING
     43  1.78    itojun  * OUT OF OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
     44   1.1   deraadt  *
     45   1.1   deraadt  * Based on:
     46   1.1   deraadt  *	@(#)if_sl.c	7.6.1.2 (Berkeley) 2/15/89
     47   1.1   deraadt  *
     48   1.1   deraadt  * Copyright (c) 1987 Regents of the University of California.
     49   1.1   deraadt  * All rights reserved.
     50   1.1   deraadt  *
     51   1.1   deraadt  * Redistribution and use in source and binary forms are permitted
     52   1.1   deraadt  * provided that the above copyright notice and this paragraph are
     53   1.1   deraadt  * duplicated in all such forms and that any documentation,
     54   1.1   deraadt  * advertising materials, and other materials related to such
     55   1.1   deraadt  * distribution and use acknowledge that the software was developed
     56   1.1   deraadt  * by the University of California, Berkeley.  The name of the
     57   1.1   deraadt  * University may not be used to endorse or promote products derived
     58   1.1   deraadt  * from this software without specific prior written permission.
     59   1.1   deraadt  * THIS SOFTWARE IS PROVIDED ``AS IS'' AND WITHOUT ANY EXPRESS OR
     60   1.1   deraadt  * IMPLIED WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED
     61   1.1   deraadt  * WARRANTIES OF MERCHANTIBILITY AND FITNESS FOR A PARTICULAR PURPOSE.
     62   1.1   deraadt  *
     63   1.1   deraadt  * Serial Line interface
     64   1.1   deraadt  *
     65   1.1   deraadt  * Rick Adams
     66   1.1   deraadt  * Center for Seismic Studies
     67   1.1   deraadt  * 1300 N 17th Street, Suite 1450
     68   1.1   deraadt  * Arlington, Virginia 22209
     69   1.1   deraadt  * (703)276-7900
     70   1.1   deraadt  * rick (at) seismo.ARPA
     71   1.1   deraadt  * seismo!rick
     72   1.1   deraadt  *
     73   1.1   deraadt  * Pounded on heavily by Chris Torek (chris (at) mimsy.umd.edu, umcp-cs!chris).
     74   1.1   deraadt  * Converted to 4.3BSD Beta by Chris Torek.
     75   1.1   deraadt  * Other changes made at Berkeley, based in part on code by Kirk Smith.
     76   1.1   deraadt  *
     77   1.1   deraadt  * Converted to 4.3BSD+ 386BSD by Brad Parker (brad (at) cayman.com)
     78   1.1   deraadt  * Added VJ tcp header compression; more unified ioctls
     79   1.1   deraadt  *
     80   1.1   deraadt  * Extensively modified by Paul Mackerras (paulus (at) cs.anu.edu.au).
     81   1.1   deraadt  * Cleaned up a lot of the mbuf-related code to fix bugs that
     82   1.1   deraadt  * caused system crashes and packet corruption.  Changed pppstart
     83   1.1   deraadt  * so that it doesn't just give up with a collision if the whole
     84   1.1   deraadt  * packet doesn't fit in the output ring buffer.
     85   1.1   deraadt  *
     86   1.2    paulus  * Added priority queueing for interactive IP packets, following
     87   1.2    paulus  * the model of if_sl.c, plus hooks for bpf.
     88   1.2    paulus  * Paul Mackerras (paulus (at) cs.anu.edu.au).
     89   1.1   deraadt  */
     90   1.1   deraadt 
     91   1.2    paulus /* from if_sl.c,v 1.11 84/10/04 12:54:47 rick Exp */
     92  1.22    paulus /* from NetBSD: if_ppp.c,v 1.15.2.2 1994/07/28 05:17:58 cgd Exp */
     93   1.2    paulus 
     94  1.68   thorpej /*
     95  1.68   thorpej  * XXX IMP ME HARDER
     96  1.68   thorpej  *
     97  1.68   thorpej  * This is an explanation of that comment.  This code used to use
     98  1.68   thorpej  * splimp() to block both network and tty interrupts.  However,
     99  1.68   thorpej  * that call is deprecated.  So, we have replaced the uses of
    100  1.68   thorpej  * splimp() with splhigh() in order to applomplish what it needs
    101  1.68   thorpej  * to accomplish, and added that happy little comment.
    102  1.68   thorpej  */
    103  1.72     lukem 
    104  1.72     lukem #include <sys/cdefs.h>
    105  1.93        he __KERNEL_RCSID(0, "$NetBSD: if_ppp.c,v 1.93 2004/12/05 13:32:03 he Exp $");
    106  1.68   thorpej 
    107   1.1   deraadt #include "ppp.h"
    108  1.60    itojun 
    109  1.61      onoe #include "opt_inet.h"
    110  1.61      onoe #include "opt_gateway.h"
    111  1.61      onoe #include "opt_ppp.h"
    112  1.61      onoe 
    113  1.59    itojun #ifdef INET
    114   1.1   deraadt #define VJC
    115  1.59    itojun #endif
    116  1.22    paulus #define PPP_COMPRESS
    117   1.1   deraadt 
    118   1.5   mycroft #include <sys/param.h>
    119   1.5   mycroft #include <sys/proc.h>
    120   1.5   mycroft #include <sys/mbuf.h>
    121   1.5   mycroft #include <sys/socket.h>
    122   1.5   mycroft #include <sys/ioctl.h>
    123   1.5   mycroft #include <sys/kernel.h>
    124  1.28  christos #include <sys/systm.h>
    125  1.29    paulus #include <sys/time.h>
    126  1.29    paulus #include <sys/malloc.h>
    127  1.22    paulus 
    128   1.5   mycroft #include <net/if.h>
    129   1.5   mycroft #include <net/if_types.h>
    130   1.5   mycroft #include <net/netisr.h>
    131   1.5   mycroft #include <net/route.h>
    132  1.37  christos #ifdef PPP_FILTER
    133  1.29    paulus #include <net/bpf.h>
    134  1.37  christos #endif
    135   1.5   mycroft 
    136  1.66   thorpej #include <machine/intr.h>
    137  1.66   thorpej 
    138   1.5   mycroft #include <netinet/in.h>
    139   1.5   mycroft #include <netinet/in_systm.h>
    140   1.5   mycroft #include <netinet/in_var.h>
    141  1.59    itojun #ifdef INET
    142   1.5   mycroft #include <netinet/ip.h>
    143   1.1   deraadt #endif
    144   1.1   deraadt 
    145   1.2    paulus #include "bpfilter.h"
    146   1.2    paulus #if NBPFILTER > 0
    147   1.5   mycroft #include <sys/time.h>
    148   1.5   mycroft #include <net/bpf.h>
    149   1.2    paulus #endif
    150   1.2    paulus 
    151  1.47  christos #if defined(PPP_FILTER) || NBPFILTER > 0
    152  1.47  christos #include <net/slip.h>
    153  1.47  christos #endif
    154  1.47  christos 
    155   1.1   deraadt #ifdef VJC
    156   1.8    paulus #include <net/slcompress.h>
    157   1.1   deraadt #endif
    158   1.1   deraadt 
    159  1.22    paulus #include <net/ppp_defs.h>
    160   1.8    paulus #include <net/if_ppp.h>
    161  1.22    paulus #include <net/if_pppvar.h>
    162   1.6       cgd #include <machine/cpu.h>
    163   1.1   deraadt 
    164  1.22    paulus #ifdef PPP_COMPRESS
    165  1.22    paulus #define PACKETPTR	struct mbuf *
    166  1.22    paulus #include <net/ppp-comp.h>
    167  1.22    paulus #endif
    168   1.1   deraadt 
    169  1.37  christos static int	pppsioctl __P((struct ifnet *, u_long, caddr_t));
    170  1.22    paulus static void	ppp_requeue __P((struct ppp_softc *));
    171  1.28  christos static void	ppp_ccp __P((struct ppp_softc *, struct mbuf *m, int rcvd));
    172  1.22    paulus static void	ppp_ccp_closed __P((struct ppp_softc *));
    173  1.22    paulus static void	ppp_inproc __P((struct ppp_softc *, struct mbuf *));
    174  1.22    paulus static void	pppdumpm __P((struct mbuf *m0));
    175  1.75    itojun #ifdef ALTQ
    176  1.75    itojun static void	ppp_ifstart __P((struct ifnet *ifp));
    177  1.75    itojun #endif
    178   1.1   deraadt 
    179  1.66   thorpej #ifndef __HAVE_GENERIC_SOFT_INTERRUPTS
    180  1.66   thorpej void		pppnetisr(void);
    181  1.66   thorpej #endif
    182  1.66   thorpej void		pppintr(void *);
    183  1.66   thorpej 
    184   1.1   deraadt /*
    185   1.1   deraadt  * Some useful mbuf macros not in mbuf.h.
    186   1.1   deraadt  */
    187  1.22    paulus #define M_IS_CLUSTER(m)	((m)->m_flags & M_EXT)
    188  1.22    paulus 
    189   1.1   deraadt #define M_DATASTART(m)	\
    190  1.22    paulus 	(M_IS_CLUSTER(m) ? (m)->m_ext.ext_buf : \
    191   1.1   deraadt 	    (m)->m_flags & M_PKTHDR ? (m)->m_pktdat : (m)->m_dat)
    192   1.1   deraadt 
    193   1.1   deraadt #define M_DATASIZE(m)	\
    194  1.22    paulus 	(M_IS_CLUSTER(m) ? (m)->m_ext.ext_size : \
    195   1.1   deraadt 	    (m)->m_flags & M_PKTHDR ? MHLEN: MLEN)
    196   1.1   deraadt 
    197   1.1   deraadt /*
    198  1.50   thorpej  * We define two link layer specific mbuf flags, to mark high-priority
    199  1.50   thorpej  * packets for output, and received packets following lost/corrupted
    200  1.50   thorpej  * packets.
    201   1.2    paulus  */
    202  1.50   thorpej #define	M_HIGHPRI	M_LINK0	/* output packet for sc_fastq */
    203  1.50   thorpej #define	M_ERRMARK	M_LINK1	/* rx packet following lost/corrupted pkt */
    204  1.77      matt 
    205  1.91  christos static int		ppp_clone_create(struct if_clone *, int);
    206  1.91  christos static int		ppp_clone_destroy(struct ifnet *);
    207  1.91  christos 
    208  1.91  christos static struct ppp_softc *ppp_create(const char *, int);
    209  1.91  christos 
    210  1.91  christos static LIST_HEAD(, ppp_softc) ppp_softc_list;
    211  1.91  christos 
    212  1.91  christos struct if_clone ppp_cloner =
    213  1.91  christos     IF_CLONE_INITIALIZER("ppp", ppp_clone_create, ppp_clone_destroy);
    214  1.91  christos 
    215  1.91  christos static struct simplelock ppp_list_mutex = SIMPLELOCK_INITIALIZER;
    216   1.2    paulus 
    217  1.22    paulus #ifdef PPP_COMPRESS
    218   1.2    paulus /*
    219  1.22    paulus  * List of compressors we know about.
    220  1.22    paulus  * We leave some space so maybe we can modload compressors.
    221   1.2    paulus  */
    222  1.22    paulus 
    223  1.22    paulus extern struct compressor ppp_bsd_compress;
    224  1.41  christos extern struct compressor ppp_deflate, ppp_deflate_draft;
    225  1.22    paulus 
    226  1.83  christos struct compressor *ppp_compressors[PPP_COMPRESSORS_MAX] = {
    227  1.30    paulus #if DO_BSD_COMPRESS && defined(PPP_BSDCOMP)
    228  1.22    paulus     &ppp_bsd_compress,
    229  1.22    paulus #endif
    230  1.30    paulus #if DO_DEFLATE && defined(PPP_DEFLATE)
    231  1.29    paulus     &ppp_deflate,
    232  1.41  christos     &ppp_deflate_draft,
    233  1.29    paulus #endif
    234  1.22    paulus     NULL
    235  1.22    paulus };
    236  1.22    paulus #endif /* PPP_COMPRESS */
    237   1.2    paulus 
    238  1.37  christos 
    239   1.2    paulus /*
    240   1.1   deraadt  * Called from boot code to establish ppp interfaces.
    241   1.1   deraadt  */
    242   1.1   deraadt void
    243  1.92  christos pppattach(void)
    244   1.1   deraadt {
    245  1.91  christos     LIST_INIT(&ppp_softc_list);
    246  1.91  christos     if_clone_attach(&ppp_cloner);
    247  1.91  christos }
    248  1.91  christos 
    249  1.91  christos static struct ppp_softc *
    250  1.91  christos ppp_create(const char *name, int unit)
    251  1.91  christos {
    252  1.91  christos     struct ppp_softc *sc, *sci, *scl = NULL;
    253  1.91  christos 
    254  1.91  christos     MALLOC(sc, struct ppp_softc *, sizeof(*sc), M_DEVBUF, M_WAIT|M_ZERO);
    255  1.91  christos 
    256  1.91  christos     simple_lock(&ppp_list_mutex);
    257  1.91  christos     if (unit == -1) {
    258  1.91  christos 	int i = 0;
    259  1.91  christos 	LIST_FOREACH(sci, &ppp_softc_list, sc_iflist) {
    260  1.91  christos 	    scl = sci;
    261  1.91  christos 	    if (i < sci->sc_unit) {
    262  1.91  christos 		unit = i;
    263  1.91  christos 		break;
    264  1.91  christos 	    } else {
    265  1.91  christos #ifdef DIAGNOSTIC
    266  1.91  christos 		KASSERT(i == sci->sc_unit);
    267  1.91  christos #endif
    268  1.91  christos 		i++;
    269  1.91  christos 	    }
    270  1.91  christos 	}
    271  1.91  christos 	if (unit == -1)
    272  1.91  christos 	    unit = i;
    273  1.91  christos     } else {
    274  1.91  christos 	LIST_FOREACH(sci, &ppp_softc_list, sc_iflist) {
    275  1.91  christos 	    scl = sci;
    276  1.91  christos 	    if (unit < sci->sc_unit)
    277  1.91  christos 		break;
    278  1.91  christos 	    else if (unit == sci->sc_unit) {
    279  1.91  christos 		FREE(sc, M_DEVBUF);
    280  1.91  christos 		return NULL;
    281  1.91  christos 	    }
    282  1.91  christos 	}
    283  1.91  christos     }
    284   1.1   deraadt 
    285  1.91  christos     if (sci != NULL)
    286  1.91  christos 	LIST_INSERT_BEFORE(sci, sc, sc_iflist);
    287  1.91  christos     else if (scl != NULL)
    288  1.91  christos 	LIST_INSERT_AFTER(scl, sc, sc_iflist);
    289  1.91  christos     else
    290  1.91  christos 	LIST_INSERT_HEAD(&ppp_softc_list, sc, sc_iflist);
    291  1.91  christos 
    292  1.91  christos     simple_unlock(&ppp_list_mutex);
    293  1.91  christos 
    294  1.91  christos     (void)snprintf(sc->sc_if.if_xname, sizeof(sc->sc_if.if_xname), "%s%d",
    295  1.91  christos 	name, sc->sc_unit = unit);
    296  1.91  christos     callout_init(&sc->sc_timo_ch);
    297  1.91  christos     sc->sc_if.if_softc = sc;
    298  1.91  christos     sc->sc_if.if_mtu = PPP_MTU;
    299  1.91  christos     sc->sc_if.if_flags = IFF_POINTOPOINT | IFF_MULTICAST;
    300  1.91  christos     sc->sc_if.if_type = IFT_PPP;
    301  1.91  christos     sc->sc_if.if_hdrlen = PPP_HDRLEN;
    302  1.91  christos     sc->sc_if.if_dlt = DLT_NULL;
    303  1.91  christos     sc->sc_if.if_ioctl = pppsioctl;
    304  1.91  christos     sc->sc_if.if_output = pppoutput;
    305  1.75    itojun #ifdef ALTQ
    306  1.91  christos     sc->sc_if.if_start = ppp_ifstart;
    307  1.75    itojun #endif
    308  1.91  christos     IFQ_SET_MAXLEN(&sc->sc_if.if_snd, IFQ_MAXLEN);
    309  1.91  christos     sc->sc_inq.ifq_maxlen = IFQ_MAXLEN;
    310  1.91  christos     sc->sc_fastq.ifq_maxlen = IFQ_MAXLEN;
    311  1.91  christos     sc->sc_rawq.ifq_maxlen = IFQ_MAXLEN;
    312  1.91  christos     IFQ_SET_READY(&sc->sc_if.if_snd);
    313  1.91  christos     if_attach(&sc->sc_if);
    314  1.91  christos     if_alloc_sadl(&sc->sc_if);
    315   1.2    paulus #if NBPFILTER > 0
    316  1.91  christos     bpfattach(&sc->sc_if, DLT_NULL, 0);
    317   1.2    paulus #endif
    318  1.91  christos     return sc;
    319  1.91  christos }
    320  1.91  christos 
    321  1.91  christos static int
    322  1.91  christos ppp_clone_create(struct if_clone *ifc, int unit)
    323  1.91  christos {
    324  1.91  christos     return ppp_create(ifc->ifc_name, unit) == NULL ? EEXIST : 0;
    325  1.91  christos }
    326  1.91  christos 
    327  1.91  christos static int
    328  1.91  christos ppp_clone_destroy(struct ifnet *ifp)
    329  1.91  christos {
    330  1.91  christos     struct ppp_softc *sc = (struct ppp_softc *)ifp->if_softc;
    331  1.91  christos 
    332  1.91  christos     if (sc->sc_devp != NULL)
    333  1.91  christos 	return EBUSY; /* Not removing it */
    334  1.91  christos 
    335  1.91  christos     simple_lock(&ppp_list_mutex);
    336  1.91  christos     LIST_REMOVE(sc, sc_iflist);
    337  1.91  christos     simple_unlock(&ppp_list_mutex);
    338  1.91  christos 
    339  1.91  christos     if_detach(ifp);
    340  1.91  christos 
    341  1.91  christos     FREE(sc, M_DEVBUF);
    342  1.91  christos     return 0;
    343   1.1   deraadt }
    344   1.1   deraadt 
    345   1.1   deraadt /*
    346   1.8    paulus  * Allocate a ppp interface unit and initialize it.
    347   1.8    paulus  */
    348   1.8    paulus struct ppp_softc *
    349   1.8    paulus pppalloc(pid)
    350   1.8    paulus     pid_t pid;
    351   1.8    paulus {
    352  1.91  christos     struct ppp_softc *sc = NULL, *scf;
    353  1.91  christos     int i;
    354   1.8    paulus 
    355  1.91  christos     simple_lock(&ppp_list_mutex);
    356  1.91  christos     for (scf = LIST_FIRST(&ppp_softc_list); scf != NULL;
    357  1.91  christos 	scf = LIST_NEXT(scf, sc_iflist)) {
    358  1.91  christos 	if (scf->sc_xfer == pid) {
    359  1.91  christos 	    scf->sc_xfer = 0;
    360  1.91  christos 	    simple_unlock(&ppp_list_mutex);
    361  1.91  christos 	    return scf;
    362  1.22    paulus 	}
    363  1.91  christos 	if (scf->sc_devp == NULL && sc == NULL)
    364  1.91  christos 	    sc = scf;
    365  1.91  christos     }
    366  1.91  christos     simple_lock(&ppp_list_mutex);
    367  1.91  christos 
    368  1.91  christos     if (sc == NULL)
    369  1.91  christos 	sc = ppp_create(ppp_cloner.ifc_name, -1);
    370   1.8    paulus 
    371  1.66   thorpej #ifdef __HAVE_GENERIC_SOFT_INTERRUPTS
    372  1.66   thorpej     sc->sc_si = softintr_establish(IPL_SOFTNET, pppintr, sc);
    373  1.66   thorpej     if (sc->sc_si == NULL) {
    374  1.91  christos 	printf("%s: unable to establish softintr\n", sc->sc_if.if_xname);
    375  1.66   thorpej 	return (NULL);
    376  1.66   thorpej     }
    377  1.66   thorpej #endif
    378   1.8    paulus     sc->sc_flags = 0;
    379   1.8    paulus     sc->sc_mru = PPP_MRU;
    380  1.22    paulus     sc->sc_relinq = NULL;
    381  1.91  christos     (void)memset(&sc->sc_stats, 0, sizeof(sc->sc_stats));
    382   1.8    paulus #ifdef VJC
    383  1.29    paulus     MALLOC(sc->sc_comp, struct slcompress *, sizeof(struct slcompress),
    384  1.29    paulus 	   M_DEVBUF, M_NOWAIT);
    385  1.29    paulus     if (sc->sc_comp)
    386  1.39  christos 	sl_compress_init(sc->sc_comp);
    387   1.8    paulus #endif
    388  1.22    paulus #ifdef PPP_COMPRESS
    389  1.22    paulus     sc->sc_xc_state = NULL;
    390  1.22    paulus     sc->sc_rc_state = NULL;
    391  1.22    paulus #endif /* PPP_COMPRESS */
    392  1.22    paulus     for (i = 0; i < NUM_NP; ++i)
    393  1.22    paulus 	sc->sc_npmode[i] = NPMODE_ERROR;
    394  1.22    paulus     sc->sc_npqueue = NULL;
    395  1.22    paulus     sc->sc_npqtail = &sc->sc_npqueue;
    396  1.22    paulus     sc->sc_last_sent = sc->sc_last_recv = time.tv_sec;
    397   1.8    paulus 
    398   1.8    paulus     return sc;
    399   1.8    paulus }
    400   1.8    paulus 
    401   1.8    paulus /*
    402  1.22    paulus  * Deallocate a ppp unit.  Must be called at splsoftnet or higher.
    403   1.8    paulus  */
    404  1.22    paulus void
    405   1.8    paulus pppdealloc(sc)
    406   1.8    paulus     struct ppp_softc *sc;
    407   1.8    paulus {
    408   1.8    paulus     struct mbuf *m;
    409   1.8    paulus 
    410  1.66   thorpej #ifdef __HAVE_GENERIC_SOFT_INTERRUPTS
    411  1.66   thorpej     softintr_disestablish(sc->sc_si);
    412  1.66   thorpej #endif
    413   1.8    paulus     if_down(&sc->sc_if);
    414  1.22    paulus     sc->sc_if.if_flags &= ~(IFF_UP|IFF_RUNNING);
    415   1.8    paulus     sc->sc_devp = NULL;
    416   1.8    paulus     sc->sc_xfer = 0;
    417   1.8    paulus     for (;;) {
    418  1.22    paulus 	IF_DEQUEUE(&sc->sc_rawq, m);
    419  1.22    paulus 	if (m == NULL)
    420  1.22    paulus 	    break;
    421  1.22    paulus 	m_freem(m);
    422  1.22    paulus     }
    423  1.22    paulus     for (;;) {
    424   1.8    paulus 	IF_DEQUEUE(&sc->sc_inq, m);
    425   1.8    paulus 	if (m == NULL)
    426   1.8    paulus 	    break;
    427   1.8    paulus 	m_freem(m);
    428   1.8    paulus     }
    429   1.8    paulus     for (;;) {
    430   1.8    paulus 	IF_DEQUEUE(&sc->sc_fastq, m);
    431   1.8    paulus 	if (m == NULL)
    432   1.8    paulus 	    break;
    433   1.8    paulus 	m_freem(m);
    434   1.8    paulus     }
    435  1.22    paulus     while ((m = sc->sc_npqueue) != NULL) {
    436  1.22    paulus 	sc->sc_npqueue = m->m_nextpkt;
    437  1.22    paulus 	m_freem(m);
    438   1.1   deraadt     }
    439  1.22    paulus     if (sc->sc_togo != NULL) {
    440  1.22    paulus 	m_freem(sc->sc_togo);
    441  1.22    paulus 	sc->sc_togo = NULL;
    442  1.22    paulus     }
    443  1.22    paulus #ifdef PPP_COMPRESS
    444  1.22    paulus     ppp_ccp_closed(sc);
    445  1.22    paulus     sc->sc_xc_state = NULL;
    446  1.22    paulus     sc->sc_rc_state = NULL;
    447  1.22    paulus #endif /* PPP_COMPRESS */
    448  1.37  christos #ifdef PPP_FILTER
    449  1.53      tron     if (sc->sc_pass_filt_in.bf_insns != 0) {
    450  1.53      tron 	FREE(sc->sc_pass_filt_in.bf_insns, M_DEVBUF);
    451  1.53      tron 	sc->sc_pass_filt_in.bf_insns = 0;
    452  1.53      tron 	sc->sc_pass_filt_in.bf_len = 0;
    453  1.29    paulus     }
    454  1.53      tron     if (sc->sc_pass_filt_out.bf_insns != 0) {
    455  1.53      tron 	FREE(sc->sc_pass_filt_out.bf_insns, M_DEVBUF);
    456  1.53      tron 	sc->sc_pass_filt_out.bf_insns = 0;
    457  1.53      tron 	sc->sc_pass_filt_out.bf_len = 0;
    458  1.53      tron     }
    459  1.53      tron     if (sc->sc_active_filt_in.bf_insns != 0) {
    460  1.53      tron 	FREE(sc->sc_active_filt_in.bf_insns, M_DEVBUF);
    461  1.53      tron 	sc->sc_active_filt_in.bf_insns = 0;
    462  1.53      tron 	sc->sc_active_filt_in.bf_len = 0;
    463  1.53      tron     }
    464  1.53      tron     if (sc->sc_active_filt_out.bf_insns != 0) {
    465  1.53      tron 	FREE(sc->sc_active_filt_out.bf_insns, M_DEVBUF);
    466  1.53      tron 	sc->sc_active_filt_out.bf_insns = 0;
    467  1.53      tron 	sc->sc_active_filt_out.bf_len = 0;
    468  1.29    paulus     }
    469  1.37  christos #endif /* PPP_FILTER */
    470  1.29    paulus #ifdef VJC
    471  1.29    paulus     if (sc->sc_comp != 0) {
    472  1.29    paulus 	FREE(sc->sc_comp, M_DEVBUF);
    473  1.29    paulus 	sc->sc_comp = 0;
    474  1.29    paulus     }
    475  1.29    paulus #endif
    476  1.91  christos     (void)ppp_clone_destroy(&sc->sc_if);
    477   1.1   deraadt }
    478   1.1   deraadt 
    479   1.1   deraadt /*
    480  1.22    paulus  * Ioctl routine for generic ppp devices.
    481   1.1   deraadt  */
    482   1.1   deraadt int
    483  1.22    paulus pppioctl(sc, cmd, data, flag, p)
    484  1.22    paulus     struct ppp_softc *sc;
    485  1.20       cgd     u_long cmd;
    486   1.1   deraadt     caddr_t data;
    487  1.20       cgd     int flag;
    488   1.8    paulus     struct proc *p;
    489   1.1   deraadt {
    490  1.71  jdolecek     int s, error, flags, mru, npx;
    491  1.71  jdolecek     u_int nb;
    492  1.22    paulus     struct ppp_option_data *odp;
    493  1.22    paulus     struct compressor **cp;
    494  1.22    paulus     struct npioctl *npi;
    495  1.22    paulus     time_t t;
    496  1.37  christos #ifdef PPP_FILTER
    497  1.29    paulus     struct bpf_program *bp, *nbp;
    498  1.29    paulus     struct bpf_insn *newcode, *oldcode;
    499  1.29    paulus     int newcodelen;
    500  1.37  christos #endif /* PPP_FILTER */
    501  1.22    paulus #ifdef	PPP_COMPRESS
    502  1.22    paulus     u_char ccp_option[CCP_MAX_OPTION_LENGTH];
    503  1.22    paulus #endif
    504   1.8    paulus 
    505   1.1   deraadt     switch (cmd) {
    506   1.1   deraadt     case FIONREAD:
    507   1.1   deraadt 	*(int *)data = sc->sc_inq.ifq_len;
    508   1.1   deraadt 	break;
    509   1.1   deraadt 
    510   1.1   deraadt     case PPPIOCGUNIT:
    511  1.91  christos 	*(int *)data = sc->sc_unit;
    512   1.1   deraadt 	break;
    513   1.1   deraadt 
    514   1.1   deraadt     case PPPIOCGFLAGS:
    515   1.1   deraadt 	*(u_int *)data = sc->sc_flags;
    516  1.85  christos 	break;
    517  1.85  christos 
    518  1.85  christos     case PPPIOCGRAWIN:
    519  1.85  christos 	{
    520  1.85  christos 	    struct ppp_rawin *rwin = (struct ppp_rawin *)data;
    521  1.85  christos 	    u_char p, q = 0;
    522  1.85  christos 
    523  1.85  christos 	    for (p = sc->sc_rawin_start; p < sizeof(sc->sc_rawin.buf);)
    524  1.85  christos 		rwin->buf[q++] = sc->sc_rawin.buf[p++];
    525  1.85  christos 
    526  1.85  christos 	    for (p = 0; p < sc->sc_rawin_start;)
    527  1.85  christos 		rwin->buf[q++] = sc->sc_rawin.buf[p++];
    528  1.85  christos 
    529  1.85  christos 	    rwin->count = sc->sc_rawin.count;
    530  1.85  christos 	}
    531   1.1   deraadt 	break;
    532   1.1   deraadt 
    533   1.1   deraadt     case PPPIOCSFLAGS:
    534  1.28  christos 	if ((error = suser(p->p_ucred, &p->p_acflag)) != 0)
    535   1.1   deraadt 	    return (error);
    536   1.2    paulus 	flags = *(int *)data & SC_MASK;
    537  1.22    paulus 	s = splsoftnet();
    538  1.22    paulus #ifdef PPP_COMPRESS
    539  1.22    paulus 	if (sc->sc_flags & SC_CCP_OPEN && !(flags & SC_CCP_OPEN))
    540  1.22    paulus 	    ppp_ccp_closed(sc);
    541  1.22    paulus #endif
    542  1.68   thorpej 	splhigh();	/* XXX IMP ME HARDER */
    543   1.2    paulus 	sc->sc_flags = (sc->sc_flags & ~SC_MASK) | flags;
    544   1.1   deraadt 	splx(s);
    545   1.1   deraadt 	break;
    546   1.1   deraadt 
    547   1.2    paulus     case PPPIOCSMRU:
    548  1.28  christos 	if ((error = suser(p->p_ucred, &p->p_acflag)) != 0)
    549   1.2    paulus 	    return (error);
    550   1.2    paulus 	mru = *(int *)data;
    551  1.62       wiz 	if (mru >= PPP_MINMRU && mru <= PPP_MAXMRU)
    552   1.2    paulus 	    sc->sc_mru = mru;
    553   1.2    paulus 	break;
    554   1.2    paulus 
    555   1.2    paulus     case PPPIOCGMRU:
    556   1.2    paulus 	*(int *)data = sc->sc_mru;
    557   1.2    paulus 	break;
    558   1.2    paulus 
    559   1.8    paulus #ifdef VJC
    560   1.8    paulus     case PPPIOCSMAXCID:
    561  1.28  christos 	if ((error = suser(p->p_ucred, &p->p_acflag)) != 0)
    562   1.8    paulus 	    return (error);
    563  1.29    paulus 	if (sc->sc_comp) {
    564  1.29    paulus 	    s = splsoftnet();
    565  1.40  christos 	    sl_compress_setup(sc->sc_comp, *(int *)data);
    566  1.29    paulus 	    splx(s);
    567  1.29    paulus 	}
    568   1.8    paulus 	break;
    569   1.8    paulus #endif
    570   1.8    paulus 
    571   1.8    paulus     case PPPIOCXFERUNIT:
    572  1.28  christos 	if ((error = suser(p->p_ucred, &p->p_acflag)) != 0)
    573   1.8    paulus 	    return (error);
    574   1.8    paulus 	sc->sc_xfer = p->p_pid;
    575   1.8    paulus 	break;
    576   1.8    paulus 
    577  1.22    paulus #ifdef PPP_COMPRESS
    578  1.22    paulus     case PPPIOCSCOMPRESS:
    579  1.28  christos 	if ((error = suser(p->p_ucred, &p->p_acflag)) != 0)
    580  1.22    paulus 	    return (error);
    581  1.22    paulus 	odp = (struct ppp_option_data *) data;
    582  1.22    paulus 	nb = odp->length;
    583  1.22    paulus 	if (nb > sizeof(ccp_option))
    584  1.22    paulus 	    nb = sizeof(ccp_option);
    585  1.28  christos 	if ((error = copyin(odp->ptr, ccp_option, nb)) != 0)
    586  1.22    paulus 	    return (error);
    587  1.22    paulus 	if (ccp_option[1] < 2)	/* preliminary check on the length byte */
    588  1.22    paulus 	    return (EINVAL);
    589  1.22    paulus 	for (cp = ppp_compressors; *cp != NULL; ++cp)
    590  1.22    paulus 	    if ((*cp)->compress_proto == ccp_option[0]) {
    591  1.22    paulus 		/*
    592  1.22    paulus 		 * Found a handler for the protocol - try to allocate
    593  1.22    paulus 		 * a compressor or decompressor.
    594  1.22    paulus 		 */
    595  1.22    paulus 		error = 0;
    596  1.22    paulus 		if (odp->transmit) {
    597  1.22    paulus 		    s = splsoftnet();
    598  1.22    paulus 		    if (sc->sc_xc_state != NULL)
    599  1.22    paulus 			(*sc->sc_xcomp->comp_free)(sc->sc_xc_state);
    600  1.22    paulus 		    sc->sc_xcomp = *cp;
    601  1.22    paulus 		    sc->sc_xc_state = (*cp)->comp_alloc(ccp_option, nb);
    602  1.22    paulus 		    if (sc->sc_xc_state == NULL) {
    603  1.22    paulus 			if (sc->sc_flags & SC_DEBUG)
    604  1.35  christos 			    printf("%s: comp_alloc failed\n",
    605  1.34  christos 				sc->sc_if.if_xname);
    606  1.22    paulus 			error = ENOBUFS;
    607  1.22    paulus 		    }
    608  1.68   thorpej 		    splhigh();	/* XXX IMP ME HARDER */
    609  1.22    paulus 		    sc->sc_flags &= ~SC_COMP_RUN;
    610  1.22    paulus 		    splx(s);
    611  1.22    paulus 		} else {
    612  1.22    paulus 		    s = splsoftnet();
    613  1.22    paulus 		    if (sc->sc_rc_state != NULL)
    614  1.22    paulus 			(*sc->sc_rcomp->decomp_free)(sc->sc_rc_state);
    615  1.22    paulus 		    sc->sc_rcomp = *cp;
    616  1.22    paulus 		    sc->sc_rc_state = (*cp)->decomp_alloc(ccp_option, nb);
    617  1.22    paulus 		    if (sc->sc_rc_state == NULL) {
    618  1.22    paulus 			if (sc->sc_flags & SC_DEBUG)
    619  1.35  christos 			    printf("%s: decomp_alloc failed\n",
    620  1.34  christos 				sc->sc_if.if_xname);
    621  1.22    paulus 			error = ENOBUFS;
    622  1.22    paulus 		    }
    623  1.68   thorpej 		    splhigh();	/* XXX IMP ME HARDER */
    624  1.22    paulus 		    sc->sc_flags &= ~SC_DECOMP_RUN;
    625  1.22    paulus 		    splx(s);
    626  1.22    paulus 		}
    627  1.22    paulus 		return (error);
    628  1.22    paulus 	    }
    629  1.22    paulus 	if (sc->sc_flags & SC_DEBUG)
    630  1.35  christos 	    printf("%s: no compressor for [%x %x %x], %x\n",
    631  1.34  christos 		sc->sc_if.if_xname, ccp_option[0], ccp_option[1],
    632  1.34  christos 		ccp_option[2], nb);
    633  1.22    paulus 	return (EINVAL);	/* no handler found */
    634  1.22    paulus #endif /* PPP_COMPRESS */
    635  1.22    paulus 
    636  1.22    paulus     case PPPIOCGNPMODE:
    637  1.22    paulus     case PPPIOCSNPMODE:
    638  1.22    paulus 	npi = (struct npioctl *) data;
    639  1.22    paulus 	switch (npi->protocol) {
    640  1.22    paulus 	case PPP_IP:
    641  1.22    paulus 	    npx = NP_IP;
    642  1.22    paulus 	    break;
    643  1.55    itojun 	case PPP_IPV6:
    644  1.55    itojun 	    npx = NP_IPV6;
    645  1.55    itojun 	    break;
    646  1.22    paulus 	default:
    647  1.22    paulus 	    return EINVAL;
    648  1.22    paulus 	}
    649  1.22    paulus 	if (cmd == PPPIOCGNPMODE) {
    650  1.22    paulus 	    npi->mode = sc->sc_npmode[npx];
    651  1.22    paulus 	} else {
    652  1.28  christos 	    if ((error = suser(p->p_ucred, &p->p_acflag)) != 0)
    653  1.22    paulus 		return (error);
    654  1.22    paulus 	    if (npi->mode != sc->sc_npmode[npx]) {
    655  1.68   thorpej 		s = splnet();
    656  1.22    paulus 		sc->sc_npmode[npx] = npi->mode;
    657  1.22    paulus 		if (npi->mode != NPMODE_QUEUE) {
    658  1.22    paulus 		    ppp_requeue(sc);
    659  1.44  sommerfe 		    ppp_restart(sc);
    660  1.22    paulus 		}
    661  1.22    paulus 		splx(s);
    662  1.22    paulus 	    }
    663  1.22    paulus 	}
    664  1.22    paulus 	break;
    665  1.22    paulus 
    666  1.22    paulus     case PPPIOCGIDLE:
    667  1.22    paulus 	s = splsoftnet();
    668  1.22    paulus 	t = time.tv_sec;
    669  1.22    paulus 	((struct ppp_idle *)data)->xmit_idle = t - sc->sc_last_sent;
    670  1.22    paulus 	((struct ppp_idle *)data)->recv_idle = t - sc->sc_last_recv;
    671  1.22    paulus 	splx(s);
    672  1.22    paulus 	break;
    673  1.22    paulus 
    674  1.37  christos #ifdef PPP_FILTER
    675  1.29    paulus     case PPPIOCSPASS:
    676  1.29    paulus     case PPPIOCSACTIVE:
    677  1.52   thorpej 	/* These are no longer supported. */
    678  1.52   thorpej 	return EOPNOTSUPP;
    679  1.52   thorpej 
    680  1.52   thorpej     case PPPIOCSIPASS:
    681  1.52   thorpej     case PPPIOCSOPASS:
    682  1.52   thorpej     case PPPIOCSIACTIVE:
    683  1.52   thorpej     case PPPIOCSOACTIVE:
    684  1.29    paulus 	nbp = (struct bpf_program *) data;
    685  1.29    paulus 	if ((unsigned) nbp->bf_len > BPF_MAXINSNS)
    686  1.29    paulus 	    return EINVAL;
    687  1.29    paulus 	newcodelen = nbp->bf_len * sizeof(struct bpf_insn);
    688  1.29    paulus 	if (newcodelen != 0) {
    689  1.52   thorpej 	    newcode = malloc(newcodelen, M_DEVBUF, M_WAITOK);
    690  1.52   thorpej 	    /* WAITOK -- malloc() never fails. */
    691  1.29    paulus 	    if ((error = copyin((caddr_t)nbp->bf_insns, (caddr_t)newcode,
    692  1.29    paulus 			       newcodelen)) != 0) {
    693  1.52   thorpej 		free(newcode, M_DEVBUF);
    694  1.29    paulus 		return error;
    695  1.29    paulus 	    }
    696  1.29    paulus 	    if (!bpf_validate(newcode, nbp->bf_len)) {
    697  1.52   thorpej 		free(newcode, M_DEVBUF);
    698  1.29    paulus 		return EINVAL;
    699  1.29    paulus 	    }
    700  1.29    paulus 	} else
    701  1.29    paulus 	    newcode = 0;
    702  1.52   thorpej 	switch (cmd) {
    703  1.52   thorpej 	case PPPIOCSIPASS:
    704  1.52   thorpej 	    bp = &sc->sc_pass_filt_in;
    705  1.52   thorpej 	    break;
    706  1.52   thorpej 
    707  1.52   thorpej 	case PPPIOCSOPASS:
    708  1.52   thorpej 	    bp = &sc->sc_pass_filt_out;
    709  1.52   thorpej 	    break;
    710  1.52   thorpej 
    711  1.52   thorpej 	case PPPIOCSIACTIVE:
    712  1.52   thorpej 	    bp = &sc->sc_active_filt_in;
    713  1.52   thorpej 	    break;
    714  1.52   thorpej 
    715  1.52   thorpej 	case PPPIOCSOACTIVE:
    716  1.52   thorpej 	    bp = &sc->sc_active_filt_out;
    717  1.86  christos 	    break;
    718  1.86  christos 	default:
    719  1.88   mycroft 	    free(newcode, M_DEVBUF);
    720  1.87   mycroft 	    return (EPASSTHROUGH);
    721  1.52   thorpej 	}
    722  1.29    paulus 	oldcode = bp->bf_insns;
    723  1.68   thorpej 	s = splnet();
    724  1.29    paulus 	bp->bf_len = nbp->bf_len;
    725  1.29    paulus 	bp->bf_insns = newcode;
    726  1.29    paulus 	splx(s);
    727  1.29    paulus 	if (oldcode != 0)
    728  1.52   thorpej 	    free(oldcode, M_DEVBUF);
    729  1.29    paulus 	break;
    730  1.52   thorpej #endif /* PPP_FILTER */
    731  1.29    paulus 
    732   1.1   deraadt     default:
    733  1.76    atatat 	return (EPASSTHROUGH);
    734   1.1   deraadt     }
    735   1.1   deraadt     return (0);
    736   1.1   deraadt }
    737   1.1   deraadt 
    738   1.1   deraadt /*
    739  1.22    paulus  * Process an ioctl request to the ppp network interface.
    740   1.1   deraadt  */
    741  1.37  christos static int
    742  1.22    paulus pppsioctl(ifp, cmd, data)
    743  1.58  augustss     struct ifnet *ifp;
    744  1.22    paulus     u_long cmd;
    745  1.22    paulus     caddr_t data;
    746  1.22    paulus {
    747  1.58  augustss     struct proc *p = curproc;	/* XXX */
    748  1.58  augustss     struct ppp_softc *sc = ifp->if_softc;
    749  1.58  augustss     struct ifaddr *ifa = (struct ifaddr *)data;
    750  1.58  augustss     struct ifreq *ifr = (struct ifreq *)data;
    751  1.22    paulus     struct ppp_stats *psp;
    752  1.22    paulus #ifdef	PPP_COMPRESS
    753  1.22    paulus     struct ppp_comp_stats *pcp;
    754  1.22    paulus #endif
    755  1.68   thorpej     int s = splnet(), error = 0;
    756  1.22    paulus 
    757  1.22    paulus     switch (cmd) {
    758  1.22    paulus     case SIOCSIFFLAGS:
    759  1.22    paulus 	if ((ifp->if_flags & IFF_RUNNING) == 0)
    760  1.22    paulus 	    ifp->if_flags &= ~IFF_UP;
    761  1.22    paulus 	break;
    762  1.22    paulus 
    763  1.22    paulus     case SIOCSIFADDR:
    764  1.55    itojun 	switch (ifa->ifa_addr->sa_family) {
    765  1.55    itojun #ifdef INET
    766  1.55    itojun 	case AF_INET:
    767  1.55    itojun 	    break;
    768  1.55    itojun #endif
    769  1.55    itojun #ifdef INET6
    770  1.55    itojun 	case AF_INET6:
    771  1.55    itojun 	    break;
    772  1.55    itojun #endif
    773  1.55    itojun 	default:
    774  1.49  christos 	    error = EAFNOSUPPORT;
    775  1.55    itojun 	    break;
    776  1.55    itojun 	}
    777  1.49  christos 	break;
    778  1.49  christos 
    779  1.22    paulus     case SIOCSIFDSTADDR:
    780  1.55    itojun 	switch (ifa->ifa_addr->sa_family) {
    781  1.55    itojun #ifdef INET
    782  1.55    itojun 	case AF_INET:
    783  1.55    itojun 	    break;
    784  1.55    itojun #endif
    785  1.55    itojun #ifdef INET6
    786  1.55    itojun 	case AF_INET6:
    787  1.55    itojun 	    break;
    788  1.55    itojun #endif
    789  1.55    itojun 	default:
    790  1.22    paulus 	    error = EAFNOSUPPORT;
    791  1.55    itojun 	    break;
    792  1.55    itojun 	}
    793  1.22    paulus 	break;
    794  1.22    paulus 
    795  1.22    paulus     case SIOCSIFMTU:
    796  1.37  christos 	if ((error = suser(p->p_ucred, &p->p_acflag)) != 0)
    797  1.37  christos 	    break;
    798  1.22    paulus 	sc->sc_if.if_mtu = ifr->ifr_mtu;
    799  1.22    paulus 	break;
    800  1.22    paulus 
    801  1.37  christos     case SIOCGIFMTU:
    802  1.37  christos 	ifr->ifr_mtu = sc->sc_if.if_mtu;
    803  1.37  christos 	break;
    804  1.37  christos 
    805  1.29    paulus     case SIOCADDMULTI:
    806  1.29    paulus     case SIOCDELMULTI:
    807  1.29    paulus 	if (ifr == 0) {
    808  1.29    paulus 	    error = EAFNOSUPPORT;
    809  1.29    paulus 	    break;
    810  1.29    paulus 	}
    811  1.84    itojun 	switch (ifr->ifr_addr.sa_family) {
    812  1.29    paulus #ifdef INET
    813  1.29    paulus 	case AF_INET:
    814  1.29    paulus 	    break;
    815  1.29    paulus #endif
    816  1.55    itojun #ifdef INET6
    817  1.55    itojun 	case AF_INET6:
    818  1.55    itojun 	    break;
    819  1.55    itojun #endif
    820  1.29    paulus 	default:
    821  1.29    paulus 	    error = EAFNOSUPPORT;
    822  1.29    paulus 	    break;
    823  1.29    paulus 	}
    824  1.29    paulus 	break;
    825  1.29    paulus 
    826  1.22    paulus     case SIOCGPPPSTATS:
    827  1.22    paulus 	psp = &((struct ifpppstatsreq *) data)->stats;
    828  1.70   thorpej 	memset(psp, 0, sizeof(*psp));
    829  1.29    paulus 	psp->p = sc->sc_stats;
    830  1.29    paulus #if defined(VJC) && !defined(SL_NO_STATS)
    831  1.29    paulus 	if (sc->sc_comp) {
    832  1.29    paulus 	    psp->vj.vjs_packets = sc->sc_comp->sls_packets;
    833  1.29    paulus 	    psp->vj.vjs_compressed = sc->sc_comp->sls_compressed;
    834  1.29    paulus 	    psp->vj.vjs_searches = sc->sc_comp->sls_searches;
    835  1.29    paulus 	    psp->vj.vjs_misses = sc->sc_comp->sls_misses;
    836  1.29    paulus 	    psp->vj.vjs_uncompressedin = sc->sc_comp->sls_uncompressedin;
    837  1.29    paulus 	    psp->vj.vjs_compressedin = sc->sc_comp->sls_compressedin;
    838  1.29    paulus 	    psp->vj.vjs_errorin = sc->sc_comp->sls_errorin;
    839  1.29    paulus 	    psp->vj.vjs_tossed = sc->sc_comp->sls_tossed;
    840  1.29    paulus 	}
    841  1.22    paulus #endif /* VJC */
    842  1.22    paulus 	break;
    843  1.22    paulus 
    844  1.22    paulus #ifdef PPP_COMPRESS
    845  1.22    paulus     case SIOCGPPPCSTATS:
    846  1.22    paulus 	pcp = &((struct ifpppcstatsreq *) data)->stats;
    847  1.70   thorpej 	memset(pcp, 0, sizeof(*pcp));
    848  1.22    paulus 	if (sc->sc_xc_state != NULL)
    849  1.22    paulus 	    (*sc->sc_xcomp->comp_stat)(sc->sc_xc_state, &pcp->c);
    850  1.22    paulus 	if (sc->sc_rc_state != NULL)
    851  1.22    paulus 	    (*sc->sc_rcomp->decomp_stat)(sc->sc_rc_state, &pcp->d);
    852  1.22    paulus 	break;
    853  1.22    paulus #endif /* PPP_COMPRESS */
    854   1.1   deraadt 
    855  1.22    paulus     default:
    856  1.22    paulus 	error = EINVAL;
    857  1.22    paulus     }
    858  1.22    paulus     splx(s);
    859  1.22    paulus     return (error);
    860   1.1   deraadt }
    861   1.1   deraadt 
    862   1.1   deraadt /*
    863   1.1   deraadt  * Queue a packet.  Start transmission if not active.
    864   1.1   deraadt  * Packet is placed in Information field of PPP frame.
    865   1.1   deraadt  */
    866   1.1   deraadt int
    867   1.9   mycroft pppoutput(ifp, m0, dst, rtp)
    868   1.1   deraadt     struct ifnet *ifp;
    869   1.1   deraadt     struct mbuf *m0;
    870   1.1   deraadt     struct sockaddr *dst;
    871   1.9   mycroft     struct rtentry *rtp;
    872   1.1   deraadt {
    873  1.58  augustss     struct ppp_softc *sc = ifp->if_softc;
    874   1.2    paulus     int protocol, address, control;
    875   1.2    paulus     u_char *cp;
    876   1.2    paulus     int s, error;
    877  1.59    itojun #ifdef INET
    878   1.2    paulus     struct ip *ip;
    879  1.59    itojun #endif
    880   1.2    paulus     struct ifqueue *ifq;
    881  1.22    paulus     enum NPmode mode;
    882  1.37  christos     int len;
    883  1.64   thorpej     ALTQ_DECL(struct altq_pktattr pktattr;)
    884   1.1   deraadt 
    885   1.8    paulus     if (sc->sc_devp == NULL || (ifp->if_flags & IFF_RUNNING) == 0
    886  1.28  christos 	|| ((ifp->if_flags & IFF_UP) == 0 && dst->sa_family != AF_UNSPEC)) {
    887   1.1   deraadt 	error = ENETDOWN;	/* sort of */
    888   1.1   deraadt 	goto bad;
    889   1.1   deraadt     }
    890   1.1   deraadt 
    891  1.64   thorpej     IFQ_CLASSIFY(&ifp->if_snd, m0, dst->sa_family, &pktattr);
    892  1.64   thorpej 
    893   1.1   deraadt     /*
    894   1.1   deraadt      * Compute PPP header.
    895   1.1   deraadt      */
    896  1.22    paulus     m0->m_flags &= ~M_HIGHPRI;
    897   1.1   deraadt     switch (dst->sa_family) {
    898   1.1   deraadt #ifdef INET
    899   1.1   deraadt     case AF_INET:
    900  1.22    paulus 	address = PPP_ALLSTATIONS;
    901  1.22    paulus 	control = PPP_UI;
    902   1.1   deraadt 	protocol = PPP_IP;
    903  1.22    paulus 	mode = sc->sc_npmode[NP_IP];
    904  1.22    paulus 
    905   1.2    paulus 	/*
    906  1.22    paulus 	 * If this packet has the "low delay" bit set in the IP header,
    907  1.22    paulus 	 * put it on the fastq instead.
    908   1.2    paulus 	 */
    909  1.22    paulus 	ip = mtod(m0, struct ip *);
    910  1.22    paulus 	if (ip->ip_tos & IPTOS_LOWDELAY)
    911  1.22    paulus 	    m0->m_flags |= M_HIGHPRI;
    912   1.1   deraadt 	break;
    913   1.1   deraadt #endif
    914  1.55    itojun #ifdef INET6
    915  1.55    itojun     case AF_INET6:
    916  1.55    itojun 	address = PPP_ALLSTATIONS;	/*XXX*/
    917  1.55    itojun 	control = PPP_UI;		/*XXX*/
    918  1.55    itojun 	protocol = PPP_IPV6;
    919  1.55    itojun 	mode = sc->sc_npmode[NP_IPV6];
    920  1.55    itojun 
    921  1.55    itojun #if 0	/* XXX flowinfo/traffic class, maybe? */
    922  1.55    itojun 	/*
    923  1.55    itojun 	 * If this packet has the "low delay" bit set in the IP header,
    924  1.55    itojun 	 * put it on the fastq instead.
    925  1.55    itojun 	 */
    926  1.55    itojun 	ip = mtod(m0, struct ip *);
    927  1.55    itojun 	if (ip->ip_tos & IPTOS_LOWDELAY)
    928  1.55    itojun 	    m0->m_flags |= M_HIGHPRI;
    929  1.56   hannken #endif
    930  1.55    itojun 	break;
    931  1.55    itojun #endif
    932   1.1   deraadt     case AF_UNSPEC:
    933  1.22    paulus 	address = PPP_ADDRESS(dst->sa_data);
    934  1.22    paulus 	control = PPP_CONTROL(dst->sa_data);
    935  1.22    paulus 	protocol = PPP_PROTOCOL(dst->sa_data);
    936  1.22    paulus 	mode = NPMODE_PASS;
    937   1.1   deraadt 	break;
    938   1.1   deraadt     default:
    939  1.35  christos 	printf("%s: af%d not supported\n", ifp->if_xname, dst->sa_family);
    940   1.1   deraadt 	error = EAFNOSUPPORT;
    941   1.1   deraadt 	goto bad;
    942   1.1   deraadt     }
    943   1.1   deraadt 
    944   1.1   deraadt     /*
    945  1.22    paulus      * Drop this packet, or return an error, if necessary.
    946  1.22    paulus      */
    947  1.22    paulus     if (mode == NPMODE_ERROR) {
    948  1.22    paulus 	error = ENETDOWN;
    949  1.22    paulus 	goto bad;
    950  1.22    paulus     }
    951  1.22    paulus     if (mode == NPMODE_DROP) {
    952  1.22    paulus 	error = 0;
    953  1.22    paulus 	goto bad;
    954  1.22    paulus     }
    955  1.22    paulus 
    956  1.22    paulus     /*
    957  1.90    dyoung      * Add PPP header.
    958   1.1   deraadt      */
    959  1.90    dyoung     M_PREPEND(m0, PPP_HDRLEN, M_DONTWAIT);
    960  1.90    dyoung     if (m0 == NULL) {
    961  1.90    dyoung 	error = ENOBUFS;
    962  1.90    dyoung 	goto bad;
    963  1.90    dyoung     }
    964   1.1   deraadt 
    965   1.1   deraadt     cp = mtod(m0, u_char *);
    966   1.2    paulus     *cp++ = address;
    967   1.2    paulus     *cp++ = control;
    968   1.2    paulus     *cp++ = protocol >> 8;
    969   1.1   deraadt     *cp++ = protocol & 0xff;
    970  1.81    itojun 
    971  1.90    dyoung     len = m_length(m0);
    972  1.29    paulus 
    973   1.8    paulus     if (sc->sc_flags & SC_LOG_OUTPKT) {
    974  1.35  christos 	printf("%s output: ", ifp->if_xname);
    975  1.22    paulus 	pppdumpm(m0);
    976   1.1   deraadt     }
    977   1.1   deraadt 
    978  1.29    paulus     if ((protocol & 0x8000) == 0) {
    979  1.37  christos #ifdef PPP_FILTER
    980  1.37  christos 	/*
    981  1.37  christos 	 * Apply the pass and active filters to the packet,
    982  1.37  christos 	 * but only if it is a data packet.
    983  1.37  christos 	 */
    984  1.52   thorpej 	if (sc->sc_pass_filt_out.bf_insns != 0
    985  1.52   thorpej 	    && bpf_filter(sc->sc_pass_filt_out.bf_insns, (u_char *) m0,
    986  1.29    paulus 			  len, 0) == 0) {
    987  1.29    paulus 	    error = 0;		/* drop this packet */
    988  1.29    paulus 	    goto bad;
    989  1.29    paulus 	}
    990  1.29    paulus 
    991  1.29    paulus 	/*
    992  1.29    paulus 	 * Update the time we sent the most recent packet.
    993  1.29    paulus 	 */
    994  1.52   thorpej 	if (sc->sc_active_filt_out.bf_insns == 0
    995  1.52   thorpej 	    || bpf_filter(sc->sc_active_filt_out.bf_insns, (u_char *) m0,
    996  1.52   thorpej 	    		  len, 0))
    997  1.29    paulus 	    sc->sc_last_sent = time.tv_sec;
    998  1.37  christos #else
    999  1.37  christos 	/*
   1000  1.37  christos 	 * Update the time we sent the most recent packet.
   1001  1.37  christos 	 */
   1002  1.37  christos 	sc->sc_last_sent = time.tv_sec;
   1003  1.37  christos #endif /* PPP_FILTER */
   1004  1.29    paulus     }
   1005  1.29    paulus 
   1006   1.2    paulus #if NBPFILTER > 0
   1007  1.22    paulus     /*
   1008  1.22    paulus      * See if bpf wants to look at the packet.
   1009  1.22    paulus      */
   1010  1.63   thorpej     if (sc->sc_if.if_bpf)
   1011  1.63   thorpej 	bpf_mtap(sc->sc_if.if_bpf, m0);
   1012   1.2    paulus #endif
   1013   1.2    paulus 
   1014   1.2    paulus     /*
   1015   1.2    paulus      * Put the packet on the appropriate queue.
   1016   1.2    paulus      */
   1017  1.68   thorpej     s = splnet();
   1018  1.22    paulus     if (mode == NPMODE_QUEUE) {
   1019  1.22    paulus 	/* XXX we should limit the number of packets on this queue */
   1020  1.22    paulus 	*sc->sc_npqtail = m0;
   1021  1.22    paulus 	m0->m_nextpkt = NULL;
   1022  1.22    paulus 	sc->sc_npqtail = &m0->m_nextpkt;
   1023  1.22    paulus     } else {
   1024  1.64   thorpej 	if ((m0->m_flags & M_HIGHPRI)
   1025  1.64   thorpej #ifdef ALTQ
   1026  1.64   thorpej 	    && ALTQ_IS_ENABLED(&sc->sc_if.if_snd) == 0
   1027  1.64   thorpej #endif
   1028  1.64   thorpej 	    ) {
   1029  1.64   thorpej 	    ifq = &sc->sc_fastq;
   1030  1.64   thorpej 	    if (IF_QFULL(ifq) && dst->sa_family != AF_UNSPEC) {
   1031  1.64   thorpej 	        IF_DROP(ifq);
   1032  1.64   thorpej 		splx(s);
   1033  1.64   thorpej 		error = ENOBUFS;
   1034  1.64   thorpej 		goto bad;
   1035  1.64   thorpej 	    } else {
   1036  1.64   thorpej 		IF_ENQUEUE(ifq, m0);
   1037  1.64   thorpej 		error = 0;
   1038  1.64   thorpej 	    }
   1039  1.64   thorpej 	} else
   1040  1.64   thorpej 	    IFQ_ENQUEUE(&sc->sc_if.if_snd, m0, &pktattr, error);
   1041  1.64   thorpej 	if (error) {
   1042  1.22    paulus 	    splx(s);
   1043  1.22    paulus 	    sc->sc_if.if_oerrors++;
   1044  1.29    paulus 	    sc->sc_stats.ppp_oerrors++;
   1045  1.64   thorpej 	    return (error);
   1046  1.22    paulus 	}
   1047  1.44  sommerfe 	ppp_restart(sc);
   1048   1.1   deraadt     }
   1049  1.29    paulus     ifp->if_opackets++;
   1050  1.29    paulus     ifp->if_obytes += len;
   1051   1.8    paulus 
   1052   1.1   deraadt     splx(s);
   1053   1.1   deraadt     return (0);
   1054   1.1   deraadt 
   1055   1.1   deraadt bad:
   1056   1.1   deraadt     m_freem(m0);
   1057   1.1   deraadt     return (error);
   1058   1.1   deraadt }
   1059   1.1   deraadt 
   1060   1.1   deraadt /*
   1061  1.22    paulus  * After a change in the NPmode for some NP, move packets from the
   1062  1.22    paulus  * npqueue to the send queue or the fast queue as appropriate.
   1063  1.68   thorpej  * Should be called at splnet, since we muck with the queues.
   1064   1.8    paulus  */
   1065  1.22    paulus static void
   1066  1.22    paulus ppp_requeue(sc)
   1067   1.8    paulus     struct ppp_softc *sc;
   1068   1.8    paulus {
   1069  1.22    paulus     struct mbuf *m, **mpp;
   1070  1.22    paulus     struct ifqueue *ifq;
   1071  1.22    paulus     enum NPmode mode;
   1072  1.64   thorpej     int error;
   1073   1.8    paulus 
   1074  1.22    paulus     for (mpp = &sc->sc_npqueue; (m = *mpp) != NULL; ) {
   1075  1.22    paulus 	switch (PPP_PROTOCOL(mtod(m, u_char *))) {
   1076  1.22    paulus 	case PPP_IP:
   1077  1.22    paulus 	    mode = sc->sc_npmode[NP_IP];
   1078  1.22    paulus 	    break;
   1079  1.55    itojun 	case PPP_IPV6:
   1080  1.55    itojun 	    mode = sc->sc_npmode[NP_IPV6];
   1081  1.55    itojun 	    break;
   1082  1.22    paulus 	default:
   1083  1.22    paulus 	    mode = NPMODE_PASS;
   1084  1.22    paulus 	}
   1085   1.8    paulus 
   1086  1.22    paulus 	switch (mode) {
   1087  1.22    paulus 	case NPMODE_PASS:
   1088  1.22    paulus 	    /*
   1089  1.22    paulus 	     * This packet can now go on one of the queues to be sent.
   1090  1.22    paulus 	     */
   1091  1.22    paulus 	    *mpp = m->m_nextpkt;
   1092  1.22    paulus 	    m->m_nextpkt = NULL;
   1093  1.64   thorpej 	    if ((m->m_flags & M_HIGHPRI)
   1094  1.64   thorpej #ifdef ALTQ
   1095  1.64   thorpej 		&& ALTQ_IS_ENABLED(&sc->sc_if.if_snd) == 0
   1096  1.64   thorpej #endif
   1097  1.64   thorpej 		) {
   1098  1.64   thorpej 		ifq = &sc->sc_fastq;
   1099  1.64   thorpej 		if (IF_QFULL(ifq)) {
   1100  1.64   thorpej 		    IF_DROP(ifq);
   1101  1.64   thorpej 		    m_freem(m);
   1102  1.64   thorpej 		    error = ENOBUFS;
   1103  1.64   thorpej 		} else {
   1104  1.64   thorpej 		    IF_ENQUEUE(ifq, m);
   1105  1.64   thorpej 		    error = 0;
   1106  1.64   thorpej 		}
   1107  1.64   thorpej 	    } else
   1108  1.64   thorpej 		IFQ_ENQUEUE(&sc->sc_if.if_snd, m, NULL, error);
   1109  1.64   thorpej 	    if (error) {
   1110  1.22    paulus 		sc->sc_if.if_oerrors++;
   1111  1.29    paulus 		sc->sc_stats.ppp_oerrors++;
   1112  1.64   thorpej 	    }
   1113  1.22    paulus 	    break;
   1114   1.8    paulus 
   1115  1.22    paulus 	case NPMODE_DROP:
   1116  1.22    paulus 	case NPMODE_ERROR:
   1117  1.22    paulus 	    *mpp = m->m_nextpkt;
   1118  1.22    paulus 	    m_freem(m);
   1119  1.22    paulus 	    break;
   1120  1.22    paulus 
   1121  1.22    paulus 	case NPMODE_QUEUE:
   1122  1.22    paulus 	    mpp = &m->m_nextpkt;
   1123  1.22    paulus 	    break;
   1124  1.22    paulus 	}
   1125  1.22    paulus     }
   1126  1.22    paulus     sc->sc_npqtail = mpp;
   1127  1.22    paulus }
   1128  1.22    paulus 
   1129  1.22    paulus /*
   1130  1.37  christos  * Transmitter has finished outputting some stuff;
   1131  1.37  christos  * remember to call sc->sc_start later at splsoftnet.
   1132  1.22    paulus  */
   1133  1.37  christos void
   1134  1.37  christos ppp_restart(sc)
   1135  1.22    paulus     struct ppp_softc *sc;
   1136  1.22    paulus {
   1137  1.68   thorpej     int s = splhigh();	/* XXX IMP ME HARDER */
   1138  1.22    paulus 
   1139  1.22    paulus     sc->sc_flags &= ~SC_TBUSY;
   1140  1.66   thorpej #ifdef __HAVE_GENERIC_SOFT_INTERRUPTS
   1141  1.66   thorpej     softintr_schedule(sc->sc_si);
   1142  1.66   thorpej #else
   1143  1.22    paulus     schednetisr(NETISR_PPP);
   1144  1.66   thorpej #endif
   1145  1.22    paulus     splx(s);
   1146  1.22    paulus }
   1147  1.22    paulus 
   1148  1.22    paulus /*
   1149  1.37  christos  * Get a packet to send.  This procedure is intended to be called at
   1150  1.37  christos  * splsoftnet, since it may involve time-consuming operations such as
   1151  1.37  christos  * applying VJ compression, packet compression, address/control and/or
   1152  1.37  christos  * protocol field compression to the packet.
   1153  1.22    paulus  */
   1154  1.37  christos struct mbuf *
   1155  1.37  christos ppp_dequeue(sc)
   1156  1.22    paulus     struct ppp_softc *sc;
   1157  1.22    paulus {
   1158  1.22    paulus     struct mbuf *m, *mp;
   1159  1.22    paulus     u_char *cp;
   1160  1.22    paulus     int address, control, protocol;
   1161  1.44  sommerfe     int s;
   1162  1.22    paulus 
   1163  1.22    paulus     /*
   1164  1.22    paulus      * Grab a packet to send: first try the fast queue, then the
   1165  1.22    paulus      * normal queue.
   1166  1.22    paulus      */
   1167  1.68   thorpej     s = splnet();
   1168  1.22    paulus     IF_DEQUEUE(&sc->sc_fastq, m);
   1169  1.22    paulus     if (m == NULL)
   1170  1.64   thorpej 	IFQ_DEQUEUE(&sc->sc_if.if_snd, m);
   1171  1.44  sommerfe     splx(s);
   1172  1.44  sommerfe 
   1173  1.22    paulus     if (m == NULL)
   1174  1.37  christos 	return NULL;
   1175  1.22    paulus 
   1176  1.29    paulus     ++sc->sc_stats.ppp_opackets;
   1177  1.29    paulus 
   1178  1.22    paulus     /*
   1179  1.22    paulus      * Extract the ppp header of the new packet.
   1180  1.22    paulus      * The ppp header will be in one mbuf.
   1181  1.22    paulus      */
   1182  1.22    paulus     cp = mtod(m, u_char *);
   1183  1.22    paulus     address = PPP_ADDRESS(cp);
   1184  1.22    paulus     control = PPP_CONTROL(cp);
   1185  1.22    paulus     protocol = PPP_PROTOCOL(cp);
   1186  1.22    paulus 
   1187  1.22    paulus     switch (protocol) {
   1188  1.22    paulus     case PPP_IP:
   1189  1.22    paulus #ifdef VJC
   1190  1.22    paulus 	/*
   1191  1.22    paulus 	 * If the packet is a TCP/IP packet, see if we can compress it.
   1192  1.22    paulus 	 */
   1193  1.29    paulus 	if ((sc->sc_flags & SC_COMP_TCP) && sc->sc_comp != NULL) {
   1194  1.22    paulus 	    struct ip *ip;
   1195  1.22    paulus 	    int type;
   1196  1.13    paulus 
   1197  1.13    paulus 	    mp = m;
   1198  1.13    paulus 	    ip = (struct ip *) (cp + PPP_HDRLEN);
   1199  1.13    paulus 	    if (mp->m_len <= PPP_HDRLEN) {
   1200  1.13    paulus 		mp = mp->m_next;
   1201  1.13    paulus 		if (mp == NULL)
   1202  1.13    paulus 		    break;
   1203  1.13    paulus 		ip = mtod(mp, struct ip *);
   1204  1.13    paulus 	    }
   1205  1.13    paulus 	    /* this code assumes the IP/TCP header is in one non-shared mbuf */
   1206  1.13    paulus 	    if (ip->ip_p == IPPROTO_TCP) {
   1207  1.29    paulus 		type = sl_compress_tcp(mp, ip, sc->sc_comp,
   1208  1.13    paulus 				       !(sc->sc_flags & SC_NO_TCP_CCID));
   1209  1.13    paulus 		switch (type) {
   1210  1.13    paulus 		case TYPE_UNCOMPRESSED_TCP:
   1211  1.13    paulus 		    protocol = PPP_VJC_UNCOMP;
   1212  1.13    paulus 		    break;
   1213  1.13    paulus 		case TYPE_COMPRESSED_TCP:
   1214  1.13    paulus 		    protocol = PPP_VJC_COMP;
   1215  1.13    paulus 		    cp = mtod(m, u_char *);
   1216  1.13    paulus 		    cp[0] = address;	/* header has moved */
   1217  1.13    paulus 		    cp[1] = control;
   1218  1.13    paulus 		    cp[2] = 0;
   1219  1.13    paulus 		    break;
   1220  1.13    paulus 		}
   1221  1.13    paulus 		cp[3] = protocol;	/* update protocol in PPP header */
   1222   1.8    paulus 	    }
   1223   1.8    paulus 	}
   1224   1.8    paulus #endif	/* VJC */
   1225  1.22    paulus 	break;
   1226  1.22    paulus 
   1227  1.22    paulus #ifdef PPP_COMPRESS
   1228  1.22    paulus     case PPP_CCP:
   1229  1.22    paulus 	ppp_ccp(sc, m, 0);
   1230  1.22    paulus 	break;
   1231  1.22    paulus #endif	/* PPP_COMPRESS */
   1232  1.22    paulus     }
   1233  1.22    paulus 
   1234  1.22    paulus #ifdef PPP_COMPRESS
   1235  1.22    paulus     if (protocol != PPP_LCP && protocol != PPP_CCP
   1236  1.22    paulus 	&& sc->sc_xc_state && (sc->sc_flags & SC_COMP_RUN)) {
   1237  1.29    paulus 	struct mbuf *mcomp = NULL;
   1238  1.82    simonb 	int slen;
   1239  1.22    paulus 
   1240  1.81    itojun 	slen = 0;
   1241  1.81    itojun 	for (mp = m; mp != NULL; mp = mp->m_next)
   1242  1.81    itojun 	    slen += mp->m_len;
   1243  1.82    simonb 	(*sc->sc_xcomp->compress)
   1244  1.37  christos 	    (sc->sc_xc_state, &mcomp, m, slen, sc->sc_if.if_mtu + PPP_HDRLEN);
   1245  1.22    paulus 	if (mcomp != NULL) {
   1246  1.37  christos 	    if (sc->sc_flags & SC_CCP_UP) {
   1247  1.37  christos 		/* Send the compressed packet instead of the original. */
   1248  1.37  christos 		m_freem(m);
   1249  1.37  christos 		m = mcomp;
   1250  1.37  christos 		cp = mtod(m, u_char *);
   1251  1.37  christos 		protocol = cp[3];
   1252  1.37  christos 	    } else {
   1253  1.37  christos 		/* Can't transmit compressed packets until CCP is up. */
   1254  1.37  christos 		m_freem(mcomp);
   1255  1.37  christos 	    }
   1256  1.22    paulus 	}
   1257   1.8    paulus     }
   1258  1.22    paulus #endif	/* PPP_COMPRESS */
   1259   1.8    paulus 
   1260   1.8    paulus     /*
   1261   1.8    paulus      * Compress the address/control and protocol, if possible.
   1262   1.8    paulus      */
   1263   1.8    paulus     if (sc->sc_flags & SC_COMP_AC && address == PPP_ALLSTATIONS &&
   1264   1.8    paulus 	control == PPP_UI && protocol != PPP_ALLSTATIONS &&
   1265   1.8    paulus 	protocol != PPP_LCP) {
   1266   1.8    paulus 	/* can compress address/control */
   1267   1.8    paulus 	m->m_data += 2;
   1268   1.8    paulus 	m->m_len -= 2;
   1269   1.8    paulus     }
   1270   1.8    paulus     if (sc->sc_flags & SC_COMP_PROT && protocol < 0xFF) {
   1271   1.8    paulus 	/* can compress protocol */
   1272   1.8    paulus 	if (mtod(m, u_char *) == cp) {
   1273   1.8    paulus 	    cp[2] = cp[1];	/* move address/control up */
   1274   1.8    paulus 	    cp[1] = cp[0];
   1275   1.8    paulus 	}
   1276  1.81    itojun 	++m->m_data;
   1277  1.81    itojun 	--m->m_len;
   1278   1.8    paulus     }
   1279   1.8    paulus 
   1280  1.37  christos     return m;
   1281  1.37  christos }
   1282  1.37  christos 
   1283  1.66   thorpej #ifndef __HAVE_GENERIC_SOFT_INTERRUPTS
   1284  1.66   thorpej void
   1285  1.66   thorpej pppnetisr(void)
   1286  1.66   thorpej {
   1287  1.66   thorpej 	struct ppp_softc *sc;
   1288  1.66   thorpej 
   1289  1.93        he 	for (sc = LIST_FIRST(&ppp_softc_list); sc != NULL;
   1290  1.91  christos 	    sc = LIST_NEXT(sc, sc_iflist))
   1291  1.66   thorpej 		pppintr(sc);
   1292  1.66   thorpej }
   1293  1.66   thorpej #endif
   1294  1.66   thorpej 
   1295  1.37  christos /*
   1296  1.37  christos  * Software interrupt routine, called at splsoftnet.
   1297  1.37  christos  */
   1298  1.37  christos void
   1299  1.66   thorpej pppintr(void *arg)
   1300  1.37  christos {
   1301  1.66   thorpej 	struct ppp_softc *sc = arg;
   1302  1.66   thorpej 	struct mbuf *m;
   1303  1.66   thorpej 	int s;
   1304  1.37  christos 
   1305  1.37  christos 	if (!(sc->sc_flags & SC_TBUSY)
   1306  1.64   thorpej 	    && (IFQ_IS_EMPTY(&sc->sc_if.if_snd) == 0 || sc->sc_fastq.ifq_head
   1307  1.46  sommerfe 		|| sc->sc_outm)) {
   1308  1.68   thorpej 		s = splhigh();	/* XXX IMP ME HARDER */
   1309  1.66   thorpej 		sc->sc_flags |= SC_TBUSY;
   1310  1.66   thorpej 		splx(s);
   1311  1.66   thorpej 		(*sc->sc_start)(sc);
   1312  1.37  christos 	}
   1313  1.37  christos 	for (;;) {
   1314  1.68   thorpej 		s = splnet();
   1315  1.66   thorpej 		IF_DEQUEUE(&sc->sc_rawq, m);
   1316  1.66   thorpej 		splx(s);
   1317  1.66   thorpej 		if (m == NULL)
   1318  1.66   thorpej 			break;
   1319  1.66   thorpej 		ppp_inproc(sc, m);
   1320  1.37  christos 	}
   1321   1.8    paulus }
   1322   1.8    paulus 
   1323  1.22    paulus #ifdef PPP_COMPRESS
   1324   1.8    paulus /*
   1325  1.22    paulus  * Handle a CCP packet.  `rcvd' is 1 if the packet was received,
   1326  1.22    paulus  * 0 if it is about to be transmitted.
   1327   1.8    paulus  */
   1328  1.28  christos static void
   1329  1.22    paulus ppp_ccp(sc, m, rcvd)
   1330  1.22    paulus     struct ppp_softc *sc;
   1331  1.22    paulus     struct mbuf *m;
   1332  1.22    paulus     int rcvd;
   1333   1.8    paulus {
   1334  1.22    paulus     u_char *dp, *ep;
   1335  1.22    paulus     struct mbuf *mp;
   1336  1.22    paulus     int slen, s;
   1337   1.8    paulus 
   1338  1.22    paulus     /*
   1339  1.22    paulus      * Get a pointer to the data after the PPP header.
   1340  1.22    paulus      */
   1341  1.22    paulus     if (m->m_len <= PPP_HDRLEN) {
   1342  1.22    paulus 	mp = m->m_next;
   1343  1.22    paulus 	if (mp == NULL)
   1344  1.22    paulus 	    return;
   1345  1.22    paulus 	dp = (mp != NULL)? mtod(mp, u_char *): NULL;
   1346  1.22    paulus     } else {
   1347  1.22    paulus 	mp = m;
   1348  1.22    paulus 	dp = mtod(mp, u_char *) + PPP_HDRLEN;
   1349  1.22    paulus     }
   1350   1.8    paulus 
   1351  1.22    paulus     ep = mtod(mp, u_char *) + mp->m_len;
   1352  1.22    paulus     if (dp + CCP_HDRLEN > ep)
   1353   1.8    paulus 	return;
   1354  1.22    paulus     slen = CCP_LENGTH(dp);
   1355  1.22    paulus     if (dp + slen > ep) {
   1356  1.22    paulus 	if (sc->sc_flags & SC_DEBUG)
   1357  1.35  christos 	    printf("if_ppp/ccp: not enough data in mbuf (%p+%x > %p+%x)\n",
   1358  1.34  christos 		dp, slen, mtod(mp, u_char *), mp->m_len);
   1359   1.8    paulus 	return;
   1360   1.8    paulus     }
   1361   1.1   deraadt 
   1362  1.22    paulus     switch (CCP_CODE(dp)) {
   1363  1.22    paulus     case CCP_CONFREQ:
   1364  1.22    paulus     case CCP_TERMREQ:
   1365  1.22    paulus     case CCP_TERMACK:
   1366  1.22    paulus 	/* CCP must be going down - disable compression */
   1367  1.22    paulus 	if (sc->sc_flags & SC_CCP_UP) {
   1368  1.68   thorpej 	    s = splhigh();	/* XXX IMP ME HARDER */
   1369  1.22    paulus 	    sc->sc_flags &= ~(SC_CCP_UP | SC_COMP_RUN | SC_DECOMP_RUN);
   1370  1.22    paulus 	    splx(s);
   1371   1.1   deraadt 	}
   1372  1.22    paulus 	break;
   1373   1.1   deraadt 
   1374  1.22    paulus     case CCP_CONFACK:
   1375  1.22    paulus 	if (sc->sc_flags & SC_CCP_OPEN && !(sc->sc_flags & SC_CCP_UP)
   1376  1.22    paulus 	    && slen >= CCP_HDRLEN + CCP_OPT_MINLEN
   1377  1.22    paulus 	    && slen >= CCP_OPT_LENGTH(dp + CCP_HDRLEN) + CCP_HDRLEN) {
   1378  1.22    paulus 	    if (!rcvd) {
   1379  1.22    paulus 		/* we're agreeing to send compressed packets. */
   1380  1.22    paulus 		if (sc->sc_xc_state != NULL
   1381  1.22    paulus 		    && (*sc->sc_xcomp->comp_init)
   1382  1.22    paulus 			(sc->sc_xc_state, dp + CCP_HDRLEN, slen - CCP_HDRLEN,
   1383  1.31   thorpej 			 sc->sc_unit, 0, sc->sc_flags & SC_DEBUG)) {
   1384  1.68   thorpej 		    s = splhigh();	/* XXX IMP ME HARDER */
   1385  1.22    paulus 		    sc->sc_flags |= SC_COMP_RUN;
   1386  1.22    paulus 		    splx(s);
   1387  1.22    paulus 		}
   1388  1.22    paulus 	    } else {
   1389  1.22    paulus 		/* peer is agreeing to send compressed packets. */
   1390  1.22    paulus 		if (sc->sc_rc_state != NULL
   1391  1.22    paulus 		    && (*sc->sc_rcomp->decomp_init)
   1392  1.22    paulus 			(sc->sc_rc_state, dp + CCP_HDRLEN, slen - CCP_HDRLEN,
   1393  1.31   thorpej 			 sc->sc_unit, 0, sc->sc_mru,
   1394  1.22    paulus 			 sc->sc_flags & SC_DEBUG)) {
   1395  1.68   thorpej 		    s = splhigh();	/* XXX IMP ME HARDER */
   1396  1.22    paulus 		    sc->sc_flags |= SC_DECOMP_RUN;
   1397  1.22    paulus 		    sc->sc_flags &= ~(SC_DC_ERROR | SC_DC_FERROR);
   1398  1.22    paulus 		    splx(s);
   1399  1.22    paulus 		}
   1400   1.1   deraadt 	    }
   1401   1.1   deraadt 	}
   1402  1.22    paulus 	break;
   1403   1.1   deraadt 
   1404  1.22    paulus     case CCP_RESETACK:
   1405  1.22    paulus 	if (sc->sc_flags & SC_CCP_UP) {
   1406  1.22    paulus 	    if (!rcvd) {
   1407  1.22    paulus 		if (sc->sc_xc_state && (sc->sc_flags & SC_COMP_RUN))
   1408  1.22    paulus 		    (*sc->sc_xcomp->comp_reset)(sc->sc_xc_state);
   1409  1.22    paulus 	    } else {
   1410  1.22    paulus 		if (sc->sc_rc_state && (sc->sc_flags & SC_DECOMP_RUN)) {
   1411  1.22    paulus 		    (*sc->sc_rcomp->decomp_reset)(sc->sc_rc_state);
   1412  1.68   thorpej 		    s = splhigh();	/* XXX IMP ME HARDER */
   1413  1.22    paulus 		    sc->sc_flags &= ~SC_DC_ERROR;
   1414  1.22    paulus 		    splx(s);
   1415   1.1   deraadt 		}
   1416   1.1   deraadt 	    }
   1417   1.2    paulus 	}
   1418  1.22    paulus 	break;
   1419   1.1   deraadt     }
   1420   1.1   deraadt }
   1421   1.1   deraadt 
   1422   1.1   deraadt /*
   1423  1.22    paulus  * CCP is down; free (de)compressor state if necessary.
   1424   1.1   deraadt  */
   1425  1.22    paulus static void
   1426  1.22    paulus ppp_ccp_closed(sc)
   1427  1.22    paulus     struct ppp_softc *sc;
   1428   1.1   deraadt {
   1429  1.22    paulus     if (sc->sc_xc_state) {
   1430  1.22    paulus 	(*sc->sc_xcomp->comp_free)(sc->sc_xc_state);
   1431  1.22    paulus 	sc->sc_xc_state = NULL;
   1432  1.22    paulus     }
   1433  1.22    paulus     if (sc->sc_rc_state) {
   1434  1.22    paulus 	(*sc->sc_rcomp->decomp_free)(sc->sc_rc_state);
   1435  1.22    paulus 	sc->sc_rc_state = NULL;
   1436   1.1   deraadt     }
   1437   1.1   deraadt }
   1438  1.22    paulus #endif /* PPP_COMPRESS */
   1439   1.1   deraadt 
   1440   1.1   deraadt /*
   1441   1.8    paulus  * PPP packet input routine.
   1442  1.13    paulus  * The caller has checked and removed the FCS and has inserted
   1443  1.13    paulus  * the address/control bytes and the protocol high byte if they
   1444  1.22    paulus  * were omitted.
   1445  1.22    paulus  */
   1446  1.22    paulus void
   1447  1.22    paulus ppppktin(sc, m, lost)
   1448  1.22    paulus     struct ppp_softc *sc;
   1449  1.22    paulus     struct mbuf *m;
   1450  1.22    paulus     int lost;
   1451  1.22    paulus {
   1452  1.68   thorpej     int s = splhigh();	/* XXX IMP ME HARDER */
   1453  1.22    paulus 
   1454  1.22    paulus     if (lost)
   1455  1.22    paulus 	m->m_flags |= M_ERRMARK;
   1456  1.22    paulus     IF_ENQUEUE(&sc->sc_rawq, m);
   1457  1.66   thorpej #ifdef __HAVE_GENERIC_SOFT_INTERRUPTS
   1458  1.66   thorpej     softintr_schedule(sc->sc_si);
   1459  1.66   thorpej #else
   1460  1.22    paulus     schednetisr(NETISR_PPP);
   1461  1.66   thorpej #endif
   1462  1.22    paulus     splx(s);
   1463  1.22    paulus }
   1464  1.22    paulus 
   1465  1.22    paulus /*
   1466  1.22    paulus  * Process a received PPP packet, doing decompression as necessary.
   1467  1.22    paulus  * Should be called at splsoftnet.
   1468   1.1   deraadt  */
   1469   1.1   deraadt #define COMPTYPE(proto)	((proto) == PPP_VJC_COMP? TYPE_COMPRESSED_TCP: \
   1470   1.1   deraadt 			 TYPE_UNCOMPRESSED_TCP)
   1471   1.1   deraadt 
   1472  1.22    paulus static void
   1473  1.22    paulus ppp_inproc(sc, m)
   1474   1.8    paulus     struct ppp_softc *sc;
   1475   1.8    paulus     struct mbuf *m;
   1476   1.8    paulus {
   1477  1.24   mycroft     struct ifnet *ifp = &sc->sc_if;
   1478   1.8    paulus     struct ifqueue *inq;
   1479  1.59    itojun     int s, ilen, proto, rv;
   1480  1.13    paulus     u_char *cp, adrs, ctrl;
   1481  1.29    paulus     struct mbuf *mp, *dmp = NULL;
   1482  1.59    itojun #ifdef VJC
   1483  1.59    itojun     int xlen;
   1484  1.22    paulus     u_char *iphdr;
   1485  1.22    paulus     u_int hlen;
   1486  1.59    itojun #endif
   1487   1.8    paulus 
   1488  1.29    paulus     sc->sc_stats.ppp_ipackets++;
   1489  1.22    paulus 
   1490  1.22    paulus     if (sc->sc_flags & SC_LOG_INPKT) {
   1491  1.81    itojun 	ilen = 0;
   1492  1.81    itojun 	for (mp = m; mp != NULL; mp = mp->m_next)
   1493  1.81    itojun 	    ilen += mp->m_len;
   1494  1.35  christos 	printf("%s: got %d bytes\n", ifp->if_xname, ilen);
   1495  1.22    paulus 	pppdumpm(m);
   1496  1.22    paulus     }
   1497   1.8    paulus 
   1498  1.13    paulus     cp = mtod(m, u_char *);
   1499  1.22    paulus     adrs = PPP_ADDRESS(cp);
   1500  1.22    paulus     ctrl = PPP_CONTROL(cp);
   1501  1.22    paulus     proto = PPP_PROTOCOL(cp);
   1502  1.22    paulus 
   1503  1.22    paulus     if (m->m_flags & M_ERRMARK) {
   1504  1.22    paulus 	m->m_flags &= ~M_ERRMARK;
   1505  1.68   thorpej 	s = splhigh();	/* XXX IMP ME HARDER */
   1506  1.22    paulus 	sc->sc_flags |= SC_VJ_RESET;
   1507  1.22    paulus 	splx(s);
   1508  1.22    paulus     }
   1509  1.22    paulus 
   1510  1.22    paulus #ifdef PPP_COMPRESS
   1511  1.22    paulus     /*
   1512  1.22    paulus      * Decompress this packet if necessary, update the receiver's
   1513  1.22    paulus      * dictionary, or take appropriate action on a CCP packet.
   1514  1.22    paulus      */
   1515  1.22    paulus     if (proto == PPP_COMP && sc->sc_rc_state && (sc->sc_flags & SC_DECOMP_RUN)
   1516  1.22    paulus 	&& !(sc->sc_flags & SC_DC_ERROR) && !(sc->sc_flags & SC_DC_FERROR)) {
   1517  1.22    paulus 	/* decompress this packet */
   1518  1.22    paulus 	rv = (*sc->sc_rcomp->decompress)(sc->sc_rc_state, m, &dmp);
   1519  1.22    paulus 	if (rv == DECOMP_OK) {
   1520  1.22    paulus 	    m_freem(m);
   1521  1.22    paulus 	    if (dmp == NULL) {
   1522  1.22    paulus 		/* no error, but no decompressed packet produced */
   1523  1.22    paulus 		return;
   1524  1.22    paulus 	    }
   1525  1.22    paulus 	    m = dmp;
   1526  1.22    paulus 	    cp = mtod(m, u_char *);
   1527  1.22    paulus 	    proto = PPP_PROTOCOL(cp);
   1528  1.22    paulus 
   1529  1.22    paulus 	} else {
   1530  1.22    paulus 	    /*
   1531  1.22    paulus 	     * An error has occurred in decompression.
   1532  1.22    paulus 	     * Pass the compressed packet up to pppd, which may take
   1533  1.22    paulus 	     * CCP down or issue a Reset-Req.
   1534  1.22    paulus 	     */
   1535  1.22    paulus 	    if (sc->sc_flags & SC_DEBUG)
   1536  1.35  christos 		printf("%s: decompress failed %d\n", ifp->if_xname, rv);
   1537  1.68   thorpej 	    s = splhigh();	/* XXX IMP ME HARDER */
   1538  1.22    paulus 	    sc->sc_flags |= SC_VJ_RESET;
   1539  1.22    paulus 	    if (rv == DECOMP_ERROR)
   1540  1.22    paulus 		sc->sc_flags |= SC_DC_ERROR;
   1541  1.22    paulus 	    else
   1542  1.22    paulus 		sc->sc_flags |= SC_DC_FERROR;
   1543  1.22    paulus 	    splx(s);
   1544  1.22    paulus 	}
   1545  1.22    paulus 
   1546  1.22    paulus     } else {
   1547  1.22    paulus 	if (sc->sc_rc_state && (sc->sc_flags & SC_DECOMP_RUN)) {
   1548  1.22    paulus 	    (*sc->sc_rcomp->incomp)(sc->sc_rc_state, m);
   1549  1.22    paulus 	}
   1550  1.22    paulus 	if (proto == PPP_CCP) {
   1551  1.22    paulus 	    ppp_ccp(sc, m, 1);
   1552  1.22    paulus 	}
   1553  1.22    paulus     }
   1554  1.22    paulus #endif
   1555  1.27        pk 
   1556  1.81    itojun     ilen = 0;
   1557  1.81    itojun     for (mp = m; mp != NULL; mp = mp->m_next)
   1558  1.81    itojun 	ilen += mp->m_len;
   1559   1.8    paulus 
   1560   1.8    paulus #ifdef VJC
   1561  1.22    paulus     if (sc->sc_flags & SC_VJ_RESET) {
   1562  1.22    paulus 	/*
   1563  1.22    paulus 	 * If we've missed a packet, we must toss subsequent compressed
   1564  1.22    paulus 	 * packets which don't have an explicit connection ID.
   1565  1.22    paulus 	 */
   1566  1.29    paulus 	if (sc->sc_comp)
   1567  1.29    paulus 	    sl_uncompress_tcp(NULL, 0, TYPE_ERROR, sc->sc_comp);
   1568  1.68   thorpej 	s = splhigh();	/* XXX IMP ME HARDER */
   1569  1.22    paulus 	sc->sc_flags &= ~SC_VJ_RESET;
   1570  1.22    paulus 	splx(s);
   1571  1.22    paulus     }
   1572  1.22    paulus 
   1573   1.8    paulus     /*
   1574   1.8    paulus      * See if we have a VJ-compressed packet to uncompress.
   1575   1.8    paulus      */
   1576  1.22    paulus     if (proto == PPP_VJC_COMP) {
   1577  1.29    paulus 	if ((sc->sc_flags & SC_REJ_COMP_TCP) || sc->sc_comp == 0)
   1578  1.22    paulus 	    goto bad;
   1579  1.22    paulus 
   1580  1.22    paulus 	xlen = sl_uncompress_tcp_core(cp + PPP_HDRLEN, m->m_len - PPP_HDRLEN,
   1581  1.22    paulus 				      ilen - PPP_HDRLEN, TYPE_COMPRESSED_TCP,
   1582  1.29    paulus 				      sc->sc_comp, &iphdr, &hlen);
   1583   1.8    paulus 
   1584  1.22    paulus 	if (xlen <= 0) {
   1585   1.8    paulus 	    if (sc->sc_flags & SC_DEBUG)
   1586  1.35  christos 		printf("%s: VJ uncompress failed on type comp\n",
   1587  1.34  christos 		    ifp->if_xname);
   1588  1.22    paulus 	    goto bad;
   1589  1.17    paulus 	}
   1590  1.17    paulus 
   1591  1.22    paulus 	/* Copy the PPP and IP headers into a new mbuf. */
   1592  1.22    paulus 	MGETHDR(mp, M_DONTWAIT, MT_DATA);
   1593  1.22    paulus 	if (mp == NULL)
   1594  1.22    paulus 	    goto bad;
   1595  1.22    paulus 	mp->m_len = 0;
   1596  1.81    itojun 	mp->m_next = NULL;
   1597  1.22    paulus 	if (hlen + PPP_HDRLEN > MHLEN) {
   1598  1.22    paulus 	    MCLGET(mp, M_DONTWAIT);
   1599  1.22    paulus 	    if (M_TRAILINGSPACE(mp) < hlen + PPP_HDRLEN) {
   1600  1.22    paulus 		m_freem(mp);
   1601  1.22    paulus 		goto bad;	/* lose if big headers and no clusters */
   1602  1.22    paulus 	    }
   1603   1.8    paulus 	}
   1604  1.22    paulus 	cp = mtod(mp, u_char *);
   1605  1.22    paulus 	cp[0] = adrs;
   1606  1.22    paulus 	cp[1] = ctrl;
   1607  1.22    paulus 	cp[2] = 0;
   1608  1.22    paulus 	cp[3] = PPP_IP;
   1609  1.22    paulus 	proto = PPP_IP;
   1610  1.22    paulus 	bcopy(iphdr, cp + PPP_HDRLEN, hlen);
   1611  1.22    paulus 	mp->m_len = hlen + PPP_HDRLEN;
   1612  1.22    paulus 
   1613  1.22    paulus 	/*
   1614  1.22    paulus 	 * Trim the PPP and VJ headers off the old mbuf
   1615  1.22    paulus 	 * and stick the new and old mbufs together.
   1616  1.22    paulus 	 */
   1617  1.22    paulus 	m->m_data += PPP_HDRLEN + xlen;
   1618  1.22    paulus 	m->m_len -= PPP_HDRLEN + xlen;
   1619  1.22    paulus 	if (m->m_len <= M_TRAILINGSPACE(mp)) {
   1620  1.22    paulus 	    bcopy(mtod(m, u_char *), mtod(mp, u_char *) + mp->m_len, m->m_len);
   1621  1.22    paulus 	    mp->m_len += m->m_len;
   1622  1.22    paulus 	    MFREE(m, mp->m_next);
   1623  1.22    paulus 	} else
   1624  1.22    paulus 	    mp->m_next = m;
   1625  1.22    paulus 	m = mp;
   1626  1.22    paulus 	ilen += hlen - xlen;
   1627   1.8    paulus 
   1628  1.22    paulus     } else if (proto == PPP_VJC_UNCOMP) {
   1629  1.29    paulus 	if ((sc->sc_flags & SC_REJ_COMP_TCP) || sc->sc_comp == 0)
   1630  1.22    paulus 	    goto bad;
   1631  1.22    paulus 
   1632  1.22    paulus 	xlen = sl_uncompress_tcp_core(cp + PPP_HDRLEN, m->m_len - PPP_HDRLEN,
   1633  1.22    paulus 				      ilen - PPP_HDRLEN, TYPE_UNCOMPRESSED_TCP,
   1634  1.29    paulus 				      sc->sc_comp, &iphdr, &hlen);
   1635   1.8    paulus 
   1636  1.22    paulus 	if (xlen < 0) {
   1637   1.8    paulus 	    if (sc->sc_flags & SC_DEBUG)
   1638  1.35  christos 		printf("%s: VJ uncompress failed on type uncomp\n",
   1639  1.34  christos 		    ifp->if_xname);
   1640  1.22    paulus 	    goto bad;
   1641   1.8    paulus 	}
   1642   1.8    paulus 
   1643   1.8    paulus 	proto = PPP_IP;
   1644  1.13    paulus 	cp[3] = PPP_IP;
   1645   1.8    paulus     }
   1646   1.8    paulus #endif /* VJC */
   1647   1.8    paulus 
   1648  1.13    paulus     /*
   1649  1.13    paulus      * If the packet will fit in a header mbuf, don't waste a
   1650  1.13    paulus      * whole cluster on it.
   1651  1.13    paulus      */
   1652  1.22    paulus     if (ilen <= MHLEN && M_IS_CLUSTER(m)) {
   1653  1.13    paulus 	MGETHDR(mp, M_DONTWAIT, MT_DATA);
   1654  1.13    paulus 	if (mp != NULL) {
   1655  1.13    paulus 	    m_copydata(m, 0, ilen, mtod(mp, caddr_t));
   1656  1.13    paulus 	    m_freem(m);
   1657  1.13    paulus 	    m = mp;
   1658  1.13    paulus 	    m->m_len = ilen;
   1659  1.13    paulus 	}
   1660   1.8    paulus     }
   1661   1.8    paulus     m->m_pkthdr.len = ilen;
   1662  1.24   mycroft     m->m_pkthdr.rcvif = ifp;
   1663   1.8    paulus 
   1664  1.29    paulus     if ((proto & 0x8000) == 0) {
   1665  1.37  christos #ifdef PPP_FILTER
   1666  1.37  christos 	/*
   1667  1.37  christos 	 * See whether we want to pass this packet, and
   1668  1.37  christos 	 * if it counts as link activity.
   1669  1.37  christos 	 */
   1670  1.52   thorpej 	if (sc->sc_pass_filt_in.bf_insns != 0
   1671  1.52   thorpej 	    && bpf_filter(sc->sc_pass_filt_in.bf_insns, (u_char *) m,
   1672  1.29    paulus 			  ilen, 0) == 0) {
   1673  1.29    paulus 	    /* drop this packet */
   1674  1.29    paulus 	    m_freem(m);
   1675  1.29    paulus 	    return;
   1676  1.29    paulus 	}
   1677  1.52   thorpej 	if (sc->sc_active_filt_in.bf_insns == 0
   1678  1.52   thorpej 	    || bpf_filter(sc->sc_active_filt_in.bf_insns, (u_char *) m,
   1679  1.52   thorpej 	    		  ilen, 0))
   1680  1.29    paulus 	    sc->sc_last_recv = time.tv_sec;
   1681  1.37  christos #else
   1682  1.37  christos 	/*
   1683  1.37  christos 	 * Record the time that we received this packet.
   1684  1.37  christos 	 */
   1685  1.37  christos 	sc->sc_last_recv = time.tv_sec;
   1686  1.37  christos #endif /* PPP_FILTER */
   1687  1.29    paulus     }
   1688  1.51   thorpej 
   1689   1.8    paulus #if NBPFILTER > 0
   1690   1.8    paulus     /* See if bpf wants to look at the packet. */
   1691  1.63   thorpej     if (sc->sc_if.if_bpf)
   1692  1.63   thorpej 	bpf_mtap(sc->sc_if.if_bpf, m);
   1693   1.8    paulus #endif
   1694   1.8    paulus 
   1695  1.22    paulus     rv = 0;
   1696   1.8    paulus     switch (proto) {
   1697   1.8    paulus #ifdef INET
   1698   1.8    paulus     case PPP_IP:
   1699   1.8    paulus 	/*
   1700   1.8    paulus 	 * IP packet - take off the ppp header and pass it up to IP.
   1701   1.8    paulus 	 */
   1702  1.24   mycroft 	if ((ifp->if_flags & IFF_UP) == 0
   1703  1.22    paulus 	    || sc->sc_npmode[NP_IP] != NPMODE_PASS) {
   1704   1.8    paulus 	    /* interface is down - drop the packet. */
   1705   1.8    paulus 	    m_freem(m);
   1706  1.22    paulus 	    return;
   1707   1.8    paulus 	}
   1708   1.8    paulus 	m->m_pkthdr.len -= PPP_HDRLEN;
   1709   1.8    paulus 	m->m_data += PPP_HDRLEN;
   1710   1.8    paulus 	m->m_len -= PPP_HDRLEN;
   1711  1.45   thorpej #ifdef GATEWAY
   1712  1.45   thorpej 	if (ipflow_fastforward(m))
   1713  1.45   thorpej 		return;
   1714  1.45   thorpej #endif
   1715   1.8    paulus 	schednetisr(NETISR_IP);
   1716   1.8    paulus 	inq = &ipintrq;
   1717  1.55    itojun 	break;
   1718  1.55    itojun #endif
   1719  1.55    itojun 
   1720  1.55    itojun #ifdef INET6
   1721  1.55    itojun     case PPP_IPV6:
   1722  1.55    itojun 	/*
   1723  1.55    itojun 	 * IPv6 packet - take off the ppp header and pass it up to IPv6.
   1724  1.55    itojun 	 */
   1725  1.55    itojun 	if ((ifp->if_flags & IFF_UP) == 0
   1726  1.55    itojun 	    || sc->sc_npmode[NP_IPV6] != NPMODE_PASS) {
   1727  1.55    itojun 	    /* interface is down - drop the packet. */
   1728  1.55    itojun 	    m_freem(m);
   1729  1.55    itojun 	    return;
   1730  1.55    itojun 	}
   1731  1.55    itojun 	m->m_pkthdr.len -= PPP_HDRLEN;
   1732  1.55    itojun 	m->m_data += PPP_HDRLEN;
   1733  1.55    itojun 	m->m_len -= PPP_HDRLEN;
   1734  1.55    itojun 	schednetisr(NETISR_IPV6);
   1735  1.55    itojun 	inq = &ip6intrq;
   1736   1.8    paulus 	break;
   1737   1.8    paulus #endif
   1738   1.8    paulus 
   1739   1.8    paulus     default:
   1740   1.8    paulus 	/*
   1741   1.8    paulus 	 * Some other protocol - place on input queue for read().
   1742   1.8    paulus 	 */
   1743   1.8    paulus 	inq = &sc->sc_inq;
   1744   1.8    paulus 	rv = 1;
   1745   1.8    paulus 	break;
   1746   1.8    paulus     }
   1747   1.8    paulus 
   1748   1.8    paulus     /*
   1749   1.8    paulus      * Put the packet on the appropriate input queue.
   1750   1.8    paulus      */
   1751  1.68   thorpej     s = splnet();
   1752   1.8    paulus     if (IF_QFULL(inq)) {
   1753   1.8    paulus 	IF_DROP(inq);
   1754  1.22    paulus 	splx(s);
   1755   1.8    paulus 	if (sc->sc_flags & SC_DEBUG)
   1756  1.35  christos 	    printf("%s: input queue full\n", ifp->if_xname);
   1757  1.24   mycroft 	ifp->if_iqdrops++;
   1758  1.22    paulus 	goto bad;
   1759  1.22    paulus     }
   1760  1.22    paulus     IF_ENQUEUE(inq, m);
   1761   1.8    paulus     splx(s);
   1762  1.29    paulus     ifp->if_ipackets++;
   1763  1.29    paulus     ifp->if_ibytes += ilen;
   1764   1.1   deraadt 
   1765  1.22    paulus     if (rv)
   1766  1.22    paulus 	(*sc->sc_ctlp)(sc);
   1767   1.1   deraadt 
   1768   1.1   deraadt     return;
   1769   1.1   deraadt 
   1770  1.22    paulus  bad:
   1771  1.22    paulus     m_freem(m);
   1772  1.22    paulus     sc->sc_if.if_ierrors++;
   1773  1.29    paulus     sc->sc_stats.ppp_ierrors++;
   1774   1.1   deraadt }
   1775   1.1   deraadt 
   1776   1.1   deraadt #define MAX_DUMP_BYTES	128
   1777   1.1   deraadt 
   1778   1.1   deraadt static void
   1779  1.22    paulus pppdumpm(m0)
   1780   1.1   deraadt     struct mbuf *m0;
   1781   1.1   deraadt {
   1782   1.8    paulus     char buf[3*MAX_DUMP_BYTES+4];
   1783   1.1   deraadt     char *bp = buf;
   1784   1.1   deraadt     struct mbuf *m;
   1785   1.1   deraadt     static char digits[] = "0123456789abcdef";
   1786   1.1   deraadt 
   1787  1.22    paulus     for (m = m0; m; m = m->m_next) {
   1788   1.1   deraadt 	int l = m->m_len;
   1789   1.1   deraadt 	u_char *rptr = (u_char *)m->m_data;
   1790   1.1   deraadt 
   1791   1.1   deraadt 	while (l--) {
   1792   1.1   deraadt 	    if (bp > buf + sizeof(buf) - 4)
   1793   1.1   deraadt 		goto done;
   1794   1.1   deraadt 	    *bp++ = digits[*rptr >> 4]; /* convert byte to ascii hex */
   1795   1.1   deraadt 	    *bp++ = digits[*rptr++ & 0xf];
   1796   1.1   deraadt 	}
   1797   1.1   deraadt 
   1798   1.1   deraadt 	if (m->m_next) {
   1799   1.1   deraadt 	    if (bp > buf + sizeof(buf) - 3)
   1800   1.1   deraadt 		goto done;
   1801   1.1   deraadt 	    *bp++ = '|';
   1802   1.8    paulus 	} else
   1803   1.8    paulus 	    *bp++ = ' ';
   1804   1.1   deraadt     }
   1805   1.1   deraadt done:
   1806  1.22    paulus     if (m)
   1807   1.1   deraadt 	*bp++ = '>';
   1808   1.1   deraadt     *bp = 0;
   1809  1.35  christos     printf("%s\n", buf);
   1810   1.1   deraadt }
   1811  1.75    itojun 
   1812  1.75    itojun #ifdef ALTQ
   1813  1.75    itojun /*
   1814  1.75    itojun  * a wrapper to transmit a packet from if_start since ALTQ uses
   1815  1.75    itojun  * if_start to send a packet.
   1816  1.75    itojun  */
   1817  1.75    itojun static void
   1818  1.75    itojun ppp_ifstart(ifp)
   1819  1.75    itojun 	struct ifnet *ifp;
   1820  1.75    itojun {
   1821  1.75    itojun 	struct ppp_softc *sc;
   1822  1.75    itojun 
   1823  1.75    itojun 	sc = ifp->if_softc;
   1824  1.75    itojun 	(*sc->sc_start)(sc);
   1825  1.75    itojun }
   1826  1.75    itojun #endif
   1827