route.c 158.5 KB
Newer Older
1
// SPDX-License-Identifier: GPL-2.0-or-later
L
Linus Torvalds 已提交
2 3 4 5 6
/*
 *	Linux INET6 implementation
 *	FIB front-end.
 *
 *	Authors:
7
 *	Pedro Roque		<roque@di.fc.ul.pt>
L
Linus Torvalds 已提交
8 9 10 11 12 13 14 15 16 17 18
 */

/*	Changes:
 *
 *	YOSHIFUJI Hideaki @USAGI
 *		reworked default router selection.
 *		- respect outgoing interface
 *		- select from (probably) reachable routers (i.e.
 *		routers in REACHABLE, STALE, DELAY or PROBE states).
 *		- always select the same router if it is (probably)
 *		reachable.  otherwise, round-robin the list.
19 20
 *	Ville Nuorvala
 *		Fixed routing subtrees.
L
Linus Torvalds 已提交
21 22
 */

23 24
#define pr_fmt(fmt) "IPv6: " fmt

25
#include <linux/capability.h>
L
Linus Torvalds 已提交
26
#include <linux/errno.h>
27
#include <linux/export.h>
L
Linus Torvalds 已提交
28 29 30 31 32 33 34 35
#include <linux/types.h>
#include <linux/times.h>
#include <linux/socket.h>
#include <linux/sockios.h>
#include <linux/net.h>
#include <linux/route.h>
#include <linux/netdevice.h>
#include <linux/in6.h>
36
#include <linux/mroute6.h>
L
Linus Torvalds 已提交
37 38 39 40
#include <linux/init.h>
#include <linux/if_arp.h>
#include <linux/proc_fs.h>
#include <linux/seq_file.h>
41
#include <linux/nsproxy.h>
42
#include <linux/slab.h>
43
#include <linux/jhash.h>
44
#include <net/net_namespace.h>
L
Linus Torvalds 已提交
45 46 47 48 49 50 51 52 53
#include <net/snmp.h>
#include <net/ipv6.h>
#include <net/ip6_fib.h>
#include <net/ip6_route.h>
#include <net/ndisc.h>
#include <net/addrconf.h>
#include <net/tcp.h>
#include <linux/rtnetlink.h>
#include <net/dst.h>
54
#include <net/dst_metadata.h>
L
Linus Torvalds 已提交
55
#include <net/xfrm.h>
56
#include <net/netevent.h>
57
#include <net/netlink.h>
58
#include <net/rtnh.h>
59
#include <net/lwtunnel.h>
60
#include <net/ip_tunnels.h>
D
David Ahern 已提交
61
#include <net/l3mdev.h>
62
#include <net/ip.h>
63
#include <linux/uaccess.h>
L
Linus Torvalds 已提交
64 65 66 67 68

#ifdef CONFIG_SYSCTL
#include <linux/sysctl.h>
#endif

69 70 71 72 73 74 75
static int ip6_rt_type_to_error(u8 fib6_type);

#define CREATE_TRACE_POINTS
#include <trace/events/fib6.h>
EXPORT_TRACEPOINT_SYMBOL_GPL(fib6_table_lookup);
#undef CREATE_TRACE_POINTS

76
enum rt6_nud_state {
J
Jiri Benc 已提交
77 78 79
	RT6_NUD_FAIL_HARD = -3,
	RT6_NUD_FAIL_PROBE = -2,
	RT6_NUD_FAIL_DO_RR = -1,
80 81 82
	RT6_NUD_SUCCEED = 1
};

L
Linus Torvalds 已提交
83
static struct dst_entry	*ip6_dst_check(struct dst_entry *dst, u32 cookie);
84
static unsigned int	 ip6_default_advmss(const struct dst_entry *dst);
85
static unsigned int	 ip6_mtu(const struct dst_entry *dst);
L
Linus Torvalds 已提交
86 87 88 89
static struct dst_entry *ip6_negative_advice(struct dst_entry *);
static void		ip6_dst_destroy(struct dst_entry *);
static void		ip6_dst_ifdown(struct dst_entry *,
				       struct net_device *dev, int how);
90
static int		 ip6_dst_gc(struct dst_ops *ops);
L
Linus Torvalds 已提交
91 92

static int		ip6_pkt_discard(struct sk_buff *skb);
E
Eric W. Biederman 已提交
93
static int		ip6_pkt_discard_out(struct net *net, struct sock *sk, struct sk_buff *skb);
94
static int		ip6_pkt_prohibit(struct sk_buff *skb);
E
Eric W. Biederman 已提交
95
static int		ip6_pkt_prohibit_out(struct net *net, struct sock *sk, struct sk_buff *skb);
L
Linus Torvalds 已提交
96
static void		ip6_link_failure(struct sk_buff *skb);
97
static void		ip6_rt_update_pmtu(struct dst_entry *dst, struct sock *sk,
98 99
					   struct sk_buff *skb, u32 mtu,
					   bool confirm_neigh);
100 101
static void		rt6_do_redirect(struct dst_entry *dst, struct sock *sk,
					struct sk_buff *skb);
102 103
static int rt6_score_route(const struct fib6_nh *nh, u32 fib6_flags, int oif,
			   int strict);
104
static size_t rt6_nlmsg_size(struct fib6_info *f6i);
105
static int rt6_fill_node(struct net *net, struct sk_buff *skb,
106
			 struct fib6_info *rt, struct dst_entry *dst,
107
			 struct in6_addr *dest, struct in6_addr *src,
108 109
			 int iif, int type, u32 portid, u32 seq,
			 unsigned int flags);
110
static struct rt6_info *rt6_find_cached_rt(const struct fib6_result *res,
111 112
					   const struct in6_addr *daddr,
					   const struct in6_addr *saddr);
L
Linus Torvalds 已提交
113

114
#ifdef CONFIG_IPV6_ROUTE_INFO
115
static struct fib6_info *rt6_add_route_info(struct net *net,
116
					   const struct in6_addr *prefix, int prefixlen,
117 118
					   const struct in6_addr *gwaddr,
					   struct net_device *dev,
119
					   unsigned int pref);
120
static struct fib6_info *rt6_get_route_info(struct net *net,
121
					   const struct in6_addr *prefix, int prefixlen,
122 123
					   const struct in6_addr *gwaddr,
					   struct net_device *dev);
124 125
#endif

126 127 128 129 130 131 132
struct uncached_list {
	spinlock_t		lock;
	struct list_head	head;
};

static DEFINE_PER_CPU_ALIGNED(struct uncached_list, rt6_uncached_list);

133
void rt6_uncached_list_add(struct rt6_info *rt)
134 135 136 137 138 139 140 141 142 143
{
	struct uncached_list *ul = raw_cpu_ptr(&rt6_uncached_list);

	rt->rt6i_uncached_list = ul;

	spin_lock_bh(&ul->lock);
	list_add_tail(&rt->rt6i_uncached, &ul->head);
	spin_unlock_bh(&ul->lock);
}

144
void rt6_uncached_list_del(struct rt6_info *rt)
145 146 147
{
	if (!list_empty(&rt->rt6i_uncached)) {
		struct uncached_list *ul = rt->rt6i_uncached_list;
W
Wei Wang 已提交
148
		struct net *net = dev_net(rt->dst.dev);
149 150 151

		spin_lock_bh(&ul->lock);
		list_del(&rt->rt6i_uncached);
W
Wei Wang 已提交
152
		atomic_dec(&net->ipv6.rt6_stats->fib_rt_uncache);
153 154 155 156 157 158 159 160 161
		spin_unlock_bh(&ul->lock);
	}
}

static void rt6_uncached_list_flush_dev(struct net *net, struct net_device *dev)
{
	struct net_device *loopback_dev = net->loopback_dev;
	int cpu;

162 163 164
	if (dev == loopback_dev)
		return;

165 166 167 168 169 170 171 172 173
	for_each_possible_cpu(cpu) {
		struct uncached_list *ul = per_cpu_ptr(&rt6_uncached_list, cpu);
		struct rt6_info *rt;

		spin_lock_bh(&ul->lock);
		list_for_each_entry(rt, &ul->head, rt6i_uncached) {
			struct inet6_dev *rt_idev = rt->rt6i_idev;
			struct net_device *rt_dev = rt->dst.dev;

174
			if (rt_idev->dev == dev) {
175 176 177 178
				rt->rt6i_idev = in6_dev_get(loopback_dev);
				in6_dev_put(rt_idev);
			}

179
			if (rt_dev == dev) {
180
				rt->dst.dev = blackhole_netdev;
181 182 183 184 185 186 187 188
				dev_hold(rt->dst.dev);
				dev_put(rt_dev);
			}
		}
		spin_unlock_bh(&ul->lock);
	}
}

189
static inline const void *choose_neigh_daddr(const struct in6_addr *p,
190 191
					     struct sk_buff *skb,
					     const void *daddr)
192
{
D
David S. Miller 已提交
193
	if (!ipv6_addr_any(p))
194
		return (const void *) p;
195 196
	else if (skb)
		return &ipv6_hdr(skb)->daddr;
197 198 199
	return daddr;
}

200 201 202 203
struct neighbour *ip6_neigh_lookup(const struct in6_addr *gw,
				   struct net_device *dev,
				   struct sk_buff *skb,
				   const void *daddr)
204
{
205 206
	struct neighbour *n;

207 208
	daddr = choose_neigh_daddr(gw, skb, daddr);
	n = __ipv6_neigh_lookup(dev, daddr);
209 210
	if (n)
		return n;
211 212 213

	n = neigh_create(&nd_tbl, daddr, dev);
	return IS_ERR(n) ? NULL : n;
214 215 216 217 218 219 220 221
}

static struct neighbour *ip6_dst_neigh_lookup(const struct dst_entry *dst,
					      struct sk_buff *skb,
					      const void *daddr)
{
	const struct rt6_info *rt = container_of(dst, struct rt6_info, dst);

222 223
	return ip6_neigh_lookup(rt6_nexthop(rt, &in6addr_any),
				dst->dev, skb, daddr);
224 225
}

226 227 228 229 230
static void ip6_confirm_neigh(const struct dst_entry *dst, const void *daddr)
{
	struct net_device *dev = dst->dev;
	struct rt6_info *rt = (struct rt6_info *)dst;

231
	daddr = choose_neigh_daddr(rt6_nexthop(rt, &in6addr_any), NULL, daddr);
232 233 234 235 236 237 238 239 240
	if (!daddr)
		return;
	if (dev->flags & (IFF_NOARP | IFF_LOOPBACK))
		return;
	if (ipv6_addr_is_multicast((const struct in6_addr *)daddr))
		return;
	__ipv6_confirm_neigh(dev, daddr);
}

241
static struct dst_ops ip6_dst_ops_template = {
L
Linus Torvalds 已提交
242 243 244 245
	.family			=	AF_INET6,
	.gc			=	ip6_dst_gc,
	.gc_thresh		=	1024,
	.check			=	ip6_dst_check,
246
	.default_advmss		=	ip6_default_advmss,
247
	.mtu			=	ip6_mtu,
248
	.cow_metrics		=	dst_cow_metrics_generic,
L
Linus Torvalds 已提交
249 250 251 252 253
	.destroy		=	ip6_dst_destroy,
	.ifdown			=	ip6_dst_ifdown,
	.negative_advice	=	ip6_negative_advice,
	.link_failure		=	ip6_link_failure,
	.update_pmtu		=	ip6_rt_update_pmtu,
254
	.redirect		=	rt6_do_redirect,
255
	.local_out		=	__ip6_local_out,
256
	.neigh_lookup		=	ip6_dst_neigh_lookup,
257
	.confirm_neigh		=	ip6_confirm_neigh,
L
Linus Torvalds 已提交
258 259
};

260
static unsigned int ip6_blackhole_mtu(const struct dst_entry *dst)
261
{
262 263 264
	unsigned int mtu = dst_metric_raw(dst, RTAX_MTU);

	return mtu ? : dst->dev->mtu;
265 266
}

267
static void ip6_rt_blackhole_update_pmtu(struct dst_entry *dst, struct sock *sk,
268 269
					 struct sk_buff *skb, u32 mtu,
					 bool confirm_neigh)
270 271 272
{
}

273 274
static void ip6_rt_blackhole_redirect(struct dst_entry *dst, struct sock *sk,
				      struct sk_buff *skb)
275 276 277
{
}

278 279 280 281
static struct dst_ops ip6_dst_blackhole_ops = {
	.family			=	AF_INET6,
	.destroy		=	ip6_dst_destroy,
	.check			=	ip6_dst_check,
282
	.mtu			=	ip6_blackhole_mtu,
283
	.default_advmss		=	ip6_default_advmss,
284
	.update_pmtu		=	ip6_rt_blackhole_update_pmtu,
285
	.redirect		=	ip6_rt_blackhole_redirect,
286
	.cow_metrics		=	dst_cow_metrics_generic,
287
	.neigh_lookup		=	ip6_dst_neigh_lookup,
288 289
};

290
static const u32 ip6_template_metrics[RTAX_MAX] = {
L
Li RongQing 已提交
291
	[RTAX_HOPLIMIT - 1] = 0,
292 293
};

294
static const struct fib6_info fib6_null_entry_template = {
295 296 297
	.fib6_flags	= (RTF_REJECT | RTF_NONEXTHOP),
	.fib6_protocol  = RTPROT_KERNEL,
	.fib6_metric	= ~(u32)0,
298
	.fib6_ref	= REFCOUNT_INIT(1),
D
David Ahern 已提交
299 300 301 302
	.fib6_type	= RTN_UNREACHABLE,
	.fib6_metrics	= (struct dst_metrics *)&dst_default_metrics,
};

303
static const struct rt6_info ip6_null_entry_template = {
304 305 306
	.dst = {
		.__refcnt	= ATOMIC_INIT(1),
		.__use		= 1,
307
		.obsolete	= DST_OBSOLETE_FORCE_CHK,
308 309 310
		.error		= -ENETUNREACH,
		.input		= ip6_pkt_discard,
		.output		= ip6_pkt_discard_out,
L
Linus Torvalds 已提交
311 312 313 314
	},
	.rt6i_flags	= (RTF_REJECT | RTF_NONEXTHOP),
};

T
Thomas Graf 已提交
315 316
#ifdef CONFIG_IPV6_MULTIPLE_TABLES

317
static const struct rt6_info ip6_prohibit_entry_template = {
318 319 320
	.dst = {
		.__refcnt	= ATOMIC_INIT(1),
		.__use		= 1,
321
		.obsolete	= DST_OBSOLETE_FORCE_CHK,
322 323 324
		.error		= -EACCES,
		.input		= ip6_pkt_prohibit,
		.output		= ip6_pkt_prohibit_out,
T
Thomas Graf 已提交
325 326 327 328
	},
	.rt6i_flags	= (RTF_REJECT | RTF_NONEXTHOP),
};

329
static const struct rt6_info ip6_blk_hole_entry_template = {
330 331 332
	.dst = {
		.__refcnt	= ATOMIC_INIT(1),
		.__use		= 1,
333
		.obsolete	= DST_OBSOLETE_FORCE_CHK,
334 335
		.error		= -EINVAL,
		.input		= dst_discard,
E
Eric W. Biederman 已提交
336
		.output		= dst_discard_out,
T
Thomas Graf 已提交
337 338 339 340 341 342
	},
	.rt6i_flags	= (RTF_REJECT | RTF_NONEXTHOP),
};

#endif

343 344 345 346 347 348 349 350
static void rt6_info_init(struct rt6_info *rt)
{
	struct dst_entry *dst = &rt->dst;

	memset(dst + 1, 0, sizeof(*rt) - sizeof(*dst));
	INIT_LIST_HEAD(&rt->rt6i_uncached);
}

L
Linus Torvalds 已提交
351
/* allocate dst with ip6_dst_ops */
352 353
struct rt6_info *ip6_dst_alloc(struct net *net, struct net_device *dev,
			       int flags)
L
Linus Torvalds 已提交
354
{
355
	struct rt6_info *rt = dst_alloc(&net->ipv6.ip6_dst_ops, dev,
W
Wei Wang 已提交
356
					1, DST_OBSOLETE_FORCE_CHK, flags);
357

W
Wei Wang 已提交
358
	if (rt) {
359
		rt6_info_init(rt);
W
Wei Wang 已提交
360 361
		atomic_inc(&net->ipv6.rt6_stats->fib_rt_alloc);
	}
362

363
	return rt;
L
Linus Torvalds 已提交
364
}
365
EXPORT_SYMBOL(ip6_dst_alloc);
M
Martin KaFai Lau 已提交
366

L
Linus Torvalds 已提交
367 368 369
static void ip6_dst_destroy(struct dst_entry *dst)
{
	struct rt6_info *rt = (struct rt6_info *)dst;
370
	struct fib6_info *from;
371
	struct inet6_dev *idev;
L
Linus Torvalds 已提交
372

373
	ip_dst_metrics_put(dst);
374 375 376
	rt6_uncached_list_del(rt);

	idev = rt->rt6i_idev;
377
	if (idev) {
L
Linus Torvalds 已提交
378 379
		rt->rt6i_idev = NULL;
		in6_dev_put(idev);
380
	}
381

382
	from = xchg((__force struct fib6_info **)&rt->from, NULL);
383
	fib6_info_release(from);
384 385
}

L
Linus Torvalds 已提交
386 387 388 389 390
static void ip6_dst_ifdown(struct dst_entry *dst, struct net_device *dev,
			   int how)
{
	struct rt6_info *rt = (struct rt6_info *)dst;
	struct inet6_dev *idev = rt->rt6i_idev;
391
	struct net_device *loopback_dev =
392
		dev_net(dev)->loopback_dev;
L
Linus Torvalds 已提交
393

394 395 396 397 398
	if (idev && idev->dev != loopback_dev) {
		struct inet6_dev *loopback_idev = in6_dev_get(loopback_dev);
		if (loopback_idev) {
			rt->rt6i_idev = loopback_idev;
			in6_dev_put(idev);
399
		}
L
Linus Torvalds 已提交
400 401 402
	}
}

403 404 405 406 407 408 409 410
static bool __rt6_check_expired(const struct rt6_info *rt)
{
	if (rt->rt6i_flags & RTF_EXPIRES)
		return time_after(jiffies, rt->dst.expires);
	else
		return false;
}

411
static bool rt6_check_expired(const struct rt6_info *rt)
L
Linus Torvalds 已提交
412
{
413 414 415 416
	struct fib6_info *from;

	from = rcu_dereference(rt->from);

417 418
	if (rt->rt6i_flags & RTF_EXPIRES) {
		if (time_after(jiffies, rt->dst.expires))
419
			return true;
420
	} else if (from) {
421
		return rt->dst.obsolete != DST_OBSOLETE_FORCE_CHK ||
422
			fib6_check_expired(from);
423
	}
424
	return false;
L
Linus Torvalds 已提交
425 426
}

427 428 429
void fib6_select_path(const struct net *net, struct fib6_result *res,
		      struct flowi6 *fl6, int oif, bool have_oif_match,
		      const struct sk_buff *skb, int strict)
430
{
431
	struct fib6_info *sibling, *next_sibling;
432 433
	struct fib6_info *match = res->f6i;

434
	if ((!match->fib6_nsiblings && !match->nh) || have_oif_match)
435
		goto out;
436

437 438 439
	/* We might have already computed the hash for ICMPv6 errors. In such
	 * case it will always be non-zero. Otherwise now is the time to do it.
	 */
440 441
	if (!fl6->mp_hash &&
	    (!match->nh || nexthop_is_multipath(match->nh)))
442
		fl6->mp_hash = rt6_multipath_hash(net, fl6, skb, NULL);
443

444 445 446 447 448
	if (unlikely(match->nh)) {
		nexthop_path_fib6_result(res, fl6->mp_hash);
		return;
	}

449
	if (fl6->mp_hash <= atomic_read(&match->fib6_nh->fib_nh_upper_bound))
450
		goto out;
451

452 453
	list_for_each_entry_safe(sibling, next_sibling, &match->fib6_siblings,
				 fib6_siblings) {
454
		const struct fib6_nh *nh = sibling->fib6_nh;
455 456
		int nh_upper_bound;

457
		nh_upper_bound = atomic_read(&nh->fib_nh_upper_bound);
458
		if (fl6->mp_hash > nh_upper_bound)
459
			continue;
460
		if (rt6_score_route(nh, sibling->fib6_flags, oif, strict) < 0)
461 462 463 464 465
			break;
		match = sibling;
		break;
	}

466 467
out:
	res->f6i = match;
468
	res->nh = match->fib6_nh;
469 470
}

L
Linus Torvalds 已提交
471
/*
472
 *	Route lookup. rcu_read_lock() should be held.
L
Linus Torvalds 已提交
473 474
 */

D
David Ahern 已提交
475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 494 495
static bool __rt6_device_match(struct net *net, const struct fib6_nh *nh,
			       const struct in6_addr *saddr, int oif, int flags)
{
	const struct net_device *dev;

	if (nh->fib_nh_flags & RTNH_F_DEAD)
		return false;

	dev = nh->fib_nh_dev;
	if (oif) {
		if (dev->ifindex == oif)
			return true;
	} else {
		if (ipv6_chk_addr(net, saddr, dev,
				  flags & RT6_LOOKUP_F_IFACE))
			return true;
	}

	return false;
}

496 497 498 499 500 501 502 503 504 505 506 507 508 509 510 511 512 513 514 515 516 517 518 519 520 521 522 523 524 525 526 527 528 529 530 531 532 533 534
struct fib6_nh_dm_arg {
	struct net		*net;
	const struct in6_addr	*saddr;
	int			oif;
	int			flags;
	struct fib6_nh		*nh;
};

static int __rt6_nh_dev_match(struct fib6_nh *nh, void *_arg)
{
	struct fib6_nh_dm_arg *arg = _arg;

	arg->nh = nh;
	return __rt6_device_match(arg->net, nh, arg->saddr, arg->oif,
				  arg->flags);
}

/* returns fib6_nh from nexthop or NULL */
static struct fib6_nh *rt6_nh_dev_match(struct net *net, struct nexthop *nh,
					struct fib6_result *res,
					const struct in6_addr *saddr,
					int oif, int flags)
{
	struct fib6_nh_dm_arg arg = {
		.net   = net,
		.saddr = saddr,
		.oif   = oif,
		.flags = flags,
	};

	if (nexthop_is_blackhole(nh))
		return NULL;

	if (nexthop_for_each_fib6_nh(nh, __rt6_nh_dev_match, &arg))
		return arg.nh;

	return NULL;
}

535 536
static void rt6_device_match(struct net *net, struct fib6_result *res,
			     const struct in6_addr *saddr, int oif, int flags)
L
Linus Torvalds 已提交
537
{
538 539 540
	struct fib6_info *f6i = res->f6i;
	struct fib6_info *spf6i;
	struct fib6_nh *nh;
L
Linus Torvalds 已提交
541

542
	if (!oif && ipv6_addr_any(saddr)) {
543 544 545 546 547 548 549
		if (unlikely(f6i->nh)) {
			nh = nexthop_fib6_nh(f6i->nh);
			if (nexthop_is_blackhole(f6i->nh))
				goto out_blackhole;
		} else {
			nh = f6i->fib6_nh;
		}
550 551
		if (!(nh->fib_nh_flags & RTNH_F_DEAD))
			goto out;
552
	}
553

554
	for (spf6i = f6i; spf6i; spf6i = rcu_dereference(spf6i->fib6_next)) {
555 556 557 558 559 560 561 562 563 564 565 566 567
		bool matched = false;

		if (unlikely(spf6i->nh)) {
			nh = rt6_nh_dev_match(net, spf6i->nh, res, saddr,
					      oif, flags);
			if (nh)
				matched = true;
		} else {
			nh = spf6i->fib6_nh;
			if (__rt6_device_match(net, nh, saddr, oif, flags))
				matched = true;
		}
		if (matched) {
568
			res->f6i = spf6i;
569
			goto out;
570
		}
571
	}
L
Linus Torvalds 已提交
572

573 574
	if (oif && flags & RT6_LOOKUP_F_IFACE) {
		res->f6i = net->ipv6.fib6_null_entry;
575
		nh = res->f6i->fib6_nh;
576
		goto out;
577
	}
578

579 580 581 582 583 584 585 586
	if (unlikely(f6i->nh)) {
		nh = nexthop_fib6_nh(f6i->nh);
		if (nexthop_is_blackhole(f6i->nh))
			goto out_blackhole;
	} else {
		nh = f6i->fib6_nh;
	}

587
	if (nh->fib_nh_flags & RTNH_F_DEAD) {
588
		res->f6i = net->ipv6.fib6_null_entry;
589
		nh = res->f6i->fib6_nh;
590
	}
591 592 593 594
out:
	res->nh = nh;
	res->fib6_type = res->f6i->fib6_type;
	res->fib6_flags = res->f6i->fib6_flags;
595 596 597 598 599 600
	return;

out_blackhole:
	res->fib6_flags |= RTF_REJECT;
	res->fib6_type = RTN_BLACKHOLE;
	res->nh = nh;
L
Linus Torvalds 已提交
601 602
}

603
#ifdef CONFIG_IPV6_ROUTER_PREF
604 605 606 607 608 609 610 611 612 613 614 615 616
struct __rt6_probe_work {
	struct work_struct work;
	struct in6_addr target;
	struct net_device *dev;
};

static void rt6_probe_deferred(struct work_struct *w)
{
	struct in6_addr mcaddr;
	struct __rt6_probe_work *work =
		container_of(w, struct __rt6_probe_work, work);

	addrconf_addr_solict_mult(&work->target, &mcaddr);
617
	ndisc_send_ns(work->dev, &work->target, &mcaddr, NULL, 0);
618
	dev_put(work->dev);
619
	kfree(work);
620 621
}

622
static void rt6_probe(struct fib6_nh *fib6_nh)
623
{
624
	struct __rt6_probe_work *work = NULL;
625
	const struct in6_addr *nh_gw;
626
	unsigned long last_probe;
627
	struct neighbour *neigh;
628
	struct net_device *dev;
629
	struct inet6_dev *idev;
630

631 632 633 634 635 636 637 638
	/*
	 * Okay, this does not seem to be appropriate
	 * for now, however, we need to check if it
	 * is really so; aka Router Reachability Probing.
	 *
	 * Router Reachability Probe MUST be rate-limited
	 * to no more than one per minute.
	 */
639
	if (!fib6_nh->fib_nh_gw_family)
640
		return;
641

642 643
	nh_gw = &fib6_nh->fib_nh_gw6;
	dev = fib6_nh->fib_nh_dev;
644
	rcu_read_lock_bh();
645
	last_probe = READ_ONCE(fib6_nh->last_probe);
646
	idev = __in6_dev_get(dev);
647
	neigh = __ipv6_neigh_lookup_noref(dev, nh_gw);
648
	if (neigh) {
649 650 651
		if (neigh->nud_state & NUD_VALID)
			goto out;

652
		write_lock(&neigh->lock);
653 654
		if (!(neigh->nud_state & NUD_VALID) &&
		    time_after(jiffies,
D
David Ahern 已提交
655
			       neigh->updated + idev->cnf.rtr_probe_interval)) {
656 657 658
			work = kmalloc(sizeof(*work), GFP_ATOMIC);
			if (work)
				__neigh_set_probe_once(neigh);
659
		}
660
		write_unlock(&neigh->lock);
661
	} else if (time_after(jiffies, last_probe +
662
				       idev->cnf.rtr_probe_interval)) {
663
		work = kmalloc(sizeof(*work), GFP_ATOMIC);
664
	}
665

666 667 668 669
	if (!work || cmpxchg(&fib6_nh->last_probe,
			     last_probe, jiffies) != last_probe) {
		kfree(work);
	} else {
670
		INIT_WORK(&work->work, rt6_probe_deferred);
671 672 673
		work->target = *nh_gw;
		dev_hold(dev);
		work->dev = dev;
674 675 676
		schedule_work(&work->work);
	}

677
out:
678
	rcu_read_unlock_bh();
679 680
}
#else
681
static inline void rt6_probe(struct fib6_nh *fib6_nh)
682 683 684 685
{
}
#endif

L
Linus Torvalds 已提交
686
/*
687
 * Default Router Selection (RFC 2461 6.3.6)
L
Linus Torvalds 已提交
688
 */
689
static enum rt6_nud_state rt6_check_neigh(const struct fib6_nh *fib6_nh)
L
Linus Torvalds 已提交
690
{
691
	enum rt6_nud_state ret = RT6_NUD_FAIL_HARD;
692
	struct neighbour *neigh;
693

694
	rcu_read_lock_bh();
695 696
	neigh = __ipv6_neigh_lookup_noref(fib6_nh->fib_nh_dev,
					  &fib6_nh->fib_nh_gw6);
697 698
	if (neigh) {
		read_lock(&neigh->lock);
699
		if (neigh->nud_state & NUD_VALID)
700
			ret = RT6_NUD_SUCCEED;
701
#ifdef CONFIG_IPV6_ROUTER_PREF
702
		else if (!(neigh->nud_state & NUD_FAILED))
703
			ret = RT6_NUD_SUCCEED;
J
Jiri Benc 已提交
704 705
		else
			ret = RT6_NUD_FAIL_PROBE;
706
#endif
707
		read_unlock(&neigh->lock);
708 709
	} else {
		ret = IS_ENABLED(CONFIG_IPV6_ROUTER_PREF) ?
J
Jiri Benc 已提交
710
		      RT6_NUD_SUCCEED : RT6_NUD_FAIL_DO_RR;
711
	}
712 713
	rcu_read_unlock_bh();

714
	return ret;
L
Linus Torvalds 已提交
715 716
}

717 718
static int rt6_score_route(const struct fib6_nh *nh, u32 fib6_flags, int oif,
			   int strict)
L
Linus Torvalds 已提交
719
{
D
David Ahern 已提交
720 721 722 723
	int m = 0;

	if (!oif || nh->fib_nh_dev->ifindex == oif)
		m = 2;
724

725
	if (!m && (strict & RT6_LOOKUP_F_IFACE))
726
		return RT6_NUD_FAIL_HARD;
727
#ifdef CONFIG_IPV6_ROUTER_PREF
728
	m |= IPV6_DECODE_PREF(IPV6_EXTRACT_PREF(fib6_flags)) << 2;
729
#endif
730
	if ((strict & RT6_LOOKUP_F_REACHABLE) &&
731
	    !(fib6_flags & RTF_NONEXTHOP) && nh->fib_nh_gw_family) {
732
		int n = rt6_check_neigh(nh);
733 734 735
		if (n < 0)
			return n;
	}
736 737 738
	return m;
}

D
David Ahern 已提交
739 740
static bool find_match(struct fib6_nh *nh, u32 fib6_flags,
		       int oif, int strict, int *mpri, bool *do_rr)
741
{
742
	bool match_do_rr = false;
D
David Ahern 已提交
743 744
	bool rc = false;
	int m;
745

D
David Ahern 已提交
746
	if (nh->fib_nh_flags & RTNH_F_DEAD)
747 748
		goto out;

D
David Ahern 已提交
749 750
	if (ip6_ignore_linkdown(nh->fib_nh_dev) &&
	    nh->fib_nh_flags & RTNH_F_LINKDOWN &&
751
	    !(strict & RT6_LOOKUP_F_IGNORE_LINKSTATE))
752
		goto out;
753

D
David Ahern 已提交
754
	m = rt6_score_route(nh, fib6_flags, oif, strict);
J
Jiri Benc 已提交
755
	if (m == RT6_NUD_FAIL_DO_RR) {
756 757
		match_do_rr = true;
		m = 0; /* lowest valid score */
J
Jiri Benc 已提交
758
	} else if (m == RT6_NUD_FAIL_HARD) {
759
		goto out;
760 761 762
	}

	if (strict & RT6_LOOKUP_F_REACHABLE)
D
David Ahern 已提交
763
		rt6_probe(nh);
764

J
Jiri Benc 已提交
765
	/* note that m can be RT6_NUD_FAIL_PROBE at this point */
766
	if (m > *mpri) {
767
		*do_rr = match_do_rr;
768
		*mpri = m;
D
David Ahern 已提交
769
		rc = true;
770 771
	}
out:
D
David Ahern 已提交
772
	return rc;
773 774
}

775 776 777 778 779 780 781 782 783 784 785 786 787 788 789 790 791 792
struct fib6_nh_frl_arg {
	u32		flags;
	int		oif;
	int		strict;
	int		*mpri;
	bool		*do_rr;
	struct fib6_nh	*nh;
};

static int rt6_nh_find_match(struct fib6_nh *nh, void *_arg)
{
	struct fib6_nh_frl_arg *arg = _arg;

	arg->nh = nh;
	return find_match(nh, arg->flags, arg->oif, arg->strict,
			  arg->mpri, arg->do_rr);
}

793
static void __find_rr_leaf(struct fib6_info *f6i_start,
D
David Ahern 已提交
794
			   struct fib6_info *nomatch, u32 metric,
795
			   struct fib6_result *res, struct fib6_info **cont,
D
David Ahern 已提交
796
			   int oif, int strict, bool *do_rr, int *mpri)
797
{
798
	struct fib6_info *f6i;
L
Linus Torvalds 已提交
799

800 801 802
	for (f6i = f6i_start;
	     f6i && f6i != nomatch;
	     f6i = rcu_dereference(f6i->fib6_next)) {
803
		bool matched = false;
D
David Ahern 已提交
804 805
		struct fib6_nh *nh;

806 807
		if (cont && f6i->fib6_metric != metric) {
			*cont = f6i;
D
David Ahern 已提交
808
			return;
809 810
		}

811
		if (fib6_check_expired(f6i))
D
David Ahern 已提交
812 813
			continue;

814 815 816 817 818 819 820 821 822 823 824 825 826 827 828 829 830 831 832 833 834 835 836 837 838 839 840 841
		if (unlikely(f6i->nh)) {
			struct fib6_nh_frl_arg arg = {
				.flags  = f6i->fib6_flags,
				.oif    = oif,
				.strict = strict,
				.mpri   = mpri,
				.do_rr  = do_rr
			};

			if (nexthop_is_blackhole(f6i->nh)) {
				res->fib6_flags = RTF_REJECT;
				res->fib6_type = RTN_BLACKHOLE;
				res->f6i = f6i;
				res->nh = nexthop_fib6_nh(f6i->nh);
				return;
			}
			if (nexthop_for_each_fib6_nh(f6i->nh, rt6_nh_find_match,
						     &arg)) {
				matched = true;
				nh = arg.nh;
			}
		} else {
			nh = f6i->fib6_nh;
			if (find_match(nh, f6i->fib6_flags, oif, strict,
				       mpri, do_rr))
				matched = true;
		}
		if (matched) {
842 843
			res->f6i = f6i;
			res->nh = nh;
844 845
			res->fib6_flags = f6i->fib6_flags;
			res->fib6_type = f6i->fib6_type;
846
		}
847
	}
D
David Ahern 已提交
848
}
849

850 851 852
static void find_rr_leaf(struct fib6_node *fn, struct fib6_info *leaf,
			 struct fib6_info *rr_head, int oif, int strict,
			 bool *do_rr, struct fib6_result *res)
D
David Ahern 已提交
853
{
854 855
	u32 metric = rr_head->fib6_metric;
	struct fib6_info *cont = NULL;
D
David Ahern 已提交
856
	int mpri = -1;
857

858
	__find_rr_leaf(rr_head, NULL, metric, res, &cont,
D
David Ahern 已提交
859
		       oif, strict, do_rr, &mpri);
D
David Ahern 已提交
860

861
	__find_rr_leaf(leaf, rr_head, metric, res, &cont,
D
David Ahern 已提交
862
		       oif, strict, do_rr, &mpri);
863

864 865
	if (res->f6i || !cont)
		return;
866

867
	__find_rr_leaf(cont, NULL, metric, res, NULL,
D
David Ahern 已提交
868
		       oif, strict, do_rr, &mpri);
869
}
L
Linus Torvalds 已提交
870

