Home | History | Annotate | Line # | Download | only in net
if_ppp.c revision 1.125
      1  1.125      cube /*	$NetBSD: if_ppp.c,v 1.125 2008/11/25 02:40:36 cube 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.125      cube __KERNEL_RCSID(0, "$NetBSD: if_ppp.c,v 1.125 2008/11/25 02:40:36 cube 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.125      cube #include <sys/module.h>
    128  1.125      cube #include <sys/mutex.h>
    129  1.102   thorpej #include <sys/conf.h>
    130  1.106      elad #include <sys/kauth.h>
    131  1.118        ad #include <sys/intr.h>
    132  1.120        ad #include <sys/simplelock.h>
    133  1.122        ad #include <sys/socketvar.h>
    134   1.22    paulus 
    135    1.5   mycroft #include <net/if.h>
    136    1.5   mycroft #include <net/if_types.h>
    137    1.5   mycroft #include <net/netisr.h>
    138    1.5   mycroft #include <net/route.h>
    139   1.37  christos #ifdef PPP_FILTER
    140   1.29    paulus #include <net/bpf.h>
    141   1.37  christos #endif
    142    1.5   mycroft 
    143    1.5   mycroft #include <netinet/in.h>
    144    1.5   mycroft #include <netinet/in_systm.h>
    145    1.5   mycroft #include <netinet/in_var.h>
    146   1.59    itojun #ifdef INET
    147    1.5   mycroft #include <netinet/ip.h>
    148    1.1   deraadt #endif
    149    1.1   deraadt 
    150    1.2    paulus #include "bpfilter.h"
    151    1.2    paulus #if NBPFILTER > 0
    152    1.5   mycroft #include <net/bpf.h>
    153    1.2    paulus #endif
    154    1.2    paulus 
    155   1.47  christos #if defined(PPP_FILTER) || NBPFILTER > 0
    156   1.47  christos #include <net/slip.h>
    157   1.47  christos #endif
    158   1.47  christos 
    159    1.1   deraadt #ifdef VJC
    160    1.8    paulus #include <net/slcompress.h>
    161    1.1   deraadt #endif
    162    1.1   deraadt 
    163   1.22    paulus #include <net/ppp_defs.h>
    164    1.8    paulus #include <net/if_ppp.h>
    165   1.22    paulus #include <net/if_pppvar.h>
    166  1.119        ad #include <sys/cpu.h>
    167    1.1   deraadt 
    168   1.22    paulus #ifdef PPP_COMPRESS
    169   1.22    paulus #define PACKETPTR	struct mbuf *
    170   1.22    paulus #include <net/ppp-comp.h>
    171   1.22    paulus #endif
    172    1.1   deraadt 
    173  1.113  christos static int	pppsioctl(struct ifnet *, u_long, void *);
    174  1.103   thorpej static void	ppp_requeue(struct ppp_softc *);
    175  1.103   thorpej static void	ppp_ccp(struct ppp_softc *, struct mbuf *m, int rcvd);
    176  1.103   thorpej static void	ppp_ccp_closed(struct ppp_softc *);
    177  1.103   thorpej static void	ppp_inproc(struct ppp_softc *, struct mbuf *);
    178  1.103   thorpej static void	pppdumpm(struct mbuf *m0);
    179   1.75    itojun #ifdef ALTQ
    180  1.103   thorpej static void	ppp_ifstart(struct ifnet *ifp);
    181   1.75    itojun #endif
    182    1.1   deraadt 
    183  1.103   thorpej static void	pppintr(void *);
    184   1.66   thorpej 
    185    1.1   deraadt /*
    186    1.1   deraadt  * Some useful mbuf macros not in mbuf.h.
    187    1.1   deraadt  */
    188   1.22    paulus #define M_IS_CLUSTER(m)	((m)->m_flags & M_EXT)
    189   1.22    paulus 
    190    1.1   deraadt #define M_DATASTART(m)	\
    191   1.22    paulus 	(M_IS_CLUSTER(m) ? (m)->m_ext.ext_buf : \
    192    1.1   deraadt 	    (m)->m_flags & M_PKTHDR ? (m)->m_pktdat : (m)->m_dat)
    193    1.1   deraadt 
    194    1.1   deraadt #define M_DATASIZE(m)	\
    195   1.22    paulus 	(M_IS_CLUSTER(m) ? (m)->m_ext.ext_size : \
    196    1.1   deraadt 	    (m)->m_flags & M_PKTHDR ? MHLEN: MLEN)
    197    1.1   deraadt 
    198    1.1   deraadt /*
    199   1.50   thorpej  * We define two link layer specific mbuf flags, to mark high-priority
    200   1.50   thorpej  * packets for output, and received packets following lost/corrupted
    201   1.50   thorpej  * packets.
    202    1.2    paulus  */
    203   1.50   thorpej #define	M_HIGHPRI	M_LINK0	/* output packet for sc_fastq */
    204   1.50   thorpej #define	M_ERRMARK	M_LINK1	/* rx packet following lost/corrupted pkt */
    205   1.77      matt 
    206   1.91  christos static int		ppp_clone_create(struct if_clone *, int);
    207   1.91  christos static int		ppp_clone_destroy(struct ifnet *);
    208   1.91  christos 
    209   1.91  christos static struct ppp_softc *ppp_create(const char *, int);
    210   1.91  christos 
    211   1.91  christos static LIST_HEAD(, ppp_softc) ppp_softc_list;
    212   1.91  christos 
    213   1.91  christos struct if_clone ppp_cloner =
    214   1.91  christos     IF_CLONE_INITIALIZER("ppp", ppp_clone_create, ppp_clone_destroy);
    215   1.91  christos 
    216   1.91  christos static struct simplelock ppp_list_mutex = SIMPLELOCK_INITIALIZER;
    217    1.2    paulus 
    218   1.22    paulus #ifdef PPP_COMPRESS
    219  1.125      cube static LIST_HEAD(, compressor) ppp_compressors = { NULL };
    220  1.125      cube static kmutex_t ppp_compressors_mtx;
    221   1.22    paulus 
    222  1.125      cube static struct compressor *ppp_get_compressor(uint8_t);
    223   1.22    paulus #endif /* PPP_COMPRESS */
    224    1.2    paulus 
    225   1.37  christos 
    226    1.2    paulus /*
    227    1.1   deraadt  * Called from boot code to establish ppp interfaces.
    228    1.1   deraadt  */
    229    1.1   deraadt void
    230   1.92  christos pppattach(void)
    231    1.1   deraadt {
    232  1.102   thorpej     extern struct linesw ppp_disc;
    233  1.102   thorpej 
    234  1.102   thorpej     if (ttyldisc_attach(&ppp_disc) != 0)
    235  1.102   thorpej     	panic("pppattach");
    236   1.91  christos     LIST_INIT(&ppp_softc_list);
    237   1.91  christos     if_clone_attach(&ppp_cloner);
    238  1.125      cube     mutex_init(&ppp_compressors_mtx, MUTEX_DEFAULT, IPL_NONE);
    239   1.91  christos }
    240   1.91  christos 
    241   1.91  christos static struct ppp_softc *
    242   1.91  christos ppp_create(const char *name, int unit)
    243   1.91  christos {
    244   1.91  christos     struct ppp_softc *sc, *sci, *scl = NULL;
    245   1.91  christos 
    246   1.91  christos     MALLOC(sc, struct ppp_softc *, sizeof(*sc), M_DEVBUF, M_WAIT|M_ZERO);
    247   1.91  christos 
    248   1.91  christos     simple_lock(&ppp_list_mutex);
    249   1.91  christos     if (unit == -1) {
    250   1.91  christos 	int i = 0;
    251   1.91  christos 	LIST_FOREACH(sci, &ppp_softc_list, sc_iflist) {
    252   1.91  christos 	    scl = sci;
    253   1.91  christos 	    if (i < sci->sc_unit) {
    254   1.91  christos 		unit = i;
    255   1.91  christos 		break;
    256   1.91  christos 	    } else {
    257   1.91  christos #ifdef DIAGNOSTIC
    258   1.91  christos 		KASSERT(i == sci->sc_unit);
    259   1.91  christos #endif
    260   1.91  christos 		i++;
    261   1.91  christos 	    }
    262   1.91  christos 	}
    263   1.91  christos 	if (unit == -1)
    264   1.91  christos 	    unit = i;
    265   1.91  christos     } else {
    266   1.91  christos 	LIST_FOREACH(sci, &ppp_softc_list, sc_iflist) {
    267   1.91  christos 	    scl = sci;
    268   1.91  christos 	    if (unit < sci->sc_unit)
    269   1.91  christos 		break;
    270   1.91  christos 	    else if (unit == sci->sc_unit) {
    271   1.91  christos 		FREE(sc, M_DEVBUF);
    272   1.91  christos 		return NULL;
    273   1.91  christos 	    }
    274   1.91  christos 	}
    275   1.91  christos     }
    276    1.1   deraadt 
    277   1.91  christos     if (sci != NULL)
    278   1.91  christos 	LIST_INSERT_BEFORE(sci, sc, sc_iflist);
    279   1.91  christos     else if (scl != NULL)
    280   1.91  christos 	LIST_INSERT_AFTER(scl, sc, sc_iflist);
    281   1.91  christos     else
    282   1.91  christos 	LIST_INSERT_HEAD(&ppp_softc_list, sc, sc_iflist);
    283   1.91  christos 
    284   1.91  christos     simple_unlock(&ppp_list_mutex);
    285   1.91  christos 
    286  1.123  christos     if_initname(&sc->sc_if, name, sc->sc_unit = unit);
    287  1.115        ad     callout_init(&sc->sc_timo_ch, 0);
    288   1.91  christos     sc->sc_if.if_softc = sc;
    289   1.91  christos     sc->sc_if.if_mtu = PPP_MTU;
    290   1.91  christos     sc->sc_if.if_flags = IFF_POINTOPOINT | IFF_MULTICAST;
    291   1.91  christos     sc->sc_if.if_type = IFT_PPP;
    292   1.91  christos     sc->sc_if.if_hdrlen = PPP_HDRLEN;
    293   1.91  christos     sc->sc_if.if_dlt = DLT_NULL;
    294   1.91  christos     sc->sc_if.if_ioctl = pppsioctl;
    295   1.91  christos     sc->sc_if.if_output = pppoutput;
    296   1.75    itojun #ifdef ALTQ
    297   1.91  christos     sc->sc_if.if_start = ppp_ifstart;
    298   1.75    itojun #endif
    299   1.91  christos     IFQ_SET_MAXLEN(&sc->sc_if.if_snd, IFQ_MAXLEN);
    300   1.91  christos     sc->sc_inq.ifq_maxlen = IFQ_MAXLEN;
    301   1.91  christos     sc->sc_fastq.ifq_maxlen = IFQ_MAXLEN;
    302   1.91  christos     sc->sc_rawq.ifq_maxlen = IFQ_MAXLEN;
    303  1.104  christos     /* Ratio of 1:2 packets between the regular and the fast queue */
    304  1.104  christos     sc->sc_maxfastq = 2;
    305   1.91  christos     IFQ_SET_READY(&sc->sc_if.if_snd);
    306   1.91  christos     if_attach(&sc->sc_if);
    307   1.91  christos     if_alloc_sadl(&sc->sc_if);
    308    1.2    paulus #if NBPFILTER > 0
    309   1.91  christos     bpfattach(&sc->sc_if, DLT_NULL, 0);
    310    1.2    paulus #endif
    311   1.91  christos     return sc;
    312   1.91  christos }
    313   1.91  christos 
    314   1.91  christos static int
    315   1.91  christos ppp_clone_create(struct if_clone *ifc, int unit)
    316   1.91  christos {
    317   1.91  christos     return ppp_create(ifc->ifc_name, unit) == NULL ? EEXIST : 0;
    318   1.91  christos }
    319   1.91  christos 
    320   1.91  christos static int
    321   1.91  christos ppp_clone_destroy(struct ifnet *ifp)
    322   1.91  christos {
    323   1.91  christos     struct ppp_softc *sc = (struct ppp_softc *)ifp->if_softc;
    324   1.91  christos 
    325   1.91  christos     if (sc->sc_devp != NULL)
    326   1.91  christos 	return EBUSY; /* Not removing it */
    327   1.91  christos 
    328   1.91  christos     simple_lock(&ppp_list_mutex);
    329   1.91  christos     LIST_REMOVE(sc, sc_iflist);
    330   1.91  christos     simple_unlock(&ppp_list_mutex);
    331   1.91  christos 
    332   1.94     peter #if NBPFILTER > 0
    333   1.94     peter     bpfdetach(ifp);
    334   1.94     peter #endif
    335   1.91  christos     if_detach(ifp);
    336   1.91  christos 
    337   1.91  christos     FREE(sc, M_DEVBUF);
    338   1.91  christos     return 0;
    339    1.1   deraadt }
    340    1.1   deraadt 
    341    1.1   deraadt /*
    342    1.8    paulus  * Allocate a ppp interface unit and initialize it.
    343    1.8    paulus  */
    344    1.8    paulus struct ppp_softc *
    345  1.103   thorpej pppalloc(pid_t pid)
    346    1.8    paulus {
    347   1.91  christos     struct ppp_softc *sc = NULL, *scf;
    348   1.91  christos     int i;
    349    1.8    paulus 
    350   1.91  christos     simple_lock(&ppp_list_mutex);
    351   1.96     perry     for (scf = LIST_FIRST(&ppp_softc_list); scf != NULL;
    352   1.91  christos 	scf = LIST_NEXT(scf, sc_iflist)) {
    353   1.91  christos 	if (scf->sc_xfer == pid) {
    354   1.91  christos 	    scf->sc_xfer = 0;
    355   1.91  christos 	    simple_unlock(&ppp_list_mutex);
    356   1.91  christos 	    return scf;
    357   1.22    paulus 	}
    358   1.91  christos 	if (scf->sc_devp == NULL && sc == NULL)
    359   1.91  christos 	    sc = scf;
    360   1.91  christos     }
    361   1.95  christos     simple_unlock(&ppp_list_mutex);
    362   1.91  christos 
    363   1.91  christos     if (sc == NULL)
    364   1.91  christos 	sc = ppp_create(ppp_cloner.ifc_name, -1);
    365    1.8    paulus 
    366  1.118        ad     sc->sc_si = softint_establish(SOFTINT_NET, pppintr, sc);
    367   1.66   thorpej     if (sc->sc_si == NULL) {
    368   1.91  christos 	printf("%s: unable to establish softintr\n", sc->sc_if.if_xname);
    369   1.66   thorpej 	return (NULL);
    370   1.66   thorpej     }
    371    1.8    paulus     sc->sc_flags = 0;
    372    1.8    paulus     sc->sc_mru = PPP_MRU;
    373   1.22    paulus     sc->sc_relinq = NULL;
    374   1.91  christos     (void)memset(&sc->sc_stats, 0, sizeof(sc->sc_stats));
    375    1.8    paulus #ifdef VJC
    376   1.29    paulus     MALLOC(sc->sc_comp, struct slcompress *, sizeof(struct slcompress),
    377   1.29    paulus 	   M_DEVBUF, M_NOWAIT);
    378   1.29    paulus     if (sc->sc_comp)
    379   1.39  christos 	sl_compress_init(sc->sc_comp);
    380    1.8    paulus #endif
    381   1.22    paulus #ifdef PPP_COMPRESS
    382   1.22    paulus     sc->sc_xc_state = NULL;
    383   1.22    paulus     sc->sc_rc_state = NULL;
    384   1.22    paulus #endif /* PPP_COMPRESS */
    385   1.22    paulus     for (i = 0; i < NUM_NP; ++i)
    386   1.22    paulus 	sc->sc_npmode[i] = NPMODE_ERROR;
    387   1.22    paulus     sc->sc_npqueue = NULL;
    388   1.22    paulus     sc->sc_npqtail = &sc->sc_npqueue;
    389  1.107    kardel     sc->sc_last_sent = sc->sc_last_recv = time_second;
    390    1.8    paulus 
    391    1.8    paulus     return sc;
    392    1.8    paulus }
    393    1.8    paulus 
    394    1.8    paulus /*
    395   1.22    paulus  * Deallocate a ppp unit.  Must be called at splsoftnet or higher.
    396    1.8    paulus  */
    397   1.22    paulus void
    398  1.103   thorpej pppdealloc(struct ppp_softc *sc)
    399    1.8    paulus {
    400    1.8    paulus     struct mbuf *m;
    401    1.8    paulus 
    402  1.118        ad     softint_disestablish(sc->sc_si);
    403    1.8    paulus     if_down(&sc->sc_if);
    404   1.22    paulus     sc->sc_if.if_flags &= ~(IFF_UP|IFF_RUNNING);
    405    1.8    paulus     sc->sc_devp = NULL;
    406    1.8    paulus     sc->sc_xfer = 0;
    407    1.8    paulus     for (;;) {
    408   1.22    paulus 	IF_DEQUEUE(&sc->sc_rawq, m);
    409   1.22    paulus 	if (m == NULL)
    410   1.22    paulus 	    break;
    411   1.22    paulus 	m_freem(m);
    412   1.22    paulus     }
    413   1.22    paulus     for (;;) {
    414    1.8    paulus 	IF_DEQUEUE(&sc->sc_inq, m);
    415    1.8    paulus 	if (m == NULL)
    416    1.8    paulus 	    break;
    417    1.8    paulus 	m_freem(m);
    418    1.8    paulus     }
    419    1.8    paulus     for (;;) {
    420    1.8    paulus 	IF_DEQUEUE(&sc->sc_fastq, m);
    421    1.8    paulus 	if (m == NULL)
    422    1.8    paulus 	    break;
    423    1.8    paulus 	m_freem(m);
    424    1.8    paulus     }
    425   1.22    paulus     while ((m = sc->sc_npqueue) != NULL) {
    426   1.22    paulus 	sc->sc_npqueue = m->m_nextpkt;
    427   1.22    paulus 	m_freem(m);
    428    1.1   deraadt     }
    429   1.22    paulus     if (sc->sc_togo != NULL) {
    430   1.22    paulus 	m_freem(sc->sc_togo);
    431   1.22    paulus 	sc->sc_togo = NULL;
    432   1.22    paulus     }
    433   1.22    paulus #ifdef PPP_COMPRESS
    434   1.22    paulus     ppp_ccp_closed(sc);
    435   1.22    paulus     sc->sc_xc_state = NULL;
    436   1.22    paulus     sc->sc_rc_state = NULL;
    437   1.22    paulus #endif /* PPP_COMPRESS */
    438   1.37  christos #ifdef PPP_FILTER
    439   1.53      tron     if (sc->sc_pass_filt_in.bf_insns != 0) {
    440   1.53      tron 	FREE(sc->sc_pass_filt_in.bf_insns, M_DEVBUF);
    441   1.53      tron 	sc->sc_pass_filt_in.bf_insns = 0;
    442   1.53      tron 	sc->sc_pass_filt_in.bf_len = 0;
    443   1.29    paulus     }
    444   1.53      tron     if (sc->sc_pass_filt_out.bf_insns != 0) {
    445   1.53      tron 	FREE(sc->sc_pass_filt_out.bf_insns, M_DEVBUF);
    446   1.53      tron 	sc->sc_pass_filt_out.bf_insns = 0;
    447   1.53      tron 	sc->sc_pass_filt_out.bf_len = 0;
    448   1.53      tron     }
    449   1.53      tron     if (sc->sc_active_filt_in.bf_insns != 0) {
    450   1.53      tron 	FREE(sc->sc_active_filt_in.bf_insns, M_DEVBUF);
    451   1.53      tron 	sc->sc_active_filt_in.bf_insns = 0;
    452   1.53      tron 	sc->sc_active_filt_in.bf_len = 0;
    453   1.53      tron     }
    454   1.53      tron     if (sc->sc_active_filt_out.bf_insns != 0) {
    455   1.53      tron 	FREE(sc->sc_active_filt_out.bf_insns, M_DEVBUF);
    456   1.53      tron 	sc->sc_active_filt_out.bf_insns = 0;
    457   1.53      tron 	sc->sc_active_filt_out.bf_len = 0;
    458   1.29    paulus     }
    459   1.37  christos #endif /* PPP_FILTER */
    460   1.29    paulus #ifdef VJC
    461   1.29    paulus     if (sc->sc_comp != 0) {
    462   1.29    paulus 	FREE(sc->sc_comp, M_DEVBUF);
    463   1.29    paulus 	sc->sc_comp = 0;
    464   1.29    paulus     }
    465   1.29    paulus #endif
    466   1.91  christos     (void)ppp_clone_destroy(&sc->sc_if);
    467    1.1   deraadt }
    468    1.1   deraadt 
    469    1.1   deraadt /*
    470   1.22    paulus  * Ioctl routine for generic ppp devices.
    471    1.1   deraadt  */
    472    1.1   deraadt int
    473  1.113  christos pppioctl(struct ppp_softc *sc, u_long cmd, void *data, int flag,
    474  1.109  christos     struct lwp *l)
    475    1.1   deraadt {
    476   1.71  jdolecek     int s, error, flags, mru, npx;
    477   1.71  jdolecek     u_int nb;
    478   1.22    paulus     struct ppp_option_data *odp;
    479  1.125      cube     struct compressor *cp;
    480   1.22    paulus     struct npioctl *npi;
    481   1.22    paulus     time_t t;
    482   1.37  christos #ifdef PPP_FILTER
    483   1.29    paulus     struct bpf_program *bp, *nbp;
    484   1.29    paulus     struct bpf_insn *newcode, *oldcode;
    485   1.29    paulus     int newcodelen;
    486   1.37  christos #endif /* PPP_FILTER */
    487   1.22    paulus #ifdef	PPP_COMPRESS
    488   1.22    paulus     u_char ccp_option[CCP_MAX_OPTION_LENGTH];
    489   1.22    paulus #endif
    490    1.8    paulus 
    491    1.1   deraadt     switch (cmd) {
    492  1.108        ad     case PPPIOCSFLAGS:
    493  1.108        ad     case PPPIOCSMRU:
    494  1.108        ad     case PPPIOCSMAXCID:
    495  1.108        ad     case PPPIOCSCOMPRESS:
    496  1.108        ad     case PPPIOCSNPMODE:
    497  1.110      elad 	if (kauth_authorize_network(l->l_cred, KAUTH_NETWORK_INTERFACE,
    498  1.110      elad 	    KAUTH_REQ_NETWORK_INTERFACE_SETPRIV, &sc->sc_if, (void *)cmd,
    499  1.110      elad 	    NULL) != 0)
    500  1.110      elad 		return (EPERM);
    501  1.110      elad 	break;
    502  1.110      elad     case PPPIOCXFERUNIT:
    503  1.110      elad 	/* XXX: Why is this privileged?! */
    504  1.110      elad 	if (kauth_authorize_network(l->l_cred, KAUTH_NETWORK_INTERFACE,
    505  1.110      elad 	    KAUTH_REQ_NETWORK_INTERFACE_GETPRIV, &sc->sc_if, (void *)cmd,
    506  1.110      elad 	    NULL) != 0)
    507  1.110      elad 		return (EPERM);
    508  1.110      elad 	break;
    509  1.108        ad     default:
    510  1.108        ad 	break;
    511  1.108        ad     }
    512  1.108        ad 
    513  1.108        ad     switch (cmd) {
    514    1.1   deraadt     case FIONREAD:
    515    1.1   deraadt 	*(int *)data = sc->sc_inq.ifq_len;
    516    1.1   deraadt 	break;
    517    1.1   deraadt 
    518    1.1   deraadt     case PPPIOCGUNIT:
    519   1.91  christos 	*(int *)data = sc->sc_unit;
    520    1.1   deraadt 	break;
    521    1.1   deraadt 
    522    1.1   deraadt     case PPPIOCGFLAGS:
    523    1.1   deraadt 	*(u_int *)data = sc->sc_flags;
    524   1.85  christos 	break;
    525   1.85  christos 
    526   1.85  christos     case PPPIOCGRAWIN:
    527   1.85  christos 	{
    528   1.85  christos 	    struct ppp_rawin *rwin = (struct ppp_rawin *)data;
    529  1.101  christos 	    u_char c, q = 0;
    530   1.85  christos 
    531  1.101  christos 	    for (c = sc->sc_rawin_start; c < sizeof(sc->sc_rawin.buf);)
    532  1.101  christos 		rwin->buf[q++] = sc->sc_rawin.buf[c++];
    533   1.85  christos 
    534  1.101  christos 	    for (c = 0; c < sc->sc_rawin_start;)
    535  1.101  christos 		rwin->buf[q++] = sc->sc_rawin.buf[c++];
    536   1.85  christos 
    537   1.85  christos 	    rwin->count = sc->sc_rawin.count;
    538   1.85  christos 	}
    539    1.1   deraadt 	break;
    540    1.1   deraadt 
    541    1.1   deraadt     case PPPIOCSFLAGS:
    542    1.2    paulus 	flags = *(int *)data & SC_MASK;
    543   1.22    paulus 	s = splsoftnet();
    544   1.22    paulus #ifdef PPP_COMPRESS
    545   1.22    paulus 	if (sc->sc_flags & SC_CCP_OPEN && !(flags & SC_CCP_OPEN))
    546   1.22    paulus 	    ppp_ccp_closed(sc);
    547   1.22    paulus #endif
    548   1.68   thorpej 	splhigh();	/* XXX IMP ME HARDER */
    549    1.2    paulus 	sc->sc_flags = (sc->sc_flags & ~SC_MASK) | flags;
    550    1.1   deraadt 	splx(s);
    551    1.1   deraadt 	break;
    552    1.1   deraadt 
    553    1.2    paulus     case PPPIOCSMRU:
    554    1.2    paulus 	mru = *(int *)data;
    555   1.62       wiz 	if (mru >= PPP_MINMRU && mru <= PPP_MAXMRU)
    556    1.2    paulus 	    sc->sc_mru = mru;
    557    1.2    paulus 	break;
    558    1.2    paulus 
    559    1.2    paulus     case PPPIOCGMRU:
    560    1.2    paulus 	*(int *)data = sc->sc_mru;
    561    1.2    paulus 	break;
    562    1.2    paulus 
    563    1.8    paulus #ifdef VJC
    564    1.8    paulus     case PPPIOCSMAXCID:
    565   1.29    paulus 	if (sc->sc_comp) {
    566   1.29    paulus 	    s = splsoftnet();
    567   1.40  christos 	    sl_compress_setup(sc->sc_comp, *(int *)data);
    568   1.29    paulus 	    splx(s);
    569   1.29    paulus 	}
    570    1.8    paulus 	break;
    571    1.8    paulus #endif
    572    1.8    paulus 
    573    1.8    paulus     case PPPIOCXFERUNIT:
    574  1.108        ad 	sc->sc_xfer = l->l_proc->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.22    paulus 	odp = (struct ppp_option_data *) data;
    580   1.22    paulus 	nb = odp->length;
    581   1.22    paulus 	if (nb > sizeof(ccp_option))
    582   1.22    paulus 	    nb = sizeof(ccp_option);
    583   1.28  christos 	if ((error = copyin(odp->ptr, ccp_option, nb)) != 0)
    584   1.22    paulus 	    return (error);
    585   1.22    paulus 	if (ccp_option[1] < 2)	/* preliminary check on the length byte */
    586   1.22    paulus 	    return (EINVAL);
    587  1.125      cube 	cp = ppp_get_compressor(ccp_option[0]);
    588  1.125      cube 	if (cp == NULL) {
    589  1.125      cube 		if (sc->sc_flags & SC_DEBUG)
    590  1.125      cube 		    printf("%s: no compressor for [%x %x %x], %x\n",
    591  1.125      cube 			sc->sc_if.if_xname, ccp_option[0], ccp_option[1],
    592  1.125      cube 			ccp_option[2], nb);
    593  1.125      cube 		return (EINVAL);	/* no handler found */
    594  1.125      cube 	}
    595  1.125      cube 	/*
    596  1.125      cube 	 * Found a handler for the protocol - try to allocate
    597  1.125      cube 	 * a compressor or decompressor.
    598  1.125      cube 	 */
    599  1.125      cube 	error = 0;
    600  1.125      cube 	if (odp->transmit) {
    601  1.125      cube 	    s = splsoftnet();
    602  1.125      cube 	    if (sc->sc_xc_state != NULL) {
    603  1.125      cube 		(*sc->sc_xcomp->comp_free)(sc->sc_xc_state);
    604  1.125      cube 		module_rele(sc->sc_xcomp->comp_name);
    605  1.125      cube 	    }
    606  1.125      cube 	    sc->sc_xcomp = cp;
    607  1.125      cube 	    sc->sc_xc_state = cp->comp_alloc(ccp_option, nb);
    608  1.125      cube 	    if (sc->sc_xc_state == NULL) {
    609  1.125      cube 		if (sc->sc_flags & SC_DEBUG)
    610  1.125      cube 		    printf("%s: comp_alloc failed\n",
    611  1.125      cube 			sc->sc_if.if_xname);
    612  1.125      cube 		error = ENOBUFS;
    613  1.125      cube 	    }
    614  1.125      cube 	    splhigh();	/* XXX IMP ME HARDER */
    615  1.125      cube 	    sc->sc_flags &= ~SC_COMP_RUN;
    616  1.125      cube 	    splx(s);
    617  1.125      cube 	} else {
    618  1.125      cube 	    s = splsoftnet();
    619  1.125      cube 	    if (sc->sc_rc_state != NULL) {
    620  1.125      cube 		(*sc->sc_rcomp->decomp_free)(sc->sc_rc_state);
    621  1.125      cube 		module_rele(sc->sc_rcomp->comp_name);
    622  1.125      cube 	    }
    623  1.125      cube 	    sc->sc_rcomp = cp;
    624  1.125      cube 	    sc->sc_rc_state = cp->decomp_alloc(ccp_option, nb);
    625  1.125      cube 	    if (sc->sc_rc_state == NULL) {
    626  1.125      cube 		if (sc->sc_flags & SC_DEBUG)
    627  1.125      cube 		    printf("%s: decomp_alloc failed\n",
    628  1.125      cube 			sc->sc_if.if_xname);
    629  1.125      cube 		error = ENOBUFS;
    630   1.22    paulus 	    }
    631  1.125      cube 	    splhigh();	/* XXX IMP ME HARDER */
    632  1.125      cube 	    sc->sc_flags &= ~SC_DECOMP_RUN;
    633  1.125      cube 	    splx(s);
    634  1.125      cube 	}
    635  1.125      cube 	return (error);
    636   1.22    paulus #endif /* PPP_COMPRESS */
    637   1.22    paulus 
    638   1.22    paulus     case PPPIOCGNPMODE:
    639   1.22    paulus     case PPPIOCSNPMODE:
    640   1.22    paulus 	npi = (struct npioctl *) data;
    641   1.22    paulus 	switch (npi->protocol) {
    642   1.22    paulus 	case PPP_IP:
    643   1.22    paulus 	    npx = NP_IP;
    644   1.22    paulus 	    break;
    645   1.55    itojun 	case PPP_IPV6:
    646   1.55    itojun 	    npx = NP_IPV6;
    647   1.55    itojun 	    break;
    648   1.22    paulus 	default:
    649   1.22    paulus 	    return EINVAL;
    650   1.22    paulus 	}
    651   1.22    paulus 	if (cmd == PPPIOCGNPMODE) {
    652   1.22    paulus 	    npi->mode = sc->sc_npmode[npx];
    653   1.22    paulus 	} else {
    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.107    kardel 	t = time_second;
    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.113  christos 	    if ((error = copyin((void *)nbp->bf_insns, (void *)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.113  christos pppsioctl(struct ifnet *ifp, u_long cmd, void *data)
    743   1.22    paulus {
    744  1.108        ad     struct lwp *l = curlwp;	/* XXX */
    745   1.58  augustss     struct ppp_softc *sc = ifp->if_softc;
    746   1.58  augustss     struct ifaddr *ifa = (struct ifaddr *)data;
    747   1.58  augustss     struct ifreq *ifr = (struct ifreq *)data;
    748   1.22    paulus     struct ppp_stats *psp;
    749   1.22    paulus #ifdef	PPP_COMPRESS
    750   1.22    paulus     struct ppp_comp_stats *pcp;
    751   1.22    paulus #endif
    752   1.68   thorpej     int s = splnet(), error = 0;
    753   1.22    paulus 
    754   1.22    paulus     switch (cmd) {
    755   1.22    paulus     case SIOCSIFFLAGS:
    756  1.124    dyoung 	if ((error = ifioctl_common(ifp, cmd, data)) != 0)
    757  1.124    dyoung 		break;
    758   1.22    paulus 	if ((ifp->if_flags & IFF_RUNNING) == 0)
    759   1.22    paulus 	    ifp->if_flags &= ~IFF_UP;
    760   1.22    paulus 	break;
    761   1.22    paulus 
    762  1.124    dyoung     case SIOCINITIFADDR:
    763   1.55    itojun 	switch (ifa->ifa_addr->sa_family) {
    764   1.55    itojun #ifdef INET
    765   1.55    itojun 	case AF_INET:
    766   1.55    itojun 	    break;
    767   1.55    itojun #endif
    768   1.55    itojun #ifdef INET6
    769   1.55    itojun 	case AF_INET6:
    770   1.55    itojun 	    break;
    771   1.55    itojun #endif
    772   1.55    itojun 	default:
    773   1.49  christos 	    error = EAFNOSUPPORT;
    774   1.55    itojun 	    break;
    775   1.55    itojun 	}
    776   1.49  christos 	break;
    777   1.49  christos 
    778   1.22    paulus     case SIOCSIFDSTADDR:
    779   1.55    itojun 	switch (ifa->ifa_addr->sa_family) {
    780   1.55    itojun #ifdef INET
    781   1.55    itojun 	case AF_INET:
    782   1.55    itojun 	    break;
    783   1.55    itojun #endif
    784   1.55    itojun #ifdef INET6
    785   1.55    itojun 	case AF_INET6:
    786   1.55    itojun 	    break;
    787   1.55    itojun #endif
    788   1.55    itojun 	default:
    789   1.22    paulus 	    error = EAFNOSUPPORT;
    790   1.55    itojun 	    break;
    791   1.55    itojun 	}
    792   1.22    paulus 	break;
    793   1.22    paulus 
    794   1.29    paulus     case SIOCADDMULTI:
    795   1.29    paulus     case SIOCDELMULTI:
    796  1.117    dyoung 	if (ifr == NULL) {
    797   1.29    paulus 	    error = EAFNOSUPPORT;
    798   1.29    paulus 	    break;
    799   1.29    paulus 	}
    800  1.117    dyoung 	switch (ifreq_getaddr(cmd, ifr)->sa_family) {
    801   1.29    paulus #ifdef INET
    802   1.29    paulus 	case AF_INET:
    803   1.29    paulus 	    break;
    804   1.29    paulus #endif
    805   1.55    itojun #ifdef INET6
    806   1.55    itojun 	case AF_INET6:
    807   1.55    itojun 	    break;
    808   1.55    itojun #endif
    809   1.29    paulus 	default:
    810   1.29    paulus 	    error = EAFNOSUPPORT;
    811   1.29    paulus 	    break;
    812   1.29    paulus 	}
    813   1.29    paulus 	break;
    814   1.29    paulus 
    815   1.22    paulus     case SIOCGPPPSTATS:
    816   1.22    paulus 	psp = &((struct ifpppstatsreq *) data)->stats;
    817   1.70   thorpej 	memset(psp, 0, sizeof(*psp));
    818   1.29    paulus 	psp->p = sc->sc_stats;
    819   1.29    paulus #if defined(VJC) && !defined(SL_NO_STATS)
    820   1.29    paulus 	if (sc->sc_comp) {
    821   1.29    paulus 	    psp->vj.vjs_packets = sc->sc_comp->sls_packets;
    822   1.29    paulus 	    psp->vj.vjs_compressed = sc->sc_comp->sls_compressed;
    823   1.29    paulus 	    psp->vj.vjs_searches = sc->sc_comp->sls_searches;
    824   1.29    paulus 	    psp->vj.vjs_misses = sc->sc_comp->sls_misses;
    825   1.29    paulus 	    psp->vj.vjs_uncompressedin = sc->sc_comp->sls_uncompressedin;
    826   1.29    paulus 	    psp->vj.vjs_compressedin = sc->sc_comp->sls_compressedin;
    827   1.29    paulus 	    psp->vj.vjs_errorin = sc->sc_comp->sls_errorin;
    828   1.29    paulus 	    psp->vj.vjs_tossed = sc->sc_comp->sls_tossed;
    829   1.29    paulus 	}
    830   1.22    paulus #endif /* VJC */
    831   1.22    paulus 	break;
    832   1.22    paulus 
    833   1.22    paulus #ifdef PPP_COMPRESS
    834   1.22    paulus     case SIOCGPPPCSTATS:
    835   1.22    paulus 	pcp = &((struct ifpppcstatsreq *) data)->stats;
    836   1.70   thorpej 	memset(pcp, 0, sizeof(*pcp));
    837   1.22    paulus 	if (sc->sc_xc_state != NULL)
    838   1.22    paulus 	    (*sc->sc_xcomp->comp_stat)(sc->sc_xc_state, &pcp->c);
    839   1.22    paulus 	if (sc->sc_rc_state != NULL)
    840   1.22    paulus 	    (*sc->sc_rcomp->decomp_stat)(sc->sc_rc_state, &pcp->d);
    841   1.22    paulus 	break;
    842   1.22    paulus #endif /* PPP_COMPRESS */
    843    1.1   deraadt 
    844  1.124    dyoung     case SIOCSIFMTU:
    845  1.124    dyoung 	if ((error = kauth_authorize_network(l->l_cred,
    846  1.124    dyoung 	    KAUTH_NETWORK_INTERFACE, KAUTH_REQ_NETWORK_INTERFACE_SETPRIV,
    847  1.124    dyoung 	    ifp, (void *)cmd, NULL) != 0))
    848  1.124    dyoung 	    break;
    849  1.124    dyoung 	/*FALLTHROUGH*/
    850   1.22    paulus     default:
    851  1.124    dyoung 	if ((error = ifioctl_common(&sc->sc_if, cmd, data)) == ENETRESET)
    852  1.124    dyoung 		error = 0;
    853  1.124    dyoung 	break;
    854   1.22    paulus     }
    855   1.22    paulus     splx(s);
    856   1.22    paulus     return (error);
    857    1.1   deraadt }
    858    1.1   deraadt 
    859    1.1   deraadt /*
    860    1.1   deraadt  * Queue a packet.  Start transmission if not active.
    861    1.1   deraadt  * Packet is placed in Information field of PPP frame.
    862    1.1   deraadt  */
    863    1.1   deraadt int
    864  1.112    dyoung pppoutput(struct ifnet *ifp, struct mbuf *m0, const struct sockaddr *dst,
    865  1.111  christos     struct rtentry *rtp)
    866    1.1   deraadt {
    867   1.58  augustss     struct ppp_softc *sc = ifp->if_softc;
    868    1.2    paulus     int protocol, address, control;
    869    1.2    paulus     u_char *cp;
    870    1.2    paulus     int s, error;
    871   1.59    itojun #ifdef INET
    872    1.2    paulus     struct ip *ip;
    873   1.59    itojun #endif
    874    1.2    paulus     struct ifqueue *ifq;
    875   1.22    paulus     enum NPmode mode;
    876   1.37  christos     int len;
    877   1.64   thorpej     ALTQ_DECL(struct altq_pktattr pktattr;)
    878    1.1   deraadt 
    879    1.8    paulus     if (sc->sc_devp == NULL || (ifp->if_flags & IFF_RUNNING) == 0
    880   1.28  christos 	|| ((ifp->if_flags & IFF_UP) == 0 && dst->sa_family != AF_UNSPEC)) {
    881    1.1   deraadt 	error = ENETDOWN;	/* sort of */
    882    1.1   deraadt 	goto bad;
    883    1.1   deraadt     }
    884    1.1   deraadt 
    885   1.64   thorpej     IFQ_CLASSIFY(&ifp->if_snd, m0, dst->sa_family, &pktattr);
    886   1.64   thorpej 
    887    1.1   deraadt     /*
    888    1.1   deraadt      * Compute PPP header.
    889    1.1   deraadt      */
    890   1.22    paulus     m0->m_flags &= ~M_HIGHPRI;
    891    1.1   deraadt     switch (dst->sa_family) {
    892    1.1   deraadt #ifdef INET
    893    1.1   deraadt     case AF_INET:
    894   1.22    paulus 	address = PPP_ALLSTATIONS;
    895   1.22    paulus 	control = PPP_UI;
    896    1.1   deraadt 	protocol = PPP_IP;
    897   1.22    paulus 	mode = sc->sc_npmode[NP_IP];
    898   1.22    paulus 
    899    1.2    paulus 	/*
    900   1.22    paulus 	 * If this packet has the "low delay" bit set in the IP header,
    901   1.22    paulus 	 * put it on the fastq instead.
    902    1.2    paulus 	 */
    903   1.22    paulus 	ip = mtod(m0, struct ip *);
    904   1.22    paulus 	if (ip->ip_tos & IPTOS_LOWDELAY)
    905   1.22    paulus 	    m0->m_flags |= M_HIGHPRI;
    906    1.1   deraadt 	break;
    907    1.1   deraadt #endif
    908   1.55    itojun #ifdef INET6
    909   1.55    itojun     case AF_INET6:
    910   1.55    itojun 	address = PPP_ALLSTATIONS;	/*XXX*/
    911   1.55    itojun 	control = PPP_UI;		/*XXX*/
    912   1.55    itojun 	protocol = PPP_IPV6;
    913   1.55    itojun 	mode = sc->sc_npmode[NP_IPV6];
    914   1.55    itojun 
    915   1.55    itojun #if 0	/* XXX flowinfo/traffic class, maybe? */
    916   1.55    itojun 	/*
    917   1.55    itojun 	 * If this packet has the "low delay" bit set in the IP header,
    918   1.55    itojun 	 * put it on the fastq instead.
    919   1.55    itojun 	 */
    920   1.55    itojun 	ip = mtod(m0, struct ip *);
    921   1.55    itojun 	if (ip->ip_tos & IPTOS_LOWDELAY)
    922   1.55    itojun 	    m0->m_flags |= M_HIGHPRI;
    923   1.56   hannken #endif
    924   1.55    itojun 	break;
    925   1.55    itojun #endif
    926    1.1   deraadt     case AF_UNSPEC:
    927   1.22    paulus 	address = PPP_ADDRESS(dst->sa_data);
    928   1.22    paulus 	control = PPP_CONTROL(dst->sa_data);
    929   1.22    paulus 	protocol = PPP_PROTOCOL(dst->sa_data);
    930   1.22    paulus 	mode = NPMODE_PASS;
    931    1.1   deraadt 	break;
    932    1.1   deraadt     default:
    933   1.35  christos 	printf("%s: af%d not supported\n", ifp->if_xname, dst->sa_family);
    934    1.1   deraadt 	error = EAFNOSUPPORT;
    935    1.1   deraadt 	goto bad;
    936    1.1   deraadt     }
    937    1.1   deraadt 
    938    1.1   deraadt     /*
    939   1.22    paulus      * Drop this packet, or return an error, if necessary.
    940   1.22    paulus      */
    941   1.22    paulus     if (mode == NPMODE_ERROR) {
    942   1.22    paulus 	error = ENETDOWN;
    943   1.22    paulus 	goto bad;
    944   1.22    paulus     }
    945   1.22    paulus     if (mode == NPMODE_DROP) {
    946   1.22    paulus 	error = 0;
    947   1.22    paulus 	goto bad;
    948   1.22    paulus     }
    949   1.22    paulus 
    950   1.22    paulus     /*
    951   1.90    dyoung      * Add PPP header.
    952    1.1   deraadt      */
    953   1.90    dyoung     M_PREPEND(m0, PPP_HDRLEN, M_DONTWAIT);
    954   1.90    dyoung     if (m0 == NULL) {
    955   1.90    dyoung 	error = ENOBUFS;
    956   1.90    dyoung 	goto bad;
    957   1.90    dyoung     }
    958    1.1   deraadt 
    959    1.1   deraadt     cp = mtod(m0, u_char *);
    960    1.2    paulus     *cp++ = address;
    961    1.2    paulus     *cp++ = control;
    962    1.2    paulus     *cp++ = protocol >> 8;
    963    1.1   deraadt     *cp++ = protocol & 0xff;
    964   1.81    itojun 
    965   1.90    dyoung     len = m_length(m0);
    966   1.29    paulus 
    967    1.8    paulus     if (sc->sc_flags & SC_LOG_OUTPKT) {
    968   1.35  christos 	printf("%s output: ", ifp->if_xname);
    969   1.22    paulus 	pppdumpm(m0);
    970    1.1   deraadt     }
    971    1.1   deraadt 
    972   1.29    paulus     if ((protocol & 0x8000) == 0) {
    973   1.37  christos #ifdef PPP_FILTER
    974   1.37  christos 	/*
    975   1.37  christos 	 * Apply the pass and active filters to the packet,
    976   1.37  christos 	 * but only if it is a data packet.
    977   1.37  christos 	 */
    978   1.52   thorpej 	if (sc->sc_pass_filt_out.bf_insns != 0
    979   1.52   thorpej 	    && bpf_filter(sc->sc_pass_filt_out.bf_insns, (u_char *) m0,
    980   1.29    paulus 			  len, 0) == 0) {
    981   1.29    paulus 	    error = 0;		/* drop this packet */
    982   1.29    paulus 	    goto bad;
    983   1.29    paulus 	}
    984   1.29    paulus 
    985   1.29    paulus 	/*
    986   1.29    paulus 	 * Update the time we sent the most recent packet.
    987   1.29    paulus 	 */
    988   1.52   thorpej 	if (sc->sc_active_filt_out.bf_insns == 0
    989   1.52   thorpej 	    || bpf_filter(sc->sc_active_filt_out.bf_insns, (u_char *) m0,
    990   1.52   thorpej 	    		  len, 0))
    991  1.107    kardel 	    sc->sc_last_sent = time_second;
    992   1.37  christos #else
    993   1.37  christos 	/*
    994   1.37  christos 	 * Update the time we sent the most recent packet.
    995   1.37  christos 	 */
    996  1.107    kardel 	sc->sc_last_sent = time_second;
    997   1.37  christos #endif /* PPP_FILTER */
    998   1.29    paulus     }
    999   1.29    paulus 
   1000    1.2    paulus #if NBPFILTER > 0
   1001   1.22    paulus     /*
   1002   1.22    paulus      * See if bpf wants to look at the packet.
   1003   1.22    paulus      */
   1004   1.63   thorpej     if (sc->sc_if.if_bpf)
   1005   1.63   thorpej 	bpf_mtap(sc->sc_if.if_bpf, m0);
   1006    1.2    paulus #endif
   1007    1.2    paulus 
   1008    1.2    paulus     /*
   1009    1.2    paulus      * Put the packet on the appropriate queue.
   1010    1.2    paulus      */
   1011   1.68   thorpej     s = splnet();
   1012   1.22    paulus     if (mode == NPMODE_QUEUE) {
   1013   1.22    paulus 	/* XXX we should limit the number of packets on this queue */
   1014   1.22    paulus 	*sc->sc_npqtail = m0;
   1015   1.22    paulus 	m0->m_nextpkt = NULL;
   1016   1.22    paulus 	sc->sc_npqtail = &m0->m_nextpkt;
   1017   1.22    paulus     } else {
   1018   1.99  christos 	ifq = (m0->m_flags & M_HIGHPRI) ? &sc->sc_fastq : NULL;
   1019   1.97  christos 	if ((error = ifq_enqueue2(&sc->sc_if, ifq, m0
   1020   1.97  christos 		ALTQ_COMMA ALTQ_DECL(&pktattr))) != 0) {
   1021   1.22    paulus 	    splx(s);
   1022   1.22    paulus 	    sc->sc_if.if_oerrors++;
   1023   1.29    paulus 	    sc->sc_stats.ppp_oerrors++;
   1024   1.64   thorpej 	    return (error);
   1025   1.22    paulus 	}
   1026   1.44  sommerfe 	ppp_restart(sc);
   1027    1.1   deraadt     }
   1028   1.29    paulus     ifp->if_opackets++;
   1029   1.29    paulus     ifp->if_obytes += len;
   1030    1.8    paulus 
   1031    1.1   deraadt     splx(s);
   1032    1.1   deraadt     return (0);
   1033    1.1   deraadt 
   1034    1.1   deraadt bad:
   1035    1.1   deraadt     m_freem(m0);
   1036    1.1   deraadt     return (error);
   1037    1.1   deraadt }
   1038    1.1   deraadt 
   1039    1.1   deraadt /*
   1040   1.22    paulus  * After a change in the NPmode for some NP, move packets from the
   1041   1.22    paulus  * npqueue to the send queue or the fast queue as appropriate.
   1042   1.68   thorpej  * Should be called at splnet, since we muck with the queues.
   1043    1.8    paulus  */
   1044   1.22    paulus static void
   1045  1.103   thorpej ppp_requeue(struct ppp_softc *sc)
   1046    1.8    paulus {
   1047   1.22    paulus     struct mbuf *m, **mpp;
   1048   1.22    paulus     struct ifqueue *ifq;
   1049   1.22    paulus     enum NPmode mode;
   1050   1.64   thorpej     int error;
   1051    1.8    paulus 
   1052   1.22    paulus     for (mpp = &sc->sc_npqueue; (m = *mpp) != NULL; ) {
   1053   1.22    paulus 	switch (PPP_PROTOCOL(mtod(m, u_char *))) {
   1054   1.22    paulus 	case PPP_IP:
   1055   1.22    paulus 	    mode = sc->sc_npmode[NP_IP];
   1056   1.22    paulus 	    break;
   1057   1.55    itojun 	case PPP_IPV6:
   1058   1.55    itojun 	    mode = sc->sc_npmode[NP_IPV6];
   1059   1.55    itojun 	    break;
   1060   1.22    paulus 	default:
   1061   1.22    paulus 	    mode = NPMODE_PASS;
   1062   1.22    paulus 	}
   1063    1.8    paulus 
   1064   1.22    paulus 	switch (mode) {
   1065   1.22    paulus 	case NPMODE_PASS:
   1066   1.22    paulus 	    /*
   1067   1.22    paulus 	     * This packet can now go on one of the queues to be sent.
   1068   1.22    paulus 	     */
   1069   1.22    paulus 	    *mpp = m->m_nextpkt;
   1070   1.22    paulus 	    m->m_nextpkt = NULL;
   1071   1.99  christos 	    ifq = (m->m_flags & M_HIGHPRI) ? &sc->sc_fastq : NULL;
   1072   1.97  christos 	    if ((error = ifq_enqueue2(&sc->sc_if, ifq, m ALTQ_COMMA
   1073   1.97  christos 		ALTQ_DECL(NULL))) != 0) {
   1074   1.22    paulus 		sc->sc_if.if_oerrors++;
   1075   1.29    paulus 		sc->sc_stats.ppp_oerrors++;
   1076   1.64   thorpej 	    }
   1077   1.22    paulus 	    break;
   1078    1.8    paulus 
   1079   1.22    paulus 	case NPMODE_DROP:
   1080   1.22    paulus 	case NPMODE_ERROR:
   1081   1.22    paulus 	    *mpp = m->m_nextpkt;
   1082   1.22    paulus 	    m_freem(m);
   1083   1.22    paulus 	    break;
   1084   1.22    paulus 
   1085   1.22    paulus 	case NPMODE_QUEUE:
   1086   1.22    paulus 	    mpp = &m->m_nextpkt;
   1087   1.22    paulus 	    break;
   1088   1.22    paulus 	}
   1089   1.22    paulus     }
   1090   1.22    paulus     sc->sc_npqtail = mpp;
   1091   1.22    paulus }
   1092   1.22    paulus 
   1093   1.22    paulus /*
   1094   1.37  christos  * Transmitter has finished outputting some stuff;
   1095   1.37  christos  * remember to call sc->sc_start later at splsoftnet.
   1096   1.22    paulus  */
   1097   1.37  christos void
   1098  1.103   thorpej ppp_restart(struct ppp_softc *sc)
   1099   1.22    paulus {
   1100   1.68   thorpej     int s = splhigh();	/* XXX IMP ME HARDER */
   1101   1.22    paulus 
   1102   1.22    paulus     sc->sc_flags &= ~SC_TBUSY;
   1103  1.118        ad     softint_schedule(sc->sc_si);
   1104   1.22    paulus     splx(s);
   1105   1.22    paulus }
   1106   1.22    paulus 
   1107   1.22    paulus /*
   1108   1.37  christos  * Get a packet to send.  This procedure is intended to be called at
   1109   1.37  christos  * splsoftnet, since it may involve time-consuming operations such as
   1110   1.37  christos  * applying VJ compression, packet compression, address/control and/or
   1111   1.37  christos  * protocol field compression to the packet.
   1112   1.22    paulus  */
   1113   1.37  christos struct mbuf *
   1114  1.103   thorpej ppp_dequeue(struct ppp_softc *sc)
   1115   1.22    paulus {
   1116   1.22    paulus     struct mbuf *m, *mp;
   1117   1.22    paulus     u_char *cp;
   1118   1.22    paulus     int address, control, protocol;
   1119   1.44  sommerfe     int s;
   1120   1.22    paulus 
   1121   1.22    paulus     /*
   1122   1.22    paulus      * Grab a packet to send: first try the fast queue, then the
   1123   1.22    paulus      * normal queue.
   1124   1.22    paulus      */
   1125   1.96     perry     s = splnet();
   1126  1.104  christos     if (sc->sc_nfastq < sc->sc_maxfastq) {
   1127  1.104  christos 	IF_DEQUEUE(&sc->sc_fastq, m);
   1128  1.104  christos 	if (m != NULL)
   1129  1.104  christos 	    sc->sc_nfastq++;
   1130  1.104  christos 	else
   1131  1.104  christos 	    IFQ_DEQUEUE(&sc->sc_if.if_snd, m);
   1132  1.104  christos     } else {
   1133  1.104  christos 	sc->sc_nfastq = 0;
   1134   1.64   thorpej 	IFQ_DEQUEUE(&sc->sc_if.if_snd, m);
   1135  1.105      yamt 	if (m == NULL) {
   1136  1.104  christos 	    IF_DEQUEUE(&sc->sc_fastq, m);
   1137  1.104  christos 	    if (m != NULL)
   1138  1.104  christos 		sc->sc_nfastq++;
   1139  1.104  christos 	}
   1140  1.104  christos     }
   1141   1.44  sommerfe     splx(s);
   1142   1.96     perry 
   1143   1.22    paulus     if (m == NULL)
   1144   1.37  christos 	return NULL;
   1145   1.22    paulus 
   1146   1.29    paulus     ++sc->sc_stats.ppp_opackets;
   1147   1.29    paulus 
   1148   1.22    paulus     /*
   1149   1.22    paulus      * Extract the ppp header of the new packet.
   1150   1.22    paulus      * The ppp header will be in one mbuf.
   1151   1.22    paulus      */
   1152   1.22    paulus     cp = mtod(m, u_char *);
   1153   1.22    paulus     address = PPP_ADDRESS(cp);
   1154   1.22    paulus     control = PPP_CONTROL(cp);
   1155   1.22    paulus     protocol = PPP_PROTOCOL(cp);
   1156   1.22    paulus 
   1157   1.22    paulus     switch (protocol) {
   1158   1.22    paulus     case PPP_IP:
   1159   1.22    paulus #ifdef VJC
   1160   1.22    paulus 	/*
   1161   1.22    paulus 	 * If the packet is a TCP/IP packet, see if we can compress it.
   1162   1.22    paulus 	 */
   1163   1.29    paulus 	if ((sc->sc_flags & SC_COMP_TCP) && sc->sc_comp != NULL) {
   1164   1.22    paulus 	    struct ip *ip;
   1165   1.22    paulus 	    int type;
   1166   1.13    paulus 
   1167   1.13    paulus 	    mp = m;
   1168   1.13    paulus 	    ip = (struct ip *) (cp + PPP_HDRLEN);
   1169   1.13    paulus 	    if (mp->m_len <= PPP_HDRLEN) {
   1170   1.13    paulus 		mp = mp->m_next;
   1171   1.13    paulus 		if (mp == NULL)
   1172   1.13    paulus 		    break;
   1173   1.13    paulus 		ip = mtod(mp, struct ip *);
   1174   1.13    paulus 	    }
   1175   1.13    paulus 	    /* this code assumes the IP/TCP header is in one non-shared mbuf */
   1176   1.13    paulus 	    if (ip->ip_p == IPPROTO_TCP) {
   1177   1.29    paulus 		type = sl_compress_tcp(mp, ip, sc->sc_comp,
   1178   1.13    paulus 				       !(sc->sc_flags & SC_NO_TCP_CCID));
   1179   1.13    paulus 		switch (type) {
   1180   1.13    paulus 		case TYPE_UNCOMPRESSED_TCP:
   1181   1.13    paulus 		    protocol = PPP_VJC_UNCOMP;
   1182   1.13    paulus 		    break;
   1183   1.13    paulus 		case TYPE_COMPRESSED_TCP:
   1184   1.13    paulus 		    protocol = PPP_VJC_COMP;
   1185   1.13    paulus 		    cp = mtod(m, u_char *);
   1186   1.13    paulus 		    cp[0] = address;	/* header has moved */
   1187   1.13    paulus 		    cp[1] = control;
   1188   1.13    paulus 		    cp[2] = 0;
   1189   1.13    paulus 		    break;
   1190   1.13    paulus 		}
   1191   1.13    paulus 		cp[3] = protocol;	/* update protocol in PPP header */
   1192    1.8    paulus 	    }
   1193    1.8    paulus 	}
   1194    1.8    paulus #endif	/* VJC */
   1195   1.22    paulus 	break;
   1196   1.22    paulus 
   1197   1.22    paulus #ifdef PPP_COMPRESS
   1198   1.22    paulus     case PPP_CCP:
   1199   1.22    paulus 	ppp_ccp(sc, m, 0);
   1200   1.22    paulus 	break;
   1201   1.22    paulus #endif	/* PPP_COMPRESS */
   1202   1.22    paulus     }
   1203   1.22    paulus 
   1204   1.22    paulus #ifdef PPP_COMPRESS
   1205   1.22    paulus     if (protocol != PPP_LCP && protocol != PPP_CCP
   1206   1.22    paulus 	&& sc->sc_xc_state && (sc->sc_flags & SC_COMP_RUN)) {
   1207   1.29    paulus 	struct mbuf *mcomp = NULL;
   1208   1.82    simonb 	int slen;
   1209   1.22    paulus 
   1210   1.81    itojun 	slen = 0;
   1211   1.81    itojun 	for (mp = m; mp != NULL; mp = mp->m_next)
   1212   1.81    itojun 	    slen += mp->m_len;
   1213   1.82    simonb 	(*sc->sc_xcomp->compress)
   1214   1.37  christos 	    (sc->sc_xc_state, &mcomp, m, slen, sc->sc_if.if_mtu + PPP_HDRLEN);
   1215   1.22    paulus 	if (mcomp != NULL) {
   1216   1.37  christos 	    if (sc->sc_flags & SC_CCP_UP) {
   1217   1.37  christos 		/* Send the compressed packet instead of the original. */
   1218   1.37  christos 		m_freem(m);
   1219   1.37  christos 		m = mcomp;
   1220   1.37  christos 		cp = mtod(m, u_char *);
   1221   1.37  christos 		protocol = cp[3];
   1222   1.37  christos 	    } else {
   1223   1.37  christos 		/* Can't transmit compressed packets until CCP is up. */
   1224   1.37  christos 		m_freem(mcomp);
   1225   1.37  christos 	    }
   1226   1.22    paulus 	}
   1227    1.8    paulus     }
   1228   1.22    paulus #endif	/* PPP_COMPRESS */
   1229    1.8    paulus 
   1230    1.8    paulus     /*
   1231    1.8    paulus      * Compress the address/control and protocol, if possible.
   1232    1.8    paulus      */
   1233    1.8    paulus     if (sc->sc_flags & SC_COMP_AC && address == PPP_ALLSTATIONS &&
   1234    1.8    paulus 	control == PPP_UI && protocol != PPP_ALLSTATIONS &&
   1235    1.8    paulus 	protocol != PPP_LCP) {
   1236    1.8    paulus 	/* can compress address/control */
   1237    1.8    paulus 	m->m_data += 2;
   1238    1.8    paulus 	m->m_len -= 2;
   1239    1.8    paulus     }
   1240    1.8    paulus     if (sc->sc_flags & SC_COMP_PROT && protocol < 0xFF) {
   1241    1.8    paulus 	/* can compress protocol */
   1242    1.8    paulus 	if (mtod(m, u_char *) == cp) {
   1243    1.8    paulus 	    cp[2] = cp[1];	/* move address/control up */
   1244    1.8    paulus 	    cp[1] = cp[0];
   1245    1.8    paulus 	}
   1246   1.81    itojun 	++m->m_data;
   1247   1.81    itojun 	--m->m_len;
   1248    1.8    paulus     }
   1249    1.8    paulus 
   1250   1.37  christos     return m;
   1251   1.37  christos }
   1252   1.37  christos 
   1253   1.37  christos /*
   1254   1.37  christos  * Software interrupt routine, called at splsoftnet.
   1255   1.37  christos  */
   1256  1.103   thorpej static void
   1257   1.66   thorpej pppintr(void *arg)
   1258   1.37  christos {
   1259   1.66   thorpej 	struct ppp_softc *sc = arg;
   1260   1.66   thorpej 	struct mbuf *m;
   1261   1.66   thorpej 	int s;
   1262   1.37  christos 
   1263  1.122        ad 	mutex_enter(softnet_lock);
   1264   1.37  christos 	if (!(sc->sc_flags & SC_TBUSY)
   1265   1.64   thorpej 	    && (IFQ_IS_EMPTY(&sc->sc_if.if_snd) == 0 || sc->sc_fastq.ifq_head
   1266   1.46  sommerfe 		|| sc->sc_outm)) {
   1267   1.68   thorpej 		s = splhigh();	/* XXX IMP ME HARDER */
   1268   1.66   thorpej 		sc->sc_flags |= SC_TBUSY;
   1269   1.66   thorpej 		splx(s);
   1270   1.66   thorpej 		(*sc->sc_start)(sc);
   1271   1.37  christos 	}
   1272   1.37  christos 	for (;;) {
   1273   1.68   thorpej 		s = splnet();
   1274   1.66   thorpej 		IF_DEQUEUE(&sc->sc_rawq, m);
   1275   1.66   thorpej 		splx(s);
   1276   1.66   thorpej 		if (m == NULL)
   1277   1.66   thorpej 			break;
   1278   1.66   thorpej 		ppp_inproc(sc, m);
   1279   1.37  christos 	}
   1280  1.122        ad 	mutex_exit(softnet_lock);
   1281    1.8    paulus }
   1282    1.8    paulus 
   1283   1.22    paulus #ifdef PPP_COMPRESS
   1284    1.8    paulus /*
   1285   1.22    paulus  * Handle a CCP packet.  `rcvd' is 1 if the packet was received,
   1286   1.22    paulus  * 0 if it is about to be transmitted.
   1287    1.8    paulus  */
   1288   1.28  christos static void
   1289  1.103   thorpej ppp_ccp(struct ppp_softc *sc, struct mbuf *m, int rcvd)
   1290    1.8    paulus {
   1291   1.22    paulus     u_char *dp, *ep;
   1292   1.22    paulus     struct mbuf *mp;
   1293   1.22    paulus     int slen, s;
   1294    1.8    paulus 
   1295   1.22    paulus     /*
   1296   1.22    paulus      * Get a pointer to the data after the PPP header.
   1297   1.22    paulus      */
   1298   1.22    paulus     if (m->m_len <= PPP_HDRLEN) {
   1299   1.22    paulus 	mp = m->m_next;
   1300   1.22    paulus 	if (mp == NULL)
   1301   1.22    paulus 	    return;
   1302   1.22    paulus 	dp = (mp != NULL)? mtod(mp, u_char *): NULL;
   1303   1.22    paulus     } else {
   1304   1.22    paulus 	mp = m;
   1305   1.22    paulus 	dp = mtod(mp, u_char *) + PPP_HDRLEN;
   1306   1.22    paulus     }
   1307    1.8    paulus 
   1308   1.22    paulus     ep = mtod(mp, u_char *) + mp->m_len;
   1309   1.22    paulus     if (dp + CCP_HDRLEN > ep)
   1310    1.8    paulus 	return;
   1311   1.22    paulus     slen = CCP_LENGTH(dp);
   1312   1.22    paulus     if (dp + slen > ep) {
   1313   1.22    paulus 	if (sc->sc_flags & SC_DEBUG)
   1314   1.35  christos 	    printf("if_ppp/ccp: not enough data in mbuf (%p+%x > %p+%x)\n",
   1315   1.34  christos 		dp, slen, mtod(mp, u_char *), mp->m_len);
   1316    1.8    paulus 	return;
   1317    1.8    paulus     }
   1318    1.1   deraadt 
   1319   1.22    paulus     switch (CCP_CODE(dp)) {
   1320   1.22    paulus     case CCP_CONFREQ:
   1321   1.22    paulus     case CCP_TERMREQ:
   1322   1.22    paulus     case CCP_TERMACK:
   1323   1.22    paulus 	/* CCP must be going down - disable compression */
   1324   1.22    paulus 	if (sc->sc_flags & SC_CCP_UP) {
   1325   1.68   thorpej 	    s = splhigh();	/* XXX IMP ME HARDER */
   1326   1.22    paulus 	    sc->sc_flags &= ~(SC_CCP_UP | SC_COMP_RUN | SC_DECOMP_RUN);
   1327   1.22    paulus 	    splx(s);
   1328    1.1   deraadt 	}
   1329   1.22    paulus 	break;
   1330    1.1   deraadt 
   1331   1.22    paulus     case CCP_CONFACK:
   1332   1.22    paulus 	if (sc->sc_flags & SC_CCP_OPEN && !(sc->sc_flags & SC_CCP_UP)
   1333   1.22    paulus 	    && slen >= CCP_HDRLEN + CCP_OPT_MINLEN
   1334   1.22    paulus 	    && slen >= CCP_OPT_LENGTH(dp + CCP_HDRLEN) + CCP_HDRLEN) {
   1335   1.22    paulus 	    if (!rcvd) {
   1336   1.22    paulus 		/* we're agreeing to send compressed packets. */
   1337   1.22    paulus 		if (sc->sc_xc_state != NULL
   1338   1.22    paulus 		    && (*sc->sc_xcomp->comp_init)
   1339   1.22    paulus 			(sc->sc_xc_state, dp + CCP_HDRLEN, slen - CCP_HDRLEN,
   1340   1.31   thorpej 			 sc->sc_unit, 0, sc->sc_flags & SC_DEBUG)) {
   1341   1.68   thorpej 		    s = splhigh();	/* XXX IMP ME HARDER */
   1342   1.22    paulus 		    sc->sc_flags |= SC_COMP_RUN;
   1343   1.22    paulus 		    splx(s);
   1344   1.22    paulus 		}
   1345   1.22    paulus 	    } else {
   1346   1.22    paulus 		/* peer is agreeing to send compressed packets. */
   1347   1.22    paulus 		if (sc->sc_rc_state != NULL
   1348   1.22    paulus 		    && (*sc->sc_rcomp->decomp_init)
   1349   1.22    paulus 			(sc->sc_rc_state, dp + CCP_HDRLEN, slen - CCP_HDRLEN,
   1350   1.31   thorpej 			 sc->sc_unit, 0, sc->sc_mru,
   1351   1.22    paulus 			 sc->sc_flags & SC_DEBUG)) {
   1352   1.68   thorpej 		    s = splhigh();	/* XXX IMP ME HARDER */
   1353   1.22    paulus 		    sc->sc_flags |= SC_DECOMP_RUN;
   1354   1.22    paulus 		    sc->sc_flags &= ~(SC_DC_ERROR | SC_DC_FERROR);
   1355   1.22    paulus 		    splx(s);
   1356   1.22    paulus 		}
   1357    1.1   deraadt 	    }
   1358    1.1   deraadt 	}
   1359   1.22    paulus 	break;
   1360    1.1   deraadt 
   1361   1.22    paulus     case CCP_RESETACK:
   1362   1.22    paulus 	if (sc->sc_flags & SC_CCP_UP) {
   1363   1.22    paulus 	    if (!rcvd) {
   1364   1.22    paulus 		if (sc->sc_xc_state && (sc->sc_flags & SC_COMP_RUN))
   1365   1.22    paulus 		    (*sc->sc_xcomp->comp_reset)(sc->sc_xc_state);
   1366   1.22    paulus 	    } else {
   1367   1.22    paulus 		if (sc->sc_rc_state && (sc->sc_flags & SC_DECOMP_RUN)) {
   1368   1.22    paulus 		    (*sc->sc_rcomp->decomp_reset)(sc->sc_rc_state);
   1369   1.68   thorpej 		    s = splhigh();	/* XXX IMP ME HARDER */
   1370   1.22    paulus 		    sc->sc_flags &= ~SC_DC_ERROR;
   1371   1.22    paulus 		    splx(s);
   1372    1.1   deraadt 		}
   1373    1.1   deraadt 	    }
   1374    1.2    paulus 	}
   1375   1.22    paulus 	break;
   1376    1.1   deraadt     }
   1377    1.1   deraadt }
   1378    1.1   deraadt 
   1379    1.1   deraadt /*
   1380   1.22    paulus  * CCP is down; free (de)compressor state if necessary.
   1381    1.1   deraadt  */
   1382   1.22    paulus static void
   1383  1.103   thorpej ppp_ccp_closed(struct ppp_softc *sc)
   1384    1.1   deraadt {
   1385   1.22    paulus     if (sc->sc_xc_state) {
   1386   1.22    paulus 	(*sc->sc_xcomp->comp_free)(sc->sc_xc_state);
   1387  1.125      cube 	module_rele(sc->sc_xcomp->comp_name);
   1388   1.22    paulus 	sc->sc_xc_state = NULL;
   1389   1.22    paulus     }
   1390   1.22    paulus     if (sc->sc_rc_state) {
   1391   1.22    paulus 	(*sc->sc_rcomp->decomp_free)(sc->sc_rc_state);
   1392  1.125      cube 	module_rele(sc->sc_rcomp->comp_name);
   1393   1.22    paulus 	sc->sc_rc_state = NULL;
   1394    1.1   deraadt     }
   1395    1.1   deraadt }
   1396   1.22    paulus #endif /* PPP_COMPRESS */
   1397    1.1   deraadt 
   1398    1.1   deraadt /*
   1399    1.8    paulus  * PPP packet input routine.
   1400   1.13    paulus  * The caller has checked and removed the FCS and has inserted
   1401   1.13    paulus  * the address/control bytes and the protocol high byte if they
   1402   1.22    paulus  * were omitted.
   1403   1.22    paulus  */
   1404   1.22    paulus void
   1405  1.103   thorpej ppppktin(struct ppp_softc *sc, struct mbuf *m, int lost)
   1406   1.22    paulus {
   1407   1.68   thorpej     int s = splhigh();	/* XXX IMP ME HARDER */
   1408   1.22    paulus 
   1409   1.22    paulus     if (lost)
   1410   1.22    paulus 	m->m_flags |= M_ERRMARK;
   1411   1.22    paulus     IF_ENQUEUE(&sc->sc_rawq, m);
   1412  1.118        ad     softint_schedule(sc->sc_si);
   1413   1.22    paulus     splx(s);
   1414   1.22    paulus }
   1415   1.22    paulus 
   1416   1.22    paulus /*
   1417   1.22    paulus  * Process a received PPP packet, doing decompression as necessary.
   1418   1.22    paulus  * Should be called at splsoftnet.
   1419    1.1   deraadt  */
   1420    1.1   deraadt #define COMPTYPE(proto)	((proto) == PPP_VJC_COMP? TYPE_COMPRESSED_TCP: \
   1421    1.1   deraadt 			 TYPE_UNCOMPRESSED_TCP)
   1422    1.1   deraadt 
   1423   1.22    paulus static void
   1424  1.103   thorpej ppp_inproc(struct ppp_softc *sc, struct mbuf *m)
   1425    1.8    paulus {
   1426   1.24   mycroft     struct ifnet *ifp = &sc->sc_if;
   1427    1.8    paulus     struct ifqueue *inq;
   1428   1.59    itojun     int s, ilen, proto, rv;
   1429   1.13    paulus     u_char *cp, adrs, ctrl;
   1430   1.29    paulus     struct mbuf *mp, *dmp = NULL;
   1431   1.59    itojun #ifdef VJC
   1432   1.59    itojun     int xlen;
   1433   1.22    paulus     u_char *iphdr;
   1434   1.22    paulus     u_int hlen;
   1435   1.59    itojun #endif
   1436    1.8    paulus 
   1437   1.29    paulus     sc->sc_stats.ppp_ipackets++;
   1438   1.22    paulus 
   1439   1.22    paulus     if (sc->sc_flags & SC_LOG_INPKT) {
   1440   1.81    itojun 	ilen = 0;
   1441   1.81    itojun 	for (mp = m; mp != NULL; mp = mp->m_next)
   1442   1.81    itojun 	    ilen += mp->m_len;
   1443   1.35  christos 	printf("%s: got %d bytes\n", ifp->if_xname, ilen);
   1444   1.22    paulus 	pppdumpm(m);
   1445   1.22    paulus     }
   1446    1.8    paulus 
   1447   1.13    paulus     cp = mtod(m, u_char *);
   1448   1.22    paulus     adrs = PPP_ADDRESS(cp);
   1449   1.22    paulus     ctrl = PPP_CONTROL(cp);
   1450   1.22    paulus     proto = PPP_PROTOCOL(cp);
   1451   1.22    paulus 
   1452   1.22    paulus     if (m->m_flags & M_ERRMARK) {
   1453   1.22    paulus 	m->m_flags &= ~M_ERRMARK;
   1454   1.68   thorpej 	s = splhigh();	/* XXX IMP ME HARDER */
   1455   1.22    paulus 	sc->sc_flags |= SC_VJ_RESET;
   1456   1.22    paulus 	splx(s);
   1457   1.22    paulus     }
   1458   1.22    paulus 
   1459   1.22    paulus #ifdef PPP_COMPRESS
   1460   1.22    paulus     /*
   1461   1.22    paulus      * Decompress this packet if necessary, update the receiver's
   1462   1.22    paulus      * dictionary, or take appropriate action on a CCP packet.
   1463   1.22    paulus      */
   1464   1.22    paulus     if (proto == PPP_COMP && sc->sc_rc_state && (sc->sc_flags & SC_DECOMP_RUN)
   1465   1.22    paulus 	&& !(sc->sc_flags & SC_DC_ERROR) && !(sc->sc_flags & SC_DC_FERROR)) {
   1466   1.22    paulus 	/* decompress this packet */
   1467   1.22    paulus 	rv = (*sc->sc_rcomp->decompress)(sc->sc_rc_state, m, &dmp);
   1468   1.22    paulus 	if (rv == DECOMP_OK) {
   1469   1.22    paulus 	    m_freem(m);
   1470   1.22    paulus 	    if (dmp == NULL) {
   1471   1.22    paulus 		/* no error, but no decompressed packet produced */
   1472   1.22    paulus 		return;
   1473   1.22    paulus 	    }
   1474   1.22    paulus 	    m = dmp;
   1475   1.22    paulus 	    cp = mtod(m, u_char *);
   1476   1.22    paulus 	    proto = PPP_PROTOCOL(cp);
   1477   1.22    paulus 
   1478   1.22    paulus 	} else {
   1479   1.22    paulus 	    /*
   1480   1.22    paulus 	     * An error has occurred in decompression.
   1481   1.22    paulus 	     * Pass the compressed packet up to pppd, which may take
   1482   1.22    paulus 	     * CCP down or issue a Reset-Req.
   1483   1.22    paulus 	     */
   1484   1.22    paulus 	    if (sc->sc_flags & SC_DEBUG)
   1485   1.35  christos 		printf("%s: decompress failed %d\n", ifp->if_xname, rv);
   1486   1.68   thorpej 	    s = splhigh();	/* XXX IMP ME HARDER */
   1487   1.22    paulus 	    sc->sc_flags |= SC_VJ_RESET;
   1488   1.22    paulus 	    if (rv == DECOMP_ERROR)
   1489   1.22    paulus 		sc->sc_flags |= SC_DC_ERROR;
   1490   1.22    paulus 	    else
   1491   1.22    paulus 		sc->sc_flags |= SC_DC_FERROR;
   1492   1.22    paulus 	    splx(s);
   1493   1.22    paulus 	}
   1494   1.22    paulus 
   1495   1.22    paulus     } else {
   1496   1.22    paulus 	if (sc->sc_rc_state && (sc->sc_flags & SC_DECOMP_RUN)) {
   1497   1.22    paulus 	    (*sc->sc_rcomp->incomp)(sc->sc_rc_state, m);
   1498   1.22    paulus 	}
   1499   1.22    paulus 	if (proto == PPP_CCP) {
   1500   1.22    paulus 	    ppp_ccp(sc, m, 1);
   1501   1.22    paulus 	}
   1502   1.22    paulus     }
   1503   1.22    paulus #endif
   1504   1.27        pk 
   1505   1.81    itojun     ilen = 0;
   1506   1.81    itojun     for (mp = m; mp != NULL; mp = mp->m_next)
   1507   1.81    itojun 	ilen += mp->m_len;
   1508    1.8    paulus 
   1509    1.8    paulus #ifdef VJC
   1510   1.22    paulus     if (sc->sc_flags & SC_VJ_RESET) {
   1511   1.22    paulus 	/*
   1512   1.22    paulus 	 * If we've missed a packet, we must toss subsequent compressed
   1513   1.22    paulus 	 * packets which don't have an explicit connection ID.
   1514   1.22    paulus 	 */
   1515   1.29    paulus 	if (sc->sc_comp)
   1516   1.29    paulus 	    sl_uncompress_tcp(NULL, 0, TYPE_ERROR, sc->sc_comp);
   1517   1.68   thorpej 	s = splhigh();	/* XXX IMP ME HARDER */
   1518   1.22    paulus 	sc->sc_flags &= ~SC_VJ_RESET;
   1519   1.22    paulus 	splx(s);
   1520   1.22    paulus     }
   1521   1.22    paulus 
   1522    1.8    paulus     /*
   1523    1.8    paulus      * See if we have a VJ-compressed packet to uncompress.
   1524    1.8    paulus      */
   1525   1.22    paulus     if (proto == PPP_VJC_COMP) {
   1526   1.29    paulus 	if ((sc->sc_flags & SC_REJ_COMP_TCP) || sc->sc_comp == 0)
   1527   1.22    paulus 	    goto bad;
   1528   1.22    paulus 
   1529   1.22    paulus 	xlen = sl_uncompress_tcp_core(cp + PPP_HDRLEN, m->m_len - PPP_HDRLEN,
   1530   1.22    paulus 				      ilen - PPP_HDRLEN, TYPE_COMPRESSED_TCP,
   1531   1.29    paulus 				      sc->sc_comp, &iphdr, &hlen);
   1532    1.8    paulus 
   1533   1.22    paulus 	if (xlen <= 0) {
   1534    1.8    paulus 	    if (sc->sc_flags & SC_DEBUG)
   1535   1.35  christos 		printf("%s: VJ uncompress failed on type comp\n",
   1536   1.34  christos 		    ifp->if_xname);
   1537   1.22    paulus 	    goto bad;
   1538   1.17    paulus 	}
   1539   1.17    paulus 
   1540   1.22    paulus 	/* Copy the PPP and IP headers into a new mbuf. */
   1541   1.22    paulus 	MGETHDR(mp, M_DONTWAIT, MT_DATA);
   1542   1.22    paulus 	if (mp == NULL)
   1543   1.22    paulus 	    goto bad;
   1544   1.22    paulus 	mp->m_len = 0;
   1545   1.81    itojun 	mp->m_next = NULL;
   1546   1.22    paulus 	if (hlen + PPP_HDRLEN > MHLEN) {
   1547   1.22    paulus 	    MCLGET(mp, M_DONTWAIT);
   1548   1.22    paulus 	    if (M_TRAILINGSPACE(mp) < hlen + PPP_HDRLEN) {
   1549   1.22    paulus 		m_freem(mp);
   1550   1.22    paulus 		goto bad;	/* lose if big headers and no clusters */
   1551   1.22    paulus 	    }
   1552    1.8    paulus 	}
   1553   1.22    paulus 	cp = mtod(mp, u_char *);
   1554   1.22    paulus 	cp[0] = adrs;
   1555   1.22    paulus 	cp[1] = ctrl;
   1556   1.22    paulus 	cp[2] = 0;
   1557   1.22    paulus 	cp[3] = PPP_IP;
   1558   1.22    paulus 	proto = PPP_IP;
   1559   1.22    paulus 	bcopy(iphdr, cp + PPP_HDRLEN, hlen);
   1560   1.22    paulus 	mp->m_len = hlen + PPP_HDRLEN;
   1561   1.22    paulus 
   1562   1.22    paulus 	/*
   1563   1.22    paulus 	 * Trim the PPP and VJ headers off the old mbuf
   1564   1.22    paulus 	 * and stick the new and old mbufs together.
   1565   1.22    paulus 	 */
   1566   1.22    paulus 	m->m_data += PPP_HDRLEN + xlen;
   1567   1.22    paulus 	m->m_len -= PPP_HDRLEN + xlen;
   1568   1.22    paulus 	if (m->m_len <= M_TRAILINGSPACE(mp)) {
   1569   1.22    paulus 	    bcopy(mtod(m, u_char *), mtod(mp, u_char *) + mp->m_len, m->m_len);
   1570   1.22    paulus 	    mp->m_len += m->m_len;
   1571   1.22    paulus 	    MFREE(m, mp->m_next);
   1572   1.22    paulus 	} else
   1573   1.22    paulus 	    mp->m_next = m;
   1574   1.22    paulus 	m = mp;
   1575   1.22    paulus 	ilen += hlen - xlen;
   1576    1.8    paulus 
   1577   1.22    paulus     } else if (proto == PPP_VJC_UNCOMP) {
   1578   1.29    paulus 	if ((sc->sc_flags & SC_REJ_COMP_TCP) || sc->sc_comp == 0)
   1579   1.22    paulus 	    goto bad;
   1580   1.22    paulus 
   1581   1.22    paulus 	xlen = sl_uncompress_tcp_core(cp + PPP_HDRLEN, m->m_len - PPP_HDRLEN,
   1582   1.22    paulus 				      ilen - PPP_HDRLEN, TYPE_UNCOMPRESSED_TCP,
   1583   1.29    paulus 				      sc->sc_comp, &iphdr, &hlen);
   1584    1.8    paulus 
   1585   1.22    paulus 	if (xlen < 0) {
   1586    1.8    paulus 	    if (sc->sc_flags & SC_DEBUG)
   1587   1.35  christos 		printf("%s: VJ uncompress failed on type uncomp\n",
   1588   1.34  christos 		    ifp->if_xname);
   1589   1.22    paulus 	    goto bad;
   1590    1.8    paulus 	}
   1591    1.8    paulus 
   1592    1.8    paulus 	proto = PPP_IP;
   1593   1.13    paulus 	cp[3] = PPP_IP;
   1594    1.8    paulus     }
   1595    1.8    paulus #endif /* VJC */
   1596    1.8    paulus 
   1597   1.13    paulus     /*
   1598   1.13    paulus      * If the packet will fit in a header mbuf, don't waste a
   1599   1.13    paulus      * whole cluster on it.
   1600   1.13    paulus      */
   1601   1.22    paulus     if (ilen <= MHLEN && M_IS_CLUSTER(m)) {
   1602   1.13    paulus 	MGETHDR(mp, M_DONTWAIT, MT_DATA);
   1603   1.13    paulus 	if (mp != NULL) {
   1604  1.113  christos 	    m_copydata(m, 0, ilen, mtod(mp, void *));
   1605   1.13    paulus 	    m_freem(m);
   1606   1.13    paulus 	    m = mp;
   1607   1.13    paulus 	    m->m_len = ilen;
   1608   1.13    paulus 	}
   1609    1.8    paulus     }
   1610    1.8    paulus     m->m_pkthdr.len = ilen;
   1611   1.24   mycroft     m->m_pkthdr.rcvif = ifp;
   1612    1.8    paulus 
   1613   1.29    paulus     if ((proto & 0x8000) == 0) {
   1614   1.37  christos #ifdef PPP_FILTER
   1615   1.37  christos 	/*
   1616   1.37  christos 	 * See whether we want to pass this packet, and
   1617   1.37  christos 	 * if it counts as link activity.
   1618   1.37  christos 	 */
   1619   1.52   thorpej 	if (sc->sc_pass_filt_in.bf_insns != 0
   1620   1.52   thorpej 	    && bpf_filter(sc->sc_pass_filt_in.bf_insns, (u_char *) m,
   1621   1.29    paulus 			  ilen, 0) == 0) {
   1622   1.29    paulus 	    /* drop this packet */
   1623   1.29    paulus 	    m_freem(m);
   1624   1.29    paulus 	    return;
   1625   1.29    paulus 	}
   1626   1.52   thorpej 	if (sc->sc_active_filt_in.bf_insns == 0
   1627   1.52   thorpej 	    || bpf_filter(sc->sc_active_filt_in.bf_insns, (u_char *) m,
   1628   1.52   thorpej 	    		  ilen, 0))
   1629  1.107    kardel 	    sc->sc_last_recv = time_second;
   1630   1.37  christos #else
   1631   1.37  christos 	/*
   1632   1.37  christos 	 * Record the time that we received this packet.
   1633   1.37  christos 	 */
   1634  1.107    kardel 	sc->sc_last_recv = time_second;
   1635   1.37  christos #endif /* PPP_FILTER */
   1636   1.29    paulus     }
   1637   1.51   thorpej 
   1638    1.8    paulus #if NBPFILTER > 0
   1639    1.8    paulus     /* See if bpf wants to look at the packet. */
   1640   1.63   thorpej     if (sc->sc_if.if_bpf)
   1641   1.63   thorpej 	bpf_mtap(sc->sc_if.if_bpf, m);
   1642    1.8    paulus #endif
   1643    1.8    paulus 
   1644   1.22    paulus     rv = 0;
   1645    1.8    paulus     switch (proto) {
   1646    1.8    paulus #ifdef INET
   1647    1.8    paulus     case PPP_IP:
   1648    1.8    paulus 	/*
   1649    1.8    paulus 	 * IP packet - take off the ppp header and pass it up to IP.
   1650    1.8    paulus 	 */
   1651   1.24   mycroft 	if ((ifp->if_flags & IFF_UP) == 0
   1652   1.22    paulus 	    || sc->sc_npmode[NP_IP] != NPMODE_PASS) {
   1653    1.8    paulus 	    /* interface is down - drop the packet. */
   1654    1.8    paulus 	    m_freem(m);
   1655   1.22    paulus 	    return;
   1656    1.8    paulus 	}
   1657    1.8    paulus 	m->m_pkthdr.len -= PPP_HDRLEN;
   1658    1.8    paulus 	m->m_data += PPP_HDRLEN;
   1659    1.8    paulus 	m->m_len -= PPP_HDRLEN;
   1660   1.45   thorpej #ifdef GATEWAY
   1661   1.45   thorpej 	if (ipflow_fastforward(m))
   1662   1.45   thorpej 		return;
   1663   1.45   thorpej #endif
   1664    1.8    paulus 	schednetisr(NETISR_IP);
   1665    1.8    paulus 	inq = &ipintrq;
   1666   1.55    itojun 	break;
   1667   1.55    itojun #endif
   1668   1.55    itojun 
   1669   1.55    itojun #ifdef INET6
   1670   1.55    itojun     case PPP_IPV6:
   1671   1.55    itojun 	/*
   1672   1.55    itojun 	 * IPv6 packet - take off the ppp header and pass it up to IPv6.
   1673   1.55    itojun 	 */
   1674   1.55    itojun 	if ((ifp->if_flags & IFF_UP) == 0
   1675   1.55    itojun 	    || sc->sc_npmode[NP_IPV6] != NPMODE_PASS) {
   1676   1.55    itojun 	    /* interface is down - drop the packet. */
   1677   1.55    itojun 	    m_freem(m);
   1678   1.55    itojun 	    return;
   1679   1.55    itojun 	}
   1680   1.55    itojun 	m->m_pkthdr.len -= PPP_HDRLEN;
   1681   1.55    itojun 	m->m_data += PPP_HDRLEN;
   1682   1.55    itojun 	m->m_len -= PPP_HDRLEN;
   1683  1.114  liamjfoy #ifdef GATEWAY
   1684  1.114  liamjfoy 	if (ip6flow_fastforward(m))
   1685  1.114  liamjfoy 		return;
   1686  1.114  liamjfoy #endif
   1687   1.55    itojun 	schednetisr(NETISR_IPV6);
   1688   1.55    itojun 	inq = &ip6intrq;
   1689    1.8    paulus 	break;
   1690    1.8    paulus #endif
   1691    1.8    paulus 
   1692    1.8    paulus     default:
   1693    1.8    paulus 	/*
   1694    1.8    paulus 	 * Some other protocol - place on input queue for read().
   1695    1.8    paulus 	 */
   1696    1.8    paulus 	inq = &sc->sc_inq;
   1697    1.8    paulus 	rv = 1;
   1698    1.8    paulus 	break;
   1699    1.8    paulus     }
   1700    1.8    paulus 
   1701    1.8    paulus     /*
   1702    1.8    paulus      * Put the packet on the appropriate input queue.
   1703    1.8    paulus      */
   1704   1.68   thorpej     s = splnet();
   1705    1.8    paulus     if (IF_QFULL(inq)) {
   1706    1.8    paulus 	IF_DROP(inq);
   1707   1.22    paulus 	splx(s);
   1708    1.8    paulus 	if (sc->sc_flags & SC_DEBUG)
   1709   1.35  christos 	    printf("%s: input queue full\n", ifp->if_xname);
   1710   1.24   mycroft 	ifp->if_iqdrops++;
   1711   1.22    paulus 	goto bad;
   1712   1.22    paulus     }
   1713   1.22    paulus     IF_ENQUEUE(inq, m);
   1714    1.8    paulus     splx(s);
   1715   1.29    paulus     ifp->if_ipackets++;
   1716   1.29    paulus     ifp->if_ibytes += ilen;
   1717    1.1   deraadt 
   1718   1.22    paulus     if (rv)
   1719   1.22    paulus 	(*sc->sc_ctlp)(sc);
   1720    1.1   deraadt 
   1721    1.1   deraadt     return;
   1722    1.1   deraadt 
   1723   1.22    paulus  bad:
   1724   1.22    paulus     m_freem(m);
   1725   1.22    paulus     sc->sc_if.if_ierrors++;
   1726   1.29    paulus     sc->sc_stats.ppp_ierrors++;
   1727    1.1   deraadt }
   1728    1.1   deraadt 
   1729    1.1   deraadt #define MAX_DUMP_BYTES	128
   1730    1.1   deraadt 
   1731    1.1   deraadt static void
   1732  1.103   thorpej pppdumpm(struct mbuf *m0)
   1733    1.1   deraadt {
   1734    1.8    paulus     char buf[3*MAX_DUMP_BYTES+4];
   1735    1.1   deraadt     char *bp = buf;
   1736    1.1   deraadt     struct mbuf *m;
   1737    1.1   deraadt 
   1738   1.22    paulus     for (m = m0; m; m = m->m_next) {
   1739    1.1   deraadt 	int l = m->m_len;
   1740    1.1   deraadt 	u_char *rptr = (u_char *)m->m_data;
   1741    1.1   deraadt 
   1742    1.1   deraadt 	while (l--) {
   1743    1.1   deraadt 	    if (bp > buf + sizeof(buf) - 4)
   1744    1.1   deraadt 		goto done;
   1745  1.100  christos 	    *bp++ = hexdigits[*rptr >> 4]; /* convert byte to ascii hex */
   1746  1.100  christos 	    *bp++ = hexdigits[*rptr++ & 0xf];
   1747    1.1   deraadt 	}
   1748    1.1   deraadt 
   1749    1.1   deraadt 	if (m->m_next) {
   1750    1.1   deraadt 	    if (bp > buf + sizeof(buf) - 3)
   1751    1.1   deraadt 		goto done;
   1752    1.1   deraadt 	    *bp++ = '|';
   1753    1.8    paulus 	} else
   1754    1.8    paulus 	    *bp++ = ' ';
   1755    1.1   deraadt     }
   1756    1.1   deraadt done:
   1757   1.22    paulus     if (m)
   1758    1.1   deraadt 	*bp++ = '>';
   1759    1.1   deraadt     *bp = 0;
   1760   1.35  christos     printf("%s\n", buf);
   1761    1.1   deraadt }
   1762   1.75    itojun 
   1763   1.75    itojun #ifdef ALTQ
   1764   1.75    itojun /*
   1765   1.75    itojun  * a wrapper to transmit a packet from if_start since ALTQ uses
   1766   1.75    itojun  * if_start to send a packet.
   1767   1.75    itojun  */
   1768   1.75    itojun static void
   1769  1.103   thorpej ppp_ifstart(struct ifnet *ifp)
   1770   1.75    itojun {
   1771   1.75    itojun 	struct ppp_softc *sc;
   1772   1.75    itojun 
   1773   1.75    itojun 	sc = ifp->if_softc;
   1774   1.75    itojun 	(*sc->sc_start)(sc);
   1775   1.75    itojun }
   1776   1.75    itojun #endif
   1777  1.125      cube 
   1778  1.125      cube static const struct ppp_known_compressor {
   1779  1.125      cube 	uint8_t code;
   1780  1.125      cube 	const char *module;
   1781  1.125      cube } ppp_known_compressors[] = {
   1782  1.125      cube 	{ CI_DEFLATE, "ppp_deflate" },
   1783  1.125      cube 	{ CI_DEFLATE_DRAFT, "ppp_deflate" },
   1784  1.125      cube 	{ CI_BSD_COMPRESS, "ppp_bsdcomp" },
   1785  1.125      cube 	{ CI_MPPE, "ppp_mppe" },
   1786  1.125      cube 	{ 0, NULL }
   1787  1.125      cube };
   1788  1.125      cube 
   1789  1.125      cube static struct compressor *
   1790  1.125      cube ppp_get_compressor_noload(uint8_t ci, bool hold)
   1791  1.125      cube {
   1792  1.125      cube 	struct compressor *cp;
   1793  1.125      cube 
   1794  1.125      cube 	mutex_enter(&ppp_compressors_mtx);
   1795  1.125      cube 	LIST_FOREACH(cp, &ppp_compressors, comp_list) {
   1796  1.125      cube 		if (cp->compress_proto == ci) {
   1797  1.125      cube 			mutex_exit(&ppp_compressors_mtx);
   1798  1.125      cube 			if (hold && module_hold(cp->comp_name) != 0)
   1799  1.125      cube 				return NULL;
   1800  1.125      cube 			return cp;
   1801  1.125      cube 		}
   1802  1.125      cube 	}
   1803  1.125      cube 	mutex_exit(&ppp_compressors_mtx);
   1804  1.125      cube 
   1805  1.125      cube 	return NULL;
   1806  1.125      cube }
   1807  1.125      cube 
   1808  1.125      cube static struct compressor *
   1809  1.125      cube ppp_get_compressor(uint8_t ci)
   1810  1.125      cube {
   1811  1.125      cube 	struct compressor *cp;
   1812  1.125      cube 	const struct ppp_known_compressor *pkc;
   1813  1.125      cube 
   1814  1.125      cube 	if ((cp = ppp_get_compressor_noload(ci, true)) != NULL)
   1815  1.125      cube 		return cp;
   1816  1.125      cube 
   1817  1.125      cube 	/* Not found, so try to autoload a module */
   1818  1.125      cube 	for (pkc = ppp_known_compressors; pkc->module != NULL; pkc++) {
   1819  1.125      cube 		if (pkc->code == ci) {
   1820  1.125      cube 			if (module_autoload(pkc->module, MODULE_CLASS_MISC))
   1821  1.125      cube 				break;
   1822  1.125      cube 			return ppp_get_compressor_noload(ci, true);
   1823  1.125      cube 		}
   1824  1.125      cube 	}
   1825  1.125      cube 
   1826  1.125      cube 	return NULL;
   1827  1.125      cube }
   1828  1.125      cube 
   1829  1.125      cube int
   1830  1.125      cube ppp_register_compressor(struct compressor *pc)
   1831  1.125      cube {
   1832  1.125      cube 
   1833  1.125      cube 	if (ppp_get_compressor_noload(pc->compress_proto, false) != NULL)
   1834  1.125      cube 		return EEXIST;
   1835  1.125      cube 
   1836  1.125      cube 	mutex_enter(&ppp_compressors_mtx);
   1837  1.125      cube 	LIST_INSERT_HEAD(&ppp_compressors, pc, comp_list);
   1838  1.125      cube 	mutex_exit(&ppp_compressors_mtx);
   1839  1.125      cube 
   1840  1.125      cube 	return 0;
   1841  1.125      cube }
   1842  1.125      cube 
   1843  1.125      cube int
   1844  1.125      cube ppp_unregister_compressor(struct compressor *pc)
   1845  1.125      cube {
   1846  1.125      cube 
   1847  1.125      cube 	if (ppp_get_compressor_noload(pc->compress_proto, false) != pc)
   1848  1.125      cube 		return ENOENT;
   1849  1.125      cube 
   1850  1.125      cube 	mutex_enter(&ppp_compressors_mtx);
   1851  1.125      cube 	LIST_REMOVE(pc, comp_list);
   1852  1.125      cube 	mutex_exit(&ppp_compressors_mtx);
   1853  1.125      cube 
   1854  1.125      cube 	return 0;
   1855  1.125      cube }
   1856