if_pppoe.c revision 1.171 1 1.171 yamaguch /* $NetBSD: if_pppoe.c,v 1.171 2021/05/13 01:01:10 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.171 yamaguch __KERNEL_RCSID(0, "$NetBSD: if_pppoe.c,v 1.171 2021/05/13 01:01:10 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.171 yamaguch 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