871 872
static void rt6_select(struct net *net, struct fib6_node *fn, int oif,
		       struct fib6_result *res, int strict)
873
{
874
	struct fib6_info *leaf = rcu_dereference(fn->leaf);
875
	struct fib6_info *rt0;
876
	bool do_rr = false;
877
	int key_plen;
L
Linus Torvalds 已提交
878

879 880 881
	/* make sure this function or its helpers sets f6i */
	res->f6i = NULL;

D
David Ahern 已提交
882
	if (!leaf || leaf == net->ipv6.fib6_null_entry)
883
		goto out;
W
Wei Wang 已提交
884

885
	rt0 = rcu_dereference(fn->rr_ptr);
886
	if (!rt0)
887
		rt0 = leaf;
L
Linus Torvalds 已提交
888

889 890 891 892 893
	/* Double check to make sure fn is not an intermediate node
	 * and fn->leaf does not points to its child's leaf
	 * (This might happen if all routes under fn are deleted from
	 * the tree and fib6_repair_tree() is called on the node.)
	 */
894
	key_plen = rt0->fib6_dst.plen;
895
#ifdef CONFIG_IPV6_SUBTREES
896 897
	if (rt0->fib6_src.plen)
		key_plen = rt0->fib6_src.plen;
898 899
#endif
	if (fn->fn_bit != key_plen)
900
		goto out;
L
Linus Torvalds 已提交
901

902
	find_rr_leaf(fn, leaf, rt0, oif, strict, &do_rr, res);
903
	if (do_rr) {
904
		struct fib6_info *next = rcu_dereference(rt0->fib6_next);
905

906
		/* no entries matched; do round-robin */
907
		if (!next || next->fib6_metric != rt0->fib6_metric)
W
Wei Wang 已提交
908
			next = leaf;
909

910
		if (next != rt0) {
911
			spin_lock_bh(&leaf->fib6_table->tb6_lock);
912
			/* make sure next is not being deleted from the tree */
913
			if (next->fib6_node)
914
				rcu_assign_pointer(fn->rr_ptr, next);
915
			spin_unlock_bh(&leaf->fib6_table->tb6_lock);
916
		}
L
Linus Torvalds 已提交
917 918
	}

919 920 921
out:
	if (!res->f6i) {
		res->f6i = net->ipv6.fib6_null_entry;
922
		res->nh = res->f6i->fib6_nh;
923 924
		res->fib6_flags = res->f6i->fib6_flags;
		res->fib6_type = res->f6i->fib6_type;
925
	}
L
Linus Torvalds 已提交
926 927
}

928
static bool rt6_is_gw_or_nonexthop(const struct fib6_result *res)
929
{
930 931
	return (res->f6i->fib6_flags & RTF_NONEXTHOP) ||
	       res->nh->fib_nh_gw_family;
932 933
}

934 935
#ifdef CONFIG_IPV6_ROUTE_INFO
int rt6_route_rcv(struct net_device *dev, u8 *opt, int len,
936
		  const struct in6_addr *gwaddr)
937
{
938
	struct net *net = dev_net(dev);
939 940 941
	struct route_info *rinfo = (struct route_info *) opt;
	struct in6_addr prefix_buf, *prefix;
	unsigned int pref;
942
	unsigned long lifetime;
943
	struct fib6_info *rt;
944 945 946 947 948 949 950 951 952 953 954 955 956 957 958 959 960 961 962 963 964 965

	if (len < sizeof(struct route_info)) {
		return -EINVAL;
	}

	/* Sanity check for prefix_len and length */
	if (rinfo->length > 3) {
		return -EINVAL;
	} else if (rinfo->prefix_len > 128) {
		return -EINVAL;
	} else if (rinfo->prefix_len > 64) {
		if (rinfo->length < 2) {
			return -EINVAL;
		}
	} else if (rinfo->prefix_len > 0) {
		if (rinfo->length < 1) {
			return -EINVAL;
		}
	}

	pref = rinfo->route_pref;
	if (pref == ICMPV6_ROUTER_PREF_INVALID)
966
		return -EINVAL;
967

968
	lifetime = addrconf_timeout_fixup(ntohl(rinfo->lifetime), HZ);
969 970 971 972 973 974 975 976 977 978 979

	if (rinfo->length == 3)
		prefix = (struct in6_addr *)rinfo->prefix;
	else {
		/* this function is safe */
		ipv6_addr_prefix(&prefix_buf,
				 (struct in6_addr *)rinfo->prefix,
				 rinfo->prefix_len);
		prefix = &prefix_buf;
	}

980
	if (rinfo->prefix_len == 0)
981
		rt = rt6_get_dflt_router(net, gwaddr, dev);
982 983
	else
		rt = rt6_get_route_info(net, prefix, rinfo->prefix_len,
984
					gwaddr, dev);
985 986

	if (rt && !lifetime) {
987
		ip6_del_rt(net, rt);
988 989 990 991
		rt = NULL;
	}

	if (!rt && lifetime)
992 993
		rt = rt6_add_route_info(net, prefix, rinfo->prefix_len, gwaddr,
					dev, pref);
994
	else if (rt)
995 996
		rt->fib6_flags = RTF_ROUTEINFO |
				 (rt->fib6_flags & ~RTF_PREF_MASK) | RTF_PREF(pref);
997 998

	if (rt) {
999
		if (!addrconf_finite_timeout(lifetime))
1000
			fib6_clean_expires(rt);
1001
		else
1002
			fib6_set_expires(rt, jiffies + HZ * lifetime);
1003

1004
		fib6_info_release(rt);
1005 1006 1007 1008 1009
	}
	return 0;
}
#endif

1010 1011 1012 1013 1014
/*
 *	Misc support functions
 */

/* called with rcu_lock held */
1015
static struct net_device *ip6_rt_get_dev_rcu(const struct fib6_result *res)
1016
{
1017
	struct net_device *dev = res->nh->fib_nh_dev;
1018

1019
	if (res->fib6_flags & (RTF_LOCAL | RTF_ANYCAST)) {
1020 1021 1022 1023 1024
		/* for copies of local routes, dst->dev needs to be the
		 * device if it is a master device, the master device if
		 * device is enslaved, and the loopback as the default
		 */
		if (netif_is_l3_slave(dev) &&
1025
		    !rt6_need_strict(&res->f6i->fib6_dst.addr))
1026 1027 1028 1029 1030 1031 1032 1033 1034 1035 1036
			dev = l3mdev_master_dev_rcu(dev);
		else if (!netif_is_l3_master(dev))
			dev = dev_net(dev)->loopback_dev;
		/* last case is netif_is_l3_master(dev) is true in which
		 * case we want dev returned to be dev
		 */
	}

	return dev;
}

1037 1038 1039 1040 1041 1042 1043 1044 1045 1046 1047 1048 1049 1050 1051 1052 1053 1054 1055 1056
static const int fib6_prop[RTN_MAX + 1] = {
	[RTN_UNSPEC]	= 0,
	[RTN_UNICAST]	= 0,
	[RTN_LOCAL]	= 0,
	[RTN_BROADCAST]	= 0,
	[RTN_ANYCAST]	= 0,
	[RTN_MULTICAST]	= 0,
	[RTN_BLACKHOLE]	= -EINVAL,
	[RTN_UNREACHABLE] = -EHOSTUNREACH,
	[RTN_PROHIBIT]	= -EACCES,
	[RTN_THROW]	= -EAGAIN,
	[RTN_NAT]	= -EINVAL,
	[RTN_XRESOLVE]	= -EINVAL,
};

static int ip6_rt_type_to_error(u8 fib6_type)
{
	return fib6_prop[fib6_type];
}

1057
static unsigned short fib6_info_dst_flags(struct fib6_info *rt)
1058 1059 1060 1061 1062 1063 1064 1065 1066 1067 1068 1069 1070
{
	unsigned short flags = 0;

	if (rt->dst_nocount)
		flags |= DST_NOCOUNT;
	if (rt->dst_nopolicy)
		flags |= DST_NOPOLICY;
	if (rt->dst_host)
		flags |= DST_HOST;

	return flags;
}

1071
static void ip6_rt_init_dst_reject(struct rt6_info *rt, u8 fib6_type)
1072
{
1073
	rt->dst.error = ip6_rt_type_to_error(fib6_type);
1074

1075
	switch (fib6_type) {
1076 1077 1078 1079 1080 1081 1082 1083 1084 1085 1086 1087 1088 1089 1090 1091 1092
	case RTN_BLACKHOLE:
		rt->dst.output = dst_discard_out;
		rt->dst.input = dst_discard;
		break;
	case RTN_PROHIBIT:
		rt->dst.output = ip6_pkt_prohibit_out;
		rt->dst.input = ip6_pkt_prohibit;
		break;
	case RTN_THROW:
	case RTN_UNREACHABLE:
	default:
		rt->dst.output = ip6_pkt_discard_out;
		rt->dst.input = ip6_pkt_discard;
		break;
	}
}

1093
static void ip6_rt_init_dst(struct rt6_info *rt, const struct fib6_result *res)
1094
{
1095
	struct fib6_info *f6i = res->f6i;
1096

1097 1098
	if (res->fib6_flags & RTF_REJECT) {
		ip6_rt_init_dst_reject(rt, res->fib6_type);
1099 1100 1101 1102 1103 1104
		return;
	}

	rt->dst.error = 0;
	rt->dst.output = ip6_output;

1105
	if (res->fib6_type == RTN_LOCAL || res->fib6_type == RTN_ANYCAST) {
1106
		rt->dst.input = ip6_input;
1107
	} else if (ipv6_addr_type(&f6i->fib6_dst.addr) & IPV6_ADDR_MULTICAST) {
1108 1109 1110 1111 1112
		rt->dst.input = ip6_mc_input;
	} else {
		rt->dst.input = ip6_forward;
	}

1113 1114
	if (res->nh->fib_nh_lws) {
		rt->dst.lwtstate = lwtstate_get(res->nh->fib_nh_lws);
1115 1116 1117 1118 1119 1120
		lwtunnel_set_redirect(&rt->dst);
	}

	rt->dst.lastuse = jiffies;
}

1121
/* Caller must already hold reference to @from */
1122
static void rt6_set_from(struct rt6_info *rt, struct fib6_info *from)
1123 1124
{
	rt->rt6i_flags &= ~RTF_EXPIRES;
1125
	rcu_assign_pointer(rt->from, from);
1126
	ip_dst_init_metrics(&rt->dst, from->fib6_metrics);
1127 1128
}

1129 1130
/* Caller must already hold reference to f6i in result */
static void ip6_rt_copy_init(struct rt6_info *rt, const struct fib6_result *res)
1131
{
1132 1133 1134
	const struct fib6_nh *nh = res->nh;
	const struct net_device *dev = nh->fib_nh_dev;
	struct fib6_info *f6i = res->f6i;
D
David Ahern 已提交
1135

1136
	ip6_rt_init_dst(rt, res);
1137

1138
	rt->rt6i_dst = f6i->fib6_dst;
D
David Ahern 已提交
1139
	rt->rt6i_idev = dev ? in6_dev_get(dev) : NULL;
1140
	rt->rt6i_flags = res->fib6_flags;
1141 1142
	if (nh->fib_nh_gw_family) {
		rt->rt6i_gateway = nh->fib_nh_gw6;
1143 1144
		rt->rt6i_flags |= RTF_GATEWAY;
	}
1145
	rt6_set_from(rt, f6i);
1146
#ifdef CONFIG_IPV6_SUBTREES
1147
	rt->rt6i_src = f6i->fib6_src;
1148 1149 1150
#endif
}

M
Martin KaFai Lau 已提交
1151 1152 1153
static struct fib6_node* fib6_backtrack(struct fib6_node *fn,
					struct in6_addr *saddr)
{
1154
	struct fib6_node *pn, *sn;
M
Martin KaFai Lau 已提交
1155 1156 1157
	while (1) {
		if (fn->fn_flags & RTN_TL_ROOT)
			return NULL;
1158 1159 1160
		pn = rcu_dereference(fn->parent);
		sn = FIB6_SUBTREE(pn);
		if (sn && sn != fn)
1161
			fn = fib6_node_lookup(sn, NULL, saddr);
M
Martin KaFai Lau 已提交
1162 1163 1164 1165 1166 1167
		else
			fn = pn;
		if (fn->fn_flags & RTN_RTINFO)
			return fn;
	}
}
T
Thomas Graf 已提交
1168

1169
static bool ip6_hold_safe(struct net *net, struct rt6_info **prt)
1170 1171 1172 1173 1174
{
	struct rt6_info *rt = *prt;

	if (dst_hold_safe(&rt->dst))
		return true;
1175
	if (net) {
1176 1177 1178 1179 1180 1181 1182 1183 1184
		rt = net->ipv6.ip6_null_entry;
		dst_hold(&rt->dst);
	} else {
		rt = NULL;
	}
	*prt = rt;
	return false;
}

1185
/* called with rcu_lock held */
1186
static struct rt6_info *ip6_create_rt_rcu(const struct fib6_result *res)
1187
{
1188 1189 1190
	struct net_device *dev = res->nh->fib_nh_dev;
	struct fib6_info *f6i = res->f6i;
	unsigned short flags;
1191 1192
	struct rt6_info *nrt;

1193
	if (!fib6_info_hold_safe(f6i))
1194
		goto fallback;
1195

1196
	flags = fib6_info_dst_flags(f6i);
1197
	nrt = ip6_dst_alloc(dev_net(dev), dev, flags);
1198
	if (!nrt) {
1199
		fib6_info_release(f6i);
1200 1201
		goto fallback;
	}
1202

1203
	ip6_rt_copy_init(nrt, res);
1204 1205 1206 1207 1208
	return nrt;

fallback:
	nrt = dev_net(dev)->ipv6.ip6_null_entry;
	dst_hold(&nrt->dst);
1209 1210 1211
	return nrt;
}

1212 1213
static struct rt6_info *ip6_pol_route_lookup(struct net *net,
					     struct fib6_table *table,
D
David Ahern 已提交
1214 1215 1216
					     struct flowi6 *fl6,
					     const struct sk_buff *skb,
					     int flags)
L
Linus Torvalds 已提交
1217
{
1218
	struct fib6_result res = {};
L
Linus Torvalds 已提交
1219
	struct fib6_node *fn;
1220
	struct rt6_info *rt;
L
Linus Torvalds 已提交
1221

1222 1223 1224
	if (fl6->flowi6_flags & FLOWI_FLAG_SKIP_NH_OIF)
		flags &= ~RT6_LOOKUP_F_IFACE;

1225
	rcu_read_lock();
1226
	fn = fib6_node_lookup(&table->tb6_root, &fl6->daddr, &fl6->saddr);
T
Thomas Graf 已提交
1227
restart:
1228 1229 1230
	res.f6i = rcu_dereference(fn->leaf);
	if (!res.f6i)
		res.f6i = net->ipv6.fib6_null_entry;
1231
	else
1232 1233
		rt6_device_match(net, &res, &fl6->saddr, fl6->flowi6_oif,
				 flags);
1234

1235
	if (res.f6i == net->ipv6.fib6_null_entry) {
M
Martin KaFai Lau 已提交
1236 1237 1238
		fn = fib6_backtrack(fn, &fl6->saddr);
		if (fn)
			goto restart;
1239

1240 1241 1242
		rt = net->ipv6.ip6_null_entry;
		dst_hold(&rt->dst);
		goto out;
1243 1244
	} else if (res.fib6_flags & RTF_REJECT) {
		goto do_create;
1245
	}
1246

1247 1248 1249
	fib6_select_path(net, &res, fl6, fl6->flowi6_oif,
			 fl6->flowi6_oif != 0, skb, flags);

1250
	/* Search through exception table */
1251
	rt = rt6_find_cached_rt(&res, &fl6->daddr, &fl6->saddr);
1252
	if (rt) {
1253
		if (ip6_hold_safe(net, &rt))
1254
			dst_use_noref(&rt->dst, jiffies);
1255
	} else {
1256
do_create:
1257
		rt = ip6_create_rt_rcu(&res);
1258
	}
D
David Ahern 已提交
1259

1260
out:
1261
	trace_fib6_table_lookup(net, &res, table, fl6);
1262

1263
	rcu_read_unlock();
D
David Ahern 已提交
1264

T
Thomas Graf 已提交
1265 1266 1267
	return rt;
}

1268
struct dst_entry *ip6_route_lookup(struct net *net, struct flowi6 *fl6,
D
David Ahern 已提交
1269
				   const struct sk_buff *skb, int flags)
F
Florian Westphal 已提交
1270
{
D
David Ahern 已提交
1271
	return fib6_rule_lookup(net, fl6, skb, flags, ip6_pol_route_lookup);
F
Florian Westphal 已提交
1272 1273 1274
}
EXPORT_SYMBOL_GPL(ip6_route_lookup);

1275
struct rt6_info *rt6_lookup(struct net *net, const struct in6_addr *daddr,
D
David Ahern 已提交
1276 1277
			    const struct in6_addr *saddr, int oif,
			    const struct sk_buff *skb, int strict)
T
Thomas Graf 已提交
1278
{
1279 1280 1281
	struct flowi6 fl6 = {
		.flowi6_oif = oif,
		.daddr = *daddr,
T
Thomas Graf 已提交
1282 1283
	};
	struct dst_entry *dst;
1284
	int flags = strict ? RT6_LOOKUP_F_IFACE : 0;
T
Thomas Graf 已提交
1285

1286
	if (saddr) {
1287
		memcpy(&fl6.saddr, saddr, sizeof(*saddr));
1288 1289 1290
		flags |= RT6_LOOKUP_F_HAS_SADDR;
	}

D
David Ahern 已提交
1291
	dst = fib6_rule_lookup(net, &fl6, skb, flags, ip6_pol_route_lookup);
T
Thomas Graf 已提交
1292 1293 1294 1295 1296
	if (dst->error == 0)
		return (struct rt6_info *) dst;

	dst_release(dst);

L
Linus Torvalds 已提交
1297 1298
	return NULL;
}
1299 1300
EXPORT_SYMBOL(rt6_lookup);

T
Thomas Graf 已提交
1301
/* ip6_ins_rt is called with FREE table->tb6_lock.
1302 1303 1304
 * It takes new route entry, the addition fails by any reason the
 * route is released.
 * Caller must hold dst before calling it.
L
Linus Torvalds 已提交
1305 1306
 */

1307
static int __ip6_ins_rt(struct fib6_info *rt, struct nl_info *info,
1308
			struct netlink_ext_ack *extack)
L
Linus Torvalds 已提交
1309 1310
{
	int err;
T
Thomas Graf 已提交
1311
	struct fib6_table *table;
L
Linus Torvalds 已提交
1312

1313
	table = rt->fib6_table;
1314
	spin_lock_bh(&table->tb6_lock);
1315
	err = fib6_add(&table->tb6_root, rt, info, extack);
1316
	spin_unlock_bh(&table->tb6_lock);
L
Linus Torvalds 已提交
1317 1318 1319 1320

	return err;
}

1321
int ip6_ins_rt(struct net *net, struct fib6_info *rt)
1322
{
1323
	struct nl_info info = {	.nl_net = net, };
1324

1325
	return __ip6_ins_rt(rt, &info, NULL);
1326 1327
}

1328
static struct rt6_info *ip6_rt_cache_alloc(const struct fib6_result *res,
1329 1330
					   const struct in6_addr *daddr,
					   const struct in6_addr *saddr)
L
Linus Torvalds 已提交
1331
{
1332
	struct fib6_info *f6i = res->f6i;
1333
	struct net_device *dev;
L
Linus Torvalds 已提交
1334 1335 1336 1337 1338 1339
	struct rt6_info *rt;

	/*
	 *	Clone the route.
	 */

1340
	if (!fib6_info_hold_safe(f6i))
1341 1342
		return NULL;

1343
	dev = ip6_rt_get_dev_rcu(res);
1344
	rt = ip6_dst_alloc(dev_net(dev), dev, 0);
1345
	if (!rt) {
1346
		fib6_info_release(f6i);
M
Martin KaFai Lau 已提交
1347
		return NULL;
1348
	}
M
Martin KaFai Lau 已提交
1349

1350
	ip6_rt_copy_init(rt, res);
M
Martin KaFai Lau 已提交
1351 1352 1353 1354
	rt->rt6i_flags |= RTF_CACHE;
	rt->dst.flags |= DST_HOST;
	rt->rt6i_dst.addr = *daddr;
	rt->rt6i_dst.plen = 128;
L
Linus Torvalds 已提交
1355

1356 1357 1358
	if (!rt6_is_gw_or_nonexthop(res)) {
		if (f6i->fib6_dst.plen != 128 &&
		    ipv6_addr_equal(&f6i->fib6_dst.addr, daddr))
M
Martin KaFai Lau 已提交
1359
			rt->rt6i_flags |= RTF_ANYCAST;
L
Linus Torvalds 已提交
1360
#ifdef CONFIG_IPV6_SUBTREES
M
Martin KaFai Lau 已提交
1361 1362 1363
		if (rt->rt6i_src.plen && saddr) {
			rt->rt6i_src.addr = *saddr;
			rt->rt6i_src.plen = 128;
1364
		}
M
Martin KaFai Lau 已提交
1365
#endif
1366
	}
L
Linus Torvalds 已提交
1367

1368 1369
	return rt;
}
L
Linus Torvalds 已提交
1370

1371
static struct rt6_info *ip6_rt_pcpu_alloc(const struct fib6_result *res)
M
Martin KaFai Lau 已提交
1372
{
1373 1374
	struct fib6_info *f6i = res->f6i;
	unsigned short flags = fib6_info_dst_flags(f6i);
1375
	struct net_device *dev;
M
Martin KaFai Lau 已提交
1376 1377
	struct rt6_info *pcpu_rt;

1378
	if (!fib6_info_hold_safe(f6i))
1379 1380
		return NULL;

1381
	rcu_read_lock();
1382
	dev = ip6_rt_get_dev_rcu(res);
1383
	pcpu_rt = ip6_dst_alloc(dev_net(dev), dev, flags);
1384
	rcu_read_unlock();
1385
	if (!pcpu_rt) {
1386
		fib6_info_release(f6i);
M
Martin KaFai Lau 已提交
1387
		return NULL;
1388
	}
1389
	ip6_rt_copy_init(pcpu_rt, res);
M
Martin KaFai Lau 已提交
1390 1391 1392 1393
	pcpu_rt->rt6i_flags |= RTF_PCPU;
	return pcpu_rt;
}

1394
/* It should be called with rcu_read_lock() acquired */
1395
static struct rt6_info *rt6_get_pcpu_route(const struct fib6_result *res)
M
Martin KaFai Lau 已提交
1396
{
1397
	struct rt6_info *pcpu_rt;
M
Martin KaFai Lau 已提交
1398

1399
	pcpu_rt = this_cpu_read(*res->nh->rt6i_pcpu);
M
Martin KaFai Lau 已提交
1400

1401 1402 1403
	return pcpu_rt;
}

1404
static struct rt6_info *rt6_make_pcpu_route(struct net *net,
1405
					    const struct fib6_result *res)
1406 1407
{
	struct rt6_info *pcpu_rt, *prev, **p;
M
Martin KaFai Lau 已提交
1408

1409
	pcpu_rt = ip6_rt_pcpu_alloc(res);
1410 1411
	if (!pcpu_rt)
		return NULL;
M
Martin KaFai Lau 已提交
1412

1413
	p = this_cpu_ptr(res->nh->rt6i_pcpu);
1414
	prev = cmpxchg(p, NULL, pcpu_rt);
1415
	BUG_ON(prev);
1416

E
Eric Dumazet 已提交
1417 1418 1419 1420 1421 1422 1423
	if (res->f6i->fib6_destroying) {
		struct fib6_info *from;

		from = xchg((__force struct fib6_info **)&pcpu_rt->from, NULL);
		fib6_info_release(from);
	}

M
Martin KaFai Lau 已提交
1424 1425 1426
	return pcpu_rt;
}

1427 1428 1429 1430 1431 1432 1433 1434 1435 1436
/* exception hash table implementation
 */
static DEFINE_SPINLOCK(rt6_exception_lock);

/* Remove rt6_ex from hash table and free the memory
 * Caller must hold rt6_exception_lock
 */
static void rt6_remove_exception(struct rt6_exception_bucket *bucket,
				 struct rt6_exception *rt6_ex)
{
1437
	struct fib6_info *from;
1438
	struct net *net;
W
Wei Wang 已提交
1439

1440 1441
	if (!bucket || !rt6_ex)
		return;
1442 1443

	net = dev_net(rt6_ex->rt6i->dst.dev);
1444 1445 1446 1447 1448
	net->ipv6.rt6_stats->fib_rt_cache--;

	/* purge completely the exception to allow releasing the held resources:
	 * some [sk] cache may keep the dst around for unlimited time
	 */
1449
	from = xchg((__force struct fib6_info **)&rt6_ex->rt6i->from, NULL);
1450 1451 1452
	fib6_info_release(from);
	dst_dev_put(&rt6_ex->rt6i->dst);

1453
	hlist_del_rcu(&rt6_ex->hlist);
1454
	dst_release(&rt6_ex->rt6i->dst);
1455 1456 1457 1458 1459 1460 1461 1462 1463 1464 1465 1466 1467 1468 1469 1470 1471 1472 1473 1474 1475 1476 1477 1478 1479 1480 1481 1482 1483
	kfree_rcu(rt6_ex, rcu);
	WARN_ON_ONCE(!bucket->depth);
	bucket->depth--;
}

/* Remove oldest rt6_ex in bucket and free the memory
 * Caller must hold rt6_exception_lock
 */
static void rt6_exception_remove_oldest(struct rt6_exception_bucket *bucket)
{
	struct rt6_exception *rt6_ex, *oldest = NULL;

	if (!bucket)
		return;

	hlist_for_each_entry(rt6_ex, &bucket->chain, hlist) {
		if (!oldest || time_before(rt6_ex->stamp, oldest->stamp))
			oldest = rt6_ex;
	}
	rt6_remove_exception(bucket, oldest);
}

static u32 rt6_exception_hash(const struct in6_addr *dst,
			      const struct in6_addr *src)
{
	static u32 seed __read_mostly;
	u32 val;

	net_get_random_once(&seed, sizeof(seed));
1484
	val = jhash2((const u32 *)dst, sizeof(*dst)/sizeof(u32), seed);
1485 1486 1487

#ifdef CONFIG_IPV6_SUBTREES
	if (src)
1488
		val = jhash2((const u32 *)src, sizeof(*src)/sizeof(u32), val);
1489 1490 1491 1492 1493 1494 1495 1496 1497 1498 1499 1500 1501 1502 1503 1504 1505 1506 1507 1508 1509 1510 1511 1512 1513 1514 1515 1516 1517 1518 1519 1520 1521 1522 1523 1524 1525 1526 1527 1528 1529 1530 1531 1532 1533 1534 1535 1536 1537 1538 1539 1540 1541 1542 1543 1544 1545 1546 1547 1548 1549 1550 1551 1552 1553 1554 1555 1556 1557 1558 1559 1560
#endif
	return hash_32(val, FIB6_EXCEPTION_BUCKET_SIZE_SHIFT);
}

/* Helper function to find the cached rt in the hash table
 * and update bucket pointer to point to the bucket for this
 * (daddr, saddr) pair
 * Caller must hold rt6_exception_lock
 */
static struct rt6_exception *
__rt6_find_exception_spinlock(struct rt6_exception_bucket **bucket,
			      const struct in6_addr *daddr,
			      const struct in6_addr *saddr)
{
	struct rt6_exception *rt6_ex;
	u32 hval;

	if (!(*bucket) || !daddr)
		return NULL;

	hval = rt6_exception_hash(daddr, saddr);
	*bucket += hval;

	hlist_for_each_entry(rt6_ex, &(*bucket)->chain, hlist) {
		struct rt6_info *rt6 = rt6_ex->rt6i;
		bool matched = ipv6_addr_equal(daddr, &rt6->rt6i_dst.addr);

#ifdef CONFIG_IPV6_SUBTREES
		if (matched && saddr)
			matched = ipv6_addr_equal(saddr, &rt6->rt6i_src.addr);
#endif
		if (matched)
			return rt6_ex;
	}
	return NULL;
}

/* Helper function to find the cached rt in the hash table
 * and update bucket pointer to point to the bucket for this
 * (daddr, saddr) pair
 * Caller must hold rcu_read_lock()
 */
static struct rt6_exception *
__rt6_find_exception_rcu(struct rt6_exception_bucket **bucket,
			 const struct in6_addr *daddr,
			 const struct in6_addr *saddr)
{
	struct rt6_exception *rt6_ex;
	u32 hval;

	WARN_ON_ONCE(!rcu_read_lock_held());

	if (!(*bucket) || !daddr)
		return NULL;

	hval = rt6_exception_hash(daddr, saddr);
	*bucket += hval;

	hlist_for_each_entry_rcu(rt6_ex, &(*bucket)->chain, hlist) {
		struct rt6_info *rt6 = rt6_ex->rt6i;
		bool matched = ipv6_addr_equal(daddr, &rt6->rt6i_dst.addr);

#ifdef CONFIG_IPV6_SUBTREES
		if (matched && saddr)
			matched = ipv6_addr_equal(saddr, &rt6->rt6i_src.addr);
#endif
		if (matched)
			return rt6_ex;
	}
	return NULL;
}

1561
static unsigned int fib6_mtu(const struct fib6_result *res)
1562
{
1563
	const struct fib6_nh *nh = res->nh;
1564 1565
	unsigned int mtu;

1566 1567
	if (res->f6i->fib6_pmtu) {
		mtu = res->f6i->fib6_pmtu;
D
David Ahern 已提交
1568
	} else {
1569
		struct net_device *dev = nh->fib_nh_dev;
D
David Ahern 已提交
1570 1571 1572 1573 1574 1575 1576 1577
		struct inet6_dev *idev;

		rcu_read_lock();
		idev = __in6_dev_get(dev);
		mtu = idev->cnf.mtu6;
		rcu_read_unlock();
	}

1578 1579
	mtu = min_t(unsigned int, mtu, IP6_MAX_MTU);

1580
	return mtu - lwtunnel_headroom(nh->fib_nh_lws, mtu);
1581 1582
}

1583 1584 1585 1586 1587 1588 1589 1590 1591 1592 1593 1594 1595 1596 1597 1598 1599 1600 1601 1602 1603 1604 1605 1606 1607 1608 1609 1610 1611 1612 1613 1614 1615 1616 1617 1618 1619 1620 1621 1622 1623 1624 1625 1626 1627 1628 1629 1630 1631 1632 1633 1634 1635
#define FIB6_EXCEPTION_BUCKET_FLUSHED  0x1UL

/* used when the flushed bit is not relevant, only access to the bucket
 * (ie., all bucket users except rt6_insert_exception);
 *
 * called under rcu lock; sometimes called with rt6_exception_lock held
 */
static
struct rt6_exception_bucket *fib6_nh_get_excptn_bucket(const struct fib6_nh *nh,
						       spinlock_t *lock)
{
	struct rt6_exception_bucket *bucket;

	if (lock)
		bucket = rcu_dereference_protected(nh->rt6i_exception_bucket,
						   lockdep_is_held(lock));
	else
		bucket = rcu_dereference(nh->rt6i_exception_bucket);

	/* remove bucket flushed bit if set */
	if (bucket) {
		unsigned long p = (unsigned long)bucket;

		p &= ~FIB6_EXCEPTION_BUCKET_FLUSHED;
		bucket = (struct rt6_exception_bucket *)p;
	}

	return bucket;
}

static bool fib6_nh_excptn_bucket_flushed(struct rt6_exception_bucket *bucket)
{
	unsigned long p = (unsigned long)bucket;

	return !!(p & FIB6_EXCEPTION_BUCKET_FLUSHED);
}

/* called with rt6_exception_lock held */
static void fib6_nh_excptn_bucket_set_flushed(struct fib6_nh *nh,
					      spinlock_t *lock)
{
	struct rt6_exception_bucket *bucket;
	unsigned long p;

	bucket = rcu_dereference_protected(nh->rt6i_exception_bucket,
					   lockdep_is_held(lock));

	p = (unsigned long)bucket;
	p |= FIB6_EXCEPTION_BUCKET_FLUSHED;
	bucket = (struct rt6_exception_bucket *)p;
	rcu_assign_pointer(nh->rt6i_exception_bucket, bucket);
}

1636
static int rt6_insert_exception(struct rt6_info *nrt,
1637
				const struct fib6_result *res)
1638
{
1639
	struct net *net = dev_net(nrt->dst.dev);
1640
	struct rt6_exception_bucket *bucket;
1641
	struct fib6_info *f6i = res->f6i;
1642 1643
	struct in6_addr *src_key = NULL;
	struct rt6_exception *rt6_ex;
1644
	struct fib6_nh *nh = res->nh;
1645 1646 1647 1648
	int err = 0;

	spin_lock_bh(&rt6_exception_lock);

1649 1650
	bucket = rcu_dereference_protected(nh->rt6i_exception_bucket,
					  lockdep_is_held(&rt6_exception_lock));
1651 1652 1653 1654 1655 1656 1657
	if (!bucket) {
		bucket = kcalloc(FIB6_EXCEPTION_BUCKET_SIZE, sizeof(*bucket),
				 GFP_ATOMIC);
		if (!bucket) {
			err = -ENOMEM;
			goto out;
		}
1658 1659 1660 1661
		rcu_assign_pointer(nh->rt6i_exception_bucket, bucket);
	} else if (fib6_nh_excptn_bucket_flushed(bucket)) {
		err = -EINVAL;
		goto out;
1662 1663 1664
	}

#ifdef CONFIG_IPV6_SUBTREES
1665
	/* fib6_src.plen != 0 indicates f6i is in subtree
1666
	 * and exception table is indexed by a hash of
1667
	 * both fib6_dst and fib6_src.
1668
	 * Otherwise, the exception table is indexed by
1669
	 * a hash of only fib6_dst.
1670
	 */
1671
	if (f6i->fib6_src.plen)
1672 1673
		src_key = &nrt->rt6i_src.addr;
#endif
1674
	/* rt6_mtu_change() might lower mtu on f6i.
1675
	 * Only insert this exception route if its mtu
1676
	 * is less than f6i's mtu value.
1677
	 */
1678
	if (dst_metric_raw(&nrt->dst, RTAX_MTU) >= fib6_mtu(res)) {
1679 1680 1681
		err = -EINVAL;
		goto out;
	}
1682

1683 1684 1685 1686 1687 1688 1689 1690 1691 1692 1693 1694 1695 1696
	rt6_ex = __rt6_find_exception_spinlock(&bucket, &nrt->rt6i_dst.addr,
					       src_key);
	if (rt6_ex)
		rt6_remove_exception(bucket, rt6_ex);

	rt6_ex = kzalloc(sizeof(*rt6_ex), GFP_ATOMIC);
	if (!rt6_ex) {
		err = -ENOMEM;
		goto out;
	}
	rt6_ex->rt6i = nrt;
	rt6_ex->stamp = jiffies;
	hlist_add_head_rcu(&rt6_ex->hlist, &bucket->chain);
	bucket->depth++;
W
Wei Wang 已提交
1697
	net->ipv6.rt6_stats->fib_rt_cache++;
1698 1699 1700 1701 1702 1703 1704 1705

	if (bucket->depth > FIB6_MAX_DEPTH)
		rt6_exception_remove_oldest(bucket);

out:
	spin_unlock_bh(&rt6_exception_lock);

	/* Update fn->fn_sernum to invalidate all cached dst */
1706
	if (!err) {
1707 1708 1709
		spin_lock_bh(&f6i->fib6_table->tb6_lock);
		fib6_update_sernum(net, f6i);
		spin_unlock_bh(&f6i->fib6_table->tb6_lock);
1710 1711
		fib6_force_start_gc(net);
	}
1712 1713 1714 1715

	return err;
}

