Linux Audio

Check our new training course

Loading...
v3.1
 
   1/*
   2 *	IPv6 tunneling device
   3 *	Linux INET6 implementation
   4 *
   5 *	Authors:
   6 *	Ville Nuorvala		<vnuorval@tcs.hut.fi>
   7 *	Yasuyuki Kozakai	<kozakai@linux-ipv6.org>
   8 *
   9 *      Based on:
  10 *      linux/net/ipv6/sit.c and linux/net/ipv4/ipip.c
  11 *
  12 *      RFC 2473
  13 *
  14 *	This program is free software; you can redistribute it and/or
  15 *      modify it under the terms of the GNU General Public License
  16 *      as published by the Free Software Foundation; either version
  17 *      2 of the License, or (at your option) any later version.
  18 *
  19 */
  20
 
 
  21#include <linux/module.h>
  22#include <linux/capability.h>
  23#include <linux/errno.h>
  24#include <linux/types.h>
  25#include <linux/sockios.h>
  26#include <linux/icmp.h>
  27#include <linux/if.h>
  28#include <linux/in.h>
  29#include <linux/ip.h>
  30#include <linux/if_tunnel.h>
  31#include <linux/net.h>
  32#include <linux/in6.h>
  33#include <linux/netdevice.h>
  34#include <linux/if_arp.h>
  35#include <linux/icmpv6.h>
  36#include <linux/init.h>
  37#include <linux/route.h>
  38#include <linux/rtnetlink.h>
  39#include <linux/netfilter_ipv6.h>
  40#include <linux/slab.h>
 
 
  41
  42#include <asm/uaccess.h>
  43#include <linux/atomic.h>
  44
  45#include <net/icmp.h>
  46#include <net/ip.h>
 
  47#include <net/ipv6.h>
  48#include <net/ip6_route.h>
  49#include <net/addrconf.h>
  50#include <net/ip6_tunnel.h>
  51#include <net/xfrm.h>
  52#include <net/dsfield.h>
  53#include <net/inet_ecn.h>
  54#include <net/net_namespace.h>
  55#include <net/netns/generic.h>
 
  56
  57MODULE_AUTHOR("Ville Nuorvala");
  58MODULE_DESCRIPTION("IPv6 tunneling device");
  59MODULE_LICENSE("GPL");
 
  60MODULE_ALIAS_NETDEV("ip6tnl0");
  61
  62#ifdef IP6_TNL_DEBUG
  63#define IP6_TNL_TRACE(x...) printk(KERN_DEBUG "%s:" x "\n", __func__)
  64#else
  65#define IP6_TNL_TRACE(x...) do {;} while(0)
  66#endif
  67
  68#define IPV6_TCLASS_MASK (IPV6_FLOWINFO_MASK & ~IPV6_FLOWLABEL_MASK)
  69#define IPV6_TCLASS_SHIFT 20
  70
  71#define HASH_SIZE  32
  72
  73#define HASH(addr) ((__force u32)((addr)->s6_addr32[0] ^ (addr)->s6_addr32[1] ^ \
  74		     (addr)->s6_addr32[2] ^ (addr)->s6_addr32[3]) & \
  75		    (HASH_SIZE - 1))
  76
  77static int ip6_tnl_dev_init(struct net_device *dev);
  78static void ip6_tnl_dev_setup(struct net_device *dev);
 
  79
  80static int ip6_tnl_net_id __read_mostly;
  81struct ip6_tnl_net {
  82	/* the IPv6 tunnel fallback device */
  83	struct net_device *fb_tnl_dev;
  84	/* lists for storing tunnels in use */
  85	struct ip6_tnl __rcu *tnls_r_l[HASH_SIZE];
  86	struct ip6_tnl __rcu *tnls_wc[1];
  87	struct ip6_tnl __rcu **tnls[2];
 
  88};
  89
  90/* often modified stats are per cpu, other are shared (netdev->stats) */
  91struct pcpu_tstats {
  92	unsigned long	rx_packets;
  93	unsigned long	rx_bytes;
  94	unsigned long	tx_packets;
  95	unsigned long	tx_bytes;
  96};
  97
  98static struct net_device_stats *ip6_get_stats(struct net_device *dev)
  99{
 100	struct pcpu_tstats sum = { 0 };
 101	int i;
 102
 103	for_each_possible_cpu(i) {
 104		const struct pcpu_tstats *tstats = per_cpu_ptr(dev->tstats, i);
 105
 106		sum.rx_packets += tstats->rx_packets;
 107		sum.rx_bytes   += tstats->rx_bytes;
 108		sum.tx_packets += tstats->tx_packets;
 109		sum.tx_bytes   += tstats->tx_bytes;
 110	}
 111	dev->stats.rx_packets = sum.rx_packets;
 112	dev->stats.rx_bytes   = sum.rx_bytes;
 113	dev->stats.tx_packets = sum.tx_packets;
 114	dev->stats.tx_bytes   = sum.tx_bytes;
 115	return &dev->stats;
 116}
 117
 118/*
 119 * Locking : hash tables are protected by RCU and RTNL
 120 */
 121
 122static inline struct dst_entry *ip6_tnl_dst_check(struct ip6_tnl *t)
 123{
 124	struct dst_entry *dst = t->dst_cache;
 125
 126	if (dst && dst->obsolete &&
 127	    dst->ops->check(dst, t->dst_cookie) == NULL) {
 128		t->dst_cache = NULL;
 129		dst_release(dst);
 130		return NULL;
 131	}
 132
 133	return dst;
 134}
 135
 136static inline void ip6_tnl_dst_reset(struct ip6_tnl *t)
 137{
 138	dst_release(t->dst_cache);
 139	t->dst_cache = NULL;
 140}
 141
 142static inline void ip6_tnl_dst_store(struct ip6_tnl *t, struct dst_entry *dst)
 143{
 144	struct rt6_info *rt = (struct rt6_info *) dst;
 145	t->dst_cookie = rt->rt6i_node ? rt->rt6i_node->fn_sernum : 0;
 146	dst_release(t->dst_cache);
 147	t->dst_cache = dst;
 148}
 149
 150/**
 151 * ip6_tnl_lookup - fetch tunnel matching the end-point addresses
 
 
 152 *   @remote: the address of the tunnel exit-point
 153 *   @local: the address of the tunnel entry-point
 154 *
 155 * Return:
 156 *   tunnel matching given end-points if found,
 157 *   else fallback tunnel if its device is up,
 158 *   else %NULL
 159 **/
 160
 161#define for_each_ip6_tunnel_rcu(start) \
 162	for (t = rcu_dereference(start); t; t = rcu_dereference(t->next))
 163
 164static struct ip6_tnl *
 165ip6_tnl_lookup(struct net *net, const struct in6_addr *remote, const struct in6_addr *local)
 
 166{
 167	unsigned int h0 = HASH(remote);
 168	unsigned int h1 = HASH(local);
 169	struct ip6_tnl *t;
 170	struct ip6_tnl_net *ip6n = net_generic(net, ip6_tnl_net_id);
 
 171
 172	for_each_ip6_tunnel_rcu(ip6n->tnls_r_l[h0 ^ h1]) {
 173		if (ipv6_addr_equal(local, &t->parms.laddr) &&
 174		    ipv6_addr_equal(remote, &t->parms.raddr) &&
 175		    (t->dev->flags & IFF_UP))
 
 
 
 176			return t;
 
 
 177	}
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 178	t = rcu_dereference(ip6n->tnls_wc[0]);
 179	if (t && (t->dev->flags & IFF_UP))
 180		return t;
 181
 182	return NULL;
 183}
 184
 185/**
 186 * ip6_tnl_bucket - get head of list matching given tunnel parameters
 
 187 *   @p: parameters containing tunnel end-points
 188 *
 189 * Description:
 190 *   ip6_tnl_bucket() returns the head of the list matching the
 191 *   &struct in6_addr entries laddr and raddr in @p.
 192 *
 193 * Return: head of IPv6 tunnel list
 194 **/
 195
 196static struct ip6_tnl __rcu **
 197ip6_tnl_bucket(struct ip6_tnl_net *ip6n, const struct ip6_tnl_parm *p)
 198{
 199	const struct in6_addr *remote = &p->raddr;
 200	const struct in6_addr *local = &p->laddr;
 201	unsigned h = 0;
 202	int prio = 0;
 203
 204	if (!ipv6_addr_any(remote) || !ipv6_addr_any(local)) {
 205		prio = 1;
 206		h = HASH(remote) ^ HASH(local);
 207	}
 208	return &ip6n->tnls[prio][h];
 209}
 210
 211/**
 212 * ip6_tnl_link - add tunnel to hash table
 
 213 *   @t: tunnel to be added
 214 **/
 215
 216static void
 217ip6_tnl_link(struct ip6_tnl_net *ip6n, struct ip6_tnl *t)
 218{
 219	struct ip6_tnl __rcu **tp = ip6_tnl_bucket(ip6n, &t->parms);
 220
 
 
 221	rcu_assign_pointer(t->next , rtnl_dereference(*tp));
 222	rcu_assign_pointer(*tp, t);
 223}
 224
 225/**
 226 * ip6_tnl_unlink - remove tunnel from hash table
 
 227 *   @t: tunnel to be removed
 228 **/
 229
 230static void
 231ip6_tnl_unlink(struct ip6_tnl_net *ip6n, struct ip6_tnl *t)
 232{
 233	struct ip6_tnl __rcu **tp;
 234	struct ip6_tnl *iter;
 235
 
 
 
 236	for (tp = ip6_tnl_bucket(ip6n, &t->parms);
 237	     (iter = rtnl_dereference(*tp)) != NULL;
 238	     tp = &iter->next) {
 239		if (t == iter) {
 240			rcu_assign_pointer(*tp, t->next);
 241			break;
 242		}
 243	}
 244}
 245
 246static void ip6_dev_free(struct net_device *dev)
 247{
 
 
 
 
 248	free_percpu(dev->tstats);
 249	free_netdev(dev);
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 250}
 251
 252/**
 253 * ip6_tnl_create() - create a new tunnel
 
 254 *   @p: tunnel parameters
 255 *   @pt: pointer to new tunnel
 256 *
 257 * Description:
 258 *   Create tunnel matching given parameters.
 259 *
 260 * Return:
 261 *   created tunnel or NULL
 262 **/
 263
 264static struct ip6_tnl *ip6_tnl_create(struct net *net, struct ip6_tnl_parm *p)
 265{
 266	struct net_device *dev;
 267	struct ip6_tnl *t;
 268	char name[IFNAMSIZ];
 269	int err;
 270	struct ip6_tnl_net *ip6n = net_generic(net, ip6_tnl_net_id);
 271
 272	if (p->name[0])
 
 
 273		strlcpy(name, p->name, IFNAMSIZ);
 274	else
 275		sprintf(name, "ip6tnl%%d");
 276
 277	dev = alloc_netdev(sizeof (*t), name, ip6_tnl_dev_setup);
 278	if (dev == NULL)
 
 
 279		goto failed;
 280
 281	dev_net_set(dev, net);
 282
 283	t = netdev_priv(dev);
 284	t->parms = *p;
 285	err = ip6_tnl_dev_init(dev);
 
 286	if (err < 0)
 287		goto failed_free;
 288
 289	if ((err = register_netdevice(dev)) < 0)
 290		goto failed_free;
 291
 292	dev_hold(dev);
 293	ip6_tnl_link(ip6n, t);
 294	return t;
 295
 296failed_free:
 297	ip6_dev_free(dev);
 298failed:
 299	return NULL;
 300}
 301
 302/**
 303 * ip6_tnl_locate - find or create tunnel matching given parameters
 
 304 *   @p: tunnel parameters
 305 *   @create: != 0 if allowed to create new tunnel if no match found
 306 *
 307 * Description:
 308 *   ip6_tnl_locate() first tries to locate an existing tunnel
 309 *   based on @parms. If this is unsuccessful, but @create is set a new
 310 *   tunnel device is created and registered for use.
 311 *
 312 * Return:
 313 *   matching tunnel or NULL
 314 **/
 315
 316static struct ip6_tnl *ip6_tnl_locate(struct net *net,
 317		struct ip6_tnl_parm *p, int create)
 318{
 319	const struct in6_addr *remote = &p->raddr;
 320	const struct in6_addr *local = &p->laddr;
 321	struct ip6_tnl __rcu **tp;
 322	struct ip6_tnl *t;
 323	struct ip6_tnl_net *ip6n = net_generic(net, ip6_tnl_net_id);
 324
 325	for (tp = ip6_tnl_bucket(ip6n, p);
 326	     (t = rtnl_dereference(*tp)) != NULL;
 327	     tp = &t->next) {
 328		if (ipv6_addr_equal(local, &t->parms.laddr) &&
 329		    ipv6_addr_equal(remote, &t->parms.raddr))
 
 
 
 
 330			return t;
 
 331	}
 332	if (!create)
 333		return NULL;
 334	return ip6_tnl_create(net, p);
 335}
 336
 337/**
 338 * ip6_tnl_dev_uninit - tunnel device uninitializer
 339 *   @dev: the device to be destroyed
 340 *
 341 * Description:
 342 *   ip6_tnl_dev_uninit() removes tunnel from its list
 343 **/
 344
 345static void
 346ip6_tnl_dev_uninit(struct net_device *dev)
 347{
 348	struct ip6_tnl *t = netdev_priv(dev);
 349	struct net *net = dev_net(dev);
 350	struct ip6_tnl_net *ip6n = net_generic(net, ip6_tnl_net_id);
 351
 352	if (dev == ip6n->fb_tnl_dev)
 353		rcu_assign_pointer(ip6n->tnls_wc[0], NULL);
 354	else
 355		ip6_tnl_unlink(ip6n, t);
 356	ip6_tnl_dst_reset(t);
 357	dev_put(dev);
 358}
 359
 360/**
 361 * parse_tvl_tnl_enc_lim - handle encapsulation limit option
 362 *   @skb: received socket buffer
 
 363 *
 364 * Return:
 365 *   0 if none was found,
 366 *   else index to encapsulation limit
 367 **/
 368
 369static __u16
 370parse_tlv_tnl_enc_lim(struct sk_buff *skb, __u8 * raw)
 371{
 372	const struct ipv6hdr *ipv6h = (const struct ipv6hdr *) raw;
 373	__u8 nexthdr = ipv6h->nexthdr;
 374	__u16 off = sizeof (*ipv6h);
 
 375
 376	while (ipv6_ext_hdr(nexthdr) && nexthdr != NEXTHDR_NONE) {
 377		__u16 optlen = 0;
 378		struct ipv6_opt_hdr *hdr;
 379		if (raw + off + sizeof (*hdr) > skb->data &&
 380		    !pskb_may_pull(skb, raw - skb->data + off + sizeof (*hdr)))
 
 381			break;
 382
 383		hdr = (struct ipv6_opt_hdr *) (raw + off);
 384		if (nexthdr == NEXTHDR_FRAGMENT) {
 385			struct frag_hdr *frag_hdr = (struct frag_hdr *) hdr;
 386			if (frag_hdr->frag_off)
 387				break;
 388			optlen = 8;
 389		} else if (nexthdr == NEXTHDR_AUTH) {
 390			optlen = (hdr->hdrlen + 2) << 2;
 391		} else {
 392			optlen = ipv6_optlen(hdr);
 393		}
 
 
 
 
 394		if (nexthdr == NEXTHDR_DEST) {
 395			__u16 i = off + 2;
 
 
 
 
 
 396			while (1) {
 397				struct ipv6_tlv_tnl_enc_lim *tel;
 398
 399				/* No more room for encapsulation limit */
 400				if (i + sizeof (*tel) > off + optlen)
 401					break;
 402
 403				tel = (struct ipv6_tlv_tnl_enc_lim *) &raw[i];
 404				/* return index of option if found and valid */
 405				if (tel->type == IPV6_TLV_TNL_ENCAP_LIMIT &&
 406				    tel->length == 1)
 407					return i;
 408				/* else jump to next option */
 409				if (tel->type)
 410					i += tel->length + 2;
 411				else
 412					i++;
 413			}
 414		}
 415		nexthdr = hdr->nexthdr;
 416		off += optlen;
 417	}
 418	return 0;
 419}
 
 420
 421/**
 422 * ip6_tnl_err - tunnel error handler
 423 *
 424 * Description:
 425 *   ip6_tnl_err() should handle errors in the tunnel according
 426 *   to the specifications in RFC 2473.
 427 **/
 428
 429static int
 430ip6_tnl_err(struct sk_buff *skb, __u8 ipproto, struct inet6_skb_parm *opt,
 431	    u8 *type, u8 *code, int *msg, __u32 *info, int offset)
 432{
 433	const struct ipv6hdr *ipv6h = (const struct ipv6hdr *) skb->data;
 434	struct ip6_tnl *t;
 435	int rel_msg = 0;
 436	u8 rel_type = ICMPV6_DEST_UNREACH;
 437	u8 rel_code = ICMPV6_ADDR_UNREACH;
 438	__u32 rel_info = 0;
 439	__u16 len;
 440	int err = -ENOENT;
 
 
 
 441
 442	/* If the packet doesn't contain the original IPv6 header we are
 443	   in trouble since we might need the source address for further
 444	   processing of the error. */
 445
 446	rcu_read_lock();
 447	if ((t = ip6_tnl_lookup(dev_net(skb->dev), &ipv6h->daddr,
 448					&ipv6h->saddr)) == NULL)
 449		goto out;
 450
 451	if (t->parms.proto != ipproto && t->parms.proto != 0)
 
 452		goto out;
 453
 454	err = 0;
 455
 456	switch (*type) {
 457		__u32 teli;
 458		struct ipv6_tlv_tnl_enc_lim *tel;
 459		__u32 mtu;
 460	case ICMPV6_DEST_UNREACH:
 461		if (net_ratelimit())
 462			printk(KERN_WARNING
 463			       "%s: Path to destination invalid "
 464			       "or inactive!\n", t->parms.name);
 465		rel_msg = 1;
 466		break;
 467	case ICMPV6_TIME_EXCEED:
 468		if ((*code) == ICMPV6_EXC_HOPLIMIT) {
 469			if (net_ratelimit())
 470				printk(KERN_WARNING
 471				       "%s: Too small hop limit or "
 472				       "routing loop in tunnel!\n",
 473				       t->parms.name);
 474			rel_msg = 1;
 475		}
 476		break;
 477	case ICMPV6_PARAMPROB:
 
 
 
 478		teli = 0;
 479		if ((*code) == ICMPV6_HDR_FIELD)
 480			teli = parse_tlv_tnl_enc_lim(skb, skb->data);
 481
 482		if (teli && teli == *info - 2) {
 483			tel = (struct ipv6_tlv_tnl_enc_lim *) &skb->data[teli];
 484			if (tel->encap_limit == 0) {
 485				if (net_ratelimit())
 486					printk(KERN_WARNING
 487					       "%s: Too small encapsulation "
 488					       "limit or routing loop in "
 489					       "tunnel!\n", t->parms.name);
 490				rel_msg = 1;
 491			}
 492		} else if (net_ratelimit()) {
 493			printk(KERN_WARNING
 494			       "%s: Recipient unable to parse tunneled "
 495			       "packet!\n ", t->parms.name);
 496		}
 497		break;
 498	case ICMPV6_PKT_TOOBIG:
 
 
 
 
 
 499		mtu = *info - offset;
 500		if (mtu < IPV6_MIN_MTU)
 501			mtu = IPV6_MIN_MTU;
 502		t->dev->mtu = mtu;
 503
 504		if ((len = sizeof (*ipv6h) + ntohs(ipv6h->payload_len)) > mtu) {
 505			rel_type = ICMPV6_PKT_TOOBIG;
 506			rel_code = 0;
 507			rel_info = mtu;
 508			rel_msg = 1;
 509		}
 510		break;
 511	}
 
 
 
 
 
 512
 513	*type = rel_type;
 514	*code = rel_code;
 515	*info = rel_info;
 516	*msg = rel_msg;
 517
 518out:
 519	rcu_read_unlock();
 520	return err;
 521}
 522
 523static int
 524ip4ip6_err(struct sk_buff *skb, struct inet6_skb_parm *opt,
 525	   u8 type, u8 code, int offset, __be32 info)
 526{
 527	int rel_msg = 0;
 528	u8 rel_type = type;
 529	u8 rel_code = code;
 530	__u32 rel_info = ntohl(info);
 531	int err;
 532	struct sk_buff *skb2;
 533	const struct iphdr *eiph;
 
 
 
 
 534	struct rtable *rt;
 535	struct flowi4 fl4;
 536
 537	err = ip6_tnl_err(skb, IPPROTO_IPIP, opt, &rel_type, &rel_code,
 538			  &rel_msg, &rel_info, offset);
 539	if (err < 0)
 540		return err;
 541
 542	if (rel_msg == 0)
 543		return 0;
 544
 545	switch (rel_type) {
 546	case ICMPV6_DEST_UNREACH:
 547		if (rel_code != ICMPV6_ADDR_UNREACH)
 548			return 0;
 549		rel_type = ICMP_DEST_UNREACH;
 550		rel_code = ICMP_HOST_UNREACH;
 551		break;
 552	case ICMPV6_PKT_TOOBIG:
 553		if (rel_code != 0)
 554			return 0;
 555		rel_type = ICMP_DEST_UNREACH;
 556		rel_code = ICMP_FRAG_NEEDED;
 557		break;
 558	default:
 559		return 0;
 560	}
 561
 562	if (!pskb_may_pull(skb, offset + sizeof(struct iphdr)))
 563		return 0;
 564
 565	skb2 = skb_clone(skb, GFP_ATOMIC);
 566	if (!skb2)
 567		return 0;
 568
 569	skb_dst_drop(skb2);
 570
 571	skb_pull(skb2, offset);
 572	skb_reset_network_header(skb2);
 573	eiph = ip_hdr(skb2);
 574
 575	/* Try to guess incoming interface */
 576	rt = ip_route_output_ports(dev_net(skb->dev), &fl4, NULL,
 577				   eiph->saddr, 0,
 578				   0, 0,
 579				   IPPROTO_IPIP, RT_TOS(eiph->tos), 0);
 580	if (IS_ERR(rt))
 581		goto out;
 582
 583	skb2->dev = rt->dst.dev;
 
 584
 585	/* route "incoming" packet */
 586	if (rt->rt_flags & RTCF_LOCAL) {
 587		ip_rt_put(rt);
 588		rt = NULL;
 589		rt = ip_route_output_ports(dev_net(skb->dev), &fl4, NULL,
 590					   eiph->daddr, eiph->saddr,
 591					   0, 0,
 592					   IPPROTO_IPIP,
 593					   RT_TOS(eiph->tos), 0);
 594		if (IS_ERR(rt) ||
 595		    rt->dst.dev->type != ARPHRD_TUNNEL) {
 596			if (!IS_ERR(rt))
 597				ip_rt_put(rt);
 598			goto out;
 599		}
 600		skb_dst_set(skb2, &rt->dst);
 601	} else {
 602		ip_rt_put(rt);
 603		if (ip_route_input(skb2, eiph->daddr, eiph->saddr, eiph->tos,
 604				   skb2->dev) ||
 605		    skb_dst(skb2)->dev->type != ARPHRD_TUNNEL)
 606			goto out;
 607	}
 608
 609	/* change mtu on this route */
 610	if (rel_type == ICMP_DEST_UNREACH && rel_code == ICMP_FRAG_NEEDED) {
 611		if (rel_info > dst_mtu(skb_dst(skb2)))
 612			goto out;
 613
 614		skb_dst(skb2)->ops->update_pmtu(skb_dst(skb2), rel_info);
 615	}
 616
 617	icmp_send(skb2, rel_type, rel_code, htonl(rel_info));
 618
 619out:
 620	kfree_skb(skb2);
 621	return 0;
 622}
 623
 624static int
 625ip6ip6_err(struct sk_buff *skb, struct inet6_skb_parm *opt,
 626	   u8 type, u8 code, int offset, __be32 info)
 627{
 628	int rel_msg = 0;
 
 629	u8 rel_type = type;
 630	u8 rel_code = code;
 631	__u32 rel_info = ntohl(info);
 632	int err;
 633
 634	err = ip6_tnl_err(skb, IPPROTO_IPV6, opt, &rel_type, &rel_code,
 635			  &rel_msg, &rel_info, offset);
 636	if (err < 0)
 637		return err;
 638
 639	if (rel_msg && pskb_may_pull(skb, offset + sizeof(struct ipv6hdr))) {
 640		struct rt6_info *rt;
 641		struct sk_buff *skb2 = skb_clone(skb, GFP_ATOMIC);
 642
 643		if (!skb2)
 644			return 0;
 645
 646		skb_dst_drop(skb2);
 647		skb_pull(skb2, offset);
 648		skb_reset_network_header(skb2);
 649
 650		/* Try to guess incoming interface */
 651		rt = rt6_lookup(dev_net(skb->dev), &ipv6_hdr(skb2)->saddr,
 652				NULL, 0, 0);
 653
 654		if (rt && rt->rt6i_dev)
 655			skb2->dev = rt->rt6i_dev;
 656
 657		icmpv6_send(skb2, rel_type, rel_code, rel_info);
 658
 659		if (rt)
 660			dst_release(&rt->dst);
 661
 662		kfree_skb(skb2);
 663	}
 664
 665	return 0;
 666}
 667
 668static void ip4ip6_dscp_ecn_decapsulate(const struct ip6_tnl *t,
 669					const struct ipv6hdr *ipv6h,
 670					struct sk_buff *skb)
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 671{
 672	__u8 dsfield = ipv6_get_dsfield(ipv6h) & ~INET_ECN_MASK;
 673
 674	if (t->parms.flags & IP6_TNL_F_RCV_DSCP_COPY)
 675		ipv4_change_dsfield(ip_hdr(skb), INET_ECN_MASK, dsfield);
 676
 677	if (INET_ECN_is_ce(dsfield))
 678		IP_ECN_set_ce(ip_hdr(skb));
 679}
 680
 681static void ip6ip6_dscp_ecn_decapsulate(const struct ip6_tnl *t,
 682					const struct ipv6hdr *ipv6h,
 683					struct sk_buff *skb)
 684{
 685	if (t->parms.flags & IP6_TNL_F_RCV_DSCP_COPY)
 686		ipv6_copy_dscp(ipv6_get_dsfield(ipv6h), ipv6_hdr(skb));
 687
 688	if (INET_ECN_is_ce(ipv6_get_dsfield(ipv6h)))
 689		IP6_ECN_set_ce(ipv6_hdr(skb));
 
 
 
 
 
 
 
 690}
 691
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 692/* called with rcu_read_lock() */
 693static inline int ip6_tnl_rcv_ctl(struct ip6_tnl *t)
 
 
 694{
 695	struct ip6_tnl_parm *p = &t->parms;
 696	int ret = 0;
 697	struct net *net = dev_net(t->dev);
 698
 699	if (p->flags & IP6_TNL_F_CAP_RCV) {
 
 
 700		struct net_device *ldev = NULL;
 701
 702		if (p->link)
 703			ldev = dev_get_by_index_rcu(net, p->link);
 704
 705		if ((ipv6_addr_is_multicast(&p->laddr) ||
 706		     likely(ipv6_chk_addr(net, &p->laddr, ldev, 0))) &&
 707		    likely(!ipv6_chk_addr(net, &p->raddr, NULL, 0)))
 
 
 
 708			ret = 1;
 709
 710	}
 711	return ret;
 712}
 
 713
 714/**
 715 * ip6_tnl_rcv - decapsulate IPv6 packet and retransmit it locally
 716 *   @skb: received socket buffer
 717 *   @protocol: ethernet protocol ID
 718 *   @dscp_ecn_decapsulate: the function to decapsulate DSCP code and ECN
 719 *
 720 * Return: 0
 721 **/
 722
 723static int ip6_tnl_rcv(struct sk_buff *skb, __u16 protocol,
 724		       __u8 ipproto,
 725		       void (*dscp_ecn_decapsulate)(const struct ip6_tnl *t,
 726						    const struct ipv6hdr *ipv6h,
 727						    struct sk_buff *skb))
 728{
 729	struct ip6_tnl *t;
 730	const struct ipv6hdr *ipv6h = ipv6_hdr(skb);
 
 731
 732	rcu_read_lock();
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 733
 734	if ((t = ip6_tnl_lookup(dev_net(skb->dev), &ipv6h->saddr,
 735					&ipv6h->daddr)) != NULL) {
 736		struct pcpu_tstats *tstats;
 737
 738		if (t->parms.proto != ipproto && t->parms.proto != 0) {
 739			rcu_read_unlock();
 740			goto discard;
 
 
 
 741		}
 742
 743		if (!xfrm6_policy_check(NULL, XFRM_POLICY_IN, skb)) {
 744			rcu_read_unlock();
 745			goto discard;
 746		}
 
 
 
 
 
 
 747
 748		if (!ip6_tnl_rcv_ctl(t)) {
 749			t->dev->stats.rx_dropped++;
 750			rcu_read_unlock();
 751			goto discard;
 
 
 
 
 
 
 
 
 752		}
 753		secpath_reset(skb);
 754		skb->mac_header = skb->network_header;
 755		skb_reset_network_header(skb);
 756		skb->protocol = htons(protocol);
 757		skb->pkt_type = PACKET_HOST;
 758		memset(skb->cb, 0, sizeof(struct inet6_skb_parm));
 759
 760		tstats = this_cpu_ptr(t->dev->tstats);
 761		tstats->rx_packets++;
 762		tstats->rx_bytes += skb->len;
 
 
 763
 764		__skb_tunnel_rx(skb, t->dev);
 765
 766		dscp_ecn_decapsulate(t, ipv6h, skb);
 
 767
 768		netif_rx(skb);
 
 769
 770		rcu_read_unlock();
 771		return 0;
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 772	}
 
 773	rcu_read_unlock();
 774	return 1;
 775
 776discard:
 
 
 
 777	kfree_skb(skb);
 778	return 0;
 779}
 780
 781static int ip4ip6_rcv(struct sk_buff *skb)
 782{
 783	return ip6_tnl_rcv(skb, ETH_P_IP, IPPROTO_IPIP,
 784			   ip4ip6_dscp_ecn_decapsulate);
 785}
 786
 787static int ip6ip6_rcv(struct sk_buff *skb)
 788{
 789	return ip6_tnl_rcv(skb, ETH_P_IPV6, IPPROTO_IPV6,
 790			   ip6ip6_dscp_ecn_decapsulate);
 
 
 
 
 
 
 791}
 792
 793struct ipv6_tel_txoption {
 794	struct ipv6_txoptions ops;
 795	__u8 dst_opt[8];
 796};
 797
 798static void init_tel_txopt(struct ipv6_tel_txoption *opt, __u8 encap_limit)
 799{
 800	memset(opt, 0, sizeof(struct ipv6_tel_txoption));
 801
 802	opt->dst_opt[2] = IPV6_TLV_TNL_ENCAP_LIMIT;
 803	opt->dst_opt[3] = 1;
 804	opt->dst_opt[4] = encap_limit;
 805	opt->dst_opt[5] = IPV6_TLV_PADN;
 806	opt->dst_opt[6] = 1;
 807
 808	opt->ops.dst0opt = (struct ipv6_opt_hdr *) opt->dst_opt;
 809	opt->ops.opt_nflen = 8;
 810}
 811
 812/**
 813 * ip6_tnl_addr_conflict - compare packet addresses to tunnel's own
 814 *   @t: the outgoing tunnel device
 815 *   @hdr: IPv6 header from the incoming packet
 816 *
 817 * Description:
 818 *   Avoid trivial tunneling loop by checking that tunnel exit-point
 819 *   doesn't match source of incoming packet.
 820 *
 821 * Return:
 822 *   1 if conflict,
 823 *   0 else
 824 **/
 825
 826static inline int
 827ip6_tnl_addr_conflict(const struct ip6_tnl *t, const struct ipv6hdr *hdr)
 828{
 829	return ipv6_addr_equal(&t->parms.raddr, &hdr->saddr);
 830}
 831
 832static inline int ip6_tnl_xmit_ctl(struct ip6_tnl *t)
 
 
 833{
 834	struct ip6_tnl_parm *p = &t->parms;
 835	int ret = 0;
 836	struct net *net = dev_net(t->dev);
 837
 838	if (p->flags & IP6_TNL_F_CAP_XMIT) {
 
 
 
 
 
 839		struct net_device *ldev = NULL;
 840
 841		rcu_read_lock();
 842		if (p->link)
 843			ldev = dev_get_by_index_rcu(net, p->link);
 844
 845		if (unlikely(!ipv6_chk_addr(net, &p->laddr, ldev, 0)))
 846			printk(KERN_WARNING
 847			       "%s xmit: Local address not yet configured!\n",
 848			       p->name);
 849		else if (!ipv6_addr_is_multicast(&p->raddr) &&
 850			 unlikely(ipv6_chk_addr(net, &p->raddr, NULL, 0)))
 851			printk(KERN_WARNING
 852			       "%s xmit: Routing loop! "
 853			       "Remote address found on this node!\n",
 854			       p->name);
 855		else
 856			ret = 1;
 857		rcu_read_unlock();
 858	}
 859	return ret;
 860}
 
 
 861/**
 862 * ip6_tnl_xmit2 - encapsulate packet and send
 863 *   @skb: the outgoing socket buffer
 864 *   @dev: the outgoing tunnel device
 865 *   @dsfield: dscp code for outer header
 866 *   @fl: flow of tunneled packet
 867 *   @encap_limit: encapsulation limit
 868 *   @pmtu: Path MTU is stored if packet is too big
 
 869 *
 870 * Description:
 871 *   Build new header and do some sanity checks on the packet before sending
 872 *   it.
 873 *
 874 * Return:
 875 *   0 on success
 876 *   -1 fail
 877 *   %-EMSGSIZE message too big. return mtu in this case.
 878 **/
 879
 880static int ip6_tnl_xmit2(struct sk_buff *skb,
 881			 struct net_device *dev,
 882			 __u8 dsfield,
 883			 struct flowi6 *fl6,
 884			 int encap_limit,
 885			 __u32 *pmtu)
 886{
 887	struct net *net = dev_net(dev);
 888	struct ip6_tnl *t = netdev_priv(dev);
 
 889	struct net_device_stats *stats = &t->dev->stats;
 890	struct ipv6hdr *ipv6h = ipv6_hdr(skb);
 891	struct ipv6_tel_txoption opt;
 892	struct dst_entry *dst;
 893	struct net_device *tdev;
 894	int mtu;
 895	unsigned int max_headroom = sizeof(struct ipv6hdr);
 896	u8 proto;
 
 
 
 897	int err = -1;
 898	int pkt_len;
 899
 900	if ((dst = ip6_tnl_dst_check(t)) != NULL)
 901		dst_hold(dst);
 902	else {
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 903		dst = ip6_route_output(net, NULL, fl6);
 904
 905		if (dst->error)
 906			goto tx_err_link_failure;
 907		dst = xfrm_lookup(net, dst, flowi6_to_flowi(fl6), NULL, 0);
 908		if (IS_ERR(dst)) {
 909			err = PTR_ERR(dst);
 910			dst = NULL;
 911			goto tx_err_link_failure;
 912		}
 
 
 
 
 
 913	}
 914
 915	tdev = dst->dev;
 916
 917	if (tdev == dev) {
 918		stats->collisions++;
 919		if (net_ratelimit())
 920			printk(KERN_WARNING
 921			       "%s: Local routing loop detected!\n",
 922			       t->parms.name);
 923		goto tx_err_dst_release;
 924	}
 925	mtu = dst_mtu(dst) - sizeof (*ipv6h);
 926	if (encap_limit >= 0) {
 927		max_headroom += 8;
 928		mtu -= 8;
 929	}
 930	if (mtu < IPV6_MIN_MTU)
 931		mtu = IPV6_MIN_MTU;
 932	if (skb_dst(skb))
 933		skb_dst(skb)->ops->update_pmtu(skb_dst(skb), mtu);
 934	if (skb->len > mtu) {
 935		*pmtu = mtu;
 936		err = -EMSGSIZE;
 937		goto tx_err_dst_release;
 938	}
 939
 
 
 
 
 
 
 
 
 
 
 
 
 
 940	/*
 941	 * Okay, now see if we can stuff it in the buffer as-is.
 942	 */
 943	max_headroom += LL_RESERVED_SPACE(tdev);
 944
 945	if (skb_headroom(skb) < max_headroom || skb_shared(skb) ||
 946	    (skb_cloned(skb) && !skb_clone_writable(skb, 0))) {
 947		struct sk_buff *new_skb;
 948
 949		if (!(new_skb = skb_realloc_headroom(skb, max_headroom)))
 
 950			goto tx_err_dst_release;
 951
 952		if (skb->sk)
 953			skb_set_owner_w(new_skb, skb->sk);
 954		kfree_skb(skb);
 955		skb = new_skb;
 956	}
 957	skb_dst_drop(skb);
 958	skb_dst_set(skb, dst_clone(dst));
 959
 960	skb->transport_header = skb->network_header;
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 961
 962	proto = fl6->flowi6_proto;
 963	if (encap_limit >= 0) {
 964		init_tel_txopt(&opt, encap_limit);
 965		ipv6_push_nfrag_opts(skb, &opt.ops, &proto, NULL);
 966	}
 
 967	skb_push(skb, sizeof(struct ipv6hdr));
 968	skb_reset_network_header(skb);
 969	ipv6h = ipv6_hdr(skb);
 970	*(__be32*)ipv6h = fl6->flowlabel | htonl(0x60000000);
 971	dsfield = INET_ECN_encapsulate(0, dsfield);
 972	ipv6_change_dsfield(ipv6h, ~INET_ECN_MASK, dsfield);
 973	ipv6h->hop_limit = t->parms.hop_limit;
 974	ipv6h->nexthdr = proto;
 975	ipv6_addr_copy(&ipv6h->saddr, &fl6->saddr);
 976	ipv6_addr_copy(&ipv6h->daddr, &fl6->daddr);
 977	nf_reset(skb);
 978	pkt_len = skb->len;
 979	err = ip6_local_out(skb);
 980
 981	if (net_xmit_eval(err) == 0) {
 982		struct pcpu_tstats *tstats = this_cpu_ptr(t->dev->tstats);
 983
 984		tstats->tx_bytes += pkt_len;
 985		tstats->tx_packets++;
 986	} else {
 987		stats->tx_errors++;
 988		stats->tx_aborted_errors++;
 989	}
 990	ip6_tnl_dst_store(t, dst);
 991	return 0;
 992tx_err_link_failure:
 993	stats->tx_carrier_errors++;
 994	dst_link_failure(skb);
 995tx_err_dst_release:
 996	dst_release(dst);
 997	return err;
 998}
 
 999
