Home | History | Annotate | Line # | Download | only in net
if_pppoe.c revision 1.170
      1  1.170  yamaguch /* $NetBSD: if_pppoe.c,v 1.170 2021/04/22 10:26:24 yamaguchi Exp $ */
      2    1.1    martin 
      3  1.145      maxv /*
      4   1.89    martin  * Copyright (c) 2002, 2008 The NetBSD Foundation, Inc.
      5   1.24    martin  * All rights reserved.
      6   1.24    martin  *
      7   1.24    martin  * This code is derived from software contributed to The NetBSD Foundation
      8   1.51    keihan  * by Martin Husemann <martin (at) NetBSD.org>.
      9    1.1    martin  *
     10    1.1    martin  * Redistribution and use in source and binary forms, with or without
     11    1.1    martin  * modification, are permitted provided that the following conditions
     12    1.1    martin  * are met:
     13    1.1    martin  * 1. Redistributions of source code must retain the above copyright
     14    1.1    martin  *    notice, this list of conditions and the following disclaimer.
     15    1.1    martin  * 2. Redistributions in binary form must reproduce the above copyright
     16    1.1    martin  *    notice, this list of conditions and the following disclaimer in the
     17    1.1    martin  *    documentation and/or other materials provided with the distribution.
     18    1.1    martin  *
     19   1.24    martin  * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
     20   1.24    martin  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
     21   1.24    martin  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     22   1.24    martin  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
     23   1.24    martin  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     24   1.24    martin  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     25   1.24    martin  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     26   1.24    martin  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     27   1.24    martin  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     28   1.24    martin  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     29   1.24    martin  * POSSIBILITY OF SUCH DAMAGE.
     30    1.1    martin  */
     31    1.7     lukem 
     32    1.7     lukem #include <sys/cdefs.h>
     33  1.170  yamaguch __KERNEL_RCSID(0, "$NetBSD: if_pppoe.c,v 1.170 2021/04/22 10:26:24 yamaguchi Exp $");
     34    1.1    martin 
     35  1.112  pgoyette #ifdef _KERNEL_OPT
     36    1.1    martin #include "pppoe.h"
     37   1.71     pavel #include "opt_pppoe.h"
     38  1.120  knakahar #include "opt_net_mpsafe.h"
     39  1.104     pooka #endif
     40    1.1    martin 
     41    1.1    martin #include <sys/param.h>
     42    1.1    martin #include <sys/systm.h>
     43    1.1    martin #include <sys/kernel.h>
     44  1.151  yamaguch #include <sys/atomic.h>
     45    1.1    martin #include <sys/callout.h>
     46    1.1    martin #include <sys/malloc.h>
     47    1.1    martin #include <sys/mbuf.h>
     48    1.1    martin #include <sys/socket.h>
     49    1.1    martin #include <sys/proc.h>
     50    1.1    martin #include <sys/ioctl.h>
     51   1.68      elad #include <sys/kauth.h>
     52   1.81        ad #include <sys/intr.h>
     53   1.85        ad #include <sys/socketvar.h>
     54  1.112  pgoyette #include <sys/device.h>
     55  1.112  pgoyette #include <sys/module.h>
     56  1.113  pgoyette #include <sys/sysctl.h>
     57  1.120  knakahar #include <sys/rwlock.h>
     58  1.120  knakahar #include <sys/mutex.h>
     59  1.125     ozaki #include <sys/psref.h>
     60  1.143      maxv #include <sys/cprng.h>
     61  1.151  yamaguch #include <sys/workqueue.h>
     62   1.81        ad 
     63    1.1    martin #include <net/if.h>
     64    1.1    martin #include <net/if_types.h>
     65    1.1    martin #include <net/if_ether.h>
     66    1.1    martin #include <net/if_sppp.h>
     67   1.15    martin #include <net/if_spppvar.h>
     68    1.1    martin #include <net/if_pppoe.h>
     69  1.136  knakahar #include <net/if_dl.h>
     70    1.1    martin 
     71    1.1    martin #include <net/bpf.h>
     72   1.16   aymeric 
     73  1.103  christos #include "ioconf.h"
     74    1.1    martin 
     75  1.120  knakahar #ifdef NET_MPSAFE
     76  1.120  knakahar #define PPPOE_MPSAFE	1
     77  1.120  knakahar #endif
     78  1.120  knakahar 
     79   1.29    itojun struct pppoehdr {
     80   1.84      matt 	uint8_t vertype;
     81   1.84      matt 	uint8_t code;
     82   1.84      matt 	uint16_t session;
     83   1.84      matt 	uint16_t plen;
     84   1.82     perry } __packed;
     85   1.29    itojun 
     86   1.29    itojun struct pppoetag {
     87   1.84      matt 	uint16_t tag;
     88   1.84      matt 	uint16_t len;
     89   1.82     perry } __packed;
     90   1.29    itojun 
     91   1.91    simonb #define	PPPOE_HEADERLEN	sizeof(struct pppoehdr)
     92   1.67      tron #define	PPPOE_OVERHEAD	(PPPOE_HEADERLEN + 2)
     93    1.1    martin #define	PPPOE_VERTYPE	0x11	/* VER=1, TYPE = 1 */
     94    1.1    martin 
     95    1.1    martin #define	PPPOE_TAG_EOL		0x0000		/* end of list */
     96    1.1    martin #define	PPPOE_TAG_SNAME		0x0101		/* service name */
     97    1.1    martin #define	PPPOE_TAG_ACNAME	0x0102		/* access concentrator name */
     98    1.1    martin #define	PPPOE_TAG_HUNIQUE	0x0103		/* host unique */
     99    1.1    martin #define	PPPOE_TAG_ACCOOKIE	0x0104		/* AC cookie */
    100    1.1    martin #define	PPPOE_TAG_VENDOR	0x0105		/* vendor specific */
    101    1.1    martin #define	PPPOE_TAG_RELAYSID	0x0110		/* relay session id */
    102   1.98       rjs #define	PPPOE_TAG_MAX_PAYLOAD	0x0120		/* max payload */
    103    1.1    martin #define	PPPOE_TAG_SNAME_ERR	0x0201		/* service name error */
    104    1.1    martin #define	PPPOE_TAG_ACSYS_ERR	0x0202		/* AC system error */
    105   1.97       rjs #define	PPPOE_TAG_GENERIC_ERR	0x0203		/* generic error */
    106    1.1    martin 
    107   1.91    simonb #define	PPPOE_CODE_PADI		0x09		/* Active Discovery Initiation */
    108    1.1    martin #define	PPPOE_CODE_PADO		0x07		/* Active Discovery Offer */
    109    1.1    martin #define	PPPOE_CODE_PADR		0x19		/* Active Discovery Request */
    110    1.1    martin #define	PPPOE_CODE_PADS		0x65		/* Active Discovery Session confirmation */
    111    1.1    martin #define	PPPOE_CODE_PADT		0xA7		/* Active Discovery Terminate */
    112    1.1    martin 
    113   1.19    martin /* two byte PPP protocol discriminator, then IP data */
    114   1.67      tron #define	PPPOE_MAXMTU	(ETHERMTU - PPPOE_OVERHEAD)
    115   1.19    martin 
    116    1.1    martin /* Add a 16 bit unsigned value to a buffer pointed to by PTR */
    117    1.1    martin #define	PPPOE_ADD_16(PTR, VAL)			\
    118    1.1    martin 		*(PTR)++ = (VAL) / 256;		\
    119    1.1    martin 		*(PTR)++ = (VAL) % 256
    120    1.1    martin 
    121    1.1    martin /* Add a complete PPPoE header to the buffer pointed to by PTR */
    122   1.91    simonb #define	PPPOE_ADD_HEADER(PTR, CODE, SESS, LEN)	\
    123    1.1    martin 		*(PTR)++ = PPPOE_VERTYPE;	\
    124    1.1    martin 		*(PTR)++ = (CODE);		\
    125    1.1    martin 		PPPOE_ADD_16(PTR, SESS);	\
    126    1.1    martin 		PPPOE_ADD_16(PTR, LEN)
    127    1.1    martin 
    128   1.13    martin #define	PPPOE_DISC_TIMEOUT	(hz*5)	/* base for quick timeout calculation */
    129   1.19    martin #define	PPPOE_SLOW_RETRY	(hz*60)	/* persistent retry interval */
    130   1.90    martin #define	PPPOE_RECON_FAST	(hz*15)	/* first retry after auth failure */
    131   1.92    martin #define	PPPOE_RECON_IMMEDIATE	(hz/10)	/* "no delay" reconnect */
    132   1.91    simonb #define	PPPOE_DISC_MAXPADI	4	/* retry PADI four times (quickly) */
    133   1.12    martin #define	PPPOE_DISC_MAXPADR	2	/* retry PADR twice */
    134   1.12    martin 
    135   1.43       oki #ifdef PPPOE_SERVER
    136   1.43       oki /* from if_spppsubr.c */
    137   1.91    simonb #define	IFF_PASSIVE	IFF_LINK0	/* wait passively for connection */
    138   1.43       oki #endif
    139   1.43       oki 
    140  1.127  knakahar #define PPPOE_LOCK(_sc, _op)	rw_enter(&(_sc)->sc_lock, (_op))
    141  1.127  knakahar #define PPPOE_UNLOCK(_sc)	rw_exit(&(_sc)->sc_lock)
    142  1.127  knakahar #define PPPOE_WLOCKED(_sc)	rw_write_held(&(_sc)->sc_lock)
    143  1.127  knakahar 
    144  1.120  knakahar #ifdef PPPOE_MPSAFE
    145  1.120  knakahar #define DECLARE_SPLNET_VARIABLE
    146  1.120  knakahar #define ACQUIRE_SPLNET()	do { } while (0)
    147  1.120  knakahar #define RELEASE_SPLNET()	do { } while (0)
    148  1.120  knakahar #else
    149  1.120  knakahar #define DECLARE_SPLNET_VARIABLE	int __s
    150  1.120  knakahar #define ACQUIRE_SPLNET()	do {					\
    151  1.120  knakahar 					__s = splnet();			\
    152  1.120  knakahar 				} while (0)
    153  1.120  knakahar #define RELEASE_SPLNET()	do {					\
    154  1.120  knakahar 					splx(__s);			\
    155  1.120  knakahar 				} while (0)
    156  1.120  knakahar #endif
    157  1.120  knakahar 
    158  1.157  yamaguch #ifdef PPPOE_DEBUG
    159  1.157  yamaguch #define DPRINTF(_sc, _fmt, _arg...)	pppoe_printf((_sc), (_fmt), ##_arg)
    160  1.157  yamaguch #else
    161  1.157  yamaguch #define DPRINTF(_sc, _fmt, _arg...)	__nothing
    162  1.157  yamaguch #endif
    163  1.157  yamaguch 
    164    1.1    martin struct pppoe_softc {
    165    1.1    martin 	struct sppp sc_sppp;		/* contains a struct ifnet as first element */
    166    1.5    martin 	LIST_ENTRY(pppoe_softc) sc_list;
    167    1.1    martin 	struct ifnet *sc_eth_if;	/* ethernet interface we are using */
    168   1.26    itojun 
    169  1.143      maxv 	uint64_t sc_id;			/* id of this softc, our hunique */
    170    1.1    martin 	int sc_state;			/* discovery phase or session connected */
    171    1.1    martin 	struct ether_addr sc_dest;	/* hardware address of concentrator */
    172   1.84      matt 	uint16_t sc_session;		/* PPPoE session id */
    173    1.1    martin 
    174    1.1    martin 	char *sc_service_name;		/* if != NULL: requested name of service */
    175    1.1    martin 	char *sc_concentrator_name;	/* if != NULL: requested concentrator id */
    176   1.84      matt 	uint8_t *sc_ac_cookie;		/* content of AC cookie we must echo back */
    177    1.1    martin 	size_t sc_ac_cookie_len;	/* length of cookie data */
    178   1.94  christos 	uint8_t *sc_relay_sid;		/* content of relay SID we must echo back */
    179   1.94  christos 	size_t sc_relay_sid_len;	/* length of relay SID data */
    180   1.43       oki #ifdef PPPOE_SERVER
    181   1.84      matt 	uint8_t *sc_hunique;		/* content of host unique we must echo back */
    182   1.43       oki 	size_t sc_hunique_len;		/* length of host unique */
    183   1.43       oki #endif
    184  1.151  yamaguch 	callout_t sc_timeout;		/* timeout while not in session state */
    185  1.151  yamaguch 	struct workqueue *sc_timeout_wq;	/* workqueue for timeout */
    186  1.151  yamaguch 	struct work sc_timeout_wk;
    187  1.151  yamaguch 	u_int sc_timeout_scheduled;
    188    1.1    martin 	int sc_padi_retried;		/* number of PADI retries already done */
    189    1.1    martin 	int sc_padr_retried;		/* number of PADR retries already done */
    190  1.127  knakahar 	krwlock_t sc_lock;	/* lock of sc_state, sc_session, and sc_eth_if */
    191  1.167  yamaguch 	bool sc_detaching;
    192    1.1    martin };
    193    1.1    martin 
    194    1.1    martin /* incoming traffic will be queued here */
    195   1.72  christos struct ifqueue ppoediscinq = { .ifq_maxlen = IFQ_MAXLEN };
    196   1.72  christos struct ifqueue ppoeinq = { .ifq_maxlen = IFQ_MAXLEN };
    197    1.1    martin 
    198   1.77  christos void *pppoe_softintr = NULL;
    199    1.1    martin static void pppoe_softintr_handler(void *);
    200    1.1    martin 
    201   1.25    itojun extern int sppp_ioctl(struct ifnet *, unsigned long, void *);
    202    1.1    martin 
    203    1.1    martin /* input routines */
    204  1.105     ozaki static void pppoeintr(void);
    205   1.25    itojun static void pppoe_disc_input(struct mbuf *);
    206   1.29    itojun static void pppoe_dispatch_disc_pkt(struct mbuf *, int);
    207   1.29    itojun static void pppoe_data_input(struct mbuf *);
    208  1.105     ozaki static void pppoe_enqueue(struct ifqueue *, struct mbuf *);
    209    1.1    martin 
    210    1.1    martin /* management routines */
    211   1.25    itojun static int pppoe_connect(struct pppoe_softc *);
    212   1.25    itojun static int pppoe_disconnect(struct pppoe_softc *);
    213   1.25    itojun static void pppoe_abort_connect(struct pppoe_softc *);
    214   1.77  christos static int pppoe_ioctl(struct ifnet *, unsigned long, void *);
    215   1.25    itojun static void pppoe_tls(struct sppp *);
    216   1.25    itojun static void pppoe_tlf(struct sppp *);
    217   1.25    itojun static void pppoe_start(struct ifnet *);
    218  1.120  knakahar #ifdef PPPOE_MPSAFE
    219  1.120  knakahar static int pppoe_transmit(struct ifnet *, struct mbuf *);
    220  1.120  knakahar #endif
    221   1.57    martin static void pppoe_clear_softc(struct pppoe_softc *, const char *);
    222  1.157  yamaguch static void pppoe_printf(struct pppoe_softc *, const char *, ...);
    223    1.1    martin 
    224    1.1    martin /* internal timeout handling */
    225  1.151  yamaguch static void pppoe_timeout_co(void *);
    226  1.151  yamaguch static void pppoe_timeout_co_halt(void *);
    227  1.151  yamaguch static void pppoe_timeout_wk(struct work *, void *);
    228  1.151  yamaguch static void pppoe_timeout(struct pppoe_softc *);
    229    1.1    martin 
    230    1.1    martin /* sending actual protocol controll packets */
    231   1.25    itojun static int pppoe_send_padi(struct pppoe_softc *);
    232   1.25    itojun static int pppoe_send_padr(struct pppoe_softc *);
    233   1.43       oki #ifdef PPPOE_SERVER
    234   1.43       oki static int pppoe_send_pado(struct pppoe_softc *);
    235   1.43       oki static int pppoe_send_pads(struct pppoe_softc *);
    236   1.43       oki #endif
    237   1.84      matt static int pppoe_send_padt(struct ifnet *, u_int, const uint8_t *);
    238    1.1    martin 
    239    1.1    martin /* raw output */
    240   1.26    itojun static int pppoe_output(struct pppoe_softc *, struct mbuf *);
    241    1.1    martin 
    242    1.1    martin /* internal helper functions */
    243  1.129   msaitoh static struct pppoe_softc * pppoe_find_softc_by_session(u_int, struct ifnet *,
    244  1.129   msaitoh     krw_t);
    245  1.120  knakahar static struct pppoe_softc * pppoe_find_softc_by_hunique(uint8_t *, size_t,
    246  1.120  knakahar     struct ifnet *, krw_t);
    247   1.34    martin static struct mbuf *pppoe_get_mbuf(size_t len);
    248    1.1    martin 
    249  1.123  christos static void pppoe_ifattach_hook(void *, unsigned long, void *);
    250   1.54    martin 
    251   1.63   thorpej static LIST_HEAD(pppoe_softc_head, pppoe_softc) pppoe_softc_list;
    252  1.120  knakahar static krwlock_t pppoe_softc_list_lock;
    253    1.1    martin 
    254   1.63   thorpej static int	pppoe_clone_create(struct if_clone *, int);
    255   1.63   thorpej static int	pppoe_clone_destroy(struct ifnet *);
    256    1.5    martin 
    257  1.113  pgoyette static bool	pppoe_term_unknown = false;
    258  1.136  knakahar static int	pppoe_term_unknown_pps = 1;
    259  1.113  pgoyette 
    260  1.113  pgoyette static struct sysctllog	*pppoe_sysctl_clog;
    261  1.117  christos static void sysctl_net_pppoe_setup(struct sysctllog **);
    262  1.113  pgoyette 
    263   1.63   thorpej static struct if_clone pppoe_cloner =
    264    1.5    martin     IF_CLONE_INITIALIZER("pppoe", pppoe_clone_create, pppoe_clone_destroy);
    265    1.5    martin 
    266    1.5    martin /* ARGSUSED */
    267    1.1    martin void
    268   1.76  christos pppoeattach(int count)
    269    1.5    martin {
    270  1.112  pgoyette 
    271  1.112  pgoyette 	/*
    272  1.114  christos 	 * Nothing to do here, initialization is handled by the
    273  1.114  christos 	 * module initialization code in pppoeinit() below).
    274  1.112  pgoyette 	 */
    275  1.112  pgoyette }
    276  1.112  pgoyette 
    277  1.112  pgoyette static void
    278  1.112  pgoyette pppoeinit(void)
    279  1.112  pgoyette {
    280  1.112  pgoyette 
    281    1.5    martin 	LIST_INIT(&pppoe_softc_list);
    282  1.120  knakahar 	rw_init(&pppoe_softc_list_lock);
    283    1.5    martin 	if_clone_attach(&pppoe_cloner);
    284    1.5    martin 
    285  1.120  knakahar 	pppoe_softintr = softint_establish(SOFTINT_MPSAFE|SOFTINT_NET,
    286  1.120  knakahar 	    pppoe_softintr_handler, NULL);
    287  1.114  christos 	sysctl_net_pppoe_setup(&pppoe_sysctl_clog);
    288  1.118     ozaki 
    289  1.118     ozaki 	IFQ_LOCK_INIT(&ppoediscinq);
    290  1.118     ozaki 	IFQ_LOCK_INIT(&ppoeinq);
    291    1.5    martin }
    292    1.5    martin 
    293   1.63   thorpej static int
    294  1.112  pgoyette pppoedetach(void)
    295  1.112  pgoyette {
    296  1.114  christos 	int error = 0;
    297  1.114  christos 
    298  1.140  yamaguch 	rw_enter(&pppoe_softc_list_lock, RW_READER);
    299  1.140  yamaguch 	if (!LIST_EMPTY(&pppoe_softc_list)) {
    300  1.140  yamaguch 		rw_exit(&pppoe_softc_list_lock);
    301  1.114  christos 		error = EBUSY;
    302  1.140  yamaguch 	}
    303  1.112  pgoyette 
    304  1.114  christos 	if (error == 0) {
    305  1.114  christos 		if_clone_detach(&pppoe_cloner);
    306  1.114  christos 		softint_disestablish(pppoe_softintr);
    307  1.114  christos 		/* Remove our sysctl sub-tree */
    308  1.114  christos 		sysctl_teardown(&pppoe_sysctl_clog);
    309  1.114  christos 	}
    310  1.112  pgoyette 
    311  1.114  christos 	return error;
    312  1.112  pgoyette }
    313  1.112  pgoyette 
    314  1.143      maxv static void
    315  1.143      maxv pppoe_softc_genid(uint64_t *id)
    316  1.143      maxv {
    317  1.143      maxv 	struct pppoe_softc *sc;
    318  1.143      maxv 	uint64_t rndid;
    319  1.143      maxv 
    320  1.143      maxv 	rw_enter(&pppoe_softc_list_lock, RW_READER);
    321  1.143      maxv 
    322  1.143      maxv 	while (1) {
    323  1.143      maxv 		rndid = cprng_strong64();
    324  1.143      maxv 
    325  1.143      maxv 		sc = NULL;
    326  1.143      maxv 		LIST_FOREACH(sc, &pppoe_softc_list, sc_list) {
    327  1.143      maxv 			if (sc->sc_id == rndid)
    328  1.143      maxv 				break;
    329  1.143      maxv 		}
    330  1.143      maxv 		if (sc == NULL) {
    331  1.143      maxv 			break;
    332  1.143      maxv 		}
    333  1.143      maxv 	}
    334  1.143      maxv 
    335  1.143      maxv 	rw_exit(&pppoe_softc_list_lock);
    336  1.143      maxv 	*id = rndid;
    337  1.143      maxv }
    338  1.143      maxv 
    339  1.112  pgoyette static int
    340   1.76  christos pppoe_clone_create(struct if_clone *ifc, int unit)
    341    1.1    martin {
    342    1.1    martin 	struct pppoe_softc *sc;
    343  1.166  yamaguch 	struct ifnet *ifp;
    344  1.129   msaitoh 	int rv;
    345    1.1    martin 
    346  1.165  yamaguch 	sc = kmem_zalloc(sizeof(*sc), KM_SLEEP);
    347  1.166  yamaguch 	ifp = &sc->sc_sppp.pp_if;
    348    1.5    martin 
    349  1.164  yamaguch 	rw_init(&sc->sc_lock);
    350  1.143      maxv 	pppoe_softc_genid(&sc->sc_id);
    351  1.166  yamaguch 	/* changed to real address later */
    352  1.166  yamaguch 	memcpy(&sc->sc_dest, etherbroadcastaddr, sizeof(sc->sc_dest));
    353  1.143      maxv 
    354  1.166  yamaguch 	if_initname(ifp, "pppoe", unit);
    355  1.166  yamaguch 	ifp->if_softc = sc;
    356  1.166  yamaguch 	ifp->if_mtu = PPPOE_MAXMTU;
    357  1.166  yamaguch 	ifp->if_flags = IFF_SIMPLEX|IFF_POINTOPOINT|IFF_MULTICAST;
    358  1.166  yamaguch #ifdef PPPOE_MPSAFE
    359  1.166  yamaguch 	ifp->if_extflags = IFEF_MPSAFE;
    360  1.166  yamaguch #endif
    361  1.166  yamaguch 	ifp->if_type = IFT_PPP;
    362  1.166  yamaguch 	ifp->if_hdrlen = sizeof(struct ether_header) + PPPOE_HEADERLEN;
    363  1.166  yamaguch 	ifp->if_dlt = DLT_PPP_ETHER;
    364  1.166  yamaguch 	ifp->if_ioctl = pppoe_ioctl;
    365  1.166  yamaguch 	ifp->if_start = pppoe_start;
    366  1.120  knakahar #ifdef PPPOE_MPSAFE
    367  1.166  yamaguch 	ifp->if_transmit = pppoe_transmit;
    368  1.120  knakahar #endif
    369  1.166  yamaguch 	IFQ_SET_MAXLEN(&ifp->if_snd, IFQ_MAXLEN);
    370  1.166  yamaguch 	IFQ_SET_READY(&ifp->if_snd);
    371  1.166  yamaguch 
    372  1.166  yamaguch 	sc->sc_sppp.pp_tls = pppoe_tls;
    373  1.166  yamaguch 	sc->sc_sppp.pp_tlf = pppoe_tlf;
    374   1.28    itojun 	sc->sc_sppp.pp_flags |= PP_KEEPALIVE |	/* use LCP keepalive */
    375   1.11    martin 				PP_NOFRAMING;	/* no serial encapsulation */
    376  1.166  yamaguch 	sc->sc_sppp.pp_framebytes = PPPOE_HEADERLEN;	/* framing added to ppp packets */
    377    1.5    martin 
    378  1.151  yamaguch 	rv = workqueue_create(&sc->sc_timeout_wq,
    379  1.166  yamaguch 	    ifp->if_xname, pppoe_timeout_wk, sc,
    380  1.151  yamaguch 	    PRI_SOFTNET, IPL_SOFTNET, 0);
    381  1.163  yamaguch 	if (rv != 0)
    382  1.164  yamaguch 		goto destroy_sclock;
    383  1.151  yamaguch 
    384  1.130  knakahar 	callout_init(&sc->sc_timeout, CALLOUT_MPSAFE);
    385  1.151  yamaguch 	callout_setfunc(&sc->sc_timeout, pppoe_timeout_co, sc);
    386    1.5    martin 
    387  1.166  yamaguch 	rv = if_initialize(ifp);
    388  1.163  yamaguch 	if (rv != 0)
    389  1.163  yamaguch 		goto destroy_timeout;
    390  1.163  yamaguch 
    391  1.166  yamaguch 	ifp->if_percpuq = if_percpuq_create(ifp);
    392    1.1    martin 
    393  1.140  yamaguch 	rw_enter(&pppoe_softc_list_lock, RW_READER);
    394   1.99     rmind 	if (LIST_EMPTY(&pppoe_softc_list)) {
    395  1.122  christos 		pfil_add_ihook(pppoe_ifattach_hook, NULL, PFIL_IFNET, if_pfil);
    396   1.99     rmind 	}
    397  1.166  yamaguch 	LIST_INSERT_HEAD(&pppoe_softc_list, sc, sc_list);
    398  1.140  yamaguch 	rw_exit(&pppoe_softc_list_lock);
    399  1.140  yamaguch 
    400  1.166  yamaguch 	sppp_attach(ifp);
    401  1.166  yamaguch 	bpf_attach(ifp, DLT_PPP_ETHER, 0);
    402  1.166  yamaguch 	if_register(ifp);
    403  1.120  knakahar 
    404    1.5    martin 	return 0;
    405  1.163  yamaguch 
    406  1.163  yamaguch destroy_timeout:
    407  1.163  yamaguch 	callout_destroy(&sc->sc_timeout);
    408  1.163  yamaguch 	workqueue_destroy(sc->sc_timeout_wq);
    409  1.164  yamaguch destroy_sclock:
    410  1.164  yamaguch 	rw_destroy(&sc->sc_lock);
    411  1.165  yamaguch 	kmem_free(sc, sizeof(*sc));
    412  1.164  yamaguch 
    413  1.163  yamaguch 	return rv;
    414    1.5    martin }
    415    1.1    martin 
    416   1.63   thorpej static int
    417   1.63   thorpej pppoe_clone_destroy(struct ifnet *ifp)
    418    1.5    martin {
    419    1.5    martin 	struct pppoe_softc * sc = ifp->if_softc;
    420    1.1    martin 
    421  1.167  yamaguch 	PPPOE_LOCK(sc, RW_WRITER);
    422  1.167  yamaguch 	/* stop ioctls */
    423  1.167  yamaguch 	sc->sc_detaching = true;
    424  1.120  knakahar 
    425  1.167  yamaguch 	if (ifp->if_flags & IFF_RUNNING) {
    426  1.167  yamaguch 		pppoe_clear_softc(sc, "destroy interface");
    427  1.167  yamaguch 		sc->sc_eth_if = NULL;
    428  1.167  yamaguch 	}
    429  1.167  yamaguch 	PPPOE_UNLOCK(sc);
    430  1.120  knakahar 
    431  1.167  yamaguch 	rw_enter(&pppoe_softc_list_lock, RW_WRITER);
    432    1.5    martin 	LIST_REMOVE(sc, sc_list);
    433  1.120  knakahar 
    434   1.99     rmind 	if (LIST_EMPTY(&pppoe_softc_list)) {
    435  1.122  christos 		pfil_remove_ihook(pppoe_ifattach_hook, NULL, PFIL_IFNET, if_pfil);
    436   1.99     rmind 	}
    437  1.120  knakahar 	rw_exit(&pppoe_softc_list_lock);
    438  1.120  knakahar 
    439  1.169  yamaguch 	bpf_detach(ifp);
    440  1.169  yamaguch 	sppp_detach(&sc->sc_sppp.pp_if);
    441  1.169  yamaguch 	if_detach(ifp);
    442  1.169  yamaguch 
    443  1.167  yamaguch 	callout_setfunc(&sc->sc_timeout, pppoe_timeout_co_halt, sc);
    444  1.169  yamaguch 
    445  1.167  yamaguch 	workqueue_wait(sc->sc_timeout_wq, &sc->sc_timeout_wk);
    446  1.169  yamaguch 	workqueue_destroy(sc->sc_timeout_wq);
    447  1.169  yamaguch 
    448  1.167  yamaguch 	callout_halt(&sc->sc_timeout, NULL);
    449  1.169  yamaguch 	callout_destroy(&sc->sc_timeout);
    450  1.167  yamaguch 
    451  1.170  yamaguch #ifdef PPPOE_SERVER
    452  1.170  yamaguch 	if (sc->sc_hunique) {
    453  1.170  yamaguch 		free(sc->sc_hunique, M_DEVBUF);
    454  1.170  yamaguch 		sc->sc_hunique = NULL;
    455  1.170  yamaguch 		sc->sc_hunique_len = 0;
    456  1.170  yamaguch 	}
    457  1.170  yamaguch #endif
    458   1.32      yamt 	if (sc->sc_concentrator_name)
    459   1.32      yamt 		free(sc->sc_concentrator_name, M_DEVBUF);
    460   1.32      yamt 	if (sc->sc_service_name)
    461   1.32      yamt 		free(sc->sc_service_name, M_DEVBUF);
    462   1.32      yamt 	if (sc->sc_ac_cookie)
    463   1.32      yamt 		free(sc->sc_ac_cookie, M_DEVBUF);
    464   1.94  christos 	if (sc->sc_relay_sid)
    465   1.94  christos 		free(sc->sc_relay_sid, M_DEVBUF);
    466  1.120  knakahar 
    467  1.127  knakahar 	rw_destroy(&sc->sc_lock);
    468  1.120  knakahar 
    469  1.165  yamaguch 	kmem_free(sc, sizeof(*sc));
    470   1.56     peter 
    471  1.129   msaitoh 	return 0;
    472    1.1    martin }
    473    1.1    martin 
    474  1.157  yamaguch static void
    475  1.157  yamaguch pppoe_printf(struct pppoe_softc *sc, const char *fmt, ...)
    476  1.157  yamaguch {
    477  1.157  yamaguch 	va_list ap;
    478  1.157  yamaguch 	bool pppoe_debug;
    479  1.157  yamaguch 
    480  1.157  yamaguch #ifdef PPPOE_DEBUG
    481  1.157  yamaguch 	pppoe_debug = true;
    482  1.157  yamaguch #else
    483  1.157  yamaguch 	pppoe_debug = false;
    484  1.157  yamaguch #endif
    485  1.157  yamaguch 
    486  1.157  yamaguch 	if (sc == NULL) {
    487  1.157  yamaguch 		if (!pppoe_debug)
    488  1.157  yamaguch 			return;
    489  1.157  yamaguch 
    490  1.157  yamaguch 		printf("pppoe: ");
    491  1.157  yamaguch 	} else {
    492  1.157  yamaguch 		if (!ISSET(sc->sc_sppp.pp_if.if_flags, IFF_DEBUG))
    493  1.157  yamaguch 			return;
    494  1.157  yamaguch 
    495  1.157  yamaguch 		printf("%s: ", sc->sc_sppp.pp_if.if_xname);
    496  1.157  yamaguch 	}
    497  1.157  yamaguch 
    498  1.157  yamaguch 	va_start(ap, fmt);
    499  1.157  yamaguch 	vprintf(fmt, ap);
    500  1.157  yamaguch 	va_end(ap);
    501  1.157  yamaguch }
    502  1.157  yamaguch 
    503    1.1    martin /*
    504    1.1    martin  * Find the interface handling the specified session.
    505    1.1    martin  * Note: O(number of sessions open), this is a client-side only, mean
    506    1.1    martin  * and lean implementation, so number of open sessions typically should
    507    1.1    martin  * be 1.
    508    1.1    martin  */
    509    1.1    martin static struct pppoe_softc *
    510  1.120  knakahar pppoe_find_softc_by_session(u_int session, struct ifnet *rcvif, krw_t lock)
    511    1.1    martin {
    512  1.120  knakahar 	struct pppoe_softc *sc = NULL;
    513    1.1    martin 
    514   1.26    itojun 	if (session == 0)
    515   1.26    itojun 		return NULL;
    516  1.120  knakahar 	rw_enter(&pppoe_softc_list_lock, RW_READER);
    517    1.5    martin 	LIST_FOREACH(sc, &pppoe_softc_list, sc_list) {
    518  1.127  knakahar 		PPPOE_LOCK(sc, lock);
    519  1.127  knakahar 		if ( sc->sc_state == PPPOE_STATE_SESSION
    520   1.93       scw 		    && sc->sc_session == session
    521   1.93       scw 		    && sc->sc_eth_if == rcvif)
    522  1.120  knakahar 			break;
    523  1.120  knakahar 
    524  1.127  knakahar 		PPPOE_UNLOCK(sc);
    525    1.1    martin 	}
    526  1.120  knakahar 	rw_exit(&pppoe_softc_list_lock);
    527  1.120  knakahar 	return sc;
    528    1.1    martin }
    529    1.1    martin 
    530    1.1    martin /* Check host unique token passed and return appropriate softc pointer,
    531    1.1    martin  * or NULL if token is bogus. */
    532    1.1    martin static struct pppoe_softc *
    533  1.120  knakahar pppoe_find_softc_by_hunique(uint8_t *token, size_t len,
    534  1.120  knakahar     struct ifnet *rcvif, krw_t lock)
    535    1.1    martin {
    536  1.143      maxv 	struct pppoe_softc *sc;
    537  1.143      maxv 	uint64_t t;
    538  1.143      maxv 
    539  1.143      maxv 	CTASSERT(sizeof(t) == sizeof(sc->sc_id));
    540    1.9    martin 
    541  1.140  yamaguch 	rw_enter(&pppoe_softc_list_lock, RW_READER);
    542  1.140  yamaguch 	if (LIST_EMPTY(&pppoe_softc_list)) {
    543  1.140  yamaguch 		rw_exit(&pppoe_softc_list_lock);
    544   1.26    itojun 		return NULL;
    545  1.140  yamaguch 	}
    546    1.9    martin 
    547  1.143      maxv 	if (len != sizeof(sc->sc_id)) {
    548  1.140  yamaguch 		rw_exit(&pppoe_softc_list_lock);
    549   1.26    itojun 		return NULL;
    550  1.140  yamaguch 	}
    551    1.5    martin 	memcpy(&t, token, len);
    552    1.5    martin 
    553  1.120  knakahar 	LIST_FOREACH(sc, &pppoe_softc_list, sc_list) {
    554  1.159  yamaguch 		PPPOE_LOCK(sc, lock);
    555  1.160  yamaguch 		if (sc->sc_id == t && sc->sc_eth_if != NULL) {
    556  1.120  knakahar 			break;
    557  1.120  knakahar 		}
    558  1.159  yamaguch 		PPPOE_UNLOCK(sc);
    559  1.120  knakahar 	}
    560  1.120  knakahar 	rw_exit(&pppoe_softc_list_lock);
    561    1.5    martin 
    562   1.40   aymeric 	if (sc == NULL) {
    563  1.157  yamaguch 		pppoe_printf(NULL, "alien host unique tag"
    564  1.157  yamaguch 		    ", no session found\n");
    565    1.1    martin 		return NULL;
    566    1.1    martin 	}
    567    1.5    martin 
    568    1.1    martin 	/* should be safe to access *sc now */
    569    1.1    martin 	if (sc->sc_state < PPPOE_STATE_PADI_SENT || sc->sc_state >= PPPOE_STATE_SESSION) {
    570  1.157  yamaguch 		pppoe_printf(sc, "host unique tag found"
    571  1.157  yamaguch 		    ", but it belongs to a connection in state %d\n",
    572  1.157  yamaguch 		    sc->sc_state);
    573  1.127  knakahar 		PPPOE_UNLOCK(sc);
    574    1.1    martin 		return NULL;
    575    1.1    martin 	}
    576    1.1    martin 	if (sc->sc_eth_if != rcvif) {
    577  1.157  yamaguch 		pppoe_printf(sc, "wrong interface, not accepting host unique\n");
    578  1.127  knakahar 		PPPOE_UNLOCK(sc);
    579    1.1    martin 		return NULL;
    580    1.1    martin 	}
    581    1.1    martin 	return sc;
    582    1.1    martin }
    583    1.1    martin 
    584   1.63   thorpej static void
    585   1.76  christos pppoe_softintr_handler(void *dummy)
    586    1.1    martin {
    587    1.1    martin 	/* called at splsoftnet() */
    588  1.105     ozaki 	pppoeintr();
    589    1.1    martin }
    590    1.1    martin 
    591    1.1    martin /* called at appropriate protection level */
    592    1.1    martin static void
    593  1.105     ozaki pppoeintr(void)
    594    1.1    martin {
    595    1.1    martin 	struct mbuf *m;
    596  1.118     ozaki 	int disc_done, data_done;
    597    1.1    martin 
    598  1.132     ozaki 	SOFTNET_LOCK_UNLESS_NET_MPSAFE();
    599  1.120  knakahar 
    600    1.3    martin 	do {
    601    1.3    martin 		disc_done = 0;
    602    1.3    martin 		data_done = 0;
    603    1.3    martin 		for (;;) {
    604  1.118     ozaki 			IFQ_LOCK(&ppoediscinq);
    605    1.1    martin 			IF_DEQUEUE(&ppoediscinq, m);
    606  1.118     ozaki 			IFQ_UNLOCK(&ppoediscinq);
    607  1.145      maxv 			if (m == NULL)
    608  1.145      maxv 				break;
    609    1.3    martin 			disc_done = 1;
    610    1.1    martin 			pppoe_disc_input(m);
    611    1.1    martin 		}
    612    1.3    martin 
    613    1.3    martin 		for (;;) {
    614  1.118     ozaki 			IFQ_LOCK(&ppoeinq);
    615    1.1    martin 			IF_DEQUEUE(&ppoeinq, m);
    616  1.118     ozaki 			IFQ_UNLOCK(&ppoeinq);
    617  1.145      maxv 			if (m == NULL)
    618  1.145      maxv 				break;
    619    1.3    martin 			data_done = 1;
    620    1.1    martin 			pppoe_data_input(m);
    621    1.1    martin 		}
    622    1.3    martin 	} while (disc_done || data_done);
    623  1.132     ozaki 
    624  1.162  yamaguch 	if (!IF_IS_EMPTY(&ppoediscinq) || !IF_IS_EMPTY(&ppoeinq))
    625  1.162  yamaguch 		softint_schedule(pppoe_softintr);
    626  1.162  yamaguch 
    627  1.132     ozaki 	SOFTNET_UNLOCK_UNLESS_NET_MPSAFE();
    628    1.1    martin }
    629    1.1    martin 
    630    1.1    martin /* analyze and handle a single received packet while not in session state */
    631   1.63   thorpej static void
    632   1.63   thorpej pppoe_dispatch_disc_pkt(struct mbuf *m, int off)
    633    1.1    martin {
    634   1.84      matt 	uint16_t tag, len;
    635   1.84      matt 	uint16_t session, plen;
    636    1.1    martin 	struct pppoe_softc *sc;
    637  1.120  knakahar 	const char *err_msg;
    638   1.64    martin 	char *error;
    639  1.149   mlelstv 	size_t dlen;
    640   1.84      matt 	uint8_t *ac_cookie;
    641    1.1    martin 	size_t ac_cookie_len;
    642   1.94  christos 	uint8_t *relay_sid;
    643   1.94  christos 	size_t relay_sid_len;
    644   1.84      matt 	uint8_t *hunique;
    645   1.43       oki 	size_t hunique_len;
    646   1.29    itojun 	struct pppoehdr *ph;
    647   1.29    itojun 	struct pppoetag *pt;
    648   1.29    itojun 	struct mbuf *n;
    649   1.46    martin 	int noff, err, errortag;
    650   1.29    itojun 	struct ether_header *eh;
    651  1.139  yamaguch 	struct ifnet *rcvif;
    652  1.139  yamaguch 	struct psref psref;
    653   1.29    itojun 
    654   1.29    itojun 	if (m->m_len < sizeof(*eh)) {
    655   1.29    itojun 		m = m_pullup(m, sizeof(*eh));
    656  1.145      maxv 		if (m == NULL)
    657   1.29    itojun 			goto done;
    658   1.29    itojun 	}
    659   1.29    itojun 	eh = mtod(m, struct ether_header *);
    660   1.29    itojun 	off += sizeof(*eh);
    661    1.1    martin 
    662   1.29    itojun 	if (m->m_pkthdr.len - off <= PPPOE_HEADERLEN) {
    663   1.29    itojun 		goto done;
    664   1.29    itojun 	}
    665   1.29    itojun 
    666  1.146      maxv 	M_REGION_GET(ph, struct pppoehdr *, m, off, sizeof(*ph));
    667  1.146      maxv 	if (ph == NULL) {
    668   1.29    itojun 		goto done;
    669   1.29    itojun 	}
    670   1.29    itojun 	if (ph->vertype != PPPOE_VERTYPE) {
    671   1.29    itojun 		goto done;
    672   1.29    itojun 	}
    673  1.146      maxv 
    674  1.146      maxv 	ac_cookie = NULL;
    675  1.146      maxv 	ac_cookie_len = 0;
    676  1.146      maxv 	relay_sid = NULL;
    677  1.146      maxv 	relay_sid_len = 0;
    678  1.146      maxv 	hunique = NULL;
    679  1.146      maxv 	hunique_len = 0;
    680  1.146      maxv 
    681   1.29    itojun 	session = ntohs(ph->session);
    682   1.29    itojun 	plen = ntohs(ph->plen);
    683   1.29    itojun 	off += sizeof(*ph);
    684   1.29    itojun 
    685   1.29    itojun 	if (plen + off > m->m_pkthdr.len) {
    686   1.29    itojun 		goto done;
    687    1.1    martin 	}
    688   1.29    itojun 	m_adj(m, off + plen - m->m_pkthdr.len);	/* ignore trailing garbage */
    689  1.145      maxv 
    690    1.1    martin 	tag = 0;
    691    1.1    martin 	len = 0;
    692    1.1    martin 	sc = NULL;
    693  1.146      maxv 	err_msg = NULL;
    694  1.146      maxv 	errortag = 0;
    695   1.31      yamt 	while (off + sizeof(*pt) <= m->m_pkthdr.len) {
    696  1.146      maxv 		M_REGION_GET(pt, struct pppoetag *, m, off, sizeof(*pt));
    697  1.146      maxv 		if (pt == NULL) {
    698   1.29    itojun 			goto done;
    699   1.29    itojun 		}
    700  1.146      maxv 
    701   1.29    itojun 		tag = ntohs(pt->tag);
    702   1.29    itojun 		len = ntohs(pt->len);
    703   1.88    martin 		if (off + len + sizeof(*pt) > m->m_pkthdr.len) {
    704   1.29    itojun 			goto done;
    705    1.1    martin 		}
    706    1.1    martin 		switch (tag) {
    707    1.1    martin 		case PPPOE_TAG_EOL:
    708   1.29    itojun 			goto breakbreak;
    709    1.1    martin 		case PPPOE_TAG_SNAME:
    710    1.1    martin 			break;	/* ignored */
    711    1.1    martin 		case PPPOE_TAG_ACNAME:
    712  1.139  yamaguch 			if (len > 0) {
    713  1.149   mlelstv 				dlen = 4 * len + 1;
    714  1.149   mlelstv 				error = malloc(dlen, M_TEMP, M_NOWAIT);
    715  1.124      maxv 				if (error == NULL)
    716  1.124      maxv 					break;
    717  1.124      maxv 
    718  1.124      maxv 				n = m_pulldown(m, off + sizeof(*pt), len,
    719  1.124      maxv 				    &noff);
    720  1.124      maxv 				if (!n) {
    721  1.124      maxv 					m = NULL;
    722   1.80    martin 					free(error, M_TEMP);
    723  1.124      maxv 					goto done;
    724   1.80    martin 				}
    725  1.124      maxv 
    726  1.149   mlelstv 				strnvisx(error, dlen,
    727  1.149   mlelstv 				    mtod(n, char*) + noff, len,
    728  1.149   mlelstv 				    VIS_SAFE | VIS_OCTAL);
    729  1.157  yamaguch 				pppoe_printf(NULL, "connected to %s\n", error);
    730  1.124      maxv 				free(error, M_TEMP);
    731   1.80    martin 			}
    732    1.1    martin 			break;	/* ignored */
    733  1.139  yamaguch 		case PPPOE_TAG_HUNIQUE:
    734  1.139  yamaguch 			if (hunique == NULL) {
    735  1.139  yamaguch 				n = m_pulldown(m, off + sizeof(*pt), len,
    736  1.139  yamaguch 				    &noff);
    737  1.139  yamaguch 				if (!n) {
    738  1.139  yamaguch 					m = NULL;
    739  1.139  yamaguch 					err_msg = "TAG HUNIQUE ERROR";
    740  1.139  yamaguch 					break;
    741  1.139  yamaguch 				}
    742  1.125     ozaki 
    743  1.139  yamaguch 				hunique = mtod(n, uint8_t *) + noff;
    744  1.139  yamaguch 				hunique_len = len;
    745  1.120  knakahar 			}
    746    1.1    martin 			break;
    747    1.1    martin 		case PPPOE_TAG_ACCOOKIE:
    748    1.1    martin 			if (ac_cookie == NULL) {
    749   1.29    itojun 				n = m_pulldown(m, off + sizeof(*pt), len,
    750   1.29    itojun 				    &noff);
    751   1.29    itojun 				if (!n) {
    752   1.29    itojun 					err_msg = "TAG ACCOOKIE ERROR";
    753   1.29    itojun 					m = NULL;
    754   1.29    itojun 					break;
    755   1.29    itojun 				}
    756   1.77  christos 				ac_cookie = mtod(n, char *) + noff;
    757    1.1    martin 				ac_cookie_len = len;
    758    1.1    martin 			}
    759    1.1    martin 			break;
    760   1.94  christos 		case PPPOE_TAG_RELAYSID:
    761   1.94  christos 			if (relay_sid == NULL) {
    762   1.94  christos 				n = m_pulldown(m, off + sizeof(*pt), len,
    763   1.94  christos 				    &noff);
    764   1.94  christos 				if (!n) {
    765   1.94  christos 					err_msg = "TAG RELAYSID ERROR";
    766   1.94  christos 					m = NULL;
    767   1.94  christos 					break;
    768   1.94  christos 				}
    769   1.94  christos 				relay_sid = mtod(n, char *) + noff;
    770   1.94  christos 				relay_sid_len = len;
    771   1.94  christos 			}
    772   1.94  christos 			break;
    773    1.1    martin 		case PPPOE_TAG_SNAME_ERR:
    774    1.1    martin 			err_msg = "SERVICE NAME ERROR";
    775   1.46    martin 			errortag = 1;
    776    1.1    martin 			break;
    777    1.1    martin 		case PPPOE_TAG_ACSYS_ERR:
    778    1.1    martin 			err_msg = "AC SYSTEM ERROR";
    779   1.46    martin 			errortag = 1;
    780    1.1    martin 			break;
    781    1.1    martin 		case PPPOE_TAG_GENERIC_ERR:
    782    1.1    martin 			err_msg = "GENERIC ERROR";
    783   1.46    martin 			errortag = 1;
    784    1.1    martin 			break;
    785    1.1    martin 		}
    786    1.1    martin 		if (err_msg) {
    787   1.64    martin 			error = NULL;
    788   1.46    martin 			if (errortag && len) {
    789  1.149   mlelstv 				dlen = 4 * len + 1;
    790  1.149   mlelstv 				error = malloc(dlen, M_TEMP,
    791  1.124      maxv 				    M_NOWAIT|M_ZERO);
    792   1.46    martin 				n = m_pulldown(m, off + sizeof(*pt), len,
    793   1.46    martin 				    &noff);
    794  1.124      maxv 				if (!n) {
    795  1.124      maxv 					m = NULL;
    796  1.124      maxv 				} else if (error) {
    797  1.149   mlelstv 					strnvisx(error, dlen,
    798  1.149   mlelstv 					    mtod(n, char*) + noff, len,
    799  1.149   mlelstv 					    VIS_SAFE | VIS_OCTAL);
    800   1.64    martin 				}
    801   1.46    martin 			}
    802   1.64    martin 			if (error) {
    803  1.157  yamaguch 				pppoe_printf(NULL, "%s: %s\n", err_msg, error);
    804   1.64    martin 				free(error, M_TEMP);
    805   1.64    martin 			} else
    806  1.157  yamaguch 				pppoe_printf(NULL, "%s\n", err_msg);
    807   1.88    martin 			if (errortag || m == NULL)
    808   1.46    martin 				goto done;
    809    1.1    martin 		}
    810   1.29    itojun 		off += sizeof(*pt) + len;
    811    1.1    martin 	}
    812   1.29    itojun breakbreak:;
    813  1.145      maxv 
    814   1.29    itojun 	switch (ph->code) {
    815    1.1    martin 	case PPPOE_CODE_PADI:
    816   1.43       oki #ifdef PPPOE_SERVER
    817   1.43       oki 		/*
    818   1.43       oki 		 * got service name, concentrator name, and/or host unique.
    819   1.43       oki 		 * ignore if we have no interfaces with IFF_PASSIVE|IFF_UP.
    820   1.43       oki 		 */
    821  1.140  yamaguch 		rw_enter(&pppoe_softc_list_lock, RW_READER);
    822  1.140  yamaguch 		if (LIST_EMPTY(&pppoe_softc_list)) {
    823  1.140  yamaguch 			rw_exit(&pppoe_softc_list_lock);
    824   1.43       oki 			goto done;
    825  1.140  yamaguch 		}
    826  1.140  yamaguch 
    827   1.43       oki 		LIST_FOREACH(sc, &pppoe_softc_list, sc_list) {
    828  1.127  knakahar 			PPPOE_LOCK(sc, RW_WRITER);
    829  1.120  knakahar 			if (!(sc->sc_sppp.pp_if.if_flags & IFF_UP)) {
    830  1.127  knakahar 				PPPOE_UNLOCK(sc);
    831   1.43       oki 				continue;
    832  1.120  knakahar 			}
    833  1.120  knakahar 			if (!(sc->sc_sppp.pp_if.if_flags & IFF_PASSIVE)) {
    834  1.127  knakahar 				PPPOE_UNLOCK(sc);
    835   1.43       oki 				continue;
    836  1.120  knakahar 			}
    837  1.120  knakahar 
    838  1.127  knakahar 			if (sc->sc_state == PPPOE_STATE_INITIAL)
    839   1.43       oki 				break;
    840  1.120  knakahar 
    841  1.127  knakahar 			PPPOE_UNLOCK(sc);
    842   1.43       oki 		}
    843  1.120  knakahar 		rw_exit(&pppoe_softc_list_lock);
    844  1.120  knakahar 
    845   1.43       oki 		if (sc == NULL) {
    846   1.43       oki 			goto done;
    847   1.43       oki 		}
    848  1.120  knakahar 
    849   1.43       oki 		if (hunique) {
    850   1.43       oki 			if (sc->sc_hunique)
    851   1.43       oki 				free(sc->sc_hunique, M_DEVBUF);
    852   1.43       oki 			sc->sc_hunique = malloc(hunique_len, M_DEVBUF,
    853   1.43       oki 			    M_DONTWAIT);
    854  1.120  knakahar 			if (sc->sc_hunique == NULL) {
    855  1.127  knakahar 				PPPOE_UNLOCK(sc);
    856   1.43       oki 				goto done;
    857  1.120  knakahar 			}
    858   1.43       oki 			sc->sc_hunique_len = hunique_len;
    859   1.43       oki 			memcpy(sc->sc_hunique, hunique, hunique_len);
    860   1.43       oki 		}
    861   1.44       oki 		memcpy(&sc->sc_dest, eh->ether_shost, sizeof sc->sc_dest);
    862   1.43       oki 		sc->sc_state = PPPOE_STATE_PADO_SENT;
    863   1.43       oki 		pppoe_send_pado(sc);
    864  1.127  knakahar 		PPPOE_UNLOCK(sc);
    865   1.43       oki 		break;
    866   1.43       oki #endif /* PPPOE_SERVER */
    867  1.145      maxv 
    868    1.1    martin 	case PPPOE_CODE_PADR:
    869   1.43       oki #ifdef PPPOE_SERVER
    870   1.43       oki 		/*
    871   1.43       oki 		 * get sc from ac_cookie if IFF_PASSIVE
    872   1.43       oki 		 */
    873   1.43       oki 		if (ac_cookie == NULL) {
    874   1.43       oki 			goto done;
    875   1.43       oki 		}
    876  1.125     ozaki 
    877  1.125     ozaki 		rcvif = m_get_rcvif_psref(m, &psref);
    878  1.125     ozaki 		if (__predict_true(rcvif != NULL)) {
    879  1.125     ozaki 			sc = pppoe_find_softc_by_hunique(ac_cookie,
    880  1.145      maxv 			    ac_cookie_len, rcvif, RW_WRITER);
    881  1.125     ozaki 		}
    882  1.125     ozaki 		m_put_rcvif_psref(rcvif, &psref);
    883   1.43       oki 		if (sc == NULL) {
    884   1.43       oki 			/* be quiet if there is not a single pppoe instance */
    885  1.140  yamaguch 			rw_enter(&pppoe_softc_list_lock, RW_READER);
    886  1.140  yamaguch 			if (!LIST_EMPTY(&pppoe_softc_list)) {
    887  1.157  yamaguch 				pppoe_printf(NULL, "received PADR"
    888  1.140  yamaguch 				    " but could not find request for it\n");
    889  1.140  yamaguch 			}
    890  1.140  yamaguch 			rw_exit(&pppoe_softc_list_lock);
    891   1.43       oki 			goto done;
    892   1.43       oki 		}
    893  1.120  knakahar 
    894  1.127  knakahar 		if (sc->sc_state != PPPOE_STATE_PADO_SENT) {
    895  1.157  yamaguch 			pppoe_printf(sc, "received unexpected PADR\n");
    896  1.127  knakahar 			PPPOE_UNLOCK(sc);
    897   1.43       oki 			goto done;
    898   1.43       oki 		}
    899  1.127  knakahar 
    900   1.43       oki 		if (hunique) {
    901   1.43       oki 			if (sc->sc_hunique)
    902   1.43       oki 				free(sc->sc_hunique, M_DEVBUF);
    903   1.43       oki 			sc->sc_hunique = malloc(hunique_len, M_DEVBUF,
    904   1.43       oki 			    M_DONTWAIT);
    905  1.120  knakahar 			if (sc->sc_hunique == NULL) {
    906  1.127  knakahar 				PPPOE_UNLOCK(sc);
    907   1.43       oki 				goto done;
    908  1.120  knakahar 			}
    909   1.43       oki 			sc->sc_hunique_len = hunique_len;
    910   1.43       oki 			memcpy(sc->sc_hunique, hunique, hunique_len);
    911   1.43       oki 		}
    912   1.43       oki 		pppoe_send_pads(sc);
    913   1.43       oki 		sc->sc_state = PPPOE_STATE_SESSION;
    914  1.127  knakahar 		PPPOE_UNLOCK(sc);
    915  1.120  knakahar 
    916   1.43       oki 		sc->sc_sppp.pp_up(&sc->sc_sppp);
    917   1.43       oki 		break;
    918   1.43       oki #else
    919    1.1    martin 		/* ignore, we are no access concentrator */
    920   1.29    itojun 		goto done;
    921   1.43       oki #endif /* PPPOE_SERVER */
    922  1.145      maxv 
    923    1.1    martin 	case PPPOE_CODE_PADO:
    924  1.139  yamaguch 		rcvif = m_get_rcvif_psref(m, &psref);
    925  1.139  yamaguch 		if (__predict_false(rcvif == NULL))
    926  1.139  yamaguch 			goto done;
    927  1.139  yamaguch 
    928  1.139  yamaguch 		if (hunique != NULL) {
    929  1.139  yamaguch 			sc = pppoe_find_softc_by_hunique(hunique,
    930  1.145      maxv 			    hunique_len, rcvif, RW_WRITER);
    931  1.139  yamaguch 		}
    932  1.139  yamaguch 
    933  1.139  yamaguch 		m_put_rcvif_psref(rcvif, &psref);
    934  1.139  yamaguch 
    935    1.1    martin 		if (sc == NULL) {
    936   1.33      tron 			/* be quiet if there is not a single pppoe instance */
    937  1.140  yamaguch 			rw_enter(&pppoe_softc_list_lock, RW_READER);
    938  1.140  yamaguch 			if (!LIST_EMPTY(&pppoe_softc_list)) {
    939  1.157  yamaguch 				pppoe_printf(NULL, "received PADO"
    940  1.140  yamaguch 				    " but could not find request for it\n");
    941  1.140  yamaguch 			}
    942  1.140  yamaguch 			rw_exit(&pppoe_softc_list_lock);
    943   1.29    itojun 			goto done;
    944    1.1    martin 		}
    945  1.120  knakahar 
    946  1.127  knakahar 		if (sc->sc_state != PPPOE_STATE_PADI_SENT) {
    947  1.157  yamaguch 			pppoe_printf(sc, "received unexpected PADO\n");
    948  1.127  knakahar 			PPPOE_UNLOCK(sc);
    949   1.29    itojun 			goto done;
    950    1.1    martin 		}
    951  1.120  knakahar 
    952    1.1    martin 		if (ac_cookie) {
    953   1.32      yamt 			if (sc->sc_ac_cookie)
    954   1.32      yamt 				free(sc->sc_ac_cookie, M_DEVBUF);
    955   1.29    itojun 			sc->sc_ac_cookie = malloc(ac_cookie_len, M_DEVBUF,
    956   1.29    itojun 			    M_DONTWAIT);
    957   1.89    martin 			if (sc->sc_ac_cookie == NULL) {
    958  1.157  yamaguch 				pppoe_printf(sc, "FATAL: could not allocate memory "
    959  1.157  yamaguch 				    "for AC cookie\n");
    960  1.127  knakahar 				PPPOE_UNLOCK(sc);
    961   1.29    itojun 				goto done;
    962   1.89    martin 			}
    963    1.1    martin 			sc->sc_ac_cookie_len = ac_cookie_len;
    964    1.1    martin 			memcpy(sc->sc_ac_cookie, ac_cookie, ac_cookie_len);
    965    1.1    martin 		}
    966   1.94  christos 		if (relay_sid) {
    967   1.94  christos 			if (sc->sc_relay_sid)
    968   1.94  christos 				free(sc->sc_relay_sid, M_DEVBUF);
    969   1.94  christos 			sc->sc_relay_sid = malloc(relay_sid_len, M_DEVBUF,
    970   1.94  christos 			    M_DONTWAIT);
    971   1.94  christos 			if (sc->sc_relay_sid == NULL) {
    972  1.157  yamaguch 				pppoe_printf(sc, "FATAL: could not allocate memory "
    973  1.157  yamaguch 				    "for relay SID\n");
    974  1.127  knakahar 				PPPOE_UNLOCK(sc);
    975   1.94  christos 				goto done;
    976   1.94  christos 			}
    977   1.94  christos 			sc->sc_relay_sid_len = relay_sid_len;
    978   1.94  christos 			memcpy(sc->sc_relay_sid, relay_sid, relay_sid_len);
    979   1.94  christos 		}
    980    1.1    martin 		memcpy(&sc->sc_dest, eh->ether_shost, sizeof sc->sc_dest);
    981    1.1    martin 		callout_stop(&sc->sc_timeout);
    982    1.1    martin 		sc->sc_padr_retried = 0;
    983    1.1    martin 		sc->sc_state = PPPOE_STATE_PADR_SENT;
    984   1.45    martin 		if ((err = pppoe_send_padr(sc)) != 0) {
    985  1.157  yamaguch 			pppoe_printf(sc,
    986  1.157  yamaguch 			    "failed to send PADR, error=%d\n", err);
    987   1.45    martin 		}
    988  1.150  yamaguch 		callout_schedule(&sc->sc_timeout,
    989  1.150  yamaguch 		    PPPOE_DISC_TIMEOUT * (1 + sc->sc_padr_retried));
    990  1.120  knakahar 
    991  1.127  knakahar 		PPPOE_UNLOCK(sc);
    992    1.1    martin 		break;
    993  1.145      maxv 
    994    1.1    martin 	case PPPOE_CODE_PADS:
    995  1.139  yamaguch 		rcvif = m_get_rcvif_psref(m, &psref);
    996  1.139  yamaguch 		if (__predict_false(rcvif == NULL))
    997  1.139  yamaguch 			goto done;
    998  1.139  yamaguch 
    999  1.139  yamaguch 		if (hunique != NULL) {
   1000  1.139  yamaguch 			sc = pppoe_find_softc_by_hunique(hunique,
   1001  1.145      maxv 			    hunique_len, rcvif, RW_WRITER);
   1002  1.139  yamaguch 		}
   1003  1.139  yamaguch 
   1004  1.139  yamaguch 		m_put_rcvif_psref(rcvif, &psref);
   1005  1.139  yamaguch 
   1006    1.1    martin 		if (sc == NULL)
   1007   1.29    itojun 			goto done;
   1008  1.120  knakahar 
   1009    1.1    martin 		sc->sc_session = session;
   1010    1.1    martin 		callout_stop(&sc->sc_timeout);
   1011  1.157  yamaguch 		pppoe_printf(sc, "session 0x%x connected\n", session);
   1012    1.1    martin 		sc->sc_state = PPPOE_STATE_SESSION;
   1013  1.127  knakahar 		PPPOE_UNLOCK(sc);
   1014  1.120  knakahar 
   1015    1.1    martin 		sc->sc_sppp.pp_up(&sc->sc_sppp);	/* notify upper layers */
   1016    1.1    martin 		break;
   1017  1.145      maxv 
   1018  1.139  yamaguch 	case PPPOE_CODE_PADT:
   1019  1.139  yamaguch 		rcvif = m_get_rcvif_psref(m, &psref);
   1020  1.139  yamaguch 		if (__predict_false(rcvif == NULL))
   1021  1.139  yamaguch 			goto done;
   1022  1.139  yamaguch 
   1023  1.139  yamaguch 		sc = pppoe_find_softc_by_session(session, rcvif,
   1024  1.139  yamaguch 		    RW_WRITER);
   1025  1.108     ozaki 
   1026  1.125     ozaki 		m_put_rcvif_psref(rcvif, &psref);
   1027  1.139  yamaguch 
   1028    1.1    martin 		if (sc == NULL)
   1029   1.29    itojun 			goto done;
   1030  1.120  knakahar 
   1031   1.57    martin 		pppoe_clear_softc(sc, "received PADT");
   1032  1.158  yamaguch 		if (sc->sc_sppp.pp_if.if_flags & IFF_RUNNING)
   1033  1.158  yamaguch 			callout_schedule(&sc->sc_timeout, PPPOE_RECON_FAST);
   1034  1.127  knakahar 		PPPOE_UNLOCK(sc);
   1035   1.25    itojun 		break;
   1036  1.145      maxv 
   1037   1.25    itojun 	default:
   1038  1.139  yamaguch 		rcvif = m_get_rcvif_psref(m, &psref);
   1039  1.139  yamaguch 		if (__predict_false(rcvif == NULL))
   1040  1.139  yamaguch 			goto done;
   1041  1.139  yamaguch 
   1042  1.139  yamaguch 		if (hunique != NULL) {
   1043  1.139  yamaguch 			sc = pppoe_find_softc_by_hunique(hunique,
   1044  1.145      maxv 			    hunique_len, rcvif, RW_READER);
   1045  1.139  yamaguch 		}
   1046  1.139  yamaguch 
   1047  1.139  yamaguch 		m_put_rcvif_psref(rcvif, &psref);
   1048  1.139  yamaguch 
   1049  1.157  yamaguch 		pppoe_printf(sc, "unknown code (0x%04x) session = 0x%04x\n",
   1050  1.157  yamaguch 		    ph->code, session);
   1051  1.157  yamaguch 		if (sc == NULL)
   1052  1.157  yamaguch 			goto done;
   1053  1.157  yamaguch 		PPPOE_UNLOCK(sc);
   1054   1.25    itojun 		break;
   1055   1.25    itojun 	}
   1056   1.29    itojun 
   1057   1.29    itojun done:
   1058   1.65  christos 	if (m)
   1059   1.65  christos 		m_freem(m);
   1060   1.29    itojun 	return;
   1061    1.1    martin }
   1062    1.1    martin 
   1063    1.1    martin static void
   1064    1.1    martin pppoe_disc_input(struct mbuf *m)
   1065    1.1    martin {
   1066  1.137      maxv 	KASSERT(m->m_flags & M_PKTHDR);
   1067    1.1    martin 
   1068  1.137      maxv 	/*
   1069  1.137      maxv 	 * Avoid error messages if there is not a single PPPoE instance.
   1070  1.137      maxv 	 */
   1071  1.140  yamaguch 	rw_enter(&pppoe_softc_list_lock, RW_READER);
   1072   1.25    itojun 	if (!LIST_EMPTY(&pppoe_softc_list)) {
   1073  1.140  yamaguch 		rw_exit(&pppoe_softc_list_lock);
   1074   1.29    itojun 		pppoe_dispatch_disc_pkt(m, 0);
   1075  1.137      maxv 	} else {
   1076  1.140  yamaguch 		rw_exit(&pppoe_softc_list_lock);
   1077   1.29    itojun 		m_freem(m);
   1078  1.137      maxv 	}
   1079    1.1    martin }
   1080    1.1    martin 
   1081  1.136  knakahar static bool
   1082  1.136  knakahar pppoe_is_my_frame(uint8_t *dhost, struct ifnet *rcvif)
   1083  1.136  knakahar {
   1084  1.136  knakahar 
   1085  1.136  knakahar 	if (memcmp(CLLADDR(rcvif->if_sadl), dhost, ETHER_ADDR_LEN) == 0)
   1086  1.136  knakahar 		return true;
   1087  1.136  knakahar 
   1088  1.136  knakahar 	return false;
   1089  1.136  knakahar }
   1090  1.136  knakahar 
   1091    1.1    martin static void
   1092    1.1    martin pppoe_data_input(struct mbuf *m)
   1093    1.1    martin {
   1094   1.84      matt 	uint16_t session, plen;
   1095   1.25    itojun 	struct pppoe_softc *sc;
   1096   1.29    itojun 	struct pppoehdr *ph;
   1097  1.108     ozaki 	struct ifnet *rcvif;
   1098  1.108     ozaki 	struct psref psref;
   1099   1.84      matt 	uint8_t shost[ETHER_ADDR_LEN];
   1100  1.136  knakahar 	uint8_t dhost[ETHER_ADDR_LEN];
   1101  1.135  knakahar 	bool term_unknown = pppoe_term_unknown;
   1102    1.1    martin 
   1103   1.25    itojun 	KASSERT(m->m_flags & M_PKTHDR);
   1104   1.25    itojun 
   1105  1.137      maxv 	/*
   1106  1.137      maxv 	 * Avoid error messages if there is not a single PPPoE instance.
   1107  1.137      maxv 	 */
   1108  1.140  yamaguch 	rw_enter(&pppoe_softc_list_lock, RW_READER);
   1109  1.137      maxv 	if (LIST_EMPTY(&pppoe_softc_list)) {
   1110  1.140  yamaguch 		rw_exit(&pppoe_softc_list_lock);
   1111  1.137      maxv 		goto drop;
   1112  1.137      maxv 	}
   1113  1.140  yamaguch 	rw_exit(&pppoe_softc_list_lock);
   1114  1.137      maxv 
   1115  1.136  knakahar 	if (term_unknown) {
   1116  1.117  christos 		memcpy(shost, mtod(m, struct ether_header*)->ether_shost,
   1117  1.117  christos 		    ETHER_ADDR_LEN);
   1118  1.136  knakahar 		memcpy(dhost, mtod(m, struct ether_header*)->ether_dhost,
   1119  1.136  knakahar 		    ETHER_ADDR_LEN);
   1120  1.136  knakahar 	}
   1121   1.25    itojun 	m_adj(m, sizeof(struct ether_header));
   1122   1.25    itojun 	if (m->m_pkthdr.len <= PPPOE_HEADERLEN) {
   1123   1.25    itojun 		goto drop;
   1124   1.25    itojun 	}
   1125   1.25    itojun 
   1126   1.30    itojun 	if (m->m_len < sizeof(*ph)) {
   1127   1.30    itojun 		m = m_pullup(m, sizeof(*ph));
   1128  1.145      maxv 		if (m == NULL) {
   1129   1.30    itojun 			return;
   1130   1.30    itojun 		}
   1131   1.29    itojun 	}
   1132   1.29    itojun 	ph = mtod(m, struct pppoehdr *);
   1133   1.25    itojun 
   1134   1.29    itojun 	if (ph->vertype != PPPOE_VERTYPE) {
   1135   1.25    itojun 		goto drop;
   1136   1.25    itojun 	}
   1137  1.146      maxv 	if (ph->code != 0) {
   1138   1.25    itojun 		goto drop;
   1139  1.146      maxv 	}
   1140   1.25    itojun 
   1141   1.29    itojun 	session = ntohs(ph->session);
   1142  1.108     ozaki 	rcvif = m_get_rcvif_psref(m, &psref);
   1143  1.110     ozaki 	if (__predict_false(rcvif == NULL))
   1144  1.110     ozaki 		goto drop;
   1145  1.120  knakahar 	sc = pppoe_find_softc_by_session(session, rcvif, RW_READER);
   1146   1.34    martin 	if (sc == NULL) {
   1147  1.135  knakahar 		if (term_unknown) {
   1148  1.136  knakahar 			static struct timeval lasttime = {0, 0};
   1149  1.136  knakahar 			static int curpps = 0;
   1150  1.136  knakahar 			/*
   1151  1.136  knakahar 			 * avoid to send wrong PADT which is response from
   1152  1.147   msaitoh 			 * session stage packets for other hosts when parent
   1153  1.136  knakahar 			 * ethernet is promiscuous mode.
   1154  1.136  knakahar 			 */
   1155  1.145      maxv 			if (pppoe_is_my_frame(dhost, rcvif) &&
   1156  1.145      maxv 			    ppsratecheck(&lasttime, &curpps,
   1157  1.136  knakahar 				pppoe_term_unknown_pps)) {
   1158  1.157  yamaguch 				pppoe_printf(NULL, "input for unknown session %#x, "
   1159  1.136  knakahar 				    "sending PADT\n", session);
   1160  1.136  knakahar 				pppoe_send_padt(rcvif, session, shost);
   1161  1.136  knakahar 			}
   1162  1.113  pgoyette 		}
   1163  1.108     ozaki 		m_put_rcvif_psref(rcvif, &psref);
   1164   1.25    itojun 		goto drop;
   1165   1.34    martin 	}
   1166  1.120  knakahar 
   1167  1.108     ozaki 	m_put_rcvif_psref(rcvif, &psref);
   1168   1.25    itojun 
   1169   1.29    itojun 	plen = ntohs(ph->plen);
   1170    1.1    martin 
   1171  1.141   msaitoh 	bpf_mtap(&sc->sc_sppp.pp_if, m, BPF_D_IN);
   1172    1.1    martin 
   1173   1.25    itojun 	m_adj(m, PPPOE_HEADERLEN);
   1174    1.1    martin 
   1175    1.1    martin #ifdef PPPOE_DEBUG
   1176   1.25    itojun 	{
   1177   1.25    itojun 		struct mbuf *p;
   1178    1.1    martin 
   1179   1.25    itojun 		printf("%s: pkthdr.len=%d, pppoe.len=%d",
   1180  1.129   msaitoh 		    sc->sc_sppp.pp_if.if_xname, m->m_pkthdr.len, plen);
   1181   1.25    itojun 		p = m;
   1182   1.25    itojun 		while (p) {
   1183   1.25    itojun 			printf(" l=%d", p->m_len);
   1184   1.25    itojun 			p = p->m_next;
   1185   1.25    itojun 		}
   1186   1.25    itojun 		printf("\n");
   1187   1.25    itojun 	}
   1188    1.1    martin #endif
   1189  1.127  knakahar 	PPPOE_UNLOCK(sc);
   1190   1.26    itojun 
   1191   1.25    itojun 	if (m->m_pkthdr.len < plen)
   1192   1.25    itojun 		goto drop;
   1193   1.25    itojun 
   1194  1.156  yamaguch 	/* ignore trailing garbage */
   1195  1.156  yamaguch 	m_adj(m, plen - m->m_pkthdr.len);
   1196  1.129   msaitoh 	/*
   1197  1.145      maxv 	 * Fix incoming interface pointer (not the raw ethernet interface
   1198  1.129   msaitoh 	 * anymore)
   1199  1.129   msaitoh 	 */
   1200  1.107     ozaki 	m_set_rcvif(m, &sc->sc_sppp.pp_if);
   1201   1.25    itojun 
   1202   1.25    itojun 	/* pass packet up and account for it */
   1203  1.148   thorpej 	if_statinc(&sc->sc_sppp.pp_if, if_ipackets);
   1204   1.25    itojun 	sppp_input(&sc->sc_sppp.pp_if, m);
   1205   1.25    itojun 	return;
   1206    1.1    martin 
   1207    1.1    martin drop:
   1208   1.29    itojun 	m_freem(m);
   1209    1.1    martin }
   1210    1.1    martin 
   1211    1.1    martin static int
   1212    1.1    martin pppoe_output(struct pppoe_softc *sc, struct mbuf *m)
   1213    1.1    martin {
   1214   1.25    itojun 	struct sockaddr dst;
   1215   1.25    itojun 	struct ether_header *eh;
   1216   1.84      matt 	uint16_t etype;
   1217   1.25    itojun 
   1218   1.52       oki 	if (sc->sc_eth_if == NULL) {
   1219   1.52       oki 		m_freem(m);
   1220   1.25    itojun 		return EIO;
   1221   1.52       oki 	}
   1222   1.25    itojun 
   1223   1.25    itojun 	memset(&dst, 0, sizeof dst);
   1224   1.25    itojun 	dst.sa_family = AF_UNSPEC;
   1225   1.25    itojun 	eh = (struct ether_header*)&dst.sa_data;
   1226  1.129   msaitoh 	etype = sc->sc_state == PPPOE_STATE_SESSION
   1227  1.129   msaitoh 	    ? ETHERTYPE_PPPOE : ETHERTYPE_PPPOEDISC;
   1228   1.25    itojun 	eh->ether_type = htons(etype);
   1229   1.25    itojun 	memcpy(&eh->ether_dhost, &sc->sc_dest, sizeof sc->sc_dest);
   1230    1.1    martin 
   1231  1.157  yamaguch 	DPRINTF(sc, "(%x) state=%d, session=0x%x output -> %s, len=%d\n",
   1232  1.157  yamaguch 	    etype, sc->sc_state, sc->sc_session,
   1233    1.1    martin 	    ether_sprintf((const unsigned char *)&sc->sc_dest), m->m_pkthdr.len);
   1234    1.1    martin 
   1235   1.22    martin 	m->m_flags &= ~(M_BCAST|M_MCAST);
   1236  1.148   thorpej 	if_statinc(&sc->sc_sppp.pp_if, if_opackets);
   1237  1.109  knakahar 	return if_output_lock(sc->sc_eth_if, sc->sc_eth_if, m, &dst, NULL);
   1238    1.1    martin }
   1239    1.1    martin 
   1240    1.1    martin static int
   1241  1.153  yamaguch pppoe_parm_cpyinstr(struct pppoe_softc *sc,
   1242  1.153  yamaguch     char **dst, const void *src, size_t len)
   1243  1.153  yamaguch {
   1244  1.153  yamaguch 	int error = 0;
   1245  1.153  yamaguch 	char *next = NULL;
   1246  1.153  yamaguch 	size_t bufsiz, cpysiz, strsiz;
   1247  1.153  yamaguch 
   1248  1.153  yamaguch 	bufsiz = len + 1;
   1249  1.153  yamaguch 
   1250  1.153  yamaguch 	if (src == NULL)
   1251  1.153  yamaguch 		goto out;
   1252  1.153  yamaguch 
   1253  1.153  yamaguch 	bufsiz = len + 1;
   1254  1.153  yamaguch 	next = malloc(bufsiz, M_DEVBUF, M_WAITOK);
   1255  1.153  yamaguch 	if (next == NULL)
   1256  1.153  yamaguch 		return ENOMEM;
   1257  1.153  yamaguch 
   1258  1.153  yamaguch 	error = copyinstr(src, next, bufsiz, &cpysiz);
   1259  1.153  yamaguch 	if (error != 0)
   1260  1.153  yamaguch 		goto fail;
   1261  1.153  yamaguch 	if (cpysiz != bufsiz) {
   1262  1.153  yamaguch 		error = EINVAL;
   1263  1.153  yamaguch 		goto fail;
   1264  1.153  yamaguch 	}
   1265  1.153  yamaguch 
   1266  1.153  yamaguch 	strsiz = strnlen(next, bufsiz);
   1267  1.153  yamaguch 	if (strsiz == bufsiz) {
   1268  1.153  yamaguch 		error = EINVAL;
   1269  1.153  yamaguch 		goto fail;
   1270  1.153  yamaguch 	}
   1271  1.153  yamaguch 
   1272  1.153  yamaguch out:
   1273  1.153  yamaguch 	PPPOE_LOCK(sc, RW_WRITER);
   1274  1.153  yamaguch 	if (*dst != NULL)
   1275  1.153  yamaguch 		free(*dst, M_DEVBUF);
   1276  1.153  yamaguch 	*dst = next;
   1277  1.153  yamaguch 	next = NULL;
   1278  1.153  yamaguch 	PPPOE_UNLOCK(sc);
   1279  1.153  yamaguch fail:
   1280  1.153  yamaguch 	if (next != NULL)
   1281  1.153  yamaguch 		free(next, M_DEVBUF);
   1282  1.153  yamaguch 
   1283  1.153  yamaguch 	return error;
   1284  1.153  yamaguch }
   1285  1.153  yamaguch 
   1286  1.153  yamaguch static int
   1287   1.77  christos pppoe_ioctl(struct ifnet *ifp, unsigned long cmd, void *data)
   1288    1.1    martin {
   1289   1.70        ad 	struct lwp *l = curlwp;	/* XXX */
   1290    1.1    martin 	struct pppoe_softc *sc = (struct pppoe_softc*)ifp;
   1291   1.83    dyoung 	struct ifreq *ifr = data;
   1292    1.1    martin 	int error = 0;
   1293    1.1    martin 
   1294    1.1    martin 	switch (cmd) {
   1295    1.1    martin 	case PPPOESETPARMS:
   1296    1.1    martin 	{
   1297    1.1    martin 		struct pppoediscparms *parms = (struct pppoediscparms*)data;
   1298   1.74      elad 		if (kauth_authorize_network(l->l_cred, KAUTH_NETWORK_INTERFACE,
   1299   1.74      elad 		    KAUTH_REQ_NETWORK_INTERFACE_SETPRIV, ifp, (void *)cmd,
   1300   1.74      elad 		    NULL) != 0)
   1301  1.129   msaitoh 			return EPERM;
   1302    1.1    martin 		if (parms->eth_ifname[0] != 0) {
   1303  1.145      maxv 			struct ifnet *eth_if;
   1304   1.67      tron 
   1305  1.127  knakahar 			PPPOE_LOCK(sc, RW_WRITER);
   1306  1.167  yamaguch 			if (sc->sc_detaching) {
   1307  1.167  yamaguch 				PPPOE_UNLOCK(sc);
   1308  1.167  yamaguch 				return ENXIO;
   1309  1.167  yamaguch 			}
   1310   1.67      tron 			eth_if = ifunit(parms->eth_ifname);
   1311   1.67      tron 			if (eth_if == NULL || eth_if->if_dlt != DLT_EN10MB) {
   1312   1.66      tron 				sc->sc_eth_if = NULL;
   1313  1.127  knakahar 				PPPOE_UNLOCK(sc);
   1314    1.1    martin 				return ENXIO;
   1315   1.66      tron 			}
   1316   1.67      tron 
   1317   1.98       rjs 			if (sc->sc_sppp.pp_if.if_mtu !=
   1318   1.67      tron 			    eth_if->if_mtu - PPPOE_OVERHEAD) {
   1319   1.67      tron 				sc->sc_sppp.pp_if.if_mtu = eth_if->if_mtu -
   1320   1.67      tron 				    PPPOE_OVERHEAD;
   1321   1.67      tron 			}
   1322   1.67      tron 			sc->sc_eth_if = eth_if;
   1323  1.127  knakahar 			PPPOE_UNLOCK(sc);
   1324    1.1    martin 		}
   1325  1.120  knakahar 
   1326  1.153  yamaguch 		error = pppoe_parm_cpyinstr(sc, &sc->sc_concentrator_name,
   1327  1.153  yamaguch 		    parms->ac_name, parms->ac_name_len);
   1328  1.153  yamaguch 		if (error != 0)
   1329  1.153  yamaguch 			return error;
   1330  1.153  yamaguch 
   1331  1.153  yamaguch 		error = pppoe_parm_cpyinstr(sc, &sc->sc_service_name,
   1332  1.153  yamaguch 		    parms->service_name, parms->service_name_len);
   1333  1.153  yamaguch 		if (error != 0)
   1334  1.153  yamaguch 			return error;
   1335    1.1    martin 		return 0;
   1336    1.1    martin 	}
   1337    1.1    martin 	break;
   1338    1.1    martin 	case PPPOEGETPARMS:
   1339    1.1    martin 	{
   1340    1.1    martin 		struct pppoediscparms *parms = (struct pppoediscparms*)data;
   1341    1.1    martin 		memset(parms, 0, sizeof *parms);
   1342  1.127  knakahar 		PPPOE_LOCK(sc, RW_READER);
   1343    1.1    martin 		if (sc->sc_eth_if)
   1344  1.106  christos 			strlcpy(parms->ifname, sc->sc_eth_if->if_xname,
   1345  1.106  christos 			    sizeof(parms->ifname));
   1346  1.127  knakahar 		PPPOE_UNLOCK(sc);
   1347   1.15    martin 		return 0;
   1348   1.15    martin 	}
   1349   1.15    martin 	break;
   1350   1.15    martin 	case PPPOEGETSESSION:
   1351   1.15    martin 	{
   1352   1.15    martin 		struct pppoeconnectionstate *state = (struct pppoeconnectionstate*)data;
   1353  1.127  knakahar 		PPPOE_LOCK(sc, RW_READER);
   1354   1.15    martin 		state->state = sc->sc_state;
   1355   1.15    martin 		state->session_id = sc->sc_session;
   1356   1.15    martin 		state->padi_retry_no = sc->sc_padi_retried;
   1357   1.15    martin 		state->padr_retry_no = sc->sc_padr_retried;
   1358  1.127  knakahar 		PPPOE_UNLOCK(sc);
   1359    1.1    martin 		return 0;
   1360    1.1    martin 	}
   1361    1.1    martin 	break;
   1362   1.13    martin 	case SIOCSIFFLAGS:
   1363   1.13    martin 		/*
   1364   1.13    martin 		 * Prevent running re-establishment timers overriding
   1365   1.13    martin 		 * administrators choice.
   1366   1.13    martin 		 */
   1367  1.127  knakahar 		PPPOE_LOCK(sc, RW_WRITER);
   1368  1.167  yamaguch 		if (sc->sc_detaching) {
   1369  1.167  yamaguch 			PPPOE_UNLOCK(sc);
   1370  1.167  yamaguch 			return ENXIO;
   1371  1.167  yamaguch 		}
   1372  1.120  knakahar 
   1373   1.14    martin 		if ((ifr->ifr_flags & IFF_UP) == 0
   1374   1.14    martin 		     && sc->sc_state < PPPOE_STATE_SESSION) {
   1375   1.13    martin 			callout_stop(&sc->sc_timeout);
   1376   1.14    martin 			sc->sc_state = PPPOE_STATE_INITIAL;
   1377   1.13    martin 			sc->sc_padi_retried = 0;
   1378   1.13    martin 			sc->sc_padr_retried = 0;
   1379   1.28    itojun 			memcpy(&sc->sc_dest, etherbroadcastaddr,
   1380   1.28    itojun 			    sizeof(sc->sc_dest));
   1381   1.13    martin 		}
   1382  1.120  knakahar 
   1383  1.127  knakahar 		PPPOE_UNLOCK(sc);
   1384  1.120  knakahar 
   1385  1.120  knakahar 		error = sppp_ioctl(ifp, cmd, data);
   1386  1.120  knakahar 
   1387  1.120  knakahar 		return error;
   1388   1.19    martin 	case SIOCSIFMTU:
   1389   1.67      tron 		if (ifr->ifr_mtu > (sc->sc_eth_if == NULL ?
   1390   1.67      tron 		    PPPOE_MAXMTU : (sc->sc_eth_if->if_mtu - PPPOE_OVERHEAD))) {
   1391   1.19    martin 			return EINVAL;
   1392   1.67      tron 		}
   1393   1.83    dyoung 		/*FALLTHROUGH*/
   1394    1.1    martin 	default:
   1395    1.1    martin 		return sppp_ioctl(ifp, cmd, data);
   1396    1.1    martin 	}
   1397    1.1    martin 	return 0;
   1398    1.1    martin }
   1399    1.1    martin 
   1400    1.1    martin /*
   1401    1.1    martin  * Allocate a mbuf/cluster with space to store the given data length
   1402    1.1    martin  * of payload, leaving space for prepending an ethernet header
   1403   1.59     perry  * in front.
   1404    1.1    martin  */
   1405    1.1    martin static struct mbuf *
   1406    1.1    martin pppoe_get_mbuf(size_t len)
   1407    1.1    martin {
   1408    1.1    martin 	struct mbuf *m;
   1409    1.1    martin 
   1410    1.1    martin 	MGETHDR(m, M_DONTWAIT, MT_DATA);
   1411    1.1    martin 	if (m == NULL)
   1412    1.1    martin 		return NULL;
   1413   1.26    itojun 	if (len + sizeof(struct ether_header) > MHLEN) {
   1414    1.1    martin 		MCLGET(m, M_DONTWAIT);
   1415    1.1    martin 		if ((m->m_flags & M_EXT) == 0) {
   1416  1.101    martin 			m_free(m);
   1417  1.101    martin 			return NULL;
   1418    1.1    martin 		}
   1419    1.1    martin 	}
   1420    1.1    martin 	m->m_data += sizeof(struct ether_header);
   1421    1.1    martin 	m->m_len = len;
   1422    1.1    martin 	m->m_pkthdr.len = len;
   1423  1.107     ozaki 	m_reset_rcvif(m);
   1424    1.1    martin 
   1425    1.1    martin 	return m;
   1426    1.1    martin }
   1427    1.1    martin 
   1428    1.1    martin static int
   1429    1.1    martin pppoe_send_padi(struct pppoe_softc *sc)
   1430    1.1    martin {
   1431    1.1    martin 	struct mbuf *m0;
   1432  1.142      maxv 	int len, l1 = 0, l2 = 0;
   1433   1.84      matt 	uint8_t *p;
   1434    1.1    martin 
   1435  1.142      maxv 	if (sc->sc_state > PPPOE_STATE_PADI_SENT)
   1436    1.1    martin 		panic("pppoe_send_padi in state %d", sc->sc_state);
   1437    1.1    martin 
   1438  1.142      maxv 	/* Compute packet length. */
   1439  1.142      maxv 	len = sizeof(struct pppoetag);
   1440    1.1    martin 	if (sc->sc_service_name != NULL) {
   1441    1.1    martin 		l1 = strlen(sc->sc_service_name);
   1442    1.1    martin 		len += l1;
   1443    1.1    martin 	}
   1444    1.1    martin 	if (sc->sc_concentrator_name != NULL) {
   1445    1.1    martin 		l2 = strlen(sc->sc_concentrator_name);
   1446  1.142      maxv 		len += sizeof(struct pppoetag) + l2;
   1447    1.1    martin 	}
   1448  1.143      maxv 	len += sizeof(struct pppoetag) + sizeof(sc->sc_id);
   1449   1.98       rjs 	if (sc->sc_sppp.pp_if.if_mtu > PPPOE_MAXMTU) {
   1450  1.142      maxv 		len += sizeof(struct pppoetag) + 2;
   1451   1.98       rjs 	}
   1452    1.1    martin 
   1453  1.142      maxv 	/* Allocate packet. */
   1454  1.142      maxv 	m0 = pppoe_get_mbuf(len + PPPOE_HEADERLEN);
   1455  1.142      maxv 	if (m0 == NULL)
   1456   1.26    itojun 		return ENOBUFS;
   1457    1.1    martin 
   1458  1.142      maxv 	/* Fill in packet. */
   1459   1.84      matt 	p = mtod(m0, uint8_t *);
   1460    1.1    martin 	PPPOE_ADD_HEADER(p, PPPOE_CODE_PADI, 0, len);
   1461    1.1    martin 	PPPOE_ADD_16(p, PPPOE_TAG_SNAME);
   1462    1.1    martin 	if (sc->sc_service_name != NULL) {
   1463    1.1    martin 		PPPOE_ADD_16(p, l1);
   1464    1.1    martin 		memcpy(p, sc->sc_service_name, l1);
   1465    1.1    martin 		p += l1;
   1466    1.1    martin 	} else {
   1467    1.1    martin 		PPPOE_ADD_16(p, 0);
   1468    1.1    martin 	}
   1469    1.1    martin 	if (sc->sc_concentrator_name != NULL) {
   1470    1.1    martin 		PPPOE_ADD_16(p, PPPOE_TAG_ACNAME);
   1471    1.1    martin 		PPPOE_ADD_16(p, l2);
   1472    1.1    martin 		memcpy(p, sc->sc_concentrator_name, l2);
   1473    1.1    martin 		p += l2;
   1474    1.1    martin 	}
   1475    1.1    martin 	PPPOE_ADD_16(p, PPPOE_TAG_HUNIQUE);
   1476  1.143      maxv 	PPPOE_ADD_16(p, sizeof(sc->sc_id));
   1477  1.143      maxv 	memcpy(p, &sc->sc_id, sizeof(sc->sc_id));
   1478  1.143      maxv 	p += sizeof(sc->sc_id);
   1479   1.98       rjs 
   1480   1.98       rjs 	if (sc->sc_sppp.pp_if.if_mtu > PPPOE_MAXMTU) {
   1481   1.98       rjs 		PPPOE_ADD_16(p, PPPOE_TAG_MAX_PAYLOAD);
   1482   1.98       rjs 		PPPOE_ADD_16(p, 2);
   1483   1.98       rjs 		PPPOE_ADD_16(p, (uint16_t)sc->sc_sppp.pp_if.if_mtu);
   1484   1.98       rjs 	}
   1485    1.1    martin 
   1486    1.1    martin #ifdef PPPOE_DEBUG
   1487   1.84      matt 	if (p - mtod(m0, uint8_t *) != len + PPPOE_HEADERLEN)
   1488    1.1    martin 		panic("pppoe_send_padi: garbled output len, should be %ld, is %ld",
   1489   1.84      matt 		    (long)(len + PPPOE_HEADERLEN), (long)(p - mtod(m0, uint8_t *)));
   1490    1.1    martin #endif
   1491    1.1    martin 
   1492  1.142      maxv 	/* Send packet. */
   1493    1.1    martin 	return pppoe_output(sc, m0);
   1494    1.1    martin }
   1495    1.1    martin 
   1496    1.1    martin static void
   1497  1.151  yamaguch pppoe_timeout_co(void *arg)
   1498  1.151  yamaguch {
   1499  1.151  yamaguch 	struct pppoe_softc *sc = (struct pppoe_softc *)arg;
   1500  1.151  yamaguch 
   1501  1.151  yamaguch 	if (atomic_swap_uint(&sc->sc_timeout_scheduled, 1) != 0)
   1502  1.151  yamaguch 		return;
   1503  1.151  yamaguch 
   1504  1.151  yamaguch 	workqueue_enqueue(sc->sc_timeout_wq, &sc->sc_timeout_wk, NULL);
   1505  1.151  yamaguch }
   1506  1.151  yamaguch 
   1507  1.151  yamaguch static void
   1508  1.151  yamaguch pppoe_timeout_co_halt(void *unused __unused)
   1509  1.151  yamaguch {
   1510  1.151  yamaguch 
   1511  1.151  yamaguch 	/* do nothing to halt callout safely */
   1512  1.151  yamaguch }
   1513  1.151  yamaguch 
   1514  1.151  yamaguch static void
   1515  1.151  yamaguch pppoe_timeout_wk(struct work *wk __unused, void *arg)
   1516  1.151  yamaguch {
   1517  1.151  yamaguch 	struct pppoe_softc *sc = (struct pppoe_softc *)arg;
   1518  1.151  yamaguch 
   1519  1.151  yamaguch 	atomic_swap_uint(&sc->sc_timeout_scheduled, 0);
   1520  1.151  yamaguch 	pppoe_timeout(sc);
   1521  1.151  yamaguch }
   1522  1.151  yamaguch 
   1523  1.151  yamaguch static void
   1524  1.151  yamaguch pppoe_timeout(struct pppoe_softc *sc)
   1525    1.1    martin {
   1526  1.120  knakahar 	int retry_wait, err;
   1527  1.120  knakahar 	DECLARE_SPLNET_VARIABLE;
   1528    1.1    martin 
   1529  1.157  yamaguch 	pppoe_printf(sc, "timeout\n");
   1530    1.1    martin 
   1531  1.127  knakahar 	PPPOE_LOCK(sc, RW_WRITER);
   1532    1.1    martin 	switch (sc->sc_state) {
   1533   1.90    martin 	case PPPOE_STATE_INITIAL:
   1534   1.90    martin 		/* delayed connect from pppoe_tls() */
   1535  1.167  yamaguch 		if (!sc->sc_detaching)
   1536  1.167  yamaguch 			pppoe_connect(sc);
   1537   1.90    martin 		break;
   1538    1.1    martin 	case PPPOE_STATE_PADI_SENT:
   1539   1.13    martin 		/*
   1540   1.13    martin 		 * We have two basic ways of retrying:
   1541   1.13    martin 		 *  - Quick retry mode: try a few times in short sequence
   1542   1.13    martin 		 *  - Slow retry mode: we already had a connection successfully
   1543   1.13    martin 		 *    established and will try infinitely (without user
   1544   1.13    martin 		 *    intervention)
   1545   1.13    martin 		 * We only enter slow retry mode if IFF_LINK1 (aka autodial)
   1546   1.35    martin 		 * is not set.
   1547   1.13    martin 		 */
   1548   1.13    martin 
   1549   1.13    martin 		/* initialize for quick retry mode */
   1550   1.30    itojun 		retry_wait = PPPOE_DISC_TIMEOUT * (1 + sc->sc_padi_retried);
   1551   1.13    martin 
   1552  1.120  knakahar 		ACQUIRE_SPLNET();
   1553    1.1    martin 		sc->sc_padi_retried++;
   1554    1.1    martin 		if (sc->sc_padi_retried >= PPPOE_DISC_MAXPADI) {
   1555   1.35    martin 			if ((sc->sc_sppp.pp_if.if_flags & IFF_LINK1) == 0) {
   1556   1.28    itojun 				/* slow retry mode */
   1557   1.28    itojun 				retry_wait = PPPOE_SLOW_RETRY;
   1558   1.13    martin 			} else {
   1559   1.28    itojun 				pppoe_abort_connect(sc);
   1560  1.121  knakahar 				RELEASE_SPLNET();
   1561  1.127  knakahar 				PPPOE_UNLOCK(sc);
   1562   1.28    itojun 				return;
   1563   1.13    martin 			}
   1564    1.1    martin 		}
   1565   1.45    martin 		if ((err = pppoe_send_padi(sc)) != 0) {
   1566   1.45    martin 			sc->sc_padi_retried--;
   1567  1.157  yamaguch 			pppoe_printf(sc,
   1568  1.157  yamaguch 			    "failed to transmit PADI, error=%d\n", err);
   1569   1.45    martin 		}
   1570  1.150  yamaguch 		callout_schedule(&sc->sc_timeout,retry_wait);
   1571  1.120  knakahar 		RELEASE_SPLNET();
   1572    1.1    martin 		break;
   1573    1.1    martin 
   1574    1.1    martin 	case PPPOE_STATE_PADR_SENT:
   1575  1.120  knakahar 		ACQUIRE_SPLNET();
   1576    1.1    martin 		sc->sc_padr_retried++;
   1577    1.1    martin 		if (sc->sc_padr_retried >= PPPOE_DISC_MAXPADR) {
   1578   1.28    itojun 			memcpy(&sc->sc_dest, etherbroadcastaddr,
   1579   1.28    itojun 			    sizeof(sc->sc_dest));
   1580    1.1    martin 			sc->sc_state = PPPOE_STATE_PADI_SENT;
   1581  1.161  yamaguch 			sc->sc_padi_retried = 0;
   1582    1.1    martin 			sc->sc_padr_retried = 0;
   1583   1.45    martin 			if ((err = pppoe_send_padi(sc)) != 0) {
   1584  1.157  yamaguch 				pppoe_printf(sc,
   1585  1.157  yamaguch 				    "failed to send PADI, error=%d\n", err);
   1586   1.45    martin 			}
   1587  1.150  yamaguch 			callout_schedule(&sc->sc_timeout,
   1588  1.150  yamaguch 			    PPPOE_DISC_TIMEOUT * (1 + sc->sc_padi_retried));
   1589  1.120  knakahar 			RELEASE_SPLNET();
   1590  1.127  knakahar 			PPPOE_UNLOCK(sc);
   1591    1.1    martin 			return;
   1592    1.1    martin 		}
   1593   1.45    martin 		if ((err = pppoe_send_padr(sc)) != 0) {
   1594   1.45    martin 			sc->sc_padr_retried--;
   1595  1.157  yamaguch 			pppoe_printf(sc,"failed to send PADR, error=%d", err);
   1596   1.45    martin 		}
   1597  1.150  yamaguch 		callout_schedule(&sc->sc_timeout,
   1598  1.150  yamaguch 		    PPPOE_DISC_TIMEOUT * (1 + sc->sc_padr_retried));
   1599  1.120  knakahar 		RELEASE_SPLNET();
   1600    1.1    martin 		break;
   1601    1.1    martin 	case PPPOE_STATE_CLOSING:
   1602    1.1    martin 		pppoe_disconnect(sc);
   1603    1.1    martin 		break;
   1604    1.1    martin 	default:
   1605  1.127  knakahar 		PPPOE_UNLOCK(sc);
   1606    1.1    martin 		return;	/* all done, work in peace */
   1607    1.1    martin 	}
   1608  1.127  knakahar 	PPPOE_UNLOCK(sc);
   1609    1.1    martin }
   1610    1.1    martin 
   1611    1.1    martin /* Start a connection (i.e. initiate discovery phase) */
   1612    1.1    martin static int
   1613    1.1    martin pppoe_connect(struct pppoe_softc *sc)
   1614    1.1    martin {
   1615  1.120  knakahar 	int err;
   1616  1.120  knakahar 	DECLARE_SPLNET_VARIABLE;
   1617  1.120  knakahar 
   1618  1.127  knakahar 	KASSERT(PPPOE_WLOCKED(sc));
   1619    1.1    martin 
   1620    1.1    martin 	if (sc->sc_state != PPPOE_STATE_INITIAL)
   1621    1.1    martin 		return EBUSY;
   1622    1.1    martin 
   1623   1.43       oki #ifdef PPPOE_SERVER
   1624   1.43       oki 	/* wait PADI if IFF_PASSIVE */
   1625   1.43       oki 	if ((sc->sc_sppp.pp_if.if_flags & IFF_PASSIVE))
   1626   1.43       oki 		return 0;
   1627   1.43       oki #endif
   1628  1.120  knakahar 	ACQUIRE_SPLNET();
   1629   1.36    martin 	/* save state, in case we fail to send PADI */
   1630    1.1    martin 	sc->sc_state = PPPOE_STATE_PADI_SENT;
   1631  1.161  yamaguch 	sc->sc_padi_retried = 0;
   1632    1.1    martin 	sc->sc_padr_retried = 0;
   1633    1.1    martin 	err = pppoe_send_padi(sc);
   1634  1.157  yamaguch 	if (err != 0)
   1635  1.157  yamaguch 		pppoe_printf(sc, "failed to send PADI, error=%d\n", err);
   1636  1.150  yamaguch 	callout_schedule(&sc->sc_timeout, PPPOE_DISC_TIMEOUT);
   1637  1.120  knakahar 	RELEASE_SPLNET();
   1638    1.1    martin 	return err;
   1639    1.1    martin }
   1640    1.1    martin 
   1641    1.1    martin /* disconnect */
   1642    1.1    martin static int
   1643    1.1    martin pppoe_disconnect(struct pppoe_softc *sc)
   1644    1.1    martin {
   1645  1.120  knakahar 	int err;
   1646  1.120  knakahar 	DECLARE_SPLNET_VARIABLE;
   1647  1.120  knakahar 
   1648  1.127  knakahar 	KASSERT(PPPOE_WLOCKED(sc));
   1649    1.1    martin 
   1650  1.120  knakahar 	ACQUIRE_SPLNET();
   1651    1.1    martin 
   1652    1.1    martin 	if (sc->sc_state < PPPOE_STATE_SESSION)
   1653    1.1    martin 		err = EBUSY;
   1654    1.1    martin 	else {
   1655  1.157  yamaguch 		pppoe_printf(sc, "disconnecting\n");
   1656  1.129   msaitoh 		err = pppoe_send_padt(sc->sc_eth_if, sc->sc_session,
   1657  1.129   msaitoh 		    (const uint8_t *)&sc->sc_dest);
   1658    1.1    martin 	}
   1659    1.1    martin 
   1660    1.1    martin 	/* cleanup softc */
   1661    1.1    martin 	sc->sc_state = PPPOE_STATE_INITIAL;
   1662  1.120  knakahar 
   1663    1.1    martin 	memcpy(&sc->sc_dest, etherbroadcastaddr, sizeof(sc->sc_dest));
   1664    1.1    martin 	if (sc->sc_ac_cookie) {
   1665   1.32      yamt 		free(sc->sc_ac_cookie, M_DEVBUF);
   1666    1.1    martin 		sc->sc_ac_cookie = NULL;
   1667    1.1    martin 	}
   1668    1.1    martin 	sc->sc_ac_cookie_len = 0;
   1669   1.94  christos 	if (sc->sc_relay_sid) {
   1670   1.94  christos 		free(sc->sc_relay_sid, M_DEVBUF);
   1671   1.94  christos 		sc->sc_relay_sid = NULL;
   1672   1.94  christos 	}
   1673   1.94  christos 	sc->sc_relay_sid_len = 0;
   1674   1.43       oki #ifdef PPPOE_SERVER
   1675   1.43       oki 	if (sc->sc_hunique) {
   1676   1.43       oki 		free(sc->sc_hunique, M_DEVBUF);
   1677   1.43       oki 		sc->sc_hunique = NULL;
   1678   1.43       oki 	}
   1679   1.43       oki 	sc->sc_hunique_len = 0;
   1680   1.43       oki #endif
   1681    1.1    martin 	sc->sc_session = 0;
   1682    1.1    martin 
   1683  1.127  knakahar 	PPPOE_UNLOCK(sc);
   1684  1.120  knakahar 
   1685    1.1    martin 	/* notify upper layer */
   1686    1.1    martin 	sc->sc_sppp.pp_down(&sc->sc_sppp);
   1687    1.1    martin 
   1688  1.127  knakahar 	PPPOE_LOCK(sc, RW_WRITER);
   1689    1.1    martin 
   1690  1.120  knakahar 	RELEASE_SPLNET();
   1691    1.1    martin 	return err;
   1692    1.1    martin }
   1693    1.1    martin 
   1694    1.1    martin /* Connection attempt aborted */
   1695    1.1    martin static void
   1696    1.1    martin pppoe_abort_connect(struct pppoe_softc *sc)
   1697    1.1    martin {
   1698  1.127  knakahar 	KASSERT(PPPOE_WLOCKED(sc));
   1699  1.120  knakahar 
   1700  1.157  yamaguch 	pppoe_printf(sc, "could not establish connection\n");
   1701   1.36    martin 	sc->sc_state = PPPOE_STATE_CLOSING;
   1702  1.120  knakahar 
   1703  1.127  knakahar 	PPPOE_UNLOCK(sc);
   1704    1.1    martin 
   1705    1.1    martin 	/* notify upper layer */
   1706    1.1    martin 	sc->sc_sppp.pp_down(&sc->sc_sppp);
   1707  1.120  knakahar 
   1708  1.127  knakahar 	PPPOE_LOCK(sc, RW_WRITER);
   1709   1.36    martin 
   1710   1.36    martin 	/* clear connection state */
   1711   1.36    martin 	memcpy(&sc->sc_dest, etherbroadcastaddr, sizeof(sc->sc_dest));
   1712   1.36    martin 	sc->sc_state = PPPOE_STATE_INITIAL;
   1713    1.1    martin }
   1714    1.1    martin 
   1715    1.1    martin static int
   1716    1.1    martin pppoe_send_padr(struct pppoe_softc *sc)
   1717    1.1    martin {
   1718    1.1    martin 	struct mbuf *m0;
   1719   1.84      matt 	uint8_t *p;
   1720  1.142      maxv 	size_t len, l1 = 0;
   1721    1.1    martin 
   1722    1.1    martin 	if (sc->sc_state != PPPOE_STATE_PADR_SENT)
   1723    1.1    martin 		return EIO;
   1724    1.1    martin 
   1725  1.142      maxv 	/* Compute packet length. */
   1726  1.142      maxv 	len = sizeof(struct pppoetag);
   1727  1.142      maxv 	if (sc->sc_service_name != NULL) {
   1728    1.1    martin 		l1 = strlen(sc->sc_service_name);
   1729    1.1    martin 		len += l1;
   1730    1.1    martin 	}
   1731  1.142      maxv 	if (sc->sc_ac_cookie_len > 0) {
   1732  1.142      maxv 		len += sizeof(struct pppoetag) + sc->sc_ac_cookie_len;
   1733  1.142      maxv 	}
   1734  1.142      maxv 	if (sc->sc_relay_sid_len > 0) {
   1735  1.142      maxv 		len += sizeof(struct pppoetag) + sc->sc_relay_sid_len;
   1736  1.142      maxv 	}
   1737  1.143      maxv 	len += sizeof(struct pppoetag) + sizeof(sc->sc_id);
   1738   1.98       rjs 	if (sc->sc_sppp.pp_if.if_mtu > PPPOE_MAXMTU) {
   1739  1.142      maxv 		len += sizeof(struct pppoetag) + 2;
   1740   1.98       rjs 	}
   1741  1.142      maxv 
   1742  1.142      maxv 	/* Allocate packet. */
   1743   1.26    itojun 	m0 = pppoe_get_mbuf(len + PPPOE_HEADERLEN);
   1744  1.142      maxv 	if (m0 == NULL)
   1745   1.26    itojun 		return ENOBUFS;
   1746  1.142      maxv 
   1747  1.142      maxv 	/* Fill in packet. */
   1748   1.84      matt 	p = mtod(m0, uint8_t *);
   1749    1.1    martin 	PPPOE_ADD_HEADER(p, PPPOE_CODE_PADR, 0, len);
   1750    1.1    martin 	PPPOE_ADD_16(p, PPPOE_TAG_SNAME);
   1751    1.1    martin 	if (sc->sc_service_name != NULL) {
   1752    1.1    martin 		PPPOE_ADD_16(p, l1);
   1753    1.1    martin 		memcpy(p, sc->sc_service_name, l1);
   1754    1.1    martin 		p += l1;
   1755    1.1    martin 	} else {
   1756    1.1    martin 		PPPOE_ADD_16(p, 0);
   1757    1.1    martin 	}
   1758    1.1    martin 	if (sc->sc_ac_cookie_len > 0) {
   1759    1.1    martin 		PPPOE_ADD_16(p, PPPOE_TAG_ACCOOKIE);
   1760    1.1    martin 		PPPOE_ADD_16(p, sc->sc_ac_cookie_len);
   1761    1.1    martin 		memcpy(p, sc->sc_ac_cookie, sc->sc_ac_cookie_len);
   1762    1.1    martin 		p += sc->sc_ac_cookie_len;
   1763    1.1    martin 	}
   1764   1.94  christos 	if (sc->sc_relay_sid_len > 0) {
   1765   1.94  christos 		PPPOE_ADD_16(p, PPPOE_TAG_RELAYSID);
   1766   1.94  christos 		PPPOE_ADD_16(p, sc->sc_relay_sid_len);
   1767   1.94  christos 		memcpy(p, sc->sc_relay_sid, sc->sc_relay_sid_len);
   1768   1.94  christos 		p += sc->sc_relay_sid_len;
   1769   1.94  christos 	}
   1770    1.1    martin 	PPPOE_ADD_16(p, PPPOE_TAG_HUNIQUE);
   1771  1.143      maxv 	PPPOE_ADD_16(p, sizeof(sc->sc_id));
   1772  1.143      maxv 	memcpy(p, &sc->sc_id, sizeof(sc->sc_id));
   1773  1.143      maxv 	p += sizeof(sc->sc_id);
   1774   1.98       rjs 
   1775   1.98       rjs 	if (sc->sc_sppp.pp_if.if_mtu > PPPOE_MAXMTU) {
   1776   1.98       rjs 		PPPOE_ADD_16(p, PPPOE_TAG_MAX_PAYLOAD);
   1777   1.98       rjs 		PPPOE_ADD_16(p, 2);
   1778   1.98       rjs 		PPPOE_ADD_16(p, (uint16_t)sc->sc_sppp.pp_if.if_mtu);
   1779   1.98       rjs 	}
   1780    1.1    martin 
   1781    1.1    martin #ifdef PPPOE_DEBUG
   1782   1.84      matt 	if (p - mtod(m0, uint8_t *) != len + PPPOE_HEADERLEN)
   1783    1.1    martin 		panic("pppoe_send_padr: garbled output len, should be %ld, is %ld",
   1784   1.84      matt 			(long)(len + PPPOE_HEADERLEN), (long)(p - mtod(m0, uint8_t *)));
   1785    1.1    martin #endif
   1786    1.1    martin 
   1787  1.142      maxv 	/* Send packet. */
   1788    1.1    martin 	return pppoe_output(sc, m0);
   1789    1.1    martin }
   1790    1.1    martin 
   1791    1.1    martin /* send a PADT packet */
   1792    1.1    martin static int
   1793   1.84      matt pppoe_send_padt(struct ifnet *outgoing_if, u_int session, const uint8_t *dest)
   1794    1.1    martin {
   1795   1.39    martin 	struct ether_header *eh;
   1796   1.39    martin 	struct sockaddr dst;
   1797    1.1    martin 	struct mbuf *m0;
   1798   1.84      matt 	uint8_t *p;
   1799    1.1    martin 
   1800    1.1    martin 	m0 = pppoe_get_mbuf(PPPOE_HEADERLEN);
   1801   1.26    itojun 	if (!m0)
   1802   1.39    martin 		return EIO;
   1803   1.84      matt 	p = mtod(m0, uint8_t *);
   1804   1.39    martin 	PPPOE_ADD_HEADER(p, PPPOE_CODE_PADT, session, 0);
   1805   1.39    martin 
   1806   1.39    martin 	memset(&dst, 0, sizeof dst);
   1807   1.39    martin 	dst.sa_family = AF_UNSPEC;
   1808   1.39    martin 	eh = (struct ether_header*)&dst.sa_data;
   1809   1.39    martin 	eh->ether_type = htons(ETHERTYPE_PPPOEDISC);
   1810   1.39    martin 	memcpy(&eh->ether_dhost, dest, ETHER_ADDR_LEN);
   1811   1.39    martin 
   1812   1.39    martin 	m0->m_flags &= ~(M_BCAST|M_MCAST);
   1813  1.109  knakahar 	return if_output_lock(outgoing_if, outgoing_if, m0, &dst, NULL);
   1814    1.1    martin }
   1815   1.43       oki 
   1816   1.43       oki #ifdef PPPOE_SERVER
   1817   1.43       oki static int
   1818   1.43       oki pppoe_send_pado(struct pppoe_softc *sc)
   1819   1.43       oki {
   1820   1.43       oki 	struct mbuf *m0;
   1821   1.84      matt 	uint8_t *p;
   1822   1.43       oki 	size_t len;
   1823   1.43       oki 
   1824   1.43       oki 	if (sc->sc_state != PPPOE_STATE_PADO_SENT)
   1825   1.43       oki 		return EIO;
   1826   1.43       oki 
   1827  1.144      maxv 	/* Include AC cookie. */
   1828  1.144      maxv 	len = sizeof(struct pppoetag) + sizeof(sc->sc_id);
   1829  1.144      maxv 	/* Include hunique. */
   1830  1.144      maxv 	len += sizeof(struct pppoetag) + sc->sc_hunique_len;
   1831  1.144      maxv 
   1832   1.43       oki 	m0 = pppoe_get_mbuf(len + PPPOE_HEADERLEN);
   1833   1.43       oki 	if (!m0)
   1834   1.43       oki 		return EIO;
   1835   1.84      matt 	p = mtod(m0, uint8_t *);
   1836  1.144      maxv 
   1837   1.43       oki 	PPPOE_ADD_HEADER(p, PPPOE_CODE_PADO, 0, len);
   1838   1.43       oki 	PPPOE_ADD_16(p, PPPOE_TAG_ACCOOKIE);
   1839  1.143      maxv 	PPPOE_ADD_16(p, sizeof(sc->sc_id));
   1840  1.143      maxv 	memcpy(p, &sc->sc_id, sizeof(sc->sc_id));
   1841  1.143      maxv 	p += sizeof(sc->sc_id);
   1842   1.43       oki 	PPPOE_ADD_16(p, PPPOE_TAG_HUNIQUE);
   1843   1.43       oki 	PPPOE_ADD_16(p, sc->sc_hunique_len);
   1844   1.43       oki 	memcpy(p, sc->sc_hunique, sc->sc_hunique_len);
   1845   1.43       oki 	return pppoe_output(sc, m0);
   1846   1.43       oki }
   1847   1.43       oki 
   1848   1.43       oki static int
   1849   1.43       oki pppoe_send_pads(struct pppoe_softc *sc)
   1850   1.43       oki {
   1851   1.69    kardel 	struct bintime bt;
   1852   1.43       oki 	struct mbuf *m0;
   1853   1.84      matt 	uint8_t *p;
   1854   1.61    martin 	size_t len, l1 = 0;	/* XXX: gcc */
   1855   1.43       oki 
   1856  1.127  knakahar 	KASSERT(PPPOE_WLOCKED(sc));
   1857  1.120  knakahar 
   1858   1.43       oki 	if (sc->sc_state != PPPOE_STATE_PADO_SENT)
   1859   1.43       oki 		return EIO;
   1860   1.43       oki 
   1861   1.69    kardel 	getbinuptime(&bt);
   1862   1.69    kardel 	sc->sc_session = bt.sec % 0xff + 1;
   1863  1.144      maxv 
   1864  1.144      maxv 	/* Include service name. */
   1865  1.144      maxv 	len = sizeof(struct pppoetag);
   1866  1.144      maxv 	if (sc->sc_service_name != NULL) {
   1867   1.43       oki 		l1 = strlen(sc->sc_service_name);
   1868   1.43       oki 		len += l1;
   1869   1.43       oki 	}
   1870  1.144      maxv 	/* Include hunique. */
   1871  1.144      maxv 	len += sizeof(struct pppoetag) + sc->sc_hunique_len;
   1872  1.144      maxv 
   1873   1.43       oki 	m0 = pppoe_get_mbuf(len + PPPOE_HEADERLEN);
   1874   1.43       oki 	if (!m0)
   1875   1.43       oki 		return ENOBUFS;
   1876   1.84      matt 	p = mtod(m0, uint8_t *);
   1877  1.144      maxv 
   1878   1.43       oki 	PPPOE_ADD_HEADER(p, PPPOE_CODE_PADS, sc->sc_session, len);
   1879   1.43       oki 	PPPOE_ADD_16(p, PPPOE_TAG_SNAME);
   1880   1.43       oki 	if (sc->sc_service_name != NULL) {
   1881   1.43       oki 		PPPOE_ADD_16(p, l1);
   1882   1.43       oki 		memcpy(p, sc->sc_service_name, l1);
   1883   1.43       oki 		p += l1;
   1884   1.43       oki 	} else {
   1885   1.43       oki 		PPPOE_ADD_16(p, 0);
   1886   1.43       oki 	}
   1887   1.43       oki 	PPPOE_ADD_16(p, PPPOE_TAG_HUNIQUE);
   1888   1.43       oki 	PPPOE_ADD_16(p, sc->sc_hunique_len);
   1889   1.43       oki 	memcpy(p, sc->sc_hunique, sc->sc_hunique_len);
   1890   1.43       oki 	return pppoe_output(sc, m0);
   1891   1.43       oki }
   1892   1.43       oki #endif
   1893    1.1    martin 
   1894    1.1    martin static void
   1895    1.1    martin pppoe_tls(struct sppp *sp)
   1896    1.1    martin {
   1897   1.26    itojun 	struct pppoe_softc *sc = (void *)sp;
   1898   1.90    martin 	int wtime;
   1899   1.90    martin 
   1900  1.127  knakahar 	PPPOE_LOCK(sc, RW_READER);
   1901  1.120  knakahar 
   1902  1.120  knakahar 	if (sc->sc_state != PPPOE_STATE_INITIAL) {
   1903  1.127  knakahar 		PPPOE_UNLOCK(sc);
   1904    1.1    martin 		return;
   1905  1.120  knakahar 	}
   1906  1.120  knakahar 
   1907   1.90    martin 	if (sc->sc_sppp.pp_phase == SPPP_PHASE_ESTABLISH &&
   1908   1.90    martin 	    sc->sc_sppp.pp_auth_failures > 0) {
   1909   1.90    martin 		/*
   1910   1.90    martin 		 * Delay trying to reconnect a bit more - the peer
   1911  1.102       snj 		 * might have failed to contact its radius server.
   1912   1.90    martin 		 */
   1913   1.92    martin 		wtime = PPPOE_RECON_FAST * sc->sc_sppp.pp_auth_failures;
   1914   1.92    martin 		if (wtime > PPPOE_SLOW_RETRY)
   1915   1.92    martin 			wtime = PPPOE_SLOW_RETRY;
   1916   1.90    martin 	} else {
   1917   1.92    martin 		wtime = PPPOE_RECON_IMMEDIATE;
   1918   1.90    martin 	}
   1919  1.150  yamaguch 	callout_schedule(&sc->sc_timeout, wtime);
   1920  1.120  knakahar 
   1921  1.127  knakahar 	PPPOE_UNLOCK(sc);
   1922    1.1    martin }
   1923    1.1    martin 
   1924    1.1    martin static void
   1925    1.1    martin pppoe_tlf(struct sppp *sp)
   1926    1.1    martin {
   1927   1.26    itojun 	struct pppoe_softc *sc = (void *)sp;
   1928  1.120  knakahar 
   1929  1.127  knakahar 	PPPOE_LOCK(sc, RW_WRITER);
   1930  1.120  knakahar 
   1931  1.120  knakahar 	if (sc->sc_state < PPPOE_STATE_SESSION) {
   1932  1.154  yamaguch 		callout_stop(&sc->sc_timeout);
   1933  1.154  yamaguch 		sc->sc_state = PPPOE_STATE_INITIAL;
   1934  1.154  yamaguch 		sc->sc_padi_retried = 0;
   1935  1.154  yamaguch 		sc->sc_padr_retried = 0;
   1936  1.154  yamaguch 		memcpy(&sc->sc_dest, etherbroadcastaddr,
   1937  1.154  yamaguch 		    sizeof(sc->sc_dest));
   1938  1.127  knakahar 		PPPOE_UNLOCK(sc);
   1939    1.1    martin 		return;
   1940  1.120  knakahar 	}
   1941  1.154  yamaguch 
   1942    1.1    martin 	/*
   1943    1.1    martin 	 * Do not call pppoe_disconnect here, the upper layer state
   1944    1.1    martin 	 * machine gets confused by this. We must return from this
   1945    1.1    martin 	 * function and defer disconnecting to the timeout handler.
   1946    1.1    martin 	 */
   1947    1.1    martin 	sc->sc_state = PPPOE_STATE_CLOSING;
   1948  1.120  knakahar 
   1949  1.150  yamaguch 	callout_schedule(&sc->sc_timeout, hz/50);
   1950  1.120  knakahar 
   1951  1.127  knakahar 	PPPOE_UNLOCK(sc);
   1952    1.1    martin }
   1953    1.1    martin 
   1954    1.1    martin static void
   1955    1.1    martin pppoe_start(struct ifnet *ifp)
   1956    1.1    martin {
   1957   1.26    itojun 	struct pppoe_softc *sc = (void *)ifp;
   1958    1.1    martin 	struct mbuf *m;
   1959   1.84      matt 	uint8_t *p;
   1960    1.1    martin 	size_t len;
   1961    1.1    martin 
   1962    1.1    martin 	if (sppp_isempty(ifp))
   1963    1.1    martin 		return;
   1964    1.1    martin 
   1965   1.48       wiz 	/* are we ready to process data yet? */
   1966  1.127  knakahar 	PPPOE_LOCK(sc, RW_READER);
   1967    1.1    martin 	if (sc->sc_state < PPPOE_STATE_SESSION) {
   1968    1.1    martin 		sppp_flush(&sc->sc_sppp.pp_if);
   1969  1.127  knakahar 		PPPOE_UNLOCK(sc);
   1970    1.1    martin 		return;
   1971    1.1    martin 	}
   1972    1.1    martin 
   1973    1.1    martin 	while ((m = sppp_dequeue(ifp)) != NULL) {
   1974    1.1    martin 		len = m->m_pkthdr.len;
   1975    1.1    martin 		M_PREPEND(m, PPPOE_HEADERLEN, M_DONTWAIT);
   1976    1.1    martin 		if (m == NULL) {
   1977  1.148   thorpej 			if_statinc(ifp, if_oerrors);
   1978   1.37    martin 			continue;
   1979    1.1    martin 		}
   1980   1.84      matt 		p = mtod(m, uint8_t *);
   1981    1.1    martin 		PPPOE_ADD_HEADER(p, 0, sc->sc_session, len);
   1982    1.1    martin 
   1983  1.141   msaitoh 		bpf_mtap(&sc->sc_sppp.pp_if, m, BPF_D_OUT);
   1984    1.1    martin 
   1985    1.1    martin 		pppoe_output(sc, m);
   1986    1.1    martin 	}
   1987  1.127  knakahar 	PPPOE_UNLOCK(sc);
   1988    1.1    martin }
   1989   1.54    martin 
   1990  1.120  knakahar #ifdef PPPOE_MPSAFE
   1991  1.120  knakahar static int
   1992  1.120  knakahar pppoe_transmit(struct ifnet *ifp, struct mbuf *m)
   1993  1.120  knakahar {
   1994  1.120  knakahar 	struct pppoe_softc *sc = (void *)ifp;
   1995  1.120  knakahar 	uint8_t *p;
   1996  1.120  knakahar 	size_t len;
   1997  1.120  knakahar 
   1998  1.120  knakahar 	if (m == NULL)
   1999  1.120  knakahar 		return EINVAL;
   2000  1.120  knakahar 
   2001  1.120  knakahar 	/* are we ready to process data yet? */
   2002  1.127  knakahar 	PPPOE_LOCK(sc, RW_READER);
   2003  1.120  knakahar 	if (sc->sc_state < PPPOE_STATE_SESSION) {
   2004  1.127  knakahar 		PPPOE_UNLOCK(sc);
   2005  1.134      maxv 		m_freem(m);
   2006  1.120  knakahar 		return ENOBUFS;
   2007  1.120  knakahar 	}
   2008  1.120  knakahar 
   2009  1.120  knakahar 	len = m->m_pkthdr.len;
   2010  1.120  knakahar 	M_PREPEND(m, PPPOE_HEADERLEN, M_DONTWAIT);
   2011  1.120  knakahar 	if (m == NULL) {
   2012  1.127  knakahar 		PPPOE_UNLOCK(sc);
   2013  1.148   thorpej 		if_statinc(ifp, if_oerrors);
   2014  1.120  knakahar 		return ENETDOWN;
   2015  1.120  knakahar 	}
   2016  1.120  knakahar 	p = mtod(m, uint8_t *);
   2017  1.120  knakahar 	PPPOE_ADD_HEADER(p, 0, sc->sc_session, len);
   2018  1.120  knakahar 
   2019  1.141   msaitoh 	bpf_mtap(&sc->sc_sppp.pp_if, m, BPF_D_OUT);
   2020  1.120  knakahar 
   2021  1.120  knakahar 	pppoe_output(sc, m);
   2022  1.127  knakahar 	PPPOE_UNLOCK(sc);
   2023  1.120  knakahar 	return 0;
   2024  1.120  knakahar }
   2025  1.120  knakahar #endif /* PPPOE_MPSAFE */
   2026   1.54    martin 
   2027  1.123  christos static void
   2028  1.123  christos pppoe_ifattach_hook(void *arg, unsigned long cmd, void *arg2)
   2029   1.54    martin {
   2030  1.123  christos 	struct ifnet *ifp = arg2;
   2031   1.54    martin 	struct pppoe_softc *sc;
   2032  1.120  knakahar 	DECLARE_SPLNET_VARIABLE;
   2033   1.54    martin 
   2034  1.123  christos 	if (cmd != PFIL_IFNET_DETACH)
   2035  1.123  christos 		return;
   2036   1.54    martin 
   2037  1.120  knakahar 	ACQUIRE_SPLNET();
   2038  1.120  knakahar 	rw_enter(&pppoe_softc_list_lock, RW_READER);
   2039   1.54    martin 	LIST_FOREACH(sc, &pppoe_softc_list, sc_list) {
   2040  1.127  knakahar 		PPPOE_LOCK(sc, RW_WRITER);
   2041  1.120  knakahar 		if (sc->sc_eth_if != ifp) {
   2042  1.127  knakahar 			PPPOE_UNLOCK(sc);
   2043   1.54    martin 			continue;
   2044  1.120  knakahar 		}
   2045   1.54    martin 		if (sc->sc_sppp.pp_if.if_flags & IFF_UP) {
   2046   1.54    martin 			sc->sc_sppp.pp_if.if_flags &= ~(IFF_UP|IFF_RUNNING);
   2047  1.157  yamaguch 			pppoe_printf(sc,
   2048  1.157  yamaguch 			    "ethernet interface detached, going down\n");
   2049   1.54    martin 		}
   2050   1.54    martin 		sc->sc_eth_if = NULL;
   2051   1.57    martin 		pppoe_clear_softc(sc, "ethernet interface detached");
   2052  1.127  knakahar 		PPPOE_UNLOCK(sc);
   2053   1.54    martin 	}
   2054  1.120  knakahar 	rw_exit(&pppoe_softc_list_lock);
   2055  1.120  knakahar 	RELEASE_SPLNET();
   2056   1.54    martin }
   2057   1.57    martin 
   2058   1.57    martin static void
   2059   1.57    martin pppoe_clear_softc(struct pppoe_softc *sc, const char *message)
   2060   1.57    martin {
   2061  1.127  knakahar 	KASSERT(PPPOE_WLOCKED(sc));
   2062  1.120  knakahar 
   2063   1.58    martin 	/* stop timer */
   2064   1.57    martin 	callout_stop(&sc->sc_timeout);
   2065  1.157  yamaguch 	pppoe_printf(sc, "session 0x%x terminated, %s\n",
   2066  1.157  yamaguch 	    sc->sc_session, message);
   2067   1.57    martin 
   2068   1.57    martin 	/* fix our state */
   2069   1.57    martin 	sc->sc_state = PPPOE_STATE_INITIAL;
   2070  1.120  knakahar 
   2071  1.127  knakahar 	PPPOE_UNLOCK(sc);
   2072   1.57    martin 
   2073   1.57    martin 	/* signal upper layer */
   2074   1.57    martin 	sc->sc_sppp.pp_down(&sc->sc_sppp);
   2075  1.120  knakahar 
   2076  1.127  knakahar 	PPPOE_LOCK(sc, RW_WRITER);
   2077   1.57    martin 
   2078   1.57    martin 	/* clean up softc */
   2079   1.57    martin 	memcpy(&sc->sc_dest, etherbroadcastaddr, sizeof(sc->sc_dest));
   2080   1.57    martin 	if (sc->sc_ac_cookie) {
   2081   1.57    martin 		free(sc->sc_ac_cookie, M_DEVBUF);
   2082   1.57    martin 		sc->sc_ac_cookie = NULL;
   2083   1.57    martin 	}
   2084   1.94  christos 	if (sc->sc_relay_sid) {
   2085   1.94  christos 		free(sc->sc_relay_sid, M_DEVBUF);
   2086   1.94  christos 		sc->sc_relay_sid = NULL;
   2087   1.94  christos 	}
   2088   1.57    martin 	sc->sc_ac_cookie_len = 0;
   2089   1.57    martin 	sc->sc_session = 0;
   2090   1.57    martin }
   2091  1.105     ozaki 
   2092  1.105     ozaki static void
   2093  1.105     ozaki pppoe_enqueue(struct ifqueue *inq, struct mbuf *m)
   2094  1.105     ozaki {
   2095  1.105     ozaki 	if (m->m_flags & M_PROMISC) {
   2096  1.134      maxv 		m_freem(m);
   2097  1.105     ozaki 		return;
   2098  1.105     ozaki 	}
   2099  1.105     ozaki 
   2100  1.105     ozaki #ifndef PPPOE_SERVER
   2101  1.105     ozaki 	if (m->m_flags & (M_MCAST | M_BCAST)) {
   2102  1.134      maxv 		m_freem(m);
   2103  1.105     ozaki 		return;
   2104  1.105     ozaki 	}
   2105  1.105     ozaki #endif
   2106  1.105     ozaki 
   2107  1.118     ozaki 	IFQ_LOCK(inq);
   2108  1.105     ozaki 	if (IF_QFULL(inq)) {
   2109  1.105     ozaki 		IF_DROP(inq);
   2110  1.118     ozaki 		IFQ_UNLOCK(inq);
   2111  1.105     ozaki 		m_freem(m);
   2112  1.105     ozaki 	} else {
   2113  1.105     ozaki 		IF_ENQUEUE(inq, m);
   2114  1.118     ozaki 		IFQ_UNLOCK(inq);
   2115  1.105     ozaki 		softint_schedule(pppoe_softintr);
   2116  1.105     ozaki 	}
   2117  1.105     ozaki 	return;
   2118  1.105     ozaki }
   2119  1.105     ozaki 
   2120  1.105     ozaki void
   2121  1.105     ozaki pppoe_input(struct ifnet *ifp, struct mbuf *m)
   2122  1.105     ozaki {
   2123  1.105     ozaki 	pppoe_enqueue(&ppoeinq, m);
   2124  1.105     ozaki 	return;
   2125  1.105     ozaki }
   2126  1.105     ozaki 
   2127  1.105     ozaki void
   2128  1.105     ozaki pppoedisc_input(struct ifnet *ifp, struct mbuf *m)
   2129  1.105     ozaki {
   2130  1.105     ozaki 	pppoe_enqueue(&ppoediscinq, m);
   2131  1.105     ozaki 	return;
   2132  1.105     ozaki }
   2133  1.112  pgoyette 
   2134  1.117  christos static void
   2135  1.117  christos sysctl_net_pppoe_setup(struct sysctllog **clog)
   2136  1.113  pgoyette {
   2137  1.113  pgoyette 	const struct sysctlnode *node = NULL;
   2138  1.113  pgoyette 
   2139  1.113  pgoyette 	sysctl_createv(clog, 0, NULL, &node,
   2140  1.113  pgoyette 	    CTLFLAG_PERMANENT,
   2141  1.113  pgoyette 	    CTLTYPE_NODE, "pppoe",
   2142  1.113  pgoyette 	    SYSCTL_DESCR("PPPOE protocol"),
   2143  1.113  pgoyette 	    NULL, 0, NULL, 0,
   2144  1.113  pgoyette 	    CTL_NET, CTL_CREATE, CTL_EOL);
   2145  1.113  pgoyette 
   2146  1.113  pgoyette 	if (node == NULL)
   2147  1.113  pgoyette 		return;
   2148  1.113  pgoyette 
   2149  1.113  pgoyette 	sysctl_createv(clog, 0, &node, NULL,
   2150  1.135  knakahar 	    CTLFLAG_PERMANENT | CTLFLAG_READWRITE,
   2151  1.113  pgoyette 	    CTLTYPE_BOOL, "term_unknown",
   2152  1.113  pgoyette 	    SYSCTL_DESCR("Terminate unknown sessions"),
   2153  1.113  pgoyette 	    NULL, 0, &pppoe_term_unknown, sizeof(pppoe_term_unknown),
   2154  1.113  pgoyette 	    CTL_CREATE, CTL_EOL);
   2155  1.113  pgoyette }
   2156  1.114  christos 
   2157  1.114  christos /*
   2158  1.114  christos  * Module infrastructure
   2159  1.114  christos  */
   2160  1.114  christos #include "if_module.h"
   2161  1.114  christos 
   2162  1.114  christos IF_MODULE(MODULE_CLASS_DRIVER, pppoe, "sppp_subr")
   2163