D
David Ahern 已提交
1716
static void fib6_nh_flush_exceptions(struct fib6_nh *nh, struct fib6_info *from)
1717 1718 1719 1720 1721 1722 1723 1724
{
	struct rt6_exception_bucket *bucket;
	struct rt6_exception *rt6_ex;
	struct hlist_node *tmp;
	int i;

	spin_lock_bh(&rt6_exception_lock);

1725
	bucket = fib6_nh_get_excptn_bucket(nh, &rt6_exception_lock);
1726 1727 1728
	if (!bucket)
		goto out;

1729 1730 1731 1732
	/* Prevent rt6_insert_exception() to recreate the bucket list */
	if (!from)
		fib6_nh_excptn_bucket_set_flushed(nh, &rt6_exception_lock);

1733
	for (i = 0; i < FIB6_EXCEPTION_BUCKET_SIZE; i++) {
1734 1735 1736 1737 1738 1739
		hlist_for_each_entry_safe(rt6_ex, tmp, &bucket->chain, hlist) {
			if (!from ||
			    rcu_access_pointer(rt6_ex->rt6i->from) == from)
				rt6_remove_exception(bucket, rt6_ex);
		}
		WARN_ON_ONCE(!from && bucket->depth);
1740 1741 1742 1743 1744 1745
		bucket++;
	}
out:
	spin_unlock_bh(&rt6_exception_lock);
}

1746 1747 1748 1749 1750 1751 1752 1753 1754
static int rt6_nh_flush_exceptions(struct fib6_nh *nh, void *arg)
{
	struct fib6_info *f6i = arg;

	fib6_nh_flush_exceptions(nh, f6i);

	return 0;
}

D
David Ahern 已提交
1755 1756
void rt6_flush_exceptions(struct fib6_info *f6i)
{
1757 1758 1759 1760 1761
	if (f6i->nh)
		nexthop_for_each_fib6_nh(f6i->nh, rt6_nh_flush_exceptions,
					 f6i);
	else
		fib6_nh_flush_exceptions(f6i->fib6_nh, f6i);
D
David Ahern 已提交
1762 1763
}

1764 1765 1766
/* Find cached rt in the hash table inside passed in rt
 * Caller has to hold rcu_read_lock()
 */
1767
static struct rt6_info *rt6_find_cached_rt(const struct fib6_result *res,
1768 1769
					   const struct in6_addr *daddr,
					   const struct in6_addr *saddr)
1770
{
1771
	const struct in6_addr *src_key = NULL;
1772 1773
	struct rt6_exception_bucket *bucket;
	struct rt6_exception *rt6_ex;
1774
	struct rt6_info *ret = NULL;
1775 1776

#ifdef CONFIG_IPV6_SUBTREES
1777
	/* fib6i_src.plen != 0 indicates f6i is in subtree
1778
	 * and exception table is indexed by a hash of
1779
	 * both fib6_dst and fib6_src.
1780 1781 1782 1783 1784 1785 1786
	 * However, the src addr used to create the hash
	 * might not be exactly the passed in saddr which
	 * is a /128 addr from the flow.
	 * So we need to use f6i->fib6_src to redo lookup
	 * if the passed in saddr does not find anything.
	 * (See the logic in ip6_rt_cache_alloc() on how
	 * rt->rt6i_src is updated.)
1787
	 */
1788
	if (res->f6i->fib6_src.plen)
1789
		src_key = saddr;
1790
find_ex:
1791
#endif
1792
	bucket = fib6_nh_get_excptn_bucket(res->nh, NULL);
1793 1794 1795
	rt6_ex = __rt6_find_exception_rcu(&bucket, daddr, src_key);

	if (rt6_ex && !rt6_check_expired(rt6_ex->rt6i))
1796
		ret = rt6_ex->rt6i;
1797

1798 1799 1800 1801 1802 1803 1804 1805
#ifdef CONFIG_IPV6_SUBTREES
	/* Use fib6_src as src_key and redo lookup */
	if (!ret && src_key && src_key != &res->f6i->fib6_src.addr) {
		src_key = &res->f6i->fib6_src.addr;
		goto find_ex;
	}
#endif

1806
	return ret;
1807 1808 1809
}

/* Remove the passed in cached rt from the hash table that contains it */
1810
static int fib6_nh_remove_exception(const struct fib6_nh *nh, int plen,
D
David Ahern 已提交
1811
				    const struct rt6_info *rt)
1812
{
D
David Ahern 已提交
1813
	const struct in6_addr *src_key = NULL;
1814 1815 1816 1817
	struct rt6_exception_bucket *bucket;
	struct rt6_exception *rt6_ex;
	int err;

1818
	if (!rcu_access_pointer(nh->rt6i_exception_bucket))
1819 1820 1821
		return -ENOENT;

	spin_lock_bh(&rt6_exception_lock);
1822 1823
	bucket = fib6_nh_get_excptn_bucket(nh, &rt6_exception_lock);

1824
#ifdef CONFIG_IPV6_SUBTREES
1825 1826 1827
	/* rt6i_src.plen != 0 indicates 'from' is in subtree
	 * and exception table is indexed by a hash of
	 * both rt6i_dst and rt6i_src.
1828 1829 1830
	 * Otherwise, the exception table is indexed by
	 * a hash of only rt6i_dst.
	 */
D
David Ahern 已提交
1831
	if (plen)
1832 1833 1834 1835 1836 1837 1838 1839 1840 1841 1842 1843 1844 1845 1846 1847
		src_key = &rt->rt6i_src.addr;
#endif
	rt6_ex = __rt6_find_exception_spinlock(&bucket,
					       &rt->rt6i_dst.addr,
					       src_key);
	if (rt6_ex) {
		rt6_remove_exception(bucket, rt6_ex);
		err = 0;
	} else {
		err = -ENOENT;
	}

	spin_unlock_bh(&rt6_exception_lock);
	return err;
}

1848 1849 1850 1851 1852 1853 1854 1855 1856 1857 1858 1859 1860 1861 1862 1863 1864
struct fib6_nh_excptn_arg {
	struct rt6_info	*rt;
	int		plen;
};

static int rt6_nh_remove_exception_rt(struct fib6_nh *nh, void *_arg)
{
	struct fib6_nh_excptn_arg *arg = _arg;
	int err;

	err = fib6_nh_remove_exception(nh, arg->plen, arg->rt);
	if (err == 0)
		return 1;

	return 0;
}

D
David Ahern 已提交
1865 1866 1867 1868 1869
static int rt6_remove_exception_rt(struct rt6_info *rt)
{
	struct fib6_info *from;

	from = rcu_dereference(rt->from);
1870
	if (!from || !(rt->rt6i_flags & RTF_CACHE))
D
David Ahern 已提交
1871 1872
		return -EINVAL;

1873 1874 1875 1876 1877 1878 1879 1880 1881 1882 1883 1884 1885 1886
	if (from->nh) {
		struct fib6_nh_excptn_arg arg = {
			.rt = rt,
			.plen = from->fib6_src.plen
		};
		int rc;

		/* rc = 1 means an entry was found */
		rc = nexthop_for_each_fib6_nh(from->nh,
					      rt6_nh_remove_exception_rt,
					      &arg);
		return rc ? 0 : -ENOENT;
	}

1887
	return fib6_nh_remove_exception(from->fib6_nh,
1888
					from->fib6_src.plen, rt);
D
David Ahern 已提交
1889 1890
}

1891 1892 1893
/* Find rt6_ex which contains the passed in rt cache and
 * refresh its stamp
 */
1894
static void fib6_nh_update_exception(const struct fib6_nh *nh, int plen,
D
David Ahern 已提交
1895
				     const struct rt6_info *rt)
1896
{
D
David Ahern 已提交
1897
	const struct in6_addr *src_key = NULL;
1898 1899
	struct rt6_exception_bucket *bucket;
	struct rt6_exception *rt6_ex;
1900

1901
	bucket = fib6_nh_get_excptn_bucket(nh, NULL);
1902
#ifdef CONFIG_IPV6_SUBTREES
1903 1904 1905
	/* rt6i_src.plen != 0 indicates 'from' is in subtree
	 * and exception table is indexed by a hash of
	 * both rt6i_dst and rt6i_src.
1906 1907 1908
	 * Otherwise, the exception table is indexed by
	 * a hash of only rt6i_dst.
	 */
D
David Ahern 已提交
1909
	if (plen)
1910 1911
		src_key = &rt->rt6i_src.addr;
#endif
1912
	rt6_ex = __rt6_find_exception_rcu(&bucket, &rt->rt6i_dst.addr, src_key);
1913 1914
	if (rt6_ex)
		rt6_ex->stamp = jiffies;
D
David Ahern 已提交
1915 1916
}

1917 1918 1919 1920 1921 1922 1923 1924 1925 1926 1927 1928 1929 1930 1931 1932 1933 1934 1935 1936 1937 1938 1939
struct fib6_nh_match_arg {
	const struct net_device *dev;
	const struct in6_addr	*gw;
	struct fib6_nh		*match;
};

/* determine if fib6_nh has given device and gateway */
static int fib6_nh_find_match(struct fib6_nh *nh, void *_arg)
{
	struct fib6_nh_match_arg *arg = _arg;

	if (arg->dev != nh->fib_nh_dev ||
	    (arg->gw && !nh->fib_nh_gw_family) ||
	    (!arg->gw && nh->fib_nh_gw_family) ||
	    (arg->gw && !ipv6_addr_equal(arg->gw, &nh->fib_nh_gw6)))
		return 0;

	arg->match = nh;

	/* found a match, break the loop */
	return 1;
}

D
David Ahern 已提交
1940 1941 1942
static void rt6_update_exception_stamp_rt(struct rt6_info *rt)
{
	struct fib6_info *from;
1943
	struct fib6_nh *fib6_nh;
1944

D
David Ahern 已提交
1945 1946 1947 1948 1949 1950
	rcu_read_lock();

	from = rcu_dereference(rt->from);
	if (!from || !(rt->rt6i_flags & RTF_CACHE))
		goto unlock;

1951 1952 1953 1954 1955 1956 1957 1958 1959
	if (from->nh) {
		struct fib6_nh_match_arg arg = {
			.dev = rt->dst.dev,
			.gw = &rt->rt6i_gateway,
		};

		nexthop_for_each_fib6_nh(from->nh, fib6_nh_find_match, &arg);

		if (!arg.match)
1960
			goto unlock;
1961 1962 1963 1964 1965
		fib6_nh = arg.match;
	} else {
		fib6_nh = from->fib6_nh;
	}
	fib6_nh_update_exception(fib6_nh, from->fib6_src.plen, rt);
1966
unlock:
1967 1968 1969
	rcu_read_unlock();
}

1970 1971 1972 1973 1974 1975 1976 1977 1978 1979 1980 1981 1982 1983 1984 1985 1986 1987 1988 1989 1990 1991 1992
static bool rt6_mtu_change_route_allowed(struct inet6_dev *idev,
					 struct rt6_info *rt, int mtu)
{
	/* If the new MTU is lower than the route PMTU, this new MTU will be the
	 * lowest MTU in the path: always allow updating the route PMTU to
	 * reflect PMTU decreases.
	 *
	 * If the new MTU is higher, and the route PMTU is equal to the local
	 * MTU, this means the old MTU is the lowest in the path, so allow
	 * updating it: if other nodes now have lower MTUs, PMTU discovery will
	 * handle this.
	 */

	if (dst_mtu(&rt->dst) >= mtu)
		return true;

	if (dst_mtu(&rt->dst) == idev->cnf.mtu6)
		return true;

	return false;
}

static void rt6_exceptions_update_pmtu(struct inet6_dev *idev,
1993
				       const struct fib6_nh *nh, int mtu)
1994 1995 1996 1997 1998
{
	struct rt6_exception_bucket *bucket;
	struct rt6_exception *rt6_ex;
	int i;

1999
	bucket = fib6_nh_get_excptn_bucket(nh, &rt6_exception_lock);
2000 2001 2002 2003 2004 2005 2006 2007
	if (!bucket)
		return;

	for (i = 0; i < FIB6_EXCEPTION_BUCKET_SIZE; i++) {
		hlist_for_each_entry(rt6_ex, &bucket->chain, hlist) {
			struct rt6_info *entry = rt6_ex->rt6i;

			/* For RTF_CACHE with rt6i_pmtu == 0 (i.e. a redirected
2008
			 * route), the metrics of its rt->from have already
2009 2010
			 * been updated.
			 */
2011
			if (dst_metric_raw(&entry->dst, RTAX_MTU) &&
2012
			    rt6_mtu_change_route_allowed(idev, entry, mtu))
2013
				dst_metric_set(&entry->dst, RTAX_MTU, mtu);
2014
		}
2015
		bucket++;
2016 2017 2018
	}
}

2019 2020
#define RTF_CACHE_GATEWAY	(RTF_GATEWAY | RTF_CACHE)

2021 2022
static void fib6_nh_exceptions_clean_tohost(const struct fib6_nh *nh,
					    const struct in6_addr *gateway)
2023 2024 2025 2026 2027 2028
{
	struct rt6_exception_bucket *bucket;
	struct rt6_exception *rt6_ex;
	struct hlist_node *tmp;
	int i;

2029
	if (!rcu_access_pointer(nh->rt6i_exception_bucket))
2030 2031 2032
		return;

	spin_lock_bh(&rt6_exception_lock);
2033
	bucket = fib6_nh_get_excptn_bucket(nh, &rt6_exception_lock);
2034 2035 2036 2037 2038 2039 2040 2041 2042 2043 2044 2045 2046 2047 2048 2049 2050 2051 2052 2053
	if (bucket) {
		for (i = 0; i < FIB6_EXCEPTION_BUCKET_SIZE; i++) {
			hlist_for_each_entry_safe(rt6_ex, tmp,
						  &bucket->chain, hlist) {
				struct rt6_info *entry = rt6_ex->rt6i;

				if ((entry->rt6i_flags & RTF_CACHE_GATEWAY) ==
				    RTF_CACHE_GATEWAY &&
				    ipv6_addr_equal(gateway,
						    &entry->rt6i_gateway)) {
					rt6_remove_exception(bucket, rt6_ex);
				}
			}
			bucket++;
		}
	}

	spin_unlock_bh(&rt6_exception_lock);
}

2054 2055 2056 2057 2058 2059 2060
static void rt6_age_examine_exception(struct rt6_exception_bucket *bucket,
				      struct rt6_exception *rt6_ex,
				      struct fib6_gc_args *gc_args,
				      unsigned long now)
{
	struct rt6_info *rt = rt6_ex->rt6i;

2061 2062 2063 2064 2065 2066
	/* we are pruning and obsoleting aged-out and non gateway exceptions
	 * even if others have still references to them, so that on next
	 * dst_check() such references can be dropped.
	 * EXPIRES exceptions - e.g. pmtu-generated ones are pruned when
	 * expired, independently from their aging, as per RFC 8201 section 4
	 */
W
Wei Wang 已提交
2067 2068 2069 2070 2071 2072 2073 2074
	if (!(rt->rt6i_flags & RTF_EXPIRES)) {
		if (time_after_eq(now, rt->dst.lastuse + gc_args->timeout)) {
			RT6_TRACE("aging clone %p\n", rt);
			rt6_remove_exception(bucket, rt6_ex);
			return;
		}
	} else if (time_after(jiffies, rt->dst.expires)) {
		RT6_TRACE("purging expired route %p\n", rt);
2075 2076
		rt6_remove_exception(bucket, rt6_ex);
		return;
W
Wei Wang 已提交
2077 2078 2079
	}

	if (rt->rt6i_flags & RTF_GATEWAY) {
2080 2081 2082
		struct neighbour *neigh;
		__u8 neigh_flags = 0;

2083 2084
		neigh = __ipv6_neigh_lookup_noref(rt->dst.dev, &rt->rt6i_gateway);
		if (neigh)
2085
			neigh_flags = neigh->flags;
2086

2087 2088 2089 2090 2091 2092 2093
		if (!(neigh_flags & NTF_ROUTER)) {
			RT6_TRACE("purging route %p via non-router but gateway\n",
				  rt);
			rt6_remove_exception(bucket, rt6_ex);
			return;
		}
	}
W
Wei Wang 已提交
2094

2095 2096 2097
	gc_args->more++;
}

2098
static void fib6_nh_age_exceptions(const struct fib6_nh *nh,
D
David Ahern 已提交
2099 2100
				   struct fib6_gc_args *gc_args,
				   unsigned long now)
2101 2102 2103 2104 2105 2106
{
	struct rt6_exception_bucket *bucket;
	struct rt6_exception *rt6_ex;
	struct hlist_node *tmp;
	int i;

2107
	if (!rcu_access_pointer(nh->rt6i_exception_bucket))
2108 2109
		return;

2110 2111
	rcu_read_lock_bh();
	spin_lock(&rt6_exception_lock);
2112
	bucket = fib6_nh_get_excptn_bucket(nh, &rt6_exception_lock);
2113 2114 2115 2116 2117 2118 2119 2120 2121 2122
	if (bucket) {
		for (i = 0; i < FIB6_EXCEPTION_BUCKET_SIZE; i++) {
			hlist_for_each_entry_safe(rt6_ex, tmp,
						  &bucket->chain, hlist) {
				rt6_age_examine_exception(bucket, rt6_ex,
							  gc_args, now);
			}
			bucket++;
		}
	}
2123 2124
	spin_unlock(&rt6_exception_lock);
	rcu_read_unlock_bh();
2125 2126
}

2127 2128 2129 2130 2131 2132 2133 2134 2135 2136 2137 2138 2139
struct fib6_nh_age_excptn_arg {
	struct fib6_gc_args	*gc_args;
	unsigned long		now;
};

static int rt6_nh_age_exceptions(struct fib6_nh *nh, void *_arg)
{
	struct fib6_nh_age_excptn_arg *arg = _arg;

	fib6_nh_age_exceptions(nh, arg->gc_args, arg->now);
	return 0;
}

2140
void rt6_age_exceptions(struct fib6_info *f6i,
D
David Ahern 已提交
2141 2142 2143
			struct fib6_gc_args *gc_args,
			unsigned long now)
{
2144 2145 2146 2147 2148 2149 2150 2151 2152 2153 2154
	if (f6i->nh) {
		struct fib6_nh_age_excptn_arg arg = {
			.gc_args = gc_args,
			.now = now
		};

		nexthop_for_each_fib6_nh(f6i->nh, rt6_nh_age_exceptions,
					 &arg);
	} else {
		fib6_nh_age_exceptions(f6i->fib6_nh, gc_args, now);
	}
D
David Ahern 已提交
2155 2156
}

2157
/* must be called with rcu lock held */
2158 2159
int fib6_table_lookup(struct net *net, struct fib6_table *table, int oif,
		      struct flowi6 *fl6, struct fib6_result *res, int strict)
L
Linus Torvalds 已提交
2160
{
2161
	struct fib6_node *fn, *saved_fn;
L
Linus Torvalds 已提交
2162

2163
	fn = fib6_node_lookup(&table->tb6_root, &fl6->daddr, &fl6->saddr);
2164
	saved_fn = fn;
L
Linus Torvalds 已提交
2165

D
David Ahern 已提交
2166 2167 2168
	if (fl6->flowi6_flags & FLOWI_FLAG_SKIP_NH_OIF)
		oif = 0;

M
Martin KaFai Lau 已提交
2169
redo_rt6_select:
2170 2171
	rt6_select(net, fn, oif, res, strict);
	if (res->f6i == net->ipv6.fib6_null_entry) {
M
Martin KaFai Lau 已提交
2172 2173 2174
		fn = fib6_backtrack(fn, &fl6->saddr);
		if (fn)
			goto redo_rt6_select;
2175 2176 2177 2178 2179 2180
		else if (strict & RT6_LOOKUP_F_REACHABLE) {
			/* also consider unreachable route */
			strict &= ~RT6_LOOKUP_F_REACHABLE;
			fn = saved_fn;
			goto redo_rt6_select;
		}
M
Martin KaFai Lau 已提交
2181 2182
	}

2183
	trace_fib6_table_lookup(net, res, table, fl6);
2184

2185
	return 0;
2186 2187 2188 2189 2190 2191
}

struct rt6_info *ip6_pol_route(struct net *net, struct fib6_table *table,
			       int oif, struct flowi6 *fl6,
			       const struct sk_buff *skb, int flags)
{
2192
	struct fib6_result res = {};
2193
	struct rt6_info *rt = NULL;
2194 2195
	int strict = 0;

2196 2197 2198
	WARN_ON_ONCE((flags & RT6_LOOKUP_F_DST_NOREF) &&
		     !rcu_read_lock_held());

2199 2200 2201 2202 2203 2204 2205
	strict |= flags & RT6_LOOKUP_F_IFACE;
	strict |= flags & RT6_LOOKUP_F_IGNORE_LINKSTATE;
	if (net->ipv6.devconf_all->forwarding == 0)
		strict |= RT6_LOOKUP_F_REACHABLE;

	rcu_read_lock();

2206
	fib6_table_lookup(net, table, oif, fl6, &res, strict);
2207 2208
	if (res.f6i == net->ipv6.fib6_null_entry)
		goto out;
2209

2210
	fib6_select_path(net, &res, fl6, oif, false, skb, strict);
2211

2212
	/*Search through exception table */
2213
	rt = rt6_find_cached_rt(&res, &fl6->daddr, &fl6->saddr);
2214
	if (rt) {
2215
		goto out;
2216
	} else if (unlikely((fl6->flowi6_flags & FLOWI_FLAG_KNOWN_NH) &&
2217
			    !res.nh->fib_nh_gw_family)) {
2218 2219 2220 2221 2222
		/* Create a RTF_CACHE clone which will not be
		 * owned by the fib6 tree.  It is for the special case where
		 * the daddr in the skb during the neighbor look-up is different
		 * from the fl6->daddr used to look-up route here.
		 */
2223
		rt = ip6_rt_cache_alloc(&res, &fl6->daddr, NULL);
T
Thomas Graf 已提交
2224

2225 2226 2227 2228 2229
		if (rt) {
			/* 1 refcnt is taken during ip6_rt_cache_alloc().
			 * As rt6_uncached_list_add() does not consume refcnt,
			 * this refcnt is always returned to the caller even
			 * if caller sets RT6_LOOKUP_F_DST_NOREF flag.
2230
			 */
2231
			rt6_uncached_list_add(rt);
W
Wei Wang 已提交
2232
			atomic_inc(&net->ipv6.rt6_stats->fib_rt_uncache);
2233
			rcu_read_unlock();
D
David Ahern 已提交
2234

2235 2236
			return rt;
		}
M
Martin KaFai Lau 已提交
2237 2238
	} else {
		/* Get a percpu copy */
2239
		local_bh_disable();
2240
		rt = rt6_get_pcpu_route(&res);
M
Martin KaFai Lau 已提交
2241

2242 2243
		if (!rt)
			rt = rt6_make_pcpu_route(net, &res);
2244

2245
		local_bh_enable();
M
Martin KaFai Lau 已提交
2246
	}
2247 2248 2249 2250 2251 2252 2253 2254
out:
	if (!rt)
		rt = net->ipv6.ip6_null_entry;
	if (!(flags & RT6_LOOKUP_F_DST_NOREF))
		ip6_hold_safe(net, &rt);
	rcu_read_unlock();

	return rt;
L
Linus Torvalds 已提交
2255
}
2256
EXPORT_SYMBOL_GPL(ip6_pol_route);
L
Linus Torvalds 已提交
2257

D
David Ahern 已提交
2258 2259 2260 2261 2262
static struct rt6_info *ip6_pol_route_input(struct net *net,
					    struct fib6_table *table,
					    struct flowi6 *fl6,
					    const struct sk_buff *skb,
					    int flags)
2263
{
D
David Ahern 已提交
2264
	return ip6_pol_route(net, table, fl6->flowi6_iif, fl6, skb, flags);
2265 2266
}

2267 2268
struct dst_entry *ip6_route_input_lookup(struct net *net,
					 struct net_device *dev,
D
David Ahern 已提交
2269 2270 2271
					 struct flowi6 *fl6,
					 const struct sk_buff *skb,
					 int flags)
2272 2273 2274 2275
{
	if (rt6_need_strict(&fl6->daddr) && dev->type != ARPHRD_PIMREG)
		flags |= RT6_LOOKUP_F_IFACE;

D
David Ahern 已提交
2276
	return fib6_rule_lookup(net, fl6, skb, flags, ip6_pol_route_input);
2277
}
2278
EXPORT_SYMBOL_GPL(ip6_route_input_lookup);
2279

2280
static void ip6_multipath_l3_keys(const struct sk_buff *skb,
2281 2282
				  struct flow_keys *keys,
				  struct flow_keys *flkeys)
2283 2284 2285
{
	const struct ipv6hdr *outer_iph = ipv6_hdr(skb);
	const struct ipv6hdr *key_iph = outer_iph;
2286
	struct flow_keys *_flkeys = flkeys;
2287 2288 2289
	const struct ipv6hdr *inner_iph;
	const struct icmp6hdr *icmph;
	struct ipv6hdr _inner_iph;
2290
	struct icmp6hdr _icmph;
2291 2292 2293 2294

	if (likely(outer_iph->nexthdr != IPPROTO_ICMPV6))
		goto out;

2295 2296 2297 2298 2299
	icmph = skb_header_pointer(skb, skb_transport_offset(skb),
				   sizeof(_icmph), &_icmph);
	if (!icmph)
		goto out;

M
Matteo Croce 已提交
2300
	if (!icmpv6_is_err(icmph->icmp6_type))
2301 2302 2303 2304 2305 2306 2307 2308 2309
		goto out;

	inner_iph = skb_header_pointer(skb,
				       skb_transport_offset(skb) + sizeof(*icmph),
				       sizeof(_inner_iph), &_inner_iph);
	if (!inner_iph)
		goto out;

	key_iph = inner_iph;
2310
	_flkeys = NULL;
2311
out:
2312 2313 2314 2315 2316 2317 2318 2319
	if (_flkeys) {
		keys->addrs.v6addrs.src = _flkeys->addrs.v6addrs.src;
		keys->addrs.v6addrs.dst = _flkeys->addrs.v6addrs.dst;
		keys->tags.flow_label = _flkeys->tags.flow_label;
		keys->basic.ip_proto = _flkeys->basic.ip_proto;
	} else {
		keys->addrs.v6addrs.src = key_iph->saddr;
		keys->addrs.v6addrs.dst = key_iph->daddr;
2320
		keys->tags.flow_label = ip6_flowlabel(key_iph);
2321 2322
		keys->basic.ip_proto = key_iph->nexthdr;
	}
2323 2324 2325
}

/* if skb is set it will be used and fl6 can be NULL */
2326 2327
u32 rt6_multipath_hash(const struct net *net, const struct flowi6 *fl6,
		       const struct sk_buff *skb, struct flow_keys *flkeys)
2328 2329
{
	struct flow_keys hash_keys;
2330
	u32 mhash;
2331

2332
	switch (ip6_multipath_hash_policy(net)) {
2333 2334 2335 2336 2337 2338 2339 2340
	case 0:
		memset(&hash_keys, 0, sizeof(hash_keys));
		hash_keys.control.addr_type = FLOW_DISSECTOR_KEY_IPV6_ADDRS;
		if (skb) {
			ip6_multipath_l3_keys(skb, &hash_keys, flkeys);
		} else {
			hash_keys.addrs.v6addrs.src = fl6->saddr;
			hash_keys.addrs.v6addrs.dst = fl6->daddr;
2341
			hash_keys.tags.flow_label = (__force u32)flowi6_get_flowlabel(fl6);
2342 2343 2344 2345 2346 2347 2348 2349 2350 2351 2352 2353 2354 2355 2356 2357 2358 2359 2360 2361 2362 2363 2364 2365 2366 2367 2368 2369 2370 2371 2372 2373 2374 2375
			hash_keys.basic.ip_proto = fl6->flowi6_proto;
		}
		break;
	case 1:
		if (skb) {
			unsigned int flag = FLOW_DISSECTOR_F_STOP_AT_ENCAP;
			struct flow_keys keys;

			/* short-circuit if we already have L4 hash present */
			if (skb->l4_hash)
				return skb_get_hash_raw(skb) >> 1;

			memset(&hash_keys, 0, sizeof(hash_keys));

                        if (!flkeys) {
				skb_flow_dissect_flow_keys(skb, &keys, flag);
				flkeys = &keys;
			}
			hash_keys.control.addr_type = FLOW_DISSECTOR_KEY_IPV6_ADDRS;
			hash_keys.addrs.v6addrs.src = flkeys->addrs.v6addrs.src;
			hash_keys.addrs.v6addrs.dst = flkeys->addrs.v6addrs.dst;
			hash_keys.ports.src = flkeys->ports.src;
			hash_keys.ports.dst = flkeys->ports.dst;
			hash_keys.basic.ip_proto = flkeys->basic.ip_proto;
		} else {
			memset(&hash_keys, 0, sizeof(hash_keys));
			hash_keys.control.addr_type = FLOW_DISSECTOR_KEY_IPV6_ADDRS;
			hash_keys.addrs.v6addrs.src = fl6->saddr;
			hash_keys.addrs.v6addrs.dst = fl6->daddr;
			hash_keys.ports.src = fl6->fl6_sport;
			hash_keys.ports.dst = fl6->fl6_dport;
			hash_keys.basic.ip_proto = fl6->flowi6_proto;
		}
		break;
2376 2377 2378 2379 2380 2381 2382 2383 2384 2385 2386 2387 2388 2389 2390 2391 2392 2393 2394 2395 2396 2397 2398 2399 2400 2401 2402 2403 2404 2405 2406 2407 2408 2409 2410 2411
	case 2:
		memset(&hash_keys, 0, sizeof(hash_keys));
		hash_keys.control.addr_type = FLOW_DISSECTOR_KEY_IPV6_ADDRS;
		if (skb) {
			struct flow_keys keys;

			if (!flkeys) {
				skb_flow_dissect_flow_keys(skb, &keys, 0);
				flkeys = &keys;
			}

			/* Inner can be v4 or v6 */
			if (flkeys->control.addr_type == FLOW_DISSECTOR_KEY_IPV4_ADDRS) {
				hash_keys.control.addr_type = FLOW_DISSECTOR_KEY_IPV4_ADDRS;
				hash_keys.addrs.v4addrs.src = flkeys->addrs.v4addrs.src;
				hash_keys.addrs.v4addrs.dst = flkeys->addrs.v4addrs.dst;
			} else if (flkeys->control.addr_type == FLOW_DISSECTOR_KEY_IPV6_ADDRS) {
				hash_keys.control.addr_type = FLOW_DISSECTOR_KEY_IPV6_ADDRS;
				hash_keys.addrs.v6addrs.src = flkeys->addrs.v6addrs.src;
				hash_keys.addrs.v6addrs.dst = flkeys->addrs.v6addrs.dst;
				hash_keys.tags.flow_label = flkeys->tags.flow_label;
				hash_keys.basic.ip_proto = flkeys->basic.ip_proto;
			} else {
				/* Same as case 0 */
				hash_keys.control.addr_type = FLOW_DISSECTOR_KEY_IPV6_ADDRS;
				ip6_multipath_l3_keys(skb, &hash_keys, flkeys);
			}
		} else {
			/* Same as case 0 */
			hash_keys.control.addr_type = FLOW_DISSECTOR_KEY_IPV6_ADDRS;
			hash_keys.addrs.v6addrs.src = fl6->saddr;
			hash_keys.addrs.v6addrs.dst = fl6->daddr;
			hash_keys.tags.flow_label = (__force u32)flowi6_get_flowlabel(fl6);
			hash_keys.basic.ip_proto = fl6->flowi6_proto;
		}
		break;
2412
	}
2413
	mhash = flow_hash_from_keys(&hash_keys);
2414

2415
	return mhash >> 1;
2416 2417
}

2418
/* Called with rcu held */
T
Thomas Graf 已提交
2419 2420
void ip6_route_input(struct sk_buff *skb)
{
2421
	const struct ipv6hdr *iph = ipv6_hdr(skb);
2422
	struct net *net = dev_net(skb->dev);
2423
	int flags = RT6_LOOKUP_F_HAS_SADDR | RT6_LOOKUP_F_DST_NOREF;
2424
	struct ip_tunnel_info *tun_info;
2425
	struct flowi6 fl6 = {
2426
		.flowi6_iif = skb->dev->ifindex,
2427 2428
		.daddr = iph->daddr,
		.saddr = iph->saddr,
2429
		.flowlabel = ip6_flowinfo(iph),
2430 2431
		.flowi6_mark = skb->mark,
		.flowi6_proto = iph->nexthdr,
T
Thomas Graf 已提交
2432
	};
2433
	struct flow_keys *flkeys = NULL, _flkeys;
2434

2435
	tun_info = skb_tunnel_info(skb);
2436
	if (tun_info && !(tun_info->mode & IP_TUNNEL_INFO_TX))
2437
		fl6.flowi6_tun_key.tun_id = tun_info->key.tun_id;
2438 2439 2440 2441

	if (fib6_rules_early_flow_dissect(net, skb, &fl6, &_flkeys))
		flkeys = &_flkeys;

2442
	if (unlikely(fl6.flowi6_proto == IPPROTO_ICMPV6))
2443
		fl6.mp_hash = rt6_multipath_hash(net, &fl6, skb, flkeys);
2444
	skb_dst_drop(skb);
2445 2446
	skb_dst_set_noref(skb, ip6_route_input_lookup(net, skb->dev,
						      &fl6, skb, flags));
T
Thomas Graf 已提交
2447 2448
}

D
David Ahern 已提交
2449 2450 2451 2452 2453
static struct rt6_info *ip6_pol_route_output(struct net *net,
					     struct fib6_table *table,
					     struct flowi6 *fl6,
					     const struct sk_buff *skb,
					     int flags)
L
Linus Torvalds 已提交
2454
{
D
David Ahern 已提交
2455
	return ip6_pol_route(net, table, fl6->flowi6_oif, fl6, skb, flags);
T
Thomas Graf 已提交
2456 2457
}

2458 2459 2460
struct dst_entry *ip6_route_output_flags_noref(struct net *net,
					       const struct sock *sk,
					       struct flowi6 *fl6, int flags)
T
Thomas Graf 已提交
2461
{
2462
	bool any_src;
T
Thomas Graf 已提交
2463

2464 2465
	if (ipv6_addr_type(&fl6->daddr) &
	    (IPV6_ADDR_MULTICAST | IPV6_ADDR_LINKLOCAL)) {
2466 2467
		struct dst_entry *dst;

2468
		/* This function does not take refcnt on the dst */
2469 2470 2471 2472
		dst = l3mdev_link_scope_lookup(net, fl6);
		if (dst)
			return dst;
	}
D
David Ahern 已提交
2473

2474
	fl6->flowi6_iif = LOOPBACK_IFINDEX;
2475

2476
	flags |= RT6_LOOKUP_F_DST_NOREF;
2477
	any_src = ipv6_addr_any(&fl6->saddr);
2478
	if ((sk && sk->sk_bound_dev_if) || rt6_need_strict(&fl6->daddr) ||
2479
	    (fl6->flowi6_oif && any_src))
2480
		flags |= RT6_LOOKUP_F_IFACE;
T
Thomas Graf 已提交
2481

2482
	if (!any_src)
2483
		flags |= RT6_LOOKUP_F_HAS_SADDR;
2484 2485
	else if (sk)
		flags |= rt6_srcprefs2flags(inet6_sk(sk)->srcprefs);
2486

D
David Ahern 已提交
2487
	return fib6_rule_lookup(net, fl6, NULL, flags, ip6_pol_route_output);
L
Linus Torvalds 已提交
2488
}
2489 2490 2491 2492 2493 2494 2495 2496 2497 2498 2499 2500 2501 2502 2503 2504 2505 2506 2507 2508 2509 2510
EXPORT_SYMBOL_GPL(ip6_route_output_flags_noref);