1000static inline int
1001ip4ip6_tnl_xmit(struct sk_buff *skb, struct net_device *dev)
 
1002{
1003	struct ip6_tnl *t = netdev_priv(dev);
1004	const struct iphdr  *iph = ip_hdr(skb);
 
1005	int encap_limit = -1;
 
1006	struct flowi6 fl6;
1007	__u8 dsfield;
1008	__u32 mtu;
 
1009	int err;
1010
1011	if ((t->parms.proto != IPPROTO_IPIP && t->parms.proto != 0) ||
1012	    !ip6_tnl_xmit_ctl(t))
1013		return -1;
1014
1015	if (!(t->parms.flags & IP6_TNL_F_IGN_ENCAP_LIMIT))
1016		encap_limit = t->parms.encap_limit;
1017
1018	memcpy(&fl6, &t->fl.u.ip6, sizeof (fl6));
1019	fl6.flowi6_proto = IPPROTO_IPIP;
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1020
1021	dsfield = ipv4_get_dsfield(iph);
 
 
 
 
 
 
 
 
1022
1023	if ((t->parms.flags & IP6_TNL_F_USE_ORIG_TCLASS))
1024		fl6.flowlabel |= htonl((__u32)iph->tos << IPV6_TCLASS_SHIFT)
1025					  & IPV6_TCLASS_MASK;
1026
1027	err = ip6_tnl_xmit2(skb, dev, dsfield, &fl6, encap_limit, &mtu);
1028	if (err != 0) {
1029		/* XXX: send ICMP error even if DF is not set. */
1030		if (err == -EMSGSIZE)
1031			icmp_send(skb, ICMP_DEST_UNREACH, ICMP_FRAG_NEEDED,
1032				  htonl(mtu));
1033		return -1;
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1034	}
1035
1036	return 0;
1037}
1038
1039static inline int
1040ip6ip6_tnl_xmit(struct sk_buff *skb, struct net_device *dev)
1041{
1042	struct ip6_tnl *t = netdev_priv(dev);
1043	struct ipv6hdr *ipv6h = ipv6_hdr(skb);
1044	int encap_limit = -1;
1045	__u16 offset;
1046	struct flowi6 fl6;
1047	__u8 dsfield;
1048	__u32 mtu;
1049	int err;
1050
1051	if ((t->parms.proto != IPPROTO_IPV6 && t->parms.proto != 0) ||
1052	    !ip6_tnl_xmit_ctl(t) || ip6_tnl_addr_conflict(t, ipv6h))
1053		return -1;
1054
1055	offset = parse_tlv_tnl_enc_lim(skb, skb_network_header(skb));
1056	if (offset > 0) {
1057		struct ipv6_tlv_tnl_enc_lim *tel;
1058		tel = (struct ipv6_tlv_tnl_enc_lim *)&skb_network_header(skb)[offset];
1059		if (tel->encap_limit == 0) {
1060			icmpv6_send(skb, ICMPV6_PARAMPROB,
1061				    ICMPV6_HDR_FIELD, offset + 2);
1062			return -1;
1063		}
1064		encap_limit = tel->encap_limit - 1;
1065	} else if (!(t->parms.flags & IP6_TNL_F_IGN_ENCAP_LIMIT))
1066		encap_limit = t->parms.encap_limit;
1067
1068	memcpy(&fl6, &t->fl.u.ip6, sizeof (fl6));
1069	fl6.flowi6_proto = IPPROTO_IPV6;
1070
1071	dsfield = ipv6_get_dsfield(ipv6h);
1072	if ((t->parms.flags & IP6_TNL_F_USE_ORIG_TCLASS))
1073		fl6.flowlabel |= (*(__be32 *) ipv6h & IPV6_TCLASS_MASK);
1074	if ((t->parms.flags & IP6_TNL_F_USE_ORIG_FLOWLABEL))
1075		fl6.flowlabel |= (*(__be32 *) ipv6h & IPV6_FLOWLABEL_MASK);
1076
1077	err = ip6_tnl_xmit2(skb, dev, dsfield, &fl6, encap_limit, &mtu);
 
1078	if (err != 0) {
 
1079		if (err == -EMSGSIZE)
1080			icmpv6_send(skb, ICMPV6_PKT_TOOBIG, 0, mtu);
 
 
 
 
 
 
 
 
 
 
1081		return -1;
1082	}
1083
1084	return 0;
1085}
1086
1087static netdev_tx_t
1088ip6_tnl_xmit(struct sk_buff *skb, struct net_device *dev)
1089{
1090	struct ip6_tnl *t = netdev_priv(dev);
1091	struct net_device_stats *stats = &t->dev->stats;
 
1092	int ret;
1093
 
 
 
1094	switch (skb->protocol) {
1095	case htons(ETH_P_IP):
1096		ret = ip4ip6_tnl_xmit(skb, dev);
1097		break;
1098	case htons(ETH_P_IPV6):
1099		ret = ip6ip6_tnl_xmit(skb, dev);
 
 
 
 
 
1100		break;
1101	default:
1102		goto tx_err;
1103	}
1104
 
1105	if (ret < 0)
1106		goto tx_err;
1107
1108	return NETDEV_TX_OK;
1109
1110tx_err:
1111	stats->tx_errors++;
1112	stats->tx_dropped++;
1113	kfree_skb(skb);
1114	return NETDEV_TX_OK;
1115}
1116
1117static void ip6_tnl_set_cap(struct ip6_tnl *t)
1118{
1119	struct ip6_tnl_parm *p = &t->parms;
1120	int ltype = ipv6_addr_type(&p->laddr);
1121	int rtype = ipv6_addr_type(&p->raddr);
1122
1123	p->flags &= ~(IP6_TNL_F_CAP_XMIT|IP6_TNL_F_CAP_RCV);
1124
1125	if (ltype & (IPV6_ADDR_UNICAST|IPV6_ADDR_MULTICAST) &&
1126	    rtype & (IPV6_ADDR_UNICAST|IPV6_ADDR_MULTICAST) &&
1127	    !((ltype|rtype) & IPV6_ADDR_LOOPBACK) &&
1128	    (!((ltype|rtype) & IPV6_ADDR_LINKLOCAL) || p->link)) {
1129		if (ltype&IPV6_ADDR_UNICAST)
1130			p->flags |= IP6_TNL_F_CAP_XMIT;
1131		if (rtype&IPV6_ADDR_UNICAST)
1132			p->flags |= IP6_TNL_F_CAP_RCV;
1133	}
1134}
1135
1136static void ip6_tnl_link_config(struct ip6_tnl *t)
1137{
1138	struct net_device *dev = t->dev;
1139	struct ip6_tnl_parm *p = &t->parms;
 
1140	struct flowi6 *fl6 = &t->fl.u.ip6;
 
 
1141
1142	memcpy(dev->dev_addr, &p->laddr, sizeof(struct in6_addr));
1143	memcpy(dev->broadcast, &p->raddr, sizeof(struct in6_addr));
1144
1145	/* Set up flowi template */
1146	ipv6_addr_copy(&fl6->saddr, &p->laddr);
1147	ipv6_addr_copy(&fl6->daddr, &p->raddr);
1148	fl6->flowi6_oif = p->link;
1149	fl6->flowlabel = 0;
1150
1151	if (!(p->flags&IP6_TNL_F_USE_ORIG_TCLASS))
1152		fl6->flowlabel |= IPV6_TCLASS_MASK & p->flowinfo;
1153	if (!(p->flags&IP6_TNL_F_USE_ORIG_FLOWLABEL))
1154		fl6->flowlabel |= IPV6_FLOWLABEL_MASK & p->flowinfo;
1155
1156	ip6_tnl_set_cap(t);
 
1157
1158	if (p->flags&IP6_TNL_F_CAP_XMIT && p->flags&IP6_TNL_F_CAP_RCV)
1159		dev->flags |= IFF_POINTOPOINT;
1160	else
1161		dev->flags &= ~IFF_POINTOPOINT;
1162
1163	dev->iflink = p->link;
 
 
1164
1165	if (p->flags & IP6_TNL_F_CAP_XMIT) {
1166		int strict = (ipv6_addr_type(&p->raddr) &
1167			      (IPV6_ADDR_MULTICAST|IPV6_ADDR_LINKLOCAL));
1168
1169		struct rt6_info *rt = rt6_lookup(dev_net(dev),
1170						 &p->raddr, &p->laddr,
1171						 p->link, strict);
 
 
 
 
1172
1173		if (rt == NULL)
1174			return;
1175
1176		if (rt->rt6i_dev) {
1177			dev->hard_header_len = rt->rt6i_dev->hard_header_len +
1178				sizeof (struct ipv6hdr);
1179
1180			dev->mtu = rt->rt6i_dev->mtu - sizeof (struct ipv6hdr);
1181			if (!(t->parms.flags & IP6_TNL_F_IGN_ENCAP_LIMIT))
1182				dev->mtu-=8;
1183
1184			if (dev->mtu < IPV6_MIN_MTU)
1185				dev->mtu = IPV6_MIN_MTU;
1186		}
1187		dst_release(&rt->dst);
1188	}
1189}
1190
1191/**
1192 * ip6_tnl_change - update the tunnel parameters
1193 *   @t: tunnel to be changed
1194 *   @p: tunnel configuration parameters
1195 *
1196 * Description:
1197 *   ip6_tnl_change() updates the tunnel parameters
1198 **/
1199
1200static int
1201ip6_tnl_change(struct ip6_tnl *t, struct ip6_tnl_parm *p)
1202{
1203	ipv6_addr_copy(&t->parms.laddr, &p->laddr);
1204	ipv6_addr_copy(&t->parms.raddr, &p->raddr);
1205	t->parms.flags = p->flags;
1206	t->parms.hop_limit = p->hop_limit;
1207	t->parms.encap_limit = p->encap_limit;
1208	t->parms.flowinfo = p->flowinfo;
1209	t->parms.link = p->link;
1210	t->parms.proto = p->proto;
1211	ip6_tnl_dst_reset(t);
 
1212	ip6_tnl_link_config(t);
1213	return 0;
1214}
1215
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1216/**
1217 * ip6_tnl_ioctl - configure ipv6 tunnels from userspace
1218 *   @dev: virtual device associated with tunnel
1219 *   @ifr: parameters passed from userspace
1220 *   @cmd: command to be performed
1221 *
1222 * Description:
1223 *   ip6_tnl_ioctl() is used for managing IPv6 tunnels
1224 *   from userspace.
1225 *
1226 *   The possible commands are the following:
1227 *     %SIOCGETTUNNEL: get tunnel parameters for device
1228 *     %SIOCADDTUNNEL: add tunnel matching given tunnel parameters
1229 *     %SIOCCHGTUNNEL: change tunnel parameters to those given
1230 *     %SIOCDELTUNNEL: delete tunnel
1231 *
1232 *   The fallback device "ip6tnl0", created during module
1233 *   initialization, can be used for creating other tunnel devices.
1234 *
1235 * Return:
1236 *   0 on success,
1237 *   %-EFAULT if unable to copy data to or from userspace,
1238 *   %-EPERM if current process hasn't %CAP_NET_ADMIN set
1239 *   %-EINVAL if passed tunnel parameters are invalid,
1240 *   %-EEXIST if changing a tunnel's parameters would cause a conflict
1241 *   %-ENODEV if attempting to change or delete a nonexisting device
1242 **/
1243
1244static int
1245ip6_tnl_ioctl(struct net_device *dev, struct ifreq *ifr, int cmd)
1246{
1247	int err = 0;
1248	struct ip6_tnl_parm p;
1249	struct ip6_tnl *t = NULL;
1250	struct net *net = dev_net(dev);
 
1251	struct ip6_tnl_net *ip6n = net_generic(net, ip6_tnl_net_id);
1252
 
 
1253	switch (cmd) {
1254	case SIOCGETTUNNEL:
1255		if (dev == ip6n->fb_tnl_dev) {
1256			if (copy_from_user(&p, ifr->ifr_ifru.ifru_data, sizeof (p))) {
1257				err = -EFAULT;
1258				break;
1259			}
1260			t = ip6_tnl_locate(net, &p, 0);
 
 
 
 
 
1261		}
1262		if (t == NULL)
1263			t = netdev_priv(dev);
1264		memcpy(&p, &t->parms, sizeof (p));
1265		if (copy_to_user(ifr->ifr_ifru.ifru_data, &p, sizeof (p))) {
1266			err = -EFAULT;
1267		}
1268		break;
1269	case SIOCADDTUNNEL:
1270	case SIOCCHGTUNNEL:
1271		err = -EPERM;
1272		if (!capable(CAP_NET_ADMIN))
1273			break;
1274		err = -EFAULT;
1275		if (copy_from_user(&p, ifr->ifr_ifru.ifru_data, sizeof (p)))
1276			break;
1277		err = -EINVAL;
1278		if (p.proto != IPPROTO_IPV6 && p.proto != IPPROTO_IPIP &&
1279		    p.proto != 0)
1280			break;
1281		t = ip6_tnl_locate(net, &p, cmd == SIOCADDTUNNEL);
1282		if (dev != ip6n->fb_tnl_dev && cmd == SIOCCHGTUNNEL) {
1283			if (t != NULL) {
 
1284				if (t->dev != dev) {
1285					err = -EEXIST;
1286					break;
1287				}
1288			} else
1289				t = netdev_priv(dev);
1290
1291			ip6_tnl_unlink(ip6n, t);
1292			synchronize_net();
1293			err = ip6_tnl_change(t, &p);
1294			ip6_tnl_link(ip6n, t);
1295			netdev_state_change(dev);
1296		}
1297		if (t) {
1298			err = 0;
1299			if (copy_to_user(ifr->ifr_ifru.ifru_data, &t->parms, sizeof (p)))
 
1300				err = -EFAULT;
1301
1302		} else
1303			err = (cmd == SIOCADDTUNNEL ? -ENOBUFS : -ENOENT);
 
1304		break;
1305	case SIOCDELTUNNEL:
1306		err = -EPERM;
1307		if (!capable(CAP_NET_ADMIN))
1308			break;
1309
1310		if (dev == ip6n->fb_tnl_dev) {
1311			err = -EFAULT;
1312			if (copy_from_user(&p, ifr->ifr_ifru.ifru_data, sizeof (p)))
1313				break;
1314			err = -ENOENT;
1315			if ((t = ip6_tnl_locate(net, &p, 0)) == NULL)
 
 
1316				break;
1317			err = -EPERM;
1318			if (t->dev == ip6n->fb_tnl_dev)
1319				break;
1320			dev = t->dev;
1321		}
1322		err = 0;
1323		unregister_netdevice(dev);
1324		break;
1325	default:
1326		err = -EINVAL;
1327	}
1328	return err;
1329}
1330
1331/**
1332 * ip6_tnl_change_mtu - change mtu manually for tunnel device
1333 *   @dev: virtual device associated with tunnel
1334 *   @new_mtu: the new mtu
1335 *
1336 * Return:
1337 *   0 on success,
1338 *   %-EINVAL if mtu too small
1339 **/
1340
1341static int
1342ip6_tnl_change_mtu(struct net_device *dev, int new_mtu)
1343{
1344	if (new_mtu < IPV6_MIN_MTU) {
1345		return -EINVAL;
 
 
 
 
 
 
 
 
 
 
 
 
 
1346	}
1347	dev->mtu = new_mtu;
1348	return 0;
1349}
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1350
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1351
1352static const struct net_device_ops ip6_tnl_netdev_ops = {
 
1353	.ndo_uninit	= ip6_tnl_dev_uninit,
1354	.ndo_start_xmit = ip6_tnl_xmit,
1355	.ndo_do_ioctl	= ip6_tnl_ioctl,
1356	.ndo_change_mtu = ip6_tnl_change_mtu,
1357	.ndo_get_stats	= ip6_get_stats,
 
1358};
1359
 
 
 
 
 
