Home | History | Annotate | Line # | Download | only in netinet6
ip6_flow.c revision 1.32
      1  1.32     ozaki /*	$NetBSD: ip6_flow.c,v 1.32 2016/10/18 07:30:31 ozaki-r Exp $	*/
      2   1.1  liamjfoy 
      3   1.1  liamjfoy /*-
      4   1.1  liamjfoy  * Copyright (c) 2007 The NetBSD Foundation, Inc.
      5   1.1  liamjfoy  * All rights reserved.
      6   1.1  liamjfoy  *
      7   1.1  liamjfoy  * This code is derived from software contributed to The NetBSD Foundation
      8   1.1  liamjfoy  * by the 3am Software Foundry ("3am").  It was developed by Liam J. Foy
      9   1.1  liamjfoy  * <liamjfoy (at) netbsd.org> and Matt Thomas <matt (at) netbsd.org>.
     10   1.1  liamjfoy  *
     11   1.1  liamjfoy  * Redistribution and use in source and binary forms, with or without
     12   1.1  liamjfoy  * modification, are permitted provided that the following conditions
     13   1.1  liamjfoy  * are met:
     14   1.1  liamjfoy  * 1. Redistributions of source code must retain the above copyright
     15   1.1  liamjfoy  *    notice, this list of conditions and the following disclaimer.
     16   1.1  liamjfoy  * 2. Redistributions in binary form must reproduce the above copyright
     17   1.1  liamjfoy  *    notice, this list of conditions and the following disclaimer in the
     18   1.1  liamjfoy  *    documentation and/or other materials provided with the distribution.
     19   1.1  liamjfoy  *
     20   1.1  liamjfoy  * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
     21   1.1  liamjfoy  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
     22   1.1  liamjfoy  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     23   1.1  liamjfoy  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
     24   1.1  liamjfoy  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     25   1.1  liamjfoy  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     26   1.1  liamjfoy  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     27   1.1  liamjfoy  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     28   1.1  liamjfoy  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     29   1.1  liamjfoy  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     30   1.1  liamjfoy  * POSSIBILITY OF SUCH DAMAGE.
     31   1.1  liamjfoy  *
     32   1.1  liamjfoy  * IPv6 version was developed by Liam J. Foy. Original source existed in IPv4
     33   1.1  liamjfoy  * format developed by Matt Thomas. Thanks to Joerg Sonnenberger, Matt
     34   1.1  liamjfoy  * Thomas and Christos Zoulas.
     35   1.1  liamjfoy  *
     36   1.1  liamjfoy  * Thanks to Liverpool John Moores University, especially Dr. David Llewellyn-Jones
     37   1.1  liamjfoy  * for providing resources (to test) and Professor Madjid Merabti.
     38   1.1  liamjfoy  */
     39   1.1  liamjfoy 
     40   1.1  liamjfoy #include <sys/cdefs.h>
     41  1.32     ozaki __KERNEL_RCSID(0, "$NetBSD: ip6_flow.c,v 1.32 2016/10/18 07:30:31 ozaki-r Exp $");
     42  1.32     ozaki 
     43  1.32     ozaki #ifdef _KERNEL_OPT
     44  1.32     ozaki #include "opt_net_mpsafe.h"
     45  1.32     ozaki #endif
     46   1.1  liamjfoy 
     47   1.1  liamjfoy #include <sys/param.h>
     48   1.1  liamjfoy #include <sys/systm.h>
     49   1.1  liamjfoy #include <sys/malloc.h>
     50   1.1  liamjfoy #include <sys/mbuf.h>
     51   1.1  liamjfoy #include <sys/domain.h>
     52   1.1  liamjfoy #include <sys/protosw.h>
     53   1.1  liamjfoy #include <sys/socket.h>
     54   1.1  liamjfoy #include <sys/socketvar.h>
     55   1.1  liamjfoy #include <sys/time.h>
     56   1.1  liamjfoy #include <sys/kernel.h>
     57   1.1  liamjfoy #include <sys/pool.h>
     58   1.1  liamjfoy #include <sys/sysctl.h>
     59  1.28     ozaki #include <sys/workqueue.h>
     60  1.29     ozaki #include <sys/atomic.h>
     61   1.1  liamjfoy 
     62   1.1  liamjfoy #include <net/if.h>
     63   1.1  liamjfoy #include <net/if_dl.h>
     64   1.1  liamjfoy #include <net/route.h>
     65   1.1  liamjfoy #include <net/pfil.h>
     66   1.1  liamjfoy 
     67   1.1  liamjfoy #include <netinet/in.h>
     68   1.1  liamjfoy #include <netinet6/in6_var.h>
     69   1.1  liamjfoy #include <netinet/in_systm.h>
     70   1.1  liamjfoy #include <netinet/ip6.h>
     71   1.1  liamjfoy #include <netinet6/ip6_var.h>
     72  1.15   thorpej #include <netinet6/ip6_private.h>
     73   1.1  liamjfoy 
     74   1.1  liamjfoy /*
     75   1.1  liamjfoy  * IPv6 Fast Forward caches/hashes flows from one source to destination.
     76   1.1  liamjfoy  *
     77   1.1  liamjfoy  * Upon a successful forward IPv6FF caches and hashes details such as the
     78   1.1  liamjfoy  * route, source and destination. Once another packet is received matching
     79   1.1  liamjfoy  * the source and destination the packet is forwarded straight onto if_output
     80   1.1  liamjfoy  * using the cached details.
     81   1.1  liamjfoy  *
     82   1.1  liamjfoy  * Example:
     83  1.20  christos  * ether/fddi_input -> ip6flow_fastforward -> if_output
     84   1.1  liamjfoy  */
     85   1.1  liamjfoy 
     86  1.18  liamjfoy static struct pool ip6flow_pool;
     87   1.1  liamjfoy 
     88  1.31  knakahar TAILQ_HEAD(ip6flowhead, ip6flow);
     89   1.1  liamjfoy 
     90   1.1  liamjfoy /*
     91   1.1  liamjfoy  * We could use IPv4 defines (IPFLOW_HASHBITS) but we'll
     92   1.1  liamjfoy  * use our own (possibly for future expansion).
     93   1.1  liamjfoy  */
     94   1.1  liamjfoy #define	IP6FLOW_TIMER		(5 * PR_SLOWHZ)
     95   1.4  liamjfoy #define	IP6FLOW_DEFAULT_HASHSIZE	(1 << IP6FLOW_HASHBITS)
     96   1.1  liamjfoy 
     97  1.25  knakahar /*
     98  1.25  knakahar  * ip6_flow.c internal lock.
     99  1.25  knakahar  * If we use softnet_lock, it would cause recursive lock.
    100  1.25  knakahar  *
    101  1.25  knakahar  * This is a tentative workaround.
    102  1.25  knakahar  * We should make it scalable somehow in the future.
    103  1.25  knakahar  */
    104  1.25  knakahar static kmutex_t ip6flow_lock;
    105   1.4  liamjfoy static struct ip6flowhead *ip6flowtable = NULL;
    106   1.1  liamjfoy static struct ip6flowhead ip6flowlist;
    107   1.1  liamjfoy static int ip6flow_inuse;
    108   1.1  liamjfoy 
    109  1.28     ozaki static void ip6flow_slowtimo_work(struct work *, void *);
    110  1.28     ozaki static struct workqueue	*ip6flow_slowtimo_wq;
    111  1.28     ozaki static struct work	ip6flow_slowtimo_wk;
    112  1.28     ozaki 
    113  1.30  knakahar static int sysctl_net_inet6_ip6_hashsize(SYSCTLFN_PROTO);
    114  1.30  knakahar static int sysctl_net_inet6_ip6_maxflows(SYSCTLFN_PROTO);
    115  1.30  knakahar static void ip6flow_sysctl_init(struct sysctllog **);
    116  1.30  knakahar 
    117   1.1  liamjfoy /*
    118   1.1  liamjfoy  * Insert an ip6flow into the list.
    119   1.1  liamjfoy  */
    120  1.31  knakahar #define	IP6FLOW_INSERT(hashidx, ip6f) \
    121   1.1  liamjfoy do { \
    122  1.31  knakahar 	(ip6f)->ip6f_hashidx = (hashidx); \
    123  1.31  knakahar 	TAILQ_INSERT_HEAD(&ip6flowtable[(hashidx)], (ip6f), ip6f_hash); \
    124  1.31  knakahar 	TAILQ_INSERT_HEAD(&ip6flowlist, (ip6f), ip6f_list); \
    125   1.1  liamjfoy } while (/*CONSTCOND*/ 0)
    126   1.1  liamjfoy 
    127   1.1  liamjfoy /*
    128   1.1  liamjfoy  * Remove an ip6flow from the list.
    129   1.1  liamjfoy  */
    130  1.31  knakahar #define	IP6FLOW_REMOVE(hashidx, ip6f) \
    131   1.1  liamjfoy do { \
    132  1.31  knakahar 	TAILQ_REMOVE(&ip6flowtable[(hashidx)], (ip6f), ip6f_hash); \
    133  1.31  knakahar 	TAILQ_REMOVE(&ip6flowlist, (ip6f), ip6f_list); \
    134   1.1  liamjfoy } while (/*CONSTCOND*/ 0)
    135   1.1  liamjfoy 
    136   1.1  liamjfoy #ifndef IP6FLOW_DEFAULT
    137   1.1  liamjfoy #define	IP6FLOW_DEFAULT		256
    138   1.1  liamjfoy #endif
    139   1.1  liamjfoy 
    140   1.1  liamjfoy int ip6_maxflows = IP6FLOW_DEFAULT;
    141   1.4  liamjfoy int ip6_hashsize = IP6FLOW_DEFAULT_HASHSIZE;
    142   1.1  liamjfoy 
    143   1.1  liamjfoy /*
    144   1.1  liamjfoy  * Calculate hash table position.
    145   1.1  liamjfoy  */
    146   1.1  liamjfoy static size_t
    147  1.13    dyoung ip6flow_hash(const struct ip6_hdr *ip6)
    148   1.1  liamjfoy {
    149   1.1  liamjfoy 	size_t hash;
    150   1.1  liamjfoy 	uint32_t dst_sum, src_sum;
    151   1.6  liamjfoy 	size_t idx;
    152   1.1  liamjfoy 
    153   1.1  liamjfoy 	src_sum = ip6->ip6_src.s6_addr32[0] + ip6->ip6_src.s6_addr32[1]
    154   1.1  liamjfoy 	    + ip6->ip6_src.s6_addr32[2] + ip6->ip6_src.s6_addr32[3];
    155   1.1  liamjfoy 	dst_sum = ip6->ip6_dst.s6_addr32[0] + ip6->ip6_dst.s6_addr32[1]
    156   1.1  liamjfoy 	    + ip6->ip6_dst.s6_addr32[2] + ip6->ip6_dst.s6_addr32[3];
    157   1.1  liamjfoy 
    158   1.1  liamjfoy 	hash = ip6->ip6_flow;
    159   1.1  liamjfoy 
    160   1.1  liamjfoy 	for (idx = 0; idx < 32; idx += IP6FLOW_HASHBITS)
    161   1.1  liamjfoy 		hash += (dst_sum >> (32 - idx)) + (src_sum >> idx);
    162   1.1  liamjfoy 
    163   1.4  liamjfoy 	return hash & (ip6_hashsize-1);
    164   1.1  liamjfoy }
    165   1.1  liamjfoy 
    166   1.1  liamjfoy /*
    167   1.1  liamjfoy  * Check to see if a flow already exists - if so return it.
    168   1.1  liamjfoy  */
    169   1.1  liamjfoy static struct ip6flow *
    170  1.13    dyoung ip6flow_lookup(const struct ip6_hdr *ip6)
    171   1.1  liamjfoy {
    172   1.1  liamjfoy 	size_t hash;
    173   1.1  liamjfoy 	struct ip6flow *ip6f;
    174   1.1  liamjfoy 
    175  1.25  knakahar 	KASSERT(mutex_owned(&ip6flow_lock));
    176  1.25  knakahar 
    177   1.1  liamjfoy 	hash = ip6flow_hash(ip6);
    178   1.1  liamjfoy 
    179  1.31  knakahar 	TAILQ_FOREACH(ip6f, &ip6flowtable[hash], ip6f_hash) {
    180   1.1  liamjfoy 		if (IN6_ARE_ADDR_EQUAL(&ip6->ip6_dst, &ip6f->ip6f_dst)
    181   1.1  liamjfoy 		    && IN6_ARE_ADDR_EQUAL(&ip6->ip6_src, &ip6f->ip6f_src)
    182   1.1  liamjfoy 		    && ip6f->ip6f_flow == ip6->ip6_flow) {
    183   1.1  liamjfoy 		    	/* A cached flow has been found. */
    184   1.1  liamjfoy 			return ip6f;
    185   1.1  liamjfoy 		}
    186   1.1  liamjfoy 	}
    187   1.1  liamjfoy 
    188   1.1  liamjfoy 	return NULL;
    189   1.1  liamjfoy }
    190   1.1  liamjfoy 
    191  1.18  liamjfoy void
    192  1.18  liamjfoy ip6flow_poolinit(void)
    193  1.18  liamjfoy {
    194  1.18  liamjfoy 
    195  1.18  liamjfoy 	pool_init(&ip6flow_pool, sizeof(struct ip6flow), 0, 0, 0, "ip6flowpl",
    196  1.18  liamjfoy 			NULL, IPL_NET);
    197  1.18  liamjfoy }
    198  1.18  liamjfoy 
    199   1.1  liamjfoy /*
    200   1.4  liamjfoy  * Allocate memory and initialise lists. This function is called
    201   1.4  liamjfoy  * from ip6_init and called there after to resize the hash table.
    202   1.4  liamjfoy  * If a newly sized table cannot be malloc'ed we just continue
    203   1.4  liamjfoy  * to use the old one.
    204   1.1  liamjfoy  */
    205  1.25  knakahar static int
    206  1.25  knakahar ip6flow_init_locked(int table_size)
    207   1.1  liamjfoy {
    208   1.4  liamjfoy 	struct ip6flowhead *new_table;
    209   1.1  liamjfoy 	size_t i;
    210   1.1  liamjfoy 
    211  1.25  knakahar 	KASSERT(mutex_owned(&ip6flow_lock));
    212  1.25  knakahar 
    213   1.4  liamjfoy 	new_table = (struct ip6flowhead *)malloc(sizeof(struct ip6flowhead) *
    214   1.4  liamjfoy 	    table_size, M_RTABLE, M_NOWAIT);
    215   1.4  liamjfoy 
    216   1.4  liamjfoy 	if (new_table == NULL)
    217   1.4  liamjfoy 		return 1;
    218   1.4  liamjfoy 
    219   1.4  liamjfoy 	if (ip6flowtable != NULL)
    220   1.4  liamjfoy 		free(ip6flowtable, M_RTABLE);
    221   1.4  liamjfoy 
    222   1.4  liamjfoy 	ip6flowtable = new_table;
    223   1.4  liamjfoy 	ip6_hashsize = table_size;
    224   1.4  liamjfoy 
    225  1.31  knakahar 	TAILQ_INIT(&ip6flowlist);
    226   1.4  liamjfoy 	for (i = 0; i < ip6_hashsize; i++)
    227  1.31  knakahar 		TAILQ_INIT(&ip6flowtable[i]);
    228   1.4  liamjfoy 
    229   1.4  liamjfoy 	return 0;
    230   1.1  liamjfoy }
    231   1.1  liamjfoy 
    232  1.25  knakahar int
    233  1.25  knakahar ip6flow_init(int table_size)
    234  1.25  knakahar {
    235  1.28     ozaki 	int ret, error;
    236  1.28     ozaki 
    237  1.28     ozaki 	error = workqueue_create(&ip6flow_slowtimo_wq, "ip6flow_slowtimo",
    238  1.28     ozaki 	    ip6flow_slowtimo_work, NULL, PRI_SOFTNET, IPL_SOFTNET, WQ_MPSAFE);
    239  1.28     ozaki 	if (error != 0)
    240  1.28     ozaki 		panic("%s: workqueue_create failed (%d)\n", __func__, error);
    241  1.25  knakahar 
    242  1.25  knakahar 	mutex_init(&ip6flow_lock, MUTEX_DEFAULT, IPL_NONE);
    243  1.25  knakahar 
    244  1.25  knakahar 	mutex_enter(&ip6flow_lock);
    245  1.25  knakahar 	ret = ip6flow_init_locked(table_size);
    246  1.25  knakahar 	mutex_exit(&ip6flow_lock);
    247  1.30  knakahar 	ip6flow_sysctl_init(NULL);
    248  1.25  knakahar 
    249  1.25  knakahar 	return ret;
    250  1.25  knakahar }
    251  1.25  knakahar 
    252   1.1  liamjfoy /*
    253   1.1  liamjfoy  * IPv6 Fast Forward routine. Attempt to forward the packet -
    254   1.1  liamjfoy  * if any problems are found return to the main IPv6 input
    255   1.1  liamjfoy  * routine to deal with.
    256   1.1  liamjfoy  */
    257   1.1  liamjfoy int
    258  1.20  christos ip6flow_fastforward(struct mbuf **mp)
    259   1.1  liamjfoy {
    260   1.1  liamjfoy 	struct ip6flow *ip6f;
    261   1.1  liamjfoy 	struct ip6_hdr *ip6;
    262   1.1  liamjfoy 	struct rtentry *rt;
    263  1.20  christos 	struct mbuf *m;
    264   1.7    dyoung 	const struct sockaddr *dst;
    265   1.1  liamjfoy 	int error;
    266  1.25  knakahar 	int ret = 0;
    267  1.25  knakahar 
    268  1.25  knakahar 	mutex_enter(&ip6flow_lock);
    269   1.1  liamjfoy 
    270   1.1  liamjfoy 	/*
    271   1.1  liamjfoy 	 * Are we forwarding packets and have flows?
    272   1.1  liamjfoy 	 */
    273   1.1  liamjfoy 	if (!ip6_forwarding || ip6flow_inuse == 0)
    274  1.25  knakahar 		goto out;
    275   1.1  liamjfoy 
    276  1.20  christos 	m = *mp;
    277   1.1  liamjfoy 	/*
    278   1.1  liamjfoy 	 * At least size of IPv6 Header?
    279   1.1  liamjfoy 	 */
    280   1.1  liamjfoy 	if (m->m_len < sizeof(struct ip6_hdr))
    281  1.25  knakahar 		goto out;
    282   1.1  liamjfoy 	/*
    283   1.1  liamjfoy 	 * Was packet received as a link-level multicast or broadcast?
    284   1.1  liamjfoy 	 * If so, don't try to fast forward.
    285   1.1  liamjfoy 	 */
    286   1.1  liamjfoy 	if ((m->m_flags & (M_BCAST|M_MCAST)) != 0)
    287  1.25  knakahar 		goto out;
    288   1.1  liamjfoy 
    289  1.13    dyoung 	if (IP6_HDR_ALIGNED_P(mtod(m, const void *)) == 0) {
    290   1.1  liamjfoy 		if ((m = m_copyup(m, sizeof(struct ip6_hdr),
    291   1.1  liamjfoy 				(max_linkhdr + 3) & ~3)) == NULL) {
    292  1.25  knakahar 			goto out;
    293   1.1  liamjfoy 		}
    294  1.20  christos 		*mp = m;
    295   1.1  liamjfoy 	} else if (__predict_false(m->m_len < sizeof(struct ip6_hdr))) {
    296   1.1  liamjfoy 		if ((m = m_pullup(m, sizeof(struct ip6_hdr))) == NULL) {
    297  1.25  knakahar 			goto out;
    298   1.1  liamjfoy 		}
    299  1.20  christos 		*mp = m;
    300   1.1  liamjfoy 	}
    301   1.1  liamjfoy 
    302   1.1  liamjfoy 	ip6 = mtod(m, struct ip6_hdr *);
    303   1.1  liamjfoy 
    304   1.1  liamjfoy 	if ((ip6->ip6_vfc & IPV6_VERSION_MASK) != IPV6_VERSION) {
    305   1.1  liamjfoy 		/* Bad version. */
    306  1.25  knakahar 		goto out;
    307   1.1  liamjfoy 	}
    308   1.1  liamjfoy 
    309   1.1  liamjfoy 	/*
    310   1.1  liamjfoy 	 * If we have a hop-by-hop extension we must process it.
    311   1.1  liamjfoy 	 * We just leave this up to ip6_input to deal with.
    312   1.1  liamjfoy 	 */
    313   1.1  liamjfoy 	if (ip6->ip6_nxt == IPPROTO_HOPOPTS)
    314  1.25  knakahar 		goto out;
    315   1.1  liamjfoy 
    316   1.1  liamjfoy 	/*
    317   1.1  liamjfoy 	 * Attempt to find a flow.
    318   1.1  liamjfoy 	 */
    319   1.1  liamjfoy 	if ((ip6f = ip6flow_lookup(ip6)) == NULL) {
    320   1.1  liamjfoy 		/* No flow found. */
    321  1.25  knakahar 		goto out;
    322   1.1  liamjfoy 	}
    323   1.1  liamjfoy 
    324   1.1  liamjfoy 	/*
    325   1.1  liamjfoy 	 * Route and interface still up?
    326   1.1  liamjfoy 	 */
    327  1.12    dyoung 	if ((rt = rtcache_validate(&ip6f->ip6f_ro)) == NULL ||
    328  1.24       roy 	    (rt->rt_ifp->if_flags & IFF_UP) == 0 ||
    329  1.24       roy 	    (rt->rt_flags & RTF_BLACKHOLE) != 0)
    330  1.25  knakahar 		goto out;
    331   1.1  liamjfoy 
    332   1.1  liamjfoy 	/*
    333   1.1  liamjfoy 	 * Packet size greater than MTU?
    334   1.1  liamjfoy 	 */
    335   1.1  liamjfoy 	if (m->m_pkthdr.len > rt->rt_ifp->if_mtu) {
    336   1.1  liamjfoy 		/* Return to main IPv6 input function. */
    337  1.25  knakahar 		goto out;
    338   1.1  liamjfoy 	}
    339   1.1  liamjfoy 
    340  1.21   msaitoh 	/*
    341  1.21   msaitoh 	 * Clear any in-bound checksum flags for this packet.
    342  1.21   msaitoh 	 */
    343  1.21   msaitoh 	m->m_pkthdr.csum_flags = 0;
    344  1.21   msaitoh 
    345   1.1  liamjfoy 	if (ip6->ip6_hlim <= IPV6_HLIMDEC)
    346  1.25  knakahar 		goto out;
    347   1.1  liamjfoy 
    348   1.1  liamjfoy 	/* Decrement hop limit (same as TTL) */
    349   1.1  liamjfoy 	ip6->ip6_hlim -= IPV6_HLIMDEC;
    350   1.1  liamjfoy 
    351   1.1  liamjfoy 	if (rt->rt_flags & RTF_GATEWAY)
    352   1.7    dyoung 		dst = rt->rt_gateway;
    353   1.1  liamjfoy 	else
    354   1.7    dyoung 		dst = rtcache_getdst(&ip6f->ip6f_ro);
    355   1.1  liamjfoy 
    356   1.1  liamjfoy 	PRT_SLOW_ARM(ip6f->ip6f_timer, IP6FLOW_TIMER);
    357   1.1  liamjfoy 
    358   1.1  liamjfoy 	ip6f->ip6f_uses++;
    359   1.1  liamjfoy 
    360  1.31  knakahar #if 0
    361  1.31  knakahar 	/*
    362  1.31  knakahar 	 * We use FIFO cache replacement instead of LRU the same ip_flow.c.
    363  1.31  knakahar 	 */
    364  1.31  knakahar 	/* move to head (LRU) for ip6flowlist. ip6flowtable does not care LRU. */
    365  1.31  knakahar 	TAILQ_REMOVE(&ip6flowlist, ip6f, ip6f_list);
    366  1.31  knakahar 	TAILQ_INSERT_HEAD(&ip6flowlist, ip6f, ip6f_list);
    367  1.31  knakahar #endif
    368  1.31  knakahar 
    369   1.1  liamjfoy 	/* Send on its way - straight to the interface output routine. */
    370  1.27  knakahar 	if ((error = if_output_lock(rt->rt_ifp, rt->rt_ifp, m, dst, rt)) != 0) {
    371   1.1  liamjfoy 		ip6f->ip6f_dropped++;
    372   1.1  liamjfoy 	} else {
    373   1.1  liamjfoy 		ip6f->ip6f_forwarded++;
    374   1.1  liamjfoy 	}
    375  1.25  knakahar 	ret = 1;
    376  1.25  knakahar  out:
    377  1.25  knakahar 	mutex_exit(&ip6flow_lock);
    378  1.25  knakahar 	return ret;
    379   1.1  liamjfoy }
    380   1.1  liamjfoy 
    381   1.1  liamjfoy /*
    382   1.1  liamjfoy  * Add the IPv6 flow statistics to the main IPv6 statistics.
    383   1.1  liamjfoy  */
    384   1.1  liamjfoy static void
    385  1.13    dyoung ip6flow_addstats(const struct ip6flow *ip6f)
    386   1.1  liamjfoy {
    387  1.11    dyoung 	struct rtentry *rt;
    388  1.15   thorpej 	uint64_t *ip6s;
    389  1.11    dyoung 
    390  1.12    dyoung 	if ((rt = rtcache_validate(&ip6f->ip6f_ro)) != NULL)
    391  1.11    dyoung 		rt->rt_use += ip6f->ip6f_uses;
    392  1.15   thorpej 	ip6s = IP6_STAT_GETREF();
    393  1.15   thorpej 	ip6s[IP6_STAT_FASTFORWARDFLOWS] = ip6flow_inuse;
    394  1.15   thorpej 	ip6s[IP6_STAT_CANTFORWARD] += ip6f->ip6f_dropped;
    395  1.15   thorpej 	ip6s[IP6_STAT_ODROPPED] += ip6f->ip6f_dropped;
    396  1.15   thorpej 	ip6s[IP6_STAT_TOTAL] += ip6f->ip6f_uses;
    397  1.15   thorpej 	ip6s[IP6_STAT_FORWARD] += ip6f->ip6f_forwarded;
    398  1.15   thorpej 	ip6s[IP6_STAT_FASTFORWARD] += ip6f->ip6f_forwarded;
    399  1.15   thorpej 	IP6_STAT_PUTREF();
    400   1.1  liamjfoy }
    401   1.1  liamjfoy 
    402   1.1  liamjfoy /*
    403   1.1  liamjfoy  * Add statistics and free the flow.
    404   1.1  liamjfoy  */
    405   1.1  liamjfoy static void
    406   1.1  liamjfoy ip6flow_free(struct ip6flow *ip6f)
    407   1.1  liamjfoy {
    408   1.1  liamjfoy 
    409  1.25  knakahar 	KASSERT(mutex_owned(&ip6flow_lock));
    410  1.25  knakahar 
    411   1.1  liamjfoy 	/*
    412   1.1  liamjfoy 	 * Remove the flow from the hash table (at elevated IPL).
    413   1.1  liamjfoy 	 * Once it's off the list, we can deal with it at normal
    414   1.1  liamjfoy 	 * network IPL.
    415   1.1  liamjfoy 	 */
    416  1.31  knakahar 	IP6FLOW_REMOVE(ip6f->ip6f_hashidx, ip6f);
    417  1.26  knakahar 
    418   1.1  liamjfoy 	ip6flow_inuse--;
    419   1.1  liamjfoy 	ip6flow_addstats(ip6f);
    420   1.7    dyoung 	rtcache_free(&ip6f->ip6f_ro);
    421   1.1  liamjfoy 	pool_put(&ip6flow_pool, ip6f);
    422   1.1  liamjfoy }
    423   1.1  liamjfoy 
    424  1.25  knakahar static struct ip6flow *
    425  1.25  knakahar ip6flow_reap_locked(int just_one)
    426   1.1  liamjfoy {
    427  1.31  knakahar 	struct ip6flow *ip6f;
    428  1.25  knakahar 
    429  1.25  knakahar 	KASSERT(mutex_owned(&ip6flow_lock));
    430  1.25  knakahar 
    431  1.31  knakahar 	/*
    432  1.31  knakahar 	 * This case must remove one ip6flow. Furthermore, this case is used in
    433  1.31  knakahar 	 * fast path(packet processing path). So, simply remove TAILQ_LAST one.
    434  1.31  knakahar 	 */
    435  1.31  knakahar 	if (just_one) {
    436  1.31  knakahar 		ip6f = TAILQ_LAST(&ip6flowlist, ip6flowhead);
    437  1.31  knakahar 		KASSERT(ip6f != NULL);
    438  1.31  knakahar 
    439  1.31  knakahar 		IP6FLOW_REMOVE(ip6f->ip6f_hashidx, ip6f);
    440  1.31  knakahar 
    441  1.31  knakahar 		ip6flow_addstats(ip6f);
    442  1.31  knakahar 		rtcache_free(&ip6f->ip6f_ro);
    443  1.31  knakahar 		return ip6f;
    444  1.31  knakahar 	}
    445   1.1  liamjfoy 
    446  1.31  knakahar 	/*
    447  1.31  knakahar 	 * This case is used in slow path(sysctl).
    448  1.31  knakahar 	 * At first, remove invalid rtcache ip6flow, and then remove TAILQ_LAST
    449  1.31  knakahar 	 * ip6flow if it is ensured least recently used by comparing last_uses.
    450  1.31  knakahar 	 */
    451  1.31  knakahar 	while (ip6flow_inuse > ip6_maxflows) {
    452  1.31  knakahar 		struct ip6flow *maybe_ip6f = TAILQ_LAST(&ip6flowlist, ip6flowhead);
    453  1.31  knakahar 
    454  1.31  knakahar 		TAILQ_FOREACH(ip6f, &ip6flowlist, ip6f_list) {
    455   1.1  liamjfoy 			/*
    456   1.1  liamjfoy 			 * If this no longer points to a valid route -
    457   1.1  liamjfoy 			 * reclaim it.
    458   1.1  liamjfoy 			 */
    459  1.12    dyoung 			if (rtcache_validate(&ip6f->ip6f_ro) == NULL)
    460   1.1  liamjfoy 				goto done;
    461   1.1  liamjfoy 			/*
    462   1.1  liamjfoy 			 * choose the one that's been least recently
    463   1.1  liamjfoy 			 * used or has had the least uses in the
    464   1.1  liamjfoy 			 * last 1.5 intervals.
    465   1.1  liamjfoy 			 */
    466  1.31  knakahar 			if (ip6f->ip6f_timer < maybe_ip6f->ip6f_timer
    467  1.31  knakahar 			    || ((ip6f->ip6f_timer == maybe_ip6f->ip6f_timer)
    468  1.31  knakahar 				&& (ip6f->ip6f_last_uses + ip6f->ip6f_uses
    469  1.31  knakahar 				    < maybe_ip6f->ip6f_last_uses + maybe_ip6f->ip6f_uses)))
    470   1.1  liamjfoy 				maybe_ip6f = ip6f;
    471   1.1  liamjfoy 		}
    472   1.1  liamjfoy 		ip6f = maybe_ip6f;
    473   1.1  liamjfoy 	    done:
    474   1.1  liamjfoy 		/*
    475   1.1  liamjfoy 		 * Remove the entry from the flow table
    476   1.1  liamjfoy 		 */
    477  1.31  knakahar 		IP6FLOW_REMOVE(ip6f->ip6f_hashidx, ip6f);
    478  1.26  knakahar 
    479   1.7    dyoung 		rtcache_free(&ip6f->ip6f_ro);
    480   1.1  liamjfoy 		ip6flow_inuse--;
    481   1.1  liamjfoy 		ip6flow_addstats(ip6f);
    482   1.1  liamjfoy 		pool_put(&ip6flow_pool, ip6f);
    483   1.1  liamjfoy 	}
    484   1.1  liamjfoy 	return NULL;
    485   1.1  liamjfoy }
    486   1.1  liamjfoy 
    487  1.25  knakahar /*
    488  1.25  knakahar  * Reap one or more flows - ip6flow_reap may remove
    489  1.25  knakahar  * multiple flows if net.inet6.ip6.maxflows is reduced.
    490  1.25  knakahar  */
    491  1.25  knakahar struct ip6flow *
    492  1.25  knakahar ip6flow_reap(int just_one)
    493  1.25  knakahar {
    494  1.25  knakahar 	struct ip6flow *ip6f;
    495  1.25  knakahar 
    496  1.25  knakahar 	mutex_enter(&ip6flow_lock);
    497  1.25  knakahar 	ip6f = ip6flow_reap_locked(just_one);
    498  1.25  knakahar 	mutex_exit(&ip6flow_lock);
    499  1.25  knakahar 	return ip6f;
    500  1.25  knakahar }
    501  1.25  knakahar 
    502  1.29     ozaki static unsigned int ip6flow_work_enqueued = 0;
    503  1.28     ozaki 
    504   1.1  liamjfoy void
    505  1.28     ozaki ip6flow_slowtimo_work(struct work *wk, void *arg)
    506   1.1  liamjfoy {
    507   1.1  liamjfoy 	struct ip6flow *ip6f, *next_ip6f;
    508   1.1  liamjfoy 
    509  1.29     ozaki 	/* We can allow enqueuing another work at this point */
    510  1.29     ozaki 	atomic_swap_uint(&ip6flow_work_enqueued, 0);
    511  1.29     ozaki 
    512  1.32     ozaki #ifndef NET_MPSAFE
    513  1.16        ad 	mutex_enter(softnet_lock);
    514  1.32     ozaki 	KERNEL_LOCK(1, NULL);
    515  1.32     ozaki #endif
    516  1.25  knakahar 	mutex_enter(&ip6flow_lock);
    517  1.16        ad 
    518  1.31  knakahar 	for (ip6f = TAILQ_FIRST(&ip6flowlist); ip6f != NULL; ip6f = next_ip6f) {
    519  1.31  knakahar 		next_ip6f = TAILQ_NEXT(ip6f, ip6f_list);
    520   1.1  liamjfoy 		if (PRT_SLOW_ISEXPIRED(ip6f->ip6f_timer) ||
    521  1.12    dyoung 		    rtcache_validate(&ip6f->ip6f_ro) == NULL) {
    522   1.1  liamjfoy 			ip6flow_free(ip6f);
    523   1.1  liamjfoy 		} else {
    524   1.1  liamjfoy 			ip6f->ip6f_last_uses = ip6f->ip6f_uses;
    525   1.1  liamjfoy 			ip6flow_addstats(ip6f);
    526   1.1  liamjfoy 			ip6f->ip6f_uses = 0;
    527   1.1  liamjfoy 			ip6f->ip6f_dropped = 0;
    528   1.1  liamjfoy 			ip6f->ip6f_forwarded = 0;
    529   1.1  liamjfoy 		}
    530   1.1  liamjfoy 	}
    531  1.16        ad 
    532  1.32     ozaki 	mutex_exit(&ip6flow_lock);
    533  1.32     ozaki #ifndef NET_MPSAFE
    534  1.16        ad 	KERNEL_UNLOCK_ONE(NULL);
    535  1.16        ad 	mutex_exit(softnet_lock);
    536  1.32     ozaki #endif
    537   1.1  liamjfoy }
    538   1.1  liamjfoy 
    539  1.28     ozaki void
    540  1.28     ozaki ip6flow_slowtimo(void)
    541  1.28     ozaki {
    542  1.28     ozaki 
    543  1.28     ozaki 	/* Avoid enqueuing another work when one is already enqueued */
    544  1.29     ozaki 	if (atomic_swap_uint(&ip6flow_work_enqueued, 1) == 1)
    545  1.28     ozaki 		return;
    546  1.28     ozaki 
    547  1.28     ozaki 	workqueue_enqueue(ip6flow_slowtimo_wq, &ip6flow_slowtimo_wk, NULL);
    548  1.28     ozaki }
    549  1.28     ozaki 
    550   1.1  liamjfoy /*
    551   1.1  liamjfoy  * We have successfully forwarded a packet using the normal
    552   1.1  liamjfoy  * IPv6 stack. Now create/update a flow.
    553   1.1  liamjfoy  */
    554   1.1  liamjfoy void
    555   1.7    dyoung ip6flow_create(const struct route *ro, struct mbuf *m)
    556   1.1  liamjfoy {
    557  1.13    dyoung 	const struct ip6_hdr *ip6;
    558   1.1  liamjfoy 	struct ip6flow *ip6f;
    559   1.1  liamjfoy 	size_t hash;
    560   1.1  liamjfoy 
    561  1.32     ozaki 	ip6 = mtod(m, const struct ip6_hdr *);
    562  1.32     ozaki 
    563  1.32     ozaki #ifndef NET_MPSAFE
    564  1.32     ozaki 	KERNEL_LOCK(1, NULL);
    565  1.32     ozaki #endif
    566  1.25  knakahar 	mutex_enter(&ip6flow_lock);
    567  1.25  knakahar 
    568   1.1  liamjfoy 	/*
    569   1.1  liamjfoy 	 * If IPv6 Fast Forward is disabled, don't create a flow.
    570   1.1  liamjfoy 	 * It can be disabled by setting net.inet6.ip6.maxflows to 0.
    571   1.1  liamjfoy 	 *
    572   1.1  liamjfoy 	 * Don't create a flow for ICMPv6 messages.
    573   1.1  liamjfoy 	 */
    574  1.32     ozaki 	if (ip6_maxflows == 0 || ip6->ip6_nxt == IPPROTO_IPV6_ICMP)
    575  1.32     ozaki 		goto out;
    576  1.22     pooka 
    577   1.1  liamjfoy 	/*
    578   1.1  liamjfoy 	 * See if an existing flow exists.  If so:
    579   1.1  liamjfoy 	 *	- Remove the flow
    580   1.1  liamjfoy 	 *	- Add flow statistics
    581   1.1  liamjfoy 	 *	- Free the route
    582   1.1  liamjfoy 	 *	- Reset statistics
    583   1.1  liamjfoy 	 *
    584   1.1  liamjfoy 	 * If a flow doesn't exist allocate a new one if
    585   1.1  liamjfoy 	 * ip6_maxflows hasn't reached its limit. If it has
    586   1.1  liamjfoy 	 * been reached, reap some flows.
    587   1.1  liamjfoy 	 */
    588   1.1  liamjfoy 	ip6f = ip6flow_lookup(ip6);
    589   1.1  liamjfoy 	if (ip6f == NULL) {
    590   1.1  liamjfoy 		if (ip6flow_inuse >= ip6_maxflows) {
    591  1.25  knakahar 			ip6f = ip6flow_reap_locked(1);
    592   1.1  liamjfoy 		} else {
    593   1.1  liamjfoy 			ip6f = pool_get(&ip6flow_pool, PR_NOWAIT);
    594   1.1  liamjfoy 			if (ip6f == NULL)
    595  1.22     pooka 				goto out;
    596   1.1  liamjfoy 			ip6flow_inuse++;
    597   1.1  liamjfoy 		}
    598   1.1  liamjfoy 		memset(ip6f, 0, sizeof(*ip6f));
    599   1.1  liamjfoy 	} else {
    600  1.31  knakahar 		IP6FLOW_REMOVE(ip6f->ip6f_hashidx, ip6f);
    601  1.26  knakahar 
    602   1.1  liamjfoy 		ip6flow_addstats(ip6f);
    603   1.7    dyoung 		rtcache_free(&ip6f->ip6f_ro);
    604   1.1  liamjfoy 		ip6f->ip6f_uses = 0;
    605   1.1  liamjfoy 		ip6f->ip6f_last_uses = 0;
    606   1.1  liamjfoy 		ip6f->ip6f_dropped = 0;
    607   1.1  liamjfoy 		ip6f->ip6f_forwarded = 0;
    608   1.1  liamjfoy 	}
    609   1.1  liamjfoy 
    610   1.1  liamjfoy 	/*
    611   1.1  liamjfoy 	 * Fill in the updated/new details.
    612   1.1  liamjfoy 	 */
    613   1.7    dyoung 	rtcache_copy(&ip6f->ip6f_ro, ro);
    614   1.1  liamjfoy 	ip6f->ip6f_dst = ip6->ip6_dst;
    615   1.1  liamjfoy 	ip6f->ip6f_src = ip6->ip6_src;
    616   1.1  liamjfoy 	ip6f->ip6f_flow = ip6->ip6_flow;
    617   1.1  liamjfoy 	PRT_SLOW_ARM(ip6f->ip6f_timer, IP6FLOW_TIMER);
    618   1.1  liamjfoy 
    619   1.1  liamjfoy 	/*
    620   1.1  liamjfoy 	 * Insert into the approriate bucket of the flow table.
    621   1.1  liamjfoy 	 */
    622   1.1  liamjfoy 	hash = ip6flow_hash(ip6);
    623  1.31  knakahar 	IP6FLOW_INSERT(hash, ip6f);
    624  1.22     pooka 
    625  1.22     pooka  out:
    626  1.32     ozaki 	mutex_exit(&ip6flow_lock);
    627  1.32     ozaki #ifndef NET_MPSAFE
    628  1.22     pooka 	KERNEL_UNLOCK_ONE(NULL);
    629  1.32     ozaki #endif
    630   1.1  liamjfoy }
    631   1.1  liamjfoy 
    632   1.1  liamjfoy /*
    633   1.4  liamjfoy  * Invalidate/remove all flows - if new_size is positive we
    634   1.4  liamjfoy  * resize the hash table.
    635   1.1  liamjfoy  */
    636   1.4  liamjfoy int
    637   1.4  liamjfoy ip6flow_invalidate_all(int new_size)
    638   1.1  liamjfoy {
    639   1.1  liamjfoy 	struct ip6flow *ip6f, *next_ip6f;
    640  1.26  knakahar 	int error;
    641   1.1  liamjfoy 
    642   1.4  liamjfoy 	error = 0;
    643  1.25  knakahar 
    644  1.25  knakahar 	mutex_enter(&ip6flow_lock);
    645  1.25  knakahar 
    646  1.31  knakahar 	for (ip6f = TAILQ_FIRST(&ip6flowlist); ip6f != NULL; ip6f = next_ip6f) {
    647  1.31  knakahar 		next_ip6f = TAILQ_NEXT(ip6f, ip6f_list);
    648   1.1  liamjfoy 		ip6flow_free(ip6f);
    649   1.1  liamjfoy 	}
    650   1.4  liamjfoy 
    651   1.4  liamjfoy 	if (new_size)
    652  1.25  knakahar 		error = ip6flow_init_locked(new_size);
    653   1.4  liamjfoy 
    654  1.25  knakahar 	mutex_exit(&ip6flow_lock);
    655  1.25  knakahar 
    656   1.4  liamjfoy 	return error;
    657   1.1  liamjfoy }
    658  1.30  knakahar 
    659  1.30  knakahar /*
    660  1.30  knakahar  * sysctl helper routine for net.inet.ip6.maxflows. Since
    661  1.30  knakahar  * we could reduce this value, call ip6flow_reap();
    662  1.30  knakahar  */
    663  1.30  knakahar static int
    664  1.30  knakahar sysctl_net_inet6_ip6_maxflows(SYSCTLFN_ARGS)
    665  1.30  knakahar {
    666  1.30  knakahar 	int error;
    667  1.30  knakahar 
    668  1.30  knakahar 	error = sysctl_lookup(SYSCTLFN_CALL(rnode));
    669  1.30  knakahar 	if (error || newp == NULL)
    670  1.30  knakahar 		return (error);
    671  1.30  knakahar 
    672  1.32     ozaki #ifndef NET_MPSAFE
    673  1.30  knakahar 	mutex_enter(softnet_lock);
    674  1.30  knakahar 	KERNEL_LOCK(1, NULL);
    675  1.32     ozaki #endif
    676  1.30  knakahar 
    677  1.30  knakahar 	ip6flow_reap(0);
    678  1.30  knakahar 
    679  1.32     ozaki #ifndef NET_MPSAFE
    680  1.30  knakahar 	KERNEL_UNLOCK_ONE(NULL);
    681  1.30  knakahar 	mutex_exit(softnet_lock);
    682  1.32     ozaki #endif
    683  1.30  knakahar 
    684  1.30  knakahar 	return (0);
    685  1.30  knakahar }
    686  1.30  knakahar 
    687  1.30  knakahar static int
    688  1.30  knakahar sysctl_net_inet6_ip6_hashsize(SYSCTLFN_ARGS)
    689  1.30  knakahar {
    690  1.30  knakahar 	int error, tmp;
    691  1.30  knakahar 	struct sysctlnode node;
    692  1.30  knakahar 
    693  1.30  knakahar 	node = *rnode;
    694  1.30  knakahar 	tmp = ip6_hashsize;
    695  1.30  knakahar 	node.sysctl_data = &tmp;
    696  1.30  knakahar 	error = sysctl_lookup(SYSCTLFN_CALL(&node));
    697  1.30  knakahar 	if (error || newp == NULL)
    698  1.30  knakahar 		return (error);
    699  1.30  knakahar 
    700  1.30  knakahar 	if ((tmp & (tmp - 1)) == 0 && tmp != 0) {
    701  1.30  knakahar 		/*
    702  1.30  knakahar 		 * Can only fail due to malloc()
    703  1.30  knakahar 		 */
    704  1.32     ozaki #ifndef NET_MPSAFE
    705  1.30  knakahar 		mutex_enter(softnet_lock);
    706  1.30  knakahar 		KERNEL_LOCK(1, NULL);
    707  1.32     ozaki #endif
    708  1.30  knakahar 		error = ip6flow_invalidate_all(tmp);
    709  1.32     ozaki #ifndef NET_MPSAFE
    710  1.30  knakahar 		KERNEL_UNLOCK_ONE(NULL);
    711  1.30  knakahar 		mutex_exit(softnet_lock);
    712  1.32     ozaki #endif
    713  1.30  knakahar 	} else {
    714  1.30  knakahar 		/*
    715  1.30  knakahar 		 * EINVAL if not a power of 2
    716  1.30  knakahar 		 */
    717  1.30  knakahar 		error = EINVAL;
    718  1.30  knakahar 	}
    719  1.30  knakahar 
    720  1.30  knakahar 	return error;
    721  1.30  knakahar }
    722  1.30  knakahar 
    723  1.30  knakahar static void
    724  1.30  knakahar ip6flow_sysctl_init(struct sysctllog **clog)
    725  1.30  knakahar {
    726  1.30  knakahar 
    727  1.30  knakahar 	sysctl_createv(clog, 0, NULL, NULL,
    728  1.30  knakahar 		       CTLFLAG_PERMANENT,
    729  1.30  knakahar 		       CTLTYPE_NODE, "inet6",
    730  1.30  knakahar 		       SYSCTL_DESCR("PF_INET6 related settings"),
    731  1.30  knakahar 		       NULL, 0, NULL, 0,
    732  1.30  knakahar 		       CTL_NET, PF_INET6, CTL_EOL);
    733  1.30  knakahar 	sysctl_createv(clog, 0, NULL, NULL,
    734  1.30  knakahar 		       CTLFLAG_PERMANENT,
    735  1.30  knakahar 		       CTLTYPE_NODE, "ip6",
    736  1.30  knakahar 		       SYSCTL_DESCR("IPv6 related settings"),
    737  1.30  knakahar 		       NULL, 0, NULL, 0,
    738  1.30  knakahar 		       CTL_NET, PF_INET6, IPPROTO_IPV6, CTL_EOL);
    739  1.30  knakahar 
    740  1.30  knakahar 	sysctl_createv(clog, 0, NULL, NULL,
    741  1.30  knakahar 			CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
    742  1.30  knakahar 			CTLTYPE_INT, "maxflows",
    743  1.30  knakahar 			SYSCTL_DESCR("Number of flows for fast forwarding (IPv6)"),
    744  1.30  knakahar 			sysctl_net_inet6_ip6_maxflows, 0, &ip6_maxflows, 0,
    745  1.30  knakahar 			CTL_NET, PF_INET6, IPPROTO_IPV6,
    746  1.30  knakahar 			CTL_CREATE, CTL_EOL);
    747  1.30  knakahar 	sysctl_createv(clog, 0, NULL, NULL,
    748  1.30  knakahar 			CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
    749  1.30  knakahar 			CTLTYPE_INT, "hashsize",
    750  1.30  knakahar 			SYSCTL_DESCR("Size of hash table for fast forwarding (IPv6)"),
    751  1.30  knakahar 			sysctl_net_inet6_ip6_hashsize, 0, &ip6_hashsize, 0,
    752  1.30  knakahar 			CTL_NET, PF_INET6, IPPROTO_IPV6,
    753  1.30  knakahar 			CTL_CREATE, CTL_EOL);
    754  1.30  knakahar }
    755