struct dst_entry *ip6_route_output_flags(struct net *net,
					 const struct sock *sk,
					 struct flowi6 *fl6,
					 int flags)
{
        struct dst_entry *dst;
        struct rt6_info *rt6;

        rcu_read_lock();
        dst = ip6_route_output_flags_noref(net, sk, fl6, flags);
        rt6 = (struct rt6_info *)dst;
        /* For dst cached in uncached_list, refcnt is already taken. */
        if (list_empty(&rt6->rt6i_uncached) && !dst_hold_safe(dst)) {
                dst = &net->ipv6.ip6_null_entry->dst;
                dst_hold(dst);
        }
        rcu_read_unlock();

        return dst;
}
2511
EXPORT_SYMBOL_GPL(ip6_route_output_flags);
L
Linus Torvalds 已提交
2512

2513
struct dst_entry *ip6_blackhole_route(struct net *net, struct dst_entry *dst_orig)
2514
{
2515
	struct rt6_info *rt, *ort = (struct rt6_info *) dst_orig;
2516
	struct net_device *loopback_dev = net->loopback_dev;
2517 2518
	struct dst_entry *new = NULL;

2519
	rt = dst_alloc(&ip6_dst_blackhole_ops, loopback_dev, 1,
2520
		       DST_OBSOLETE_DEAD, 0);
2521
	if (rt) {
2522
		rt6_info_init(rt);
W
Wei Wang 已提交
2523
		atomic_inc(&net->ipv6.rt6_stats->fib_rt_alloc);
2524

2525
		new = &rt->dst;
2526
		new->__use = 1;
2527
		new->input = dst_discard;
E
Eric W. Biederman 已提交
2528
		new->output = dst_discard_out;
2529

2530
		dst_copy_metrics(new, &ort->dst);
2531

2532
		rt->rt6i_idev = in6_dev_get(loopback_dev);
A
Alexey Dobriyan 已提交
2533
		rt->rt6i_gateway = ort->rt6i_gateway;
2534
		rt->rt6i_flags = ort->rt6i_flags & ~RTF_PCPU;
2535 2536 2537 2538 2539 2540 2541

		memcpy(&rt->rt6i_dst, &ort->rt6i_dst, sizeof(struct rt6key));
#ifdef CONFIG_IPV6_SUBTREES
		memcpy(&rt->rt6i_src, &ort->rt6i_src, sizeof(struct rt6key));
#endif
	}

2542 2543
	dst_release(dst_orig);
	return new ? new : ERR_PTR(-ENOMEM);
2544 2545
}

L
Linus Torvalds 已提交
2546 2547 2548 2549
/*
 *	Destination cache support functions
 */

2550
static bool fib6_check(struct fib6_info *f6i, u32 cookie)
2551
{
2552 2553
	u32 rt_cookie = 0;

2554
	if (!fib6_get_cookie_safe(f6i, &rt_cookie) || rt_cookie != cookie)
2555 2556 2557 2558 2559 2560
		return false;

	if (fib6_check_expired(f6i))
		return false;

	return true;
2561 2562
}

2563 2564 2565
static struct dst_entry *rt6_check(struct rt6_info *rt,
				   struct fib6_info *from,
				   u32 cookie)
2566
{
2567
	u32 rt_cookie = 0;
2568

2569
	if (!from || !fib6_get_cookie_safe(from, &rt_cookie) ||
2570
	    rt_cookie != cookie)
2571 2572 2573 2574 2575 2576 2577 2578
		return NULL;

	if (rt6_check_expired(rt))
		return NULL;

	return &rt->dst;
}

2579 2580 2581
static struct dst_entry *rt6_dst_from_check(struct rt6_info *rt,
					    struct fib6_info *from,
					    u32 cookie)
2582
{
2583 2584
	if (!__rt6_check_expired(rt) &&
	    rt->dst.obsolete == DST_OBSOLETE_FORCE_CHK &&
2585
	    fib6_check(from, cookie))
2586 2587 2588 2589 2590
		return &rt->dst;
	else
		return NULL;
}

L
Linus Torvalds 已提交
2591 2592
static struct dst_entry *ip6_dst_check(struct dst_entry *dst, u32 cookie)
{
2593
	struct dst_entry *dst_ret;
2594
	struct fib6_info *from;
L
Linus Torvalds 已提交
2595 2596
	struct rt6_info *rt;

2597 2598 2599
	rt = container_of(dst, struct rt6_info, dst);

	rcu_read_lock();
L
Linus Torvalds 已提交
2600

2601 2602 2603 2604
	/* All IPV6 dsts are created with ->obsolete set to the value
	 * DST_OBSOLETE_FORCE_CHK which forces validation calls down
	 * into this function always.
	 */
2605

2606
	from = rcu_dereference(rt->from);
2607

2608 2609 2610
	if (from && (rt->rt6i_flags & RTF_PCPU ||
	    unlikely(!list_empty(&rt->rt6i_uncached))))
		dst_ret = rt6_dst_from_check(rt, from, cookie);
2611
	else
2612
		dst_ret = rt6_check(rt, from, cookie);
2613 2614 2615 2616

	rcu_read_unlock();

	return dst_ret;
L
Linus Torvalds 已提交
2617 2618 2619 2620 2621 2622 2623
}

static struct dst_entry *ip6_negative_advice(struct dst_entry *dst)
{
	struct rt6_info *rt = (struct rt6_info *) dst;

	if (rt) {
2624
		if (rt->rt6i_flags & RTF_CACHE) {
2625
			rcu_read_lock();
2626
			if (rt6_check_expired(rt)) {
2627
				rt6_remove_exception_rt(rt);
2628 2629
				dst = NULL;
			}
2630
			rcu_read_unlock();
2631
		} else {
L
Linus Torvalds 已提交
2632
			dst_release(dst);
2633 2634
			dst = NULL;
		}
L
Linus Torvalds 已提交
2635
	}
2636
	return dst;
L
Linus Torvalds 已提交
2637 2638 2639 2640 2641 2642
}

static void ip6_link_failure(struct sk_buff *skb)
{
	struct rt6_info *rt;

2643
	icmpv6_send(skb, ICMPV6_DEST_UNREACH, ICMPV6_ADDR_UNREACH, 0);
L
Linus Torvalds 已提交
2644

E
Eric Dumazet 已提交
2645
	rt = (struct rt6_info *) skb_dst(skb);
L
Linus Torvalds 已提交
2646
	if (rt) {
2647
		rcu_read_lock();
2648
		if (rt->rt6i_flags & RTF_CACHE) {
2649
			rt6_remove_exception_rt(rt);
2650
		} else {
2651
			struct fib6_info *from;
2652 2653
			struct fib6_node *fn;

2654 2655 2656 2657 2658 2659
			from = rcu_dereference(rt->from);
			if (from) {
				fn = rcu_dereference(from->fib6_node);
				if (fn && (rt->rt6i_flags & RTF_DEFAULT))
					fn->fn_sernum = -1;
			}
2660
		}
2661
		rcu_read_unlock();
L
Linus Torvalds 已提交
2662 2663 2664
	}
}

2665 2666
static void rt6_update_expires(struct rt6_info *rt0, int timeout)
{
2667 2668 2669 2670 2671 2672 2673 2674 2675
	if (!(rt0->rt6i_flags & RTF_EXPIRES)) {
		struct fib6_info *from;

		rcu_read_lock();
		from = rcu_dereference(rt0->from);
		if (from)
			rt0->dst.expires = from->expires;
		rcu_read_unlock();
	}
2676 2677 2678 2679 2680

	dst_set_expires(&rt0->dst, timeout);
	rt0->rt6i_flags |= RTF_EXPIRES;
}

2681 2682 2683 2684
static void rt6_do_update_pmtu(struct rt6_info *rt, u32 mtu)
{
	struct net *net = dev_net(rt->dst.dev);

2685
	dst_metric_set(&rt->dst, RTAX_MTU, mtu);
2686 2687 2688 2689
	rt->rt6i_flags |= RTF_MODIFIED;
	rt6_update_expires(rt, net->ipv6.sysctl.ip6_rt_mtu_expires);
}

2690 2691 2692
static bool rt6_cache_allowed_for_pmtu(const struct rt6_info *rt)
{
	return !(rt->rt6i_flags & RTF_CACHE) &&
2693
		(rt->rt6i_flags & RTF_PCPU || rcu_access_pointer(rt->from));
2694 2695
}

2696
static void __ip6_rt_update_pmtu(struct dst_entry *dst, const struct sock *sk,
2697 2698
				 const struct ipv6hdr *iph, u32 mtu,
				 bool confirm_neigh)
L
Linus Torvalds 已提交
2699
{
2700
	const struct in6_addr *daddr, *saddr;
2701
	struct rt6_info *rt6 = (struct rt6_info *)dst;
L
Linus Torvalds 已提交
2702

2703 2704 2705
	if (dst_metric_locked(dst, RTAX_MTU))
		return;

2706 2707 2708 2709 2710 2711 2712 2713 2714 2715
	if (iph) {
		daddr = &iph->daddr;
		saddr = &iph->saddr;
	} else if (sk) {
		daddr = &sk->sk_v6_daddr;
		saddr = &inet6_sk(sk)->saddr;
	} else {
		daddr = NULL;
		saddr = NULL;
	}
2716 2717 2718 2719

	if (confirm_neigh)
		dst_confirm_neigh(dst, daddr);

2720 2721 2722
	mtu = max_t(u32, mtu, IPV6_MIN_MTU);
	if (mtu >= dst_mtu(dst))
		return;
2723

2724
	if (!rt6_cache_allowed_for_pmtu(rt6)) {
2725
		rt6_do_update_pmtu(rt6, mtu);
2726 2727 2728
		/* update rt6_ex->stamp for cache */
		if (rt6->rt6i_flags & RTF_CACHE)
			rt6_update_exception_stamp_rt(rt6);
2729
	} else if (daddr) {
2730
		struct fib6_result res = {};
2731 2732
		struct rt6_info *nrt6;

2733
		rcu_read_lock();
2734
		res.f6i = rcu_dereference(rt6->from);
2735 2736 2737
		if (!res.f6i)
			goto out_unlock;

2738 2739 2740
		res.fib6_flags = res.f6i->fib6_flags;
		res.fib6_type = res.f6i->fib6_type;

2741 2742 2743 2744 2745 2746 2747 2748 2749 2750 2751 2752
		if (res.f6i->nh) {
			struct fib6_nh_match_arg arg = {
				.dev = dst->dev,
				.gw = &rt6->rt6i_gateway,
			};

			nexthop_for_each_fib6_nh(res.f6i->nh,
						 fib6_nh_find_match, &arg);

			/* fib6_info uses a nexthop that does not have fib6_nh
			 * using the dst->dev + gw. Should be impossible.
			 */
2753 2754
			if (!arg.match)
				goto out_unlock;
2755 2756 2757 2758 2759 2760

			res.nh = arg.match;
		} else {
			res.nh = res.f6i->fib6_nh;
		}

2761
		nrt6 = ip6_rt_cache_alloc(&res, daddr, saddr);
2762 2763
		if (nrt6) {
			rt6_do_update_pmtu(nrt6, mtu);
2764
			if (rt6_insert_exception(nrt6, &res))
2765
				dst_release_immediate(&nrt6->dst);
2766
		}
2767
out_unlock:
2768
		rcu_read_unlock();
L
Linus Torvalds 已提交
2769 2770 2771
	}
}

2772
static void ip6_rt_update_pmtu(struct dst_entry *dst, struct sock *sk,
2773 2774
			       struct sk_buff *skb, u32 mtu,
			       bool confirm_neigh)
2775
{
2776 2777
	__ip6_rt_update_pmtu(dst, sk, skb ? ipv6_hdr(skb) : NULL, mtu,
			     confirm_neigh);
2778 2779
}

2780
void ip6_update_pmtu(struct sk_buff *skb, struct net *net, __be32 mtu,
2781
		     int oif, u32 mark, kuid_t uid)
2782 2783 2784
{
	const struct ipv6hdr *iph = (struct ipv6hdr *) skb->data;
	struct dst_entry *dst;
2785 2786 2787 2788 2789 2790 2791 2792
	struct flowi6 fl6 = {
		.flowi6_oif = oif,
		.flowi6_mark = mark ? mark : IP6_REPLY_MARK(net, skb->mark),
		.daddr = iph->daddr,
		.saddr = iph->saddr,
		.flowlabel = ip6_flowinfo(iph),
		.flowi6_uid = uid,
	};
2793 2794 2795

	dst = ip6_route_output(net, NULL, &fl6);
	if (!dst->error)
2796
		__ip6_rt_update_pmtu(dst, NULL, iph, ntohl(mtu), true);
2797 2798 2799 2800 2801 2802
	dst_release(dst);
}
EXPORT_SYMBOL_GPL(ip6_update_pmtu);

void ip6_sk_update_pmtu(struct sk_buff *skb, struct sock *sk, __be32 mtu)
{
2803
	int oif = sk->sk_bound_dev_if;
2804 2805
	struct dst_entry *dst;

2806 2807 2808 2809
	if (!oif && skb->dev)
		oif = l3mdev_master_ifindex(skb->dev);

	ip6_update_pmtu(skb, sock_net(sk), mtu, oif, sk->sk_mark, sk->sk_uid);
2810 2811 2812 2813 2814 2815 2816 2817 2818 2819

	dst = __sk_dst_get(sk);
	if (!dst || !dst->obsolete ||
	    dst->ops->check(dst, inet6_sk(sk)->dst_cookie))
		return;

	bh_lock_sock(sk);
	if (!sock_owned_by_user(sk) && !ipv6_addr_v4mapped(&sk->sk_v6_daddr))
		ip6_datagram_dst_update(sk, false);
	bh_unlock_sock(sk);
2820 2821 2822
}
EXPORT_SYMBOL_GPL(ip6_sk_update_pmtu);

2823 2824 2825 2826 2827 2828 2829 2830 2831 2832 2833 2834 2835 2836 2837 2838 2839
void ip6_sk_dst_store_flow(struct sock *sk, struct dst_entry *dst,
			   const struct flowi6 *fl6)
{
#ifdef CONFIG_IPV6_SUBTREES
	struct ipv6_pinfo *np = inet6_sk(sk);
#endif

	ip6_dst_store(sk, dst,
		      ipv6_addr_equal(&fl6->daddr, &sk->sk_v6_daddr) ?
		      &sk->sk_v6_daddr : NULL,
#ifdef CONFIG_IPV6_SUBTREES
		      ipv6_addr_equal(&fl6->saddr, &np->saddr) ?
		      &np->saddr :
#endif
		      NULL);
}

2840
static bool ip6_redirect_nh_match(const struct fib6_result *res,
2841 2842 2843 2844
				  struct flowi6 *fl6,
				  const struct in6_addr *gw,
				  struct rt6_info **ret)
{
2845 2846
	const struct fib6_nh *nh = res->nh;

2847 2848 2849 2850 2851 2852 2853 2854 2855 2856 2857 2858
	if (nh->fib_nh_flags & RTNH_F_DEAD || !nh->fib_nh_gw_family ||
	    fl6->flowi6_oif != nh->fib_nh_dev->ifindex)
		return false;

	/* rt_cache's gateway might be different from its 'parent'
	 * in the case of an ip redirect.
	 * So we keep searching in the exception table if the gateway
	 * is different.
	 */
	if (!ipv6_addr_equal(gw, &nh->fib_nh_gw6)) {
		struct rt6_info *rt_cache;

2859
		rt_cache = rt6_find_cached_rt(res, &fl6->daddr, &fl6->saddr);
2860 2861 2862 2863 2864 2865 2866 2867 2868 2869
		if (rt_cache &&
		    ipv6_addr_equal(gw, &rt_cache->rt6i_gateway)) {
			*ret = rt_cache;
			return true;
		}
		return false;
	}
	return true;
}

2870 2871 2872 2873 2874 2875 2876 2877 2878 2879 2880 2881 2882 2883 2884
struct fib6_nh_rd_arg {
	struct fib6_result	*res;
	struct flowi6		*fl6;
	const struct in6_addr	*gw;
	struct rt6_info		**ret;
};

static int fib6_nh_redirect_match(struct fib6_nh *nh, void *_arg)
{
	struct fib6_nh_rd_arg *arg = _arg;

	arg->res->nh = nh;
	return ip6_redirect_nh_match(arg->res, arg->fl6, arg->gw, arg->ret);
}

2885 2886 2887 2888 2889 2890 2891 2892 2893
/* Handle redirects */
struct ip6rd_flowi {
	struct flowi6 fl6;
	struct in6_addr gateway;
};

static struct rt6_info *__ip6_route_redirect(struct net *net,
					     struct fib6_table *table,
					     struct flowi6 *fl6,
D
David Ahern 已提交
2894
					     const struct sk_buff *skb,
2895 2896 2897
					     int flags)
{
	struct ip6rd_flowi *rdfl = (struct ip6rd_flowi *)fl6;
2898
	struct rt6_info *ret = NULL;
2899
	struct fib6_result res = {};
2900 2901 2902 2903 2904 2905
	struct fib6_nh_rd_arg arg = {
		.res = &res,
		.fl6 = fl6,
		.gw  = &rdfl->gateway,
		.ret = &ret
	};
2906
	struct fib6_info *rt;
2907 2908
	struct fib6_node *fn;

D
David Ahern 已提交
2909 2910 2911 2912 2913 2914
	/* l3mdev_update_flow overrides oif if the device is enslaved; in
	 * this case we must match on the real ingress device, so reset it
	 */
	if (fl6->flowi6_flags & FLOWI_FLAG_SKIP_NH_OIF)
		fl6->flowi6_oif = skb->dev->ifindex;

2915
	/* Get the "current" route for this destination and
A
Alexander Alemayhu 已提交
2916
	 * check if the redirect has come from appropriate router.
2917 2918 2919 2920 2921 2922 2923 2924
	 *
	 * RFC 4861 specifies that redirects should only be
	 * accepted if they come from the nexthop to the target.
	 * Due to the way the routes are chosen, this notion
	 * is a bit fuzzy and one might need to check all possible
	 * routes.
	 */

2925
	rcu_read_lock();
2926
	fn = fib6_node_lookup(&table->tb6_root, &fl6->daddr, &fl6->saddr);
2927
restart:
2928
	for_each_fib6_node_rt_rcu(fn) {
2929
		res.f6i = rt;
2930
		if (fib6_check_expired(rt))
2931
			continue;
2932
		if (rt->fib6_flags & RTF_REJECT)
2933
			break;
2934 2935 2936 2937 2938 2939 2940 2941 2942 2943 2944 2945 2946 2947
		if (unlikely(rt->nh)) {
			if (nexthop_is_blackhole(rt->nh))
				continue;
			/* on match, res->nh is filled in and potentially ret */
			if (nexthop_for_each_fib6_nh(rt->nh,
						     fib6_nh_redirect_match,
						     &arg))
				goto out;
		} else {
			res.nh = rt->fib6_nh;
			if (ip6_redirect_nh_match(&res, fl6, &rdfl->gateway,
						  &ret))
				goto out;
		}
2948 2949 2950
	}

	if (!rt)
D
David Ahern 已提交
2951
		rt = net->ipv6.fib6_null_entry;
2952
	else if (rt->fib6_flags & RTF_REJECT) {
2953
		ret = net->ipv6.ip6_null_entry;
2954 2955 2956
		goto out;
	}

D
David Ahern 已提交
2957
	if (rt == net->ipv6.fib6_null_entry) {
M
Martin KaFai Lau 已提交
2958 2959 2960
		fn = fib6_backtrack(fn, &fl6->saddr);
		if (fn)
			goto restart;
2961
	}
M
Martin KaFai Lau 已提交
2962

2963
	res.f6i = rt;
2964
	res.nh = rt->fib6_nh;
2965
out:
2966
	if (ret) {
2967
		ip6_hold_safe(net, &ret);
2968 2969 2970
	} else {
		res.fib6_flags = res.f6i->fib6_flags;
		res.fib6_type = res.f6i->fib6_type;
2971
		ret = ip6_create_rt_rcu(&res);
2972
	}
2973

2974
	rcu_read_unlock();
2975

2976
	trace_fib6_table_lookup(net, &res, table, fl6);
2977
	return ret;
2978 2979 2980
};

static struct dst_entry *ip6_route_redirect(struct net *net,
D
David Ahern 已提交
2981 2982 2983
					    const struct flowi6 *fl6,
					    const struct sk_buff *skb,
					    const struct in6_addr *gateway)
2984 2985 2986 2987 2988 2989 2990
{
	int flags = RT6_LOOKUP_F_HAS_SADDR;
	struct ip6rd_flowi rdfl;

	rdfl.fl6 = *fl6;
	rdfl.gateway = *gateway;

D
David Ahern 已提交
2991
	return fib6_rule_lookup(net, &rdfl.fl6, skb,
2992 2993 2994
				flags, __ip6_route_redirect);
}

2995 2996
void ip6_redirect(struct sk_buff *skb, struct net *net, int oif, u32 mark,
		  kuid_t uid)
2997 2998 2999
{
	const struct ipv6hdr *iph = (struct ipv6hdr *) skb->data;
	struct dst_entry *dst;
3000 3001 3002 3003 3004 3005 3006 3007 3008
	struct flowi6 fl6 = {
		.flowi6_iif = LOOPBACK_IFINDEX,
		.flowi6_oif = oif,
		.flowi6_mark = mark,
		.daddr = iph->daddr,
		.saddr = iph->saddr,
		.flowlabel = ip6_flowinfo(iph),
		.flowi6_uid = uid,
	};
3009

D
David Ahern 已提交
3010
	dst = ip6_route_redirect(net, &fl6, skb, &ipv6_hdr(skb)->saddr);
3011
	rt6_do_redirect(dst, NULL, skb);
3012 3013 3014 3015
	dst_release(dst);
}
EXPORT_SYMBOL_GPL(ip6_redirect);

3016
void ip6_redirect_no_header(struct sk_buff *skb, struct net *net, int oif)
3017 3018 3019 3020
{
	const struct ipv6hdr *iph = ipv6_hdr(skb);
	const struct rd_msg *msg = (struct rd_msg *)icmp6_hdr(skb);
	struct dst_entry *dst;
3021 3022 3023 3024 3025 3026 3027
	struct flowi6 fl6 = {
		.flowi6_iif = LOOPBACK_IFINDEX,
		.flowi6_oif = oif,
		.daddr = msg->dest,
		.saddr = iph->daddr,
		.flowi6_uid = sock_net_uid(net, NULL),
	};
3028

D
David Ahern 已提交
3029
	dst = ip6_route_redirect(net, &fl6, skb, &iph->saddr);
3030
	rt6_do_redirect(dst, NULL, skb);
3031 3032 3033
	dst_release(dst);
}

3034 3035
void ip6_sk_redirect(struct sk_buff *skb, struct sock *sk)
{
3036 3037
	ip6_redirect(skb, sock_net(sk), sk->sk_bound_dev_if, sk->sk_mark,
		     sk->sk_uid);
3038 3039 3040
}
EXPORT_SYMBOL_GPL(ip6_sk_redirect);

3041
static unsigned int ip6_default_advmss(const struct dst_entry *dst)
L
Linus Torvalds 已提交
3042
{
3043 3044 3045 3046
	struct net_device *dev = dst->dev;
	unsigned int mtu = dst_mtu(dst);
	struct net *net = dev_net(dev);

L
Linus Torvalds 已提交
3047 3048
	mtu -= sizeof(struct ipv6hdr) + sizeof(struct tcphdr);

3049 3050
	if (mtu < net->ipv6.sysctl.ip6_rt_min_advmss)
		mtu = net->ipv6.sysctl.ip6_rt_min_advmss;
L
Linus Torvalds 已提交
3051 3052

	/*
3053 3054 3055
	 * Maximal non-jumbo IPv6 payload is IPV6_MAXPLEN and
	 * corresponding MSS is IPV6_MAXPLEN - tcp_header_size.
	 * IPV6_MAXPLEN is also valid and means: "any MSS,
L
Linus Torvalds 已提交
3056 3057 3058 3059 3060 3061 3062
	 * rely only on pmtu discovery"
	 */
	if (mtu > IPV6_MAXPLEN - sizeof(struct tcphdr))
		mtu = IPV6_MAXPLEN;
	return mtu;
}

3063
static unsigned int ip6_mtu(const struct dst_entry *dst)
3064 3065
{
	struct inet6_dev *idev;
3066
	unsigned int mtu;
3067 3068

	mtu = dst_metric_raw(dst, RTAX_MTU);
3069
	if (mtu)
E
Eric Dumazet 已提交
3070
		goto out;
3071 3072

	mtu = IPV6_MIN_MTU;
3073 3074 3075 3076 3077 3078 3079

	rcu_read_lock();
	idev = __in6_dev_get(dst->dev);
	if (idev)
		mtu = idev->cnf.mtu6;
	rcu_read_unlock();

E
Eric Dumazet 已提交
3080
out:
3081 3082 3083
	mtu = min_t(unsigned int, mtu, IP6_MAX_MTU);

	return mtu - lwtunnel_headroom(dst->lwtstate, mtu);
3084 3085
}

3086 3087 3088 3089 3090 3091 3092 3093
/* MTU selection:
 * 1. mtu on route is locked - use it
 * 2. mtu from nexthop exception
 * 3. mtu from egress device
 *
 * based on ip6_dst_mtu_forward and exception logic of
 * rt6_find_cached_rt; called with rcu_read_lock
 */
3094 3095 3096
u32 ip6_mtu_from_fib6(const struct fib6_result *res,
		      const struct in6_addr *daddr,
		      const struct in6_addr *saddr)
3097
{
3098 3099
	const struct fib6_nh *nh = res->nh;
	struct fib6_info *f6i = res->f6i;
3100
	struct inet6_dev *idev;
3101
	struct rt6_info *rt;
3102 3103 3104 3105 3106 3107 3108 3109
	u32 mtu = 0;

	if (unlikely(fib6_metric_locked(f6i, RTAX_MTU))) {
		mtu = f6i->fib6_pmtu;
		if (mtu)
			goto out;
	}

3110 3111 3112 3113
	rt = rt6_find_cached_rt(res, daddr, saddr);
	if (unlikely(rt)) {
		mtu = dst_metric_raw(&rt->dst, RTAX_MTU);
	} else {
3114
		struct net_device *dev = nh->fib_nh_dev;
3115 3116 3117 3118 3119 3120 3121 3122 3123

		mtu = IPV6_MIN_MTU;
		idev = __in6_dev_get(dev);
		if (idev && idev->cnf.mtu6 > mtu)
			mtu = idev->cnf.mtu6;
	}

	mtu = min_t(unsigned int, mtu, IP6_MAX_MTU);
out:
3124
	return mtu - lwtunnel_headroom(nh->fib_nh_lws, mtu);
3125 3126
}

3127
struct dst_entry *icmp6_dst_alloc(struct net_device *dev,
3128
				  struct flowi6 *fl6)
L
Linus Torvalds 已提交
3129
{
3130
	struct dst_entry *dst;
L
Linus Torvalds 已提交
3131 3132
	struct rt6_info *rt;
	struct inet6_dev *idev = in6_dev_get(dev);
3133
	struct net *net = dev_net(dev);
L
Linus Torvalds 已提交
3134

3135
	if (unlikely(!idev))
E
Eric Dumazet 已提交
3136
		return ERR_PTR(-ENODEV);
L
Linus Torvalds 已提交
3137

3138
	rt = ip6_dst_alloc(net, dev, 0);
3139
	if (unlikely(!rt)) {
L
Linus Torvalds 已提交
3140
		in6_dev_put(idev);
3141
		dst = ERR_PTR(-ENOMEM);
L
Linus Torvalds 已提交
3142 3143 3144
		goto out;
	}

3145
	rt->dst.flags |= DST_HOST;
3146
	rt->dst.input = ip6_input;
3147
	rt->dst.output  = ip6_output;
3148
	rt->rt6i_gateway  = fl6->daddr;
3149
	rt->rt6i_dst.addr = fl6->daddr;
3150 3151
	rt->rt6i_dst.plen = 128;
	rt->rt6i_idev     = idev;
L
Li RongQing 已提交
3152
	dst_metric_set(&rt->dst, RTAX_HOPLIMIT, 0);
L
Linus Torvalds 已提交
3153

3154
	/* Add this dst into uncached_list so that rt6_disable_ip() can
3155 3156 3157
	 * do proper release of the net_device
	 */
	rt6_uncached_list_add(rt);
W
Wei Wang 已提交
3158
	atomic_inc(&net->ipv6.rt6_stats->fib_rt_uncache);
L
Linus Torvalds 已提交
3159

3160 3161
	dst = xfrm_lookup(net, &rt->dst, flowi6_to_flowi(fl6), NULL, 0);

L
Linus Torvalds 已提交
3162
out:
3163
	return dst;
L
Linus Torvalds 已提交
3164 3165
}

3166
static int ip6_dst_gc(struct dst_ops *ops)
L
Linus Torvalds 已提交
3167
{
3168
	struct net *net = container_of(ops, struct net, ipv6.ip6_dst_ops);
3169 3170 3171 3172 3173
	int rt_min_interval = net->ipv6.sysctl.ip6_rt_gc_min_interval;
	int rt_max_size = net->ipv6.sysctl.ip6_rt_max_size;
	int rt_elasticity = net->ipv6.sysctl.ip6_rt_gc_elasticity;
	int rt_gc_timeout = net->ipv6.sysctl.ip6_rt_gc_timeout;
	unsigned long rt_last_gc = net->ipv6.ip6_rt_last_gc;
3174
	int entries;
3175

3176
	entries = dst_entries_get_fast(ops);
3177
	if (time_after(rt_last_gc + rt_min_interval, jiffies) &&
3178
	    entries <= rt_max_size)
L
Linus Torvalds 已提交
3179 3180
		goto out;

3181
	net->ipv6.ip6_rt_gc_expire++;
3182
	fib6_run_gc(net->ipv6.ip6_rt_gc_expire, net, true);
3183 3184
	entries = dst_entries_get_slow(ops);
	if (entries < ops->gc_thresh)
3185
		net->ipv6.ip6_rt_gc_expire = rt_gc_timeout>>1;
L
Linus Torvalds 已提交
3186
out:
3187
	net->ipv6.ip6_rt_gc_expire -= net->ipv6.ip6_rt_gc_expire>>rt_elasticity;
3188
	return entries > rt_max_size;
L
Linus Torvalds 已提交
3189 3190
}

3191 3192 3193
static int ip6_nh_lookup_table(struct net *net, struct fib6_config *cfg,
			       const struct in6_addr *gw_addr, u32 tbid,
			       int flags, struct fib6_result *res)
3194 3195 3196 3197 3198 3199 3200
{
	struct flowi6 fl6 = {
		.flowi6_oif = cfg->fc_ifindex,
		.daddr = *gw_addr,
		.saddr = cfg->fc_prefsrc,
	};
	struct fib6_table *table;
3201
	int err;
3202

3203
	table = fib6_get_table(net, tbid);
3204
	if (!table)
3205
		return -EINVAL;
3206 3207 3208 3209

	if (!ipv6_addr_any(&cfg->fc_prefsrc))
		flags |= RT6_LOOKUP_F_HAS_SADDR;

3210
	flags |= RT6_LOOKUP_F_IGNORE_LINKSTATE;
3211

3212 3213 3214 3215
	err = fib6_table_lookup(net, table, cfg->fc_ifindex, &fl6, res, flags);
	if (!err && res->f6i != net->ipv6.fib6_null_entry)
		fib6_select_path(net, res, &fl6, cfg->fc_ifindex,
				 cfg->fc_ifindex != 0, NULL, flags);
3216

3217
	return err;
3218 3219
}

3220 3221
static int ip6_route_check_nh_onlink(struct net *net,
				     struct fib6_config *cfg,
3222
				     const struct net_device *dev,
3223 3224
				     struct netlink_ext_ack *extack)
{
3225
	u32 tbid = l3mdev_fib_table_rcu(dev) ? : RT_TABLE_MAIN;
3226
	const struct in6_addr *gw_addr = &cfg->fc_gateway;
3227
	struct fib6_result res = {};
3228 3229
	int err;

3230 3231 3232 3233 3234 3235 3236 3237
	err = ip6_nh_lookup_table(net, cfg, gw_addr, tbid, 0, &res);
	if (!err && !(res.fib6_flags & RTF_REJECT) &&
	    /* ignore match if it is the default route */
	    !ipv6_addr_any(&res.f6i->fib6_dst.addr) &&
	    (res.fib6_type != RTN_UNICAST || dev != res.nh->fib_nh_dev)) {
		NL_SET_ERR_MSG(extack,
			       "Nexthop has invalid gateway or device mismatch");
		err = -EINVAL;
3238 3239 3240 3241 3242
	}

	return err;
}

3243 3244 3245 3246 3247 3248 3249
static int ip6_route_check_nh(struct net *net,
			      struct fib6_config *cfg,
			      struct net_device **_dev,
			      struct inet6_dev **idev)
{
	const struct in6_addr *gw_addr = &cfg->fc_gateway;
	struct net_device *dev = _dev ? *_dev : NULL;
3250 3251
	int flags = RT6_LOOKUP_F_IFACE;
	struct fib6_result res = {};
3252 3253 3254
	int err = -EHOSTUNREACH;

	if (cfg->fc_table) {
3255 3256 3257 3258 3259 3260 3261 3262 3263
		err = ip6_nh_lookup_table(net, cfg, gw_addr,
					  cfg->fc_table, flags, &res);
		/* gw_addr can not require a gateway or resolve to a reject
		 * route. If a device is given, it must match the result.
		 */
		if (err || res.fib6_flags & RTF_REJECT ||
		    res.nh->fib_nh_gw_family ||
		    (dev && dev != res.nh->fib_nh_dev))
			err = -EHOSTUNREACH;
3264 3265
	}

3266 3267 3268 3269 3270
	if (err < 0) {
		struct flowi6 fl6 = {
			.flowi6_oif = cfg->fc_ifindex,
			.daddr = *gw_addr,
		};
3271

3272 3273 3274 3275 3276 3277 3278 3279 3280 3281 3282
		err = fib6_lookup(net, cfg->fc_ifindex, &fl6, &res, flags);
		if (err || res.fib6_flags & RTF_REJECT ||
		    res.nh->fib_nh_gw_family)
			err = -EHOSTUNREACH;

		if (err)
			return err;

		fib6_select_path(net, &res, &fl6, cfg->fc_ifindex,
				 cfg->fc_ifindex != 0, NULL, flags);
	}
3283

3284
	err = 0;
3285
	if (dev) {
3286 3287
		if (dev != res.nh->fib_nh_dev)
			err = -EHOSTUNREACH;
3288
	} else {
3289
		*_dev = dev = res.nh->fib_nh_dev;
3290
		dev_hold(dev);
3291
		*idev = in6_dev_get(dev);
3292 3293 3294 3295 3296
	}

	return err;
}

3297 3298 3299 3300 3301 3302
static int ip6_validate_gw(struct net *net, struct fib6_config *cfg,
			   struct net_device **_dev, struct inet6_dev **idev,
			   struct netlink_ext_ack *extack)
{
	const struct in6_addr *gw_addr = &cfg->fc_gateway;
	int gwa_type = ipv6_addr_type(gw_addr);
3303
	bool skip_dev = gwa_type & IPV6_ADDR_LINKLOCAL ? false : true;
3304
	const struct net_device *dev = *_dev;
3305
	bool need_addr_check = !dev;
3306 3307 3308 3309 3310 3311 3312
	int err = -EINVAL;

