xref: /NextBSD/sys/net/if_atmsubr.c (revision b137080f19736ee33fede2e88bb54438604cf86b)
1 /*      $NetBSD: if_atmsubr.c,v 1.10 1997/03/11 23:19:51 chuck Exp $       */
2 
3 /*-
4  *
5  * Copyright (c) 1996 Charles D. Cranor and Washington University.
6  * All rights reserved.
7  *
8  * Redistribution and use in source and binary forms, with or without
9  * modification, are permitted provided that the following conditions
10  * are met:
11  * 1. Redistributions of source code must retain the above copyright
12  *    notice, this list of conditions and the following disclaimer.
13  * 2. Redistributions in binary form must reproduce the above copyright
14  *    notice, this list of conditions and the following disclaimer in the
15  *    documentation and/or other materials provided with the distribution.
16  * 3. All advertising materials mentioning features or use of this software
17  *    must display the following acknowledgement:
18  *      This product includes software developed by Charles D. Cranor and
19  *	Washington University.
20  * 4. The name of the author may not be used to endorse or promote products
21  *    derived from this software without specific prior written permission.
22  *
23  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
24  * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
25  * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
26  * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
27  * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
28  * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
29  * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
30  * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
31  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
32  * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
33  *
34  * if_atmsubr.c
35  */
36 
37 #include <sys/cdefs.h>
38 __FBSDID("$FreeBSD$");
39 
40 #include "opt_inet.h"
41 #include "opt_inet6.h"
42 #include "opt_natm.h"
43 
44 #include <sys/param.h>
45 #include <sys/systm.h>
46 #include <sys/kernel.h>
47 #include <sys/module.h>
48 #include <sys/mbuf.h>
49 #include <sys/socket.h>
50 #include <sys/sockio.h>
51 #include <sys/errno.h>
52 #include <sys/sysctl.h>
53 #include <sys/malloc.h>
54 
55 #include <net/if.h>
56 #include <net/if_var.h>
57 #include <net/netisr.h>
58 #include <net/route.h>
59 #include <net/if_dl.h>
60 #include <net/if_types.h>
61 #include <net/if_atm.h>
62 
63 #include <netinet/in.h>
64 #include <netinet/if_atm.h>
65 #include <netinet/if_ether.h> /* XXX: for ETHERTYPE_* */
66 #if defined(INET) || defined(INET6)
67 #include <netinet/in_var.h>
68 #endif
69 #ifdef NATM
70 #include <netnatm/natm.h>
71 #endif
72 
73 #include <security/mac/mac_framework.h>
74 
75 /*
76  * Netgraph interface functions.
77  * These need not be protected by a lock, because ng_atm nodes are persitent.
78  * The ng_atm module can be unloaded only if all ATM interfaces have been
79  * unloaded, so nobody should be in the code paths accessing these function
80  * pointers.
81  */
82 void	(*ng_atm_attach_p)(struct ifnet *);
83 void	(*ng_atm_detach_p)(struct ifnet *);
84 int	(*ng_atm_output_p)(struct ifnet *, struct mbuf **);
85 void	(*ng_atm_input_p)(struct ifnet *, struct mbuf **,
86 	    struct atm_pseudohdr *, void *);
87 void	(*ng_atm_input_orphan_p)(struct ifnet *, struct mbuf *,
88 	    struct atm_pseudohdr *, void *);
89 void	(*ng_atm_event_p)(struct ifnet *, uint32_t, void *);
90 
91 /*
92  * Harp pseudo interface hooks
93  */
94 void	(*atm_harp_input_p)(struct ifnet *ifp, struct mbuf **m,
95 	    struct atm_pseudohdr *ah, void *rxhand);
96 void	(*atm_harp_attach_p)(struct ifnet *);
97 void	(*atm_harp_detach_p)(struct ifnet *);
98 void	(*atm_harp_event_p)(struct ifnet *, uint32_t, void *);
99 
100 SYSCTL_NODE(_hw, OID_AUTO, atm, CTLFLAG_RW, 0, "ATM hardware");
101 
102 static MALLOC_DEFINE(M_IFATM, "ifatm", "atm interface internals");
103 
104 #ifndef ETHERTYPE_IPV6
105 #define	ETHERTYPE_IPV6	0x86dd
106 #endif
107 
108 #define	senderr(e) do { error = (e); goto bad; } while (0)
109 
110 /*
111  * atm_output: ATM output routine
112  *   inputs:
113  *     "ifp" = ATM interface to output to
114  *     "m0" = the packet to output
115  *     "dst" = the sockaddr to send to (either IP addr, or raw VPI/VCI)
116  *     "ro" = the route to use
117  *   returns: error code   [0 == ok]
118  *
119  *   note: special semantic: if (dst == NULL) then we assume "m" already
120  *		has an atm_pseudohdr on it and just send it directly.
121  *		[for native mode ATM output]   if dst is null, then
122  *		ro->ro_rt must also be NULL.
123  */
124 int
atm_output(struct ifnet * ifp,struct mbuf * m0,const struct sockaddr * dst,struct route * ro)125 atm_output(struct ifnet *ifp, struct mbuf *m0, const struct sockaddr *dst,
126     struct route *ro)
127 {
128 	u_int16_t etype = 0;			/* if using LLC/SNAP */
129 	int error = 0, sz;
130 	struct atm_pseudohdr atmdst, *ad;
131 	struct mbuf *m = m0;
132 	struct atmllc *atmllc;
133 	const struct atmllc *llc_hdr = NULL;
134 	u_int32_t atm_flags;
135 
136 #ifdef MAC
137 	error = mac_ifnet_check_transmit(ifp, m);
138 	if (error)
139 		senderr(error);
140 #endif
141 
142 	if (!((ifp->if_flags & IFF_UP) &&
143 	    (ifp->if_drv_flags & IFF_DRV_RUNNING)))
144 		senderr(ENETDOWN);
145 
146 	/*
147 	 * check for non-native ATM traffic   (dst != NULL)
148 	 */
149 	if (dst) {
150 		switch (dst->sa_family) {
151 
152 #if defined(INET) || defined(INET6)
153 		case AF_INET:
154 		case AF_INET6:
155 		{
156 			if (dst->sa_family == AF_INET6)
157 			        etype = ETHERTYPE_IPV6;
158 			else
159 			        etype = ETHERTYPE_IP;
160 			if (!atmresolve(ro->ro_rt, m, dst, &atmdst)) {
161 				m = NULL;
162 				/* XXX: atmresolve already free'd it */
163 				senderr(EHOSTUNREACH);
164 				/* XXX: put ATMARP stuff here */
165 				/* XXX: watch who frees m on failure */
166 			}
167 		}
168 			break;
169 #endif /* INET || INET6 */
170 
171 		case AF_UNSPEC:
172 			/*
173 			 * XXX: bpfwrite. assuming dst contains 12 bytes
174 			 * (atm pseudo header (4) + LLC/SNAP (8))
175 			 */
176 			bcopy(dst->sa_data, &atmdst, sizeof(atmdst));
177 			llc_hdr = (const struct atmllc *)(dst->sa_data +
178 			    sizeof(atmdst));
179 			break;
180 
181 		default:
182 			printf("%s: can't handle af%d\n", ifp->if_xname,
183 			    dst->sa_family);
184 			senderr(EAFNOSUPPORT);
185 		}
186 
187 		/*
188 		 * must add atm_pseudohdr to data
189 		 */
190 		sz = sizeof(atmdst);
191 		atm_flags = ATM_PH_FLAGS(&atmdst);
192 		if (atm_flags & ATM_PH_LLCSNAP)
193 			sz += 8;	/* sizeof snap == 8 */
194 		M_PREPEND(m, sz, M_NOWAIT);
195 		if (m == 0)
196 			senderr(ENOBUFS);
197 		ad = mtod(m, struct atm_pseudohdr *);
198 		*ad = atmdst;
199 		if (atm_flags & ATM_PH_LLCSNAP) {
200 			atmllc = (struct atmllc *)(ad + 1);
201 			if (llc_hdr == NULL) {
202 			        bcopy(ATMLLC_HDR, atmllc->llchdr,
203 				      sizeof(atmllc->llchdr));
204 				/* note: in host order */
205 				ATM_LLC_SETTYPE(atmllc, etype);
206 			}
207 			else
208 			        bcopy(llc_hdr, atmllc, sizeof(struct atmllc));
209 		}
210 	}
211 
212 	if (ng_atm_output_p != NULL) {
213 		if ((error = (*ng_atm_output_p)(ifp, &m)) != 0) {
214 			if (m != NULL)
215 				m_freem(m);
216 			return (error);
217 		}
218 		if (m == NULL)
219 			return (0);
220 	}
221 
222 	/*
223 	 * Queue message on interface, and start output if interface
224 	 * not yet active.
225 	 */
226 	if (!IF_HANDOFF_ADJ(&ifp->if_snd, m, ifp,
227 	    -(int)sizeof(struct atm_pseudohdr)))
228 		return (ENOBUFS);
229 	return (error);
230 
231 bad:
232 	if (m)
233 		m_freem(m);
234 	return (error);
235 }
236 
237 /*
238  * Process a received ATM packet;
239  * the packet is in the mbuf chain m.
240  */
241 void
atm_input(struct ifnet * ifp,struct atm_pseudohdr * ah,struct mbuf * m,void * rxhand)242 atm_input(struct ifnet *ifp, struct atm_pseudohdr *ah, struct mbuf *m,
243     void *rxhand)
244 {
245 	int isr;
246 	u_int16_t etype = ETHERTYPE_IP;		/* default */
247 
248 	if ((ifp->if_flags & IFF_UP) == 0) {
249 		m_freem(m);
250 		return;
251 	}
252 #ifdef MAC
253 	mac_ifnet_create_mbuf(ifp, m);
254 #endif
255 	if_inc_counter(ifp, IFCOUNTER_IBYTES, m->m_pkthdr.len);
256 
257 	if (ng_atm_input_p != NULL) {
258 		(*ng_atm_input_p)(ifp, &m, ah, rxhand);
259 		if (m == NULL)
260 			return;
261 	}
262 
263 	/* not eaten by ng_atm. Maybe it's a pseudo-harp PDU? */
264 	if (atm_harp_input_p != NULL) {
265 		(*atm_harp_input_p)(ifp, &m, ah, rxhand);
266 		if (m == NULL)
267 			return;
268 	}
269 
270 	if (rxhand) {
271 #ifdef NATM
272 		struct natmpcb *npcb;
273 
274 		/*
275 		 * XXXRW: this use of 'rxhand' is not a very good idea, and
276 		 * was subject to races even before SMPng due to the release
277 		 * of spl here.
278 		 */
279 		NATM_LOCK();
280 		npcb = rxhand;
281 		npcb->npcb_inq++;	/* count # in queue */
282 		isr = NETISR_NATM;
283 		m->m_pkthdr.rcvif = rxhand; /* XXX: overload */
284 		NATM_UNLOCK();
285 #else
286 		printf("atm_input: NATM detected but not "
287 		    "configured in kernel\n");
288 		goto dropit;
289 #endif
290 	} else {
291 		/*
292 		 * handle LLC/SNAP header, if present
293 		 */
294 		if (ATM_PH_FLAGS(ah) & ATM_PH_LLCSNAP) {
295 			struct atmllc *alc;
296 
297 			if (m->m_len < sizeof(*alc) &&
298 			    (m = m_pullup(m, sizeof(*alc))) == 0)
299 				return; /* failed */
300 			alc = mtod(m, struct atmllc *);
301 			if (bcmp(alc, ATMLLC_HDR, 6)) {
302 				printf("%s: recv'd invalid LLC/SNAP frame "
303 				    "[vp=%d,vc=%d]\n", ifp->if_xname,
304 				    ATM_PH_VPI(ah), ATM_PH_VCI(ah));
305 				m_freem(m);
306 				return;
307 			}
308 			etype = ATM_LLC_TYPE(alc);
309 			m_adj(m, sizeof(*alc));
310 		}
311 
312 		switch (etype) {
313 
314 #ifdef INET
315 		case ETHERTYPE_IP:
316 			isr = NETISR_IP;
317 			break;
318 #endif
319 
320 #ifdef INET6
321 		case ETHERTYPE_IPV6:
322 			isr = NETISR_IPV6;
323 			break;
324 #endif
325 		default:
326 #ifndef NATM
327   dropit:
328 #endif
329 			if (ng_atm_input_orphan_p != NULL)
330 				(*ng_atm_input_orphan_p)(ifp, m, ah, rxhand);
331 			else
332 				m_freem(m);
333 			return;
334 		}
335 	}
336 	M_SETFIB(m, ifp->if_fib);
337 	netisr_dispatch(isr, m);
338 }
339 
340 /*
341  * Perform common duties while attaching to interface list.
342  */
343 void
atm_ifattach(struct ifnet * ifp)344 atm_ifattach(struct ifnet *ifp)
345 {
346 	struct ifaddr *ifa;
347 	struct sockaddr_dl *sdl;
348 	struct ifatm *ifatm = ifp->if_l2com;
349 
350 	ifp->if_addrlen = 0;
351 	ifp->if_hdrlen = 0;
352 	if_attach(ifp);
353 	ifp->if_mtu = ATMMTU;
354 	ifp->if_output = atm_output;
355 #if 0
356 	ifp->if_input = atm_input;
357 #endif
358 	ifp->if_snd.ifq_maxlen = 50;	/* dummy */
359 
360 	TAILQ_FOREACH(ifa, &ifp->if_addrhead, ifa_link)
361 		if (ifa->ifa_addr->sa_family == AF_LINK) {
362 			sdl = (struct sockaddr_dl *)ifa->ifa_addr;
363 			sdl->sdl_type = IFT_ATM;
364 			sdl->sdl_alen = ifp->if_addrlen;
365 #ifdef notyet /* if using ATMARP, store hardware address using the next line */
366 			bcopy(ifp->hw_addr, LLADDR(sdl), ifp->if_addrlen);
367 #endif
368 			break;
369 		}
370 
371 	ifp->if_linkmib = &ifatm->mib;
372 	ifp->if_linkmiblen = sizeof(ifatm->mib);
373 
374 	if(ng_atm_attach_p)
375 		(*ng_atm_attach_p)(ifp);
376 	if (atm_harp_attach_p)
377 		(*atm_harp_attach_p)(ifp);
378 }
379 
380 /*
381  * Common stuff for detaching an ATM interface
382  */
383 void
atm_ifdetach(struct ifnet * ifp)384 atm_ifdetach(struct ifnet *ifp)
385 {
386 	if (atm_harp_detach_p)
387 		(*atm_harp_detach_p)(ifp);
388 	if(ng_atm_detach_p)
389 		(*ng_atm_detach_p)(ifp);
390 	if_detach(ifp);
391 }
392 
393 /*
394  * Support routine for the SIOCATMGVCCS ioctl().
395  *
396  * This routine assumes, that the private VCC structures used by the driver
397  * begin with a struct atmio_vcc.
398  *
399  * Return a table of VCCs in a freshly allocated memory area.
400  * Here we have a problem: we first count, how many vccs we need
401  * to return. The we allocate the memory and finally fill it in.
402  * Because we cannot lock while calling malloc, the number of active
403  * vccs may change while we're in malloc. So we allocate a couple of
404  * vccs more and if space anyway is not enough re-iterate.
405  *
406  * We could use an sx lock for the vcc tables.
407  */
408 struct atmio_vcctable *
atm_getvccs(struct atmio_vcc ** table,u_int size,u_int start,struct mtx * lock,int waitok)409 atm_getvccs(struct atmio_vcc **table, u_int size, u_int start,
410     struct mtx *lock, int waitok)
411 {
412 	u_int cid, alloc;
413 	size_t len;
414 	struct atmio_vcctable *vccs;
415 	struct atmio_vcc *v;
416 
417 	alloc = start + 10;
418 	vccs = NULL;
419 
420 	for (;;) {
421 		len = sizeof(*vccs) + alloc * sizeof(vccs->vccs[0]);
422 		vccs = reallocf(vccs, len, M_TEMP,
423 		    waitok ? M_WAITOK : M_NOWAIT);
424 		if (vccs == NULL)
425 			return (NULL);
426 		bzero(vccs, len);
427 
428 		vccs->count = 0;
429 		v = vccs->vccs;
430 
431 		mtx_lock(lock);
432 		for (cid = 0; cid < size; cid++)
433 			if (table[cid] != NULL) {
434 				if (++vccs->count == alloc)
435 					/* too many - try again */
436 					break;
437 				*v++ = *table[cid];
438 			}
439 		mtx_unlock(lock);
440 
441 		if (cid == size)
442 			break;
443 
444 		alloc *= 2;
445 	}
446 	return (vccs);
447 }
448 
449 /*
450  * Driver or channel state has changed. Inform whoever is interested
451  * in these events.
452  */
453 void
atm_event(struct ifnet * ifp,u_int event,void * arg)454 atm_event(struct ifnet *ifp, u_int event, void *arg)
455 {
456 	if (ng_atm_event_p != NULL)
457 		(*ng_atm_event_p)(ifp, event, arg);
458 	if (atm_harp_event_p != NULL)
459 		(*atm_harp_event_p)(ifp, event, arg);
460 }
461 
462 static void *
atm_alloc(u_char type,struct ifnet * ifp)463 atm_alloc(u_char type, struct ifnet *ifp)
464 {
465 	struct ifatm	*ifatm;
466 
467 	ifatm = malloc(sizeof(struct ifatm), M_IFATM, M_WAITOK | M_ZERO);
468 	ifatm->ifp = ifp;
469 
470 	return (ifatm);
471 }
472 
473 static void
atm_free(void * com,u_char type)474 atm_free(void *com, u_char type)
475 {
476 
477 	free(com, M_IFATM);
478 }
479 
480 static int
atm_modevent(module_t mod,int type,void * data)481 atm_modevent(module_t mod, int type, void *data)
482 {
483 	switch (type) {
484 	case MOD_LOAD:
485 		if_register_com_alloc(IFT_ATM, atm_alloc, atm_free);
486 		break;
487 	case MOD_UNLOAD:
488 		if_deregister_com_alloc(IFT_ATM);
489 		break;
490 	default:
491 		return (EOPNOTSUPP);
492 	}
493 
494 	return (0);
495 }
496 
497 static moduledata_t atm_mod = {
498         "atm",
499         atm_modevent,
500         0
501 };
502 
503 DECLARE_MODULE(atm, atm_mod, SI_SUB_INIT_IF, SI_ORDER_ANY);
504 MODULE_VERSION(atm, 1);
505