ip6_flow.c revision 1.28.2.3 1 1.28.2.3 pgoyette /* $NetBSD: ip6_flow.c,v 1.28.2.3 2017/01/07 08:56:51 pgoyette 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.28.2.3 pgoyette __KERNEL_RCSID(0, "$NetBSD: ip6_flow.c,v 1.28.2.3 2017/01/07 08:56:51 pgoyette Exp $");
42 1.28.2.2 pgoyette
43 1.28.2.2 pgoyette #ifdef _KERNEL_OPT
44 1.28.2.2 pgoyette #include "opt_net_mpsafe.h"
45 1.28.2.2 pgoyette #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.28.2.1 pgoyette #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.1 liamjfoy LIST_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.28.2.1 pgoyette static int sysctl_net_inet6_ip6_hashsize(SYSCTLFN_PROTO);
114 1.28.2.1 pgoyette static int sysctl_net_inet6_ip6_maxflows(SYSCTLFN_PROTO);
115 1.28.2.1 pgoyette static void ip6flow_sysctl_init(struct sysctllog **);
116 1.28.2.1 pgoyette
117 1.1 liamjfoy /*
118 1.1 liamjfoy * Insert an ip6flow into the list.
119 1.1 liamjfoy */
120 1.1 liamjfoy #define IP6FLOW_INSERT(bucket, ip6f) \
121 1.1 liamjfoy do { \
122 1.1 liamjfoy LIST_INSERT_HEAD((bucket), (ip6f), ip6f_hash); \
123 1.1 liamjfoy LIST_INSERT_HEAD(&ip6flowlist, (ip6f), ip6f_list); \
124 1.1 liamjfoy } while (/*CONSTCOND*/ 0)
125 1.1 liamjfoy
126 1.1 liamjfoy /*
127 1.1 liamjfoy * Remove an ip6flow from the list.
128 1.1 liamjfoy */
129 1.1 liamjfoy #define IP6FLOW_REMOVE(ip6f) \
130 1.1 liamjfoy do { \
131 1.1 liamjfoy LIST_REMOVE((ip6f), ip6f_hash); \
132 1.1 liamjfoy LIST_REMOVE((ip6f), ip6f_list); \
133 1.1 liamjfoy } while (/*CONSTCOND*/ 0)
134 1.1 liamjfoy
135 1.1 liamjfoy #ifndef IP6FLOW_DEFAULT
136 1.1 liamjfoy #define IP6FLOW_DEFAULT 256
137 1.1 liamjfoy #endif
138 1.1 liamjfoy
139 1.1 liamjfoy int ip6_maxflows = IP6FLOW_DEFAULT;
140 1.4 liamjfoy int ip6_hashsize = IP6FLOW_DEFAULT_HASHSIZE;
141 1.1 liamjfoy
142 1.1 liamjfoy /*
143 1.1 liamjfoy * Calculate hash table position.
144 1.1 liamjfoy */
145 1.1 liamjfoy static size_t
146 1.13 dyoung ip6flow_hash(const struct ip6_hdr *ip6)
147 1.1 liamjfoy {
148 1.1 liamjfoy size_t hash;
149 1.1 liamjfoy uint32_t dst_sum, src_sum;
150 1.6 liamjfoy size_t idx;
151 1.1 liamjfoy
152 1.1 liamjfoy src_sum = ip6->ip6_src.s6_addr32[0] + ip6->ip6_src.s6_addr32[1]
153 1.1 liamjfoy + ip6->ip6_src.s6_addr32[2] + ip6->ip6_src.s6_addr32[3];
154 1.1 liamjfoy dst_sum = ip6->ip6_dst.s6_addr32[0] + ip6->ip6_dst.s6_addr32[1]
155 1.1 liamjfoy + ip6->ip6_dst.s6_addr32[2] + ip6->ip6_dst.s6_addr32[3];
156 1.1 liamjfoy
157 1.1 liamjfoy hash = ip6->ip6_flow;
158 1.1 liamjfoy
159 1.1 liamjfoy for (idx = 0; idx < 32; idx += IP6FLOW_HASHBITS)
160 1.1 liamjfoy hash += (dst_sum >> (32 - idx)) + (src_sum >> idx);
161 1.1 liamjfoy
162 1.4 liamjfoy return hash & (ip6_hashsize-1);
163 1.1 liamjfoy }
164 1.1 liamjfoy
165 1.1 liamjfoy /*
166 1.1 liamjfoy * Check to see if a flow already exists - if so return it.
167 1.1 liamjfoy */
168 1.1 liamjfoy static struct ip6flow *
169 1.13 dyoung ip6flow_lookup(const struct ip6_hdr *ip6)
170 1.1 liamjfoy {
171 1.1 liamjfoy size_t hash;
172 1.1 liamjfoy struct ip6flow *ip6f;
173 1.1 liamjfoy
174 1.25 knakahar KASSERT(mutex_owned(&ip6flow_lock));
175 1.25 knakahar
176 1.1 liamjfoy hash = ip6flow_hash(ip6);
177 1.1 liamjfoy
178 1.2 liamjfoy LIST_FOREACH(ip6f, &ip6flowtable[hash], ip6f_hash) {
179 1.1 liamjfoy if (IN6_ARE_ADDR_EQUAL(&ip6->ip6_dst, &ip6f->ip6f_dst)
180 1.1 liamjfoy && IN6_ARE_ADDR_EQUAL(&ip6->ip6_src, &ip6f->ip6f_src)
181 1.1 liamjfoy && ip6f->ip6f_flow == ip6->ip6_flow) {
182 1.1 liamjfoy /* A cached flow has been found. */
183 1.1 liamjfoy return ip6f;
184 1.1 liamjfoy }
185 1.1 liamjfoy }
186 1.1 liamjfoy
187 1.1 liamjfoy return NULL;
188 1.1 liamjfoy }
189 1.1 liamjfoy
190 1.18 liamjfoy void
191 1.18 liamjfoy ip6flow_poolinit(void)
192 1.18 liamjfoy {
193 1.18 liamjfoy
194 1.18 liamjfoy pool_init(&ip6flow_pool, sizeof(struct ip6flow), 0, 0, 0, "ip6flowpl",
195 1.18 liamjfoy NULL, IPL_NET);
196 1.18 liamjfoy }
197 1.18 liamjfoy
198 1.1 liamjfoy /*
199 1.4 liamjfoy * Allocate memory and initialise lists. This function is called
200 1.4 liamjfoy * from ip6_init and called there after to resize the hash table.
201 1.4 liamjfoy * If a newly sized table cannot be malloc'ed we just continue
202 1.4 liamjfoy * to use the old one.
203 1.1 liamjfoy */
204 1.25 knakahar static int
205 1.25 knakahar ip6flow_init_locked(int table_size)
206 1.1 liamjfoy {
207 1.4 liamjfoy struct ip6flowhead *new_table;
208 1.1 liamjfoy size_t i;
209 1.1 liamjfoy
210 1.25 knakahar KASSERT(mutex_owned(&ip6flow_lock));
211 1.25 knakahar
212 1.4 liamjfoy new_table = (struct ip6flowhead *)malloc(sizeof(struct ip6flowhead) *
213 1.4 liamjfoy table_size, M_RTABLE, M_NOWAIT);
214 1.4 liamjfoy
215 1.4 liamjfoy if (new_table == NULL)
216 1.4 liamjfoy return 1;
217 1.4 liamjfoy
218 1.4 liamjfoy if (ip6flowtable != NULL)
219 1.4 liamjfoy free(ip6flowtable, M_RTABLE);
220 1.4 liamjfoy
221 1.4 liamjfoy ip6flowtable = new_table;
222 1.4 liamjfoy ip6_hashsize = table_size;
223 1.4 liamjfoy
224 1.1 liamjfoy LIST_INIT(&ip6flowlist);
225 1.4 liamjfoy for (i = 0; i < ip6_hashsize; i++)
226 1.1 liamjfoy LIST_INIT(&ip6flowtable[i]);
227 1.4 liamjfoy
228 1.4 liamjfoy return 0;
229 1.1 liamjfoy }
230 1.1 liamjfoy
231 1.25 knakahar int
232 1.25 knakahar ip6flow_init(int table_size)
233 1.25 knakahar {
234 1.28 ozaki int ret, error;
235 1.28 ozaki
236 1.28 ozaki error = workqueue_create(&ip6flow_slowtimo_wq, "ip6flow_slowtimo",
237 1.28 ozaki ip6flow_slowtimo_work, NULL, PRI_SOFTNET, IPL_SOFTNET, WQ_MPSAFE);
238 1.28 ozaki if (error != 0)
239 1.28 ozaki panic("%s: workqueue_create failed (%d)\n", __func__, error);
240 1.25 knakahar
241 1.25 knakahar mutex_init(&ip6flow_lock, MUTEX_DEFAULT, IPL_NONE);
242 1.25 knakahar
243 1.25 knakahar mutex_enter(&ip6flow_lock);
244 1.25 knakahar ret = ip6flow_init_locked(table_size);
245 1.25 knakahar mutex_exit(&ip6flow_lock);
246 1.28.2.1 pgoyette ip6flow_sysctl_init(NULL);
247 1.25 knakahar
248 1.25 knakahar return ret;
249 1.25 knakahar }
250 1.25 knakahar
251 1.1 liamjfoy /*
252 1.1 liamjfoy * IPv6 Fast Forward routine. Attempt to forward the packet -
253 1.1 liamjfoy * if any problems are found return to the main IPv6 input
254 1.1 liamjfoy * routine to deal with.
255 1.1 liamjfoy */
256 1.1 liamjfoy int
257 1.20 christos ip6flow_fastforward(struct mbuf **mp)
258 1.1 liamjfoy {
259 1.1 liamjfoy struct ip6flow *ip6f;
260 1.1 liamjfoy struct ip6_hdr *ip6;
261 1.28.2.3 pgoyette struct rtentry *rt = NULL;
262 1.20 christos struct mbuf *m;
263 1.7 dyoung const struct sockaddr *dst;
264 1.1 liamjfoy int error;
265 1.25 knakahar int ret = 0;
266 1.25 knakahar
267 1.25 knakahar mutex_enter(&ip6flow_lock);
268 1.1 liamjfoy
269 1.1 liamjfoy /*
270 1.1 liamjfoy * Are we forwarding packets and have flows?
271 1.1 liamjfoy */
272 1.1 liamjfoy if (!ip6_forwarding || ip6flow_inuse == 0)
273 1.25 knakahar goto out;
274 1.1 liamjfoy
275 1.20 christos m = *mp;
276 1.1 liamjfoy /*
277 1.1 liamjfoy * At least size of IPv6 Header?
278 1.1 liamjfoy */
279 1.1 liamjfoy if (m->m_len < sizeof(struct ip6_hdr))
280 1.25 knakahar goto out;
281 1.1 liamjfoy /*
282 1.1 liamjfoy * Was packet received as a link-level multicast or broadcast?
283 1.1 liamjfoy * If so, don't try to fast forward.
284 1.1 liamjfoy */
285 1.1 liamjfoy if ((m->m_flags & (M_BCAST|M_MCAST)) != 0)
286 1.25 knakahar goto out;
287 1.1 liamjfoy
288 1.13 dyoung if (IP6_HDR_ALIGNED_P(mtod(m, const void *)) == 0) {
289 1.1 liamjfoy if ((m = m_copyup(m, sizeof(struct ip6_hdr),
290 1.1 liamjfoy (max_linkhdr + 3) & ~3)) == NULL) {
291 1.25 knakahar goto out;
292 1.1 liamjfoy }
293 1.20 christos *mp = m;
294 1.1 liamjfoy } else if (__predict_false(m->m_len < sizeof(struct ip6_hdr))) {
295 1.1 liamjfoy if ((m = m_pullup(m, sizeof(struct ip6_hdr))) == NULL) {
296 1.25 knakahar goto out;
297 1.1 liamjfoy }
298 1.20 christos *mp = m;
299 1.1 liamjfoy }
300 1.1 liamjfoy
301 1.1 liamjfoy ip6 = mtod(m, struct ip6_hdr *);
302 1.1 liamjfoy
303 1.1 liamjfoy if ((ip6->ip6_vfc & IPV6_VERSION_MASK) != IPV6_VERSION) {
304 1.1 liamjfoy /* Bad version. */
305 1.25 knakahar goto out;
306 1.1 liamjfoy }
307 1.1 liamjfoy
308 1.1 liamjfoy /*
309 1.1 liamjfoy * If we have a hop-by-hop extension we must process it.
310 1.1 liamjfoy * We just leave this up to ip6_input to deal with.
311 1.1 liamjfoy */
312 1.1 liamjfoy if (ip6->ip6_nxt == IPPROTO_HOPOPTS)
313 1.25 knakahar goto out;
314 1.1 liamjfoy
315 1.1 liamjfoy /*
316 1.1 liamjfoy * Attempt to find a flow.
317 1.1 liamjfoy */
318 1.1 liamjfoy if ((ip6f = ip6flow_lookup(ip6)) == NULL) {
319 1.1 liamjfoy /* No flow found. */
320 1.25 knakahar goto out;
321 1.1 liamjfoy }
322 1.1 liamjfoy
323 1.1 liamjfoy /*
324 1.1 liamjfoy * Route and interface still up?
325 1.1 liamjfoy */
326 1.12 dyoung if ((rt = rtcache_validate(&ip6f->ip6f_ro)) == NULL ||
327 1.24 roy (rt->rt_ifp->if_flags & IFF_UP) == 0 ||
328 1.24 roy (rt->rt_flags & RTF_BLACKHOLE) != 0)
329 1.28.2.3 pgoyette goto out_unref;
330 1.1 liamjfoy
331 1.1 liamjfoy /*
332 1.1 liamjfoy * Packet size greater than MTU?
333 1.1 liamjfoy */
334 1.1 liamjfoy if (m->m_pkthdr.len > rt->rt_ifp->if_mtu) {
335 1.1 liamjfoy /* Return to main IPv6 input function. */
336 1.28.2.3 pgoyette goto out_unref;
337 1.1 liamjfoy }
338 1.1 liamjfoy
339 1.21 msaitoh /*
340 1.21 msaitoh * Clear any in-bound checksum flags for this packet.
341 1.21 msaitoh */
342 1.21 msaitoh m->m_pkthdr.csum_flags = 0;
343 1.21 msaitoh
344 1.1 liamjfoy if (ip6->ip6_hlim <= IPV6_HLIMDEC)
345 1.28.2.3 pgoyette goto out_unref;
346 1.1 liamjfoy
347 1.1 liamjfoy /* Decrement hop limit (same as TTL) */
348 1.1 liamjfoy ip6->ip6_hlim -= IPV6_HLIMDEC;
349 1.1 liamjfoy
350 1.1 liamjfoy if (rt->rt_flags & RTF_GATEWAY)
351 1.7 dyoung dst = rt->rt_gateway;
352 1.1 liamjfoy else
353 1.7 dyoung dst = rtcache_getdst(&ip6f->ip6f_ro);
354 1.1 liamjfoy
355 1.1 liamjfoy PRT_SLOW_ARM(ip6f->ip6f_timer, IP6FLOW_TIMER);
356 1.1 liamjfoy
357 1.1 liamjfoy ip6f->ip6f_uses++;
358 1.1 liamjfoy
359 1.1 liamjfoy /* Send on its way - straight to the interface output routine. */
360 1.27 knakahar if ((error = if_output_lock(rt->rt_ifp, rt->rt_ifp, m, dst, rt)) != 0) {
361 1.1 liamjfoy ip6f->ip6f_dropped++;
362 1.1 liamjfoy } else {
363 1.1 liamjfoy ip6f->ip6f_forwarded++;
364 1.1 liamjfoy }
365 1.25 knakahar ret = 1;
366 1.28.2.3 pgoyette out_unref:
367 1.28.2.3 pgoyette rtcache_unref(rt, &ip6f->ip6f_ro);
368 1.28.2.3 pgoyette out:
369 1.25 knakahar mutex_exit(&ip6flow_lock);
370 1.25 knakahar return ret;
371 1.1 liamjfoy }
372 1.1 liamjfoy
373 1.1 liamjfoy /*
374 1.1 liamjfoy * Add the IPv6 flow statistics to the main IPv6 statistics.
375 1.1 liamjfoy */
376 1.1 liamjfoy static void
377 1.28.2.3 pgoyette ip6flow_addstats_rt(struct rtentry *rt, struct ip6flow *ip6f)
378 1.1 liamjfoy {
379 1.15 thorpej uint64_t *ip6s;
380 1.11 dyoung
381 1.28.2.3 pgoyette if (rt != NULL)
382 1.11 dyoung rt->rt_use += ip6f->ip6f_uses;
383 1.15 thorpej ip6s = IP6_STAT_GETREF();
384 1.15 thorpej ip6s[IP6_STAT_FASTFORWARDFLOWS] = ip6flow_inuse;
385 1.15 thorpej ip6s[IP6_STAT_CANTFORWARD] += ip6f->ip6f_dropped;
386 1.15 thorpej ip6s[IP6_STAT_ODROPPED] += ip6f->ip6f_dropped;
387 1.15 thorpej ip6s[IP6_STAT_TOTAL] += ip6f->ip6f_uses;
388 1.15 thorpej ip6s[IP6_STAT_FORWARD] += ip6f->ip6f_forwarded;
389 1.15 thorpej ip6s[IP6_STAT_FASTFORWARD] += ip6f->ip6f_forwarded;
390 1.15 thorpej IP6_STAT_PUTREF();
391 1.1 liamjfoy }
392 1.1 liamjfoy
393 1.28.2.3 pgoyette static void
394 1.28.2.3 pgoyette ip6flow_addstats(struct ip6flow *ip6f)
395 1.28.2.3 pgoyette {
396 1.28.2.3 pgoyette struct rtentry *rt;
397 1.28.2.3 pgoyette
398 1.28.2.3 pgoyette rt = rtcache_validate(&ip6f->ip6f_ro);
399 1.28.2.3 pgoyette ip6flow_addstats_rt(rt, ip6f);
400 1.28.2.3 pgoyette rtcache_unref(rt, &ip6f->ip6f_ro);
401 1.28.2.3 pgoyette }
402 1.28.2.3 pgoyette
403 1.1 liamjfoy /*
404 1.1 liamjfoy * Add statistics and free the flow.
405 1.1 liamjfoy */
406 1.1 liamjfoy static void
407 1.1 liamjfoy ip6flow_free(struct ip6flow *ip6f)
408 1.1 liamjfoy {
409 1.1 liamjfoy
410 1.25 knakahar KASSERT(mutex_owned(&ip6flow_lock));
411 1.25 knakahar
412 1.1 liamjfoy /*
413 1.1 liamjfoy * Remove the flow from the hash table (at elevated IPL).
414 1.1 liamjfoy * Once it's off the list, we can deal with it at normal
415 1.1 liamjfoy * network IPL.
416 1.1 liamjfoy */
417 1.1 liamjfoy IP6FLOW_REMOVE(ip6f);
418 1.26 knakahar
419 1.1 liamjfoy ip6flow_inuse--;
420 1.1 liamjfoy ip6flow_addstats(ip6f);
421 1.7 dyoung rtcache_free(&ip6f->ip6f_ro);
422 1.1 liamjfoy pool_put(&ip6flow_pool, ip6f);
423 1.1 liamjfoy }
424 1.1 liamjfoy
425 1.25 knakahar static struct ip6flow *
426 1.25 knakahar ip6flow_reap_locked(int just_one)
427 1.1 liamjfoy {
428 1.25 knakahar
429 1.25 knakahar KASSERT(mutex_owned(&ip6flow_lock));
430 1.25 knakahar
431 1.1 liamjfoy while (just_one || ip6flow_inuse > ip6_maxflows) {
432 1.1 liamjfoy struct ip6flow *ip6f, *maybe_ip6f = NULL;
433 1.1 liamjfoy
434 1.28.2.3 pgoyette /*
435 1.28.2.3 pgoyette * This case is used in slow path(sysctl).
436 1.28.2.3 pgoyette * At first, remove invalid rtcache ip6flow, and then remove TAILQ_LAST
437 1.28.2.3 pgoyette * ip6flow if it is ensured least recently used by comparing last_uses.
438 1.28.2.3 pgoyette */
439 1.28.2.3 pgoyette while (ip6flow_inuse > ip6_maxflows) {
440 1.28.2.3 pgoyette struct ip6flow *maybe_ip6f = TAILQ_LAST(&ip6flowlist, ip6flowhead);
441 1.28.2.3 pgoyette
442 1.28.2.3 pgoyette TAILQ_FOREACH(ip6f, &ip6flowlist, ip6f_list) {
443 1.28.2.3 pgoyette struct rtentry *rt;
444 1.1 liamjfoy /*
445 1.1 liamjfoy * If this no longer points to a valid route -
446 1.1 liamjfoy * reclaim it.
447 1.1 liamjfoy */
448 1.28.2.3 pgoyette if ((rt = rtcache_validate(&ip6f->ip6f_ro)) == NULL)
449 1.1 liamjfoy goto done;
450 1.28.2.3 pgoyette rtcache_unref(rt, &ip6f->ip6f_ro);
451 1.1 liamjfoy /*
452 1.1 liamjfoy * choose the one that's been least recently
453 1.1 liamjfoy * used or has had the least uses in the
454 1.1 liamjfoy * last 1.5 intervals.
455 1.1 liamjfoy */
456 1.1 liamjfoy if (maybe_ip6f == NULL ||
457 1.1 liamjfoy ip6f->ip6f_timer < maybe_ip6f->ip6f_timer ||
458 1.1 liamjfoy (ip6f->ip6f_timer == maybe_ip6f->ip6f_timer &&
459 1.1 liamjfoy ip6f->ip6f_last_uses + ip6f->ip6f_uses <
460 1.1 liamjfoy maybe_ip6f->ip6f_last_uses +
461 1.1 liamjfoy maybe_ip6f->ip6f_uses))
462 1.1 liamjfoy maybe_ip6f = ip6f;
463 1.1 liamjfoy ip6f = LIST_NEXT(ip6f, ip6f_list);
464 1.1 liamjfoy }
465 1.1 liamjfoy ip6f = maybe_ip6f;
466 1.1 liamjfoy done:
467 1.1 liamjfoy /*
468 1.1 liamjfoy * Remove the entry from the flow table
469 1.1 liamjfoy */
470 1.1 liamjfoy IP6FLOW_REMOVE(ip6f);
471 1.26 knakahar
472 1.7 dyoung rtcache_free(&ip6f->ip6f_ro);
473 1.1 liamjfoy if (just_one) {
474 1.1 liamjfoy ip6flow_addstats(ip6f);
475 1.1 liamjfoy return ip6f;
476 1.1 liamjfoy }
477 1.1 liamjfoy ip6flow_inuse--;
478 1.1 liamjfoy ip6flow_addstats(ip6f);
479 1.1 liamjfoy pool_put(&ip6flow_pool, ip6f);
480 1.1 liamjfoy }
481 1.1 liamjfoy return NULL;
482 1.1 liamjfoy }
483 1.1 liamjfoy
484 1.25 knakahar /*
485 1.25 knakahar * Reap one or more flows - ip6flow_reap may remove
486 1.25 knakahar * multiple flows if net.inet6.ip6.maxflows is reduced.
487 1.25 knakahar */
488 1.25 knakahar struct ip6flow *
489 1.25 knakahar ip6flow_reap(int just_one)
490 1.25 knakahar {
491 1.25 knakahar struct ip6flow *ip6f;
492 1.25 knakahar
493 1.25 knakahar mutex_enter(&ip6flow_lock);
494 1.25 knakahar ip6f = ip6flow_reap_locked(just_one);
495 1.25 knakahar mutex_exit(&ip6flow_lock);
496 1.25 knakahar return ip6f;
497 1.25 knakahar }
498 1.25 knakahar
499 1.28.2.1 pgoyette static unsigned int ip6flow_work_enqueued = 0;
500 1.28 ozaki
501 1.1 liamjfoy void
502 1.28 ozaki ip6flow_slowtimo_work(struct work *wk, void *arg)
503 1.1 liamjfoy {
504 1.1 liamjfoy struct ip6flow *ip6f, *next_ip6f;
505 1.1 liamjfoy
506 1.28.2.1 pgoyette /* We can allow enqueuing another work at this point */
507 1.28.2.1 pgoyette atomic_swap_uint(&ip6flow_work_enqueued, 0);
508 1.28.2.1 pgoyette
509 1.28.2.2 pgoyette #ifndef NET_MPSAFE
510 1.16 ad mutex_enter(softnet_lock);
511 1.16 ad KERNEL_LOCK(1, NULL);
512 1.28.2.2 pgoyette #endif
513 1.28.2.2 pgoyette mutex_enter(&ip6flow_lock);
514 1.16 ad
515 1.28.2.3 pgoyette for (ip6f = TAILQ_FIRST(&ip6flowlist); ip6f != NULL; ip6f = next_ip6f) {
516 1.28.2.3 pgoyette struct rtentry *rt = NULL;
517 1.28.2.3 pgoyette next_ip6f = TAILQ_NEXT(ip6f, ip6f_list);
518 1.1 liamjfoy if (PRT_SLOW_ISEXPIRED(ip6f->ip6f_timer) ||
519 1.28.2.3 pgoyette (rt = rtcache_validate(&ip6f->ip6f_ro)) == NULL) {
520 1.1 liamjfoy ip6flow_free(ip6f);
521 1.1 liamjfoy } else {
522 1.1 liamjfoy ip6f->ip6f_last_uses = ip6f->ip6f_uses;
523 1.28.2.3 pgoyette ip6flow_addstats_rt(rt, ip6f);
524 1.1 liamjfoy ip6f->ip6f_uses = 0;
525 1.1 liamjfoy ip6f->ip6f_dropped = 0;
526 1.1 liamjfoy ip6f->ip6f_forwarded = 0;
527 1.1 liamjfoy }
528 1.28.2.3 pgoyette rtcache_unref(rt, &ip6f->ip6f_ro);
529 1.1 liamjfoy }
530 1.16 ad
531 1.25 knakahar mutex_exit(&ip6flow_lock);
532 1.28.2.2 pgoyette #ifndef NET_MPSAFE
533 1.28.2.2 pgoyette KERNEL_UNLOCK_ONE(NULL);
534 1.16 ad mutex_exit(softnet_lock);
535 1.28.2.2 pgoyette #endif
536 1.1 liamjfoy }
537 1.1 liamjfoy
538 1.28 ozaki void
539 1.28 ozaki ip6flow_slowtimo(void)
540 1.28 ozaki {
541 1.28 ozaki
542 1.28 ozaki /* Avoid enqueuing another work when one is already enqueued */
543 1.28.2.1 pgoyette if (atomic_swap_uint(&ip6flow_work_enqueued, 1) == 1)
544 1.28 ozaki return;
545 1.28 ozaki
546 1.28 ozaki workqueue_enqueue(ip6flow_slowtimo_wq, &ip6flow_slowtimo_wk, NULL);
547 1.28 ozaki }
548 1.28 ozaki
549 1.1 liamjfoy /*
550 1.1 liamjfoy * We have successfully forwarded a packet using the normal
551 1.1 liamjfoy * IPv6 stack. Now create/update a flow.
552 1.1 liamjfoy */
553 1.1 liamjfoy void
554 1.28.2.3 pgoyette ip6flow_create(struct route *ro, struct mbuf *m)
555 1.1 liamjfoy {
556 1.13 dyoung const struct ip6_hdr *ip6;
557 1.1 liamjfoy struct ip6flow *ip6f;
558 1.1 liamjfoy size_t hash;
559 1.1 liamjfoy
560 1.13 dyoung ip6 = mtod(m, const struct ip6_hdr *);
561 1.1 liamjfoy
562 1.28.2.2 pgoyette #ifndef NET_MPSAFE
563 1.28.2.2 pgoyette KERNEL_LOCK(1, NULL);
564 1.28.2.2 pgoyette #endif
565 1.28.2.2 pgoyette mutex_enter(&ip6flow_lock);
566 1.28.2.2 pgoyette
567 1.1 liamjfoy /*
568 1.1 liamjfoy * If IPv6 Fast Forward is disabled, don't create a flow.
569 1.1 liamjfoy * It can be disabled by setting net.inet6.ip6.maxflows to 0.
570 1.1 liamjfoy *
571 1.1 liamjfoy * Don't create a flow for ICMPv6 messages.
572 1.1 liamjfoy */
573 1.28.2.2 pgoyette if (ip6_maxflows == 0 || ip6->ip6_nxt == IPPROTO_IPV6_ICMP)
574 1.28.2.2 pgoyette goto out;
575 1.22 pooka
576 1.1 liamjfoy /*
577 1.1 liamjfoy * See if an existing flow exists. If so:
578 1.1 liamjfoy * - Remove the flow
579 1.1 liamjfoy * - Add flow statistics
580 1.1 liamjfoy * - Free the route
581 1.1 liamjfoy * - Reset statistics
582 1.1 liamjfoy *
583 1.1 liamjfoy * If a flow doesn't exist allocate a new one if
584 1.1 liamjfoy * ip6_maxflows hasn't reached its limit. If it has
585 1.1 liamjfoy * been reached, reap some flows.
586 1.1 liamjfoy */
587 1.1 liamjfoy ip6f = ip6flow_lookup(ip6);
588 1.1 liamjfoy if (ip6f == NULL) {
589 1.1 liamjfoy if (ip6flow_inuse >= ip6_maxflows) {
590 1.25 knakahar ip6f = ip6flow_reap_locked(1);
591 1.1 liamjfoy } else {
592 1.1 liamjfoy ip6f = pool_get(&ip6flow_pool, PR_NOWAIT);
593 1.1 liamjfoy if (ip6f == NULL)
594 1.22 pooka goto out;
595 1.1 liamjfoy ip6flow_inuse++;
596 1.1 liamjfoy }
597 1.1 liamjfoy memset(ip6f, 0, sizeof(*ip6f));
598 1.1 liamjfoy } else {
599 1.1 liamjfoy IP6FLOW_REMOVE(ip6f);
600 1.26 knakahar
601 1.1 liamjfoy ip6flow_addstats(ip6f);
602 1.7 dyoung rtcache_free(&ip6f->ip6f_ro);
603 1.1 liamjfoy ip6f->ip6f_uses = 0;
604 1.1 liamjfoy ip6f->ip6f_last_uses = 0;
605 1.1 liamjfoy ip6f->ip6f_dropped = 0;
606 1.1 liamjfoy ip6f->ip6f_forwarded = 0;
607 1.1 liamjfoy }
608 1.1 liamjfoy
609 1.1 liamjfoy /*
610 1.1 liamjfoy * Fill in the updated/new details.
611 1.1 liamjfoy */
612 1.7 dyoung rtcache_copy(&ip6f->ip6f_ro, ro);
613 1.1 liamjfoy ip6f->ip6f_dst = ip6->ip6_dst;
614 1.1 liamjfoy ip6f->ip6f_src = ip6->ip6_src;
615 1.1 liamjfoy ip6f->ip6f_flow = ip6->ip6_flow;
616 1.1 liamjfoy PRT_SLOW_ARM(ip6f->ip6f_timer, IP6FLOW_TIMER);
617 1.1 liamjfoy
618 1.1 liamjfoy /*
619 1.1 liamjfoy * Insert into the approriate bucket of the flow table.
620 1.1 liamjfoy */
621 1.1 liamjfoy hash = ip6flow_hash(ip6);
622 1.1 liamjfoy IP6FLOW_INSERT(&ip6flowtable[hash], ip6f);
623 1.22 pooka
624 1.22 pooka out:
625 1.25 knakahar mutex_exit(&ip6flow_lock);
626 1.28.2.2 pgoyette #ifndef NET_MPSAFE
627 1.28.2.2 pgoyette KERNEL_UNLOCK_ONE(NULL);
628 1.28.2.2 pgoyette #endif
629 1.1 liamjfoy }
630 1.1 liamjfoy
631 1.1 liamjfoy /*
632 1.4 liamjfoy * Invalidate/remove all flows - if new_size is positive we
633 1.4 liamjfoy * resize the hash table.
634 1.1 liamjfoy */
635 1.4 liamjfoy int
636 1.4 liamjfoy ip6flow_invalidate_all(int new_size)
637 1.1 liamjfoy {
638 1.1 liamjfoy struct ip6flow *ip6f, *next_ip6f;
639 1.26 knakahar int error;
640 1.1 liamjfoy
641 1.4 liamjfoy error = 0;
642 1.25 knakahar
643 1.25 knakahar mutex_enter(&ip6flow_lock);
644 1.25 knakahar
645 1.1 liamjfoy for (ip6f = LIST_FIRST(&ip6flowlist); ip6f != NULL; ip6f = next_ip6f) {
646 1.1 liamjfoy next_ip6f = LIST_NEXT(ip6f, ip6f_list);
647 1.1 liamjfoy ip6flow_free(ip6f);
648 1.1 liamjfoy }
649 1.4 liamjfoy
650 1.4 liamjfoy if (new_size)
651 1.25 knakahar error = ip6flow_init_locked(new_size);
652 1.4 liamjfoy
653 1.25 knakahar mutex_exit(&ip6flow_lock);
654 1.25 knakahar
655 1.4 liamjfoy return error;
656 1.1 liamjfoy }
657 1.28.2.1 pgoyette
658 1.28.2.1 pgoyette /*
659 1.28.2.1 pgoyette * sysctl helper routine for net.inet.ip6.maxflows. Since
660 1.28.2.1 pgoyette * we could reduce this value, call ip6flow_reap();
661 1.28.2.1 pgoyette */
662 1.28.2.1 pgoyette static int
663 1.28.2.1 pgoyette sysctl_net_inet6_ip6_maxflows(SYSCTLFN_ARGS)
664 1.28.2.1 pgoyette {
665 1.28.2.1 pgoyette int error;
666 1.28.2.1 pgoyette
667 1.28.2.1 pgoyette error = sysctl_lookup(SYSCTLFN_CALL(rnode));
668 1.28.2.1 pgoyette if (error || newp == NULL)
669 1.28.2.1 pgoyette return (error);
670 1.28.2.1 pgoyette
671 1.28.2.2 pgoyette #ifndef NET_MPSAFE
672 1.28.2.1 pgoyette mutex_enter(softnet_lock);
673 1.28.2.1 pgoyette KERNEL_LOCK(1, NULL);
674 1.28.2.2 pgoyette #endif
675 1.28.2.1 pgoyette
676 1.28.2.1 pgoyette ip6flow_reap(0);
677 1.28.2.1 pgoyette
678 1.28.2.2 pgoyette #ifndef NET_MPSAFE
679 1.28.2.1 pgoyette KERNEL_UNLOCK_ONE(NULL);
680 1.28.2.1 pgoyette mutex_exit(softnet_lock);
681 1.28.2.2 pgoyette #endif
682 1.28.2.1 pgoyette
683 1.28.2.1 pgoyette return (0);
684 1.28.2.1 pgoyette }
685 1.28.2.1 pgoyette
686 1.28.2.1 pgoyette static int
687 1.28.2.1 pgoyette sysctl_net_inet6_ip6_hashsize(SYSCTLFN_ARGS)
688 1.28.2.1 pgoyette {
689 1.28.2.1 pgoyette int error, tmp;
690 1.28.2.1 pgoyette struct sysctlnode node;
691 1.28.2.1 pgoyette
692 1.28.2.1 pgoyette node = *rnode;
693 1.28.2.1 pgoyette tmp = ip6_hashsize;
694 1.28.2.1 pgoyette node.sysctl_data = &tmp;
695 1.28.2.1 pgoyette error = sysctl_lookup(SYSCTLFN_CALL(&node));
696 1.28.2.1 pgoyette if (error || newp == NULL)
697 1.28.2.1 pgoyette return (error);
698 1.28.2.1 pgoyette
699 1.28.2.1 pgoyette if ((tmp & (tmp - 1)) == 0 && tmp != 0) {
700 1.28.2.1 pgoyette /*
701 1.28.2.1 pgoyette * Can only fail due to malloc()
702 1.28.2.1 pgoyette */
703 1.28.2.2 pgoyette #ifndef NET_MPSAFE
704 1.28.2.1 pgoyette mutex_enter(softnet_lock);
705 1.28.2.1 pgoyette KERNEL_LOCK(1, NULL);
706 1.28.2.2 pgoyette #endif
707 1.28.2.1 pgoyette error = ip6flow_invalidate_all(tmp);
708 1.28.2.2 pgoyette #ifndef NET_MPSAFE
709 1.28.2.1 pgoyette KERNEL_UNLOCK_ONE(NULL);
710 1.28.2.1 pgoyette mutex_exit(softnet_lock);
711 1.28.2.2 pgoyette #endif
712 1.28.2.1 pgoyette } else {
713 1.28.2.1 pgoyette /*
714 1.28.2.1 pgoyette * EINVAL if not a power of 2
715 1.28.2.1 pgoyette */
716 1.28.2.1 pgoyette error = EINVAL;
717 1.28.2.1 pgoyette }
718 1.28.2.1 pgoyette
719 1.28.2.1 pgoyette return error;
720 1.28.2.1 pgoyette }
721 1.28.2.1 pgoyette
722 1.28.2.1 pgoyette static void
723 1.28.2.1 pgoyette ip6flow_sysctl_init(struct sysctllog **clog)
724 1.28.2.1 pgoyette {
725 1.28.2.1 pgoyette
726 1.28.2.1 pgoyette sysctl_createv(clog, 0, NULL, NULL,
727 1.28.2.1 pgoyette CTLFLAG_PERMANENT,
728 1.28.2.1 pgoyette CTLTYPE_NODE, "inet6",
729 1.28.2.1 pgoyette SYSCTL_DESCR("PF_INET6 related settings"),
730 1.28.2.1 pgoyette NULL, 0, NULL, 0,
731 1.28.2.1 pgoyette CTL_NET, PF_INET6, CTL_EOL);
732 1.28.2.1 pgoyette sysctl_createv(clog, 0, NULL, NULL,
733 1.28.2.1 pgoyette CTLFLAG_PERMANENT,
734 1.28.2.1 pgoyette CTLTYPE_NODE, "ip6",
735 1.28.2.1 pgoyette SYSCTL_DESCR("IPv6 related settings"),
736 1.28.2.1 pgoyette NULL, 0, NULL, 0,
737 1.28.2.1 pgoyette CTL_NET, PF_INET6, IPPROTO_IPV6, CTL_EOL);
738 1.28.2.1 pgoyette
739 1.28.2.1 pgoyette sysctl_createv(clog, 0, NULL, NULL,
740 1.28.2.1 pgoyette CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
741 1.28.2.1 pgoyette CTLTYPE_INT, "maxflows",
742 1.28.2.1 pgoyette SYSCTL_DESCR("Number of flows for fast forwarding (IPv6)"),
743 1.28.2.1 pgoyette sysctl_net_inet6_ip6_maxflows, 0, &ip6_maxflows, 0,
744 1.28.2.1 pgoyette CTL_NET, PF_INET6, IPPROTO_IPV6,
745 1.28.2.1 pgoyette CTL_CREATE, CTL_EOL);
746 1.28.2.1 pgoyette sysctl_createv(clog, 0, NULL, NULL,
747 1.28.2.1 pgoyette CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
748 1.28.2.1 pgoyette CTLTYPE_INT, "hashsize",
749 1.28.2.1 pgoyette SYSCTL_DESCR("Size of hash table for fast forwarding (IPv6)"),
750 1.28.2.1 pgoyette sysctl_net_inet6_ip6_hashsize, 0, &ip6_hashsize, 0,
751 1.28.2.1 pgoyette CTL_NET, PF_INET6, IPPROTO_IPV6,
752 1.28.2.1 pgoyette CTL_CREATE, CTL_EOL);
753 1.28.2.1 pgoyette }
754