	/* if gw_addr is local we will fail to detect this in case
	 * address is still TENTATIVE (DAD in progress). rt6_lookup()
	 * will return already-added prefix route via interface that
	 * prefix route was assigned to, which might be non-loopback.
	 */
3313 3314 3315
	if (dev &&
	    ipv6_chk_addr_and_flags(net, gw_addr, dev, skip_dev, 0, 0)) {
		NL_SET_ERR_MSG(extack, "Gateway can not be a local address");
3316 3317 3318 3319 3320 3321 3322 3323 3324 3325 3326 3327 3328 3329 3330 3331 3332 3333
		goto out;
	}

	if (gwa_type != (IPV6_ADDR_LINKLOCAL | IPV6_ADDR_UNICAST)) {
		/* IPv6 strictly inhibits using not link-local
		 * addresses as nexthop address.
		 * Otherwise, router will not able to send redirects.
		 * It is very good, but in some (rare!) circumstances
		 * (SIT, PtP, NBMA NOARP links) it is handy to allow
		 * some exceptions. --ANK
		 * We allow IPv4-mapped nexthops to support RFC4798-type
		 * addressing
		 */
		if (!(gwa_type & (IPV6_ADDR_UNICAST | IPV6_ADDR_MAPPED))) {
			NL_SET_ERR_MSG(extack, "Invalid gateway address");
			goto out;
		}

3334 3335
		rcu_read_lock();

3336 3337 3338 3339 3340
		if (cfg->fc_flags & RTNH_F_ONLINK)
			err = ip6_route_check_nh_onlink(net, cfg, dev, extack);
		else
			err = ip6_route_check_nh(net, cfg, _dev, idev);

3341 3342
		rcu_read_unlock();

3343 3344 3345 3346 3347 3348 3349 3350 3351 3352 3353 3354 3355 3356 3357 3358
		if (err)
			goto out;
	}

	/* reload in case device was changed */
	dev = *_dev;

	err = -EINVAL;
	if (!dev) {
		NL_SET_ERR_MSG(extack, "Egress device not specified");
		goto out;
	} else if (dev->flags & IFF_LOOPBACK) {
		NL_SET_ERR_MSG(extack,
			       "Egress device can not be loopback device for this route");
		goto out;
	}
3359 3360 3361 3362 3363 3364 3365 3366 3367 3368

	/* if we did not check gw_addr above, do so now that the
	 * egress device has been resolved.
	 */
	if (need_addr_check &&
	    ipv6_chk_addr_and_flags(net, gw_addr, dev, skip_dev, 0, 0)) {
		NL_SET_ERR_MSG(extack, "Gateway can not be a local address");
		goto out;
	}

3369 3370 3371 3372 3373
	err = 0;
out:
	return err;
}

3374 3375 3376 3377 3378 3379 3380 3381 3382 3383 3384 3385 3386 3387 3388 3389 3390 3391 3392 3393
static bool fib6_is_reject(u32 flags, struct net_device *dev, int addr_type)
{
	if ((flags & RTF_REJECT) ||
	    (dev && (dev->flags & IFF_LOOPBACK) &&
	     !(addr_type & IPV6_ADDR_LOOPBACK) &&
	     !(flags & RTF_LOCAL)))
		return true;

	return false;
}

int fib6_nh_init(struct net *net, struct fib6_nh *fib6_nh,
		 struct fib6_config *cfg, gfp_t gfp_flags,
		 struct netlink_ext_ack *extack)
{
	struct net_device *dev = NULL;
	struct inet6_dev *idev = NULL;
	int addr_type;
	int err;

3394
	fib6_nh->fib_nh_family = AF_INET6;
3395 3396 3397
#ifdef CONFIG_IPV6_ROUTER_PREF
	fib6_nh->last_probe = jiffies;
#endif
3398

3399 3400 3401 3402 3403 3404 3405 3406 3407 3408 3409 3410 3411 3412 3413 3414 3415 3416 3417 3418 3419 3420 3421
	err = -ENODEV;
	if (cfg->fc_ifindex) {
		dev = dev_get_by_index(net, cfg->fc_ifindex);
		if (!dev)
			goto out;
		idev = in6_dev_get(dev);
		if (!idev)
			goto out;
	}

	if (cfg->fc_flags & RTNH_F_ONLINK) {
		if (!dev) {
			NL_SET_ERR_MSG(extack,
				       "Nexthop device required for onlink");
			goto out;
		}

		if (!(dev->flags & IFF_UP)) {
			NL_SET_ERR_MSG(extack, "Nexthop device is not up");
			err = -ENETDOWN;
			goto out;
		}

D
David Ahern 已提交
3422
		fib6_nh->fib_nh_flags |= RTNH_F_ONLINK;
3423 3424
	}

D
David Ahern 已提交
3425
	fib6_nh->fib_nh_weight = 1;
3426 3427 3428 3429 3430 3431 3432 3433 3434 3435 3436 3437 3438 3439 3440 3441 3442 3443 3444 3445

	/* We cannot add true routes via loopback here,
	 * they would result in kernel looping; promote them to reject routes
	 */
	addr_type = ipv6_addr_type(&cfg->fc_dst);
	if (fib6_is_reject(cfg->fc_flags, dev, addr_type)) {
		/* hold loopback dev/idev if we haven't done so. */
		if (dev != net->loopback_dev) {
			if (dev) {
				dev_put(dev);
				in6_dev_put(idev);
			}
			dev = net->loopback_dev;
			dev_hold(dev);
			idev = in6_dev_get(dev);
			if (!idev) {
				err = -ENODEV;
				goto out;
			}
		}
3446
		goto pcpu_alloc;
3447 3448 3449 3450 3451 3452 3453
	}

	if (cfg->fc_flags & RTF_GATEWAY) {
		err = ip6_validate_gw(net, cfg, &dev, &idev, extack);
		if (err)
			goto out;

D
David Ahern 已提交
3454
		fib6_nh->fib_nh_gw6 = cfg->fc_gateway;
3455
		fib6_nh->fib_nh_gw_family = AF_INET6;
3456 3457 3458 3459 3460 3461 3462 3463 3464 3465 3466 3467 3468 3469 3470 3471 3472 3473 3474 3475
	}

	err = -ENODEV;
	if (!dev)
		goto out;

	if (idev->cnf.disable_ipv6) {
		NL_SET_ERR_MSG(extack, "IPv6 is disabled on nexthop device");
		err = -EACCES;
		goto out;
	}

	if (!(dev->flags & IFF_UP) && !cfg->fc_ignore_dev_down) {
		NL_SET_ERR_MSG(extack, "Nexthop device is not up");
		err = -ENETDOWN;
		goto out;
	}

	if (!(cfg->fc_flags & (RTF_LOCAL | RTF_ANYCAST)) &&
	    !netif_carrier_ok(dev))
D
David Ahern 已提交
3476
		fib6_nh->fib_nh_flags |= RTNH_F_LINKDOWN;
3477

3478 3479 3480 3481 3482 3483
	err = fib_nh_common_init(&fib6_nh->nh_common, cfg->fc_encap,
				 cfg->fc_encap_type, cfg, gfp_flags, extack);
	if (err)
		goto out;

pcpu_alloc:
3484 3485 3486 3487 3488 3489
	fib6_nh->rt6i_pcpu = alloc_percpu_gfp(struct rt6_info *, gfp_flags);
	if (!fib6_nh->rt6i_pcpu) {
		err = -ENOMEM;
		goto out;
	}

D
David Ahern 已提交
3490
	fib6_nh->fib_nh_dev = dev;
3491
	fib6_nh->fib_nh_oif = dev->ifindex;
3492 3493 3494 3495 3496 3497
	err = 0;
out:
	if (idev)
		in6_dev_put(idev);

	if (err) {
D
David Ahern 已提交
3498 3499
		lwtstate_put(fib6_nh->fib_nh_lws);
		fib6_nh->fib_nh_lws = NULL;
3500 3501 3502 3503 3504 3505 3506
		if (dev)
			dev_put(dev);
	}

	return err;
}

3507 3508
void fib6_nh_release(struct fib6_nh *fib6_nh)
{
3509 3510 3511 3512 3513 3514 3515 3516 3517 3518 3519 3520 3521
	struct rt6_exception_bucket *bucket;

	rcu_read_lock();

	fib6_nh_flush_exceptions(fib6_nh, NULL);
	bucket = fib6_nh_get_excptn_bucket(fib6_nh, NULL);
	if (bucket) {
		rcu_assign_pointer(fib6_nh->rt6i_exception_bucket, NULL);
		kfree(bucket);
	}

	rcu_read_unlock();

3522 3523 3524 3525 3526 3527 3528 3529 3530 3531 3532 3533 3534 3535 3536 3537 3538 3539 3540
	if (fib6_nh->rt6i_pcpu) {
		int cpu;

		for_each_possible_cpu(cpu) {
			struct rt6_info **ppcpu_rt;
			struct rt6_info *pcpu_rt;

			ppcpu_rt = per_cpu_ptr(fib6_nh->rt6i_pcpu, cpu);
			pcpu_rt = *ppcpu_rt;
			if (pcpu_rt) {
				dst_dev_put(&pcpu_rt->dst);
				dst_release(&pcpu_rt->dst);
				*ppcpu_rt = NULL;
			}
		}

		free_percpu(fib6_nh->rt6i_pcpu);
	}

3541
	fib_nh_common_release(&fib6_nh->nh_common);
3542 3543
}

3544
static struct fib6_info *ip6_route_info_create(struct fib6_config *cfg,
3545
					      gfp_t gfp_flags,
3546
					      struct netlink_ext_ack *extack)
L
Linus Torvalds 已提交
3547
{
3548
	struct net *net = cfg->fc_nlinfo.nl_net;
3549
	struct fib6_info *rt = NULL;
3550
	struct nexthop *nh = NULL;
T
Thomas Graf 已提交
3551
	struct fib6_table *table;
3552
	struct fib6_nh *fib6_nh;
3553
	int err = -EINVAL;
3554
	int addr_type;
L
Linus Torvalds 已提交
3555

3556
	/* RTF_PCPU is an internal flag; can not be set by userspace */
3557 3558
	if (cfg->fc_flags & RTF_PCPU) {
		NL_SET_ERR_MSG(extack, "Userspace can not set RTF_PCPU");
3559
		goto out;
3560
	}
3561

3562 3563 3564 3565 3566 3567
	/* RTF_CACHE is an internal flag; can not be set by userspace */
	if (cfg->fc_flags & RTF_CACHE) {
		NL_SET_ERR_MSG(extack, "Userspace can not set RTF_CACHE");
		goto out;
	}

3568 3569 3570 3571 3572
	if (cfg->fc_type > RTN_MAX) {
		NL_SET_ERR_MSG(extack, "Invalid route type");
		goto out;
	}

3573 3574 3575 3576 3577 3578
	if (cfg->fc_dst_len > 128) {
		NL_SET_ERR_MSG(extack, "Invalid prefix length");
		goto out;
	}
	if (cfg->fc_src_len > 128) {
		NL_SET_ERR_MSG(extack, "Invalid source address length");
3579
		goto out;
3580
	}
L
Linus Torvalds 已提交
3581
#ifndef CONFIG_IPV6_SUBTREES
3582 3583 3584
	if (cfg->fc_src_len) {
		NL_SET_ERR_MSG(extack,
			       "Specifying source address requires IPV6_SUBTREES to be enabled");
3585
		goto out;
3586
	}
L
Linus Torvalds 已提交
3587
#endif
3588 3589 3590 3591 3592 3593 3594 3595 3596 3597
	if (cfg->fc_nh_id) {
		nh = nexthop_find_by_id(net, cfg->fc_nh_id);
		if (!nh) {
			NL_SET_ERR_MSG(extack, "Nexthop id does not exist");
			goto out;
		}
		err = fib6_check_nexthop(nh, cfg, extack);
		if (err)
			goto out;
	}
3598

3599
	err = -ENOBUFS;
3600 3601
	if (cfg->fc_nlinfo.nlh &&
	    !(cfg->fc_nlinfo.nlh->nlmsg_flags & NLM_F_CREATE)) {
3602
		table = fib6_get_table(net, cfg->fc_table);
3603
		if (!table) {
3604
			pr_warn("NLM_F_CREATE should be specified when creating new route\n");
3605 3606 3607 3608 3609
			table = fib6_new_table(net, cfg->fc_table);
		}
	} else {
		table = fib6_new_table(net, cfg->fc_table);
	}
3610 3611

	if (!table)
T
Thomas Graf 已提交
3612 3613
		goto out;

3614
	err = -ENOMEM;
3615
	rt = fib6_info_alloc(gfp_flags, !nh);
3616
	if (!rt)
L
Linus Torvalds 已提交
3617
		goto out;
3618

3619 3620
	rt->fib6_metrics = ip_fib_metrics_init(net, cfg->fc_mx, cfg->fc_mx_len,
					       extack);
3621 3622
	if (IS_ERR(rt->fib6_metrics)) {
		err = PTR_ERR(rt->fib6_metrics);
3623 3624
		/* Do not leave garbage there. */
		rt->fib6_metrics = (struct dst_metrics *)&dst_default_metrics;
3625 3626 3627
		goto out;
	}

3628 3629
	if (cfg->fc_flags & RTF_ADDRCONF)
		rt->dst_nocount = true;
L
Linus Torvalds 已提交
3630

3631
	if (cfg->fc_flags & RTF_EXPIRES)
3632
		fib6_set_expires(rt, jiffies +
3633 3634
				clock_t_to_jiffies(cfg->fc_expires));
	else
3635
		fib6_clean_expires(rt);
L
Linus Torvalds 已提交
3636

3637 3638
	if (cfg->fc_protocol == RTPROT_UNSPEC)
		cfg->fc_protocol = RTPROT_BOOT;
3639
	rt->fib6_protocol = cfg->fc_protocol;
3640

3641 3642
	rt->fib6_table = table;
	rt->fib6_metric = cfg->fc_metric;
3643
	rt->fib6_type = cfg->fc_type ? : RTN_UNICAST;
3644
	rt->fib6_flags = cfg->fc_flags & ~RTF_GATEWAY;
3645

3646 3647 3648
	ipv6_addr_prefix(&rt->fib6_dst.addr, &cfg->fc_dst, cfg->fc_dst_len);
	rt->fib6_dst.plen = cfg->fc_dst_len;
	if (rt->fib6_dst.plen == 128)
3649
		rt->dst_host = true;
3650

L
Linus Torvalds 已提交
3651
#ifdef CONFIG_IPV6_SUBTREES
3652 3653
	ipv6_addr_prefix(&rt->fib6_src.addr, &cfg->fc_src, cfg->fc_src_len);
	rt->fib6_src.plen = cfg->fc_src_len;
L
Linus Torvalds 已提交
3654
#endif
3655 3656 3657 3658 3659 3660
	if (nh) {
		if (!nexthop_get(nh)) {
			NL_SET_ERR_MSG(extack, "Nexthop has been deleted");
			goto out;
		}
		if (rt->fib6_src.plen) {
3661
			NL_SET_ERR_MSG(extack, "Nexthops can not be used with source routing");
3662 3663 3664 3665 3666 3667 3668 3669
			goto out;
		}
		rt->nh = nh;
		fib6_nh = nexthop_fib6_nh(rt->nh);
	} else {
		err = fib6_nh_init(net, rt->fib6_nh, cfg, gfp_flags, extack);
		if (err)
			goto out;
L
Linus Torvalds 已提交
3670

3671 3672 3673 3674 3675 3676 3677 3678 3679 3680
		fib6_nh = rt->fib6_nh;

		/* We cannot add true routes via loopback here, they would
		 * result in kernel looping; promote them to reject routes
		 */
		addr_type = ipv6_addr_type(&cfg->fc_dst);
		if (fib6_is_reject(cfg->fc_flags, rt->fib6_nh->fib_nh_dev,
				   addr_type))
			rt->fib6_flags = RTF_REJECT | RTF_NONEXTHOP;
	}
3681

3682
	if (!ipv6_addr_any(&cfg->fc_prefsrc)) {
3683
		struct net_device *dev = fib6_nh->fib_nh_dev;
3684

3685
		if (!ipv6_chk_addr(net, &cfg->fc_prefsrc, dev, 0)) {
3686
			NL_SET_ERR_MSG(extack, "Invalid source address");
3687 3688 3689
			err = -EINVAL;
			goto out;
		}
3690 3691
		rt->fib6_prefsrc.addr = cfg->fc_prefsrc;
		rt->fib6_prefsrc.plen = 128;
3692
	} else
3693
		rt->fib6_prefsrc.plen = 0;
3694

3695
	return rt;
3696
out:
3697
	fib6_info_release(rt);
3698
	return ERR_PTR(err);
3699 3700
}

3701
int ip6_route_add(struct fib6_config *cfg, gfp_t gfp_flags,
3702
		  struct netlink_ext_ack *extack)
3703
{
3704
	struct fib6_info *rt;
3705 3706
	int err;

3707
	rt = ip6_route_info_create(cfg, gfp_flags, extack);
3708 3709
	if (IS_ERR(rt))
		return PTR_ERR(rt);
3710

3711
	err = __ip6_ins_rt(rt, &cfg->fc_nlinfo, extack);
3712
	fib6_info_release(rt);
3713

L
Linus Torvalds 已提交
3714 3715 3716
	return err;
}

3717
static int __ip6_del_rt(struct fib6_info *rt, struct nl_info *info)
L
Linus Torvalds 已提交
3718
{
3719
	struct net *net = info->nl_net;
T
Thomas Graf 已提交
3720
	struct fib6_table *table;
3721
	int err;
L
Linus Torvalds 已提交
3722

D
David Ahern 已提交
3723
	if (rt == net->ipv6.fib6_null_entry) {
3724 3725 3726
		err = -ENOENT;
		goto out;
	}
3727

3728
	table = rt->fib6_table;
3729
	spin_lock_bh(&table->tb6_lock);
3730
	err = fib6_del(rt, info);
3731
	spin_unlock_bh(&table->tb6_lock);
L
Linus Torvalds 已提交
3732

3733
out:
3734
	fib6_info_release(rt);
L
Linus Torvalds 已提交
3735 3736 3737
	return err;
}

3738
int ip6_del_rt(struct net *net, struct fib6_info *rt)
3739
{
3740 3741
	struct nl_info info = { .nl_net = net };

3742
	return __ip6_del_rt(rt, &info);
3743 3744
}

3745
static int __ip6_del_rt_siblings(struct fib6_info *rt, struct fib6_config *cfg)
3746 3747
{
	struct nl_info *info = &cfg->fc_nlinfo;
3748
	struct net *net = info->nl_net;
3749
	struct sk_buff *skb = NULL;
3750
	struct fib6_table *table;
3751
	int err = -ENOENT;
3752

D
David Ahern 已提交
3753
	if (rt == net->ipv6.fib6_null_entry)
3754
		goto out_put;
3755
	table = rt->fib6_table;
3756
	spin_lock_bh(&table->tb6_lock);
3757

3758
	if (rt->fib6_nsiblings && cfg->fc_delete_all_nh) {
3759
		struct fib6_info *sibling, *next_sibling;
3760
		struct fib6_node *fn;
3761

3762 3763 3764 3765 3766
		/* prefer to send a single notification with all hops */
		skb = nlmsg_new(rt6_nlmsg_size(rt), gfp_any());
		if (skb) {
			u32 seq = info->nlh ? info->nlh->nlmsg_seq : 0;

3767
			if (rt6_fill_node(net, skb, rt, NULL,
3768 3769 3770 3771 3772 3773 3774 3775
					  NULL, NULL, 0, RTM_DELROUTE,
					  info->portid, seq, 0) < 0) {
				kfree_skb(skb);
				skb = NULL;
			} else
				info->skip_notify = 1;
		}

3776 3777 3778 3779 3780
		/* 'rt' points to the first sibling route. If it is not the
		 * leaf, then we do not need to send a notification. Otherwise,
		 * we need to check if the last sibling has a next route or not
		 * and emit a replace or delete notification, respectively.
		 */
3781
		info->skip_notify_kernel = 1;
3782 3783 3784 3785 3786 3787 3788 3789 3790 3791 3792 3793 3794 3795 3796 3797
		fn = rcu_dereference_protected(rt->fib6_node,
					    lockdep_is_held(&table->tb6_lock));
		if (rcu_access_pointer(fn->leaf) == rt) {
			struct fib6_info *last_sibling, *replace_rt;

			last_sibling = list_last_entry(&rt->fib6_siblings,
						       struct fib6_info,
						       fib6_siblings);
			replace_rt = rcu_dereference_protected(
					    last_sibling->fib6_next,
					    lockdep_is_held(&table->tb6_lock));
			if (replace_rt)
				call_fib6_entry_notifiers_replace(net,
								  replace_rt);
			else
				call_fib6_multipath_entry_notifiers(net,
3798
						       FIB_EVENT_ENTRY_DEL,
3799 3800 3801
						       rt, rt->fib6_nsiblings,
						       NULL);
		}
3802
		list_for_each_entry_safe(sibling, next_sibling,
3803 3804
					 &rt->fib6_siblings,
					 fib6_siblings) {
3805 3806
			err = fib6_del(sibling, info);
			if (err)
3807
				goto out_unlock;
3808 3809 3810 3811
		}
	}

	err = fib6_del(rt, info);
3812
out_unlock:
3813
	spin_unlock_bh(&table->tb6_lock);
3814
out_put:
3815
	fib6_info_release(rt);
3816 3817

	if (skb) {
3818
		rtnl_notify(skb, net, info->portid, RTNLGRP_IPV6_ROUTE,
3819 3820
			    info->nlh, gfp_any());
	}
3821 3822 3823
	return err;
}

3824
static int __ip6_del_cached_rt(struct rt6_info *rt, struct fib6_config *cfg)
3825 3826 3827 3828 3829 3830 3831 3832 3833
{
	int rc = -ESRCH;

	if (cfg->fc_ifindex && rt->dst.dev->ifindex != cfg->fc_ifindex)
		goto out;

	if (cfg->fc_flags & RTF_GATEWAY &&
	    !ipv6_addr_equal(&cfg->fc_gateway, &rt->rt6i_gateway))
		goto out;
3834 3835

	rc = rt6_remove_exception_rt(rt);
3836 3837 3838 3839
out:
	return rc;
}

3840 3841 3842 3843 3844 3845 3846 3847 3848 3849 3850 3851 3852 3853 3854 3855
static int ip6_del_cached_rt(struct fib6_config *cfg, struct fib6_info *rt,
			     struct fib6_nh *nh)
{
	struct fib6_result res = {
		.f6i = rt,
		.nh = nh,
	};
	struct rt6_info *rt_cache;

	rt_cache = rt6_find_cached_rt(&res, &cfg->fc_dst, &cfg->fc_src);
	if (rt_cache)
		return __ip6_del_cached_rt(rt_cache, cfg);

	return 0;
}

3856 3857 3858 3859 3860 3861 3862 3863 3864 3865 3866 3867 3868 3869 3870 3871 3872 3873 3874 3875 3876 3877 3878 3879
struct fib6_nh_del_cached_rt_arg {
	struct fib6_config *cfg;
	struct fib6_info *f6i;
};

static int fib6_nh_del_cached_rt(struct fib6_nh *nh, void *_arg)
{
	struct fib6_nh_del_cached_rt_arg *arg = _arg;
	int rc;

	rc = ip6_del_cached_rt(arg->cfg, arg->f6i, nh);
	return rc != -ESRCH ? rc : 0;
}

static int ip6_del_cached_rt_nh(struct fib6_config *cfg, struct fib6_info *f6i)
{
	struct fib6_nh_del_cached_rt_arg arg = {
		.cfg = cfg,
		.f6i = f6i
	};

	return nexthop_for_each_fib6_nh(f6i->nh, fib6_nh_del_cached_rt, &arg);
}

3880 3881
static int ip6_route_del(struct fib6_config *cfg,
			 struct netlink_ext_ack *extack)
L
Linus Torvalds 已提交
3882
{
T
Thomas Graf 已提交
3883
	struct fib6_table *table;
3884
	struct fib6_info *rt;
L
Linus Torvalds 已提交
3885 3886 3887
	struct fib6_node *fn;
	int err = -ESRCH;

3888
	table = fib6_get_table(cfg->fc_nlinfo.nl_net, cfg->fc_table);
3889 3890
	if (!table) {
		NL_SET_ERR_MSG(extack, "FIB table does not exist");
T
Thomas Graf 已提交
3891
		return err;
3892
	}
T
Thomas Graf 已提交
3893

3894
	rcu_read_lock();
L
Linus Torvalds 已提交
3895

T
Thomas Graf 已提交
3896
	fn = fib6_locate(&table->tb6_root,
3897
			 &cfg->fc_dst, cfg->fc_dst_len,
3898
			 &cfg->fc_src, cfg->fc_src_len,
3899
			 !(cfg->fc_flags & RTF_CACHE));
3900

L
Linus Torvalds 已提交
3901
	if (fn) {
3902
		for_each_fib6_node_rt_rcu(fn) {
D
David Ahern 已提交
3903 3904
			struct fib6_nh *nh;

3905 3906
			if (rt->nh && cfg->fc_nh_id &&
			    rt->nh->id != cfg->fc_nh_id)
3907
				continue;
3908

3909 3910 3911 3912 3913 3914 3915 3916 3917 3918 3919
			if (cfg->fc_flags & RTF_CACHE) {
				int rc = 0;

				if (rt->nh) {
					rc = ip6_del_cached_rt_nh(cfg, rt);
				} else if (cfg->fc_nh_id) {
					continue;
				} else {
					nh = rt->fib6_nh;
					rc = ip6_del_cached_rt(cfg, rt, nh);
				}
3920 3921 3922
				if (rc != -ESRCH) {
					rcu_read_unlock();
					return rc;
3923 3924
				}
				continue;
3925
			}
D
David Ahern 已提交
3926

3927 3928 3929 3930 3931 3932 3933 3934 3935 3936 3937 3938 3939 3940 3941 3942 3943
			if (cfg->fc_metric && cfg->fc_metric != rt->fib6_metric)
				continue;
			if (cfg->fc_protocol &&
			    cfg->fc_protocol != rt->fib6_protocol)
				continue;

			if (rt->nh) {
				if (!fib6_info_hold_safe(rt))
					continue;
				rcu_read_unlock();

				return __ip6_del_rt(rt, &cfg->fc_nlinfo);
			}
			if (cfg->fc_nh_id)
				continue;

			nh = rt->fib6_nh;
3944
			if (cfg->fc_ifindex &&
D
David Ahern 已提交
3945 3946
			    (!nh->fib_nh_dev ||
			     nh->fib_nh_dev->ifindex != cfg->fc_ifindex))
L
Linus Torvalds 已提交
3947
				continue;
3948
			if (cfg->fc_flags & RTF_GATEWAY &&
D
David Ahern 已提交
3949
			    !ipv6_addr_equal(&cfg->fc_gateway, &nh->fib_nh_gw6))
L
Linus Torvalds 已提交
3950
				continue;
3951 3952
			if (!fib6_info_hold_safe(rt))
				continue;
3953
			rcu_read_unlock();
L
Linus Torvalds 已提交
3954

3955 3956 3957 3958 3959
			/* if gateway was specified only delete the one hop */
			if (cfg->fc_flags & RTF_GATEWAY)
				return __ip6_del_rt(rt, &cfg->fc_nlinfo);

			return __ip6_del_rt_siblings(rt, cfg);
L
Linus Torvalds 已提交
3960 3961
		}
	}
3962
	rcu_read_unlock();
L
Linus Torvalds 已提交
3963 3964 3965 3966

	return err;
}

3967
static void rt6_do_redirect(struct dst_entry *dst, struct sock *sk, struct sk_buff *skb)
3968 3969
{
	struct netevent_redirect netevent;
3970
	struct rt6_info *rt, *nrt = NULL;
3971
	struct fib6_result res = {};
3972 3973 3974
	struct ndisc_options ndopts;
	struct inet6_dev *in6_dev;
	struct neighbour *neigh;
3975
	struct rd_msg *msg;
3976 3977
	int optlen, on_link;
	u8 *lladdr;
3978

3979
	optlen = skb_tail_pointer(skb) - skb_transport_header(skb);
3980
	optlen -= sizeof(*msg);
3981 3982

	if (optlen < 0) {
3983
		net_dbg_ratelimited("rt6_do_redirect: packet too short\n");
3984 3985 3986
		return;
	}

3987
	msg = (struct rd_msg *)icmp6_hdr(skb);
3988

3989
	if (ipv6_addr_is_multicast(&msg->dest)) {
3990
		net_dbg_ratelimited("rt6_do_redirect: destination address is multicast\n");
3991 3992 3993
		return;
	}

3994
	on_link = 0;
3995
	if (ipv6_addr_equal(&msg->dest, &msg->target)) {
3996
		on_link = 1;
3997
	} else if (ipv6_addr_type(&msg->target) !=
3998
		   (IPV6_ADDR_UNICAST|IPV6_ADDR_LINKLOCAL)) {
3999
		net_dbg_ratelimited("rt6_do_redirect: target address is not link-local unicast\n");
4000 4001 4002 4003 4004 4005 4006 4007 4008 4009 4010 4011 4012 4013
		return;
	}

	in6_dev = __in6_dev_get(skb->dev);
	if (!in6_dev)
		return;
	if (in6_dev->cnf.forwarding || !in6_dev->cnf.accept_redirects)
		return;

	/* RFC2461 8.1:
	 *	The IP source address of the Redirect MUST be the same as the current
	 *	first-hop router for the specified ICMP Destination Address.
	 */

4014
	if (!ndisc_parse_options(skb->dev, msg->opt, optlen, &ndopts)) {
4015 4016 4017
		net_dbg_ratelimited("rt6_redirect: invalid ND options\n");
		return;
	}
4018 4019

	lladdr = NULL;
4020 4021 4022 4023 4024 4025 4026 4027 4028
	if (ndopts.nd_opts_tgt_lladdr) {
		lladdr = ndisc_opt_addr_data(ndopts.nd_opts_tgt_lladdr,
					     skb->dev);
		if (!lladdr) {
			net_dbg_ratelimited("rt6_redirect: invalid link-layer address length\n");
			return;
		}
	}

4029
	rt = (struct rt6_info *) dst;
4030
	if (rt->rt6i_flags & RTF_REJECT) {
4031
		net_dbg_ratelimited("rt6_redirect: source isn't a valid nexthop for redirect target\n");
4032
		return;
4033
	}
4034

4035 4036 4037 4038
	/* Redirect received -> path was valid.
	 * Look, redirects are sent only in response to data packets,
	 * so that this nexthop apparently is reachable. --ANK
	 */
4039
	dst_confirm_neigh(&rt->dst, &ipv6_hdr(skb)->saddr);
4040

4041
	neigh = __neigh_lookup(&nd_tbl, &msg->target, skb->dev, 1);
4042 4043
	if (!neigh)
		return;
4044

L
Linus Torvalds 已提交
4045 4046 4047 4048
	/*
	 *	We have finally decided to accept it.
	 */

4049
	ndisc_update(skb->dev, neigh, lladdr, NUD_STALE,
L
Linus Torvalds 已提交
4050 4051 4052
		     NEIGH_UPDATE_F_WEAK_OVERRIDE|
		     NEIGH_UPDATE_F_OVERRIDE|
		     (on_link ? 0 : (NEIGH_UPDATE_F_OVERRIDE_ISROUTER|
4053 4054
				     NEIGH_UPDATE_F_ISROUTER)),
		     NDISC_REDIRECT, &ndopts);
L
Linus Torvalds 已提交
4055

4056
	rcu_read_lock();
4057
	res.f6i = rcu_dereference(rt->from);
4058
	if (!res.f6i)
4059
		goto out;
4060

4061 4062 4063 4064 4065 4066 4067 4068 4069 4070 4071 4072 4073 4074 4075 4076 4077 4078 4079
	if (res.f6i->nh) {
		struct fib6_nh_match_arg arg = {
			.dev = dst->dev,
			.gw = &rt->rt6i_gateway,
		};

		nexthop_for_each_fib6_nh(res.f6i->nh,
					 fib6_nh_find_match, &arg);

		/* fib6_info uses a nexthop that does not have fib6_nh
		 * using the dst->dev. Should be impossible
		 */
		if (!arg.match)
			goto out;
		res.nh = arg.match;
	} else {
		res.nh = res.f6i->fib6_nh;
	}

4080 4081
	res.fib6_flags = res.f6i->fib6_flags;
	res.fib6_type = res.f6i->fib6_type;
4082
	nrt = ip6_rt_cache_alloc(&res, &msg->dest, NULL);
4083
	if (!nrt)
L
Linus Torvalds 已提交
4084 4085 4086 4087 4088 4089
		goto out;

	nrt->rt6i_flags = RTF_GATEWAY|RTF_UP|RTF_DYNAMIC|RTF_CACHE;
	if (on_link)
		nrt->rt6i_flags &= ~RTF_GATEWAY;

A
Alexey Dobriyan 已提交
4090
	nrt->rt6i_gateway = *(struct in6_addr *)neigh->primary_key;
L
Linus Torvalds 已提交
4091

4092
	/* rt6_insert_exception() will take care of duplicated exceptions */
4093
	if (rt6_insert_exception(nrt, &res)) {
4094 4095 4096
		dst_release_immediate(&nrt->dst);
		goto out;
	}
L
Linus Torvalds 已提交
4097

4098 4099
	netevent.old = &rt->dst;
	netevent.new = &nrt->dst;
4100
	netevent.daddr = &msg->dest;
4101
	netevent.neigh = neigh;
4102 4103
	call_netevent_notifiers(NETEVENT_REDIRECT, &netevent);

L
Linus Torvalds 已提交
4104
out:
4105
	rcu_read_unlock();
4106
	neigh_release(neigh);
4107 4108
}

4109
#ifdef CONFIG_IPV6_ROUTE_INFO
4110
static struct fib6_info *rt6_get_route_info(struct net *net,
4111
					   const struct in6_addr *prefix, int prefixlen,
4112 4113
					   const struct in6_addr *gwaddr,
					   struct net_device *dev)
4114
{
4115 4116
	u32 tb_id = l3mdev_fib_table(dev) ? : RT6_TABLE_INFO;
	int ifindex = dev->ifindex;
4117
	struct fib6_node *fn;
4118
	struct fib6_info *rt = NULL;
T
Thomas Graf 已提交
4119 4120
	struct fib6_table *table;

4121
	table = fib6_get_table(net, tb_id);
4122
	if (!table)
T
Thomas Graf 已提交
4123
		return NULL;
4124

4125
	rcu_read_lock();
4126
	fn = fib6_locate(&table->tb6_root, prefix, prefixlen, NULL, 0, true);
4127 4128 4129
	if (!fn)
		goto out;

4130
	for_each_fib6_node_rt_rcu(fn) {
4131 4132 4133
		/* these routes do not use nexthops */
		if (rt->nh)
			continue;
4134
		if (rt->fib6_nh->fib_nh_dev->ifindex != ifindex)
4135
			continue;
4136
		if (!(rt->fib6_flags & RTF_ROUTEINFO) ||
4137
		    !rt->fib6_nh->fib_nh_gw_family)
4138
			continue;
4139
		if (!ipv6_addr_equal(&rt->fib6_nh->fib_nh_gw6, gwaddr))
4140
			continue;
4141 4142
		if (!fib6_info_hold_safe(rt))
			continue;
4143 4144 4145
		break;
	}
out:
4146
	rcu_read_unlock();
4147 4148 4149
	return rt;
}

4150
static struct fib6_info *rt6_add_route_info(struct net *net,
4151
					   const struct in6_addr *prefix, int prefixlen,
4152 4153
					   const struct in6_addr *gwaddr,
					   struct net_device *dev,
4154
					   unsigned int pref)
