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