if_pppoe.c revision 1.167 1 1.167 yamaguch /* $NetBSD: if_pppoe.c,v 1.167 2021/04/16 01:59:50 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.167 yamaguch __KERNEL_RCSID(0, "$NetBSD: if_pppoe.c,v 1.167 2021/04/16 01:59:50 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.167 yamaguch PPPOE_LOCK(sc, RW_WRITER);
440 1.167 yamaguch callout_setfunc(&sc->sc_timeout, pppoe_timeout_co_halt, sc);
441 1.167 yamaguch workqueue_wait(sc->sc_timeout_wq, &sc->sc_timeout_wk);
442 1.167 yamaguch callout_halt(&sc->sc_timeout, NULL);
443 1.167 yamaguch
444 1.96 joerg bpf_detach(ifp);
445 1.6 martin sppp_detach(&sc->sc_sppp.pp_if);
446 1.5 martin if_detach(ifp);
447 1.32 yamt if (sc->sc_concentrator_name)
448 1.32 yamt free(sc->sc_concentrator_name, M_DEVBUF);
449 1.32 yamt if (sc->sc_service_name)
450 1.32 yamt free(sc->sc_service_name, M_DEVBUF);
451 1.32 yamt if (sc->sc_ac_cookie)
452 1.32 yamt free(sc->sc_ac_cookie, M_DEVBUF);
453 1.94 christos if (sc->sc_relay_sid)
454 1.94 christos free(sc->sc_relay_sid, M_DEVBUF);
455 1.79 ad callout_destroy(&sc->sc_timeout);
456 1.151 yamaguch workqueue_destroy(sc->sc_timeout_wq);
457 1.120 knakahar
458 1.127 knakahar PPPOE_UNLOCK(sc);
459 1.127 knakahar rw_destroy(&sc->sc_lock);
460 1.120 knakahar
461 1.165 yamaguch kmem_free(sc, sizeof(*sc));
462 1.56 peter
463 1.129 msaitoh return 0;
464 1.1 martin }
465 1.1 martin
466 1.157 yamaguch static void
467 1.157 yamaguch pppoe_printf(struct pppoe_softc *sc, const char *fmt, ...)
468 1.157 yamaguch {
469 1.157 yamaguch va_list ap;
470 1.157 yamaguch bool pppoe_debug;
471 1.157 yamaguch
472 1.157 yamaguch #ifdef PPPOE_DEBUG
473 1.157 yamaguch pppoe_debug = true;
474 1.157 yamaguch #else
475 1.157 yamaguch pppoe_debug = false;
476 1.157 yamaguch #endif
477 1.157 yamaguch
478 1.157 yamaguch if (sc == NULL) {
479 1.157 yamaguch if (!pppoe_debug)
480 1.157 yamaguch return;
481 1.157 yamaguch
482 1.157 yamaguch printf("pppoe: ");
483 1.157 yamaguch } else {
484 1.157 yamaguch if (!ISSET(sc->sc_sppp.pp_if.if_flags, IFF_DEBUG))
485 1.157 yamaguch return;
486 1.157 yamaguch
487 1.157 yamaguch printf("%s: ", sc->sc_sppp.pp_if.if_xname);
488 1.157 yamaguch }
489 1.157 yamaguch
490 1.157 yamaguch va_start(ap, fmt);
491 1.157 yamaguch vprintf(fmt, ap);
492 1.157 yamaguch va_end(ap);
493 1.157 yamaguch }
494 1.157 yamaguch
495 1.1 martin /*
496 1.1 martin * Find the interface handling the specified session.
497 1.1 martin * Note: O(number of sessions open), this is a client-side only, mean
498 1.1 martin * and lean implementation, so number of open sessions typically should
499 1.1 martin * be 1.
500 1.1 martin */
501 1.1 martin static struct pppoe_softc *
502 1.120 knakahar pppoe_find_softc_by_session(u_int session, struct ifnet *rcvif, krw_t lock)
503 1.1 martin {
504 1.120 knakahar struct pppoe_softc *sc = NULL;
505 1.1 martin
506 1.26 itojun if (session == 0)
507 1.26 itojun return NULL;
508 1.120 knakahar rw_enter(&pppoe_softc_list_lock, RW_READER);
509 1.5 martin LIST_FOREACH(sc, &pppoe_softc_list, sc_list) {
510 1.127 knakahar PPPOE_LOCK(sc, lock);
511 1.127 knakahar if ( sc->sc_state == PPPOE_STATE_SESSION
512 1.93 scw && sc->sc_session == session
513 1.93 scw && sc->sc_eth_if == rcvif)
514 1.120 knakahar break;
515 1.120 knakahar
516 1.127 knakahar PPPOE_UNLOCK(sc);
517 1.1 martin }
518 1.120 knakahar rw_exit(&pppoe_softc_list_lock);
519 1.120 knakahar return sc;
520 1.1 martin }
521 1.1 martin
522 1.1 martin /* Check host unique token passed and return appropriate softc pointer,
523 1.1 martin * or NULL if token is bogus. */
524 1.1 martin static struct pppoe_softc *
525 1.120 knakahar pppoe_find_softc_by_hunique(uint8_t *token, size_t len,
526 1.120 knakahar struct ifnet *rcvif, krw_t lock)
527 1.1 martin {
528 1.143 maxv struct pppoe_softc *sc;
529 1.143 maxv uint64_t t;
530 1.143 maxv
531 1.143 maxv CTASSERT(sizeof(t) == sizeof(sc->sc_id));
532 1.9 martin
533 1.140 yamaguch rw_enter(&pppoe_softc_list_lock, RW_READER);
534 1.140 yamaguch if (LIST_EMPTY(&pppoe_softc_list)) {
535 1.140 yamaguch rw_exit(&pppoe_softc_list_lock);
536 1.26 itojun return NULL;
537 1.140 yamaguch }
538 1.9 martin
539 1.143 maxv if (len != sizeof(sc->sc_id)) {
540 1.140 yamaguch rw_exit(&pppoe_softc_list_lock);
541 1.26 itojun return NULL;
542 1.140 yamaguch }
543 1.5 martin memcpy(&t, token, len);
544 1.5 martin
545 1.120 knakahar LIST_FOREACH(sc, &pppoe_softc_list, sc_list) {
546 1.159 yamaguch PPPOE_LOCK(sc, lock);
547 1.160 yamaguch if (sc->sc_id == t && sc->sc_eth_if != NULL) {
548 1.120 knakahar break;
549 1.120 knakahar }
550 1.159 yamaguch PPPOE_UNLOCK(sc);
551 1.120 knakahar }
552 1.120 knakahar rw_exit(&pppoe_softc_list_lock);
553 1.5 martin
554 1.40 aymeric if (sc == NULL) {
555 1.157 yamaguch pppoe_printf(NULL, "alien host unique tag"
556 1.157 yamaguch ", no session found\n");
557 1.1 martin return NULL;
558 1.1 martin }
559 1.5 martin
560 1.1 martin /* should be safe to access *sc now */
561 1.1 martin if (sc->sc_state < PPPOE_STATE_PADI_SENT || sc->sc_state >= PPPOE_STATE_SESSION) {
562 1.157 yamaguch pppoe_printf(sc, "host unique tag found"
563 1.157 yamaguch ", but it belongs to a connection in state %d\n",
564 1.157 yamaguch sc->sc_state);
565 1.127 knakahar PPPOE_UNLOCK(sc);
566 1.1 martin return NULL;
567 1.1 martin }
568 1.1 martin if (sc->sc_eth_if != rcvif) {
569 1.157 yamaguch pppoe_printf(sc, "wrong interface, not accepting host unique\n");
570 1.127 knakahar PPPOE_UNLOCK(sc);
571 1.1 martin return NULL;
572 1.1 martin }
573 1.1 martin return sc;
574 1.1 martin }
575 1.1 martin
576 1.63 thorpej static void
577 1.76 christos pppoe_softintr_handler(void *dummy)
578 1.1 martin {
579 1.1 martin /* called at splsoftnet() */
580 1.105 ozaki pppoeintr();
581 1.1 martin }
582 1.1 martin
583 1.1 martin /* called at appropriate protection level */
584 1.1 martin static void
585 1.105 ozaki pppoeintr(void)
586 1.1 martin {
587 1.1 martin struct mbuf *m;
588 1.118 ozaki int disc_done, data_done;
589 1.1 martin
590 1.132 ozaki SOFTNET_LOCK_UNLESS_NET_MPSAFE();
591 1.120 knakahar
592 1.3 martin do {
593 1.3 martin disc_done = 0;
594 1.3 martin data_done = 0;
595 1.3 martin for (;;) {
596 1.118 ozaki IFQ_LOCK(&ppoediscinq);
597 1.1 martin IF_DEQUEUE(&ppoediscinq, m);
598 1.118 ozaki IFQ_UNLOCK(&ppoediscinq);
599 1.145 maxv if (m == NULL)
600 1.145 maxv break;
601 1.3 martin disc_done = 1;
602 1.1 martin pppoe_disc_input(m);
603 1.1 martin }
604 1.3 martin
605 1.3 martin for (;;) {
606 1.118 ozaki IFQ_LOCK(&ppoeinq);
607 1.1 martin IF_DEQUEUE(&ppoeinq, m);
608 1.118 ozaki IFQ_UNLOCK(&ppoeinq);
609 1.145 maxv if (m == NULL)
610 1.145 maxv break;
611 1.3 martin data_done = 1;
612 1.1 martin pppoe_data_input(m);
613 1.1 martin }
614 1.3 martin } while (disc_done || data_done);
615 1.132 ozaki
616 1.162 yamaguch if (!IF_IS_EMPTY(&ppoediscinq) || !IF_IS_EMPTY(&ppoeinq))
617 1.162 yamaguch softint_schedule(pppoe_softintr);
618 1.162 yamaguch
619 1.132 ozaki SOFTNET_UNLOCK_UNLESS_NET_MPSAFE();
620 1.1 martin }
621 1.1 martin
622 1.1 martin /* analyze and handle a single received packet while not in session state */
623 1.63 thorpej static void
624 1.63 thorpej pppoe_dispatch_disc_pkt(struct mbuf *m, int off)
625 1.1 martin {
626 1.84 matt uint16_t tag, len;
627 1.84 matt uint16_t session, plen;
628 1.1 martin struct pppoe_softc *sc;
629 1.120 knakahar const char *err_msg;
630 1.64 martin char *error;
631 1.149 mlelstv size_t dlen;
632 1.84 matt uint8_t *ac_cookie;
633 1.1 martin size_t ac_cookie_len;
634 1.94 christos uint8_t *relay_sid;
635 1.94 christos size_t relay_sid_len;
636 1.84 matt uint8_t *hunique;
637 1.43 oki size_t hunique_len;
638 1.29 itojun struct pppoehdr *ph;
639 1.29 itojun struct pppoetag *pt;
640 1.29 itojun struct mbuf *n;
641 1.46 martin int noff, err, errortag;
642 1.29 itojun struct ether_header *eh;
643 1.139 yamaguch struct ifnet *rcvif;
644 1.139 yamaguch struct psref psref;
645 1.29 itojun
646 1.29 itojun if (m->m_len < sizeof(*eh)) {
647 1.29 itojun m = m_pullup(m, sizeof(*eh));
648 1.145 maxv if (m == NULL)
649 1.29 itojun goto done;
650 1.29 itojun }
651 1.29 itojun eh = mtod(m, struct ether_header *);
652 1.29 itojun off += sizeof(*eh);
653 1.1 martin
654 1.29 itojun if (m->m_pkthdr.len - off <= PPPOE_HEADERLEN) {
655 1.29 itojun goto done;
656 1.29 itojun }
657 1.29 itojun
658 1.146 maxv M_REGION_GET(ph, struct pppoehdr *, m, off, sizeof(*ph));
659 1.146 maxv if (ph == NULL) {
660 1.29 itojun goto done;
661 1.29 itojun }
662 1.29 itojun if (ph->vertype != PPPOE_VERTYPE) {
663 1.29 itojun goto done;
664 1.29 itojun }
665 1.146 maxv
666 1.146 maxv ac_cookie = NULL;
667 1.146 maxv ac_cookie_len = 0;
668 1.146 maxv relay_sid = NULL;
669 1.146 maxv relay_sid_len = 0;
670 1.146 maxv hunique = NULL;
671 1.146 maxv hunique_len = 0;
672 1.146 maxv
673 1.29 itojun session = ntohs(ph->session);
674 1.29 itojun plen = ntohs(ph->plen);
675 1.29 itojun off += sizeof(*ph);
676 1.29 itojun
677 1.29 itojun if (plen + off > m->m_pkthdr.len) {
678 1.29 itojun goto done;
679 1.1 martin }
680 1.29 itojun m_adj(m, off + plen - m->m_pkthdr.len); /* ignore trailing garbage */
681 1.145 maxv
682 1.1 martin tag = 0;
683 1.1 martin len = 0;
684 1.1 martin sc = NULL;
685 1.146 maxv err_msg = NULL;
686 1.146 maxv errortag = 0;
687 1.31 yamt while (off + sizeof(*pt) <= m->m_pkthdr.len) {
688 1.146 maxv M_REGION_GET(pt, struct pppoetag *, m, off, sizeof(*pt));
689 1.146 maxv if (pt == NULL) {
690 1.29 itojun goto done;
691 1.29 itojun }
692 1.146 maxv
693 1.29 itojun tag = ntohs(pt->tag);
694 1.29 itojun len = ntohs(pt->len);
695 1.88 martin if (off + len + sizeof(*pt) > m->m_pkthdr.len) {
696 1.29 itojun goto done;
697 1.1 martin }
698 1.1 martin switch (tag) {
699 1.1 martin case PPPOE_TAG_EOL:
700 1.29 itojun goto breakbreak;
701 1.1 martin case PPPOE_TAG_SNAME:
702 1.1 martin break; /* ignored */
703 1.1 martin case PPPOE_TAG_ACNAME:
704 1.139 yamaguch if (len > 0) {
705 1.149 mlelstv dlen = 4 * len + 1;
706 1.149 mlelstv error = malloc(dlen, M_TEMP, M_NOWAIT);
707 1.124 maxv if (error == NULL)
708 1.124 maxv break;
709 1.124 maxv
710 1.124 maxv n = m_pulldown(m, off + sizeof(*pt), len,
711 1.124 maxv &noff);
712 1.124 maxv if (!n) {
713 1.124 maxv m = NULL;
714 1.80 martin free(error, M_TEMP);
715 1.124 maxv goto done;
716 1.80 martin }
717 1.124 maxv
718 1.149 mlelstv strnvisx(error, dlen,
719 1.149 mlelstv mtod(n, char*) + noff, len,
720 1.149 mlelstv VIS_SAFE | VIS_OCTAL);
721 1.157 yamaguch pppoe_printf(NULL, "connected to %s\n", error);
722 1.124 maxv free(error, M_TEMP);
723 1.80 martin }
724 1.1 martin break; /* ignored */
725 1.139 yamaguch case PPPOE_TAG_HUNIQUE:
726 1.139 yamaguch if (hunique == NULL) {
727 1.139 yamaguch n = m_pulldown(m, off + sizeof(*pt), len,
728 1.139 yamaguch &noff);
729 1.139 yamaguch if (!n) {
730 1.139 yamaguch m = NULL;
731 1.139 yamaguch err_msg = "TAG HUNIQUE ERROR";
732 1.139 yamaguch break;
733 1.139 yamaguch }
734 1.125 ozaki
735 1.139 yamaguch hunique = mtod(n, uint8_t *) + noff;
736 1.139 yamaguch hunique_len = len;
737 1.120 knakahar }
738 1.1 martin break;
739 1.1 martin case PPPOE_TAG_ACCOOKIE:
740 1.1 martin if (ac_cookie == NULL) {
741 1.29 itojun n = m_pulldown(m, off + sizeof(*pt), len,
742 1.29 itojun &noff);
743 1.29 itojun if (!n) {
744 1.29 itojun err_msg = "TAG ACCOOKIE ERROR";
745 1.29 itojun m = NULL;
746 1.29 itojun break;
747 1.29 itojun }
748 1.77 christos ac_cookie = mtod(n, char *) + noff;
749 1.1 martin ac_cookie_len = len;
750 1.1 martin }
751 1.1 martin break;
752 1.94 christos case PPPOE_TAG_RELAYSID:
753 1.94 christos if (relay_sid == NULL) {
754 1.94 christos n = m_pulldown(m, off + sizeof(*pt), len,
755 1.94 christos &noff);
756 1.94 christos if (!n) {
757 1.94 christos err_msg = "TAG RELAYSID ERROR";
758 1.94 christos m = NULL;
759 1.94 christos break;
760 1.94 christos }
761 1.94 christos relay_sid = mtod(n, char *) + noff;
762 1.94 christos relay_sid_len = len;
763 1.94 christos }
764 1.94 christos break;
765 1.1 martin case PPPOE_TAG_SNAME_ERR:
766 1.1 martin err_msg = "SERVICE NAME ERROR";
767 1.46 martin errortag = 1;
768 1.1 martin break;
769 1.1 martin case PPPOE_TAG_ACSYS_ERR:
770 1.1 martin err_msg = "AC SYSTEM ERROR";
771 1.46 martin errortag = 1;
772 1.1 martin break;
773 1.1 martin case PPPOE_TAG_GENERIC_ERR:
774 1.1 martin err_msg = "GENERIC ERROR";
775 1.46 martin errortag = 1;
776 1.1 martin break;
777 1.1 martin }
778 1.1 martin if (err_msg) {
779 1.64 martin error = NULL;
780 1.46 martin if (errortag && len) {
781 1.149 mlelstv dlen = 4 * len + 1;
782 1.149 mlelstv error = malloc(dlen, M_TEMP,
783 1.124 maxv M_NOWAIT|M_ZERO);
784 1.46 martin n = m_pulldown(m, off + sizeof(*pt), len,
785 1.46 martin &noff);
786 1.124 maxv if (!n) {
787 1.124 maxv m = NULL;
788 1.124 maxv } else if (error) {
789 1.149 mlelstv strnvisx(error, dlen,
790 1.149 mlelstv mtod(n, char*) + noff, len,
791 1.149 mlelstv VIS_SAFE | VIS_OCTAL);
792 1.64 martin }
793 1.46 martin }
794 1.64 martin if (error) {
795 1.157 yamaguch pppoe_printf(NULL, "%s: %s\n", err_msg, error);
796 1.64 martin free(error, M_TEMP);
797 1.64 martin } else
798 1.157 yamaguch pppoe_printf(NULL, "%s\n", err_msg);
799 1.88 martin if (errortag || m == NULL)
800 1.46 martin goto done;
801 1.1 martin }
802 1.29 itojun off += sizeof(*pt) + len;
803 1.1 martin }
804 1.29 itojun breakbreak:;
805 1.145 maxv
806 1.29 itojun switch (ph->code) {
807 1.1 martin case PPPOE_CODE_PADI:
808 1.43 oki #ifdef PPPOE_SERVER
809 1.43 oki /*
810 1.43 oki * got service name, concentrator name, and/or host unique.
811 1.43 oki * ignore if we have no interfaces with IFF_PASSIVE|IFF_UP.
812 1.43 oki */
813 1.140 yamaguch rw_enter(&pppoe_softc_list_lock, RW_READER);
814 1.140 yamaguch if (LIST_EMPTY(&pppoe_softc_list)) {
815 1.140 yamaguch rw_exit(&pppoe_softc_list_lock);
816 1.43 oki goto done;
817 1.140 yamaguch }
818 1.140 yamaguch
819 1.43 oki LIST_FOREACH(sc, &pppoe_softc_list, sc_list) {
820 1.127 knakahar PPPOE_LOCK(sc, RW_WRITER);
821 1.120 knakahar if (!(sc->sc_sppp.pp_if.if_flags & IFF_UP)) {
822 1.127 knakahar PPPOE_UNLOCK(sc);
823 1.43 oki continue;
824 1.120 knakahar }
825 1.120 knakahar if (!(sc->sc_sppp.pp_if.if_flags & IFF_PASSIVE)) {
826 1.127 knakahar PPPOE_UNLOCK(sc);
827 1.43 oki continue;
828 1.120 knakahar }
829 1.120 knakahar
830 1.127 knakahar if (sc->sc_state == PPPOE_STATE_INITIAL)
831 1.43 oki break;
832 1.120 knakahar
833 1.127 knakahar PPPOE_UNLOCK(sc);
834 1.43 oki }
835 1.120 knakahar rw_exit(&pppoe_softc_list_lock);
836 1.120 knakahar
837 1.43 oki if (sc == NULL) {
838 1.43 oki goto done;
839 1.43 oki }
840 1.120 knakahar
841 1.43 oki if (hunique) {
842 1.43 oki if (sc->sc_hunique)
843 1.43 oki free(sc->sc_hunique, M_DEVBUF);
844 1.43 oki sc->sc_hunique = malloc(hunique_len, M_DEVBUF,
845 1.43 oki M_DONTWAIT);
846 1.120 knakahar if (sc->sc_hunique == NULL) {
847 1.127 knakahar PPPOE_UNLOCK(sc);
848 1.43 oki goto done;
849 1.120 knakahar }
850 1.43 oki sc->sc_hunique_len = hunique_len;
851 1.43 oki memcpy(sc->sc_hunique, hunique, hunique_len);
852 1.43 oki }
853 1.44 oki memcpy(&sc->sc_dest, eh->ether_shost, sizeof sc->sc_dest);
854 1.43 oki sc->sc_state = PPPOE_STATE_PADO_SENT;
855 1.43 oki pppoe_send_pado(sc);
856 1.127 knakahar PPPOE_UNLOCK(sc);
857 1.43 oki break;
858 1.43 oki #endif /* PPPOE_SERVER */
859 1.145 maxv
860 1.1 martin case PPPOE_CODE_PADR:
861 1.43 oki #ifdef PPPOE_SERVER
862 1.43 oki /*
863 1.43 oki * get sc from ac_cookie if IFF_PASSIVE
864 1.43 oki */
865 1.43 oki if (ac_cookie == NULL) {
866 1.43 oki goto done;
867 1.43 oki }
868 1.125 ozaki
869 1.125 ozaki rcvif = m_get_rcvif_psref(m, &psref);
870 1.125 ozaki if (__predict_true(rcvif != NULL)) {
871 1.125 ozaki sc = pppoe_find_softc_by_hunique(ac_cookie,
872 1.145 maxv ac_cookie_len, rcvif, RW_WRITER);
873 1.125 ozaki }
874 1.125 ozaki m_put_rcvif_psref(rcvif, &psref);
875 1.43 oki if (sc == NULL) {
876 1.43 oki /* be quiet if there is not a single pppoe instance */
877 1.140 yamaguch rw_enter(&pppoe_softc_list_lock, RW_READER);
878 1.140 yamaguch if (!LIST_EMPTY(&pppoe_softc_list)) {
879 1.157 yamaguch pppoe_printf(NULL, "received PADR"
880 1.140 yamaguch " but could not find request for it\n");
881 1.140 yamaguch }
882 1.140 yamaguch rw_exit(&pppoe_softc_list_lock);
883 1.43 oki goto done;
884 1.43 oki }
885 1.120 knakahar
886 1.127 knakahar if (sc->sc_state != PPPOE_STATE_PADO_SENT) {
887 1.157 yamaguch pppoe_printf(sc, "received unexpected PADR\n");
888 1.127 knakahar PPPOE_UNLOCK(sc);
889 1.43 oki goto done;
890 1.43 oki }
891 1.127 knakahar
892 1.43 oki if (hunique) {
893 1.43 oki if (sc->sc_hunique)
894 1.43 oki free(sc->sc_hunique, M_DEVBUF);
895 1.43 oki sc->sc_hunique = malloc(hunique_len, M_DEVBUF,
896 1.43 oki M_DONTWAIT);
897 1.120 knakahar if (sc->sc_hunique == NULL) {
898 1.127 knakahar PPPOE_UNLOCK(sc);
899 1.43 oki goto done;
900 1.120 knakahar }
901 1.43 oki sc->sc_hunique_len = hunique_len;
902 1.43 oki memcpy(sc->sc_hunique, hunique, hunique_len);
903 1.43 oki }
904 1.43 oki pppoe_send_pads(sc);
905 1.43 oki sc->sc_state = PPPOE_STATE_SESSION;
906 1.127 knakahar PPPOE_UNLOCK(sc);
907 1.120 knakahar
908 1.43 oki sc->sc_sppp.pp_up(&sc->sc_sppp);
909 1.43 oki break;
910 1.43 oki #else
911 1.1 martin /* ignore, we are no access concentrator */
912 1.29 itojun goto done;
913 1.43 oki #endif /* PPPOE_SERVER */
914 1.145 maxv
915 1.1 martin case PPPOE_CODE_PADO:
916 1.139 yamaguch rcvif = m_get_rcvif_psref(m, &psref);
917 1.139 yamaguch if (__predict_false(rcvif == NULL))
918 1.139 yamaguch goto done;
919 1.139 yamaguch
920 1.139 yamaguch if (hunique != NULL) {
921 1.139 yamaguch sc = pppoe_find_softc_by_hunique(hunique,
922 1.145 maxv hunique_len, rcvif, RW_WRITER);
923 1.139 yamaguch }
924 1.139 yamaguch
925 1.139 yamaguch m_put_rcvif_psref(rcvif, &psref);
926 1.139 yamaguch
927 1.1 martin if (sc == NULL) {
928 1.33 tron /* be quiet if there is not a single pppoe instance */
929 1.140 yamaguch rw_enter(&pppoe_softc_list_lock, RW_READER);
930 1.140 yamaguch if (!LIST_EMPTY(&pppoe_softc_list)) {
931 1.157 yamaguch pppoe_printf(NULL, "received PADO"
932 1.140 yamaguch " but could not find request for it\n");
933 1.140 yamaguch }
934 1.140 yamaguch rw_exit(&pppoe_softc_list_lock);
935 1.29 itojun goto done;
936 1.1 martin }
937 1.120 knakahar
938 1.127 knakahar if (sc->sc_state != PPPOE_STATE_PADI_SENT) {
939 1.157 yamaguch pppoe_printf(sc, "received unexpected PADO\n");
940 1.127 knakahar PPPOE_UNLOCK(sc);
941 1.29 itojun goto done;
942 1.1 martin }
943 1.120 knakahar
944 1.1 martin if (ac_cookie) {
945 1.32 yamt if (sc->sc_ac_cookie)
946 1.32 yamt free(sc->sc_ac_cookie, M_DEVBUF);
947 1.29 itojun sc->sc_ac_cookie = malloc(ac_cookie_len, M_DEVBUF,
948 1.29 itojun M_DONTWAIT);
949 1.89 martin if (sc->sc_ac_cookie == NULL) {
950 1.157 yamaguch pppoe_printf(sc, "FATAL: could not allocate memory "
951 1.157 yamaguch "for AC cookie\n");
952 1.127 knakahar PPPOE_UNLOCK(sc);
953 1.29 itojun goto done;
954 1.89 martin }
955 1.1 martin sc->sc_ac_cookie_len = ac_cookie_len;
956 1.1 martin memcpy(sc->sc_ac_cookie, ac_cookie, ac_cookie_len);
957 1.1 martin }
958 1.94 christos if (relay_sid) {
959 1.94 christos if (sc->sc_relay_sid)
960 1.94 christos free(sc->sc_relay_sid, M_DEVBUF);
961 1.94 christos sc->sc_relay_sid = malloc(relay_sid_len, M_DEVBUF,
962 1.94 christos M_DONTWAIT);
963 1.94 christos if (sc->sc_relay_sid == NULL) {
964 1.157 yamaguch pppoe_printf(sc, "FATAL: could not allocate memory "
965 1.157 yamaguch "for relay SID\n");
966 1.127 knakahar PPPOE_UNLOCK(sc);
967 1.94 christos goto done;
968 1.94 christos }
969 1.94 christos sc->sc_relay_sid_len = relay_sid_len;
970 1.94 christos memcpy(sc->sc_relay_sid, relay_sid, relay_sid_len);
971 1.94 christos }
972 1.1 martin memcpy(&sc->sc_dest, eh->ether_shost, sizeof sc->sc_dest);
973 1.1 martin callout_stop(&sc->sc_timeout);
974 1.1 martin sc->sc_padr_retried = 0;
975 1.1 martin sc->sc_state = PPPOE_STATE_PADR_SENT;
976 1.45 martin if ((err = pppoe_send_padr(sc)) != 0) {
977 1.157 yamaguch pppoe_printf(sc,
978 1.157 yamaguch "failed to send PADR, error=%d\n", err);
979 1.45 martin }
980 1.150 yamaguch callout_schedule(&sc->sc_timeout,
981 1.150 yamaguch PPPOE_DISC_TIMEOUT * (1 + sc->sc_padr_retried));
982 1.120 knakahar
983 1.127 knakahar PPPOE_UNLOCK(sc);
984 1.1 martin break;
985 1.145 maxv
986 1.1 martin case PPPOE_CODE_PADS:
987 1.139 yamaguch rcvif = m_get_rcvif_psref(m, &psref);
988 1.139 yamaguch if (__predict_false(rcvif == NULL))
989 1.139 yamaguch goto done;
990 1.139 yamaguch
991 1.139 yamaguch if (hunique != NULL) {
992 1.139 yamaguch sc = pppoe_find_softc_by_hunique(hunique,
993 1.145 maxv hunique_len, rcvif, RW_WRITER);
994 1.139 yamaguch }
995 1.139 yamaguch
996 1.139 yamaguch m_put_rcvif_psref(rcvif, &psref);
997 1.139 yamaguch
998 1.1 martin if (sc == NULL)
999 1.29 itojun goto done;
1000 1.120 knakahar
1001 1.1 martin sc->sc_session = session;
1002 1.1 martin callout_stop(&sc->sc_timeout);
1003 1.157 yamaguch pppoe_printf(sc, "session 0x%x connected\n", session);
1004 1.1 martin sc->sc_state = PPPOE_STATE_SESSION;
1005 1.127 knakahar PPPOE_UNLOCK(sc);
1006 1.120 knakahar
1007 1.1 martin sc->sc_sppp.pp_up(&sc->sc_sppp); /* notify upper layers */
1008 1.1 martin break;
1009 1.145 maxv
1010 1.139 yamaguch case PPPOE_CODE_PADT:
1011 1.139 yamaguch rcvif = m_get_rcvif_psref(m, &psref);
1012 1.139 yamaguch if (__predict_false(rcvif == NULL))
1013 1.139 yamaguch goto done;
1014 1.139 yamaguch
1015 1.139 yamaguch sc = pppoe_find_softc_by_session(session, rcvif,
1016 1.139 yamaguch RW_WRITER);
1017 1.108 ozaki
1018 1.125 ozaki m_put_rcvif_psref(rcvif, &psref);
1019 1.139 yamaguch
1020 1.1 martin if (sc == NULL)
1021 1.29 itojun goto done;
1022 1.120 knakahar
1023 1.57 martin pppoe_clear_softc(sc, "received PADT");
1024 1.158 yamaguch if (sc->sc_sppp.pp_if.if_flags & IFF_RUNNING)
1025 1.158 yamaguch callout_schedule(&sc->sc_timeout, PPPOE_RECON_FAST);
1026 1.127 knakahar PPPOE_UNLOCK(sc);
1027 1.25 itojun break;
1028 1.145 maxv
1029 1.25 itojun default:
1030 1.139 yamaguch rcvif = m_get_rcvif_psref(m, &psref);
1031 1.139 yamaguch if (__predict_false(rcvif == NULL))
1032 1.139 yamaguch goto done;
1033 1.139 yamaguch
1034 1.139 yamaguch if (hunique != NULL) {
1035 1.139 yamaguch sc = pppoe_find_softc_by_hunique(hunique,
1036 1.145 maxv hunique_len, rcvif, RW_READER);
1037 1.139 yamaguch }
1038 1.139 yamaguch
1039 1.139 yamaguch m_put_rcvif_psref(rcvif, &psref);
1040 1.139 yamaguch
1041 1.157 yamaguch pppoe_printf(sc, "unknown code (0x%04x) session = 0x%04x\n",
1042 1.157 yamaguch ph->code, session);
1043 1.157 yamaguch if (sc == NULL)
1044 1.157 yamaguch goto done;
1045 1.157 yamaguch PPPOE_UNLOCK(sc);
1046 1.25 itojun break;
1047 1.25 itojun }
1048 1.29 itojun
1049 1.29 itojun done:
1050 1.65 christos if (m)
1051 1.65 christos m_freem(m);
1052 1.29 itojun return;
1053 1.1 martin }
1054 1.1 martin
1055 1.1 martin static void
1056 1.1 martin pppoe_disc_input(struct mbuf *m)
1057 1.1 martin {
1058 1.137 maxv KASSERT(m->m_flags & M_PKTHDR);
1059 1.1 martin
1060 1.137 maxv /*
1061 1.137 maxv * Avoid error messages if there is not a single PPPoE instance.
1062 1.137 maxv */
1063 1.140 yamaguch rw_enter(&pppoe_softc_list_lock, RW_READER);
1064 1.25 itojun if (!LIST_EMPTY(&pppoe_softc_list)) {
1065 1.140 yamaguch rw_exit(&pppoe_softc_list_lock);
1066 1.29 itojun pppoe_dispatch_disc_pkt(m, 0);
1067 1.137 maxv } else {
1068 1.140 yamaguch rw_exit(&pppoe_softc_list_lock);
1069 1.29 itojun m_freem(m);
1070 1.137 maxv }
1071 1.1 martin }
1072 1.1 martin
1073 1.136 knakahar static bool
1074 1.136 knakahar pppoe_is_my_frame(uint8_t *dhost, struct ifnet *rcvif)
1075 1.136 knakahar {
1076 1.136 knakahar
1077 1.136 knakahar if (memcmp(CLLADDR(rcvif->if_sadl), dhost, ETHER_ADDR_LEN) == 0)
1078 1.136 knakahar return true;
1079 1.136 knakahar
1080 1.136 knakahar return false;
1081 1.136 knakahar }
1082 1.136 knakahar
1083 1.1 martin static void
1084 1.1 martin pppoe_data_input(struct mbuf *m)
1085 1.1 martin {
1086 1.84 matt uint16_t session, plen;
1087 1.25 itojun struct pppoe_softc *sc;
1088 1.29 itojun struct pppoehdr *ph;
1089 1.108 ozaki struct ifnet *rcvif;
1090 1.108 ozaki struct psref psref;
1091 1.84 matt uint8_t shost[ETHER_ADDR_LEN];
1092 1.136 knakahar uint8_t dhost[ETHER_ADDR_LEN];
1093 1.135 knakahar bool term_unknown = pppoe_term_unknown;
1094 1.1 martin
1095 1.25 itojun KASSERT(m->m_flags & M_PKTHDR);
1096 1.25 itojun
1097 1.137 maxv /*
1098 1.137 maxv * Avoid error messages if there is not a single PPPoE instance.
1099 1.137 maxv */
1100 1.140 yamaguch rw_enter(&pppoe_softc_list_lock, RW_READER);
1101 1.137 maxv if (LIST_EMPTY(&pppoe_softc_list)) {
1102 1.140 yamaguch rw_exit(&pppoe_softc_list_lock);
1103 1.137 maxv goto drop;
1104 1.137 maxv }
1105 1.140 yamaguch rw_exit(&pppoe_softc_list_lock);
1106 1.137 maxv
1107 1.136 knakahar if (term_unknown) {
1108 1.117 christos memcpy(shost, mtod(m, struct ether_header*)->ether_shost,
1109 1.117 christos ETHER_ADDR_LEN);
1110 1.136 knakahar memcpy(dhost, mtod(m, struct ether_header*)->ether_dhost,
1111 1.136 knakahar ETHER_ADDR_LEN);
1112 1.136 knakahar }
1113 1.25 itojun m_adj(m, sizeof(struct ether_header));
1114 1.25 itojun if (m->m_pkthdr.len <= PPPOE_HEADERLEN) {
1115 1.25 itojun goto drop;
1116 1.25 itojun }
1117 1.25 itojun
1118 1.30 itojun if (m->m_len < sizeof(*ph)) {
1119 1.30 itojun m = m_pullup(m, sizeof(*ph));
1120 1.145 maxv if (m == NULL) {
1121 1.30 itojun return;
1122 1.30 itojun }
1123 1.29 itojun }
1124 1.29 itojun ph = mtod(m, struct pppoehdr *);
1125 1.25 itojun
1126 1.29 itojun if (ph->vertype != PPPOE_VERTYPE) {
1127 1.25 itojun goto drop;
1128 1.25 itojun }
1129 1.146 maxv if (ph->code != 0) {
1130 1.25 itojun goto drop;
1131 1.146 maxv }
1132 1.25 itojun
1133 1.29 itojun session = ntohs(ph->session);
1134 1.108 ozaki rcvif = m_get_rcvif_psref(m, &psref);
1135 1.110 ozaki if (__predict_false(rcvif == NULL))
1136 1.110 ozaki goto drop;
1137 1.120 knakahar sc = pppoe_find_softc_by_session(session, rcvif, RW_READER);
1138 1.34 martin if (sc == NULL) {
1139 1.135 knakahar if (term_unknown) {
1140 1.136 knakahar static struct timeval lasttime = {0, 0};
1141 1.136 knakahar static int curpps = 0;
1142 1.136 knakahar /*
1143 1.136 knakahar * avoid to send wrong PADT which is response from
1144 1.147 msaitoh * session stage packets for other hosts when parent
1145 1.136 knakahar * ethernet is promiscuous mode.
1146 1.136 knakahar */
1147 1.145 maxv if (pppoe_is_my_frame(dhost, rcvif) &&
1148 1.145 maxv ppsratecheck(&lasttime, &curpps,
1149 1.136 knakahar pppoe_term_unknown_pps)) {
1150 1.157 yamaguch pppoe_printf(NULL, "input for unknown session %#x, "
1151 1.136 knakahar "sending PADT\n", session);
1152 1.136 knakahar pppoe_send_padt(rcvif, session, shost);
1153 1.136 knakahar }
1154 1.113 pgoyette }
1155 1.108 ozaki m_put_rcvif_psref(rcvif, &psref);
1156 1.25 itojun goto drop;
1157 1.34 martin }
1158 1.120 knakahar
1159 1.108 ozaki m_put_rcvif_psref(rcvif, &psref);
1160 1.25 itojun
1161 1.29 itojun plen = ntohs(ph->plen);
1162 1.1 martin
1163 1.141 msaitoh bpf_mtap(&sc->sc_sppp.pp_if, m, BPF_D_IN);
1164 1.1 martin
1165 1.25 itojun m_adj(m, PPPOE_HEADERLEN);
1166 1.1 martin
1167 1.1 martin #ifdef PPPOE_DEBUG
1168 1.25 itojun {
1169 1.25 itojun struct mbuf *p;
1170 1.1 martin
1171 1.25 itojun printf("%s: pkthdr.len=%d, pppoe.len=%d",
1172 1.129 msaitoh sc->sc_sppp.pp_if.if_xname, m->m_pkthdr.len, plen);
1173 1.25 itojun p = m;
1174 1.25 itojun while (p) {
1175 1.25 itojun printf(" l=%d", p->m_len);
1176 1.25 itojun p = p->m_next;
1177 1.25 itojun }
1178 1.25 itojun printf("\n");
1179 1.25 itojun }
1180 1.1 martin #endif
1181 1.127 knakahar PPPOE_UNLOCK(sc);
1182 1.26 itojun
1183 1.25 itojun if (m->m_pkthdr.len < plen)
1184 1.25 itojun goto drop;
1185 1.25 itojun
1186 1.156 yamaguch /* ignore trailing garbage */
1187 1.156 yamaguch m_adj(m, plen - m->m_pkthdr.len);
1188 1.129 msaitoh /*
1189 1.145 maxv * Fix incoming interface pointer (not the raw ethernet interface
1190 1.129 msaitoh * anymore)
1191 1.129 msaitoh */
1192 1.107 ozaki m_set_rcvif(m, &sc->sc_sppp.pp_if);
1193 1.25 itojun
1194 1.25 itojun /* pass packet up and account for it */
1195 1.148 thorpej if_statinc(&sc->sc_sppp.pp_if, if_ipackets);
1196 1.25 itojun sppp_input(&sc->sc_sppp.pp_if, m);
1197 1.25 itojun return;
1198 1.1 martin
1199 1.1 martin drop:
1200 1.29 itojun m_freem(m);
1201 1.1 martin }
1202 1.1 martin
1203 1.1 martin static int
1204 1.1 martin pppoe_output(struct pppoe_softc *sc, struct mbuf *m)
1205 1.1 martin {
1206 1.25 itojun struct sockaddr dst;
1207 1.25 itojun struct ether_header *eh;
1208 1.84 matt uint16_t etype;
1209 1.25 itojun
1210 1.52 oki if (sc->sc_eth_if == NULL) {
1211 1.52 oki m_freem(m);
1212 1.25 itojun return EIO;
1213 1.52 oki }
1214 1.25 itojun
1215 1.25 itojun memset(&dst, 0, sizeof dst);
1216 1.25 itojun dst.sa_family = AF_UNSPEC;
1217 1.25 itojun eh = (struct ether_header*)&dst.sa_data;
1218 1.129 msaitoh etype = sc->sc_state == PPPOE_STATE_SESSION
1219 1.129 msaitoh ? ETHERTYPE_PPPOE : ETHERTYPE_PPPOEDISC;
1220 1.25 itojun eh->ether_type = htons(etype);
1221 1.25 itojun memcpy(&eh->ether_dhost, &sc->sc_dest, sizeof sc->sc_dest);
1222 1.1 martin
1223 1.157 yamaguch DPRINTF(sc, "(%x) state=%d, session=0x%x output -> %s, len=%d\n",
1224 1.157 yamaguch etype, sc->sc_state, sc->sc_session,
1225 1.1 martin ether_sprintf((const unsigned char *)&sc->sc_dest), m->m_pkthdr.len);
1226 1.1 martin
1227 1.22 martin m->m_flags &= ~(M_BCAST|M_MCAST);
1228 1.148 thorpej if_statinc(&sc->sc_sppp.pp_if, if_opackets);
1229 1.109 knakahar return if_output_lock(sc->sc_eth_if, sc->sc_eth_if, m, &dst, NULL);
1230 1.1 martin }
1231 1.1 martin
1232 1.1 martin static int
1233 1.153 yamaguch pppoe_parm_cpyinstr(struct pppoe_softc *sc,
1234 1.153 yamaguch char **dst, const void *src, size_t len)
1235 1.153 yamaguch {
1236 1.153 yamaguch int error = 0;
1237 1.153 yamaguch char *next = NULL;
1238 1.153 yamaguch size_t bufsiz, cpysiz, strsiz;
1239 1.153 yamaguch
1240 1.153 yamaguch bufsiz = len + 1;
1241 1.153 yamaguch
1242 1.153 yamaguch if (src == NULL)
1243 1.153 yamaguch goto out;
1244 1.153 yamaguch
1245 1.153 yamaguch bufsiz = len + 1;
1246 1.153 yamaguch next = malloc(bufsiz, M_DEVBUF, M_WAITOK);
1247 1.153 yamaguch if (next == NULL)
1248 1.153 yamaguch return ENOMEM;
1249 1.153 yamaguch
1250 1.153 yamaguch error = copyinstr(src, next, bufsiz, &cpysiz);
1251 1.153 yamaguch if (error != 0)
1252 1.153 yamaguch goto fail;
1253 1.153 yamaguch if (cpysiz != bufsiz) {
1254 1.153 yamaguch error = EINVAL;
1255 1.153 yamaguch goto fail;
1256 1.153 yamaguch }
1257 1.153 yamaguch
1258 1.153 yamaguch strsiz = strnlen(next, bufsiz);
1259 1.153 yamaguch if (strsiz == bufsiz) {
1260 1.153 yamaguch error = EINVAL;
1261 1.153 yamaguch goto fail;
1262 1.153 yamaguch }
1263 1.153 yamaguch
1264 1.153 yamaguch out:
1265 1.153 yamaguch PPPOE_LOCK(sc, RW_WRITER);
1266 1.153 yamaguch if (*dst != NULL)
1267 1.153 yamaguch free(*dst, M_DEVBUF);
1268 1.153 yamaguch *dst = next;
1269 1.153 yamaguch next = NULL;
1270 1.153 yamaguch PPPOE_UNLOCK(sc);
1271 1.153 yamaguch fail:
1272 1.153 yamaguch if (next != NULL)
1273 1.153 yamaguch free(next, M_DEVBUF);
1274 1.153 yamaguch
1275 1.153 yamaguch return error;
1276 1.153 yamaguch }
1277 1.153 yamaguch
1278 1.153 yamaguch static int
1279 1.77 christos pppoe_ioctl(struct ifnet *ifp, unsigned long cmd, void *data)
1280 1.1 martin {
1281 1.70 ad struct lwp *l = curlwp; /* XXX */
1282 1.1 martin struct pppoe_softc *sc = (struct pppoe_softc*)ifp;
1283 1.83 dyoung struct ifreq *ifr = data;
1284 1.1 martin int error = 0;
1285 1.1 martin
1286 1.1 martin switch (cmd) {
1287 1.1 martin case PPPOESETPARMS:
1288 1.1 martin {
1289 1.1 martin struct pppoediscparms *parms = (struct pppoediscparms*)data;
1290 1.74 elad if (kauth_authorize_network(l->l_cred, KAUTH_NETWORK_INTERFACE,
1291 1.74 elad KAUTH_REQ_NETWORK_INTERFACE_SETPRIV, ifp, (void *)cmd,
1292 1.74 elad NULL) != 0)
1293 1.129 msaitoh return EPERM;
1294 1.1 martin if (parms->eth_ifname[0] != 0) {
1295 1.145 maxv struct ifnet *eth_if;
1296 1.67 tron
1297 1.127 knakahar PPPOE_LOCK(sc, RW_WRITER);
1298 1.167 yamaguch if (sc->sc_detaching) {
1299 1.167 yamaguch PPPOE_UNLOCK(sc);
1300 1.167 yamaguch return ENXIO;
1301 1.167 yamaguch }
1302 1.67 tron eth_if = ifunit(parms->eth_ifname);
1303 1.67 tron if (eth_if == NULL || eth_if->if_dlt != DLT_EN10MB) {
1304 1.66 tron sc->sc_eth_if = NULL;
1305 1.127 knakahar PPPOE_UNLOCK(sc);
1306 1.1 martin return ENXIO;
1307 1.66 tron }
1308 1.67 tron
1309 1.98 rjs if (sc->sc_sppp.pp_if.if_mtu !=
1310 1.67 tron eth_if->if_mtu - PPPOE_OVERHEAD) {
1311 1.67 tron sc->sc_sppp.pp_if.if_mtu = eth_if->if_mtu -
1312 1.67 tron PPPOE_OVERHEAD;
1313 1.67 tron }
1314 1.67 tron sc->sc_eth_if = eth_if;
1315 1.127 knakahar PPPOE_UNLOCK(sc);
1316 1.1 martin }
1317 1.120 knakahar
1318 1.153 yamaguch error = pppoe_parm_cpyinstr(sc, &sc->sc_concentrator_name,
1319 1.153 yamaguch parms->ac_name, parms->ac_name_len);
1320 1.153 yamaguch if (error != 0)
1321 1.153 yamaguch return error;
1322 1.153 yamaguch
1323 1.153 yamaguch error = pppoe_parm_cpyinstr(sc, &sc->sc_service_name,
1324 1.153 yamaguch parms->service_name, parms->service_name_len);
1325 1.153 yamaguch if (error != 0)
1326 1.153 yamaguch return error;
1327 1.1 martin return 0;
1328 1.1 martin }
1329 1.1 martin break;
1330 1.1 martin case PPPOEGETPARMS:
1331 1.1 martin {
1332 1.1 martin struct pppoediscparms *parms = (struct pppoediscparms*)data;
1333 1.1 martin memset(parms, 0, sizeof *parms);
1334 1.127 knakahar PPPOE_LOCK(sc, RW_READER);
1335 1.1 martin if (sc->sc_eth_if)
1336 1.106 christos strlcpy(parms->ifname, sc->sc_eth_if->if_xname,
1337 1.106 christos sizeof(parms->ifname));
1338 1.127 knakahar PPPOE_UNLOCK(sc);
1339 1.15 martin return 0;
1340 1.15 martin }
1341 1.15 martin break;
1342 1.15 martin case PPPOEGETSESSION:
1343 1.15 martin {
1344 1.15 martin struct pppoeconnectionstate *state = (struct pppoeconnectionstate*)data;
1345 1.127 knakahar PPPOE_LOCK(sc, RW_READER);
1346 1.15 martin state->state = sc->sc_state;
1347 1.15 martin state->session_id = sc->sc_session;
1348 1.15 martin state->padi_retry_no = sc->sc_padi_retried;
1349 1.15 martin state->padr_retry_no = sc->sc_padr_retried;
1350 1.127 knakahar PPPOE_UNLOCK(sc);
1351 1.1 martin return 0;
1352 1.1 martin }
1353 1.1 martin break;
1354 1.13 martin case SIOCSIFFLAGS:
1355 1.13 martin /*
1356 1.13 martin * Prevent running re-establishment timers overriding
1357 1.13 martin * administrators choice.
1358 1.13 martin */
1359 1.127 knakahar PPPOE_LOCK(sc, RW_WRITER);
1360 1.167 yamaguch if (sc->sc_detaching) {
1361 1.167 yamaguch PPPOE_UNLOCK(sc);
1362 1.167 yamaguch return ENXIO;
1363 1.167 yamaguch }
1364 1.120 knakahar
1365 1.14 martin if ((ifr->ifr_flags & IFF_UP) == 0
1366 1.14 martin && sc->sc_state < PPPOE_STATE_SESSION) {
1367 1.13 martin callout_stop(&sc->sc_timeout);
1368 1.14 martin sc->sc_state = PPPOE_STATE_INITIAL;
1369 1.13 martin sc->sc_padi_retried = 0;
1370 1.13 martin sc->sc_padr_retried = 0;
1371 1.28 itojun memcpy(&sc->sc_dest, etherbroadcastaddr,
1372 1.28 itojun sizeof(sc->sc_dest));
1373 1.13 martin }
1374 1.120 knakahar
1375 1.127 knakahar PPPOE_UNLOCK(sc);
1376 1.120 knakahar
1377 1.120 knakahar error = sppp_ioctl(ifp, cmd, data);
1378 1.120 knakahar
1379 1.120 knakahar return error;
1380 1.19 martin case SIOCSIFMTU:
1381 1.67 tron if (ifr->ifr_mtu > (sc->sc_eth_if == NULL ?
1382 1.67 tron PPPOE_MAXMTU : (sc->sc_eth_if->if_mtu - PPPOE_OVERHEAD))) {
1383 1.19 martin return EINVAL;
1384 1.67 tron }
1385 1.83 dyoung /*FALLTHROUGH*/
1386 1.1 martin default:
1387 1.1 martin return sppp_ioctl(ifp, cmd, data);
1388 1.1 martin }
1389 1.1 martin return 0;
1390 1.1 martin }
1391 1.1 martin
1392 1.1 martin /*
1393 1.1 martin * Allocate a mbuf/cluster with space to store the given data length
1394 1.1 martin * of payload, leaving space for prepending an ethernet header
1395 1.59 perry * in front.
1396 1.1 martin */
1397 1.1 martin static struct mbuf *
1398 1.1 martin pppoe_get_mbuf(size_t len)
1399 1.1 martin {
1400 1.1 martin struct mbuf *m;
1401 1.1 martin
1402 1.1 martin MGETHDR(m, M_DONTWAIT, MT_DATA);
1403 1.1 martin if (m == NULL)
1404 1.1 martin return NULL;
1405 1.26 itojun if (len + sizeof(struct ether_header) > MHLEN) {
1406 1.1 martin MCLGET(m, M_DONTWAIT);
1407 1.1 martin if ((m->m_flags & M_EXT) == 0) {
1408 1.101 martin m_free(m);
1409 1.101 martin return NULL;
1410 1.1 martin }
1411 1.1 martin }
1412 1.1 martin m->m_data += sizeof(struct ether_header);
1413 1.1 martin m->m_len = len;
1414 1.1 martin m->m_pkthdr.len = len;
1415 1.107 ozaki m_reset_rcvif(m);
1416 1.1 martin
1417 1.1 martin return m;
1418 1.1 martin }
1419 1.1 martin
1420 1.1 martin static int
1421 1.1 martin pppoe_send_padi(struct pppoe_softc *sc)
1422 1.1 martin {
1423 1.1 martin struct mbuf *m0;
1424 1.142 maxv int len, l1 = 0, l2 = 0;
1425 1.84 matt uint8_t *p;
1426 1.1 martin
1427 1.142 maxv if (sc->sc_state > PPPOE_STATE_PADI_SENT)
1428 1.1 martin panic("pppoe_send_padi in state %d", sc->sc_state);
1429 1.1 martin
1430 1.142 maxv /* Compute packet length. */
1431 1.142 maxv len = sizeof(struct pppoetag);
1432 1.1 martin if (sc->sc_service_name != NULL) {
1433 1.1 martin l1 = strlen(sc->sc_service_name);
1434 1.1 martin len += l1;
1435 1.1 martin }
1436 1.1 martin if (sc->sc_concentrator_name != NULL) {
1437 1.1 martin l2 = strlen(sc->sc_concentrator_name);
1438 1.142 maxv len += sizeof(struct pppoetag) + l2;
1439 1.1 martin }
1440 1.143 maxv len += sizeof(struct pppoetag) + sizeof(sc->sc_id);
1441 1.98 rjs if (sc->sc_sppp.pp_if.if_mtu > PPPOE_MAXMTU) {
1442 1.142 maxv len += sizeof(struct pppoetag) + 2;
1443 1.98 rjs }
1444 1.1 martin
1445 1.142 maxv /* Allocate packet. */
1446 1.142 maxv m0 = pppoe_get_mbuf(len + PPPOE_HEADERLEN);
1447 1.142 maxv if (m0 == NULL)
1448 1.26 itojun return ENOBUFS;
1449 1.1 martin
1450 1.142 maxv /* Fill in packet. */
1451 1.84 matt p = mtod(m0, uint8_t *);
1452 1.1 martin PPPOE_ADD_HEADER(p, PPPOE_CODE_PADI, 0, len);
1453 1.1 martin PPPOE_ADD_16(p, PPPOE_TAG_SNAME);
1454 1.1 martin if (sc->sc_service_name != NULL) {
1455 1.1 martin PPPOE_ADD_16(p, l1);
1456 1.1 martin memcpy(p, sc->sc_service_name, l1);
1457 1.1 martin p += l1;
1458 1.1 martin } else {
1459 1.1 martin PPPOE_ADD_16(p, 0);
1460 1.1 martin }
1461 1.1 martin if (sc->sc_concentrator_name != NULL) {
1462 1.1 martin PPPOE_ADD_16(p, PPPOE_TAG_ACNAME);
1463 1.1 martin PPPOE_ADD_16(p, l2);
1464 1.1 martin memcpy(p, sc->sc_concentrator_name, l2);
1465 1.1 martin p += l2;
1466 1.1 martin }
1467 1.1 martin PPPOE_ADD_16(p, PPPOE_TAG_HUNIQUE);
1468 1.143 maxv PPPOE_ADD_16(p, sizeof(sc->sc_id));
1469 1.143 maxv memcpy(p, &sc->sc_id, sizeof(sc->sc_id));
1470 1.143 maxv p += sizeof(sc->sc_id);
1471 1.98 rjs
1472 1.98 rjs if (sc->sc_sppp.pp_if.if_mtu > PPPOE_MAXMTU) {
1473 1.98 rjs PPPOE_ADD_16(p, PPPOE_TAG_MAX_PAYLOAD);
1474 1.98 rjs PPPOE_ADD_16(p, 2);
1475 1.98 rjs PPPOE_ADD_16(p, (uint16_t)sc->sc_sppp.pp_if.if_mtu);
1476 1.98 rjs }
1477 1.1 martin
1478 1.1 martin #ifdef PPPOE_DEBUG
1479 1.84 matt if (p - mtod(m0, uint8_t *) != len + PPPOE_HEADERLEN)
1480 1.1 martin panic("pppoe_send_padi: garbled output len, should be %ld, is %ld",
1481 1.84 matt (long)(len + PPPOE_HEADERLEN), (long)(p - mtod(m0, uint8_t *)));
1482 1.1 martin #endif
1483 1.1 martin
1484 1.142 maxv /* Send packet. */
1485 1.1 martin return pppoe_output(sc, m0);
1486 1.1 martin }
1487 1.1 martin
1488 1.1 martin static void
1489 1.151 yamaguch pppoe_timeout_co(void *arg)
1490 1.151 yamaguch {
1491 1.151 yamaguch struct pppoe_softc *sc = (struct pppoe_softc *)arg;
1492 1.151 yamaguch
1493 1.151 yamaguch if (atomic_swap_uint(&sc->sc_timeout_scheduled, 1) != 0)
1494 1.151 yamaguch return;
1495 1.151 yamaguch
1496 1.151 yamaguch workqueue_enqueue(sc->sc_timeout_wq, &sc->sc_timeout_wk, NULL);
1497 1.151 yamaguch }
1498 1.151 yamaguch
1499 1.151 yamaguch static void
1500 1.151 yamaguch pppoe_timeout_co_halt(void *unused __unused)
1501 1.151 yamaguch {
1502 1.151 yamaguch
1503 1.151 yamaguch /* do nothing to halt callout safely */
1504 1.151 yamaguch }
1505 1.151 yamaguch
1506 1.151 yamaguch static void
1507 1.151 yamaguch pppoe_timeout_wk(struct work *wk __unused, void *arg)
1508 1.151 yamaguch {
1509 1.151 yamaguch struct pppoe_softc *sc = (struct pppoe_softc *)arg;
1510 1.151 yamaguch
1511 1.151 yamaguch atomic_swap_uint(&sc->sc_timeout_scheduled, 0);
1512 1.151 yamaguch pppoe_timeout(sc);
1513 1.151 yamaguch }
1514 1.151 yamaguch
1515 1.151 yamaguch static void
1516 1.151 yamaguch pppoe_timeout(struct pppoe_softc *sc)
1517 1.1 martin {
1518 1.120 knakahar int retry_wait, err;
1519 1.120 knakahar DECLARE_SPLNET_VARIABLE;
1520 1.1 martin
1521 1.157 yamaguch pppoe_printf(sc, "timeout\n");
1522 1.1 martin
1523 1.127 knakahar PPPOE_LOCK(sc, RW_WRITER);
1524 1.1 martin switch (sc->sc_state) {
1525 1.90 martin case PPPOE_STATE_INITIAL:
1526 1.90 martin /* delayed connect from pppoe_tls() */
1527 1.167 yamaguch if (!sc->sc_detaching)
1528 1.167 yamaguch pppoe_connect(sc);
1529 1.90 martin break;
1530 1.1 martin case PPPOE_STATE_PADI_SENT:
1531 1.13 martin /*
1532 1.13 martin * We have two basic ways of retrying:
1533 1.13 martin * - Quick retry mode: try a few times in short sequence
1534 1.13 martin * - Slow retry mode: we already had a connection successfully
1535 1.13 martin * established and will try infinitely (without user
1536 1.13 martin * intervention)
1537 1.13 martin * We only enter slow retry mode if IFF_LINK1 (aka autodial)
1538 1.35 martin * is not set.
1539 1.13 martin */
1540 1.13 martin
1541 1.13 martin /* initialize for quick retry mode */
1542 1.30 itojun retry_wait = PPPOE_DISC_TIMEOUT * (1 + sc->sc_padi_retried);
1543 1.13 martin
1544 1.120 knakahar ACQUIRE_SPLNET();
1545 1.1 martin sc->sc_padi_retried++;
1546 1.1 martin if (sc->sc_padi_retried >= PPPOE_DISC_MAXPADI) {
1547 1.35 martin if ((sc->sc_sppp.pp_if.if_flags & IFF_LINK1) == 0) {
1548 1.28 itojun /* slow retry mode */
1549 1.28 itojun retry_wait = PPPOE_SLOW_RETRY;
1550 1.13 martin } else {
1551 1.28 itojun pppoe_abort_connect(sc);
1552 1.121 knakahar RELEASE_SPLNET();
1553 1.127 knakahar PPPOE_UNLOCK(sc);
1554 1.28 itojun return;
1555 1.13 martin }
1556 1.1 martin }
1557 1.45 martin if ((err = pppoe_send_padi(sc)) != 0) {
1558 1.45 martin sc->sc_padi_retried--;
1559 1.157 yamaguch pppoe_printf(sc,
1560 1.157 yamaguch "failed to transmit PADI, error=%d\n", err);
1561 1.45 martin }
1562 1.150 yamaguch callout_schedule(&sc->sc_timeout,retry_wait);
1563 1.120 knakahar RELEASE_SPLNET();
1564 1.1 martin break;
1565 1.1 martin
1566 1.1 martin case PPPOE_STATE_PADR_SENT:
1567 1.120 knakahar ACQUIRE_SPLNET();
1568 1.1 martin sc->sc_padr_retried++;
1569 1.1 martin if (sc->sc_padr_retried >= PPPOE_DISC_MAXPADR) {
1570 1.28 itojun memcpy(&sc->sc_dest, etherbroadcastaddr,
1571 1.28 itojun sizeof(sc->sc_dest));
1572 1.1 martin sc->sc_state = PPPOE_STATE_PADI_SENT;
1573 1.161 yamaguch sc->sc_padi_retried = 0;
1574 1.1 martin sc->sc_padr_retried = 0;
1575 1.45 martin if ((err = pppoe_send_padi(sc)) != 0) {
1576 1.157 yamaguch pppoe_printf(sc,
1577 1.157 yamaguch "failed to send PADI, error=%d\n", err);
1578 1.45 martin }
1579 1.150 yamaguch callout_schedule(&sc->sc_timeout,
1580 1.150 yamaguch PPPOE_DISC_TIMEOUT * (1 + sc->sc_padi_retried));
1581 1.120 knakahar RELEASE_SPLNET();
1582 1.127 knakahar PPPOE_UNLOCK(sc);
1583 1.1 martin return;
1584 1.1 martin }
1585 1.45 martin if ((err = pppoe_send_padr(sc)) != 0) {
1586 1.45 martin sc->sc_padr_retried--;
1587 1.157 yamaguch pppoe_printf(sc,"failed to send PADR, error=%d", err);
1588 1.45 martin }
1589 1.150 yamaguch callout_schedule(&sc->sc_timeout,
1590 1.150 yamaguch PPPOE_DISC_TIMEOUT * (1 + sc->sc_padr_retried));
1591 1.120 knakahar RELEASE_SPLNET();
1592 1.1 martin break;
1593 1.1 martin case PPPOE_STATE_CLOSING:
1594 1.1 martin pppoe_disconnect(sc);
1595 1.1 martin break;
1596 1.1 martin default:
1597 1.127 knakahar PPPOE_UNLOCK(sc);
1598 1.1 martin return; /* all done, work in peace */
1599 1.1 martin }
1600 1.127 knakahar PPPOE_UNLOCK(sc);
1601 1.1 martin }
1602 1.1 martin
1603 1.1 martin /* Start a connection (i.e. initiate discovery phase) */
1604 1.1 martin static int
1605 1.1 martin pppoe_connect(struct pppoe_softc *sc)
1606 1.1 martin {
1607 1.120 knakahar int err;
1608 1.120 knakahar DECLARE_SPLNET_VARIABLE;
1609 1.120 knakahar
1610 1.127 knakahar KASSERT(PPPOE_WLOCKED(sc));
1611 1.1 martin
1612 1.1 martin if (sc->sc_state != PPPOE_STATE_INITIAL)
1613 1.1 martin return EBUSY;
1614 1.1 martin
1615 1.43 oki #ifdef PPPOE_SERVER
1616 1.43 oki /* wait PADI if IFF_PASSIVE */
1617 1.43 oki if ((sc->sc_sppp.pp_if.if_flags & IFF_PASSIVE))
1618 1.43 oki return 0;
1619 1.43 oki #endif
1620 1.120 knakahar ACQUIRE_SPLNET();
1621 1.36 martin /* save state, in case we fail to send PADI */
1622 1.1 martin sc->sc_state = PPPOE_STATE_PADI_SENT;
1623 1.161 yamaguch sc->sc_padi_retried = 0;
1624 1.1 martin sc->sc_padr_retried = 0;
1625 1.1 martin err = pppoe_send_padi(sc);
1626 1.157 yamaguch if (err != 0)
1627 1.157 yamaguch pppoe_printf(sc, "failed to send PADI, error=%d\n", err);
1628 1.150 yamaguch callout_schedule(&sc->sc_timeout, PPPOE_DISC_TIMEOUT);
1629 1.120 knakahar RELEASE_SPLNET();
1630 1.1 martin return err;
1631 1.1 martin }
1632 1.1 martin
1633 1.1 martin /* disconnect */
1634 1.1 martin static int
1635 1.1 martin pppoe_disconnect(struct pppoe_softc *sc)
1636 1.1 martin {
1637 1.120 knakahar int err;
1638 1.120 knakahar DECLARE_SPLNET_VARIABLE;
1639 1.120 knakahar
1640 1.127 knakahar KASSERT(PPPOE_WLOCKED(sc));
1641 1.1 martin
1642 1.120 knakahar ACQUIRE_SPLNET();
1643 1.1 martin
1644 1.1 martin if (sc->sc_state < PPPOE_STATE_SESSION)
1645 1.1 martin err = EBUSY;
1646 1.1 martin else {
1647 1.157 yamaguch pppoe_printf(sc, "disconnecting\n");
1648 1.129 msaitoh err = pppoe_send_padt(sc->sc_eth_if, sc->sc_session,
1649 1.129 msaitoh (const uint8_t *)&sc->sc_dest);
1650 1.1 martin }
1651 1.1 martin
1652 1.1 martin /* cleanup softc */
1653 1.1 martin sc->sc_state = PPPOE_STATE_INITIAL;
1654 1.120 knakahar
1655 1.1 martin memcpy(&sc->sc_dest, etherbroadcastaddr, sizeof(sc->sc_dest));
1656 1.1 martin if (sc->sc_ac_cookie) {
1657 1.32 yamt free(sc->sc_ac_cookie, M_DEVBUF);
1658 1.1 martin sc->sc_ac_cookie = NULL;
1659 1.1 martin }
1660 1.1 martin sc->sc_ac_cookie_len = 0;
1661 1.94 christos if (sc->sc_relay_sid) {
1662 1.94 christos free(sc->sc_relay_sid, M_DEVBUF);
1663 1.94 christos sc->sc_relay_sid = NULL;
1664 1.94 christos }
1665 1.94 christos sc->sc_relay_sid_len = 0;
1666 1.43 oki #ifdef PPPOE_SERVER
1667 1.43 oki if (sc->sc_hunique) {
1668 1.43 oki free(sc->sc_hunique, M_DEVBUF);
1669 1.43 oki sc->sc_hunique = NULL;
1670 1.43 oki }
1671 1.43 oki sc->sc_hunique_len = 0;
1672 1.43 oki #endif
1673 1.1 martin sc->sc_session = 0;
1674 1.1 martin
1675 1.127 knakahar PPPOE_UNLOCK(sc);
1676 1.120 knakahar
1677 1.1 martin /* notify upper layer */
1678 1.1 martin sc->sc_sppp.pp_down(&sc->sc_sppp);
1679 1.1 martin
1680 1.127 knakahar PPPOE_LOCK(sc, RW_WRITER);
1681 1.1 martin
1682 1.120 knakahar RELEASE_SPLNET();
1683 1.1 martin return err;
1684 1.1 martin }
1685 1.1 martin
1686 1.1 martin /* Connection attempt aborted */
1687 1.1 martin static void
1688 1.1 martin pppoe_abort_connect(struct pppoe_softc *sc)
1689 1.1 martin {
1690 1.127 knakahar KASSERT(PPPOE_WLOCKED(sc));
1691 1.120 knakahar
1692 1.157 yamaguch pppoe_printf(sc, "could not establish connection\n");
1693 1.36 martin sc->sc_state = PPPOE_STATE_CLOSING;
1694 1.120 knakahar
1695 1.127 knakahar PPPOE_UNLOCK(sc);
1696 1.1 martin
1697 1.1 martin /* notify upper layer */
1698 1.1 martin sc->sc_sppp.pp_down(&sc->sc_sppp);
1699 1.120 knakahar
1700 1.127 knakahar PPPOE_LOCK(sc, RW_WRITER);
1701 1.36 martin
1702 1.36 martin /* clear connection state */
1703 1.36 martin memcpy(&sc->sc_dest, etherbroadcastaddr, sizeof(sc->sc_dest));
1704 1.36 martin sc->sc_state = PPPOE_STATE_INITIAL;
1705 1.1 martin }
1706 1.1 martin
1707 1.1 martin static int
1708 1.1 martin pppoe_send_padr(struct pppoe_softc *sc)
1709 1.1 martin {
1710 1.1 martin struct mbuf *m0;
1711 1.84 matt uint8_t *p;
1712 1.142 maxv size_t len, l1 = 0;
1713 1.1 martin
1714 1.1 martin if (sc->sc_state != PPPOE_STATE_PADR_SENT)
1715 1.1 martin return EIO;
1716 1.1 martin
1717 1.142 maxv /* Compute packet length. */
1718 1.142 maxv len = sizeof(struct pppoetag);
1719 1.142 maxv if (sc->sc_service_name != NULL) {
1720 1.1 martin l1 = strlen(sc->sc_service_name);
1721 1.1 martin len += l1;
1722 1.1 martin }
1723 1.142 maxv if (sc->sc_ac_cookie_len > 0) {
1724 1.142 maxv len += sizeof(struct pppoetag) + sc->sc_ac_cookie_len;
1725 1.142 maxv }
1726 1.142 maxv if (sc->sc_relay_sid_len > 0) {
1727 1.142 maxv len += sizeof(struct pppoetag) + sc->sc_relay_sid_len;
1728 1.142 maxv }
1729 1.143 maxv len += sizeof(struct pppoetag) + sizeof(sc->sc_id);
1730 1.98 rjs if (sc->sc_sppp.pp_if.if_mtu > PPPOE_MAXMTU) {
1731 1.142 maxv len += sizeof(struct pppoetag) + 2;
1732 1.98 rjs }
1733 1.142 maxv
1734 1.142 maxv /* Allocate packet. */
1735 1.26 itojun m0 = pppoe_get_mbuf(len + PPPOE_HEADERLEN);
1736 1.142 maxv if (m0 == NULL)
1737 1.26 itojun return ENOBUFS;
1738 1.142 maxv
1739 1.142 maxv /* Fill in packet. */
1740 1.84 matt p = mtod(m0, uint8_t *);
1741 1.1 martin PPPOE_ADD_HEADER(p, PPPOE_CODE_PADR, 0, len);
1742 1.1 martin PPPOE_ADD_16(p, PPPOE_TAG_SNAME);
1743 1.1 martin if (sc->sc_service_name != NULL) {
1744 1.1 martin PPPOE_ADD_16(p, l1);
1745 1.1 martin memcpy(p, sc->sc_service_name, l1);
1746 1.1 martin p += l1;
1747 1.1 martin } else {
1748 1.1 martin PPPOE_ADD_16(p, 0);
1749 1.1 martin }
1750 1.1 martin if (sc->sc_ac_cookie_len > 0) {
1751 1.1 martin PPPOE_ADD_16(p, PPPOE_TAG_ACCOOKIE);
1752 1.1 martin PPPOE_ADD_16(p, sc->sc_ac_cookie_len);
1753 1.1 martin memcpy(p, sc->sc_ac_cookie, sc->sc_ac_cookie_len);
1754 1.1 martin p += sc->sc_ac_cookie_len;
1755 1.1 martin }
1756 1.94 christos if (sc->sc_relay_sid_len > 0) {
1757 1.94 christos PPPOE_ADD_16(p, PPPOE_TAG_RELAYSID);
1758 1.94 christos PPPOE_ADD_16(p, sc->sc_relay_sid_len);
1759 1.94 christos memcpy(p, sc->sc_relay_sid, sc->sc_relay_sid_len);
1760 1.94 christos p += sc->sc_relay_sid_len;
1761 1.94 christos }
1762 1.1 martin PPPOE_ADD_16(p, PPPOE_TAG_HUNIQUE);
1763 1.143 maxv PPPOE_ADD_16(p, sizeof(sc->sc_id));
1764 1.143 maxv memcpy(p, &sc->sc_id, sizeof(sc->sc_id));
1765 1.143 maxv p += sizeof(sc->sc_id);
1766 1.98 rjs
1767 1.98 rjs if (sc->sc_sppp.pp_if.if_mtu > PPPOE_MAXMTU) {
1768 1.98 rjs PPPOE_ADD_16(p, PPPOE_TAG_MAX_PAYLOAD);
1769 1.98 rjs PPPOE_ADD_16(p, 2);
1770 1.98 rjs PPPOE_ADD_16(p, (uint16_t)sc->sc_sppp.pp_if.if_mtu);
1771 1.98 rjs }
1772 1.1 martin
1773 1.1 martin #ifdef PPPOE_DEBUG
1774 1.84 matt if (p - mtod(m0, uint8_t *) != len + PPPOE_HEADERLEN)
1775 1.1 martin panic("pppoe_send_padr: garbled output len, should be %ld, is %ld",
1776 1.84 matt (long)(len + PPPOE_HEADERLEN), (long)(p - mtod(m0, uint8_t *)));
1777 1.1 martin #endif
1778 1.1 martin
1779 1.142 maxv /* Send packet. */
1780 1.1 martin return pppoe_output(sc, m0);
1781 1.1 martin }
1782 1.1 martin
1783 1.1 martin /* send a PADT packet */
1784 1.1 martin static int
1785 1.84 matt pppoe_send_padt(struct ifnet *outgoing_if, u_int session, const uint8_t *dest)
1786 1.1 martin {
1787 1.39 martin struct ether_header *eh;
1788 1.39 martin struct sockaddr dst;
1789 1.1 martin struct mbuf *m0;
1790 1.84 matt uint8_t *p;
1791 1.1 martin
1792 1.1 martin m0 = pppoe_get_mbuf(PPPOE_HEADERLEN);
1793 1.26 itojun if (!m0)
1794 1.39 martin return EIO;
1795 1.84 matt p = mtod(m0, uint8_t *);
1796 1.39 martin PPPOE_ADD_HEADER(p, PPPOE_CODE_PADT, session, 0);
1797 1.39 martin
1798 1.39 martin memset(&dst, 0, sizeof dst);
1799 1.39 martin dst.sa_family = AF_UNSPEC;
1800 1.39 martin eh = (struct ether_header*)&dst.sa_data;
1801 1.39 martin eh->ether_type = htons(ETHERTYPE_PPPOEDISC);
1802 1.39 martin memcpy(&eh->ether_dhost, dest, ETHER_ADDR_LEN);
1803 1.39 martin
1804 1.39 martin m0->m_flags &= ~(M_BCAST|M_MCAST);
1805 1.109 knakahar return if_output_lock(outgoing_if, outgoing_if, m0, &dst, NULL);
1806 1.1 martin }
1807 1.43 oki
1808 1.43 oki #ifdef PPPOE_SERVER
1809 1.43 oki static int
1810 1.43 oki pppoe_send_pado(struct pppoe_softc *sc)
1811 1.43 oki {
1812 1.43 oki struct mbuf *m0;
1813 1.84 matt uint8_t *p;
1814 1.43 oki size_t len;
1815 1.43 oki
1816 1.43 oki if (sc->sc_state != PPPOE_STATE_PADO_SENT)
1817 1.43 oki return EIO;
1818 1.43 oki
1819 1.144 maxv /* Include AC cookie. */
1820 1.144 maxv len = sizeof(struct pppoetag) + sizeof(sc->sc_id);
1821 1.144 maxv /* Include hunique. */
1822 1.144 maxv len += sizeof(struct pppoetag) + sc->sc_hunique_len;
1823 1.144 maxv
1824 1.43 oki m0 = pppoe_get_mbuf(len + PPPOE_HEADERLEN);
1825 1.43 oki if (!m0)
1826 1.43 oki return EIO;
1827 1.84 matt p = mtod(m0, uint8_t *);
1828 1.144 maxv
1829 1.43 oki PPPOE_ADD_HEADER(p, PPPOE_CODE_PADO, 0, len);
1830 1.43 oki PPPOE_ADD_16(p, PPPOE_TAG_ACCOOKIE);
1831 1.143 maxv PPPOE_ADD_16(p, sizeof(sc->sc_id));
1832 1.143 maxv memcpy(p, &sc->sc_id, sizeof(sc->sc_id));
1833 1.143 maxv p += sizeof(sc->sc_id);
1834 1.43 oki PPPOE_ADD_16(p, PPPOE_TAG_HUNIQUE);
1835 1.43 oki PPPOE_ADD_16(p, sc->sc_hunique_len);
1836 1.43 oki memcpy(p, sc->sc_hunique, sc->sc_hunique_len);
1837 1.43 oki return pppoe_output(sc, m0);
1838 1.43 oki }
1839 1.43 oki
1840 1.43 oki static int
1841 1.43 oki pppoe_send_pads(struct pppoe_softc *sc)
1842 1.43 oki {
1843 1.69 kardel struct bintime bt;
1844 1.43 oki struct mbuf *m0;
1845 1.84 matt uint8_t *p;
1846 1.61 martin size_t len, l1 = 0; /* XXX: gcc */
1847 1.43 oki
1848 1.127 knakahar KASSERT(PPPOE_WLOCKED(sc));
1849 1.120 knakahar
1850 1.43 oki if (sc->sc_state != PPPOE_STATE_PADO_SENT)
1851 1.43 oki return EIO;
1852 1.43 oki
1853 1.69 kardel getbinuptime(&bt);
1854 1.69 kardel sc->sc_session = bt.sec % 0xff + 1;
1855 1.144 maxv
1856 1.144 maxv /* Include service name. */
1857 1.144 maxv len = sizeof(struct pppoetag);
1858 1.144 maxv if (sc->sc_service_name != NULL) {
1859 1.43 oki l1 = strlen(sc->sc_service_name);
1860 1.43 oki len += l1;
1861 1.43 oki }
1862 1.144 maxv /* Include hunique. */
1863 1.144 maxv len += sizeof(struct pppoetag) + sc->sc_hunique_len;
1864 1.144 maxv
1865 1.43 oki m0 = pppoe_get_mbuf(len + PPPOE_HEADERLEN);
1866 1.43 oki if (!m0)
1867 1.43 oki return ENOBUFS;
1868 1.84 matt p = mtod(m0, uint8_t *);
1869 1.144 maxv
1870 1.43 oki PPPOE_ADD_HEADER(p, PPPOE_CODE_PADS, sc->sc_session, len);
1871 1.43 oki PPPOE_ADD_16(p, PPPOE_TAG_SNAME);
1872 1.43 oki if (sc->sc_service_name != NULL) {
1873 1.43 oki PPPOE_ADD_16(p, l1);
1874 1.43 oki memcpy(p, sc->sc_service_name, l1);
1875 1.43 oki p += l1;
1876 1.43 oki } else {
1877 1.43 oki PPPOE_ADD_16(p, 0);
1878 1.43 oki }
1879 1.43 oki PPPOE_ADD_16(p, PPPOE_TAG_HUNIQUE);
1880 1.43 oki PPPOE_ADD_16(p, sc->sc_hunique_len);
1881 1.43 oki memcpy(p, sc->sc_hunique, sc->sc_hunique_len);
1882 1.43 oki return pppoe_output(sc, m0);
1883 1.43 oki }
1884 1.43 oki #endif
1885 1.1 martin
1886 1.1 martin static void
1887 1.1 martin pppoe_tls(struct sppp *sp)
1888 1.1 martin {
1889 1.26 itojun struct pppoe_softc *sc = (void *)sp;
1890 1.90 martin int wtime;
1891 1.90 martin
1892 1.127 knakahar PPPOE_LOCK(sc, RW_READER);
1893 1.120 knakahar
1894 1.120 knakahar if (sc->sc_state != PPPOE_STATE_INITIAL) {
1895 1.127 knakahar PPPOE_UNLOCK(sc);
1896 1.1 martin return;
1897 1.120 knakahar }
1898 1.120 knakahar
1899 1.90 martin if (sc->sc_sppp.pp_phase == SPPP_PHASE_ESTABLISH &&
1900 1.90 martin sc->sc_sppp.pp_auth_failures > 0) {
1901 1.90 martin /*
1902 1.90 martin * Delay trying to reconnect a bit more - the peer
1903 1.102 snj * might have failed to contact its radius server.
1904 1.90 martin */
1905 1.92 martin wtime = PPPOE_RECON_FAST * sc->sc_sppp.pp_auth_failures;
1906 1.92 martin if (wtime > PPPOE_SLOW_RETRY)
1907 1.92 martin wtime = PPPOE_SLOW_RETRY;
1908 1.90 martin } else {
1909 1.92 martin wtime = PPPOE_RECON_IMMEDIATE;
1910 1.90 martin }
1911 1.150 yamaguch callout_schedule(&sc->sc_timeout, wtime);
1912 1.120 knakahar
1913 1.127 knakahar PPPOE_UNLOCK(sc);
1914 1.1 martin }
1915 1.1 martin
1916 1.1 martin static void
1917 1.1 martin pppoe_tlf(struct sppp *sp)
1918 1.1 martin {
1919 1.26 itojun struct pppoe_softc *sc = (void *)sp;
1920 1.120 knakahar
1921 1.127 knakahar PPPOE_LOCK(sc, RW_WRITER);
1922 1.120 knakahar
1923 1.120 knakahar if (sc->sc_state < PPPOE_STATE_SESSION) {
1924 1.154 yamaguch callout_stop(&sc->sc_timeout);
1925 1.154 yamaguch sc->sc_state = PPPOE_STATE_INITIAL;
1926 1.154 yamaguch sc->sc_padi_retried = 0;
1927 1.154 yamaguch sc->sc_padr_retried = 0;
1928 1.154 yamaguch memcpy(&sc->sc_dest, etherbroadcastaddr,
1929 1.154 yamaguch sizeof(sc->sc_dest));
1930 1.127 knakahar PPPOE_UNLOCK(sc);
1931 1.1 martin return;
1932 1.120 knakahar }
1933 1.154 yamaguch
1934 1.1 martin /*
1935 1.1 martin * Do not call pppoe_disconnect here, the upper layer state
1936 1.1 martin * machine gets confused by this. We must return from this
1937 1.1 martin * function and defer disconnecting to the timeout handler.
1938 1.1 martin */
1939 1.1 martin sc->sc_state = PPPOE_STATE_CLOSING;
1940 1.120 knakahar
1941 1.150 yamaguch callout_schedule(&sc->sc_timeout, hz/50);
1942 1.120 knakahar
1943 1.127 knakahar PPPOE_UNLOCK(sc);
1944 1.1 martin }
1945 1.1 martin
1946 1.1 martin static void
1947 1.1 martin pppoe_start(struct ifnet *ifp)
1948 1.1 martin {
1949 1.26 itojun struct pppoe_softc *sc = (void *)ifp;
1950 1.1 martin struct mbuf *m;
1951 1.84 matt uint8_t *p;
1952 1.1 martin size_t len;
1953 1.1 martin
1954 1.1 martin if (sppp_isempty(ifp))
1955 1.1 martin return;
1956 1.1 martin
1957 1.48 wiz /* are we ready to process data yet? */
1958 1.127 knakahar PPPOE_LOCK(sc, RW_READER);
1959 1.1 martin if (sc->sc_state < PPPOE_STATE_SESSION) {
1960 1.1 martin sppp_flush(&sc->sc_sppp.pp_if);
1961 1.127 knakahar PPPOE_UNLOCK(sc);
1962 1.1 martin return;
1963 1.1 martin }
1964 1.1 martin
1965 1.1 martin while ((m = sppp_dequeue(ifp)) != NULL) {
1966 1.1 martin len = m->m_pkthdr.len;
1967 1.1 martin M_PREPEND(m, PPPOE_HEADERLEN, M_DONTWAIT);
1968 1.1 martin if (m == NULL) {
1969 1.148 thorpej if_statinc(ifp, if_oerrors);
1970 1.37 martin continue;
1971 1.1 martin }
1972 1.84 matt p = mtod(m, uint8_t *);
1973 1.1 martin PPPOE_ADD_HEADER(p, 0, sc->sc_session, len);
1974 1.1 martin
1975 1.141 msaitoh bpf_mtap(&sc->sc_sppp.pp_if, m, BPF_D_OUT);
1976 1.1 martin
1977 1.1 martin pppoe_output(sc, m);
1978 1.1 martin }
1979 1.127 knakahar PPPOE_UNLOCK(sc);
1980 1.1 martin }
1981 1.54 martin
1982 1.120 knakahar #ifdef PPPOE_MPSAFE
1983 1.120 knakahar static int
1984 1.120 knakahar pppoe_transmit(struct ifnet *ifp, struct mbuf *m)
1985 1.120 knakahar {
1986 1.120 knakahar struct pppoe_softc *sc = (void *)ifp;
1987 1.120 knakahar uint8_t *p;
1988 1.120 knakahar size_t len;
1989 1.120 knakahar
1990 1.120 knakahar if (m == NULL)
1991 1.120 knakahar return EINVAL;
1992 1.120 knakahar
1993 1.120 knakahar /* are we ready to process data yet? */
1994 1.127 knakahar PPPOE_LOCK(sc, RW_READER);
1995 1.120 knakahar if (sc->sc_state < PPPOE_STATE_SESSION) {
1996 1.127 knakahar PPPOE_UNLOCK(sc);
1997 1.134 maxv m_freem(m);
1998 1.120 knakahar return ENOBUFS;
1999 1.120 knakahar }
2000 1.120 knakahar
2001 1.120 knakahar len = m->m_pkthdr.len;
2002 1.120 knakahar M_PREPEND(m, PPPOE_HEADERLEN, M_DONTWAIT);
2003 1.120 knakahar if (m == NULL) {
2004 1.127 knakahar PPPOE_UNLOCK(sc);
2005 1.148 thorpej if_statinc(ifp, if_oerrors);
2006 1.120 knakahar return ENETDOWN;
2007 1.120 knakahar }
2008 1.120 knakahar p = mtod(m, uint8_t *);
2009 1.120 knakahar PPPOE_ADD_HEADER(p, 0, sc->sc_session, len);
2010 1.120 knakahar
2011 1.141 msaitoh bpf_mtap(&sc->sc_sppp.pp_if, m, BPF_D_OUT);
2012 1.120 knakahar
2013 1.120 knakahar pppoe_output(sc, m);
2014 1.127 knakahar PPPOE_UNLOCK(sc);
2015 1.120 knakahar return 0;
2016 1.120 knakahar }
2017 1.120 knakahar #endif /* PPPOE_MPSAFE */
2018 1.54 martin
2019 1.123 christos static void
2020 1.123 christos pppoe_ifattach_hook(void *arg, unsigned long cmd, void *arg2)
2021 1.54 martin {
2022 1.123 christos struct ifnet *ifp = arg2;
2023 1.54 martin struct pppoe_softc *sc;
2024 1.120 knakahar DECLARE_SPLNET_VARIABLE;
2025 1.54 martin
2026 1.123 christos if (cmd != PFIL_IFNET_DETACH)
2027 1.123 christos return;
2028 1.54 martin
2029 1.120 knakahar ACQUIRE_SPLNET();
2030 1.120 knakahar rw_enter(&pppoe_softc_list_lock, RW_READER);
2031 1.54 martin LIST_FOREACH(sc, &pppoe_softc_list, sc_list) {
2032 1.127 knakahar PPPOE_LOCK(sc, RW_WRITER);
2033 1.120 knakahar if (sc->sc_eth_if != ifp) {
2034 1.127 knakahar PPPOE_UNLOCK(sc);
2035 1.54 martin continue;
2036 1.120 knakahar }
2037 1.54 martin if (sc->sc_sppp.pp_if.if_flags & IFF_UP) {
2038 1.54 martin sc->sc_sppp.pp_if.if_flags &= ~(IFF_UP|IFF_RUNNING);
2039 1.157 yamaguch pppoe_printf(sc,
2040 1.157 yamaguch "ethernet interface detached, going down\n");
2041 1.54 martin }
2042 1.54 martin sc->sc_eth_if = NULL;
2043 1.57 martin pppoe_clear_softc(sc, "ethernet interface detached");
2044 1.127 knakahar PPPOE_UNLOCK(sc);
2045 1.54 martin }
2046 1.120 knakahar rw_exit(&pppoe_softc_list_lock);
2047 1.120 knakahar RELEASE_SPLNET();
2048 1.54 martin }
2049 1.57 martin
2050 1.57 martin static void
2051 1.57 martin pppoe_clear_softc(struct pppoe_softc *sc, const char *message)
2052 1.57 martin {
2053 1.127 knakahar KASSERT(PPPOE_WLOCKED(sc));
2054 1.120 knakahar
2055 1.58 martin /* stop timer */
2056 1.57 martin callout_stop(&sc->sc_timeout);
2057 1.157 yamaguch pppoe_printf(sc, "session 0x%x terminated, %s\n",
2058 1.157 yamaguch sc->sc_session, message);
2059 1.57 martin
2060 1.57 martin /* fix our state */
2061 1.57 martin sc->sc_state = PPPOE_STATE_INITIAL;
2062 1.120 knakahar
2063 1.127 knakahar PPPOE_UNLOCK(sc);
2064 1.57 martin
2065 1.57 martin /* signal upper layer */
2066 1.57 martin sc->sc_sppp.pp_down(&sc->sc_sppp);
2067 1.120 knakahar
2068 1.127 knakahar PPPOE_LOCK(sc, RW_WRITER);
2069 1.57 martin
2070 1.57 martin /* clean up softc */
2071 1.57 martin memcpy(&sc->sc_dest, etherbroadcastaddr, sizeof(sc->sc_dest));
2072 1.57 martin if (sc->sc_ac_cookie) {
2073 1.57 martin free(sc->sc_ac_cookie, M_DEVBUF);
2074 1.57 martin sc->sc_ac_cookie = NULL;
2075 1.57 martin }
2076 1.94 christos if (sc->sc_relay_sid) {
2077 1.94 christos free(sc->sc_relay_sid, M_DEVBUF);
2078 1.94 christos sc->sc_relay_sid = NULL;
2079 1.94 christos }
2080 1.57 martin sc->sc_ac_cookie_len = 0;
2081 1.57 martin sc->sc_session = 0;
2082 1.57 martin }
2083 1.105 ozaki
2084 1.105 ozaki static void
2085 1.105 ozaki pppoe_enqueue(struct ifqueue *inq, struct mbuf *m)
2086 1.105 ozaki {
2087 1.105 ozaki if (m->m_flags & M_PROMISC) {
2088 1.134 maxv m_freem(m);
2089 1.105 ozaki return;
2090 1.105 ozaki }
2091 1.105 ozaki
2092 1.105 ozaki #ifndef PPPOE_SERVER
2093 1.105 ozaki if (m->m_flags & (M_MCAST | M_BCAST)) {
2094 1.134 maxv m_freem(m);
2095 1.105 ozaki return;
2096 1.105 ozaki }
2097 1.105 ozaki #endif
2098 1.105 ozaki
2099 1.118 ozaki IFQ_LOCK(inq);
2100 1.105 ozaki if (IF_QFULL(inq)) {
2101 1.105 ozaki IF_DROP(inq);
2102 1.118 ozaki IFQ_UNLOCK(inq);
2103 1.105 ozaki m_freem(m);
2104 1.105 ozaki } else {
2105 1.105 ozaki IF_ENQUEUE(inq, m);
2106 1.118 ozaki IFQ_UNLOCK(inq);
2107 1.105 ozaki softint_schedule(pppoe_softintr);
2108 1.105 ozaki }
2109 1.105 ozaki return;
2110 1.105 ozaki }
2111 1.105 ozaki
2112 1.105 ozaki void
2113 1.105 ozaki pppoe_input(struct ifnet *ifp, struct mbuf *m)
2114 1.105 ozaki {
2115 1.105 ozaki pppoe_enqueue(&ppoeinq, m);
2116 1.105 ozaki return;
2117 1.105 ozaki }
2118 1.105 ozaki
2119 1.105 ozaki void
2120 1.105 ozaki pppoedisc_input(struct ifnet *ifp, struct mbuf *m)
2121 1.105 ozaki {
2122 1.105 ozaki pppoe_enqueue(&ppoediscinq, m);
2123 1.105 ozaki return;
2124 1.105 ozaki }
2125 1.112 pgoyette
2126 1.117 christos static void
2127 1.117 christos sysctl_net_pppoe_setup(struct sysctllog **clog)
2128 1.113 pgoyette {
2129 1.113 pgoyette const struct sysctlnode *node = NULL;
2130 1.113 pgoyette
2131 1.113 pgoyette sysctl_createv(clog, 0, NULL, &node,
2132 1.113 pgoyette CTLFLAG_PERMANENT,
2133 1.113 pgoyette CTLTYPE_NODE, "pppoe",
2134 1.113 pgoyette SYSCTL_DESCR("PPPOE protocol"),
2135 1.113 pgoyette NULL, 0, NULL, 0,
2136 1.113 pgoyette CTL_NET, CTL_CREATE, CTL_EOL);
2137 1.113 pgoyette
2138 1.113 pgoyette if (node == NULL)
2139 1.113 pgoyette return;
2140 1.113 pgoyette
2141 1.113 pgoyette sysctl_createv(clog, 0, &node, NULL,
2142 1.135 knakahar CTLFLAG_PERMANENT | CTLFLAG_READWRITE,
2143 1.113 pgoyette CTLTYPE_BOOL, "term_unknown",
2144 1.113 pgoyette SYSCTL_DESCR("Terminate unknown sessions"),
2145 1.113 pgoyette NULL, 0, &pppoe_term_unknown, sizeof(pppoe_term_unknown),
2146 1.113 pgoyette CTL_CREATE, CTL_EOL);
2147 1.113 pgoyette }
2148 1.114 christos
2149 1.114 christos /*
2150 1.114 christos * Module infrastructure
2151 1.114 christos */
2152 1.114 christos #include "if_module.h"
2153 1.114 christos
2154 1.114 christos IF_MODULE(MODULE_CLASS_DRIVER, pppoe, "sppp_subr")
2155