4155
{
4156
	struct fib6_config cfg = {
4157
		.fc_metric	= IP6_RT_PRIO_USER,
4158
		.fc_ifindex	= dev->ifindex,
4159 4160 4161
		.fc_dst_len	= prefixlen,
		.fc_flags	= RTF_GATEWAY | RTF_ADDRCONF | RTF_ROUTEINFO |
				  RTF_UP | RTF_PREF(pref),
4162
		.fc_protocol = RTPROT_RA,
4163
		.fc_type = RTN_UNICAST,
4164
		.fc_nlinfo.portid = 0,
4165 4166
		.fc_nlinfo.nlh = NULL,
		.fc_nlinfo.nl_net = net,
4167 4168
	};

4169
	cfg.fc_table = l3mdev_fib_table(dev) ? : RT6_TABLE_INFO,
A
Alexey Dobriyan 已提交
4170 4171
	cfg.fc_dst = *prefix;
	cfg.fc_gateway = *gwaddr;
4172

4173 4174
	/* We should treat it as a default route if prefix length is 0. */
	if (!prefixlen)
4175
		cfg.fc_flags |= RTF_DEFAULT;
4176

4177
	ip6_route_add(&cfg, GFP_ATOMIC, NULL);
4178

4179
	return rt6_get_route_info(net, prefix, prefixlen, gwaddr, dev);
4180 4181 4182
}
#endif

4183
struct fib6_info *rt6_get_dflt_router(struct net *net,
4184 4185
				     const struct in6_addr *addr,
				     struct net_device *dev)
4186
{
4187
	u32 tb_id = l3mdev_fib_table(dev) ? : RT6_TABLE_DFLT;
4188
	struct fib6_info *rt;
T
Thomas Graf 已提交
4189
	struct fib6_table *table;
L
Linus Torvalds 已提交
4190

4191
	table = fib6_get_table(net, tb_id);
4192
	if (!table)
T
Thomas Graf 已提交
4193
		return NULL;
L
Linus Torvalds 已提交
4194

4195 4196
	rcu_read_lock();
	for_each_fib6_node_rt_rcu(&table->tb6_root) {
4197
		struct fib6_nh *nh;
D
David Ahern 已提交
4198

4199 4200 4201 4202 4203
		/* RA routes do not use nexthops */
		if (rt->nh)
			continue;

		nh = rt->fib6_nh;
D
David Ahern 已提交
4204
		if (dev == nh->fib_nh_dev &&
4205
		    ((rt->fib6_flags & (RTF_ADDRCONF | RTF_DEFAULT)) == (RTF_ADDRCONF | RTF_DEFAULT)) &&
D
David Ahern 已提交
4206
		    ipv6_addr_equal(&nh->fib_nh_gw6, addr))
L
Linus Torvalds 已提交
4207 4208
			break;
	}
4209 4210
	if (rt && !fib6_info_hold_safe(rt))
		rt = NULL;
4211
	rcu_read_unlock();
L
Linus Torvalds 已提交
4212 4213 4214
	return rt;
}

4215
struct fib6_info *rt6_add_dflt_router(struct net *net,
4216
				     const struct in6_addr *gwaddr,
4217 4218
				     struct net_device *dev,
				     unsigned int pref)
L
Linus Torvalds 已提交
4219
{
4220
	struct fib6_config cfg = {
D
David Ahern 已提交
4221
		.fc_table	= l3mdev_fib_table(dev) ? : RT6_TABLE_DFLT,
4222
		.fc_metric	= IP6_RT_PRIO_USER,
4223 4224 4225
		.fc_ifindex	= dev->ifindex,
		.fc_flags	= RTF_GATEWAY | RTF_ADDRCONF | RTF_DEFAULT |
				  RTF_UP | RTF_EXPIRES | RTF_PREF(pref),
4226
		.fc_protocol = RTPROT_RA,
4227
		.fc_type = RTN_UNICAST,
4228
		.fc_nlinfo.portid = 0,
4229
		.fc_nlinfo.nlh = NULL,
4230
		.fc_nlinfo.nl_net = net,
4231
	};
L
Linus Torvalds 已提交
4232

A
Alexey Dobriyan 已提交
4233
	cfg.fc_gateway = *gwaddr;
L
Linus Torvalds 已提交
4234

4235
	if (!ip6_route_add(&cfg, GFP_ATOMIC, NULL)) {
4236 4237 4238 4239 4240 4241
		struct fib6_table *table;

		table = fib6_get_table(dev_net(dev), cfg.fc_table);
		if (table)
			table->flags |= RT6_TABLE_HAS_DFLT_ROUTER;
	}
L
Linus Torvalds 已提交
4242

4243
	return rt6_get_dflt_router(net, gwaddr, dev);
L
Linus Torvalds 已提交
4244 4245
}

4246 4247
static void __rt6_purge_dflt_routers(struct net *net,
				     struct fib6_table *table)
L
Linus Torvalds 已提交
4248
{
4249
	struct fib6_info *rt;
L
Linus Torvalds 已提交
4250 4251

restart:
4252 4253
	rcu_read_lock();
	for_each_fib6_node_rt_rcu(&table->tb6_root) {
D
David Ahern 已提交
4254 4255 4256
		struct net_device *dev = fib6_info_nh_dev(rt);
		struct inet6_dev *idev = dev ? __in6_dev_get(dev) : NULL;

4257
		if (rt->fib6_flags & (RTF_DEFAULT | RTF_ADDRCONF) &&
4258 4259
		    (!idev || idev->cnf.accept_ra != 2) &&
		    fib6_info_hold_safe(rt)) {
4260 4261
			rcu_read_unlock();
			ip6_del_rt(net, rt);
L
Linus Torvalds 已提交
4262 4263 4264
			goto restart;
		}
	}
4265
	rcu_read_unlock();
4266 4267 4268 4269 4270 4271 4272 4273 4274 4275 4276 4277 4278 4279 4280 4281

	table->flags &= ~RT6_TABLE_HAS_DFLT_ROUTER;
}

void rt6_purge_dflt_routers(struct net *net)
{
	struct fib6_table *table;
	struct hlist_head *head;
	unsigned int h;

	rcu_read_lock();

	for (h = 0; h < FIB6_TABLE_HASHSZ; h++) {
		head = &net->ipv6.fib_table_hash[h];
		hlist_for_each_entry_rcu(table, head, tb6_hlist) {
			if (table->flags & RT6_TABLE_HAS_DFLT_ROUTER)
4282
				__rt6_purge_dflt_routers(net, table);
4283 4284 4285 4286
		}
	}

	rcu_read_unlock();
L
Linus Torvalds 已提交
4287 4288
}

4289 4290
static void rtmsg_to_fib6_config(struct net *net,
				 struct in6_rtmsg *rtmsg,
4291 4292
				 struct fib6_config *cfg)
{
4293 4294 4295 4296
	*cfg = (struct fib6_config){
		.fc_table = l3mdev_fib_table_by_index(net, rtmsg->rtmsg_ifindex) ?
			 : RT6_TABLE_MAIN,
		.fc_ifindex = rtmsg->rtmsg_ifindex,
4297
		.fc_metric = rtmsg->rtmsg_metric ? : IP6_RT_PRIO_USER,
4298 4299 4300 4301 4302 4303 4304 4305 4306 4307 4308 4309
		.fc_expires = rtmsg->rtmsg_info,
		.fc_dst_len = rtmsg->rtmsg_dst_len,
		.fc_src_len = rtmsg->rtmsg_src_len,
		.fc_flags = rtmsg->rtmsg_flags,
		.fc_type = rtmsg->rtmsg_type,

		.fc_nlinfo.nl_net = net,

		.fc_dst = rtmsg->rtmsg_dst,
		.fc_src = rtmsg->rtmsg_src,
		.fc_gateway = rtmsg->rtmsg_gateway,
	};
4310 4311
}

4312
int ipv6_route_ioctl(struct net *net, unsigned int cmd, void __user *arg)
L
Linus Torvalds 已提交
4313
{
4314
	struct fib6_config cfg;
L
Linus Torvalds 已提交
4315 4316 4317
	struct in6_rtmsg rtmsg;
	int err;

4318
	switch (cmd) {
L
Linus Torvalds 已提交
4319 4320
	case SIOCADDRT:		/* Add a route */
	case SIOCDELRT:		/* Delete a route */
4321
		if (!ns_capable(net->user_ns, CAP_NET_ADMIN))
L
Linus Torvalds 已提交
4322 4323 4324 4325 4326
			return -EPERM;
		err = copy_from_user(&rtmsg, arg,
				     sizeof(struct in6_rtmsg));
		if (err)
			return -EFAULT;
4327

4328
		rtmsg_to_fib6_config(net, &rtmsg, &cfg);
4329

L
Linus Torvalds 已提交
4330 4331 4332
		rtnl_lock();
		switch (cmd) {
		case SIOCADDRT:
4333
			err = ip6_route_add(&cfg, GFP_KERNEL, NULL);
L
Linus Torvalds 已提交
4334 4335
			break;
		case SIOCDELRT:
4336
			err = ip6_route_del(&cfg, NULL);
L
Linus Torvalds 已提交
4337 4338 4339 4340 4341 4342 4343
			break;
		default:
			err = -EINVAL;
		}
		rtnl_unlock();

		return err;
4344
	}
L
Linus Torvalds 已提交
4345 4346 4347 4348 4349 4350 4351 4352

	return -EINVAL;
}

/*
 *	Drop the packet on the floor
 */

4353
static int ip6_pkt_drop(struct sk_buff *skb, u8 code, int ipstats_mib_noroutes)
L
Linus Torvalds 已提交
4354
{
E
Eric Dumazet 已提交
4355
	struct dst_entry *dst = skb_dst(skb);
4356 4357 4358 4359 4360 4361 4362 4363 4364 4365
	struct net *net = dev_net(dst->dev);
	struct inet6_dev *idev;
	int type;

	if (netif_is_l3_master(skb->dev) &&
	    dst->dev == net->loopback_dev)
		idev = __in6_dev_get_safely(dev_get_by_index_rcu(net, IP6CB(skb)->iif));
	else
		idev = ip6_dst_idev(dst);

4366 4367
	switch (ipstats_mib_noroutes) {
	case IPSTATS_MIB_INNOROUTES:
4368
		type = ipv6_addr_type(&ipv6_hdr(skb)->daddr);
U
Ulrich Weber 已提交
4369
		if (type == IPV6_ADDR_ANY) {
4370
			IP6_INC_STATS(net, idev, IPSTATS_MIB_INADDRERRORS);
4371 4372 4373 4374
			break;
		}
		/* FALLTHROUGH */
	case IPSTATS_MIB_OUTNOROUTES:
4375
		IP6_INC_STATS(net, idev, ipstats_mib_noroutes);
4376 4377
		break;
	}
4378 4379 4380 4381 4382

	/* Start over by dropping the dst for l3mdev case */
	if (netif_is_l3_master(skb->dev))
		skb_dst_drop(skb);

4383
	icmpv6_send(skb, ICMPV6_DEST_UNREACH, code, 0);
L
Linus Torvalds 已提交
4384 4385 4386 4387
	kfree_skb(skb);
	return 0;
}

4388 4389
static int ip6_pkt_discard(struct sk_buff *skb)
{
4390
	return ip6_pkt_drop(skb, ICMPV6_NOROUTE, IPSTATS_MIB_INNOROUTES);
4391 4392
}

E
Eric W. Biederman 已提交
4393
static int ip6_pkt_discard_out(struct net *net, struct sock *sk, struct sk_buff *skb)
L
Linus Torvalds 已提交
4394
{
E
Eric Dumazet 已提交
4395
	skb->dev = skb_dst(skb)->dev;
4396
	return ip6_pkt_drop(skb, ICMPV6_NOROUTE, IPSTATS_MIB_OUTNOROUTES);
L
Linus Torvalds 已提交
4397 4398
}

4399 4400
static int ip6_pkt_prohibit(struct sk_buff *skb)
{
4401
	return ip6_pkt_drop(skb, ICMPV6_ADM_PROHIBITED, IPSTATS_MIB_INNOROUTES);
4402 4403
}

E
Eric W. Biederman 已提交
4404
static int ip6_pkt_prohibit_out(struct net *net, struct sock *sk, struct sk_buff *skb)
4405
{
E
Eric Dumazet 已提交
4406
	skb->dev = skb_dst(skb)->dev;
4407
	return ip6_pkt_drop(skb, ICMPV6_ADM_PROHIBITED, IPSTATS_MIB_OUTNOROUTES);
4408 4409
}

L
Linus Torvalds 已提交
4410 4411 4412 4413
/*
 *	Allocate a dst for local (unicast / anycast) address.
 */

4414 4415 4416 4417
struct fib6_info *addrconf_f6i_alloc(struct net *net,
				     struct inet6_dev *idev,
				     const struct in6_addr *addr,
				     bool anycast, gfp_t gfp_flags)
L
Linus Torvalds 已提交
4418
{
4419 4420 4421
	struct fib6_config cfg = {
		.fc_table = l3mdev_fib_table(idev->dev) ? : RT6_TABLE_LOCAL,
		.fc_ifindex = idev->dev->ifindex,
4422
		.fc_flags = RTF_UP | RTF_NONEXTHOP,
4423 4424 4425 4426 4427 4428
		.fc_dst = *addr,
		.fc_dst_len = 128,
		.fc_protocol = RTPROT_KERNEL,
		.fc_nlinfo.nl_net = net,
		.fc_ignore_dev_down = true,
	};
4429
	struct fib6_info *f6i;
L
Linus Torvalds 已提交
4430

4431
	if (anycast) {
4432 4433
		cfg.fc_type = RTN_ANYCAST;
		cfg.fc_flags |= RTF_ANYCAST;
4434
	} else {
4435 4436
		cfg.fc_type = RTN_LOCAL;
		cfg.fc_flags |= RTF_LOCAL;
4437
	}
L
Linus Torvalds 已提交
4438

4439
	f6i = ip6_route_info_create(&cfg, gfp_flags, NULL);
4440
	if (!IS_ERR(f6i))
4441 4442
		f6i->dst_nocount = true;
	return f6i;
L
Linus Torvalds 已提交
4443 4444
}

4445 4446 4447 4448 4449 4450 4451
/* remove deleted ip from prefsrc entries */
struct arg_dev_net_ip {
	struct net_device *dev;
	struct net *net;
	struct in6_addr *addr;
};

4452
static int fib6_remove_prefsrc(struct fib6_info *rt, void *arg)
4453 4454 4455 4456 4457
{
	struct net_device *dev = ((struct arg_dev_net_ip *)arg)->dev;
	struct net *net = ((struct arg_dev_net_ip *)arg)->net;
	struct in6_addr *addr = ((struct arg_dev_net_ip *)arg)->addr;

4458 4459
	if (!rt->nh &&
	    ((void *)rt->fib6_nh->fib_nh_dev == dev || !dev) &&
D
David Ahern 已提交
4460
	    rt != net->ipv6.fib6_null_entry &&
4461
	    ipv6_addr_equal(addr, &rt->fib6_prefsrc.addr)) {
4462
		spin_lock_bh(&rt6_exception_lock);
4463
		/* remove prefsrc entry */
4464
		rt->fib6_prefsrc.plen = 0;
4465
		spin_unlock_bh(&rt6_exception_lock);
4466 4467 4468 4469 4470 4471 4472 4473 4474 4475 4476 4477
	}
	return 0;
}

void rt6_remove_prefsrc(struct inet6_ifaddr *ifp)
{
	struct net *net = dev_net(ifp->idev->dev);
	struct arg_dev_net_ip adni = {
		.dev = ifp->idev->dev,
		.net = net,
		.addr = &ifp->addr,
	};
4478
	fib6_clean_all(net, fib6_remove_prefsrc, &adni);
4479 4480
}

4481
#define RTF_RA_ROUTER		(RTF_ADDRCONF | RTF_DEFAULT)
4482 4483

/* Remove routers and update dst entries when gateway turn into host. */
4484
static int fib6_clean_tohost(struct fib6_info *rt, void *arg)
4485 4486
{
	struct in6_addr *gateway = (struct in6_addr *)arg;
4487 4488 4489 4490 4491
	struct fib6_nh *nh;

	/* RA routes do not use nexthops */
	if (rt->nh)
		return 0;
4492

4493
	nh = rt->fib6_nh;
4494
	if (((rt->fib6_flags & RTF_RA_ROUTER) == RTF_RA_ROUTER) &&
4495
	    nh->fib_nh_gw_family && ipv6_addr_equal(gateway, &nh->fib_nh_gw6))
4496
		return -1;
4497 4498 4499 4500 4501

	/* Further clean up cached routes in exception table.
	 * This is needed because cached route may have a different
	 * gateway than its 'parent' in the case of an ip redirect.
	 */
4502
	fib6_nh_exceptions_clean_tohost(nh, gateway);
4503

4504 4505 4506 4507 4508 4509 4510 4511
	return 0;
}

void rt6_clean_tohost(struct net *net, struct in6_addr *gateway)
{
	fib6_clean_all(net, fib6_clean_tohost, gateway);
}

4512 4513
struct arg_netdev_event {
	const struct net_device *dev;
4514
	union {
4515
		unsigned char nh_flags;
4516 4517
		unsigned long event;
	};
4518 4519
};

4520
static struct fib6_info *rt6_multipath_first_sibling(const struct fib6_info *rt)
4521
{
4522
	struct fib6_info *iter;
4523 4524
	struct fib6_node *fn;

4525 4526
	fn = rcu_dereference_protected(rt->fib6_node,
			lockdep_is_held(&rt->fib6_table->tb6_lock));
4527
	iter = rcu_dereference_protected(fn->leaf,
4528
			lockdep_is_held(&rt->fib6_table->tb6_lock));
4529
	while (iter) {
4530
		if (iter->fib6_metric == rt->fib6_metric &&
4531
		    rt6_qualify_for_ecmp(iter))
4532
			return iter;
4533
		iter = rcu_dereference_protected(iter->fib6_next,
4534
				lockdep_is_held(&rt->fib6_table->tb6_lock));
4535 4536 4537 4538 4539
	}

	return NULL;
}

4540
/* only called for fib entries with builtin fib6_nh */
4541
static bool rt6_is_dead(const struct fib6_info *rt)
4542
{
4543 4544 4545
	if (rt->fib6_nh->fib_nh_flags & RTNH_F_DEAD ||
	    (rt->fib6_nh->fib_nh_flags & RTNH_F_LINKDOWN &&
	     ip6_ignore_linkdown(rt->fib6_nh->fib_nh_dev)))
4546 4547 4548 4549 4550
		return true;

	return false;
}

4551
static int rt6_multipath_total_weight(const struct fib6_info *rt)
4552
{
4553
	struct fib6_info *iter;
4554 4555 4556
	int total = 0;

	if (!rt6_is_dead(rt))
4557
		total += rt->fib6_nh->fib_nh_weight;
4558

4559
	list_for_each_entry(iter, &rt->fib6_siblings, fib6_siblings) {
4560
		if (!rt6_is_dead(iter))
4561
			total += iter->fib6_nh->fib_nh_weight;
4562 4563 4564 4565 4566
	}

	return total;
}

4567
static void rt6_upper_bound_set(struct fib6_info *rt, int *weight, int total)
4568 4569 4570 4571
{
	int upper_bound = -1;

	if (!rt6_is_dead(rt)) {
4572
		*weight += rt->fib6_nh->fib_nh_weight;
4573 4574 4575
		upper_bound = DIV_ROUND_CLOSEST_ULL((u64) (*weight) << 31,
						    total) - 1;
	}
4576
	atomic_set(&rt->fib6_nh->fib_nh_upper_bound, upper_bound);
4577 4578
}

4579
static void rt6_multipath_upper_bound_set(struct fib6_info *rt, int total)
4580
{
4581
	struct fib6_info *iter;
4582 4583 4584 4585
	int weight = 0;

	rt6_upper_bound_set(rt, &weight, total);

4586
	list_for_each_entry(iter, &rt->fib6_siblings, fib6_siblings)
4587 4588 4589
		rt6_upper_bound_set(iter, &weight, total);
}

4590
void rt6_multipath_rebalance(struct fib6_info *rt)
4591
{
4592
	struct fib6_info *first;
4593 4594 4595 4596 4597 4598
	int total;

	/* In case the entire multipath route was marked for flushing,
	 * then there is no need to rebalance upon the removal of every
	 * sibling route.
	 */
4599
	if (!rt->fib6_nsiblings || rt->should_flush)
4600 4601 4602 4603 4604 4605 4606 4607 4608 4609 4610 4611 4612 4613
		return;

	/* During lookup routes are evaluated in order, so we need to
	 * make sure upper bounds are assigned from the first sibling
	 * onwards.
	 */
	first = rt6_multipath_first_sibling(rt);
	if (WARN_ON_ONCE(!first))
		return;

	total = rt6_multipath_total_weight(first);
	rt6_multipath_upper_bound_set(first, total);
}

4614
static int fib6_ifup(struct fib6_info *rt, void *p_arg)
4615 4616
{
	const struct arg_netdev_event *arg = p_arg;
4617
	struct net *net = dev_net(arg->dev);
4618

4619
	if (rt != net->ipv6.fib6_null_entry && !rt->nh &&
4620 4621
	    rt->fib6_nh->fib_nh_dev == arg->dev) {
		rt->fib6_nh->fib_nh_flags &= ~arg->nh_flags;
4622
		fib6_update_sernum_upto_root(net, rt);
4623
		rt6_multipath_rebalance(rt);
4624
	}
4625 4626 4627 4628

	return 0;
}

4629
void rt6_sync_up(struct net_device *dev, unsigned char nh_flags)
4630 4631 4632
{
	struct arg_netdev_event arg = {
		.dev = dev,
I
Ido Schimmel 已提交
4633 4634 4635
		{
			.nh_flags = nh_flags,
		},
4636 4637 4638 4639 4640 4641 4642 4643
	};

	if (nh_flags & RTNH_F_DEAD && netif_carrier_ok(dev))
		arg.nh_flags |= RTNH_F_LINKDOWN;

	fib6_clean_all(dev_net(dev), fib6_ifup, &arg);
}

4644
/* only called for fib entries with inline fib6_nh */
4645
static bool rt6_multipath_uses_dev(const struct fib6_info *rt,
4646 4647
				   const struct net_device *dev)
{
4648
	struct fib6_info *iter;
4649

4650
	if (rt->fib6_nh->fib_nh_dev == dev)
4651
		return true;
4652
	list_for_each_entry(iter, &rt->fib6_siblings, fib6_siblings)
4653
		if (iter->fib6_nh->fib_nh_dev == dev)
4654 4655 4656 4657 4658
			return true;

	return false;
}

4659
static void rt6_multipath_flush(struct fib6_info *rt)
4660
{
4661
	struct fib6_info *iter;
4662 4663

	rt->should_flush = 1;
4664
	list_for_each_entry(iter, &rt->fib6_siblings, fib6_siblings)
4665 4666 4667
		iter->should_flush = 1;
}

4668
static unsigned int rt6_multipath_dead_count(const struct fib6_info *rt,
4669 4670
					     const struct net_device *down_dev)
{
4671
	struct fib6_info *iter;
4672 4673
	unsigned int dead = 0;

4674 4675
	if (rt->fib6_nh->fib_nh_dev == down_dev ||
	    rt->fib6_nh->fib_nh_flags & RTNH_F_DEAD)
4676
		dead++;
4677
	list_for_each_entry(iter, &rt->fib6_siblings, fib6_siblings)
4678 4679
		if (iter->fib6_nh->fib_nh_dev == down_dev ||
		    iter->fib6_nh->fib_nh_flags & RTNH_F_DEAD)
4680 4681 4682 4683 4684
			dead++;

	return dead;
}

4685
static void rt6_multipath_nh_flags_set(struct fib6_info *rt,
4686
				       const struct net_device *dev,
4687
				       unsigned char nh_flags)
4688
{
4689
	struct fib6_info *iter;
4690

4691 4692
	if (rt->fib6_nh->fib_nh_dev == dev)
		rt->fib6_nh->fib_nh_flags |= nh_flags;
4693
	list_for_each_entry(iter, &rt->fib6_siblings, fib6_siblings)
4694 4695
		if (iter->fib6_nh->fib_nh_dev == dev)
			iter->fib6_nh->fib_nh_flags |= nh_flags;
4696 4697
}

4698
/* called with write lock held for table with rt */
4699
static int fib6_ifdown(struct fib6_info *rt, void *p_arg)
L
Linus Torvalds 已提交
4700
{
4701 4702
	const struct arg_netdev_event *arg = p_arg;
	const struct net_device *dev = arg->dev;
4703
	struct net *net = dev_net(dev);
4704

4705
	if (rt == net->ipv6.fib6_null_entry || rt->nh)
4706 4707 4708 4709
		return 0;

	switch (arg->event) {
	case NETDEV_UNREGISTER:
4710
		return rt->fib6_nh->fib_nh_dev == dev ? -1 : 0;
4711
	case NETDEV_DOWN:
4712
		if (rt->should_flush)
4713
			return -1;
4714
		if (!rt->fib6_nsiblings)
4715
			return rt->fib6_nh->fib_nh_dev == dev ? -1 : 0;
4716 4717 4718 4719
		if (rt6_multipath_uses_dev(rt, dev)) {
			unsigned int count;

			count = rt6_multipath_dead_count(rt, dev);
4720
			if (rt->fib6_nsiblings + 1 == count) {
4721 4722 4723 4724 4725
				rt6_multipath_flush(rt);
				return -1;
			}
			rt6_multipath_nh_flags_set(rt, dev, RTNH_F_DEAD |
						   RTNH_F_LINKDOWN);
4726
			fib6_update_sernum(net, rt);
4727
			rt6_multipath_rebalance(rt);
4728 4729
		}
		return -2;
4730
	case NETDEV_CHANGE:
4731
		if (rt->fib6_nh->fib_nh_dev != dev ||
4732
		    rt->fib6_flags & (RTF_LOCAL | RTF_ANYCAST))
4733
			break;
4734
		rt->fib6_nh->fib_nh_flags |= RTNH_F_LINKDOWN;
4735
		rt6_multipath_rebalance(rt);
4736
		break;
4737
	}
4738

L
Linus Torvalds 已提交
4739 4740 4741
	return 0;
}

4742
void rt6_sync_down_dev(struct net_device *dev, unsigned long event)
L
Linus Torvalds 已提交
4743
{
4744
	struct arg_netdev_event arg = {
4745
		.dev = dev,
I
Ido Schimmel 已提交
4746 4747 4748
		{
			.event = event,
		},
4749
	};
4750
	struct net *net = dev_net(dev);
4751

4752 4753 4754 4755
	if (net->ipv6.sysctl.skip_notify_on_dev_down)
		fib6_clean_all_skip_notify(net, fib6_ifdown, &arg);
	else
		fib6_clean_all(net, fib6_ifdown, &arg);
4756 4757 4758 4759 4760 4761 4762
}

void rt6_disable_ip(struct net_device *dev, unsigned long event)
{
	rt6_sync_down_dev(dev, event);
	rt6_uncached_list_flush_dev(dev_net(dev), dev);
	neigh_ifdown(&nd_tbl, dev);
L
Linus Torvalds 已提交
4763 4764
}

4765
struct rt6_mtu_change_arg {
L
Linus Torvalds 已提交
4766
	struct net_device *dev;
4767
	unsigned int mtu;
D
David Ahern 已提交
4768
	struct fib6_info *f6i;
L
Linus Torvalds 已提交
4769 4770
};

4771
static int fib6_nh_mtu_change(struct fib6_nh *nh, void *_arg)
D
David Ahern 已提交
4772 4773
{
	struct rt6_mtu_change_arg *arg = (struct rt6_mtu_change_arg *)_arg;
4774
	struct fib6_info *f6i = arg->f6i;
D
David Ahern 已提交
4775 4776 4777 4778 4779 4780 4781 4782 4783 4784 4785 4786 4787 4788 4789

	/* For administrative MTU increase, there is no way to discover
	 * IPv6 PMTU increase, so PMTU increase should be updated here.
	 * Since RFC 1981 doesn't include administrative MTU increase
	 * update PMTU increase is a MUST. (i.e. jumbo frame)
	 */
	if (nh->fib_nh_dev == arg->dev) {
		struct inet6_dev *idev = __in6_dev_get(arg->dev);
		u32 mtu = f6i->fib6_pmtu;

		if (mtu >= arg->mtu ||
		    (mtu < arg->mtu && mtu == idev->cnf.mtu6))
			fib6_metric_set(f6i, RTAX_MTU, arg->mtu);

		spin_lock_bh(&rt6_exception_lock);
4790
		rt6_exceptions_update_pmtu(idev, nh, arg->mtu);
D
David Ahern 已提交
4791 4792 4793 4794 4795 4796 4797
		spin_unlock_bh(&rt6_exception_lock);
	}

	return 0;
}

static int rt6_mtu_change_route(struct fib6_info *f6i, void *p_arg)
L
Linus Torvalds 已提交
4798 4799 4800 4801 4802 4803 4804 4805 4806 4807 4808
{
	struct rt6_mtu_change_arg *arg = (struct rt6_mtu_change_arg *) p_arg;
	struct inet6_dev *idev;

	/* In IPv6 pmtu discovery is not optional,
	   so that RTAX_MTU lock cannot disable it.
	   We still use this lock to block changes
	   caused by addrconf/ndisc.
	*/

	idev = __in6_dev_get(arg->dev);
4809
	if (!idev)
L
Linus Torvalds 已提交
4810 4811
		return 0;

D
David Ahern 已提交
4812 4813
	if (fib6_metric_locked(f6i, RTAX_MTU))
		return 0;
4814

D
David Ahern 已提交
4815
	arg->f6i = f6i;
4816 4817 4818 4819 4820 4821
	if (f6i->nh) {
		/* fib6_nh_mtu_change only returns 0, so this is safe */
		return nexthop_for_each_fib6_nh(f6i->nh, fib6_nh_mtu_change,
						arg);
	}

4822
	return fib6_nh_mtu_change(f6i->fib6_nh, arg);
L
Linus Torvalds 已提交
4823 4824
}

4825
void rt6_mtu_change(struct net_device *dev, unsigned int mtu)
L
Linus Torvalds 已提交
4826
{
T
Thomas Graf 已提交
4827 4828 4829 4830
	struct rt6_mtu_change_arg arg = {
		.dev = dev,
		.mtu = mtu,
	};
L
Linus Torvalds 已提交
4831

4832
	fib6_clean_all(dev_net(dev), rt6_mtu_change_route, &arg);
L
Linus Torvalds 已提交
4833 4834
}

4835
static const struct nla_policy rtm_ipv6_policy[RTA_MAX+1] = {
4836
	[RTA_UNSPEC]		= { .strict_start_type = RTA_DPORT + 1 },
4837
	[RTA_GATEWAY]           = { .len = sizeof(struct in6_addr) },
4838
	[RTA_PREFSRC]		= { .len = sizeof(struct in6_addr) },
4839
	[RTA_OIF]               = { .type = NLA_U32 },
4840
	[RTA_IIF]		= { .type = NLA_U32 },
4841 4842
	[RTA_PRIORITY]          = { .type = NLA_U32 },
	[RTA_METRICS]           = { .type = NLA_NESTED },
4843
	[RTA_MULTIPATH]		= { .len = sizeof(struct rtnexthop) },
4844
	[RTA_PREF]              = { .type = NLA_U8 },
4845 4846
	[RTA_ENCAP_TYPE]	= { .type = NLA_U16 },
	[RTA_ENCAP]		= { .type = NLA_NESTED },
4847
	[RTA_EXPIRES]		= { .type = NLA_U32 },
4848
	[RTA_UID]		= { .type = NLA_U32 },
4849
	[RTA_MARK]		= { .type = NLA_U32 },
4850
	[RTA_TABLE]		= { .type = NLA_U32 },
4851 4852 4853
	[RTA_IP_PROTO]		= { .type = NLA_U8 },
	[RTA_SPORT]		= { .type = NLA_U16 },
	[RTA_DPORT]		= { .type = NLA_U16 },
4854
	[RTA_NH_ID]		= { .type = NLA_U32 },
4855 4856 4857
};

static int rtm_to_fib6_config(struct sk_buff *skb, struct nlmsghdr *nlh,
4858 4859
			      struct fib6_config *cfg,
			      struct netlink_ext_ack *extack)
L
Linus Torvalds 已提交
4860
{
4861 4862
	struct rtmsg *rtm;
	struct nlattr *tb[RTA_MAX+1];
4863
	unsigned int pref;
4864
	int err;
L
Linus Torvalds 已提交
4865

4866 4867
	err = nlmsg_parse_deprecated(nlh, sizeof(*rtm), tb, RTA_MAX,
				     rtm_ipv6_policy, extack);
4868 4869
	if (err < 0)
		goto errout;
L
Linus Torvalds 已提交
4870

4871 4872 4873
	err = -EINVAL;
	rtm = nlmsg_data(nlh);

4874 4875 4876 4877 4878 4879 4880 4881 4882 4883 4884 4885
	*cfg = (struct fib6_config){
		.fc_table = rtm->rtm_table,
		.fc_dst_len = rtm->rtm_dst_len,
		.fc_src_len = rtm->rtm_src_len,
		.fc_flags = RTF_UP,
		.fc_protocol = rtm->rtm_protocol,
		.fc_type = rtm->rtm_type,

		.fc_nlinfo.portid = NETLINK_CB(skb).portid,
		.fc_nlinfo.nlh = nlh,
		.fc_nlinfo.nl_net = sock_net(skb->sk),
	};
4886

4887 4888
	if (rtm->rtm_type == RTN_UNREACHABLE ||
	    rtm->rtm_type == RTN_BLACKHOLE ||
4889 4890
	    rtm->rtm_type == RTN_PROHIBIT ||
	    rtm->rtm_type == RTN_THROW)
4891 4892
		cfg->fc_flags |= RTF_REJECT;

4893 4894 4895
	if (rtm->rtm_type == RTN_LOCAL)
		cfg->fc_flags |= RTF_LOCAL;

4896 4897 4898
	if (rtm->rtm_flags & RTM_F_CLONED)
		cfg->fc_flags |= RTF_CACHE;

4899 4900
	cfg->fc_flags |= (rtm->rtm_flags & RTNH_F_ONLINK);

4901 4902 4903 4904 4905 4906 4907 4908 4909 4910
	if (tb[RTA_NH_ID]) {
		if (tb[RTA_GATEWAY]   || tb[RTA_OIF] ||
		    tb[RTA_MULTIPATH] || tb[RTA_ENCAP]) {
			NL_SET_ERR_MSG(extack,
				       "Nexthop specification and nexthop id are mutually exclusive");
			goto errout;
		}
		cfg->fc_nh_id = nla_get_u32(tb[RTA_NH_ID]);
	}

4911
	if (tb[RTA_GATEWAY]) {
4912
		cfg->fc_gateway = nla_get_in6_addr(tb[RTA_GATEWAY]);
4913
		cfg->fc_flags |= RTF_GATEWAY;
L
Linus Torvalds 已提交
4914
	}
4915 4916 4917 4918
	if (tb[RTA_VIA]) {
		NL_SET_ERR_MSG(extack, "IPv6 does not support RTA_VIA attribute");
		goto errout;
	}
4919 4920 4921 4922 4923 4924 4925 4926

	if (tb[RTA_DST]) {
		int plen = (rtm->rtm_dst_len + 7) >> 3;

		if (nla_len(tb[RTA_DST]) < plen)
			goto errout;

		nla_memcpy(&cfg->fc_dst, tb[RTA_DST], plen);
L
Linus Torvalds 已提交
4927
	}
4928 4929 4930 4931 4932 4933 4934 4935

	if (tb[RTA_SRC]) {
		int plen = (rtm->rtm_src_len + 7) >> 3;

		if (nla_len(tb[RTA_SRC]) < plen)
			goto errout;

		nla_memcpy(&cfg->fc_src, tb[RTA_SRC], plen);
L
Linus Torvalds 已提交
4936
	}
4937

4938
	if (tb[RTA_PREFSRC])
4939
		cfg->fc_prefsrc = nla_get_in6_addr(tb[RTA_PREFSRC]);
4940

4941 4942 4943 4944 4945 4946 4947 4948 4949
	if (tb[RTA_OIF])
		cfg->fc_ifindex = nla_get_u32(tb[RTA_OIF]);

	if (tb[RTA_PRIORITY])
		cfg->fc_metric = nla_get_u32(tb[RTA_PRIORITY]);

	if (tb[RTA_METRICS]) {
		cfg->fc_mx = nla_data(tb[RTA_METRICS]);
		cfg->fc_mx_len = nla_len(tb[RTA_METRICS]);
L
Linus Torvalds 已提交
4950
	}
4951 4952 4953 4954

	if (tb[RTA_TABLE])
		cfg->fc_table = nla_get_u32(tb[RTA_TABLE]);

4955 4956 4957
	if (tb[RTA_MULTIPATH]) {
		cfg->fc_mp = nla_data(tb[RTA_MULTIPATH]);
		cfg->fc_mp_len = nla_len(tb[RTA_MULTIPATH]);
4958 4959

		err = lwtunnel_valid_encap_type_attr(cfg->fc_mp,
4960
						     cfg->fc_mp_len, extack);
4961 4962
		if (err < 0)
			goto errout;
4963 4964
	}

4965 4966 4967 4968 4969 4970 4971 4972
	if (tb[RTA_PREF]) {
		pref = nla_get_u8(tb[RTA_PREF]);
		if (pref != ICMPV6_ROUTER_PREF_LOW &&
		    pref != ICMPV6_ROUTER_PREF_HIGH)
			pref = ICMPV6_ROUTER_PREF_MEDIUM;
		cfg->fc_flags |= RTF_PREF(pref);
	}

4973 4974 4975
	if (tb[RTA_ENCAP])
		cfg->fc_encap = tb[RTA_ENCAP];

4976
	if (tb[RTA_ENCAP_TYPE]) {
4977 4978
		cfg->fc_encap_type = nla_get_u16(tb[RTA_ENCAP_TYPE]);

4979
		err = lwtunnel_valid_encap_type(cfg->fc_encap_type, extack);
4980 4981 4982 4983
		if (err < 0)
			goto errout;
	}

4984 4985 4986 4987 4988 4989 4990 4991 4992
	if (tb[RTA_EXPIRES]) {
		unsigned long timeout = addrconf_timeout_fixup(nla_get_u32(tb[RTA_EXPIRES]), HZ);

		if (addrconf_finite_timeout(timeout)) {
			cfg->fc_expires = jiffies_to_clock_t(timeout * HZ);
			cfg->fc_flags |= RTF_EXPIRES;
		}
	}

4993 4994 4995
	err = 0;
errout:
	return err;
L
Linus Torvalds 已提交
4996 4997
}

