xref: /freebsd/sys/netgraph/ng_tee.c (revision f8aae7776f85d2fa8aa93f73c37782cd9e1204c6)
14cf49a43SJulian Elischer 
24cf49a43SJulian Elischer /*
34cf49a43SJulian Elischer  * ng_tee.c
44cf49a43SJulian Elischer  *
54cf49a43SJulian Elischer  * Copyright (c) 1996-1999 Whistle Communications, Inc.
64cf49a43SJulian Elischer  * All rights reserved.
74cf49a43SJulian Elischer  *
84cf49a43SJulian Elischer  * Subject to the following obligations and disclaimer of warranty, use and
94cf49a43SJulian Elischer  * redistribution of this software, in source or object code forms, with or
104cf49a43SJulian Elischer  * without modifications are expressly permitted by Whistle Communications;
114cf49a43SJulian Elischer  * provided, however, that:
124cf49a43SJulian Elischer  * 1. Any and all reproductions of the source or object code must include the
134cf49a43SJulian Elischer  *    copyright notice above and the following disclaimer of warranties; and
144cf49a43SJulian Elischer  * 2. No rights are granted, in any manner or form, to use Whistle
154cf49a43SJulian Elischer  *    Communications, Inc. trademarks, including the mark "WHISTLE
164cf49a43SJulian Elischer  *    COMMUNICATIONS" on advertising, endorsements, or otherwise except as
174cf49a43SJulian Elischer  *    such appears in the above copyright notice or in the software.
184cf49a43SJulian Elischer  *
194cf49a43SJulian Elischer  * THIS SOFTWARE IS BEING PROVIDED BY WHISTLE COMMUNICATIONS "AS IS", AND
204cf49a43SJulian Elischer  * TO THE MAXIMUM EXTENT PERMITTED BY LAW, WHISTLE COMMUNICATIONS MAKES NO
214cf49a43SJulian Elischer  * REPRESENTATIONS OR WARRANTIES, EXPRESS OR IMPLIED, REGARDING THIS SOFTWARE,
224cf49a43SJulian Elischer  * INCLUDING WITHOUT LIMITATION, ANY AND ALL IMPLIED WARRANTIES OF
234cf49a43SJulian Elischer  * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE, OR NON-INFRINGEMENT.
244cf49a43SJulian Elischer  * WHISTLE COMMUNICATIONS DOES NOT WARRANT, GUARANTEE, OR MAKE ANY
254cf49a43SJulian Elischer  * REPRESENTATIONS REGARDING THE USE OF, OR THE RESULTS OF THE USE OF THIS
264cf49a43SJulian Elischer  * SOFTWARE IN TERMS OF ITS CORRECTNESS, ACCURACY, RELIABILITY OR OTHERWISE.
274cf49a43SJulian Elischer  * IN NO EVENT SHALL WHISTLE COMMUNICATIONS BE LIABLE FOR ANY DAMAGES
284cf49a43SJulian Elischer  * RESULTING FROM OR ARISING OUT OF ANY USE OF THIS SOFTWARE, INCLUDING
294cf49a43SJulian Elischer  * WITHOUT LIMITATION, ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY,
304cf49a43SJulian Elischer  * PUNITIVE, OR CONSEQUENTIAL DAMAGES, PROCUREMENT OF SUBSTITUTE GOODS OR
314cf49a43SJulian Elischer  * SERVICES, LOSS OF USE, DATA OR PROFITS, HOWEVER CAUSED AND UNDER ANY
324cf49a43SJulian Elischer  * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
334cf49a43SJulian Elischer  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
344cf49a43SJulian Elischer  * THIS SOFTWARE, EVEN IF WHISTLE COMMUNICATIONS IS ADVISED OF THE POSSIBILITY
354cf49a43SJulian Elischer  * OF SUCH DAMAGE.
364cf49a43SJulian Elischer  *
37cc3bbd68SJulian Elischer  * Author: Julian Elischer <julian@freebsd.org>
384cf49a43SJulian Elischer  *
394cf49a43SJulian Elischer  * $FreeBSD$
4074f5c6aaSJulian Elischer  * $Whistle: ng_tee.c,v 1.18 1999/11/01 09:24:52 julian Exp $
414cf49a43SJulian Elischer  */
424cf49a43SJulian Elischer 
434cf49a43SJulian Elischer /*
444cf49a43SJulian Elischer  * This node is like the tee(1) command and is useful for ``snooping.''
454cf49a43SJulian Elischer  * It has 4 hooks: left, right, left2right, and right2left. Data
464cf49a43SJulian Elischer  * entering from the right is passed to the left and duplicated on
474cf49a43SJulian Elischer  * right2left, and data entering from the left is passed to the right
484cf49a43SJulian Elischer  * and duplicated on left2right. Data entering from left2right is
49722a139cSJulian Elischer  * sent to left, and data from right2left to right.
504cf49a43SJulian Elischer  */
514cf49a43SJulian Elischer 
524cf49a43SJulian Elischer #include <sys/param.h>
534cf49a43SJulian Elischer #include <sys/systm.h>
544cf49a43SJulian Elischer #include <sys/errno.h>
554cf49a43SJulian Elischer #include <sys/kernel.h>
564cf49a43SJulian Elischer #include <sys/malloc.h>
574cf49a43SJulian Elischer #include <sys/mbuf.h>
584cf49a43SJulian Elischer #include <netgraph/ng_message.h>
594cf49a43SJulian Elischer #include <netgraph/netgraph.h>
605c63f81fSArchie Cobbs #include <netgraph/ng_parse.h>
614cf49a43SJulian Elischer #include <netgraph/ng_tee.h>
624cf49a43SJulian Elischer 
634cf49a43SJulian Elischer /* Per hook info */
644cf49a43SJulian Elischer struct hookinfo {
654cf49a43SJulian Elischer 	hook_p			hook;
669cb887a6SArchie Cobbs 	struct ng_tee_hookstat	stats;
674cf49a43SJulian Elischer };
684cf49a43SJulian Elischer 
694cf49a43SJulian Elischer /* Per node info */
704cf49a43SJulian Elischer struct privdata {
714cf49a43SJulian Elischer 	node_p			node;
724cf49a43SJulian Elischer 	struct hookinfo		left;
734cf49a43SJulian Elischer 	struct hookinfo		right;
744cf49a43SJulian Elischer 	struct hookinfo		left2right;
754cf49a43SJulian Elischer 	struct hookinfo		right2left;
764cf49a43SJulian Elischer };
774cf49a43SJulian Elischer typedef struct privdata *sc_p;
784cf49a43SJulian Elischer 
794cf49a43SJulian Elischer /* Netgraph methods */
8074f5c6aaSJulian Elischer static ng_constructor_t	ngt_constructor;
8174f5c6aaSJulian Elischer static ng_rcvmsg_t	ngt_rcvmsg;
82069154d5SJulian Elischer static ng_shutdown_t	ngt_shutdown;
8374f5c6aaSJulian Elischer static ng_newhook_t	ngt_newhook;
8474f5c6aaSJulian Elischer static ng_rcvdata_t	ngt_rcvdata;
8574f5c6aaSJulian Elischer static ng_disconnect_t	ngt_disconnect;
864cf49a43SJulian Elischer 
875c63f81fSArchie Cobbs /* Parse type for struct ng_tee_hookstat */
88f0184ff8SArchie Cobbs static const struct ng_parse_struct_field ng_tee_hookstat_type_fields[]
89f0184ff8SArchie Cobbs 	= NG_TEE_HOOKSTAT_INFO;
905c63f81fSArchie Cobbs static const struct ng_parse_type ng_tee_hookstat_type = {
915c63f81fSArchie Cobbs 	&ng_parse_struct_type,
92f0184ff8SArchie Cobbs 	&ng_tee_hookstat_type_fields
935c63f81fSArchie Cobbs };
945c63f81fSArchie Cobbs 
955c63f81fSArchie Cobbs /* Parse type for struct ng_tee_stats */
96f0184ff8SArchie Cobbs static const struct ng_parse_struct_field ng_tee_stats_type_fields[]
97f0184ff8SArchie Cobbs 	= NG_TEE_STATS_INFO(&ng_tee_hookstat_type);
985c63f81fSArchie Cobbs static const struct ng_parse_type ng_tee_stats_type = {
995c63f81fSArchie Cobbs 	&ng_parse_struct_type,
100f0184ff8SArchie Cobbs 	&ng_tee_stats_type_fields
1015c63f81fSArchie Cobbs };
1025c63f81fSArchie Cobbs 
1035c63f81fSArchie Cobbs /* List of commands and how to convert arguments to/from ASCII */
1045c63f81fSArchie Cobbs static const struct ng_cmdlist ng_tee_cmds[] = {
1055c63f81fSArchie Cobbs 	{
1065c63f81fSArchie Cobbs 	  NGM_TEE_COOKIE,
1075c63f81fSArchie Cobbs 	  NGM_TEE_GET_STATS,
1085c63f81fSArchie Cobbs 	  "getstats",
1095c63f81fSArchie Cobbs 	  NULL,
1105c63f81fSArchie Cobbs 	  &ng_tee_stats_type
1115c63f81fSArchie Cobbs 	},
1125c63f81fSArchie Cobbs 	{
1135c63f81fSArchie Cobbs 	  NGM_TEE_COOKIE,
1145c63f81fSArchie Cobbs 	  NGM_TEE_CLR_STATS,
1155c63f81fSArchie Cobbs 	  "clrstats",
1165c63f81fSArchie Cobbs 	  NULL,
1175c63f81fSArchie Cobbs 	  NULL
1185c63f81fSArchie Cobbs 	},
11905215785SArchie Cobbs 	{
12005215785SArchie Cobbs 	  NGM_TEE_COOKIE,
12105215785SArchie Cobbs 	  NGM_TEE_GETCLR_STATS,
12205215785SArchie Cobbs 	  "getclrstats",
12305215785SArchie Cobbs 	  NULL,
12405215785SArchie Cobbs 	  &ng_tee_stats_type
12505215785SArchie Cobbs 	},
1265c63f81fSArchie Cobbs 	{ 0 }
1275c63f81fSArchie Cobbs };
1285c63f81fSArchie Cobbs 
1294cf49a43SJulian Elischer /* Netgraph type descriptor */
1305c63f81fSArchie Cobbs static struct ng_type ng_tee_typestruct = {
131f8aae777SJulian Elischer 	.version =	NG_ABI_VERSION,
132f8aae777SJulian Elischer 	.name =		NG_TEE_NODE_TYPE,
133f8aae777SJulian Elischer 	.constructor =	ngt_constructor,
134f8aae777SJulian Elischer 	.rcvmsg =	ngt_rcvmsg,
135f8aae777SJulian Elischer 	.shutdown =	ngt_shutdown,
136f8aae777SJulian Elischer 	.newhook =	ngt_newhook,
137f8aae777SJulian Elischer 	.rcvdata =	ngt_rcvdata,
138f8aae777SJulian Elischer 	.disconnect =	ngt_disconnect,
139f8aae777SJulian Elischer 	.cmdlist =	ng_tee_cmds,
1404cf49a43SJulian Elischer };
1415c63f81fSArchie Cobbs NETGRAPH_INIT(tee, &ng_tee_typestruct);
1424cf49a43SJulian Elischer 
1434cf49a43SJulian Elischer /*
1444cf49a43SJulian Elischer  * Node constructor
1454cf49a43SJulian Elischer  */
1464cf49a43SJulian Elischer static int
147069154d5SJulian Elischer ngt_constructor(node_p node)
1484cf49a43SJulian Elischer {
1494cf49a43SJulian Elischer 	sc_p privdata;
1504cf49a43SJulian Elischer 
15199cdf4ccSDavid Malone 	MALLOC(privdata, sc_p, sizeof(*privdata), M_NETGRAPH, M_NOWAIT|M_ZERO);
1524cf49a43SJulian Elischer 	if (privdata == NULL)
1534cf49a43SJulian Elischer 		return (ENOMEM);
1544cf49a43SJulian Elischer 
15530400f03SJulian Elischer 	NG_NODE_SET_PRIVATE(node, privdata);
156069154d5SJulian Elischer 	privdata->node = node;
1574cf49a43SJulian Elischer 	return (0);
1584cf49a43SJulian Elischer }
1594cf49a43SJulian Elischer 
1604cf49a43SJulian Elischer /*
1614cf49a43SJulian Elischer  * Add a hook
1624cf49a43SJulian Elischer  */
1634cf49a43SJulian Elischer static int
1644cf49a43SJulian Elischer ngt_newhook(node_p node, hook_p hook, const char *name)
1654cf49a43SJulian Elischer {
16630400f03SJulian Elischer 	const sc_p sc = NG_NODE_PRIVATE(node);
1674cf49a43SJulian Elischer 
1684cf49a43SJulian Elischer 	if (strcmp(name, NG_TEE_HOOK_RIGHT) == 0) {
1694cf49a43SJulian Elischer 		sc->right.hook = hook;
1709cb887a6SArchie Cobbs 		bzero(&sc->right.stats, sizeof(sc->right.stats));
17130400f03SJulian Elischer 		NG_HOOK_SET_PRIVATE(hook, &sc->right);
1724cf49a43SJulian Elischer 	} else if (strcmp(name, NG_TEE_HOOK_LEFT) == 0) {
1734cf49a43SJulian Elischer 		sc->left.hook = hook;
1749cb887a6SArchie Cobbs 		bzero(&sc->left.stats, sizeof(sc->left.stats));
17530400f03SJulian Elischer 		NG_HOOK_SET_PRIVATE(hook, &sc->left);
1764cf49a43SJulian Elischer 	} else if (strcmp(name, NG_TEE_HOOK_RIGHT2LEFT) == 0) {
1774cf49a43SJulian Elischer 		sc->right2left.hook = hook;
1789cb887a6SArchie Cobbs 		bzero(&sc->right2left.stats, sizeof(sc->right2left.stats));
17930400f03SJulian Elischer 		NG_HOOK_SET_PRIVATE(hook, &sc->right2left);
1804cf49a43SJulian Elischer 	} else if (strcmp(name, NG_TEE_HOOK_LEFT2RIGHT) == 0) {
1814cf49a43SJulian Elischer 		sc->left2right.hook = hook;
1829cb887a6SArchie Cobbs 		bzero(&sc->left2right.stats, sizeof(sc->left2right.stats));
18330400f03SJulian Elischer 		NG_HOOK_SET_PRIVATE(hook, &sc->left2right);
1844cf49a43SJulian Elischer 	} else
1854cf49a43SJulian Elischer 		return (EINVAL);
1864cf49a43SJulian Elischer 	return (0);
1874cf49a43SJulian Elischer }
1884cf49a43SJulian Elischer 
1894cf49a43SJulian Elischer /*
1909cb887a6SArchie Cobbs  * Receive a control message
1914cf49a43SJulian Elischer  */
1924cf49a43SJulian Elischer static int
193069154d5SJulian Elischer ngt_rcvmsg(node_p node, item_p item, hook_p lasthook)
1944cf49a43SJulian Elischer {
19530400f03SJulian Elischer 	const sc_p sc = NG_NODE_PRIVATE(node);
1969cb887a6SArchie Cobbs 	struct ng_mesg *resp = NULL;
1979cb887a6SArchie Cobbs 	int error = 0;
198069154d5SJulian Elischer 	struct ng_mesg *msg;
1999cb887a6SArchie Cobbs 
200069154d5SJulian Elischer 	NGI_GET_MSG(item, msg);
2019cb887a6SArchie Cobbs 	switch (msg->header.typecookie) {
2029cb887a6SArchie Cobbs 	case NGM_TEE_COOKIE:
2039cb887a6SArchie Cobbs 		switch (msg->header.cmd) {
2049cb887a6SArchie Cobbs 		case NGM_TEE_GET_STATS:
20505215785SArchie Cobbs 		case NGM_TEE_CLR_STATS:
20605215785SArchie Cobbs 		case NGM_TEE_GETCLR_STATS:
2079cb887a6SArchie Cobbs                     {
2089cb887a6SArchie Cobbs 			struct ng_tee_stats *stats;
2099cb887a6SArchie Cobbs 
21005215785SArchie Cobbs                         if (msg->header.cmd != NGM_TEE_CLR_STATS) {
2119cb887a6SArchie Cobbs                                 NG_MKRESPONSE(resp, msg,
21205215785SArchie Cobbs                                     sizeof(*stats), M_NOWAIT);
2139cb887a6SArchie Cobbs 				if (resp == NULL) {
2149cb887a6SArchie Cobbs 					error = ENOMEM;
2159cb887a6SArchie Cobbs 					goto done;
2169cb887a6SArchie Cobbs 				}
2179cb887a6SArchie Cobbs 				stats = (struct ng_tee_stats *)resp->data;
21805215785SArchie Cobbs 				bcopy(&sc->right.stats, &stats->right,
21905215785SArchie Cobbs 				    sizeof(stats->right));
22005215785SArchie Cobbs 				bcopy(&sc->left.stats, &stats->left,
22105215785SArchie Cobbs 				    sizeof(stats->left));
22205215785SArchie Cobbs 				bcopy(&sc->right2left.stats, &stats->right2left,
22305215785SArchie Cobbs 				    sizeof(stats->right2left));
22405215785SArchie Cobbs 				bcopy(&sc->left2right.stats, &stats->left2right,
22505215785SArchie Cobbs 				    sizeof(stats->left2right));
2269cb887a6SArchie Cobbs                         }
22705215785SArchie Cobbs                         if (msg->header.cmd != NGM_TEE_GET_STATS) {
22805215785SArchie Cobbs 				bzero(&sc->right.stats,
22905215785SArchie Cobbs 				    sizeof(sc->right.stats));
23005215785SArchie Cobbs 				bzero(&sc->left.stats,
23105215785SArchie Cobbs 				    sizeof(sc->left.stats));
2329cb887a6SArchie Cobbs 				bzero(&sc->right2left.stats,
2339cb887a6SArchie Cobbs 				    sizeof(sc->right2left.stats));
2349cb887a6SArchie Cobbs 				bzero(&sc->left2right.stats,
2359cb887a6SArchie Cobbs 				    sizeof(sc->left2right.stats));
23605215785SArchie Cobbs 			}
2379cb887a6SArchie Cobbs                         break;
23805215785SArchie Cobbs 		    }
2399cb887a6SArchie Cobbs 		default:
2409cb887a6SArchie Cobbs 			error = EINVAL;
2419cb887a6SArchie Cobbs 			break;
2429cb887a6SArchie Cobbs 		}
2439cb887a6SArchie Cobbs 		break;
244069154d5SJulian Elischer 	case NGM_FLOW_COOKIE:
245069154d5SJulian Elischer 		if (lasthook)  {
246069154d5SJulian Elischer 			if (lasthook == sc->left.hook) {
247069154d5SJulian Elischer 				if (sc->right.hook) {
248069154d5SJulian Elischer 					NGI_MSG(item) = msg;
24930400f03SJulian Elischer 					NG_FWD_ITEM_HOOK(error, item,
25030400f03SJulian Elischer 							sc->right.hook);
251069154d5SJulian Elischer 					return (error);
252069154d5SJulian Elischer 				}
253069154d5SJulian Elischer 			} else {
254069154d5SJulian Elischer 				if (sc->left.hook) {
255069154d5SJulian Elischer 					NGI_MSG(item) = msg;
25630400f03SJulian Elischer 					NG_FWD_ITEM_HOOK(error, item,
25730400f03SJulian Elischer 							sc->left.hook);
258069154d5SJulian Elischer 					return (error);
259069154d5SJulian Elischer 				}
260069154d5SJulian Elischer 			}
261069154d5SJulian Elischer 		}
262069154d5SJulian Elischer 		break;
2639cb887a6SArchie Cobbs 	default:
2649cb887a6SArchie Cobbs 		error = EINVAL;
2659cb887a6SArchie Cobbs 		break;
2669cb887a6SArchie Cobbs 	}
2679cb887a6SArchie Cobbs done:
268069154d5SJulian Elischer 	NG_RESPOND_MSG(error, node, item, resp);
269069154d5SJulian Elischer 	NG_FREE_MSG(msg);
2709cb887a6SArchie Cobbs 	return (error);
2714cf49a43SJulian Elischer }
2724cf49a43SJulian Elischer 
2734cf49a43SJulian Elischer /*
2744cf49a43SJulian Elischer  * Receive data on a hook
2754cf49a43SJulian Elischer  *
2764cf49a43SJulian Elischer  * If data comes in the right link send a copy out right2left, and then
2774cf49a43SJulian Elischer  * send the original onwards out through the left link.
2784cf49a43SJulian Elischer  * Do the opposite for data coming in from the left link.
2794cf49a43SJulian Elischer  * Data coming in right2left or left2right is forwarded
2804cf49a43SJulian Elischer  * on through the appropriate destination hook as if it had come
2814cf49a43SJulian Elischer  * from the other side.
2824cf49a43SJulian Elischer  */
2834cf49a43SJulian Elischer static int
284069154d5SJulian Elischer ngt_rcvdata(hook_p hook, item_p item)
2854cf49a43SJulian Elischer {
28630400f03SJulian Elischer 	const sc_p sc = NG_NODE_PRIVATE(NG_HOOK_NODE(hook));
28730400f03SJulian Elischer 	struct hookinfo *const hinfo = NG_HOOK_PRIVATE(hook);
2884cf49a43SJulian Elischer 	struct hookinfo *dest;
2894cf49a43SJulian Elischer 	struct hookinfo *dup;
2904cf49a43SJulian Elischer 	int error = 0;
291069154d5SJulian Elischer 	struct mbuf *m;
292069154d5SJulian Elischer 	meta_p meta;
2934cf49a43SJulian Elischer 
294069154d5SJulian Elischer 	m = NGI_M(item);
295069154d5SJulian Elischer 	meta = NGI_META(item); /* leave these owned by the item */
2969cb887a6SArchie Cobbs 	/* Which hook? */
2979cb887a6SArchie Cobbs 	if (hinfo == &sc->left) {
2984cf49a43SJulian Elischer 		dup = &sc->left2right;
2994cf49a43SJulian Elischer 		dest = &sc->right;
3009cb887a6SArchie Cobbs 	} else if (hinfo == &sc->right) {
3014cf49a43SJulian Elischer 		dup = &sc->right2left;
3024cf49a43SJulian Elischer 		dest = &sc->left;
3039cb887a6SArchie Cobbs 	} else if (hinfo == &sc->right2left) {
3044cf49a43SJulian Elischer 		dup = NULL;
3050633aaefSJulian Elischer 		dest = &sc->right;
3069cb887a6SArchie Cobbs 	} else if (hinfo == &sc->left2right) {
3074cf49a43SJulian Elischer 		dup = NULL;
3080633aaefSJulian Elischer 		dest = &sc->left;
309b40ce416SJulian Elischer 	} else {
3106e551fb6SDavid E. O'Brien 		panic("%s: no hook!", __func__);
311b40ce416SJulian Elischer #ifdef	RESTARTABLE_PANICS
312b40ce416SJulian Elischer 		return(EINVAL);
313b40ce416SJulian Elischer #endif
314b40ce416SJulian Elischer 	}
3154cf49a43SJulian Elischer 
3169cb887a6SArchie Cobbs 	/* Update stats on incoming hook */
3179cb887a6SArchie Cobbs 	hinfo->stats.inOctets += m->m_pkthdr.len;
3189cb887a6SArchie Cobbs 	hinfo->stats.inFrames++;
3194cf49a43SJulian Elischer 
320069154d5SJulian Elischer 	/*
321069154d5SJulian Elischer 	 * Don't make a copy if only the dup hook exists.
322069154d5SJulian Elischer 	 */
323069154d5SJulian Elischer 	if ((dup && dup->hook) && (dest->hook == NULL)) {
324069154d5SJulian Elischer 		dest = dup;
325069154d5SJulian Elischer 		dup = NULL;
326069154d5SJulian Elischer 	}
327069154d5SJulian Elischer 
3289cb887a6SArchie Cobbs 	/* Duplicate packet and meta info if requried */
329ba9c6c61SJulian Elischer 	if (dup && dup->hook) {
3309cb887a6SArchie Cobbs 		struct mbuf *m2;
3319cb887a6SArchie Cobbs 		meta_p meta2;
3329cb887a6SArchie Cobbs 
333069154d5SJulian Elischer 		/* Copy packet (failure will not stop the original)*/
334a163d034SWarner Losh 		m2 = m_dup(m, M_DONTWAIT);
335069154d5SJulian Elischer 		if (m2) {
3369cb887a6SArchie Cobbs 
3379cb887a6SArchie Cobbs 			/* Copy meta info */
338069154d5SJulian Elischer 			/* If we can't get a copy, tough.. */
3393a0d1d88SArchie Cobbs 			if (meta != NULL) {
340069154d5SJulian Elischer 				meta2 = ng_copy_meta(meta);
3413a0d1d88SArchie Cobbs 			} else
3423a0d1d88SArchie Cobbs 				meta2 = NULL;
3439cb887a6SArchie Cobbs 
3449cb887a6SArchie Cobbs 			/* Deliver duplicate */
3459cb887a6SArchie Cobbs 			dup->stats.outOctets += m->m_pkthdr.len;
3469cb887a6SArchie Cobbs 			dup->stats.outFrames++;
3479cb887a6SArchie Cobbs 			NG_SEND_DATA(error, dup->hook, m2, meta2);
3489cb887a6SArchie Cobbs 		}
349069154d5SJulian Elischer 	}
3509cb887a6SArchie Cobbs 	/* Deliver frame out destination hook */
3510598ef01SJulian Elischer 	if (dest->hook) {
3529cb887a6SArchie Cobbs 		dest->stats.outOctets += m->m_pkthdr.len;
3539cb887a6SArchie Cobbs 		dest->stats.outFrames++;
35430400f03SJulian Elischer 		NG_FWD_ITEM_HOOK(error, item, dest->hook);
3550598ef01SJulian Elischer 	} else
356069154d5SJulian Elischer 		NG_FREE_ITEM(item);
35753dc6459SJulian Elischer 	return (error);
3584cf49a43SJulian Elischer }
3594cf49a43SJulian Elischer 
3604cf49a43SJulian Elischer /*
3614cf49a43SJulian Elischer  * Shutdown processing
3624cf49a43SJulian Elischer  *
3634cf49a43SJulian Elischer  * This is tricky. If we have both a left and right hook, then we
3644cf49a43SJulian Elischer  * probably want to extricate ourselves and leave the two peers
3654cf49a43SJulian Elischer  * still linked to each other. Otherwise we should just shut down as
3664cf49a43SJulian Elischer  * a normal node would.
3674cf49a43SJulian Elischer  *
3684cf49a43SJulian Elischer  * To keep the scope of info correct the routine to "extract" a node
3694cf49a43SJulian Elischer  * from two links is in ng_base.c.
3704cf49a43SJulian Elischer  */
3714cf49a43SJulian Elischer static int
372069154d5SJulian Elischer ngt_shutdown(node_p node)
3734cf49a43SJulian Elischer {
37430400f03SJulian Elischer 	const sc_p privdata = NG_NODE_PRIVATE(node);
3754cf49a43SJulian Elischer 
376069154d5SJulian Elischer #if 0 /* can never happen as cutlinks is already called */
3774cf49a43SJulian Elischer 	if (privdata->left.hook && privdata->right.hook)
3784cf49a43SJulian Elischer 		ng_bypass(privdata->left.hook, privdata->right.hook);
379069154d5SJulian Elischer #endif
38030400f03SJulian Elischer 	NG_NODE_SET_PRIVATE(node, NULL);
38130400f03SJulian Elischer 	NG_NODE_UNREF(privdata->node);
3824cf49a43SJulian Elischer 	FREE(privdata, M_NETGRAPH);
3834cf49a43SJulian Elischer 	return (0);
3844cf49a43SJulian Elischer }
3854cf49a43SJulian Elischer 
3864cf49a43SJulian Elischer /*
3874cf49a43SJulian Elischer  * Hook disconnection
3884cf49a43SJulian Elischer  */
3894cf49a43SJulian Elischer static int
3904cf49a43SJulian Elischer ngt_disconnect(hook_p hook)
3914cf49a43SJulian Elischer {
39230400f03SJulian Elischer 	struct hookinfo *const hinfo = NG_HOOK_PRIVATE(hook);
3934cf49a43SJulian Elischer 
3946e551fb6SDavid E. O'Brien 	KASSERT(hinfo != NULL, ("%s: null info", __func__));
3959cb887a6SArchie Cobbs 	hinfo->hook = NULL;
39630400f03SJulian Elischer 	if ((NG_NODE_NUMHOOKS(NG_HOOK_NODE(hook)) == 0)
39730400f03SJulian Elischer 	&& (NG_NODE_IS_VALID(NG_HOOK_NODE(hook))))
39830400f03SJulian Elischer 		ng_rmnode_self(NG_HOOK_NODE(hook));
3994cf49a43SJulian Elischer 	return (0);
4004cf49a43SJulian Elischer }
4014cf49a43SJulian Elischer 
402