1360
1361/**
1362 * ip6_tnl_dev_setup - setup virtual tunnel device
1363 *   @dev: virtual device associated with tunnel
1364 *
1365 * Description:
1366 *   Initialize function pointers and device parameters
1367 **/
1368
1369static void ip6_tnl_dev_setup(struct net_device *dev)
1370{
1371	struct ip6_tnl *t;
1372
1373	dev->netdev_ops = &ip6_tnl_netdev_ops;
1374	dev->destructor = ip6_dev_free;
 
 
1375
1376	dev->type = ARPHRD_TUNNEL6;
1377	dev->hard_header_len = LL_MAX_HEADER + sizeof (struct ipv6hdr);
1378	dev->mtu = ETH_DATA_LEN - sizeof (struct ipv6hdr);
1379	t = netdev_priv(dev);
1380	if (!(t->parms.flags & IP6_TNL_F_IGN_ENCAP_LIMIT))
1381		dev->mtu-=8;
1382	dev->flags |= IFF_NOARP;
1383	dev->addr_len = sizeof(struct in6_addr);
1384	dev->features |= NETIF_F_NETNS_LOCAL;
1385	dev->priv_flags &= ~IFF_XMIT_DST_RELEASE;
 
 
 
 
 
 
 
1386}
1387
1388
1389/**
1390 * ip6_tnl_dev_init_gen - general initializer for all tunnel devices
1391 *   @dev: virtual device associated with tunnel
1392 **/
1393
1394static inline int
1395ip6_tnl_dev_init_gen(struct net_device *dev)
1396{
1397	struct ip6_tnl *t = netdev_priv(dev);
 
 
1398
1399	t->dev = dev;
1400	strcpy(t->parms.name, dev->name);
1401	dev->tstats = alloc_percpu(struct pcpu_tstats);
1402	if (!dev->tstats)
1403		return -ENOMEM;
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1404	return 0;
 
 
 
 
 
 
 
 
1405}
1406
1407/**
1408 * ip6_tnl_dev_init - initializer for all non fallback tunnel devices
1409 *   @dev: virtual device associated with tunnel
1410 **/
1411
1412static int ip6_tnl_dev_init(struct net_device *dev)
1413{
1414	struct ip6_tnl *t = netdev_priv(dev);
1415	int err = ip6_tnl_dev_init_gen(dev);
1416
1417	if (err)
1418		return err;
1419	ip6_tnl_link_config(t);
 
 
1420	return 0;
1421}
1422
1423/**
1424 * ip6_fb_tnl_dev_init - initializer for fallback tunnel device
1425 *   @dev: fallback device
1426 *
1427 * Return: 0
1428 **/
1429
1430static int __net_init ip6_fb_tnl_dev_init(struct net_device *dev)
1431{
1432	struct ip6_tnl *t = netdev_priv(dev);
1433	struct net *net = dev_net(dev);
1434	struct ip6_tnl_net *ip6n = net_generic(net, ip6_tnl_net_id);
1435	int err = ip6_tnl_dev_init_gen(dev);
1436
1437	if (err)
1438		return err;
1439
1440	t->parms.proto = IPPROTO_IPV6;
1441	dev_hold(dev);
1442	rcu_assign_pointer(ip6n->tnls_wc[0], t);
1443	return 0;
1444}
1445
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1446static struct xfrm6_tunnel ip4ip6_handler __read_mostly = {
1447	.handler	= ip4ip6_rcv,
1448	.err_handler	= ip4ip6_err,
1449	.priority	=	1,
1450};
1451
1452static struct xfrm6_tunnel ip6ip6_handler __read_mostly = {
1453	.handler	= ip6ip6_rcv,
1454	.err_handler	= ip6ip6_err,
1455	.priority	=	1,
1456};
1457
1458static void __net_exit ip6_tnl_destroy_tunnels(struct ip6_tnl_net *ip6n)
 
 
 
 
 
 
1459{
 
 
1460	int h;
1461	struct ip6_tnl *t;
1462	LIST_HEAD(list);
1463
1464	for (h = 0; h < HASH_SIZE; h++) {
 
 
 
 
1465		t = rtnl_dereference(ip6n->tnls_r_l[h]);
1466		while (t != NULL) {
1467			unregister_netdevice_queue(t->dev, &list);
 
 
 
 
1468			t = rtnl_dereference(t->next);
1469		}
1470	}
1471
1472	t = rtnl_dereference(ip6n->tnls_wc[0]);
1473	unregister_netdevice_queue(t->dev, &list);
1474	unregister_netdevice_many(&list);
 
 
 
 
 
 
1475}
1476
1477static int __net_init ip6_tnl_init_net(struct net *net)
1478{
1479	struct ip6_tnl_net *ip6n = net_generic(net, ip6_tnl_net_id);
 
1480	int err;
1481
1482	ip6n->tnls[0] = ip6n->tnls_wc;
1483	ip6n->tnls[1] = ip6n->tnls_r_l;
1484
 
 
1485	err = -ENOMEM;
1486	ip6n->fb_tnl_dev = alloc_netdev(sizeof(struct ip6_tnl), "ip6tnl0",
1487				      ip6_tnl_dev_setup);
1488
1489	if (!ip6n->fb_tnl_dev)
1490		goto err_alloc_dev;
1491	dev_net_set(ip6n->fb_tnl_dev, net);
 
 
 
 
 
1492
1493	err = ip6_fb_tnl_dev_init(ip6n->fb_tnl_dev);
1494	if (err < 0)
1495		goto err_register;
1496
1497	err = register_netdev(ip6n->fb_tnl_dev);
1498	if (err < 0)
1499		goto err_register;
 
 
 
 
1500	return 0;
1501
1502err_register:
1503	ip6_dev_free(ip6n->fb_tnl_dev);
1504err_alloc_dev:
1505	return err;
1506}
1507
1508static void __net_exit ip6_tnl_exit_net(struct net *net)
1509{
1510	struct ip6_tnl_net *ip6n = net_generic(net, ip6_tnl_net_id);
 
1511
1512	rtnl_lock();
1513	ip6_tnl_destroy_tunnels(ip6n);
 
 
1514	rtnl_unlock();
1515}
1516
1517static struct pernet_operations ip6_tnl_net_ops = {
1518	.init = ip6_tnl_init_net,
1519	.exit = ip6_tnl_exit_net,
1520	.id   = &ip6_tnl_net_id,
1521	.size = sizeof(struct ip6_tnl_net),
1522};
1523
1524/**
1525 * ip6_tunnel_init - register protocol and reserve needed resources
1526 *
1527 * Return: 0 on success
1528 **/
1529
1530static int __init ip6_tunnel_init(void)
1531{
1532	int  err;
1533
 
 
 
1534	err = register_pernet_device(&ip6_tnl_net_ops);
1535	if (err < 0)
1536		goto out_pernet;
1537
1538	err = xfrm6_tunnel_register(&ip4ip6_handler, AF_INET);
1539	if (err < 0) {
1540		printk(KERN_ERR "ip6_tunnel init: can't register ip4ip6\n");
1541		goto out_ip4ip6;
1542	}
1543
1544	err = xfrm6_tunnel_register(&ip6ip6_handler, AF_INET6);
1545	if (err < 0) {
1546		printk(KERN_ERR "ip6_tunnel init: can't register ip6ip6\n");
1547		goto out_ip6ip6;
1548	}
1549
 
 
 
 
 
 
 
 
 
 
 
 
1550	return 0;
1551
 
 
 
 
 
1552out_ip6ip6:
1553	xfrm6_tunnel_deregister(&ip4ip6_handler, AF_INET);
1554out_ip4ip6:
1555	unregister_pernet_device(&ip6_tnl_net_ops);
1556out_pernet:
1557	return err;
1558}
1559
1560/**
1561 * ip6_tunnel_cleanup - free resources and unregister protocol
1562 **/
1563
1564static void __exit ip6_tunnel_cleanup(void)
1565{
 
1566	if (xfrm6_tunnel_deregister(&ip4ip6_handler, AF_INET))
1567		printk(KERN_INFO "ip6_tunnel close: can't deregister ip4ip6\n");
1568
1569	if (xfrm6_tunnel_deregister(&ip6ip6_handler, AF_INET6))
1570		printk(KERN_INFO "ip6_tunnel close: can't deregister ip6ip6\n");
1571
 
 
 
1572	unregister_pernet_device(&ip6_tnl_net_ops);
1573}
1574
1575module_init(ip6_tunnel_init);
1576module_exit(ip6_tunnel_cleanup);
v5.14.15
   1// SPDX-License-Identifier: GPL-2.0-or-later
   2/*
   3 *	IPv6 tunneling device
   4 *	Linux INET6 implementation
   5 *
   6 *	Authors:
   7 *	Ville Nuorvala		<vnuorval@tcs.hut.fi>
   8 *	Yasuyuki Kozakai	<kozakai@linux-ipv6.org>
   9 *
  10 *      Based on:
  11 *      linux/net/ipv6/sit.c and linux/net/ipv4/ipip.c
  12 *
  13 *      RFC 2473
 
 
 
 
 
 
  14 */
  15
  16#define pr_fmt(fmt) KBUILD_MODNAME ": " fmt
  17
  18#include <linux/module.h>
  19#include <linux/capability.h>
  20#include <linux/errno.h>
  21#include <linux/types.h>
  22#include <linux/sockios.h>
  23#include <linux/icmp.h>
  24#include <linux/if.h>
  25#include <linux/in.h>
  26#include <linux/ip.h>
 
  27#include <linux/net.h>
  28#include <linux/in6.h>
  29#include <linux/netdevice.h>
  30#include <linux/if_arp.h>
  31#include <linux/icmpv6.h>
  32#include <linux/init.h>
  33#include <linux/route.h>
  34#include <linux/rtnetlink.h>
  35#include <linux/netfilter_ipv6.h>
  36#include <linux/slab.h>
  37#include <linux/hash.h>
  38#include <linux/etherdevice.h>
  39
  40#include <linux/uaccess.h>
  41#include <linux/atomic.h>
  42
  43#include <net/icmp.h>
  44#include <net/ip.h>
  45#include <net/ip_tunnels.h>
  46#include <net/ipv6.h>
  47#include <net/ip6_route.h>
  48#include <net/addrconf.h>
  49#include <net/ip6_tunnel.h>
  50#include <net/xfrm.h>
  51#include <net/dsfield.h>
  52#include <net/inet_ecn.h>
  53#include <net/net_namespace.h>
  54#include <net/netns/generic.h>
  55#include <net/dst_metadata.h>
  56
  57MODULE_AUTHOR("Ville Nuorvala");
  58MODULE_DESCRIPTION("IPv6 tunneling device");
  59MODULE_LICENSE("GPL");
  60MODULE_ALIAS_RTNL_LINK("ip6tnl");
  61MODULE_ALIAS_NETDEV("ip6tnl0");
  62
  63#define IP6_TUNNEL_HASH_SIZE_SHIFT  5
  64#define IP6_TUNNEL_HASH_SIZE (1 << IP6_TUNNEL_HASH_SIZE_SHIFT)
  65
  66static bool log_ecn_error = true;
  67module_param(log_ecn_error, bool, 0644);
  68MODULE_PARM_DESC(log_ecn_error, "Log packets received with corrupted ECN");
  69
  70static u32 HASH(const struct in6_addr *addr1, const struct in6_addr *addr2)
  71{
  72	u32 hash = ipv6_addr_hash(addr1) ^ ipv6_addr_hash(addr2);
  73
  74	return hash_32(hash, IP6_TUNNEL_HASH_SIZE_SHIFT);
  75}
 
  76
  77static int ip6_tnl_dev_init(struct net_device *dev);
  78static void ip6_tnl_dev_setup(struct net_device *dev);
  79static struct rtnl_link_ops ip6_link_ops __read_mostly;
  80
  81static unsigned int ip6_tnl_net_id __read_mostly;
  82struct ip6_tnl_net {
  83	/* the IPv6 tunnel fallback device */
  84	struct net_device *fb_tnl_dev;
  85	/* lists for storing tunnels in use */
  86	struct ip6_tnl __rcu *tnls_r_l[IP6_TUNNEL_HASH_SIZE];
  87	struct ip6_tnl __rcu *tnls_wc[1];
  88	struct ip6_tnl __rcu **tnls[2];
  89	struct ip6_tnl __rcu *collect_md_tun;
  90};
  91
  92static inline int ip6_tnl_mpls_supported(void)
 
 
 
 
 
 
 
 
  93{
  94	return IS_ENABLED(CONFIG_MPLS);
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
  95}
  96
  97#define for_each_ip6_tunnel_rcu(start) \
  98	for (t = rcu_dereference(start); t; t = rcu_dereference(t->next))
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
  99
 100/**
 101 * ip6_tnl_lookup - fetch tunnel matching the end-point addresses
 102 *   @net: network namespace
 103 *   @link: ifindex of underlying interface
 104 *   @remote: the address of the tunnel exit-point
 105 *   @local: the address of the tunnel entry-point
 106 *
 107 * Return:
 108 *   tunnel matching given end-points if found,
 109 *   else fallback tunnel if its device is up,
 110 *   else %NULL
 111 **/
 112
 
 
 
 113static struct ip6_tnl *
 114ip6_tnl_lookup(struct net *net, int link,
 115	       const struct in6_addr *remote, const struct in6_addr *local)
 116{
 117	unsigned int hash = HASH(remote, local);
 118	struct ip6_tnl *t, *cand = NULL;
 
 119	struct ip6_tnl_net *ip6n = net_generic(net, ip6_tnl_net_id);
 120	struct in6_addr any;
 121
 122	for_each_ip6_tunnel_rcu(ip6n->tnls_r_l[hash]) {
 123		if (!ipv6_addr_equal(local, &t->parms.laddr) ||
 124		    !ipv6_addr_equal(remote, &t->parms.raddr) ||
 125		    !(t->dev->flags & IFF_UP))
 126			continue;
 127
 128		if (link == t->parms.link)
 129			return t;
 130		else
 131			cand = t;
 132	}
 133
 134	memset(&any, 0, sizeof(any));
 135	hash = HASH(&any, local);
 136	for_each_ip6_tunnel_rcu(ip6n->tnls_r_l[hash]) {
 137		if (!ipv6_addr_equal(local, &t->parms.laddr) ||
 138		    !ipv6_addr_any(&t->parms.raddr) ||
 139		    !(t->dev->flags & IFF_UP))
 140			continue;
 141
 142		if (link == t->parms.link)
 143			return t;
 144		else if (!cand)
 145			cand = t;
 146	}
 147
 148	hash = HASH(remote, &any);
 149	for_each_ip6_tunnel_rcu(ip6n->tnls_r_l[hash]) {
 150		if (!ipv6_addr_equal(remote, &t->parms.raddr) ||
 151		    !ipv6_addr_any(&t->parms.laddr) ||
 152		    !(t->dev->flags & IFF_UP))
 153			continue;
 154
 155		if (link == t->parms.link)
 156			return t;
 157		else if (!cand)
 158			cand = t;
 159	}
 160
 161	if (cand)
 162		return cand;
 163
 164	t = rcu_dereference(ip6n->collect_md_tun);
 165	if (t && t->dev->flags & IFF_UP)
 166		return t;
 167
 168	t = rcu_dereference(ip6n->tnls_wc[0]);
 169	if (t && (t->dev->flags & IFF_UP))
 170		return t;
 171
 172	return NULL;
 173}
 174
 175/**
 176 * ip6_tnl_bucket - get head of list matching given tunnel parameters
 177 *   @ip6n: the private data for ip6_vti in the netns
 178 *   @p: parameters containing tunnel end-points
 179 *
 180 * Description:
 181 *   ip6_tnl_bucket() returns the head of the list matching the
 182 *   &struct in6_addr entries laddr and raddr in @p.
 183 *
 184 * Return: head of IPv6 tunnel list
 185 **/
 186
 187static struct ip6_tnl __rcu **
 188ip6_tnl_bucket(struct ip6_tnl_net *ip6n, const struct __ip6_tnl_parm *p)
 189{
 190	const struct in6_addr *remote = &p->raddr;
 191	const struct in6_addr *local = &p->laddr;
 192	unsigned int h = 0;
 193	int prio = 0;
 194
 195	if (!ipv6_addr_any(remote) || !ipv6_addr_any(local)) {
 196		prio = 1;
 197		h = HASH(remote, local);
 198	}
 199	return &ip6n->tnls[prio][h];
 200}
 201
 202/**
 203 * ip6_tnl_link - add tunnel to hash table
 204 *   @ip6n: the private data for ip6_vti in the netns
 205 *   @t: tunnel to be added
 206 **/
 207
 208static void
 209ip6_tnl_link(struct ip6_tnl_net *ip6n, struct ip6_tnl *t)
 210{
 211	struct ip6_tnl __rcu **tp = ip6_tnl_bucket(ip6n, &t->parms);
 212
 213	if (t->parms.collect_md)
 214		rcu_assign_pointer(ip6n->collect_md_tun, t);
 215	rcu_assign_pointer(t->next , rtnl_dereference(*tp));
 216	rcu_assign_pointer(*tp, t);
 217}
 218
 219/**
 220 * ip6_tnl_unlink - remove tunnel from hash table
 221 *   @ip6n: the private data for ip6_vti in the netns
 222 *   @t: tunnel to be removed
 223 **/
 224
 225static void
 226ip6_tnl_unlink(struct ip6_tnl_net *ip6n, struct ip6_tnl *t)
 227{
 228	struct ip6_tnl __rcu **tp;
 229	struct ip6_tnl *iter;
 230
 231	if (t->parms.collect_md)
 232		rcu_assign_pointer(ip6n->collect_md_tun, NULL);
 233
 234	for (tp = ip6_tnl_bucket(ip6n, &t->parms);
 235	     (iter = rtnl_dereference(*tp)) != NULL;
 236	     tp = &iter->next) {
 237		if (t == iter) {
 238			rcu_assign_pointer(*tp, t->next);
 239			break;
 240		}
 241	}
 242}
 243
 244static void ip6_dev_free(struct net_device *dev)
 245{
 246	struct ip6_tnl *t = netdev_priv(dev);
 247
 248	gro_cells_destroy(&t->gro_cells);
 249	dst_cache_destroy(&t->dst_cache);
 250	free_percpu(dev->tstats);
 251}
 252
 253static int ip6_tnl_create2(struct net_device *dev)
 254{
 255	struct ip6_tnl *t = netdev_priv(dev);
 256	struct net *net = dev_net(dev);
 257	struct ip6_tnl_net *ip6n = net_generic(net, ip6_tnl_net_id);
 258	int err;
 259
 260	t = netdev_priv(dev);
 261
 262	dev->rtnl_link_ops = &ip6_link_ops;
 263	err = register_netdevice(dev);
 264	if (err < 0)
 265		goto out;
 266
 267	strcpy(t->parms.name, dev->name);
 268
 269	ip6_tnl_link(ip6n, t);
 270	return 0;
 271
 272out:
 273	return err;
 274}
 275
 276/**
 277 * ip6_tnl_create - create a new tunnel
 278 *   @net: network namespace
 279 *   @p: tunnel parameters
 
 280 *
 281 * Description:
 282 *   Create tunnel matching given parameters.
 283 *
 284 * Return:
 285 *   created tunnel or error pointer
 286 **/
 287
 288static struct ip6_tnl *ip6_tnl_create(struct net *net, struct __ip6_tnl_parm *p)
 289{
 290	struct net_device *dev;
 291	struct ip6_tnl *t;
 292	char name[IFNAMSIZ];
 293	int err = -E2BIG;
 
 294
 295	if (p->name[0]) {
 296		if (!dev_valid_name(p->name))
 297			goto failed;
 298		strlcpy(name, p->name, IFNAMSIZ);
 299	} else {
 300		sprintf(name, "ip6tnl%%d");
 301	}
 302	err = -ENOMEM;
 303	dev = alloc_netdev(sizeof(*t), name, NET_NAME_UNKNOWN,
 304			   ip6_tnl_dev_setup);
 305	if (!dev)
 306		goto failed;
 307
 308	dev_net_set(dev, net);
 309
 310	t = netdev_priv(dev);
 311	t->parms = *p;
 312	t->net = dev_net(dev);
 313	err = ip6_tnl_create2(dev);
 314	if (err < 0)
 315		goto failed_free;
 316
 
 
 
 
 
 317	return t;
 318
 319failed_free:
 320	free_netdev(dev);
 321failed:
 322	return ERR_PTR(err);
 323}
 324
 325/**
 326 * ip6_tnl_locate - find or create tunnel matching given parameters
 327 *   @net: network namespace
 328 *   @p: tunnel parameters
 329 *   @create: != 0 if allowed to create new tunnel if no match found
 330 *
 331 * Description:
 332 *   ip6_tnl_locate() first tries to locate an existing tunnel
 333 *   based on @parms. If this is unsuccessful, but @create is set a new
 334 *   tunnel device is created and registered for use.
 335 *
 336 * Return:
 337 *   matching tunnel or error pointer
 338 **/
 339
 340static struct ip6_tnl *ip6_tnl_locate(struct net *net,
 341		struct __ip6_tnl_parm *p, int create)
 342{
 343	const struct in6_addr *remote = &p->raddr;
 344	const struct in6_addr *local = &p->laddr;
 345	struct ip6_tnl __rcu **tp;
 346	struct ip6_tnl *t;
 347	struct ip6_tnl_net *ip6n = net_generic(net, ip6_tnl_net_id);
 348
 349	for (tp = ip6_tnl_bucket(ip6n, p);
 350	     (t = rtnl_dereference(*tp)) != NULL;
 351	     tp = &t->next) {
 352		if (ipv6_addr_equal(local, &t->parms.laddr) &&
 353		    ipv6_addr_equal(remote, &t->parms.raddr) &&
 354		    p->link == t->parms.link) {
 355			if (create)
 356				return ERR_PTR(-EEXIST);
 357
 358			return t;
 359		}
 360	}
 361	if (!create)
 362		return ERR_PTR(-ENODEV);
 363	return ip6_tnl_create(net, p);
 364}
 365
 366/**
 367 * ip6_tnl_dev_uninit - tunnel device uninitializer
 368 *   @dev: the device to be destroyed
 369 *
 370 * Description:
 371 *   ip6_tnl_dev_uninit() removes tunnel from its list
 372 **/
 373
 374static void
 375ip6_tnl_dev_uninit(struct net_device *dev)
 376{
 377	struct ip6_tnl *t = netdev_priv(dev);
 378	struct net *net = t->net;
 379	struct ip6_tnl_net *ip6n = net_generic(net, ip6_tnl_net_id);
 380
 381	if (dev == ip6n->fb_tnl_dev)
 382		RCU_INIT_POINTER(ip6n->tnls_wc[0], NULL);
 383	else
 384		ip6_tnl_unlink(ip6n, t);
 385	dst_cache_reset(&t->dst_cache);
 386	dev_put(dev);
 387}
 388
 389/**
 390 * ip6_tnl_parse_tlv_enc_lim - handle encapsulation limit option
 391 *   @skb: received socket buffer
 392 *   @raw: the ICMPv6 error message data
 393 *
 394 * Return:
 395 *   0 if none was found,
 396 *   else index to encapsulation limit
 397 **/
 398
 399__u16 ip6_tnl_parse_tlv_enc_lim(struct sk_buff *skb, __u8 *raw)
 
 400{
 401	const struct ipv6hdr *ipv6h = (const struct ipv6hdr *)raw;
 402	unsigned int nhoff = raw - skb->data;
 403	unsigned int off = nhoff + sizeof(*ipv6h);
 404	u8 next, nexthdr = ipv6h->nexthdr;
 405
 406	while (ipv6_ext_hdr(nexthdr) && nexthdr != NEXTHDR_NONE) {
 
 407		struct ipv6_opt_hdr *hdr;
 408		u16 optlen;
 409
 410		if (!pskb_may_pull(skb, off + sizeof(*hdr)))
 411			break;
 412
 413		hdr = (struct ipv6_opt_hdr *)(skb->data + off);
 414		if (nexthdr == NEXTHDR_FRAGMENT) {
 415			struct frag_hdr *frag_hdr = (struct frag_hdr *) hdr;
 416			if (frag_hdr->frag_off)
 417				break;
 418			optlen = 8;
 419		} else if (nexthdr == NEXTHDR_AUTH) {
 420			optlen = ipv6_authlen(hdr);
 421		} else {
 422			optlen = ipv6_optlen(hdr);
 423		}
 424		/* cache hdr->nexthdr, since pskb_may_pull() might
 425		 * invalidate hdr
 426		 */
 427		next = hdr->nexthdr;
 428		if (nexthdr == NEXTHDR_DEST) {
 429			u16 i = 2;
 430
 431			/* Remember : hdr is no longer valid at this point. */
 432			if (!pskb_may_pull(skb, off + optlen))
 433				break;
 434
 435			while (1) {
 436				struct ipv6_tlv_tnl_enc_lim *tel;
 437
 438				/* No more room for encapsulation limit */
 439				if (i + sizeof(*tel) > optlen)
 440					break;
 441
 442				tel = (struct ipv6_tlv_tnl_enc_lim *)(skb->data + off + i);
 443				/* return index of option if found and valid */
 444				if (tel->type == IPV6_TLV_TNL_ENCAP_LIMIT &&
 445				    tel->length == 1)
 446					return i + off - nhoff;
 447				/* else jump to next option */
 448				if (tel->type)
 449					i += tel->length + 2;
 450				else
 451					i++;
 452			}
 453		}
 454		nexthdr = next;
 455		off += optlen;
 456	}
 457	return 0;
 458}
 459EXPORT_SYMBOL(ip6_tnl_parse_tlv_enc_lim);
 460
 461/* ip6_tnl_err() should handle errors in the tunnel according to the
 462 * specifications in RFC 2473.
 463 */
 
 
 
 
 
 464static int
 465ip6_tnl_err(struct sk_buff *skb, __u8 ipproto, struct inet6_skb_parm *opt,
 466	    u8 *type, u8 *code, int *msg, __u32 *info, int offset)
 467{
 468	const struct ipv6hdr *ipv6h = (const struct ipv6hdr *)skb->data;
 469	struct net *net = dev_net(skb->dev);
 
 470	u8 rel_type = ICMPV6_DEST_UNREACH;
 471	u8 rel_code = ICMPV6_ADDR_UNREACH;
 472	__u32 rel_info = 0;
 473	struct ip6_tnl *t;
 474	int err = -ENOENT;
 475	int rel_msg = 0;
 476	u8 tproto;
 477	__u16 len;
 478
 479	/* If the packet doesn't contain the original IPv6 header we are
 480	   in trouble since we might need the source address for further
 481	   processing of the error. */
 482
 483	rcu_read_lock();
 484	t = ip6_tnl_lookup(dev_net(skb->dev), skb->dev->ifindex, &ipv6h->daddr, &ipv6h->saddr);
 485	if (!t)
 486		goto out;
 487
 488	tproto = READ_ONCE(t->parms.proto);
 489	if (tproto != ipproto && tproto != 0)
 490		goto out;
 491
 492	err = 0;
 493
 494	switch (*type) {
 
 
 
 495	case ICMPV6_DEST_UNREACH:
 496		net_dbg_ratelimited("%s: Path to destination invalid or inactive!\n",
 497				    t->parms.name);
 
 
 498		rel_msg = 1;
 499		break;
 500	case ICMPV6_TIME_EXCEED:
 501		if ((*code) == ICMPV6_EXC_HOPLIMIT) {
 502			net_dbg_ratelimited("%s: Too small hop limit or routing loop in tunnel!\n",
 503					    t->parms.name);
 
 
 
 504			rel_msg = 1;
 505		}
 506		break;
 507	case ICMPV6_PARAMPROB: {
 508		struct ipv6_tlv_tnl_enc_lim *tel;
 509		__u32 teli;
 510
 511		teli = 0;
 512		if ((*code) == ICMPV6_HDR_FIELD)
 513			teli = ip6_tnl_parse_tlv_enc_lim(skb, skb->data);
 514
 515		if (teli && teli == *info - 2) {
 516			tel = (struct ipv6_tlv_tnl_enc_lim *) &skb->data[teli];
 517			if (tel->encap_limit == 0) {
 518				net_dbg_ratelimited("%s: Too small encapsulation limit or routing loop in tunnel!\n",
 519						    t->parms.name);
 
 
 
 520				rel_msg = 1;
 521			}
 522		} else {
 523			net_dbg_ratelimited("%s: Recipient unable to parse tunneled packet!\n",
 524					    t->parms.name);
 
 525		}
 526		break;
 527	}
 528	case ICMPV6_PKT_TOOBIG: {
 529		__u32 mtu;
 530
 531		ip6_update_pmtu(skb, net, htonl(*info), 0, 0,
 532				sock_net_uid(net, NULL));
 533		mtu = *info - offset;
 534		if (mtu < IPV6_MIN_MTU)
 535			mtu = IPV6_MIN_MTU;
 536		len = sizeof(*ipv6h) + ntohs(ipv6h->payload_len);
 537		if (len > mtu) {
 
 538			rel_type = ICMPV6_PKT_TOOBIG;
 539			rel_code = 0;
 540			rel_info = mtu;
 541			rel_msg = 1;
 542		}
 543		break;
 544	}
 545	case NDISC_REDIRECT:
 546		ip6_redirect(skb, net, skb->dev->ifindex, 0,
 547			     sock_net_uid(net, NULL));
 548		break;
 549	}
 550
 551	*type = rel_type;
 552	*code = rel_code;
 553	*info = rel_info;
 554	*msg = rel_msg;
 555
 556out:
 557	rcu_read_unlock();
 558	return err;
 559}
 560
 561static int
 562ip4ip6_err(struct sk_buff *skb, struct inet6_skb_parm *opt,
 563	   u8 type, u8 code, int offset, __be32 info)
 564{
 
 
 
 565	__u32 rel_info = ntohl(info);
 
 
 566	const struct iphdr *eiph;
 567	struct sk_buff *skb2;
 568	int err, rel_msg = 0;
 569	u8 rel_type = type;
 570	u8 rel_code = code;
 571	struct rtable *rt;
 572	struct flowi4 fl4;
 573
 574	err = ip6_tnl_err(skb, IPPROTO_IPIP, opt, &rel_type, &rel_code,
 575			  &rel_msg, &rel_info, offset);
 576	if (err < 0)
 577		return err;
 578
 579	if (rel_msg == 0)
 580		return 0;
 581
 582	switch (rel_type) {
 583	case ICMPV6_DEST_UNREACH:
 584		if (rel_code != ICMPV6_ADDR_UNREACH)
 585			return 0;
 586		rel_type = ICMP_DEST_UNREACH;
 587		rel_code = ICMP_HOST_UNREACH;
 588		break;
 589	case ICMPV6_PKT_TOOBIG:
 590		if (rel_code != 0)
 591			return 0;
 592		rel_type = ICMP_DEST_UNREACH;
 593		rel_code = ICMP_FRAG_NEEDED;
 594		break;
 595	default:
 596		return 0;
 597	}
 598
 599	if (!pskb_may_pull(skb, offset + sizeof(struct iphdr)))
 600		return 0;
 601
 602	skb2 = skb_clone(skb, GFP_ATOMIC);
 603	if (!skb2)
 604		return 0;
 605
 606	skb_dst_drop(skb2);
 607
 608	skb_pull(skb2, offset);
 609	skb_reset_network_header(skb2);
 610	eiph = ip_hdr(skb2);
 611
 612	/* Try to guess incoming interface */
 613	rt = ip_route_output_ports(dev_net(skb->dev), &fl4, NULL, eiph->saddr,
 614				   0, 0, 0, IPPROTO_IPIP, RT_TOS(eiph->tos), 0);
 
 
 615	if (IS_ERR(rt))
 616		goto out;
 617
 618	skb2->dev = rt->dst.dev;
 619	ip_rt_put(rt);
 620
 621	/* route "incoming" packet */
 622	if (rt->rt_flags & RTCF_LOCAL) {
 
 
 623		rt = ip_route_output_ports(dev_net(skb->dev), &fl4, NULL,
 624					   eiph->daddr, eiph->saddr, 0, 0,
 625					   IPPROTO_IPIP, RT_TOS(eiph->tos), 0);
 626		if (IS_ERR(rt) || rt->dst.dev->type != ARPHRD_TUNNEL6) {
 
 
 
 627			if (!IS_ERR(rt))
 628				ip_rt_put(rt);
 629			goto out;
 630		}
 631		skb_dst_set(skb2, &rt->dst);
 632	} else {
 
 633		if (ip_route_input(skb2, eiph->daddr, eiph->saddr, eiph->tos,
 634				   skb2->dev) ||
 635		    skb_dst(skb2)->dev->type != ARPHRD_TUNNEL6)
 636			goto out;
 637	}
 638
 639	/* change mtu on this route */
 640	if (rel_type == ICMP_DEST_UNREACH && rel_code == ICMP_FRAG_NEEDED) {
 641		if (rel_info > dst_mtu(skb_dst(skb2)))
 642			goto out;
 643
 644		skb_dst_update_pmtu_no_confirm(skb2, rel_info);
 645	}
 646
 647	icmp_send(skb2, rel_type, rel_code, htonl(rel_info));
 648
 649out:
 650	kfree_skb(skb2);
 651	return 0;
 652}
 653
 654static int
 655ip6ip6_err(struct sk_buff *skb, struct inet6_skb_parm *opt,
 656	   u8 type, u8 code, int offset, __be32 info)
 657{
 658	__u32 rel_info = ntohl(info);
 659	int err, rel_msg = 0;
 660	u8 rel_type = type;
 661	u8 rel_code = code;
 
 
 662
 663	err = ip6_tnl_err(skb, IPPROTO_IPV6, opt, &rel_type, &rel_code,
 664			  &rel_msg, &rel_info, offset);
 665	if (err < 0)
 666		return err;
 667
 668	if (rel_msg && pskb_may_pull(skb, offset + sizeof(struct ipv6hdr))) {
 669		struct rt6_info *rt;
 670		struct sk_buff *skb2 = skb_clone(skb, GFP_ATOMIC);
 671
 672		if (!skb2)
 673			return 0;
 674
 675		skb_dst_drop(skb2);
 676		skb_pull(skb2, offset);
 677		skb_reset_network_header(skb2);
 678
 679		/* Try to guess incoming interface */
 680		rt = rt6_lookup(dev_net(skb->dev), &ipv6_hdr(skb2)->saddr,
 681				NULL, 0, skb2, 0);
 682
 683		if (rt && rt->dst.dev)
 684			skb2->dev = rt->dst.dev;
 685
 686		icmpv6_send(skb2, rel_type, rel_code, rel_info);
 687
 688		ip6_rt_put(rt);
 
 689
 690		kfree_skb(skb2);
 691	}
 692
 693	return 0;
 694}
 695
 696static int
 697mplsip6_err(struct sk_buff *skb, struct inet6_skb_parm *opt,
 698	    u8 type, u8 code, int offset, __be32 info)
 699{
 700	__u32 rel_info = ntohl(info);
 701	int err, rel_msg = 0;
 702	u8 rel_type = type;
 703	u8 rel_code = code;
 704
 705	err = ip6_tnl_err(skb, IPPROTO_MPLS, opt, &rel_type, &rel_code,
 706			  &rel_msg, &rel_info, offset);
 707	return err;
 708}
 709
 710static int ip4ip6_dscp_ecn_decapsulate(const struct ip6_tnl *t,
 711				       const struct ipv6hdr *ipv6h,
 712				       struct sk_buff *skb)
 713{
 714	__u8 dsfield = ipv6_get_dsfield(ipv6h) & ~INET_ECN_MASK;
 715
 716	if (t->parms.flags & IP6_TNL_F_RCV_DSCP_COPY)
 717		ipv4_change_dsfield(ip_hdr(skb), INET_ECN_MASK, dsfield);
 718
 719	return IP6_ECN_decapsulate(ipv6h, skb);
 
 720}
 721
 722static int ip6ip6_dscp_ecn_decapsulate(const struct ip6_tnl *t,
 723				       const struct ipv6hdr *ipv6h,
 724				       struct sk_buff *skb)
 725{
 726	if (t->parms.flags & IP6_TNL_F_RCV_DSCP_COPY)
 727		ipv6_copy_dscp(ipv6_get_dsfield(ipv6h), ipv6_hdr(skb));
 728
 729	return IP6_ECN_decapsulate(ipv6h, skb);
 730}
 731
 732static inline int mplsip6_dscp_ecn_decapsulate(const struct ip6_tnl *t,
 733					       const struct ipv6hdr *ipv6h,
 734					       struct sk_buff *skb)
 735{
 736	/* ECN is not supported in AF_MPLS */
 737	return 0;
 738}
 739
 740__u32 ip6_tnl_get_cap(struct ip6_tnl *t,
 741			     const struct in6_addr *laddr,
 742			     const struct in6_addr *raddr)
 743{
 744	struct __ip6_tnl_parm *p = &t->parms;
 745	int ltype = ipv6_addr_type(laddr);
 746	int rtype = ipv6_addr_type(raddr);
 747	__u32 flags = 0;
 748
 749	if (ltype == IPV6_ADDR_ANY || rtype == IPV6_ADDR_ANY) {
 750		flags = IP6_TNL_F_CAP_PER_PACKET;
 751	} else if (ltype & (IPV6_ADDR_UNICAST|IPV6_ADDR_MULTICAST) &&
 752		   rtype & (IPV6_ADDR_UNICAST|IPV6_ADDR_MULTICAST) &&
 753		   !((ltype|rtype) & IPV6_ADDR_LOOPBACK) &&
 754		   (!((ltype|rtype) & IPV6_ADDR_LINKLOCAL) || p->link)) {
 755		if (ltype&IPV6_ADDR_UNICAST)
 756			flags |= IP6_TNL_F_CAP_XMIT;
 757		if (rtype&IPV6_ADDR_UNICAST)
 758			flags |= IP6_TNL_F_CAP_RCV;
 759	}
 760	return flags;
 761}
 762EXPORT_SYMBOL(ip6_tnl_get_cap);
 763
 764/* called with rcu_read_lock() */
 765int ip6_tnl_rcv_ctl(struct ip6_tnl *t,
 766				  const struct in6_addr *laddr,
 767				  const struct in6_addr *raddr)
 768{
 769	struct __ip6_tnl_parm *p = &t->parms;
 770	int ret = 0;
 771	struct net *net = t->net;
 772
 773	if ((p->flags & IP6_TNL_F_CAP_RCV) ||
 774	    ((p->flags & IP6_TNL_F_CAP_PER_PACKET) &&
 775	     (ip6_tnl_get_cap(t, laddr, raddr) & IP6_TNL_F_CAP_RCV))) {
 776		struct net_device *ldev = NULL;
 777
 778		if (p->link)
 779			ldev = dev_get_by_index_rcu(net, p->link);
 780
 781		if ((ipv6_addr_is_multicast(laddr) ||
 782		     likely(ipv6_chk_addr_and_flags(net, laddr, ldev, false,
 783						    0, IFA_F_TENTATIVE))) &&
 784		    ((p->flags & IP6_TNL_F_ALLOW_LOCAL_REMOTE) ||
 785		     likely(!ipv6_chk_addr_and_flags(net, raddr, ldev, true,
 786						     0, IFA_F_TENTATIVE))))
 787			ret = 1;
 
 788	}
 789	return ret;
 790}
 791EXPORT_SYMBOL_GPL(ip6_tnl_rcv_ctl);
 792
 793static int __ip6_tnl_rcv(struct ip6_tnl *tunnel, struct sk_buff *skb,
 794			 const struct tnl_ptk_info *tpi,
 795			 struct metadata_dst *tun_dst,
 796			 int (*dscp_ecn_decapsulate)(const struct ip6_tnl *t,
 797						const struct ipv6hdr *ipv6h,
 798						struct sk_buff *skb),
 799			 bool log_ecn_err)
 
 
 
 
 
 
 
 800{
 801	struct pcpu_sw_netstats *tstats;
 802	const struct ipv6hdr *ipv6h = ipv6_hdr(skb);
 803	int err;
 804
 805	if ((!(tpi->flags & TUNNEL_CSUM) &&
 806	     (tunnel->parms.i_flags & TUNNEL_CSUM)) ||
 807	    ((tpi->flags & TUNNEL_CSUM) &&
 808	     !(tunnel->parms.i_flags & TUNNEL_CSUM))) {
 809		tunnel->dev->stats.rx_crc_errors++;
 810		tunnel->dev->stats.rx_errors++;
 811		goto drop;
 812	}
 813
 814	if (tunnel->parms.i_flags & TUNNEL_SEQ) {
 815		if (!(tpi->flags & TUNNEL_SEQ) ||
 816		    (tunnel->i_seqno &&
 817		     (s32)(ntohl(tpi->seq) - tunnel->i_seqno) < 0)) {
 818			tunnel->dev->stats.rx_fifo_errors++;
 819			tunnel->dev->stats.rx_errors++;
 820			goto drop;
 821		}
 822		tunnel->i_seqno = ntohl(tpi->seq) + 1;
 823	}
 824
 825	skb->protocol = tpi->proto;
 
 
 826
 827	/* Warning: All skb pointers will be invalidated! */
 828	if (tunnel->dev->type == ARPHRD_ETHER) {
 829		if (!pskb_may_pull(skb, ETH_HLEN)) {
 830			tunnel->dev->stats.rx_length_errors++;
 831			tunnel->dev->stats.rx_errors++;
 832			goto drop;
 833		}
 834
 835		ipv6h = ipv6_hdr(skb);
 836		skb->protocol = eth_type_trans(skb, tunnel->dev);
 837		skb_postpull_rcsum(skb, eth_hdr(skb), ETH_HLEN);
 838	} else {
 839		skb->dev = tunnel->dev;
 840		skb_reset_mac_header(skb);
 841	}
 842
 843	skb_reset_network_header(skb);
 844	memset(skb->cb, 0, sizeof(struct inet6_skb_parm));
 845
 846	__skb_tunnel_rx(skb, tunnel->dev, tunnel->net);
 847
 848	err = dscp_ecn_decapsulate(tunnel, ipv6h, skb);
 849	if (unlikely(err)) {
 850		if (log_ecn_err)
 851			net_info_ratelimited("non-ECT from %pI6 with DS=%#x\n",
 852					     &ipv6h->saddr,
 853					     ipv6_get_dsfield(ipv6h));
 854		if (err > 1) {
 855			++tunnel->dev->stats.rx_frame_errors;
 856			++tunnel->dev->stats.rx_errors;
 857			goto drop;
 858		}
 859	}
 
 
 
 
 
 860
 861	tstats = this_cpu_ptr(tunnel->dev->tstats);
 862	u64_stats_update_begin(&tstats->syncp);
 863	tstats->rx_packets++;
 864	tstats->rx_bytes += skb->len;
 865	u64_stats_update_end(&tstats->syncp);
 866
 867	skb_scrub_packet(skb, !net_eq(tunnel->net, dev_net(tunnel->dev)));
 868
 869	if (tun_dst)
 870		skb_dst_set(skb, (struct dst_entry *)tun_dst);
 871
 872	gro_cells_receive(&tunnel->gro_cells, skb);
 873	return 0;
 874
 875drop:
 876	if (tun_dst)
 877		dst_release((struct dst_entry *)tun_dst);
 878	kfree_skb(skb);
 879	return 0;
 880}
 881
 882int ip6_tnl_rcv(struct ip6_tnl *t, struct sk_buff *skb,
 883		const struct tnl_ptk_info *tpi,
 884		struct metadata_dst *tun_dst,
 885		bool log_ecn_err)
 886{
 887	int (*dscp_ecn_decapsulate)(const struct ip6_tnl *t,
 888				    const struct ipv6hdr *ipv6h,
 889				    struct sk_buff *skb);
 890
 891	dscp_ecn_decapsulate = ip6ip6_dscp_ecn_decapsulate;
 892	if (tpi->proto == htons(ETH_P_IP))
 893		dscp_ecn_decapsulate = ip4ip6_dscp_ecn_decapsulate;
 894
 895	return __ip6_tnl_rcv(t, skb, tpi, tun_dst, dscp_ecn_decapsulate,
 896			     log_ecn_err);
 897}
 898EXPORT_SYMBOL(ip6_tnl_rcv);
 899
 900static const struct tnl_ptk_info tpi_v6 = {
 901	/* no tunnel info required for ipxip6. */
 902	.proto = htons(ETH_P_IPV6),
 903};
 904
 905static const struct tnl_ptk_info tpi_v4 = {
 906	/* no tunnel info required for ipxip6. */
 907	.proto = htons(ETH_P_IP),
 908};
 909
 910static const struct tnl_ptk_info tpi_mpls = {
 911	/* no tunnel info required for mplsip6. */
 912	.proto = htons(ETH_P_MPLS_UC),
 913};
 914
 915static int ipxip6_rcv(struct sk_buff *skb, u8 ipproto,
 916		      const struct tnl_ptk_info *tpi,
 917		      int (*dscp_ecn_decapsulate)(const struct ip6_tnl *t,
 918						  const struct ipv6hdr *ipv6h,
 919						  struct sk_buff *skb))
 920{
 921	struct ip6_tnl *t;
 922	const struct ipv6hdr *ipv6h = ipv6_hdr(skb);
 923	struct metadata_dst *tun_dst = NULL;
 924	int ret = -1;
 925
 926	rcu_read_lock();
 927	t = ip6_tnl_lookup(dev_net(skb->dev), skb->dev->ifindex, &ipv6h->saddr, &ipv6h->daddr);
 928
 929	if (t) {
 930		u8 tproto = READ_ONCE(t->parms.proto);
 931
 932		if (tproto != ipproto && tproto != 0)
 933			goto drop;
 934		if (!xfrm6_policy_check(NULL, XFRM_POLICY_IN, skb))
 935			goto drop;
 936		ipv6h = ipv6_hdr(skb);
 937		if (!ip6_tnl_rcv_ctl(t, &ipv6h->daddr, &ipv6h->saddr))
 938			goto drop;
 939		if (iptunnel_pull_header(skb, 0, tpi->proto, false))
 940			goto drop;
 941		if (t->parms.collect_md) {
 942			tun_dst = ipv6_tun_rx_dst(skb, 0, 0, 0);
 943			if (!tun_dst)
 944				goto drop;
 945		}
 946		ret = __ip6_tnl_rcv(t, skb, tpi, tun_dst, dscp_ecn_decapsulate,
 947				    log_ecn_error);
 948	}
 949
 950	rcu_read_unlock();
 
 951
 952	return ret;
 953
 954drop:
 955	rcu_read_unlock();
 956	kfree_skb(skb);
 957	return 0;
 958}
 959
 960static int ip4ip6_rcv(struct sk_buff *skb)
 961{
 962	return ipxip6_rcv(skb, IPPROTO_IPIP, &tpi_v4,
 963			  ip4ip6_dscp_ecn_decapsulate);
 964}
 965
 966static int ip6ip6_rcv(struct sk_buff *skb)
 967{
 968	return ipxip6_rcv(skb, IPPROTO_IPV6, &tpi_v6,
 969			  ip6ip6_dscp_ecn_decapsulate);
 970}
 971
 972static int mplsip6_rcv(struct sk_buff *skb)
 973{
 974	return ipxip6_rcv(skb, IPPROTO_MPLS, &tpi_mpls,
 975			  mplsip6_dscp_ecn_decapsulate);
 976}
 977
 978struct ipv6_tel_txoption {
 979	struct ipv6_txoptions ops;
 980	__u8 dst_opt[8];
 981};
 982
 983static void init_tel_txopt(struct ipv6_tel_txoption *opt, __u8 encap_limit)
 984{
 985	memset(opt, 0, sizeof(struct ipv6_tel_txoption));
 986
 987	opt->dst_opt[2] = IPV6_TLV_TNL_ENCAP_LIMIT;
 988	opt->dst_opt[3] = 1;
 989	opt->dst_opt[4] = encap_limit;
 990	opt->dst_opt[5] = IPV6_TLV_PADN;
 991	opt->dst_opt[6] = 1;
 992
 993	opt->ops.dst1opt = (struct ipv6_opt_hdr *) opt->dst_opt;
 994	opt->ops.opt_nflen = 8;
 995}
 996
 997/**
 998 * ip6_tnl_addr_conflict - compare packet addresses to tunnel's own
 999 *   @t: the outgoing tunnel device
1000 *   @hdr: IPv6 header from the incoming packet
1001 *
1002 * Description:
1003 *   Avoid trivial tunneling loop by checking that tunnel exit-point
1004 *   doesn't match source of incoming packet.
1005 *
1006 * Return:
1007 *   1 if conflict,
1008 *   0 else
1009 **/
1010
1011static inline bool
1012ip6_tnl_addr_conflict(const struct ip6_tnl *t, const struct ipv6hdr *hdr)
1013{
1014	return ipv6_addr_equal(&t->parms.raddr, &hdr->saddr);
1015}
1016
1017int ip6_tnl_xmit_ctl(struct ip6_tnl *t,
1018		     const struct in6_addr *laddr,
1019		     const struct in6_addr *raddr)
1020{
1021	struct __ip6_tnl_parm *p = &t->parms;
1022	int ret = 0;
1023	struct net *net = t->net;
1024
1025	if (t->parms.collect_md)
1026		return 1;
1027
1028	if ((p->flags & IP6_TNL_F_CAP_XMIT) ||
1029	    ((p->flags & IP6_TNL_F_CAP_PER_PACKET) &&
1030	     (ip6_tnl_get_cap(t, laddr, raddr) & IP6_TNL_F_CAP_XMIT))) {
1031		struct net_device *ldev = NULL;
1032
1033		rcu_read_lock();
1034		if (p->link)
1035			ldev = dev_get_by_index_rcu(net, p->link);
1036
1037		if (unlikely(!ipv6_chk_addr_and_flags(net, laddr, ldev, false,
1038						      0, IFA_F_TENTATIVE)))
1039			pr_warn("%s xmit: Local address not yet configured!\n",
1040				p->name);
1041		else if (!(p->flags & IP6_TNL_F_ALLOW_LOCAL_REMOTE) &&
1042			 !ipv6_addr_is_multicast(raddr) &&
1043			 unlikely(ipv6_chk_addr_and_flags(net, raddr, ldev,
1044							  true, 0, IFA_F_TENTATIVE)))
1045			pr_warn("%s xmit: Routing loop! Remote address found on this node!\n",
1046				p->name);
1047		else
1048			ret = 1;
1049		rcu_read_unlock();
1050	}
1051	return ret;
1052}
1053EXPORT_SYMBOL_GPL(ip6_tnl_xmit_ctl);
1054
1055/**
1056 * ip6_tnl_xmit - encapsulate packet and send
1057 *   @skb: the outgoing socket buffer
1058 *   @dev: the outgoing tunnel device
1059 *   @dsfield: dscp code for outer header
1060 *   @fl6: flow of tunneled packet
1061 *   @encap_limit: encapsulation limit
1062 *   @pmtu: Path MTU is stored if packet is too big
1063 *   @proto: next header value
1064 *
1065 * Description:
1066 *   Build new header and do some sanity checks on the packet before sending
1067 *   it.
1068 *
1069 * Return:
1070 *   0 on success
1071 *   -1 fail
1072 *   %-EMSGSIZE message too big. return mtu in this case.
1073 **/
1074
1075int ip6_tnl_xmit(struct sk_buff *skb, struct net_device *dev, __u8 dsfield,
1076		 struct flowi6 *fl6, int encap_limit, __u32 *pmtu,
1077		 __u8 proto)
 
 
 