4998
struct rt6_nh {
4999
	struct fib6_info *fib6_info;
5000 5001 5002 5003
	struct fib6_config r_cfg;
	struct list_head next;
};

5004 5005
static int ip6_route_info_append(struct net *net,
				 struct list_head *rt6_nh_list,
5006 5007
				 struct fib6_info *rt,
				 struct fib6_config *r_cfg)
5008 5009 5010 5011 5012
{
	struct rt6_nh *nh;
	int err = -EEXIST;

	list_for_each_entry(nh, rt6_nh_list, next) {
5013 5014
		/* check if fib6_info already exists */
		if (rt6_duplicate_nexthop(nh->fib6_info, rt))
5015 5016 5017 5018 5019 5020
			return err;
	}

	nh = kzalloc(sizeof(*nh), GFP_KERNEL);
	if (!nh)
		return -ENOMEM;
5021
	nh->fib6_info = rt;
5022 5023 5024 5025 5026 5027
	memcpy(&nh->r_cfg, r_cfg, sizeof(*r_cfg));
	list_add_tail(&nh->next, rt6_nh_list);

	return 0;
}

5028 5029
static void ip6_route_mpath_notify(struct fib6_info *rt,
				   struct fib6_info *rt_last,
5030 5031 5032 5033 5034 5035 5036 5037 5038
				   struct nl_info *info,
				   __u16 nlflags)
{
	/* if this is an APPEND route, then rt points to the first route
	 * inserted and rt_last points to last route inserted. Userspace
	 * wants a consistent dump of the route which starts at the first
	 * nexthop. Since sibling routes are always added at the end of
	 * the list, find the first sibling of the last route appended
	 */
5039 5040
	if ((nlflags & NLM_F_APPEND) && rt_last && rt_last->fib6_nsiblings) {
		rt = list_first_entry(&rt_last->fib6_siblings,
5041
				      struct fib6_info,
5042
				      fib6_siblings);
5043 5044 5045 5046 5047 5048
	}

	if (rt)
		inet6_rt_notify(RTM_NEWROUTE, rt, info, nlflags);
}

5049 5050 5051 5052 5053 5054 5055 5056 5057 5058 5059 5060 5061 5062 5063 5064 5065 5066 5067 5068 5069 5070 5071 5072 5073 5074
static bool ip6_route_mpath_should_notify(const struct fib6_info *rt)
{
	bool rt_can_ecmp = rt6_qualify_for_ecmp(rt);
	bool should_notify = false;
	struct fib6_info *leaf;
	struct fib6_node *fn;

	rcu_read_lock();
	fn = rcu_dereference(rt->fib6_node);
	if (!fn)
		goto out;

	leaf = rcu_dereference(fn->leaf);
	if (!leaf)
		goto out;

	if (rt == leaf ||
	    (rt_can_ecmp && rt->fib6_metric == leaf->fib6_metric &&
	     rt6_qualify_for_ecmp(leaf)))
		should_notify = true;
out:
	rcu_read_unlock();

	return should_notify;
}

5075 5076
static int ip6_route_multipath_add(struct fib6_config *cfg,
				   struct netlink_ext_ack *extack)
5077
{
5078
	struct fib6_info *rt_notif = NULL, *rt_last = NULL;
5079
	struct nl_info *info = &cfg->fc_nlinfo;
5080 5081
	struct fib6_config r_cfg;
	struct rtnexthop *rtnh;
5082
	struct fib6_info *rt;
5083 5084
	struct rt6_nh *err_nh;
	struct rt6_nh *nh, *nh_safe;
5085
	__u16 nlflags;
5086 5087
	int remaining;
	int attrlen;
5088 5089 5090 5091 5092
	int err = 1;
	int nhn = 0;
	int replace = (cfg->fc_nlinfo.nlh &&
		       (cfg->fc_nlinfo.nlh->nlmsg_flags & NLM_F_REPLACE));
	LIST_HEAD(rt6_nh_list);
5093

5094 5095 5096 5097
	nlflags = replace ? NLM_F_REPLACE : NLM_F_CREATE;
	if (info->nlh && info->nlh->nlmsg_flags & NLM_F_APPEND)
		nlflags |= NLM_F_APPEND;

5098
	remaining = cfg->fc_mp_len;
5099 5100
	rtnh = (struct rtnexthop *)cfg->fc_mp;

5101
	/* Parse a Multipath Entry and build a list (rt6_nh_list) of
5102
	 * fib6_info structs per nexthop
5103
	 */
5104 5105 5106 5107 5108 5109 5110 5111 5112 5113 5114
	while (rtnh_ok(rtnh, remaining)) {
		memcpy(&r_cfg, cfg, sizeof(*cfg));
		if (rtnh->rtnh_ifindex)
			r_cfg.fc_ifindex = rtnh->rtnh_ifindex;

		attrlen = rtnh_attrlen(rtnh);
		if (attrlen > 0) {
			struct nlattr *nla, *attrs = rtnh_attrs(rtnh);

			nla = nla_find(attrs, attrlen, RTA_GATEWAY);
			if (nla) {
5115
				r_cfg.fc_gateway = nla_get_in6_addr(nla);
5116 5117
				r_cfg.fc_flags |= RTF_GATEWAY;
			}
5118 5119 5120 5121
			r_cfg.fc_encap = nla_find(attrs, attrlen, RTA_ENCAP);
			nla = nla_find(attrs, attrlen, RTA_ENCAP_TYPE);
			if (nla)
				r_cfg.fc_encap_type = nla_get_u16(nla);
5122
		}
5123

5124
		r_cfg.fc_flags |= (rtnh->rtnh_flags & RTNH_F_ONLINK);
5125
		rt = ip6_route_info_create(&r_cfg, GFP_KERNEL, extack);
5126 5127 5128
		if (IS_ERR(rt)) {
			err = PTR_ERR(rt);
			rt = NULL;
5129
			goto cleanup;
5130
		}
5131 5132 5133 5134 5135 5136 5137
		if (!rt6_qualify_for_ecmp(rt)) {
			err = -EINVAL;
			NL_SET_ERR_MSG(extack,
				       "Device only routes can not be added for IPv6 using the multipath API.");
			fib6_info_release(rt);
			goto cleanup;
		}
5138

5139
		rt->fib6_nh->fib_nh_weight = rtnh->rtnh_hops + 1;
5140

5141 5142
		err = ip6_route_info_append(info->nl_net, &rt6_nh_list,
					    rt, &r_cfg);
5143
		if (err) {
5144
			fib6_info_release(rt);
5145 5146 5147 5148 5149 5150
			goto cleanup;
		}

		rtnh = rtnh_next(rtnh, &remaining);
	}

5151 5152 5153 5154 5155 5156
	if (list_empty(&rt6_nh_list)) {
		NL_SET_ERR_MSG(extack,
			       "Invalid nexthop configuration - no valid nexthops");
		return -EINVAL;
	}

5157 5158 5159 5160 5161 5162
	/* for add and replace send one notification with all nexthops.
	 * Skip the notification in fib6_add_rt2node and send one with
	 * the full route when done
	 */
	info->skip_notify = 1;

5163 5164 5165 5166 5167
	/* For add and replace, send one notification with all nexthops. For
	 * append, send one notification with all appended nexthops.
	 */
	info->skip_notify_kernel = 1;

5168 5169
	err_nh = NULL;
	list_for_each_entry(nh, &rt6_nh_list, next) {
5170 5171
		err = __ip6_ins_rt(nh->fib6_info, info, extack);
		fib6_info_release(nh->fib6_info);
5172

5173 5174 5175 5176 5177 5178 5179 5180
		if (!err) {
			/* save reference to last route successfully inserted */
			rt_last = nh->fib6_info;

			/* save reference to first route for notification */
			if (!rt_notif)
				rt_notif = nh->fib6_info;
		}
5181

5182 5183
		/* nh->fib6_info is used or freed at this point, reset to NULL*/
		nh->fib6_info = NULL;
5184 5185
		if (err) {
			if (replace && nhn)
5186 5187
				NL_SET_ERR_MSG_MOD(extack,
						   "multipath route replace failed (check consistency of installed routes)");
5188 5189
			err_nh = nh;
			goto add_errout;
5190
		}
5191

5192
		/* Because each route is added like a single route we remove
5193 5194 5195 5196 5197
		 * these flags after the first nexthop: if there is a collision,
		 * we have already failed to add the first nexthop:
		 * fib6_add_rt2node() has rejected it; when replacing, old
		 * nexthops have been replaced by first new, the rest should
		 * be added to it.
5198
		 */
5199 5200
		cfg->fc_nlinfo.nlh->nlmsg_flags &= ~(NLM_F_EXCL |
						     NLM_F_REPLACE);
5201 5202 5203
		nhn++;
	}

5204 5205 5206 5207 5208 5209 5210 5211 5212 5213 5214
	/* An in-kernel notification should only be sent in case the new
	 * multipath route is added as the first route in the node, or if
	 * it was appended to it. We pass 'rt_notif' since it is the first
	 * sibling and might allow us to skip some checks in the replace case.
	 */
	if (ip6_route_mpath_should_notify(rt_notif)) {
		enum fib_event_type fib_event;

		if (rt_notif->fib6_nsiblings != nhn - 1)
			fib_event = FIB_EVENT_ENTRY_APPEND;
		else
5215
			fib_event = FIB_EVENT_ENTRY_REPLACE;
5216 5217 5218 5219 5220 5221 5222 5223 5224 5225

		err = call_fib6_multipath_entry_notifiers(info->nl_net,
							  fib_event, rt_notif,
							  nhn - 1, extack);
		if (err) {
			/* Delete all the siblings that were just added */
			err_nh = NULL;
			goto add_errout;
		}
	}
5226

5227 5228
	/* success ... tell user about new route */
	ip6_route_mpath_notify(rt_notif, rt_last, info, nlflags);
5229 5230 5231
	goto cleanup;

add_errout:
5232 5233 5234 5235 5236 5237 5238
	/* send notification for routes that were added so that
	 * the delete notifications sent by ip6_route_del are
	 * coherent
	 */
	if (rt_notif)
		ip6_route_mpath_notify(rt_notif, rt_last, info, nlflags);

5239 5240 5241 5242
	/* Delete routes that were already added */
	list_for_each_entry(nh, &rt6_nh_list, next) {
		if (err_nh == nh)
			break;
5243
		ip6_route_del(&nh->r_cfg, extack);
5244 5245 5246 5247
	}

cleanup:
	list_for_each_entry_safe(nh, nh_safe, &rt6_nh_list, next) {
5248 5249
		if (nh->fib6_info)
			fib6_info_release(nh->fib6_info);
5250 5251 5252 5253 5254 5255 5256
		list_del(&nh->next);
		kfree(nh);
	}

	return err;
}

5257 5258
static int ip6_route_multipath_del(struct fib6_config *cfg,
				   struct netlink_ext_ack *extack)
5259 5260 5261 5262 5263 5264 5265 5266 5267 5268 5269 5270 5271 5272 5273 5274 5275 5276 5277 5278 5279 5280 5281 5282 5283 5284
{
	struct fib6_config r_cfg;
	struct rtnexthop *rtnh;
	int remaining;
	int attrlen;
	int err = 1, last_err = 0;

	remaining = cfg->fc_mp_len;
	rtnh = (struct rtnexthop *)cfg->fc_mp;

	/* Parse a Multipath Entry */
	while (rtnh_ok(rtnh, remaining)) {
		memcpy(&r_cfg, cfg, sizeof(*cfg));
		if (rtnh->rtnh_ifindex)
			r_cfg.fc_ifindex = rtnh->rtnh_ifindex;

		attrlen = rtnh_attrlen(rtnh);
		if (attrlen > 0) {
			struct nlattr *nla, *attrs = rtnh_attrs(rtnh);

			nla = nla_find(attrs, attrlen, RTA_GATEWAY);
			if (nla) {
				nla_memcpy(&r_cfg.fc_gateway, nla, 16);
				r_cfg.fc_flags |= RTF_GATEWAY;
			}
		}
5285
		err = ip6_route_del(&r_cfg, extack);
5286 5287 5288
		if (err)
			last_err = err;

5289 5290 5291 5292 5293 5294
		rtnh = rtnh_next(rtnh, &remaining);
	}

	return last_err;
}

5295 5296
static int inet6_rtm_delroute(struct sk_buff *skb, struct nlmsghdr *nlh,
			      struct netlink_ext_ack *extack)
L
Linus Torvalds 已提交
5297
{
5298 5299
	struct fib6_config cfg;
	int err;
L
Linus Torvalds 已提交
5300

5301
	err = rtm_to_fib6_config(skb, nlh, &cfg, extack);
5302 5303 5304
	if (err < 0)
		return err;

5305 5306 5307 5308 5309 5310
	if (cfg.fc_nh_id &&
	    !nexthop_find_by_id(sock_net(skb->sk), cfg.fc_nh_id)) {
		NL_SET_ERR_MSG(extack, "Nexthop id does not exist");
		return -EINVAL;
	}

5311
	if (cfg.fc_mp)
5312
		return ip6_route_multipath_del(&cfg, extack);
5313 5314
	else {
		cfg.fc_delete_all_nh = 1;
5315
		return ip6_route_del(&cfg, extack);
5316
	}
L
Linus Torvalds 已提交
5317 5318
}

5319 5320
static int inet6_rtm_newroute(struct sk_buff *skb, struct nlmsghdr *nlh,
			      struct netlink_ext_ack *extack)
L
Linus Torvalds 已提交
5321
{
5322 5323
	struct fib6_config cfg;
	int err;
L
Linus Torvalds 已提交
5324

5325
	err = rtm_to_fib6_config(skb, nlh, &cfg, extack);
5326 5327 5328
	if (err < 0)
		return err;

5329 5330 5331
	if (cfg.fc_metric == 0)
		cfg.fc_metric = IP6_RT_PRIO_USER;

5332
	if (cfg.fc_mp)
5333
		return ip6_route_multipath_add(&cfg, extack);
5334
	else
5335
		return ip6_route_add(&cfg, GFP_KERNEL, extack);
L
Linus Torvalds 已提交
5336 5337
}

5338 5339
/* add the overhead of this fib6_nh to nexthop_len */
static int rt6_nh_nlmsg_size(struct fib6_nh *nh, void *arg)
5340
{
5341
	int *nexthop_len = arg;
5342

5343 5344 5345 5346 5347 5348 5349 5350 5351 5352
	*nexthop_len += nla_total_size(0)	 /* RTA_MULTIPATH */
		     + NLA_ALIGN(sizeof(struct rtnexthop))
		     + nla_total_size(16); /* RTA_GATEWAY */

	if (nh->fib_nh_lws) {
		/* RTA_ENCAP_TYPE */
		*nexthop_len += lwtunnel_get_encap_size(nh->fib_nh_lws);
		/* RTA_ENCAP */
		*nexthop_len += nla_total_size(2);
	}
5353

5354 5355
	return 0;
}
5356

5357 5358 5359 5360 5361 5362 5363 5364 5365 5366 5367 5368 5369 5370 5371 5372 5373 5374 5375 5376 5377
static size_t rt6_nlmsg_size(struct fib6_info *f6i)
{
	int nexthop_len;

	if (f6i->nh) {
		nexthop_len = nla_total_size(4); /* RTA_NH_ID */
		nexthop_for_each_fib6_nh(f6i->nh, rt6_nh_nlmsg_size,
					 &nexthop_len);
	} else {
		struct fib6_nh *nh = f6i->fib6_nh;

		nexthop_len = 0;
		if (f6i->fib6_nsiblings) {
			nexthop_len = nla_total_size(0)	 /* RTA_MULTIPATH */
				    + NLA_ALIGN(sizeof(struct rtnexthop))
				    + nla_total_size(16) /* RTA_GATEWAY */
				    + lwtunnel_get_encap_size(nh->fib_nh_lws);

			nexthop_len *= f6i->fib6_nsiblings;
		}
		nexthop_len += lwtunnel_get_encap_size(nh->fib_nh_lws);
5378 5379
	}

5380 5381 5382 5383 5384 5385 5386 5387 5388
	return NLMSG_ALIGN(sizeof(struct rtmsg))
	       + nla_total_size(16) /* RTA_SRC */
	       + nla_total_size(16) /* RTA_DST */
	       + nla_total_size(16) /* RTA_GATEWAY */
	       + nla_total_size(16) /* RTA_PREFSRC */
	       + nla_total_size(4) /* RTA_TABLE */
	       + nla_total_size(4) /* RTA_IIF */
	       + nla_total_size(4) /* RTA_OIF */
	       + nla_total_size(4) /* RTA_PRIORITY */
5389
	       + RTAX_MAX * nla_total_size(4) /* RTA_METRICS */
5390
	       + nla_total_size(sizeof(struct rta_cacheinfo))
5391
	       + nla_total_size(TCP_CA_NAME_MAX) /* RTAX_CC_ALGO */
5392
	       + nla_total_size(1) /* RTA_PREF */
5393 5394 5395
	       + nexthop_len;
}

5396 5397 5398 5399 5400 5401
static int rt6_fill_node_nexthop(struct sk_buff *skb, struct nexthop *nh,
				 unsigned char *flags)
{
	if (nexthop_is_multipath(nh)) {
		struct nlattr *mp;

5402
		mp = nla_nest_start_noflag(skb, RTA_MULTIPATH);
5403 5404 5405
		if (!mp)
			goto nla_put_failure;

5406
		if (nexthop_mpath_fill_node(skb, nh, AF_INET6))
5407 5408 5409 5410 5411 5412 5413
			goto nla_put_failure;

		nla_nest_end(skb, mp);
	} else {
		struct fib6_nh *fib6_nh;

		fib6_nh = nexthop_fib6_nh(nh);
5414
		if (fib_nexthop_info(skb, &fib6_nh->nh_common, AF_INET6,
5415 5416 5417 5418 5419 5420 5421 5422 5423 5424
				     flags, false) < 0)
			goto nla_put_failure;
	}

	return 0;

nla_put_failure:
	return -EMSGSIZE;
}

5425
static int rt6_fill_node(struct net *net, struct sk_buff *skb,
5426
			 struct fib6_info *rt, struct dst_entry *dst,
5427
			 struct in6_addr *dest, struct in6_addr *src,
5428
			 int iif, int type, u32 portid, u32 seq,
5429
			 unsigned int flags)
L
Linus Torvalds 已提交
5430
{
5431 5432 5433
	struct rt6_info *rt6 = (struct rt6_info *)dst;
	struct rt6key *rt6_dst, *rt6_src;
	u32 *pmetrics, table, rt6_flags;
5434
	unsigned char nh_flags = 0;
5435
	struct nlmsghdr *nlh;
5436
	struct rtmsg *rtm;
5437
	long expires = 0;
L
Linus Torvalds 已提交
5438

5439
	nlh = nlmsg_put(skb, portid, seq, type, sizeof(*rtm), flags);
5440
	if (!nlh)
5441
		return -EMSGSIZE;
5442

5443 5444 5445 5446 5447 5448 5449 5450 5451 5452
	if (rt6) {
		rt6_dst = &rt6->rt6i_dst;
		rt6_src = &rt6->rt6i_src;
		rt6_flags = rt6->rt6i_flags;
	} else {
		rt6_dst = &rt->fib6_dst;
		rt6_src = &rt->fib6_src;
		rt6_flags = rt->fib6_flags;
	}

5453
	rtm = nlmsg_data(nlh);
L
Linus Torvalds 已提交
5454
	rtm->rtm_family = AF_INET6;
5455 5456
	rtm->rtm_dst_len = rt6_dst->plen;
	rtm->rtm_src_len = rt6_src->plen;
L
Linus Torvalds 已提交
5457
	rtm->rtm_tos = 0;
5458 5459
	if (rt->fib6_table)
		table = rt->fib6_table->tb6_id;
T
Thomas Graf 已提交
5460
	else
5461
		table = RT6_TABLE_UNSPEC;
5462
	rtm->rtm_table = table < 256 ? table : RT_TABLE_COMPAT;
D
David S. Miller 已提交
5463 5464
	if (nla_put_u32(skb, RTA_TABLE, table))
		goto nla_put_failure;
5465 5466

	rtm->rtm_type = rt->fib6_type;
L
Linus Torvalds 已提交
5467 5468
	rtm->rtm_flags = 0;
	rtm->rtm_scope = RT_SCOPE_UNIVERSE;
5469
	rtm->rtm_protocol = rt->fib6_protocol;
L
Linus Torvalds 已提交
5470

5471
	if (rt6_flags & RTF_CACHE)
L
Linus Torvalds 已提交
5472 5473
		rtm->rtm_flags |= RTM_F_CLONED;

5474 5475
	if (dest) {
		if (nla_put_in6_addr(skb, RTA_DST, dest))
D
David S. Miller 已提交
5476
			goto nla_put_failure;
5477
		rtm->rtm_dst_len = 128;
L
Linus Torvalds 已提交
5478
	} else if (rtm->rtm_dst_len)
5479
		if (nla_put_in6_addr(skb, RTA_DST, &rt6_dst->addr))
D
David S. Miller 已提交
5480
			goto nla_put_failure;
L
Linus Torvalds 已提交
5481 5482
#ifdef CONFIG_IPV6_SUBTREES
	if (src) {
5483
		if (nla_put_in6_addr(skb, RTA_SRC, src))
D
David S. Miller 已提交
5484
			goto nla_put_failure;
5485
		rtm->rtm_src_len = 128;
D
David S. Miller 已提交
5486
	} else if (rtm->rtm_src_len &&
5487
		   nla_put_in6_addr(skb, RTA_SRC, &rt6_src->addr))
D
David S. Miller 已提交
5488
		goto nla_put_failure;
L
Linus Torvalds 已提交
5489
#endif
5490 5491
	if (iif) {
#ifdef CONFIG_IPV6_MROUTE
5492
		if (ipv6_addr_is_multicast(&rt6_dst->addr)) {
5493 5494 5495 5496 5497 5498
			int err = ip6mr_get_route(net, skb, rtm, portid);

			if (err == 0)
				return 0;
			if (err < 0)
				goto nla_put_failure;
5499 5500
		} else
#endif
D
David S. Miller 已提交
5501 5502
			if (nla_put_u32(skb, RTA_IIF, iif))
				goto nla_put_failure;
5503
	} else if (dest) {
L
Linus Torvalds 已提交
5504
		struct in6_addr saddr_buf;
5505
		if (ip6_route_get_saddr(net, rt, dest, 0, &saddr_buf) == 0 &&
5506
		    nla_put_in6_addr(skb, RTA_PREFSRC, &saddr_buf))
D
David S. Miller 已提交
5507
			goto nla_put_failure;
L
Linus Torvalds 已提交
5508
	}
5509

5510
	if (rt->fib6_prefsrc.plen) {
5511
		struct in6_addr saddr_buf;
5512
		saddr_buf = rt->fib6_prefsrc.addr;
5513
		if (nla_put_in6_addr(skb, RTA_PREFSRC, &saddr_buf))
D
David S. Miller 已提交
5514
			goto nla_put_failure;
5515 5516
	}

5517 5518
	pmetrics = dst ? dst_metrics_ptr(dst) : rt->fib6_metrics->metrics;
	if (rtnetlink_put_metrics(skb, pmetrics) < 0)
5519 5520
		goto nla_put_failure;

5521
	if (nla_put_u32(skb, RTA_PRIORITY, rt->fib6_metric))
D
David S. Miller 已提交
5522
		goto nla_put_failure;
5523

5524 5525 5526
	/* For multipath routes, walk the siblings list and add
	 * each as a nexthop within RTA_MULTIPATH.
	 */
5527 5528 5529 5530 5531 5532 5533 5534
	if (rt6) {
		if (rt6_flags & RTF_GATEWAY &&
		    nla_put_in6_addr(skb, RTA_GATEWAY, &rt6->rt6i_gateway))
			goto nla_put_failure;

		if (dst->dev && nla_put_u32(skb, RTA_OIF, dst->dev->ifindex))
			goto nla_put_failure;
	} else if (rt->fib6_nsiblings) {
5535
		struct fib6_info *sibling, *next_sibling;
5536 5537
		struct nlattr *mp;

5538
		mp = nla_nest_start_noflag(skb, RTA_MULTIPATH);
5539 5540 5541
		if (!mp)
			goto nla_put_failure;

5542
		if (fib_add_nexthop(skb, &rt->fib6_nh->nh_common,
5543
				    rt->fib6_nh->fib_nh_weight, AF_INET6) < 0)
5544 5545 5546
			goto nla_put_failure;

		list_for_each_entry_safe(sibling, next_sibling,
5547
					 &rt->fib6_siblings, fib6_siblings) {
5548
			if (fib_add_nexthop(skb, &sibling->fib6_nh->nh_common,
5549 5550
					    sibling->fib6_nh->fib_nh_weight,
					    AF_INET6) < 0)
5551 5552 5553 5554
				goto nla_put_failure;
		}

		nla_nest_end(skb, mp);
5555 5556 5557
	} else if (rt->nh) {
		if (nla_put_u32(skb, RTA_NH_ID, rt->nh->id))
			goto nla_put_failure;
5558

5559 5560 5561 5562 5563 5564 5565 5566
		if (nexthop_is_blackhole(rt->nh))
			rtm->rtm_type = RTN_BLACKHOLE;

		if (rt6_fill_node_nexthop(skb, rt->nh, &nh_flags) < 0)
			goto nla_put_failure;

		rtm->rtm_flags |= nh_flags;
	} else {
5567
		if (fib_nexthop_info(skb, &rt->fib6_nh->nh_common, AF_INET6,
5568
				     &nh_flags, false) < 0)
5569
			goto nla_put_failure;
5570 5571

		rtm->rtm_flags |= nh_flags;
5572 5573
	}

5574
	if (rt6_flags & RTF_EXPIRES) {
5575 5576 5577
		expires = dst ? dst->expires : rt->expires;
		expires -= jiffies;
	}
5578

5579 5580 5581 5582 5583 5584 5585
	if (!dst) {
		if (rt->offload)
			rtm->rtm_flags |= RTM_F_OFFLOAD;
		if (rt->trap)
			rtm->rtm_flags |= RTM_F_TRAP;
	}

5586
	if (rtnl_put_cacheinfo(skb, dst, 0, expires, dst ? dst->error : 0) < 0)
5587
		goto nla_put_failure;
5588

5589
	if (nla_put_u8(skb, RTA_PREF, IPV6_EXTRACT_PREF(rt6_flags)))
5590 5591
		goto nla_put_failure;

5592

5593 5594
	nlmsg_end(skb, nlh);
	return 0;
5595 5596

nla_put_failure:
5597 5598
	nlmsg_cancel(skb, nlh);
	return -EMSGSIZE;
L
Linus Torvalds 已提交
5599 5600
}

5601 5602 5603 5604 5605 5606 5607 5608 5609 5610
static int fib6_info_nh_uses_dev(struct fib6_nh *nh, void *arg)
{
	const struct net_device *dev = arg;

	if (nh->fib_nh_dev == dev)
		return 1;

	return 0;
}

5611 5612 5613
static bool fib6_info_uses_dev(const struct fib6_info *f6i,
			       const struct net_device *dev)
{
5614 5615 5616 5617 5618 5619 5620 5621
	if (f6i->nh) {
		struct net_device *_dev = (struct net_device *)dev;

		return !!nexthop_for_each_fib6_nh(f6i->nh,
						  fib6_info_nh_uses_dev,
						  _dev);
	}

5622
	if (f6i->fib6_nh->fib_nh_dev == dev)
5623 5624 5625 5626 5627 5628 5629
		return true;

	if (f6i->fib6_nsiblings) {
		struct fib6_info *sibling, *next_sibling;

		list_for_each_entry_safe(sibling, next_sibling,
					 &f6i->fib6_siblings, fib6_siblings) {
5630
			if (sibling->fib6_nh->fib_nh_dev == dev)
5631 5632 5633 5634 5635 5636 5637
				return true;
		}
	}

	return false;
}

5638 5639 5640 5641 5642 5643 5644 5645 5646 5647 5648 5649 5650 5651 5652 5653 5654 5655 5656 5657 5658 5659 5660 5661 5662 5663 5664 5665 5666 5667 5668 5669 5670 5671 5672 5673 5674 5675 5676 5677 5678 5679 5680 5681 5682 5683 5684 5685 5686 5687 5688 5689 5690 5691 5692 5693 5694 5695 5696
struct fib6_nh_exception_dump_walker {
	struct rt6_rtnl_dump_arg *dump;
	struct fib6_info *rt;
	unsigned int flags;
	unsigned int skip;
	unsigned int count;
};

static int rt6_nh_dump_exceptions(struct fib6_nh *nh, void *arg)
{
	struct fib6_nh_exception_dump_walker *w = arg;
	struct rt6_rtnl_dump_arg *dump = w->dump;
	struct rt6_exception_bucket *bucket;
	struct rt6_exception *rt6_ex;
	int i, err;

	bucket = fib6_nh_get_excptn_bucket(nh, NULL);
	if (!bucket)
		return 0;

	for (i = 0; i < FIB6_EXCEPTION_BUCKET_SIZE; i++) {
		hlist_for_each_entry(rt6_ex, &bucket->chain, hlist) {
			if (w->skip) {
				w->skip--;
				continue;
			}

			/* Expiration of entries doesn't bump sernum, insertion
			 * does. Removal is triggered by insertion, so we can
			 * rely on the fact that if entries change between two
			 * partial dumps, this node is scanned again completely,
			 * see rt6_insert_exception() and fib6_dump_table().
			 *
			 * Count expired entries we go through as handled
			 * entries that we'll skip next time, in case of partial
			 * node dump. Otherwise, if entries expire meanwhile,
			 * we'll skip the wrong amount.
			 */
			if (rt6_check_expired(rt6_ex->rt6i)) {
				w->count++;
				continue;
			}

			err = rt6_fill_node(dump->net, dump->skb, w->rt,
					    &rt6_ex->rt6i->dst, NULL, NULL, 0,
					    RTM_NEWROUTE,
					    NETLINK_CB(dump->cb->skb).portid,
					    dump->cb->nlh->nlmsg_seq, w->flags);
			if (err)
				return err;

			w->count++;
		}
		bucket++;
	}

	return 0;
}

5697
/* Return -1 if done with node, number of handled routes on partial dump */
5698
int rt6_dump_route(struct fib6_info *rt, void *p_arg, unsigned int skip)
L
Linus Torvalds 已提交
5699 5700
{
	struct rt6_rtnl_dump_arg *arg = (struct rt6_rtnl_dump_arg *) p_arg;
5701 5702
	struct fib_dump_filter *filter = &arg->filter;
	unsigned int flags = NLM_F_MULTI;
5703
	struct net *net = arg->net;
5704
	int count = 0;
5705

D
David Ahern 已提交
5706
	if (rt == net->ipv6.fib6_null_entry)
5707
		return -1;
L
Linus Torvalds 已提交
5708

5709 5710 5711
	if ((filter->flags & RTM_F_PREFIX) &&
	    !(rt->fib6_flags & RTF_PREFIX_RT)) {
		/* success since this is not a prefix route */
5712
		return -1;
5713
	}
5714 5715 5716 5717 5718 5719 5720 5721 5722
	if (filter->filter_set &&
	    ((filter->rt_type  && rt->fib6_type != filter->rt_type) ||
	     (filter->dev      && !fib6_info_uses_dev(rt, filter->dev)) ||
	     (filter->protocol && rt->fib6_protocol != filter->protocol))) {
		return -1;
	}

	if (filter->filter_set ||
	    !filter->dump_routes || !filter->dump_exceptions) {
5723
		flags |= NLM_F_DUMP_FILTERED;
5724
	}
L
Linus Torvalds 已提交
5725

5726 5727 5728 5729 5730 5731 5732 5733 5734 5735 5736 5737 5738 5739 5740 5741 5742 5743 5744 5745 5746 5747
	if (filter->dump_routes) {
		if (skip) {
			skip--;
		} else {
			if (rt6_fill_node(net, arg->skb, rt, NULL, NULL, NULL,
					  0, RTM_NEWROUTE,
					  NETLINK_CB(arg->cb->skb).portid,
					  arg->cb->nlh->nlmsg_seq, flags)) {
				return 0;
			}
			count++;
		}
	}

	if (filter->dump_exceptions) {
		struct fib6_nh_exception_dump_walker w = { .dump = arg,
							   .rt = rt,
							   .flags = flags,
							   .skip = skip,
							   .count = 0 };
		int err;

5748
		rcu_read_lock();
5749 5750 5751 5752 5753 5754 5755
		if (rt->nh) {
			err = nexthop_for_each_fib6_nh(rt->nh,
						       rt6_nh_dump_exceptions,
						       &w);
		} else {
			err = rt6_nh_dump_exceptions(rt->fib6_nh, &w);
		}
5756
		rcu_read_unlock();
5757 5758 5759 5760

		if (err)
			return count += w.count;
	}
5761 5762

	return -1;
L
Linus Torvalds 已提交
5763 5764
}

