xref: /freebsd/sys/netgraph/ng_gif.c (revision 953a8b2e)
1 /*
2  * ng_gif.c
3  */
4 
5 /*-
6  * Copyright 2001 The Aerospace Corporation.  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  *
12  * 1. Redistributions of source code must retain the above copyright
13  *    notice, this list of conditions, and the following disclaimer.
14  * 2. Redistributions in binary form must reproduce the above copyright
15  *    notice, this list of conditions, and the following disclaimer in the
16  *    documentation and/or other materials provided with the distribution.
17  * 3. The name of The Aerospace Corporation may not be used to endorse or
18  *    promote products derived from this software.
19  *
20  * THIS SOFTWARE IS PROVIDED BY THE AEROSPACE CORPORATION ``AS IS'' AND
21  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
22  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
23  * ARE DISCLAIMED.  IN NO EVENT SHALL THE AEROSPACE CORPORATION BE LIABLE
24  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
25  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
26  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
27  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
28  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
29  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
30  * SUCH DAMAGE.
31  *
32  *
33  * Copyright (c) 1996-2000 Whistle Communications, Inc.
34  * All rights reserved.
35  *
36  * Subject to the following obligations and disclaimer of warranty, use and
37  * redistribution of this software, in source or object code forms, with or
38  * without modifications are expressly permitted by Whistle Communications;
39  * provided, however, that:
40  * 1. Any and all reproductions of the source or object code must include the
41  *    copyright notice above and the following disclaimer of warranties; and
42  * 2. No rights are granted, in any manner or form, to use Whistle
43  *    Communications, Inc. trademarks, including the mark "WHISTLE
44  *    COMMUNICATIONS" on advertising, endorsements, or otherwise except as
45  *    such appears in the above copyright notice or in the software.
46  *
47  * THIS SOFTWARE IS BEING PROVIDED BY WHISTLE COMMUNICATIONS "AS IS", AND
48  * TO THE MAXIMUM EXTENT PERMITTED BY LAW, WHISTLE COMMUNICATIONS MAKES NO
49  * REPRESENTATIONS OR WARRANTIES, EXPRESS OR IMPLIED, REGARDING THIS SOFTWARE,
50  * INCLUDING WITHOUT LIMITATION, ANY AND ALL IMPLIED WARRANTIES OF
51  * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE, OR NON-INFRINGEMENT.
52  * WHISTLE COMMUNICATIONS DOES NOT WARRANT, GUARANTEE, OR MAKE ANY
53  * REPRESENTATIONS REGARDING THE USE OF, OR THE RESULTS OF THE USE OF THIS
54  * SOFTWARE IN TERMS OF ITS CORRECTNESS, ACCURACY, RELIABILITY OR OTHERWISE.
55  * IN NO EVENT SHALL WHISTLE COMMUNICATIONS BE LIABLE FOR ANY DAMAGES
56  * RESULTING FROM OR ARISING OUT OF ANY USE OF THIS SOFTWARE, INCLUDING
57  * WITHOUT LIMITATION, ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY,
58  * PUNITIVE, OR CONSEQUENTIAL DAMAGES, PROCUREMENT OF SUBSTITUTE GOODS OR
59  * SERVICES, LOSS OF USE, DATA OR PROFITS, HOWEVER CAUSED AND UNDER ANY
60  * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
61  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
62  * THIS SOFTWARE, EVEN IF WHISTLE COMMUNICATIONS IS ADVISED OF THE POSSIBILITY
63  * OF SUCH DAMAGE.
64  *
65  * $FreeBSD$
66  */
67 
68 /*
69  * ng_gif(4) netgraph node type
70  */
71 
72 #include <sys/param.h>
73 #include <sys/systm.h>
74 #include <sys/kernel.h>
75 #include <sys/malloc.h>
76 #include <sys/mbuf.h>
77 #include <sys/errno.h>
78 #include <sys/syslog.h>
79 #include <sys/socket.h>
80 
81 #include <net/if.h>
82 #include <net/route.h>
83 #include <net/if_types.h>
84 #include <net/if_var.h>
85 #include <net/if_gif.h>
86 
87 #include <netgraph/ng_message.h>
88 #include <netgraph/netgraph.h>
89 #include <netgraph/ng_parse.h>
90 #include <netgraph/ng_gif.h>
91 
92 #define IFP2NG(ifp)  ((struct ng_node *)((struct gif_softc *)(ifp))->gif_netgraph)
93 #define IFP2NG_SET(ifp, val)  (((struct gif_softc *)(ifp))->gif_netgraph = (val))
94 
95 /* Per-node private data */
96 struct private {
97 	struct ifnet	*ifp;		/* associated interface */
98 	hook_p		lower;		/* lower OR orphan hook connection */
99 	u_char		lowerOrphan;	/* whether lower is lower or orphan */
100 };
101 typedef struct private *priv_p;
102 
103 /* Functional hooks called from if_gif.c */
104 static void	ng_gif_input(struct ifnet *ifp, struct mbuf **mp, int af);
105 static void	ng_gif_input_orphan(struct ifnet *ifp, struct mbuf *m, int af);
106 static void	ng_gif_attach(struct ifnet *ifp);
107 static void	ng_gif_detach(struct ifnet *ifp);
108 
109 /* Other functions */
110 static void	ng_gif_input2(node_p node, struct mbuf **mp, int af);
111 static int	ng_gif_glue_af(struct mbuf **mp, int af);
112 static int	ng_gif_rcv_lower(node_p node, struct mbuf *m);
113 
114 /* Netgraph node methods */
115 static ng_constructor_t	ng_gif_constructor;
116 static ng_rcvmsg_t	ng_gif_rcvmsg;
117 static ng_shutdown_t	ng_gif_shutdown;
118 static ng_newhook_t	ng_gif_newhook;
119 static ng_connect_t	ng_gif_connect;
120 static ng_rcvdata_t	ng_gif_rcvdata;
121 static ng_disconnect_t	ng_gif_disconnect;
122 static int		ng_gif_mod_event(module_t mod, int event, void *data);
123 
124 /* List of commands and how to convert arguments to/from ASCII */
125 static const struct ng_cmdlist ng_gif_cmdlist[] = {
126 	{
127 	  NGM_GIF_COOKIE,
128 	  NGM_GIF_GET_IFNAME,
129 	  "getifname",
130 	  NULL,
131 	  &ng_parse_string_type
132 	},
133 	{
134 	  NGM_GIF_COOKIE,
135 	  NGM_GIF_GET_IFINDEX,
136 	  "getifindex",
137 	  NULL,
138 	  &ng_parse_int32_type
139 	},
140 	{ 0 }
141 };
142 
143 static struct ng_type ng_gif_typestruct = {
144 	.version =	NG_ABI_VERSION,
145 	.name =		NG_GIF_NODE_TYPE,
146 	.mod_event =	ng_gif_mod_event,
147 	.constructor =	ng_gif_constructor,
148 	.rcvmsg =	ng_gif_rcvmsg,
149 	.shutdown =	ng_gif_shutdown,
150 	.newhook =	ng_gif_newhook,
151 	.connect =	ng_gif_connect,
152 	.rcvdata =	ng_gif_rcvdata,
153 	.disconnect =	ng_gif_disconnect,
154 	.cmdlist =	ng_gif_cmdlist,
155 };
156 MODULE_DEPEND(ng_gif, if_gif, 1,1,1);
157 NETGRAPH_INIT(gif, &ng_gif_typestruct);
158 
159 /******************************************************************
160 		       GIF FUNCTION HOOKS
161 ******************************************************************/
162 
163 /*
164  * Handle a packet that has come in on an interface. We get to
165  * look at it here before any upper layer protocols do.
166  *
167  * NOTE: this function will get called at splimp()
168  */
169 static void
170 ng_gif_input(struct ifnet *ifp, struct mbuf **mp, int af)
171 {
172 	const node_p node = IFP2NG(ifp);
173 	const priv_p priv = NG_NODE_PRIVATE(node);
174 
175 	/* If "lower" hook not connected, let packet continue */
176 	if (priv->lower == NULL || priv->lowerOrphan)
177 		return;
178 	ng_gif_input2(node, mp, af);
179 }
180 
181 /*
182  * Handle a packet that has come in on an interface, and which
183  * does not match any of our known protocols (an ``orphan'').
184  *
185  * NOTE: this function will get called at splimp()
186  */
187 static void
188 ng_gif_input_orphan(struct ifnet *ifp, struct mbuf *m, int af)
189 {
190 	const node_p node = IFP2NG(ifp);
191 	const priv_p priv = NG_NODE_PRIVATE(node);
192 
193 	/* If "orphan" hook not connected, let packet continue */
194 	if (priv->lower == NULL || !priv->lowerOrphan) {
195 		m_freem(m);
196 		return;
197 	}
198 	ng_gif_input2(node, &m, af);
199 	if (m != NULL)
200 		m_freem(m);
201 }
202 
203 /*
204  * Handle a packet that has come in on a gif interface.
205  * Attach the address family to the mbuf for later use.
206  *
207  * NOTE: this function will get called at splimp()
208  */
209 static void
210 ng_gif_input2(node_p node, struct mbuf **mp, int af)
211 {
212 	const priv_p priv = NG_NODE_PRIVATE(node);
213 	int error;
214 
215 	/* Glue address family on */
216 	if ((error = ng_gif_glue_af(mp, af)) != 0)
217 		return;
218 
219 	/* Send out lower/orphan hook */
220 	NG_SEND_DATA_ONLY(error, priv->lower, *mp);
221 	*mp = NULL;
222 }
223 
224 /*
225  * A new gif interface has been attached.
226  * Create a new node for it, etc.
227  */
228 static void
229 ng_gif_attach(struct ifnet *ifp)
230 {
231 	priv_p priv;
232 	node_p node;
233 
234 	/* Create node */
235 	KASSERT(!IFP2NG(ifp), ("%s: node already exists?", __func__));
236 	if (ng_make_node_common(&ng_gif_typestruct, &node) != 0) {
237 		log(LOG_ERR, "%s: can't %s for %s\n",
238 		    __func__, "create node", ifp->if_xname);
239 		return;
240 	}
241 
242 	/* Allocate private data */
243 	MALLOC(priv, priv_p, sizeof(*priv), M_NETGRAPH, M_NOWAIT | M_ZERO);
244 	if (priv == NULL) {
245 		log(LOG_ERR, "%s: can't %s for %s\n",
246 		    __func__, "allocate memory", ifp->if_xname);
247 		NG_NODE_UNREF(node);
248 		return;
249 	}
250 	NG_NODE_SET_PRIVATE(node, priv);
251 	priv->ifp = ifp;
252 	IFP2NG_SET(ifp, node);
253 
254 	/* Try to give the node the same name as the interface */
255 	if (ng_name_node(node, ifp->if_xname) != 0) {
256 		log(LOG_WARNING, "%s: can't name node %s\n",
257 		    __func__, ifp->if_xname);
258 	}
259 }
260 
261 /*
262  * An interface is being detached.
263  * REALLY Destroy its node.
264  */
265 static void
266 ng_gif_detach(struct ifnet *ifp)
267 {
268 	const node_p node = IFP2NG(ifp);
269 	priv_p priv;
270 
271 	if (node == NULL)		/* no node (why not?), ignore */
272 		return;
273 	priv = NG_NODE_PRIVATE(node);
274 	NG_NODE_REALLY_DIE(node);	/* Force real removal of node */
275 	/*
276 	 * We can't assume the ifnet is still around when we run shutdown
277 	 * So zap it now. XXX We HOPE that anything running at this time
278 	 * handles it (as it should in the non netgraph case).
279 	 */
280 	IFP2NG_SET(ifp, NULL);
281 	priv->ifp = NULL;	/* XXX race if interrupted an output packet */
282 	ng_rmnode_self(node);		/* remove all netgraph parts */
283 }
284 
285 /*
286  * Optimization for gluing the address family onto
287  * the front of an incoming packet.
288  */
289 static int
290 ng_gif_glue_af(struct mbuf **mp, int af)
291 {
292 	struct mbuf *m = *mp;
293 	int error = 0;
294 	sa_family_t tmp_af;
295 
296 	tmp_af = (sa_family_t) af;
297 
298 	/*
299 	 * XXX: should try to bring back some of the optimizations from
300 	 * ng_ether.c
301 	 */
302 
303 	/*
304 	 * Doing anything more is likely to get more
305 	 * expensive than it's worth..
306 	 * it's probable that everything else is in one
307 	 * big lump. The next node will do an m_pullup()
308 	 * for exactly the amount of data it needs and
309 	 * hopefully everything after that will not
310 	 * need one. So let's just use M_PREPEND.
311 	 */
312 	M_PREPEND(m, sizeof (tmp_af), M_DONTWAIT);
313 	if (m == NULL) {
314 		error = ENOBUFS;
315 		goto done;
316 	}
317 
318 #if 0
319 copy:
320 #endif
321 	/* Copy header and return (possibly new) mbuf */
322 	*mtod(m, sa_family_t *) = tmp_af;
323 #if 0
324 	bcopy((caddr_t)&tmp_af, mtod(m, sa_family_t *), sizeof(tmp_af));
325 #endif
326 done:
327 	*mp = m;
328 	return error;
329 }
330 
331 /******************************************************************
332 		    NETGRAPH NODE METHODS
333 ******************************************************************/
334 
335 /*
336  * It is not possible or allowable to create a node of this type.
337  * Nodes get created when the interface is attached (or, when
338  * this node type's KLD is loaded).
339  */
340 static int
341 ng_gif_constructor(node_p node)
342 {
343 	return (EINVAL);
344 }
345 
346 /*
347  * Check for attaching a new hook.
348  */
349 static	int
350 ng_gif_newhook(node_p node, hook_p hook, const char *name)
351 {
352 	const priv_p priv = NG_NODE_PRIVATE(node);
353 	u_char orphan = priv->lowerOrphan;
354 	hook_p *hookptr;
355 
356 	/* Divert hook is an alias for lower */
357 	if (strcmp(name, NG_GIF_HOOK_DIVERT) == 0)
358 		name = NG_GIF_HOOK_LOWER;
359 
360 	/* Which hook? */
361 	if (strcmp(name, NG_GIF_HOOK_LOWER) == 0) {
362 		hookptr = &priv->lower;
363 		orphan = 0;
364 	} else if (strcmp(name, NG_GIF_HOOK_ORPHAN) == 0) {
365 		hookptr = &priv->lower;
366 		orphan = 1;
367 	} else
368 		return (EINVAL);
369 
370 	/* Check if already connected (shouldn't be, but doesn't hurt) */
371 	if (*hookptr != NULL)
372 		return (EISCONN);
373 
374 	/* OK */
375 	*hookptr = hook;
376 	priv->lowerOrphan = orphan;
377 	return (0);
378 }
379 
380 /*
381  * Hooks are attached, adjust to force queueing.
382  * We don't really care which hook it is.
383  * they should all be queuing for outgoing data.
384  */
385 static	int
386 ng_gif_connect(hook_p hook)
387 {
388 	NG_HOOK_FORCE_QUEUE(NG_HOOK_PEER(hook));
389 	return (0);
390 }
391 
392 /*
393  * Receive an incoming control message.
394  */
395 static int
396 ng_gif_rcvmsg(node_p node, item_p item, hook_p lasthook)
397 {
398 	const priv_p priv = NG_NODE_PRIVATE(node);
399 	struct ng_mesg *resp = NULL;
400 	int error = 0;
401 	struct ng_mesg *msg;
402 
403 	NGI_GET_MSG(item, msg);
404 	switch (msg->header.typecookie) {
405 	case NGM_GIF_COOKIE:
406 		switch (msg->header.cmd) {
407 		case NGM_GIF_GET_IFNAME:
408 			NG_MKRESPONSE(resp, msg, IFNAMSIZ, M_NOWAIT);
409 			if (resp == NULL) {
410 				error = ENOMEM;
411 				break;
412 			}
413 			strlcpy(resp->data, priv->ifp->if_xname, IFNAMSIZ);
414 			break;
415 		case NGM_GIF_GET_IFINDEX:
416 			NG_MKRESPONSE(resp, msg, sizeof(u_int32_t), M_NOWAIT);
417 			if (resp == NULL) {
418 				error = ENOMEM;
419 				break;
420 			}
421 			*((u_int32_t *)resp->data) = priv->ifp->if_index;
422 			break;
423 		default:
424 			error = EINVAL;
425 			break;
426 		}
427 		break;
428 	default:
429 		error = EINVAL;
430 		break;
431 	}
432 	NG_RESPOND_MSG(error, node, item, resp);
433 	NG_FREE_MSG(msg);
434 	return (error);
435 }
436 
437 /*
438  * Receive data on a hook.
439  */
440 static int
441 ng_gif_rcvdata(hook_p hook, item_p item)
442 {
443 	const node_p node = NG_HOOK_NODE(hook);
444 	const priv_p priv = NG_NODE_PRIVATE(node);
445 	struct mbuf *m;
446 
447 	NGI_GET_M(item, m);
448 	NG_FREE_ITEM(item);
449 
450 	if (hook == priv->lower)
451 		return ng_gif_rcv_lower(node, m);
452 	panic("%s: weird hook", __func__);
453 }
454 
455 /*
456  * Handle an mbuf received on the "lower" hook.
457  */
458 static int
459 ng_gif_rcv_lower(node_p node, struct mbuf *m)
460 {
461 	struct sockaddr	dst;
462 	const priv_p priv = NG_NODE_PRIVATE(node);
463 
464 	bzero(&dst, sizeof(dst));
465 
466 	/* Make sure header is fully pulled up */
467 	if (m->m_pkthdr.len < sizeof(sa_family_t)) {
468 		NG_FREE_M(m);
469 		return (EINVAL);
470 	}
471 	if (m->m_len < sizeof(sa_family_t)
472 	    && (m = m_pullup(m, sizeof(sa_family_t))) == NULL) {
473 		return (ENOBUFS);
474 	}
475 
476 	dst.sa_family = *mtod(m, sa_family_t *);
477 	m_adj(m, sizeof(sa_family_t));
478 
479 	/* Send it on its way */
480 	/*
481 	 * XXX: gif_output only uses dst for the family and passes the
482 	 * fourth argument (rt) to in{,6}_gif_output which ignore it.
483 	 * If this changes ng_gif will probably break.
484 	 */
485 	return gif_output(priv->ifp, m, &dst, NULL);
486 }
487 
488 /*
489  * Shutdown node. This resets the node but does not remove it
490  * unless the REALLY_DIE flag is set.
491  */
492 static int
493 ng_gif_shutdown(node_p node)
494 {
495 	const priv_p priv = NG_NODE_PRIVATE(node);
496 
497 	if (node->nd_flags & NGF_REALLY_DIE) {
498 		/*
499 		 * WE came here because the gif interface is being destroyed,
500 		 * so stop being persistant.
501 		 * Actually undo all the things we did on creation.
502 		 * Assume the ifp has already been freed.
503 		 */
504 		NG_NODE_SET_PRIVATE(node, NULL);
505 		FREE(priv, M_NETGRAPH);
506 		NG_NODE_UNREF(node);	/* free node itself */
507 		return (0);
508 	}
509 	NG_NODE_REVIVE(node);		/* Signal ng_rmnode we are persisant */
510 	return (0);
511 }
512 
513 /*
514  * Hook disconnection.
515  */
516 static int
517 ng_gif_disconnect(hook_p hook)
518 {
519 	const priv_p priv = NG_NODE_PRIVATE(NG_HOOK_NODE(hook));
520 
521 	if (hook == priv->lower) {
522 		priv->lower = NULL;
523 		priv->lowerOrphan = 0;
524 	} else
525 		panic("%s: weird hook", __func__);
526 	if ((NG_NODE_NUMHOOKS(NG_HOOK_NODE(hook)) == 0)
527 	    && (NG_NODE_IS_VALID(NG_HOOK_NODE(hook))))
528 		ng_rmnode_self(NG_HOOK_NODE(hook));	/* reset node */
529 
530 	return (0);
531 }
532 
533 /******************************************************************
534 		    	INITIALIZATION
535 ******************************************************************/
536 
537 /*
538  * Handle loading and unloading for this node type.
539  */
540 static int
541 ng_gif_mod_event(module_t mod, int event, void *data)
542 {
543 	struct ifnet *ifp;
544 	int error = 0;
545 	int s;
546 
547 	s = splnet();
548 	switch (event) {
549 	case MOD_LOAD:
550 
551 		/* Register function hooks */
552 		if (ng_gif_attach_p != NULL) {
553 			error = EEXIST;
554 			break;
555 		}
556 		ng_gif_attach_p = ng_gif_attach;
557 		ng_gif_detach_p = ng_gif_detach;
558 		ng_gif_input_p = ng_gif_input;
559 		ng_gif_input_orphan_p = ng_gif_input_orphan;
560 
561 		/* Create nodes for any already-existing gif interfaces */
562 		IFNET_RLOCK();
563 		TAILQ_FOREACH(ifp, &ifnet, if_link) {
564 			if (ifp->if_type == IFT_GIF)
565 				ng_gif_attach(ifp);
566 		}
567 		IFNET_RUNLOCK();
568 		break;
569 
570 	case MOD_UNLOAD:
571 
572 		/*
573 		 * Note that the base code won't try to unload us until
574 		 * all nodes have been removed, and that can't happen
575 		 * until all gif interfaces are destroyed. In any
576 		 * case, we know there are no nodes left if the action
577 		 * is MOD_UNLOAD, so there's no need to detach any nodes.
578 		 *
579 		 * XXX: what about manual unloads?!?
580 		 */
581 
582 		/* Unregister function hooks */
583 		ng_gif_attach_p = NULL;
584 		ng_gif_detach_p = NULL;
585 		ng_gif_input_p = NULL;
586 		ng_gif_input_orphan_p = NULL;
587 		break;
588 
589 	default:
590 		error = EOPNOTSUPP;
591 		break;
592 	}
593 	splx(s);
594 	return (error);
595 }
596 
597