1078{
 
1079	struct ip6_tnl *t = netdev_priv(dev);
1080	struct net *net = t->net;
1081	struct net_device_stats *stats = &t->dev->stats;
1082	struct ipv6hdr *ipv6h;
1083	struct ipv6_tel_txoption opt;
1084	struct dst_entry *dst = NULL, *ndst = NULL;
1085	struct net_device *tdev;
1086	int mtu;
1087	unsigned int eth_hlen = t->dev->type == ARPHRD_ETHER ? ETH_HLEN : 0;
1088	unsigned int psh_hlen = sizeof(struct ipv6hdr) + t->encap_hlen;
1089	unsigned int max_headroom = psh_hlen;
1090	bool use_cache = false;
1091	u8 hop_limit;
1092	int err = -1;
 
1093
1094	if (t->parms.collect_md) {
1095		hop_limit = skb_tunnel_info(skb)->key.ttl;
1096		goto route_lookup;
1097	} else {
1098		hop_limit = t->parms.hop_limit;
1099	}
1100
1101	/* NBMA tunnel */
1102	if (ipv6_addr_any(&t->parms.raddr)) {
1103		if (skb->protocol == htons(ETH_P_IPV6)) {
1104			struct in6_addr *addr6;
1105			struct neighbour *neigh;
1106			int addr_type;
1107
1108			if (!skb_dst(skb))
1109				goto tx_err_link_failure;
1110
1111			neigh = dst_neigh_lookup(skb_dst(skb),
1112						 &ipv6_hdr(skb)->daddr);
1113			if (!neigh)
1114				goto tx_err_link_failure;
1115
1116			addr6 = (struct in6_addr *)&neigh->primary_key;
1117			addr_type = ipv6_addr_type(addr6);
1118
1119			if (addr_type == IPV6_ADDR_ANY)
1120				addr6 = &ipv6_hdr(skb)->daddr;
1121
1122			memcpy(&fl6->daddr, addr6, sizeof(fl6->daddr));
1123			neigh_release(neigh);
1124		}
1125	} else if (t->parms.proto != 0 && !(t->parms.flags &
1126					    (IP6_TNL_F_USE_ORIG_TCLASS |
1127					     IP6_TNL_F_USE_ORIG_FWMARK))) {
1128		/* enable the cache only if neither the outer protocol nor the
1129		 * routing decision depends on the current inner header value
1130		 */
1131		use_cache = true;
1132	}
1133
1134	if (use_cache)
1135		dst = dst_cache_get(&t->dst_cache);
1136
1137	if (!ip6_tnl_xmit_ctl(t, &fl6->saddr, &fl6->daddr))
1138		goto tx_err_link_failure;
1139
1140	if (!dst) {
1141route_lookup:
1142		/* add dsfield to flowlabel for route lookup */
1143		fl6->flowlabel = ip6_make_flowinfo(dsfield, fl6->flowlabel);
1144
1145		dst = ip6_route_output(net, NULL, fl6);
1146
1147		if (dst->error)
1148			goto tx_err_link_failure;
1149		dst = xfrm_lookup(net, dst, flowi6_to_flowi(fl6), NULL, 0);
1150		if (IS_ERR(dst)) {
1151			err = PTR_ERR(dst);
1152			dst = NULL;
1153			goto tx_err_link_failure;
1154		}
1155		if (t->parms.collect_md && ipv6_addr_any(&fl6->saddr) &&
1156		    ipv6_dev_get_saddr(net, ip6_dst_idev(dst)->dev,
1157				       &fl6->daddr, 0, &fl6->saddr))
1158			goto tx_err_link_failure;
1159		ndst = dst;
1160	}
1161
1162	tdev = dst->dev;
1163
1164	if (tdev == dev) {
1165		stats->collisions++;
1166		net_warn_ratelimited("%s: Local routing loop detected!\n",
1167				     t->parms.name);
 
 
1168		goto tx_err_dst_release;
1169	}
1170	mtu = dst_mtu(dst) - eth_hlen - psh_hlen - t->tun_hlen;
1171	if (encap_limit >= 0) {
1172		max_headroom += 8;
1173		mtu -= 8;
1174	}
1175	mtu = max(mtu, skb->protocol == htons(ETH_P_IPV6) ?
1176		       IPV6_MIN_MTU : IPV4_MIN_MTU);
1177
1178	skb_dst_update_pmtu_no_confirm(skb, mtu);
1179	if (skb->len - t->tun_hlen - eth_hlen > mtu && !skb_is_gso(skb)) {
1180		*pmtu = mtu;
1181		err = -EMSGSIZE;
1182		goto tx_err_dst_release;
1183	}
1184
1185	if (t->err_count > 0) {
1186		if (time_before(jiffies,
1187				t->err_time + IP6TUNNEL_ERR_TIMEO)) {
1188			t->err_count--;
1189
1190			dst_link_failure(skb);
1191		} else {
1192			t->err_count = 0;
1193		}
1194	}
1195
1196	skb_scrub_packet(skb, !net_eq(t->net, dev_net(dev)));
1197
1198	/*
1199	 * Okay, now see if we can stuff it in the buffer as-is.
1200	 */
1201	max_headroom += LL_RESERVED_SPACE(tdev);
1202
1203	if (skb_headroom(skb) < max_headroom || skb_shared(skb) ||
1204	    (skb_cloned(skb) && !skb_clone_writable(skb, 0))) {
1205		struct sk_buff *new_skb;
1206
1207		new_skb = skb_realloc_headroom(skb, max_headroom);
1208		if (!new_skb)
1209			goto tx_err_dst_release;
1210
1211		if (skb->sk)
1212			skb_set_owner_w(new_skb, skb->sk);
1213		consume_skb(skb);
1214		skb = new_skb;
1215	}
 
 
1216
1217	if (t->parms.collect_md) {
1218		if (t->encap.type != TUNNEL_ENCAP_NONE)
1219			goto tx_err_dst_release;
1220	} else {
1221		if (use_cache && ndst)
1222			dst_cache_set_ip6(&t->dst_cache, ndst, &fl6->saddr);
1223	}
1224	skb_dst_set(skb, dst);
1225
1226	if (hop_limit == 0) {
1227		if (skb->protocol == htons(ETH_P_IP))
1228			hop_limit = ip_hdr(skb)->ttl;
1229		else if (skb->protocol == htons(ETH_P_IPV6))
1230			hop_limit = ipv6_hdr(skb)->hop_limit;
1231		else
1232			hop_limit = ip6_dst_hoplimit(dst);
1233	}
1234
1235	/* Calculate max headroom for all the headers and adjust
1236	 * needed_headroom if necessary.
1237	 */
1238	max_headroom = LL_RESERVED_SPACE(dst->dev) + sizeof(struct ipv6hdr)
1239			+ dst->header_len + t->hlen;
1240	if (max_headroom > dev->needed_headroom)
1241		dev->needed_headroom = max_headroom;
1242
1243	err = ip6_tnl_encap(skb, t, &proto, fl6);
1244	if (err)
1245		return err;
1246
 
1247	if (encap_limit >= 0) {
1248		init_tel_txopt(&opt, encap_limit);
1249		ipv6_push_frag_opts(skb, &opt.ops, &proto);
1250	}
1251
1252	skb_push(skb, sizeof(struct ipv6hdr));
1253	skb_reset_network_header(skb);
1254	ipv6h = ipv6_hdr(skb);
1255	ip6_flow_hdr(ipv6h, dsfield,
1256		     ip6_make_flowlabel(net, skb, fl6->flowlabel, true, fl6));
1257	ipv6h->hop_limit = hop_limit;
 
1258	ipv6h->nexthdr = proto;
1259	ipv6h->saddr = fl6->saddr;
1260	ipv6h->daddr = fl6->daddr;
1261	ip6tunnel_xmit(NULL, skb, dev);
 
 
 
 
 
 
 
 
 
 
 
 
 
1262	return 0;
1263tx_err_link_failure:
1264	stats->tx_carrier_errors++;
1265	dst_link_failure(skb);
1266tx_err_dst_release:
1267	dst_release(dst);
1268	return err;
1269}
1270EXPORT_SYMBOL(ip6_tnl_xmit);
1271
1272static inline int
1273ipxip6_tnl_xmit(struct sk_buff *skb, struct net_device *dev,
1274		u8 protocol)
1275{
1276	struct ip6_tnl *t = netdev_priv(dev);
1277	struct ipv6hdr *ipv6h;
1278	const struct iphdr  *iph;
1279	int encap_limit = -1;
1280	__u16 offset;
1281	struct flowi6 fl6;
1282	__u8 dsfield, orig_dsfield;
1283	__u32 mtu;
1284	u8 tproto;
1285	int err;
1286
1287	tproto = READ_ONCE(t->parms.proto);
1288	if (tproto != protocol && tproto != 0)
1289		return -1;
1290
1291	if (t->parms.collect_md) {
1292		struct ip_tunnel_info *tun_info;
1293		const struct ip_tunnel_key *key;
1294
1295		tun_info = skb_tunnel_info(skb);
1296		if (unlikely(!tun_info || !(tun_info->mode & IP_TUNNEL_INFO_TX) ||
1297			     ip_tunnel_info_af(tun_info) != AF_INET6))
1298			return -1;
1299		key = &tun_info->key;
1300		memset(&fl6, 0, sizeof(fl6));
1301		fl6.flowi6_proto = protocol;
1302		fl6.saddr = key->u.ipv6.src;
1303		fl6.daddr = key->u.ipv6.dst;
1304		fl6.flowlabel = key->label;
1305		dsfield =  key->tos;
1306		switch (protocol) {
1307		case IPPROTO_IPIP:
1308			iph = ip_hdr(skb);
1309			orig_dsfield = ipv4_get_dsfield(iph);
1310			break;
1311		case IPPROTO_IPV6:
1312			ipv6h = ipv6_hdr(skb);
1313			orig_dsfield = ipv6_get_dsfield(ipv6h);
1314			break;
1315		default:
1316			orig_dsfield = dsfield;
1317			break;
1318		}
1319	} else {
1320		if (!(t->parms.flags & IP6_TNL_F_IGN_ENCAP_LIMIT))
1321			encap_limit = t->parms.encap_limit;
1322		if (protocol == IPPROTO_IPV6) {
1323			offset = ip6_tnl_parse_tlv_enc_lim(skb,
1324						skb_network_header(skb));
1325			/* ip6_tnl_parse_tlv_enc_lim() might have
1326			 * reallocated skb->head
1327			 */
1328			if (offset > 0) {
1329				struct ipv6_tlv_tnl_enc_lim *tel;
1330
1331				tel = (void *)&skb_network_header(skb)[offset];
1332				if (tel->encap_limit == 0) {
1333					icmpv6_ndo_send(skb, ICMPV6_PARAMPROB,
1334							ICMPV6_HDR_FIELD, offset + 2);
1335					return -1;
1336				}
1337				encap_limit = tel->encap_limit - 1;
1338			}
1339		}
1340
1341		memcpy(&fl6, &t->fl.u.ip6, sizeof(fl6));
1342		fl6.flowi6_proto = protocol;
 
1343
1344		if (t->parms.flags & IP6_TNL_F_USE_ORIG_FWMARK)
1345			fl6.flowi6_mark = skb->mark;
1346		else
1347			fl6.flowi6_mark = t->parms.fwmark;
1348		switch (protocol) {
1349		case IPPROTO_IPIP:
1350			iph = ip_hdr(skb);
1351			orig_dsfield = ipv4_get_dsfield(iph);
1352			if (t->parms.flags & IP6_TNL_F_USE_ORIG_TCLASS)
1353				dsfield = orig_dsfield;
1354			else
1355				dsfield = ip6_tclass(t->parms.flowinfo);
1356			break;
1357		case IPPROTO_IPV6:
1358			ipv6h = ipv6_hdr(skb);
1359			orig_dsfield = ipv6_get_dsfield(ipv6h);
1360			if (t->parms.flags & IP6_TNL_F_USE_ORIG_TCLASS)
1361				dsfield = orig_dsfield;
1362			else
1363				dsfield = ip6_tclass(t->parms.flowinfo);
1364			if (t->parms.flags & IP6_TNL_F_USE_ORIG_FLOWLABEL)
1365				fl6.flowlabel |= ip6_flowlabel(ipv6h);
1366			break;
1367		default:
1368			orig_dsfield = dsfield = ip6_tclass(t->parms.flowinfo);
1369			break;
1370		}
1371	}
1372
1373	fl6.flowi6_uid = sock_net_uid(dev_net(dev), NULL);
1374	dsfield = INET_ECN_encapsulate(dsfield, orig_dsfield);
1375
1376	if (iptunnel_handle_offloads(skb, SKB_GSO_IPXIP6))
 
 
 
 
 
 
 
 
 
 
 
 
 
1377		return -1;
1378
1379	skb_set_inner_ipproto(skb, protocol);
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1380
1381	err = ip6_tnl_xmit(skb, dev, dsfield, &fl6, encap_limit, &mtu,
1382			   protocol);
1383	if (err != 0) {
1384		/* XXX: send ICMP error even if DF is not set. */
1385		if (err == -EMSGSIZE)
1386			switch (protocol) {
1387			case IPPROTO_IPIP:
1388				icmp_ndo_send(skb, ICMP_DEST_UNREACH,
1389					      ICMP_FRAG_NEEDED, htonl(mtu));
1390				break;
1391			case IPPROTO_IPV6:
1392				icmpv6_ndo_send(skb, ICMPV6_PKT_TOOBIG, 0, mtu);
1393				break;
1394			default:
1395				break;
1396			}
1397		return -1;
1398	}
1399
1400	return 0;
1401}
1402
1403static netdev_tx_t
1404ip6_tnl_start_xmit(struct sk_buff *skb, struct net_device *dev)
1405{
1406	struct ip6_tnl *t = netdev_priv(dev);
1407	struct net_device_stats *stats = &t->dev->stats;
1408	u8 ipproto;
1409	int ret;
1410
1411	if (!pskb_inet_may_pull(skb))
1412		goto tx_err;
1413
1414	switch (skb->protocol) {
1415	case htons(ETH_P_IP):
1416		ipproto = IPPROTO_IPIP;
1417		break;
1418	case htons(ETH_P_IPV6):
1419		if (ip6_tnl_addr_conflict(t, ipv6_hdr(skb)))
1420			goto tx_err;
1421		ipproto = IPPROTO_IPV6;
1422		break;
1423	case htons(ETH_P_MPLS_UC):
1424		ipproto = IPPROTO_MPLS;
1425		break;
1426	default:
1427		goto tx_err;
1428	}
1429
1430	ret = ipxip6_tnl_xmit(skb, dev, ipproto);
1431	if (ret < 0)
1432		goto tx_err;
1433
1434	return NETDEV_TX_OK;
1435
1436tx_err:
1437	stats->tx_errors++;
1438	stats->tx_dropped++;
1439	kfree_skb(skb);
1440	return NETDEV_TX_OK;
1441}
1442
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1443static void ip6_tnl_link_config(struct ip6_tnl *t)
1444{
1445	struct net_device *dev = t->dev;
1446	struct net_device *tdev = NULL;
1447	struct __ip6_tnl_parm *p = &t->parms;
1448	struct flowi6 *fl6 = &t->fl.u.ip6;
1449	unsigned int mtu;
1450	int t_hlen;
1451
1452	memcpy(dev->dev_addr, &p->laddr, sizeof(struct in6_addr));
1453	memcpy(dev->broadcast, &p->raddr, sizeof(struct in6_addr));
1454
1455	/* Set up flowi template */
1456	fl6->saddr = p->laddr;
1457	fl6->daddr = p->raddr;
1458	fl6->flowi6_oif = p->link;
1459	fl6->flowlabel = 0;
1460
1461	if (!(p->flags&IP6_TNL_F_USE_ORIG_TCLASS))
1462		fl6->flowlabel |= IPV6_TCLASS_MASK & p->flowinfo;
1463	if (!(p->flags&IP6_TNL_F_USE_ORIG_FLOWLABEL))
1464		fl6->flowlabel |= IPV6_FLOWLABEL_MASK & p->flowinfo;
1465
1466	p->flags &= ~(IP6_TNL_F_CAP_XMIT|IP6_TNL_F_CAP_RCV|IP6_TNL_F_CAP_PER_PACKET);
1467	p->flags |= ip6_tnl_get_cap(t, &p->laddr, &p->raddr);
1468
1469	if (p->flags&IP6_TNL_F_CAP_XMIT && p->flags&IP6_TNL_F_CAP_RCV)
1470		dev->flags |= IFF_POINTOPOINT;
1471	else
1472		dev->flags &= ~IFF_POINTOPOINT;
1473
1474	t->tun_hlen = 0;
1475	t->hlen = t->encap_hlen + t->tun_hlen;
1476	t_hlen = t->hlen + sizeof(struct ipv6hdr);
1477
1478	if (p->flags & IP6_TNL_F_CAP_XMIT) {
1479		int strict = (ipv6_addr_type(&p->raddr) &
1480			      (IPV6_ADDR_MULTICAST|IPV6_ADDR_LINKLOCAL));
1481
1482		struct rt6_info *rt = rt6_lookup(t->net,
1483						 &p->raddr, &p->laddr,
1484						 p->link, NULL, strict);
1485		if (rt) {
1486			tdev = rt->dst.dev;
1487			ip6_rt_put(rt);
1488		}
1489
1490		if (!tdev && p->link)
1491			tdev = __dev_get_by_index(t->net, p->link);
1492
1493		if (tdev) {
1494			dev->hard_header_len = tdev->hard_header_len + t_hlen;
1495			mtu = min_t(unsigned int, tdev->mtu, IP6_MAX_MTU);
1496
1497			dev->mtu = mtu - t_hlen;
1498			if (!(t->parms.flags & IP6_TNL_F_IGN_ENCAP_LIMIT))
1499				dev->mtu -= 8;
1500
1501			if (dev->mtu < IPV6_MIN_MTU)
1502				dev->mtu = IPV6_MIN_MTU;
1503		}
 
1504	}
1505}
1506
1507/**
1508 * ip6_tnl_change - update the tunnel parameters
1509 *   @t: tunnel to be changed
1510 *   @p: tunnel configuration parameters
1511 *
1512 * Description:
1513 *   ip6_tnl_change() updates the tunnel parameters
1514 **/
1515
1516static int
1517ip6_tnl_change(struct ip6_tnl *t, const struct __ip6_tnl_parm *p)
1518{
1519	t->parms.laddr = p->laddr;
1520	t->parms.raddr = p->raddr;
1521	t->parms.flags = p->flags;
1522	t->parms.hop_limit = p->hop_limit;
1523	t->parms.encap_limit = p->encap_limit;
1524	t->parms.flowinfo = p->flowinfo;
1525	t->parms.link = p->link;
1526	t->parms.proto = p->proto;
1527	t->parms.fwmark = p->fwmark;
1528	dst_cache_reset(&t->dst_cache);
1529	ip6_tnl_link_config(t);
1530	return 0;
1531}
1532
1533static int ip6_tnl_update(struct ip6_tnl *t, struct __ip6_tnl_parm *p)
1534{
1535	struct net *net = t->net;
1536	struct ip6_tnl_net *ip6n = net_generic(net, ip6_tnl_net_id);
1537	int err;
1538
1539	ip6_tnl_unlink(ip6n, t);
1540	synchronize_net();
1541	err = ip6_tnl_change(t, p);
1542	ip6_tnl_link(ip6n, t);
1543	netdev_state_change(t->dev);
1544	return err;
1545}
1546
1547static int ip6_tnl0_update(struct ip6_tnl *t, struct __ip6_tnl_parm *p)
1548{
1549	/* for default tnl0 device allow to change only the proto */
1550	t->parms.proto = p->proto;
1551	netdev_state_change(t->dev);
1552	return 0;
1553}
1554
1555static void
1556ip6_tnl_parm_from_user(struct __ip6_tnl_parm *p, const struct ip6_tnl_parm *u)
1557{
1558	p->laddr = u->laddr;
1559	p->raddr = u->raddr;
1560	p->flags = u->flags;
1561	p->hop_limit = u->hop_limit;
1562	p->encap_limit = u->encap_limit;
1563	p->flowinfo = u->flowinfo;
1564	p->link = u->link;
1565	p->proto = u->proto;
1566	memcpy(p->name, u->name, sizeof(u->name));
1567}
1568
1569static void
1570ip6_tnl_parm_to_user(struct ip6_tnl_parm *u, const struct __ip6_tnl_parm *p)
1571{
1572	u->laddr = p->laddr;
1573	u->raddr = p->raddr;
1574	u->flags = p->flags;
1575	u->hop_limit = p->hop_limit;
1576	u->encap_limit = p->encap_limit;
1577	u->flowinfo = p->flowinfo;
1578	u->link = p->link;
1579	u->proto = p->proto;
1580	memcpy(u->name, p->name, sizeof(u->name));
1581}
1582
1583/**
1584 * ip6_tnl_ioctl - configure ipv6 tunnels from userspace
1585 *   @dev: virtual device associated with tunnel
1586 *   @ifr: parameters passed from userspace
1587 *   @cmd: command to be performed
1588 *
1589 * Description:
1590 *   ip6_tnl_ioctl() is used for managing IPv6 tunnels
1591 *   from userspace.
1592 *
1593 *   The possible commands are the following:
1594 *     %SIOCGETTUNNEL: get tunnel parameters for device
1595 *     %SIOCADDTUNNEL: add tunnel matching given tunnel parameters
1596 *     %SIOCCHGTUNNEL: change tunnel parameters to those given
1597 *     %SIOCDELTUNNEL: delete tunnel
1598 *
1599 *   The fallback device "ip6tnl0", created during module
1600 *   initialization, can be used for creating other tunnel devices.
1601 *
1602 * Return:
1603 *   0 on success,
1604 *   %-EFAULT if unable to copy data to or from userspace,
1605 *   %-EPERM if current process hasn't %CAP_NET_ADMIN set
1606 *   %-EINVAL if passed tunnel parameters are invalid,
1607 *   %-EEXIST if changing a tunnel's parameters would cause a conflict
1608 *   %-ENODEV if attempting to change or delete a nonexisting device
1609 **/
1610
1611static int
1612ip6_tnl_ioctl(struct net_device *dev, struct ifreq *ifr, int cmd)
1613{
1614	int err = 0;
1615	struct ip6_tnl_parm p;
1616	struct __ip6_tnl_parm p1;
1617	struct ip6_tnl *t = netdev_priv(dev);
1618	struct net *net = t->net;
1619	struct ip6_tnl_net *ip6n = net_generic(net, ip6_tnl_net_id);
1620
1621	memset(&p1, 0, sizeof(p1));
1622
1623	switch (cmd) {
1624	case SIOCGETTUNNEL:
1625		if (dev == ip6n->fb_tnl_dev) {
1626			if (copy_from_user(&p, ifr->ifr_ifru.ifru_data, sizeof(p))) {
1627				err = -EFAULT;
1628				break;
1629			}
1630			ip6_tnl_parm_from_user(&p1, &p);
1631			t = ip6_tnl_locate(net, &p1, 0);
1632			if (IS_ERR(t))
1633				t = netdev_priv(dev);
1634		} else {
1635			memset(&p, 0, sizeof(p));
1636		}
1637		ip6_tnl_parm_to_user(&p, &t->parms);
1638		if (copy_to_user(ifr->ifr_ifru.ifru_data, &p, sizeof(p))) {
 
 
1639			err = -EFAULT;
1640		}
1641		break;
1642	case SIOCADDTUNNEL:
1643	case SIOCCHGTUNNEL:
1644		err = -EPERM;
1645		if (!ns_capable(net->user_ns, CAP_NET_ADMIN))
1646			break;
1647		err = -EFAULT;
1648		if (copy_from_user(&p, ifr->ifr_ifru.ifru_data, sizeof(p)))
1649			break;
1650		err = -EINVAL;
1651		if (p.proto != IPPROTO_IPV6 && p.proto != IPPROTO_IPIP &&
1652		    p.proto != 0)
1653			break;
1654		ip6_tnl_parm_from_user(&p1, &p);
1655		t = ip6_tnl_locate(net, &p1, cmd == SIOCADDTUNNEL);
1656		if (cmd == SIOCCHGTUNNEL) {
1657			if (!IS_ERR(t)) {
1658				if (t->dev != dev) {
1659					err = -EEXIST;
1660					break;
1661				}
1662			} else
1663				t = netdev_priv(dev);
1664			if (dev == ip6n->fb_tnl_dev)
1665				err = ip6_tnl0_update(t, &p1);
1666			else
1667				err = ip6_tnl_update(t, &p1);
 
 
1668		}
1669		if (!IS_ERR(t)) {
1670			err = 0;
1671			ip6_tnl_parm_to_user(&p, &t->parms);
1672			if (copy_to_user(ifr->ifr_ifru.ifru_data, &p, sizeof(p)))
1673				err = -EFAULT;
1674
1675		} else {
1676			err = PTR_ERR(t);
1677		}
1678		break;
1679	case SIOCDELTUNNEL:
1680		err = -EPERM;
1681		if (!ns_capable(net->user_ns, CAP_NET_ADMIN))
1682			break;
1683
1684		if (dev == ip6n->fb_tnl_dev) {
1685			err = -EFAULT;
1686			if (copy_from_user(&p, ifr->ifr_ifru.ifru_data, sizeof(p)))
1687				break;
1688			err = -ENOENT;
1689			ip6_tnl_parm_from_user(&p1, &p);
1690			t = ip6_tnl_locate(net, &p1, 0);
1691			if (IS_ERR(t))
1692				break;
1693			err = -EPERM;
1694			if (t->dev == ip6n->fb_tnl_dev)
1695				break;
1696			dev = t->dev;
1697		}
1698		err = 0;
1699		unregister_netdevice(dev);
1700		break;
1701	default:
1702		err = -EINVAL;
1703	}
1704	return err;
1705}
1706
1707/**
1708 * ip6_tnl_change_mtu - change mtu manually for tunnel device
1709 *   @dev: virtual device associated with tunnel
1710 *   @new_mtu: the new mtu
1711 *
1712 * Return:
1713 *   0 on success,
1714 *   %-EINVAL if mtu too small
1715 **/
1716
1717int ip6_tnl_change_mtu(struct net_device *dev, int new_mtu)
 