5765 5766 5767 5768 5769 5770 5771 5772 5773 5774 5775 5776 5777 5778 5779
static int inet6_rtm_valid_getroute_req(struct sk_buff *skb,
					const struct nlmsghdr *nlh,
					struct nlattr **tb,
					struct netlink_ext_ack *extack)
{
	struct rtmsg *rtm;
	int i, err;

	if (nlh->nlmsg_len < nlmsg_msg_size(sizeof(*rtm))) {
		NL_SET_ERR_MSG_MOD(extack,
				   "Invalid header for get route request");
		return -EINVAL;
	}

	if (!netlink_strict_get_check(skb))
5780 5781
		return nlmsg_parse_deprecated(nlh, sizeof(*rtm), tb, RTA_MAX,
					      rtm_ipv6_policy, extack);
5782 5783 5784 5785 5786 5787 5788 5789 5790 5791 5792 5793 5794 5795 5796

	rtm = nlmsg_data(nlh);
	if ((rtm->rtm_src_len && rtm->rtm_src_len != 128) ||
	    (rtm->rtm_dst_len && rtm->rtm_dst_len != 128) ||
	    rtm->rtm_table || rtm->rtm_protocol || rtm->rtm_scope ||
	    rtm->rtm_type) {
		NL_SET_ERR_MSG_MOD(extack, "Invalid values in header for get route request");
		return -EINVAL;
	}
	if (rtm->rtm_flags & ~RTM_F_FIB_MATCH) {
		NL_SET_ERR_MSG_MOD(extack,
				   "Invalid flags for get route request");
		return -EINVAL;
	}

5797 5798
	err = nlmsg_parse_deprecated_strict(nlh, sizeof(*rtm), tb, RTA_MAX,
					    rtm_ipv6_policy, extack);
5799 5800 5801 5802 5803 5804 5805 5806 5807 5808 5809 5810 5811 5812 5813 5814 5815 5816 5817 5818 5819 5820 5821 5822 5823 5824 5825 5826 5827 5828 5829 5830 5831
	if (err)
		return err;

	if ((tb[RTA_SRC] && !rtm->rtm_src_len) ||
	    (tb[RTA_DST] && !rtm->rtm_dst_len)) {
		NL_SET_ERR_MSG_MOD(extack, "rtm_src_len and rtm_dst_len must be 128 for IPv6");
		return -EINVAL;
	}

	for (i = 0; i <= RTA_MAX; i++) {
		if (!tb[i])
			continue;

		switch (i) {
		case RTA_SRC:
		case RTA_DST:
		case RTA_IIF:
		case RTA_OIF:
		case RTA_MARK:
		case RTA_UID:
		case RTA_SPORT:
		case RTA_DPORT:
		case RTA_IP_PROTO:
			break;
		default:
			NL_SET_ERR_MSG_MOD(extack, "Unsupported attribute in get route request");
			return -EINVAL;
		}
	}

	return 0;
}

5832 5833
static int inet6_rtm_getroute(struct sk_buff *in_skb, struct nlmsghdr *nlh,
			      struct netlink_ext_ack *extack)
L
Linus Torvalds 已提交
5834
{
5835
	struct net *net = sock_net(in_skb->sk);
5836
	struct nlattr *tb[RTA_MAX+1];
5837
	int err, iif = 0, oif = 0;
5838
	struct fib6_info *from;
5839
	struct dst_entry *dst;
5840
	struct rt6_info *rt;
L
Linus Torvalds 已提交
5841
	struct sk_buff *skb;
5842
	struct rtmsg *rtm;
5843
	struct flowi6 fl6 = {};
5844
	bool fibmatch;
L
Linus Torvalds 已提交
5845

5846
	err = inet6_rtm_valid_getroute_req(in_skb, nlh, tb, extack);
5847 5848
	if (err < 0)
		goto errout;
L
Linus Torvalds 已提交
5849

5850
	err = -EINVAL;
5851 5852
	rtm = nlmsg_data(nlh);
	fl6.flowlabel = ip6_make_flowinfo(rtm->rtm_tos, 0);
5853
	fibmatch = !!(rtm->rtm_flags & RTM_F_FIB_MATCH);
L
Linus Torvalds 已提交
5854

5855 5856 5857 5858
	if (tb[RTA_SRC]) {
		if (nla_len(tb[RTA_SRC]) < sizeof(struct in6_addr))
			goto errout;

A
Alexey Dobriyan 已提交
5859
		fl6.saddr = *(struct in6_addr *)nla_data(tb[RTA_SRC]);
5860 5861 5862 5863 5864 5865
	}

	if (tb[RTA_DST]) {
		if (nla_len(tb[RTA_DST]) < sizeof(struct in6_addr))
			goto errout;

A
Alexey Dobriyan 已提交
5866
		fl6.daddr = *(struct in6_addr *)nla_data(tb[RTA_DST]);
5867 5868 5869 5870 5871 5872
	}

	if (tb[RTA_IIF])
		iif = nla_get_u32(tb[RTA_IIF]);

	if (tb[RTA_OIF])
5873
		oif = nla_get_u32(tb[RTA_OIF]);
L
Linus Torvalds 已提交
5874

5875 5876 5877
	if (tb[RTA_MARK])
		fl6.flowi6_mark = nla_get_u32(tb[RTA_MARK]);

5878 5879 5880 5881 5882 5883
	if (tb[RTA_UID])
		fl6.flowi6_uid = make_kuid(current_user_ns(),
					   nla_get_u32(tb[RTA_UID]));
	else
		fl6.flowi6_uid = iif ? INVALID_UID : current_uid();

5884 5885 5886 5887 5888 5889 5890 5891
	if (tb[RTA_SPORT])
		fl6.fl6_sport = nla_get_be16(tb[RTA_SPORT]);

	if (tb[RTA_DPORT])
		fl6.fl6_dport = nla_get_be16(tb[RTA_DPORT]);

	if (tb[RTA_IP_PROTO]) {
		err = rtm_getroute_parse_ip_proto(tb[RTA_IP_PROTO],
5892 5893
						  &fl6.flowi6_proto, AF_INET6,
						  extack);
5894 5895 5896 5897
		if (err)
			goto errout;
	}

L
Linus Torvalds 已提交
5898 5899
	if (iif) {
		struct net_device *dev;
5900 5901
		int flags = 0;

5902 5903 5904
		rcu_read_lock();

		dev = dev_get_by_index_rcu(net, iif);
L
Linus Torvalds 已提交
5905
		if (!dev) {
5906
			rcu_read_unlock();
L
Linus Torvalds 已提交
5907
			err = -ENODEV;
5908
			goto errout;
L
Linus Torvalds 已提交
5909
		}
5910 5911 5912 5913 5914 5915

		fl6.flowi6_iif = iif;

		if (!ipv6_addr_any(&fl6.saddr))
			flags |= RT6_LOOKUP_F_HAS_SADDR;

D
David Ahern 已提交
5916
		dst = ip6_route_input_lookup(net, dev, &fl6, NULL, flags);
5917 5918

		rcu_read_unlock();
5919 5920 5921
	} else {
		fl6.flowi6_oif = oif;

5922
		dst = ip6_route_output(net, NULL, &fl6);
5923 5924 5925 5926 5927 5928 5929 5930
	}


	rt = container_of(dst, struct rt6_info, dst);
	if (rt->dst.error) {
		err = rt->dst.error;
		ip6_rt_put(rt);
		goto errout;
L
Linus Torvalds 已提交
5931 5932
	}

5933 5934 5935 5936 5937 5938
	if (rt == net->ipv6.ip6_null_entry) {
		err = rt->dst.error;
		ip6_rt_put(rt);
		goto errout;
	}

5939
	skb = alloc_skb(NLMSG_GOODSIZE, GFP_KERNEL);
5940
	if (!skb) {
A
Amerigo Wang 已提交
5941
		ip6_rt_put(rt);
5942 5943 5944
		err = -ENOBUFS;
		goto errout;
	}
L
Linus Torvalds 已提交
5945

5946
	skb_dst_set(skb, &rt->dst);
5947 5948 5949

	rcu_read_lock();
	from = rcu_dereference(rt->from);
5950 5951 5952 5953 5954 5955 5956 5957 5958 5959 5960 5961 5962 5963
	if (from) {
		if (fibmatch)
			err = rt6_fill_node(net, skb, from, NULL, NULL, NULL,
					    iif, RTM_NEWROUTE,
					    NETLINK_CB(in_skb).portid,
					    nlh->nlmsg_seq, 0);
		else
			err = rt6_fill_node(net, skb, from, dst, &fl6.daddr,
					    &fl6.saddr, iif, RTM_NEWROUTE,
					    NETLINK_CB(in_skb).portid,
					    nlh->nlmsg_seq, 0);
	} else {
		err = -ENETUNREACH;
	}
5964 5965
	rcu_read_unlock();

L
Linus Torvalds 已提交
5966
	if (err < 0) {
5967 5968
		kfree_skb(skb);
		goto errout;
L
Linus Torvalds 已提交
5969 5970
	}

5971
	err = rtnl_unicast(skb, net, NETLINK_CB(in_skb).portid);
5972
errout:
L
Linus Torvalds 已提交
5973 5974 5975
	return err;
}

5976
void inet6_rt_notify(int event, struct fib6_info *rt, struct nl_info *info,
5977
		     unsigned int nlm_flags)
L
Linus Torvalds 已提交
5978 5979
{
	struct sk_buff *skb;
5980
	struct net *net = info->nl_net;
5981 5982 5983 5984
	u32 seq;
	int err;

	err = -ENOBUFS;
5985
	seq = info->nlh ? info->nlh->nlmsg_seq : 0;
5986

5987
	skb = nlmsg_new(rt6_nlmsg_size(rt), gfp_any());
5988
	if (!skb)
5989 5990
		goto errout;

5991 5992
	err = rt6_fill_node(net, skb, rt, NULL, NULL, NULL, 0,
			    event, info->portid, seq, nlm_flags);
5993 5994 5995 5996 5997 5998
	if (err < 0) {
		/* -EMSGSIZE implies BUG in rt6_nlmsg_size() */
		WARN_ON(err == -EMSGSIZE);
		kfree_skb(skb);
		goto errout;
	}
5999
	rtnl_notify(skb, net, info->portid, RTNLGRP_IPV6_ROUTE,
6000 6001
		    info->nlh, gfp_any());
	return;
6002 6003
errout:
	if (err < 0)
6004
		rtnl_set_sk_err(net, RTNLGRP_IPV6_ROUTE, err);
L
Linus Torvalds 已提交
6005 6006
}

6007 6008 6009 6010 6011 6012 6013 6014 6015 6016 6017 6018 6019 6020 6021 6022 6023 6024 6025 6026 6027 6028 6029 6030 6031 6032 6033 6034 6035 6036 6037 6038
void fib6_rt_update(struct net *net, struct fib6_info *rt,
		    struct nl_info *info)
{
	u32 seq = info->nlh ? info->nlh->nlmsg_seq : 0;
	struct sk_buff *skb;
	int err = -ENOBUFS;

	/* call_fib6_entry_notifiers will be removed when in-kernel notifier
	 * is implemented and supported for nexthop objects
	 */
	call_fib6_entry_notifiers(net, FIB_EVENT_ENTRY_REPLACE, rt, NULL);

	skb = nlmsg_new(rt6_nlmsg_size(rt), gfp_any());
	if (!skb)
		goto errout;

	err = rt6_fill_node(net, skb, rt, NULL, NULL, NULL, 0,
			    RTM_NEWROUTE, info->portid, seq, NLM_F_REPLACE);
	if (err < 0) {
		/* -EMSGSIZE implies BUG in rt6_nlmsg_size() */
		WARN_ON(err == -EMSGSIZE);
		kfree_skb(skb);
		goto errout;
	}
	rtnl_notify(skb, net, info->portid, RTNLGRP_IPV6_ROUTE,
		    info->nlh, gfp_any());
	return;
errout:
	if (err < 0)
		rtnl_set_sk_err(net, RTNLGRP_IPV6_ROUTE, err);
}

6039
static int ip6_route_dev_notify(struct notifier_block *this,
6040
				unsigned long event, void *ptr)
6041
{
6042
	struct net_device *dev = netdev_notifier_info_to_dev(ptr);
6043
	struct net *net = dev_net(dev);
6044

6045 6046 6047 6048
	if (!(dev->flags & IFF_LOOPBACK))
		return NOTIFY_OK;

	if (event == NETDEV_REGISTER) {
6049
		net->ipv6.fib6_null_entry->fib6_nh->fib_nh_dev = dev;
6050
		net->ipv6.ip6_null_entry->dst.dev = dev;
6051 6052
		net->ipv6.ip6_null_entry->rt6i_idev = in6_dev_get(dev);
#ifdef CONFIG_IPV6_MULTIPLE_TABLES
6053
		net->ipv6.ip6_prohibit_entry->dst.dev = dev;
6054
		net->ipv6.ip6_prohibit_entry->rt6i_idev = in6_dev_get(dev);
6055
		net->ipv6.ip6_blk_hole_entry->dst.dev = dev;
6056
		net->ipv6.ip6_blk_hole_entry->rt6i_idev = in6_dev_get(dev);
6057
#endif
6058 6059 6060 6061 6062
	 } else if (event == NETDEV_UNREGISTER &&
		    dev->reg_state != NETREG_UNREGISTERED) {
		/* NETDEV_UNREGISTER could be fired for multiple times by
		 * netdev_wait_allrefs(). Make sure we only call this once.
		 */
6063
		in6_dev_put_clear(&net->ipv6.ip6_null_entry->rt6i_idev);
6064
#ifdef CONFIG_IPV6_MULTIPLE_TABLES
6065 6066
		in6_dev_put_clear(&net->ipv6.ip6_prohibit_entry->rt6i_idev);
		in6_dev_put_clear(&net->ipv6.ip6_blk_hole_entry->rt6i_idev);
6067 6068 6069 6070 6071 6072
#endif
	}

	return NOTIFY_OK;
}

L
Linus Torvalds 已提交
6073 6074 6075 6076 6077 6078 6079
/*
 *	/proc
 */

#ifdef CONFIG_PROC_FS
static int rt6_stats_seq_show(struct seq_file *seq, void *v)
{
6080
	struct net *net = (struct net *)seq->private;
L
Linus Torvalds 已提交
6081
	seq_printf(seq, "%04x %04x %04x %04x %04x %04x %04x\n",
6082 6083
		   net->ipv6.rt6_stats->fib_nodes,
		   net->ipv6.rt6_stats->fib_route_nodes,
W
Wei Wang 已提交
6084
		   atomic_read(&net->ipv6.rt6_stats->fib_rt_alloc),
6085 6086
		   net->ipv6.rt6_stats->fib_rt_entries,
		   net->ipv6.rt6_stats->fib_rt_cache,
6087
		   dst_entries_get_slow(&net->ipv6.ip6_dst_ops),
6088
		   net->ipv6.rt6_stats->fib_discarded_routes);
L
Linus Torvalds 已提交
6089 6090 6091 6092 6093 6094 6095 6096

	return 0;
}
#endif	/* CONFIG_PROC_FS */

#ifdef CONFIG_SYSCTL

static
6097
int ipv6_sysctl_rtcache_flush(struct ctl_table *ctl, int write,
L
Linus Torvalds 已提交
6098 6099
			      void __user *buffer, size_t *lenp, loff_t *ppos)
{
6100 6101
	struct net *net;
	int delay;
6102
	int ret;
6103
	if (!write)
L
Linus Torvalds 已提交
6104
		return -EINVAL;
6105 6106 6107

	net = (struct net *)ctl->extra1;
	delay = net->ipv6.sysctl.flush_delay;
6108 6109 6110 6111
	ret = proc_dointvec(ctl, write, buffer, lenp, ppos);
	if (ret)
		return ret;

6112
	fib6_run_gc(delay <= 0 ? 0 : (unsigned long)delay, net, delay > 0);
6113
	return 0;
L
Linus Torvalds 已提交
6114 6115
}

6116
static struct ctl_table ipv6_route_table_template[] = {
6117
	{
L
Linus Torvalds 已提交
6118
		.procname	=	"flush",
6119
		.data		=	&init_net.ipv6.sysctl.flush_delay,
L
Linus Torvalds 已提交
6120
		.maxlen		=	sizeof(int),
6121
		.mode		=	0200,
A
Alexey Dobriyan 已提交
6122
		.proc_handler	=	ipv6_sysctl_rtcache_flush
L
Linus Torvalds 已提交
6123 6124 6125
	},
	{
		.procname	=	"gc_thresh",
6126
		.data		=	&ip6_dst_ops_template.gc_thresh,
L
Linus Torvalds 已提交
6127 6128
		.maxlen		=	sizeof(int),
		.mode		=	0644,
A
Alexey Dobriyan 已提交
6129
		.proc_handler	=	proc_dointvec,
L
Linus Torvalds 已提交
6130 6131 6132
	},
	{
		.procname	=	"max_size",
6133
		.data		=	&init_net.ipv6.sysctl.ip6_rt_max_size,
L
Linus Torvalds 已提交
6134 6135
		.maxlen		=	sizeof(int),
		.mode		=	0644,
A
Alexey Dobriyan 已提交
6136
		.proc_handler	=	proc_dointvec,
L
Linus Torvalds 已提交
6137 6138 6139
	},
	{
		.procname	=	"gc_min_interval",
6140
		.data		=	&init_net.ipv6.sysctl.ip6_rt_gc_min_interval,
L
Linus Torvalds 已提交
6141 6142
		.maxlen		=	sizeof(int),
		.mode		=	0644,
A
Alexey Dobriyan 已提交
6143
		.proc_handler	=	proc_dointvec_jiffies,
L
Linus Torvalds 已提交
6144 6145 6146
	},
	{
		.procname	=	"gc_timeout",
6147
		.data		=	&init_net.ipv6.sysctl.ip6_rt_gc_timeout,
L
Linus Torvalds 已提交
6148 6149
		.maxlen		=	sizeof(int),
		.mode		=	0644,
A
Alexey Dobriyan 已提交
6150
		.proc_handler	=	proc_dointvec_jiffies,
L
Linus Torvalds 已提交
6151 6152 6153
	},
	{
		.procname	=	"gc_interval",
6154
		.data		=	&init_net.ipv6.sysctl.ip6_rt_gc_interval,
L
Linus Torvalds 已提交
6155 6156
		.maxlen		=	sizeof(int),
		.mode		=	0644,
A
Alexey Dobriyan 已提交
6157
		.proc_handler	=	proc_dointvec_jiffies,
L
Linus Torvalds 已提交
6158 6159 6160
	},
	{
		.procname	=	"gc_elasticity",
6161
		.data		=	&init_net.ipv6.sysctl.ip6_rt_gc_elasticity,
L
Linus Torvalds 已提交
6162 6163
		.maxlen		=	sizeof(int),
		.mode		=	0644,
6164
		.proc_handler	=	proc_dointvec,
L
Linus Torvalds 已提交
6165 6166 6167
	},
	{
		.procname	=	"mtu_expires",
6168
		.data		=	&init_net.ipv6.sysctl.ip6_rt_mtu_expires,
L
Linus Torvalds 已提交
6169 6170
		.maxlen		=	sizeof(int),
		.mode		=	0644,
A
Alexey Dobriyan 已提交
6171
		.proc_handler	=	proc_dointvec_jiffies,
L
Linus Torvalds 已提交
6172 6173 6174
	},
	{
		.procname	=	"min_adv_mss",
6175
		.data		=	&init_net.ipv6.sysctl.ip6_rt_min_advmss,
L
Linus Torvalds 已提交
6176 6177
		.maxlen		=	sizeof(int),
		.mode		=	0644,
6178
		.proc_handler	=	proc_dointvec,
L
Linus Torvalds 已提交
6179 6180 6181
	},
	{
		.procname	=	"gc_min_interval_ms",
6182
		.data		=	&init_net.ipv6.sysctl.ip6_rt_gc_min_interval,
L
Linus Torvalds 已提交
6183 6184
		.maxlen		=	sizeof(int),
		.mode		=	0644,
A
Alexey Dobriyan 已提交
6185
		.proc_handler	=	proc_dointvec_ms_jiffies,
L
Linus Torvalds 已提交
6186
	},
6187 6188 6189 6190 6191
	{
		.procname	=	"skip_notify_on_dev_down",
		.data		=	&init_net.ipv6.sysctl.skip_notify_on_dev_down,
		.maxlen		=	sizeof(int),
		.mode		=	0644,
6192
		.proc_handler	=	proc_dointvec_minmax,
6193 6194
		.extra1		=	SYSCTL_ZERO,
		.extra2		=	SYSCTL_ONE,
6195
	},
6196
	{ }
L
Linus Torvalds 已提交
6197 6198
};

6199
struct ctl_table * __net_init ipv6_route_sysctl_init(struct net *net)
6200 6201 6202 6203 6204 6205
{
	struct ctl_table *table;

	table = kmemdup(ipv6_route_table_template,
			sizeof(ipv6_route_table_template),
			GFP_KERNEL);
6206 6207 6208

	if (table) {
		table[0].data = &net->ipv6.sysctl.flush_delay;
6209
		table[0].extra1 = net;
6210
		table[1].data = &net->ipv6.ip6_dst_ops.gc_thresh;
6211 6212 6213 6214 6215 6216 6217
		table[2].data = &net->ipv6.sysctl.ip6_rt_max_size;
		table[3].data = &net->ipv6.sysctl.ip6_rt_gc_min_interval;
		table[4].data = &net->ipv6.sysctl.ip6_rt_gc_timeout;
		table[5].data = &net->ipv6.sysctl.ip6_rt_gc_interval;
		table[6].data = &net->ipv6.sysctl.ip6_rt_gc_elasticity;
		table[7].data = &net->ipv6.sysctl.ip6_rt_mtu_expires;
		table[8].data = &net->ipv6.sysctl.ip6_rt_min_advmss;
6218
		table[9].data = &net->ipv6.sysctl.ip6_rt_gc_min_interval;
6219
		table[10].data = &net->ipv6.sysctl.skip_notify_on_dev_down;
6220 6221 6222 6223

		/* Don't export sysctls to unprivileged users */
		if (net->user_ns != &init_user_ns)
			table[0].procname = NULL;
6224 6225
	}

6226 6227
	return table;
}
L
Linus Torvalds 已提交
6228 6229
#endif

6230
static int __net_init ip6_route_net_init(struct net *net)
6231
{
6232
	int ret = -ENOMEM;
6233

6234 6235
	memcpy(&net->ipv6.ip6_dst_ops, &ip6_dst_ops_template,
	       sizeof(net->ipv6.ip6_dst_ops));
6236

6237 6238 6239
	if (dst_entries_init(&net->ipv6.ip6_dst_ops) < 0)
		goto out_ip6_dst_ops;

6240
	net->ipv6.fib6_null_entry = fib6_info_alloc(GFP_KERNEL, true);
D
David Ahern 已提交
6241 6242
	if (!net->ipv6.fib6_null_entry)
		goto out_ip6_dst_entries;
6243 6244
	memcpy(net->ipv6.fib6_null_entry, &fib6_null_entry_template,
	       sizeof(*net->ipv6.fib6_null_entry));
D
David Ahern 已提交
6245

6246 6247 6248 6249
	net->ipv6.ip6_null_entry = kmemdup(&ip6_null_entry_template,
					   sizeof(*net->ipv6.ip6_null_entry),
					   GFP_KERNEL);
	if (!net->ipv6.ip6_null_entry)
D
David Ahern 已提交
6250
		goto out_fib6_null_entry;
6251
	net->ipv6.ip6_null_entry->dst.ops = &net->ipv6.ip6_dst_ops;
6252 6253
	dst_init_metrics(&net->ipv6.ip6_null_entry->dst,
			 ip6_template_metrics, true);
6254
	INIT_LIST_HEAD(&net->ipv6.ip6_null_entry->rt6i_uncached);
6255 6256

#ifdef CONFIG_IPV6_MULTIPLE_TABLES
6257
	net->ipv6.fib6_has_custom_rules = false;
6258 6259 6260
	net->ipv6.ip6_prohibit_entry = kmemdup(&ip6_prohibit_entry_template,
					       sizeof(*net->ipv6.ip6_prohibit_entry),
					       GFP_KERNEL);
6261 6262
	if (!net->ipv6.ip6_prohibit_entry)
		goto out_ip6_null_entry;
6263
	net->ipv6.ip6_prohibit_entry->dst.ops = &net->ipv6.ip6_dst_ops;
6264 6265
	dst_init_metrics(&net->ipv6.ip6_prohibit_entry->dst,
			 ip6_template_metrics, true);
6266
	INIT_LIST_HEAD(&net->ipv6.ip6_prohibit_entry->rt6i_uncached);
6267 6268 6269 6270

	net->ipv6.ip6_blk_hole_entry = kmemdup(&ip6_blk_hole_entry_template,
					       sizeof(*net->ipv6.ip6_blk_hole_entry),
					       GFP_KERNEL);
6271 6272
	if (!net->ipv6.ip6_blk_hole_entry)
		goto out_ip6_prohibit_entry;
6273
	net->ipv6.ip6_blk_hole_entry->dst.ops = &net->ipv6.ip6_dst_ops;
6274 6275
	dst_init_metrics(&net->ipv6.ip6_blk_hole_entry->dst,
			 ip6_template_metrics, true);
6276
	INIT_LIST_HEAD(&net->ipv6.ip6_blk_hole_entry->rt6i_uncached);
P
Paolo Abeni 已提交
6277 6278 6279
#ifdef CONFIG_IPV6_SUBTREES
	net->ipv6.fib6_routes_require_src = 0;
#endif
6280 6281
#endif

6282 6283 6284 6285 6286 6287 6288 6289
	net->ipv6.sysctl.flush_delay = 0;
	net->ipv6.sysctl.ip6_rt_max_size = 4096;
	net->ipv6.sysctl.ip6_rt_gc_min_interval = HZ / 2;
	net->ipv6.sysctl.ip6_rt_gc_timeout = 60*HZ;
	net->ipv6.sysctl.ip6_rt_gc_interval = 30*HZ;
	net->ipv6.sysctl.ip6_rt_gc_elasticity = 9;
	net->ipv6.sysctl.ip6_rt_mtu_expires = 10*60*HZ;
	net->ipv6.sysctl.ip6_rt_min_advmss = IPV6_MIN_MTU - 20 - 40;
6290
	net->ipv6.sysctl.skip_notify_on_dev_down = 0;
6291

6292 6293
	net->ipv6.ip6_rt_gc_expire = 30*HZ;

6294 6295 6296
	ret = 0;
out:
	return ret;
6297

6298 6299 6300 6301 6302 6303
#ifdef CONFIG_IPV6_MULTIPLE_TABLES
out_ip6_prohibit_entry:
	kfree(net->ipv6.ip6_prohibit_entry);
out_ip6_null_entry:
	kfree(net->ipv6.ip6_null_entry);
#endif
D
David Ahern 已提交
6304 6305
out_fib6_null_entry:
	kfree(net->ipv6.fib6_null_entry);
6306 6307
out_ip6_dst_entries:
	dst_entries_destroy(&net->ipv6.ip6_dst_ops);
6308 6309
out_ip6_dst_ops:
	goto out;
6310 6311
}

6312
static void __net_exit ip6_route_net_exit(struct net *net)
6313
{
D
David Ahern 已提交
6314
	kfree(net->ipv6.fib6_null_entry);
6315 6316 6317 6318 6319
	kfree(net->ipv6.ip6_null_entry);
#ifdef CONFIG_IPV6_MULTIPLE_TABLES
	kfree(net->ipv6.ip6_prohibit_entry);
	kfree(net->ipv6.ip6_blk_hole_entry);
#endif
6320
	dst_entries_destroy(&net->ipv6.ip6_dst_ops);
6321 6322
}

6323 6324 6325
static int __net_init ip6_route_net_init_late(struct net *net)
{
#ifdef CONFIG_PROC_FS
6326 6327
	proc_create_net("ipv6_route", 0, net->proc_net, &ipv6_route_seq_ops,
			sizeof(struct ipv6_route_iter));
6328 6329
	proc_create_net_single("rt6_stats", 0444, net->proc_net,
			rt6_stats_seq_show, NULL);
6330 6331 6332 6333 6334 6335 6336
#endif
	return 0;
}

static void __net_exit ip6_route_net_exit_late(struct net *net)
{
#ifdef CONFIG_PROC_FS
6337 6338
	remove_proc_entry("ipv6_route", net->proc_net);
	remove_proc_entry("rt6_stats", net->proc_net);
6339 6340 6341
#endif
}

6342 6343 6344 6345 6346
static struct pernet_operations ip6_route_net_ops = {
	.init = ip6_route_net_init,
	.exit = ip6_route_net_exit,
};

6347 6348 6349 6350 6351 6352 6353 6354 6355 6356 6357 6358 6359 6360 6361 6362
static int __net_init ipv6_inetpeer_init(struct net *net)
{
	struct inet_peer_base *bp = kmalloc(sizeof(*bp), GFP_KERNEL);

	if (!bp)
		return -ENOMEM;
	inet_peer_base_init(bp);
	net->ipv6.peers = bp;
	return 0;
}

static void __net_exit ipv6_inetpeer_exit(struct net *net)
{
	struct inet_peer_base *bp = net->ipv6.peers;

	net->ipv6.peers = NULL;
6363
	inetpeer_invalidate_tree(bp);
6364 6365 6366
	kfree(bp);
}

6367
static struct pernet_operations ipv6_inetpeer_ops = {
6368 6369 6370 6371
	.init	=	ipv6_inetpeer_init,
	.exit	=	ipv6_inetpeer_exit,
};

6372 6373 6374 6375 6376
static struct pernet_operations ip6_route_net_late_ops = {
	.init = ip6_route_net_init_late,
	.exit = ip6_route_net_exit_late,
};

6377 6378
static struct notifier_block ip6_route_dev_notifier = {
	.notifier_call = ip6_route_dev_notify,
6379
	.priority = ADDRCONF_NOTIFY_PRIORITY - 10,
6380 6381
};

6382 6383 6384 6385 6386
void __init ip6_route_init_special_entries(void)
{
	/* Registering of the loopback is done before this portion of code,
	 * the loopback reference in rt6_info will not be taken, do it
	 * manually for init_net */
6387
	init_net.ipv6.fib6_null_entry->fib6_nh->fib_nh_dev = init_net.loopback_dev;
6388 6389 6390 6391 6392 6393 6394 6395 6396 6397
	init_net.ipv6.ip6_null_entry->dst.dev = init_net.loopback_dev;
	init_net.ipv6.ip6_null_entry->rt6i_idev = in6_dev_get(init_net.loopback_dev);
  #ifdef CONFIG_IPV6_MULTIPLE_TABLES
	init_net.ipv6.ip6_prohibit_entry->dst.dev = init_net.loopback_dev;
	init_net.ipv6.ip6_prohibit_entry->rt6i_idev = in6_dev_get(init_net.loopback_dev);
	init_net.ipv6.ip6_blk_hole_entry->dst.dev = init_net.loopback_dev;
	init_net.ipv6.ip6_blk_hole_entry->rt6i_idev = in6_dev_get(init_net.loopback_dev);
  #endif
}

6398
int __init ip6_route_init(void)
L
Linus Torvalds 已提交
6399
{
6400
	int ret;
6401
	int cpu;
6402

6403 6404
	ret = -ENOMEM;
	ip6_dst_ops_template.kmem_cachep =
A
Alexey Dobriyan 已提交
6405
		kmem_cache_create("ip6_dst_cache", sizeof(struct rt6_info), 0,
6406
				  SLAB_HWCACHE_ALIGN, NULL);
6407
	if (!ip6_dst_ops_template.kmem_cachep)
6408
		goto out;
6409

6410
	ret = dst_entries_init(&ip6_dst_blackhole_ops);
6411
	if (ret)
6412 6413
		goto out_kmem_cache;

6414 6415
	ret = register_pernet_subsys(&ipv6_inetpeer_ops);
	if (ret)
6416
		goto out_dst_entries;
6417

6418 6419 6420
	ret = register_pernet_subsys(&ip6_route_net_ops);
	if (ret)
		goto out_register_inetpeer;
6421

6422 6423
	ip6_dst_blackhole_ops.kmem_cachep = ip6_dst_ops_template.kmem_cachep;

6424
	ret = fib6_init();
6425
	if (ret)
6426
		goto out_register_subsys;
6427 6428 6429

	ret = xfrm6_init();
	if (ret)
6430
		goto out_fib6_init;
6431

6432 6433 6434
	ret = fib6_rules_init();
	if (ret)
		goto xfrm6_init;
6435

6436 6437 6438 6439
	ret = register_pernet_subsys(&ip6_route_net_late_ops);
	if (ret)
		goto fib6_rules_init;

6440 6441 6442 6443 6444 6445 6446 6447 6448 6449 6450 6451 6452 6453
	ret = rtnl_register_module(THIS_MODULE, PF_INET6, RTM_NEWROUTE,
				   inet6_rtm_newroute, NULL, 0);
	if (ret < 0)
		goto out_register_late_subsys;

	ret = rtnl_register_module(THIS_MODULE, PF_INET6, RTM_DELROUTE,
				   inet6_rtm_delroute, NULL, 0);
	if (ret < 0)
		goto out_register_late_subsys;

	ret = rtnl_register_module(THIS_MODULE, PF_INET6, RTM_GETROUTE,
				   inet6_rtm_getroute, NULL,
				   RTNL_FLAG_DOIT_UNLOCKED);
	if (ret < 0)
6454
		goto out_register_late_subsys;
6455

6456
	ret = register_netdevice_notifier(&ip6_route_dev_notifier);
6457
	if (ret)
6458
		goto out_register_late_subsys;
6459

6460 6461 6462 6463 6464 6465 6466
	for_each_possible_cpu(cpu) {
		struct uncached_list *ul = per_cpu_ptr(&rt6_uncached_list, cpu);

		INIT_LIST_HEAD(&ul->head);
		spin_lock_init(&ul->lock);
	}

6467 6468 6469
out:
	return ret;

6470
out_register_late_subsys:
6471
	rtnl_unregister_all(PF_INET6);
6472
	unregister_pernet_subsys(&ip6_route_net_late_ops);
6473 6474 6475 6476
fib6_rules_init:
	fib6_rules_cleanup();
xfrm6_init:
	xfrm6_fini();
6477 6478
out_fib6_init:
	fib6_gc_cleanup();
6479 6480
out_register_subsys:
	unregister_pernet_subsys(&ip6_route_net_ops);
6481 6482
out_register_inetpeer:
	unregister_pernet_subsys(&ipv6_inetpeer_ops);
6483 6484
out_dst_entries:
	dst_entries_destroy(&ip6_dst_blackhole_ops);
6485
out_kmem_cache:
6486
	kmem_cache_destroy(ip6_dst_ops_template.kmem_cachep);
6487
	goto out;
L
Linus Torvalds 已提交
6488 6489 6490 6491
}

void ip6_route_cleanup(void)
{
6492
	unregister_netdevice_notifier(&ip6_route_dev_notifier);
6493
	unregister_pernet_subsys(&ip6_route_net_late_ops);
T
Thomas Graf 已提交
6494
	fib6_rules_cleanup();
L
Linus Torvalds 已提交
6495 6496
	xfrm6_fini();
	fib6_gc_cleanup();
6497
	unregister_pernet_subsys(&ipv6_inetpeer_ops);
6498
	unregister_pernet_subsys(&ip6_route_net_ops);
6499
	dst_entries_destroy(&ip6_dst_blackhole_ops);
6500
	kmem_cache_destroy(ip6_dst_ops_template.kmem_cachep);
L
Linus Torvalds 已提交
6501
}