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