1718{
1719	struct ip6_tnl *tnl = netdev_priv(dev);
1720
1721	if (tnl->parms.proto == IPPROTO_IPV6) {
1722		if (new_mtu < IPV6_MIN_MTU)
1723			return -EINVAL;
1724	} else {
1725		if (new_mtu < ETH_MIN_MTU)
1726			return -EINVAL;
1727	}
1728	if (tnl->parms.proto == IPPROTO_IPV6 || tnl->parms.proto == 0) {
1729		if (new_mtu > IP6_MAX_MTU - dev->hard_header_len)
1730			return -EINVAL;
1731	} else {
1732		if (new_mtu > IP_MAX_MTU - dev->hard_header_len)
1733			return -EINVAL;
1734	}
1735	dev->mtu = new_mtu;
1736	return 0;
1737}
1738EXPORT_SYMBOL(ip6_tnl_change_mtu);
1739
1740int ip6_tnl_get_iflink(const struct net_device *dev)
1741{
1742	struct ip6_tnl *t = netdev_priv(dev);
1743
1744	return t->parms.link;
1745}
1746EXPORT_SYMBOL(ip6_tnl_get_iflink);
1747
1748int ip6_tnl_encap_add_ops(const struct ip6_tnl_encap_ops *ops,
1749			  unsigned int num)
1750{
1751	if (num >= MAX_IPTUN_ENCAP_OPS)
1752		return -ERANGE;
1753
1754	return !cmpxchg((const struct ip6_tnl_encap_ops **)
1755			&ip6tun_encaps[num],
1756			NULL, ops) ? 0 : -1;
1757}
1758EXPORT_SYMBOL(ip6_tnl_encap_add_ops);
1759
1760int ip6_tnl_encap_del_ops(const struct ip6_tnl_encap_ops *ops,
1761			  unsigned int num)
1762{
1763	int ret;
1764
1765	if (num >= MAX_IPTUN_ENCAP_OPS)
1766		return -ERANGE;
1767
1768	ret = (cmpxchg((const struct ip6_tnl_encap_ops **)
1769		       &ip6tun_encaps[num],
1770		       ops, NULL) == ops) ? 0 : -1;
1771
1772	synchronize_net();
1773
1774	return ret;
1775}
1776EXPORT_SYMBOL(ip6_tnl_encap_del_ops);
1777
1778int ip6_tnl_encap_setup(struct ip6_tnl *t,
1779			struct ip_tunnel_encap *ipencap)
1780{
1781	int hlen;
1782
1783	memset(&t->encap, 0, sizeof(t->encap));
1784
1785	hlen = ip6_encap_hlen(ipencap);
1786	if (hlen < 0)
1787		return hlen;
1788
1789	t->encap.type = ipencap->type;
1790	t->encap.sport = ipencap->sport;
1791	t->encap.dport = ipencap->dport;
1792	t->encap.flags = ipencap->flags;
1793
1794	t->encap_hlen = hlen;
1795	t->hlen = t->encap_hlen + t->tun_hlen;
1796
1797	return 0;
1798}
1799EXPORT_SYMBOL_GPL(ip6_tnl_encap_setup);
1800
1801static const struct net_device_ops ip6_tnl_netdev_ops = {
1802	.ndo_init	= ip6_tnl_dev_init,
1803	.ndo_uninit	= ip6_tnl_dev_uninit,
1804	.ndo_start_xmit = ip6_tnl_start_xmit,
1805	.ndo_do_ioctl	= ip6_tnl_ioctl,
1806	.ndo_change_mtu = ip6_tnl_change_mtu,
1807	.ndo_get_stats64 = dev_get_tstats64,
1808	.ndo_get_iflink = ip6_tnl_get_iflink,
1809};
1810
1811#define IPXIPX_FEATURES (NETIF_F_SG |		\
1812			 NETIF_F_FRAGLIST |	\
1813			 NETIF_F_HIGHDMA |	\
1814			 NETIF_F_GSO_SOFTWARE |	\
1815			 NETIF_F_HW_CSUM)
1816
1817/**
1818 * ip6_tnl_dev_setup - setup virtual tunnel device
1819 *   @dev: virtual device associated with tunnel
1820 *
1821 * Description:
1822 *   Initialize function pointers and device parameters
1823 **/
1824
1825static void ip6_tnl_dev_setup(struct net_device *dev)
1826{
 
 
1827	dev->netdev_ops = &ip6_tnl_netdev_ops;
1828	dev->header_ops = &ip_tunnel_header_ops;
1829	dev->needs_free_netdev = true;
1830	dev->priv_destructor = ip6_dev_free;
1831
1832	dev->type = ARPHRD_TUNNEL6;
 
 
 
 
 
1833	dev->flags |= IFF_NOARP;
1834	dev->addr_len = sizeof(struct in6_addr);
1835	dev->features |= NETIF_F_LLTX;
1836	netif_keep_dst(dev);
1837
1838	dev->features		|= IPXIPX_FEATURES;
1839	dev->hw_features	|= IPXIPX_FEATURES;
1840
1841	/* This perm addr will be used as interface identifier by IPv6 */
1842	dev->addr_assign_type = NET_ADDR_RANDOM;
1843	eth_random_addr(dev->perm_addr);
1844}
1845
1846
1847/**
1848 * ip6_tnl_dev_init_gen - general initializer for all tunnel devices
1849 *   @dev: virtual device associated with tunnel
1850 **/
1851
1852static inline int
1853ip6_tnl_dev_init_gen(struct net_device *dev)
1854{
1855	struct ip6_tnl *t = netdev_priv(dev);
1856	int ret;
1857	int t_hlen;
1858
1859	t->dev = dev;
1860	t->net = dev_net(dev);
1861	dev->tstats = netdev_alloc_pcpu_stats(struct pcpu_sw_netstats);
1862	if (!dev->tstats)
1863		return -ENOMEM;
1864
1865	ret = dst_cache_init(&t->dst_cache, GFP_KERNEL);
1866	if (ret)
1867		goto free_stats;
1868
1869	ret = gro_cells_init(&t->gro_cells, dev);
1870	if (ret)
1871		goto destroy_dst;
1872
1873	t->tun_hlen = 0;
1874	t->hlen = t->encap_hlen + t->tun_hlen;
1875	t_hlen = t->hlen + sizeof(struct ipv6hdr);
1876
1877	dev->type = ARPHRD_TUNNEL6;
1878	dev->hard_header_len = LL_MAX_HEADER + t_hlen;
1879	dev->mtu = ETH_DATA_LEN - t_hlen;
1880	if (!(t->parms.flags & IP6_TNL_F_IGN_ENCAP_LIMIT))
1881		dev->mtu -= 8;
1882	dev->min_mtu = ETH_MIN_MTU;
1883	dev->max_mtu = IP6_MAX_MTU - dev->hard_header_len;
1884
1885	dev_hold(dev);
1886	return 0;
1887
1888destroy_dst:
1889	dst_cache_destroy(&t->dst_cache);
1890free_stats:
1891	free_percpu(dev->tstats);
1892	dev->tstats = NULL;
1893
1894	return ret;
1895}
1896
1897/**
1898 * ip6_tnl_dev_init - initializer for all non fallback tunnel devices
1899 *   @dev: virtual device associated with tunnel
1900 **/
1901
1902static int ip6_tnl_dev_init(struct net_device *dev)
1903{
1904	struct ip6_tnl *t = netdev_priv(dev);
1905	int err = ip6_tnl_dev_init_gen(dev);
1906
1907	if (err)
1908		return err;
1909	ip6_tnl_link_config(t);
1910	if (t->parms.collect_md)
1911		netif_keep_dst(dev);
1912	return 0;
1913}
1914
1915/**
1916 * ip6_fb_tnl_dev_init - initializer for fallback tunnel device
1917 *   @dev: fallback device
1918 *
1919 * Return: 0
1920 **/
1921
1922static int __net_init ip6_fb_tnl_dev_init(struct net_device *dev)
1923{
1924	struct ip6_tnl *t = netdev_priv(dev);
1925	struct net *net = dev_net(dev);
1926	struct ip6_tnl_net *ip6n = net_generic(net, ip6_tnl_net_id);
 
 
 
 
1927
1928	t->parms.proto = IPPROTO_IPV6;
1929
1930	rcu_assign_pointer(ip6n->tnls_wc[0], t);
1931	return 0;
1932}
1933
1934static int ip6_tnl_validate(struct nlattr *tb[], struct nlattr *data[],
1935			    struct netlink_ext_ack *extack)
1936{
1937	u8 proto;
1938
1939	if (!data || !data[IFLA_IPTUN_PROTO])
1940		return 0;
1941
1942	proto = nla_get_u8(data[IFLA_IPTUN_PROTO]);
1943	if (proto != IPPROTO_IPV6 &&
1944	    proto != IPPROTO_IPIP &&
1945	    proto != 0)
1946		return -EINVAL;
1947
1948	return 0;
1949}
1950
1951static void ip6_tnl_netlink_parms(struct nlattr *data[],
1952				  struct __ip6_tnl_parm *parms)
1953{
1954	memset(parms, 0, sizeof(*parms));
1955
1956	if (!data)
1957		return;
1958
1959	if (data[IFLA_IPTUN_LINK])
1960		parms->link = nla_get_u32(data[IFLA_IPTUN_LINK]);
1961
1962	if (data[IFLA_IPTUN_LOCAL])
1963		parms->laddr = nla_get_in6_addr(data[IFLA_IPTUN_LOCAL]);
1964
1965	if (data[IFLA_IPTUN_REMOTE])
1966		parms->raddr = nla_get_in6_addr(data[IFLA_IPTUN_REMOTE]);
1967
1968	if (data[IFLA_IPTUN_TTL])
1969		parms->hop_limit = nla_get_u8(data[IFLA_IPTUN_TTL]);
1970
1971	if (data[IFLA_IPTUN_ENCAP_LIMIT])
1972		parms->encap_limit = nla_get_u8(data[IFLA_IPTUN_ENCAP_LIMIT]);
1973
1974	if (data[IFLA_IPTUN_FLOWINFO])
1975		parms->flowinfo = nla_get_be32(data[IFLA_IPTUN_FLOWINFO]);
1976
1977	if (data[IFLA_IPTUN_FLAGS])
1978		parms->flags = nla_get_u32(data[IFLA_IPTUN_FLAGS]);
1979
1980	if (data[IFLA_IPTUN_PROTO])
1981		parms->proto = nla_get_u8(data[IFLA_IPTUN_PROTO]);
1982
1983	if (data[IFLA_IPTUN_COLLECT_METADATA])
1984		parms->collect_md = true;
1985
1986	if (data[IFLA_IPTUN_FWMARK])
1987		parms->fwmark = nla_get_u32(data[IFLA_IPTUN_FWMARK]);
1988}
1989
1990static bool ip6_tnl_netlink_encap_parms(struct nlattr *data[],
1991					struct ip_tunnel_encap *ipencap)
1992{
1993	bool ret = false;
1994
1995	memset(ipencap, 0, sizeof(*ipencap));
1996
1997	if (!data)
1998		return ret;
1999
2000	if (data[IFLA_IPTUN_ENCAP_TYPE]) {
2001		ret = true;
2002		ipencap->type = nla_get_u16(data[IFLA_IPTUN_ENCAP_TYPE]);
2003	}
2004
2005	if (data[IFLA_IPTUN_ENCAP_FLAGS]) {
2006		ret = true;
2007		ipencap->flags = nla_get_u16(data[IFLA_IPTUN_ENCAP_FLAGS]);
2008	}
2009
2010	if (data[IFLA_IPTUN_ENCAP_SPORT]) {
2011		ret = true;
2012		ipencap->sport = nla_get_be16(data[IFLA_IPTUN_ENCAP_SPORT]);
2013	}
2014
2015	if (data[IFLA_IPTUN_ENCAP_DPORT]) {
2016		ret = true;
2017		ipencap->dport = nla_get_be16(data[IFLA_IPTUN_ENCAP_DPORT]);
2018	}
2019
2020	return ret;
2021}
2022
2023static int ip6_tnl_newlink(struct net *src_net, struct net_device *dev,
2024			   struct nlattr *tb[], struct nlattr *data[],
2025			   struct netlink_ext_ack *extack)
2026{
2027	struct net *net = dev_net(dev);
2028	struct ip6_tnl_net *ip6n = net_generic(net, ip6_tnl_net_id);
2029	struct ip_tunnel_encap ipencap;
2030	struct ip6_tnl *nt, *t;
2031	int err;
2032
2033	nt = netdev_priv(dev);
2034
2035	if (ip6_tnl_netlink_encap_parms(data, &ipencap)) {
2036		err = ip6_tnl_encap_setup(nt, &ipencap);
2037		if (err < 0)
2038			return err;
2039	}
2040
2041	ip6_tnl_netlink_parms(data, &nt->parms);
2042
2043	if (nt->parms.collect_md) {
2044		if (rtnl_dereference(ip6n->collect_md_tun))
2045			return -EEXIST;
2046	} else {
2047		t = ip6_tnl_locate(net, &nt->parms, 0);
2048		if (!IS_ERR(t))
2049			return -EEXIST;
2050	}
2051
2052	err = ip6_tnl_create2(dev);
2053	if (!err && tb[IFLA_MTU])
2054		ip6_tnl_change_mtu(dev, nla_get_u32(tb[IFLA_MTU]));
2055
2056	return err;
2057}
2058
2059static int ip6_tnl_changelink(struct net_device *dev, struct nlattr *tb[],
2060			      struct nlattr *data[],
2061			      struct netlink_ext_ack *extack)
2062{
2063	struct ip6_tnl *t = netdev_priv(dev);
2064	struct __ip6_tnl_parm p;
2065	struct net *net = t->net;
2066	struct ip6_tnl_net *ip6n = net_generic(net, ip6_tnl_net_id);
2067	struct ip_tunnel_encap ipencap;
2068
2069	if (dev == ip6n->fb_tnl_dev)
2070		return -EINVAL;
2071
2072	if (ip6_tnl_netlink_encap_parms(data, &ipencap)) {
2073		int err = ip6_tnl_encap_setup(t, &ipencap);
2074
2075		if (err < 0)
2076			return err;
2077	}
2078	ip6_tnl_netlink_parms(data, &p);
2079	if (p.collect_md)
2080		return -EINVAL;
2081
2082	t = ip6_tnl_locate(net, &p, 0);
2083	if (!IS_ERR(t)) {
2084		if (t->dev != dev)
2085			return -EEXIST;
2086	} else
2087		t = netdev_priv(dev);
2088
2089	return ip6_tnl_update(t, &p);
2090}
2091
2092static void ip6_tnl_dellink(struct net_device *dev, struct list_head *head)
2093{
2094	struct net *net = dev_net(dev);
2095	struct ip6_tnl_net *ip6n = net_generic(net, ip6_tnl_net_id);
2096
2097	if (dev != ip6n->fb_tnl_dev)
2098		unregister_netdevice_queue(dev, head);
2099}
2100
2101static size_t ip6_tnl_get_size(const struct net_device *dev)
2102{
2103	return
2104		/* IFLA_IPTUN_LINK */
2105		nla_total_size(4) +
2106		/* IFLA_IPTUN_LOCAL */
2107		nla_total_size(sizeof(struct in6_addr)) +
2108		/* IFLA_IPTUN_REMOTE */
2109		nla_total_size(sizeof(struct in6_addr)) +
2110		/* IFLA_IPTUN_TTL */
2111		nla_total_size(1) +
2112		/* IFLA_IPTUN_ENCAP_LIMIT */
2113		nla_total_size(1) +
2114		/* IFLA_IPTUN_FLOWINFO */
2115		nla_total_size(4) +
2116		/* IFLA_IPTUN_FLAGS */
2117		nla_total_size(4) +
2118		/* IFLA_IPTUN_PROTO */
2119		nla_total_size(1) +
2120		/* IFLA_IPTUN_ENCAP_TYPE */
2121		nla_total_size(2) +
2122		/* IFLA_IPTUN_ENCAP_FLAGS */
2123		nla_total_size(2) +
2124		/* IFLA_IPTUN_ENCAP_SPORT */
2125		nla_total_size(2) +
2126		/* IFLA_IPTUN_ENCAP_DPORT */
2127		nla_total_size(2) +
2128		/* IFLA_IPTUN_COLLECT_METADATA */
2129		nla_total_size(0) +
2130		/* IFLA_IPTUN_FWMARK */
2131		nla_total_size(4) +
2132		0;
2133}
2134
2135static int ip6_tnl_fill_info(struct sk_buff *skb, const struct net_device *dev)
2136{
2137	struct ip6_tnl *tunnel = netdev_priv(dev);
2138	struct __ip6_tnl_parm *parm = &tunnel->parms;
2139
2140	if (nla_put_u32(skb, IFLA_IPTUN_LINK, parm->link) ||
2141	    nla_put_in6_addr(skb, IFLA_IPTUN_LOCAL, &parm->laddr) ||
2142	    nla_put_in6_addr(skb, IFLA_IPTUN_REMOTE, &parm->raddr) ||
2143	    nla_put_u8(skb, IFLA_IPTUN_TTL, parm->hop_limit) ||
2144	    nla_put_u8(skb, IFLA_IPTUN_ENCAP_LIMIT, parm->encap_limit) ||
2145	    nla_put_be32(skb, IFLA_IPTUN_FLOWINFO, parm->flowinfo) ||
2146	    nla_put_u32(skb, IFLA_IPTUN_FLAGS, parm->flags) ||
2147	    nla_put_u8(skb, IFLA_IPTUN_PROTO, parm->proto) ||
2148	    nla_put_u32(skb, IFLA_IPTUN_FWMARK, parm->fwmark))
2149		goto nla_put_failure;
2150
2151	if (nla_put_u16(skb, IFLA_IPTUN_ENCAP_TYPE, tunnel->encap.type) ||
2152	    nla_put_be16(skb, IFLA_IPTUN_ENCAP_SPORT, tunnel->encap.sport) ||
2153	    nla_put_be16(skb, IFLA_IPTUN_ENCAP_DPORT, tunnel->encap.dport) ||
2154	    nla_put_u16(skb, IFLA_IPTUN_ENCAP_FLAGS, tunnel->encap.flags))
2155		goto nla_put_failure;
2156
2157	if (parm->collect_md)
2158		if (nla_put_flag(skb, IFLA_IPTUN_COLLECT_METADATA))
2159			goto nla_put_failure;
2160
2161	return 0;
2162
2163nla_put_failure:
2164	return -EMSGSIZE;
2165}
2166
2167struct net *ip6_tnl_get_link_net(const struct net_device *dev)
2168{
2169	struct ip6_tnl *tunnel = netdev_priv(dev);
2170
2171	return tunnel->net;
2172}
2173EXPORT_SYMBOL(ip6_tnl_get_link_net);
2174
2175static const struct nla_policy ip6_tnl_policy[IFLA_IPTUN_MAX + 1] = {
2176	[IFLA_IPTUN_LINK]		= { .type = NLA_U32 },
2177	[IFLA_IPTUN_LOCAL]		= { .len = sizeof(struct in6_addr) },
2178	[IFLA_IPTUN_REMOTE]		= { .len = sizeof(struct in6_addr) },
2179	[IFLA_IPTUN_TTL]		= { .type = NLA_U8 },
2180	[IFLA_IPTUN_ENCAP_LIMIT]	= { .type = NLA_U8 },
2181	[IFLA_IPTUN_FLOWINFO]		= { .type = NLA_U32 },
2182	[IFLA_IPTUN_FLAGS]		= { .type = NLA_U32 },
2183	[IFLA_IPTUN_PROTO]		= { .type = NLA_U8 },
2184	[IFLA_IPTUN_ENCAP_TYPE]		= { .type = NLA_U16 },
2185	[IFLA_IPTUN_ENCAP_FLAGS]	= { .type = NLA_U16 },
2186	[IFLA_IPTUN_ENCAP_SPORT]	= { .type = NLA_U16 },
2187	[IFLA_IPTUN_ENCAP_DPORT]	= { .type = NLA_U16 },
2188	[IFLA_IPTUN_COLLECT_METADATA]	= { .type = NLA_FLAG },
2189	[IFLA_IPTUN_FWMARK]		= { .type = NLA_U32 },
2190};
2191
2192static struct rtnl_link_ops ip6_link_ops __read_mostly = {
2193	.kind		= "ip6tnl",
2194	.maxtype	= IFLA_IPTUN_MAX,
2195	.policy		= ip6_tnl_policy,
2196	.priv_size	= sizeof(struct ip6_tnl),
2197	.setup		= ip6_tnl_dev_setup,
2198	.validate	= ip6_tnl_validate,
2199	.newlink	= ip6_tnl_newlink,
2200	.changelink	= ip6_tnl_changelink,
2201	.dellink	= ip6_tnl_dellink,
2202	.get_size	= ip6_tnl_get_size,
2203	.fill_info	= ip6_tnl_fill_info,
2204	.get_link_net	= ip6_tnl_get_link_net,
2205};
2206
2207static struct xfrm6_tunnel ip4ip6_handler __read_mostly = {
2208	.handler	= ip4ip6_rcv,
2209	.err_handler	= ip4ip6_err,
2210	.priority	=	1,
2211};
2212
2213static struct xfrm6_tunnel ip6ip6_handler __read_mostly = {
2214	.handler	= ip6ip6_rcv,
2215	.err_handler	= ip6ip6_err,
2216	.priority	=	1,
2217};
2218
2219static struct xfrm6_tunnel mplsip6_handler __read_mostly = {
2220	.handler	= mplsip6_rcv,
2221	.err_handler	= mplsip6_err,
2222	.priority	=	1,
2223};
2224
2225static void __net_exit ip6_tnl_destroy_tunnels(struct net *net, struct list_head *list)
2226{
2227	struct ip6_tnl_net *ip6n = net_generic(net, ip6_tnl_net_id);
2228	struct net_device *dev, *aux;
2229	int h;
2230	struct ip6_tnl *t;
 
2231
2232	for_each_netdev_safe(net, dev, aux)
2233		if (dev->rtnl_link_ops == &ip6_link_ops)
2234			unregister_netdevice_queue(dev, list);
2235
2236	for (h = 0; h < IP6_TUNNEL_HASH_SIZE; h++) {
2237		t = rtnl_dereference(ip6n->tnls_r_l[h]);
2238		while (t) {
2239			/* If dev is in the same netns, it has already
2240			 * been added to the list by the previous loop.
2241			 */
2242			if (!net_eq(dev_net(t->dev), net))
2243				unregister_netdevice_queue(t->dev, list);
2244			t = rtnl_dereference(t->next);
2245		}
2246	}
2247
2248	t = rtnl_dereference(ip6n->tnls_wc[0]);
2249	while (t) {
2250		/* If dev is in the same netns, it has already
2251		 * been added to the list by the previous loop.
2252		 */
2253		if (!net_eq(dev_net(t->dev), net))
2254			unregister_netdevice_queue(t->dev, list);
2255		t = rtnl_dereference(t->next);
2256	}
2257}
2258
2259static int __net_init ip6_tnl_init_net(struct net *net)
2260{
2261	struct ip6_tnl_net *ip6n = net_generic(net, ip6_tnl_net_id);
2262	struct ip6_tnl *t = NULL;
2263	int err;
2264
2265	ip6n->tnls[0] = ip6n->tnls_wc;
2266	ip6n->tnls[1] = ip6n->tnls_r_l;
2267
2268	if (!net_has_fallback_tunnels(net))
2269		return 0;
2270	err = -ENOMEM;
2271	ip6n->fb_tnl_dev = alloc_netdev(sizeof(struct ip6_tnl), "ip6tnl0",
2272					NET_NAME_UNKNOWN, ip6_tnl_dev_setup);
2273
2274	if (!ip6n->fb_tnl_dev)
2275		goto err_alloc_dev;
2276	dev_net_set(ip6n->fb_tnl_dev, net);
2277	ip6n->fb_tnl_dev->rtnl_link_ops = &ip6_link_ops;
2278	/* FB netdevice is special: we have one, and only one per netns.
2279	 * Allowing to move it to another netns is clearly unsafe.
2280	 */
2281	ip6n->fb_tnl_dev->features |= NETIF_F_NETNS_LOCAL;
2282
2283	err = ip6_fb_tnl_dev_init(ip6n->fb_tnl_dev);
2284	if (err < 0)
2285		goto err_register;
2286
2287	err = register_netdev(ip6n->fb_tnl_dev);
2288	if (err < 0)
2289		goto err_register;
2290
2291	t = netdev_priv(ip6n->fb_tnl_dev);
2292
2293	strcpy(t->parms.name, ip6n->fb_tnl_dev->name);
2294	return 0;
2295
2296err_register:
2297	free_netdev(ip6n->fb_tnl_dev);
2298err_alloc_dev:
2299	return err;
2300}
2301
2302static void __net_exit ip6_tnl_exit_batch_net(struct list_head *net_list)
2303{
2304	struct net *net;
2305	LIST_HEAD(list);
2306
2307	rtnl_lock();
2308	list_for_each_entry(net, net_list, exit_list)
2309		ip6_tnl_destroy_tunnels(net, &list);
2310	unregister_netdevice_many(&list);
2311	rtnl_unlock();
2312}
2313
2314static struct pernet_operations ip6_tnl_net_ops = {
2315	.init = ip6_tnl_init_net,
2316	.exit_batch = ip6_tnl_exit_batch_net,
2317	.id   = &ip6_tnl_net_id,
2318	.size = sizeof(struct ip6_tnl_net),
2319};
2320
2321/**
2322 * ip6_tunnel_init - register protocol and reserve needed resources
2323 *
2324 * Return: 0 on success
2325 **/
2326
2327static int __init ip6_tunnel_init(void)
2328{
2329	int  err;
2330
2331	if (!ipv6_mod_enabled())
2332		return -EOPNOTSUPP;
2333
2334	err = register_pernet_device(&ip6_tnl_net_ops);
2335	if (err < 0)
2336		goto out_pernet;
2337
2338	err = xfrm6_tunnel_register(&ip4ip6_handler, AF_INET);
2339	if (err < 0) {
2340		pr_err("%s: can't register ip4ip6\n", __func__);
2341		goto out_ip4ip6;
2342	}
2343
2344	err = xfrm6_tunnel_register(&ip6ip6_handler, AF_INET6);
2345	if (err < 0) {
2346		pr_err("%s: can't register ip6ip6\n", __func__);
2347		goto out_ip6ip6;
2348	}
2349
2350	if (ip6_tnl_mpls_supported()) {
2351		err = xfrm6_tunnel_register(&mplsip6_handler, AF_MPLS);
2352		if (err < 0) {
2353			pr_err("%s: can't register mplsip6\n", __func__);
2354			goto out_mplsip6;
2355		}
2356	}
2357
2358	err = rtnl_link_register(&ip6_link_ops);
2359	if (err < 0)
2360		goto rtnl_link_failed;
2361
2362	return 0;
2363
2364rtnl_link_failed:
2365	if (ip6_tnl_mpls_supported())
2366		xfrm6_tunnel_deregister(&mplsip6_handler, AF_MPLS);
2367out_mplsip6:
2368	xfrm6_tunnel_deregister(&ip6ip6_handler, AF_INET6);
2369out_ip6ip6:
2370	xfrm6_tunnel_deregister(&ip4ip6_handler, AF_INET);
2371out_ip4ip6:
2372	unregister_pernet_device(&ip6_tnl_net_ops);
2373out_pernet:
2374	return err;
2375}
2376
2377/**
2378 * ip6_tunnel_cleanup - free resources and unregister protocol
2379 **/
2380
2381static void __exit ip6_tunnel_cleanup(void)
2382{
2383	rtnl_link_unregister(&ip6_link_ops);
2384	if (xfrm6_tunnel_deregister(&ip4ip6_handler, AF_INET))
2385		pr_info("%s: can't deregister ip4ip6\n", __func__);
2386
2387	if (xfrm6_tunnel_deregister(&ip6ip6_handler, AF_INET6))
2388		pr_info("%s: can't deregister ip6ip6\n", __func__);
2389
2390	if (ip6_tnl_mpls_supported() &&
2391	    xfrm6_tunnel_deregister(&mplsip6_handler, AF_MPLS))
2392		pr_info("%s: can't deregister mplsip6\n", __func__);
2393	unregister_pernet_device(&ip6_tnl_net_ops);
2394}
2395
2396module_init(ip6_tunnel_init);
2397module_exit(ip6_tunnel_cleanup);