datapath/vport-gre.c

   1 /*
   2  * Copyright (c) 2010 Nicira Networks.
   3  * Distributed under the terms of the GNU GPL version 2.
   4  *
   5  * Significant portions of this file may be copied from parts of the Linux
   6  * kernel, by Linus Torvalds and others.
   7  */
   8
   9 #include <linux/if_arp.h>
  10 #include <linux/if_ether.h>
  11 #include <linux/ip.h>
  12 #include <linux/if_tunnel.h>
  13 #include <linux/if_vlan.h>
  14 #include <linux/in.h>
  15 #include <linux/in_route.h>
  16 #include <linux/jhash.h>
  17 #include <linux/kernel.h>
  18 #include <linux/version.h>
  19
  20 #include <net/dsfield.h>
  21 #include <net/dst.h>
  22 #include <net/icmp.h>
  23 #include <net/inet_ecn.h>
  24 #include <net/ip.h>
  25 #include <net/ipv6.h>
  26 #include <net/protocol.h>
  27 #include <net/route.h>
  28 #include <net/xfrm.h>
  29
  30 #include "actions.h"
  31 #include "datapath.h"
  32 #include "openvswitch/gre.h"
  33 #include "table.h"
  34 #include "vport.h"
  35
  36 /* The absolute minimum fragment size.  Note that there are many other
  37  * definitions of the minimum MTU. */
  38 #define IP_MIN_MTU 68
  39
  40 /* The GRE header is composed of a series of sections: a base and then a variable
  41  * number of options. */
  42 #define GRE_HEADER_SECTION 4
  43
  44 struct mutable_config {
  45         struct rcu_head rcu;
  46
  47         unsigned char eth_addr[ETH_ALEN];
  48         unsigned int mtu;
  49         struct gre_port_config port_config;
  50
  51         int tunnel_hlen; /* Tunnel header length. */
  52 };
  53
  54 struct gre_vport {
  55         struct tbl_node tbl_node;
  56
  57         char name[IFNAMSIZ];
  58
  59         /* Protected by RCU. */
  60         struct mutable_config *mutable;
  61 };
  62
  63 struct vport_ops gre_vport_ops;
  64
  65 /* Protected by RCU. */
  66 static struct tbl *port_table;
  67
  68 /* These are just used as an optimization: they don't require any kind of
  69  * synchronization because we could have just as easily read the value before
  70  * the port change happened. */
  71 static unsigned int key_local_remote_ports;
  72 static unsigned int key_remote_ports;
  73 static unsigned int local_remote_ports;
  74 static unsigned int remote_ports;
  75
  76 static inline struct gre_vport *
  77 gre_vport_priv(const struct vport *vport)
  78 {
  79         return vport_priv(vport);
  80 }
  81
  82 static inline struct vport *
  83 gre_vport_to_vport(const struct gre_vport *gre_vport)
  84 {
  85         return vport_from_priv(gre_vport);
  86 }
  87
  88 static inline struct gre_vport *
  89 gre_vport_table_cast(const struct tbl_node *node)
  90 {
  91         return container_of(node, struct gre_vport, tbl_node);
  92 }
  93
  94 /* RCU callback. */
  95 static void
  96 free_config(struct rcu_head *rcu)
  97 {
  98         struct mutable_config *c = container_of(rcu, struct mutable_config, rcu);
  99         kfree(c);
 100 }
 101
 102 static void
 103 assign_config_rcu(struct vport *vport, struct mutable_config *new_config)
 104 {
 105         struct gre_vport *gre_vport = gre_vport_priv(vport);
 106         struct mutable_config *old_config;
 107
 108         old_config = rcu_dereference(gre_vport->mutable);
 109         rcu_assign_pointer(gre_vport->mutable, new_config);
 110         call_rcu(&old_config->rcu, free_config);
 111 }
 112
 113 static unsigned int *
 114 find_port_pool(const struct mutable_config *mutable)
 115 {
 116         if (mutable->port_config.flags & GRE_F_IN_KEY_MATCH) {
 117                 if (mutable->port_config.saddr)
 118                         return &local_remote_ports;
 119                 else
 120                         return &remote_ports;
 121         } else {
 122                 if (mutable->port_config.saddr)
 123                         return &key_local_remote_ports;
 124                 else
 125                         return &key_remote_ports;
 126         }
 127 }
 128
 129 enum lookup_key {
 130         LOOKUP_SADDR            = 0,
 131         LOOKUP_DADDR            = 1,
 132         LOOKUP_KEY              = 2,
 133         LOOKUP_KEY_MATCH        = 3
 134 };
 135
 136 struct port_lookup_key {
 137         u32 vals[4];                    /* Contains enum lookup_key keys. */
 138         const struct mutable_config *mutable;
 139 };
 140
 141 /* Modifies 'target' to store the rcu_dereferenced pointer that was used to do
 142  * the comparision. */
 143 static int
 144 port_cmp(const struct tbl_node *node, void *target)
 145 {
 146         const struct gre_vport *gre_vport = gre_vport_table_cast(node);
 147         struct port_lookup_key *lookup = target;
 148
 149         lookup->mutable = rcu_dereference(gre_vport->mutable);
 150
 151         return ((lookup->mutable->port_config.flags & GRE_F_IN_KEY_MATCH) ==
 152                         lookup->vals[LOOKUP_KEY_MATCH]) &&
 153                lookup->mutable->port_config.daddr == lookup->vals[LOOKUP_DADDR] &&
 154                lookup->mutable->port_config.in_key == lookup->vals[LOOKUP_KEY] &&
 155                lookup->mutable->port_config.saddr == lookup->vals[LOOKUP_SADDR];
 156 }
 157
 158 static u32
 159 port_hash(struct port_lookup_key *lookup)
 160 {
 161         return jhash2(lookup->vals, ARRAY_SIZE(lookup->vals), 0);
 162 }
 163
 164 static int
 165 add_port(struct vport *vport)
 166 {
 167         struct gre_vport *gre_vport = gre_vport_priv(vport);
 168         struct port_lookup_key lookup;
 169         int err;
 170
 171         if (!port_table) {
 172                 struct tbl *new_table;
 173
 174                 new_table = tbl_create(0);
 175                 if (!new_table)
 176                         return -ENOMEM;
 177
 178                 rcu_assign_pointer(port_table, new_table);
 179
 180         } else if (tbl_count(port_table) > tbl_n_buckets(port_table)) {
 181                 struct tbl *old_table = port_table;
 182                 struct tbl *new_table;
 183
 184                 new_table = tbl_expand(old_table);
 185                 if (IS_ERR(new_table))
 186                         return PTR_ERR(new_table);
 187
 188                 rcu_assign_pointer(port_table, new_table);
 189                 tbl_deferred_destroy(old_table, NULL);
 190         }
 191
 192         lookup.vals[LOOKUP_SADDR] = gre_vport->mutable->port_config.saddr;
 193         lookup.vals[LOOKUP_DADDR] = gre_vport->mutable->port_config.daddr;
 194         lookup.vals[LOOKUP_KEY] = gre_vport->mutable->port_config.in_key;
 195         lookup.vals[LOOKUP_KEY_MATCH] = gre_vport->mutable->port_config.flags & GRE_F_IN_KEY_MATCH;
 196
 197         err = tbl_insert(port_table, &gre_vport->tbl_node, port_hash(&lookup));
 198         if (err)
 199                 return err;
 200
 201         (*find_port_pool(gre_vport->mutable))++;
 202
 203         return 0;
 204 }
 205
 206 static int
 207 del_port(struct vport *vport)
 208 {
 209         struct gre_vport *gre_vport = gre_vport_priv(vport);
 210         int err;
 211
 212         err = tbl_remove(port_table, &gre_vport->tbl_node);
 213         if (err)
 214                 return err;
 215
 216         (*find_port_pool(gre_vport->mutable))--;
 217
 218         return 0;
 219 }
 220
 221 #define FIND_PORT_KEY           (1 << 0)
 222 #define FIND_PORT_MATCH         (1 << 1)
 223 #define FIND_PORT_ANY           (FIND_PORT_KEY | FIND_PORT_MATCH)
 224
 225 static struct vport *
 226 find_port(__be32 saddr, __be32 daddr, __be32 key, int port_type,
 227           const struct mutable_config **mutable)
 228 {
 229         struct port_lookup_key lookup;
 230         struct tbl *table = rcu_dereference(port_table);
 231         struct tbl_node *tbl_node;
 232
 233         if (!table)
 234                 return NULL;
 235
 236         lookup.vals[LOOKUP_SADDR] = saddr;
 237         lookup.vals[LOOKUP_DADDR] = daddr;
 238
 239         if (port_type & FIND_PORT_KEY) {
 240                 lookup.vals[LOOKUP_KEY] = key;
 241                 lookup.vals[LOOKUP_KEY_MATCH] = 0;
 242
 243                 if (key_local_remote_ports) {
 244                         tbl_node = tbl_lookup(table, &lookup, port_hash(&lookup), port_cmp);
 245                         if (tbl_node)
 246                                 goto found;
 247                 }
 248
 249                 if (key_remote_ports) {
 250                         lookup.vals[LOOKUP_SADDR] = 0;
 251
 252                         tbl_node = tbl_lookup(table, &lookup, port_hash(&lookup), port_cmp);
 253                         if (tbl_node)
 254                                 goto found;
 255
 256                         lookup.vals[LOOKUP_SADDR] = saddr;
 257                 }
 258         }
 259
 260         if (port_type & FIND_PORT_MATCH) {
 261                 lookup.vals[LOOKUP_KEY] = 0;
 262                 lookup.vals[LOOKUP_KEY_MATCH] = GRE_F_IN_KEY_MATCH;
 263
 264                 if (local_remote_ports) {
 265                         tbl_node = tbl_lookup(table, &lookup, port_hash(&lookup), port_cmp);
 266                         if (tbl_node)
 267                                 goto found;
 268                 }
 269
 270                 if (remote_ports) {
 271                         lookup.vals[LOOKUP_SADDR] = 0;
 272
 273                         tbl_node = tbl_lookup(table, &lookup, port_hash(&lookup), port_cmp);
 274                         if (tbl_node)
 275                                 goto found;
 276                 }
 277         }
 278
 279         return NULL;
 280
 281 found:
 282         *mutable = lookup.mutable;
 283         return gre_vport_to_vport(gre_vport_table_cast(tbl_node));
 284 }
 285
 286 static bool
 287 check_ipv4_address(__be32 addr)
 288 {
 289         if (ipv4_is_multicast(addr) || ipv4_is_lbcast(addr)
 290             || ipv4_is_loopback(addr) || ipv4_is_zeronet(addr))
 291                 return false;
 292
 293         return true;
 294 }
 295
 296 static bool
 297 ipv4_should_icmp(struct sk_buff *skb)
 298 {
 299         struct iphdr *old_iph = ip_hdr(skb);
 300
 301         /* Don't respond to L2 broadcast. */
 302         if (is_multicast_ether_addr(eth_hdr(skb)->h_dest))
 303                 return false;
 304
 305         /* Don't respond to L3 broadcast or invalid addresses. */
 306         if (!check_ipv4_address(old_iph->daddr) ||
 307             !check_ipv4_address(old_iph->saddr))
 308                 return false;
 309
 310         /* Only respond to the first fragment. */
 311         if (old_iph->frag_off & htons(IP_OFFSET))
 312                 return false;
 313
 314         /* Don't respond to ICMP error messages. */
 315         if (old_iph->protocol == IPPROTO_ICMP) {
 316                 u8 icmp_type, *icmp_typep;
 317
 318                 icmp_typep = skb_header_pointer(skb, (u8 *)old_iph +
 319                                                 (old_iph->ihl << 2) +
 320                                                 offsetof(struct icmphdr, type) -
 321                                                 skb->data, sizeof(icmp_type),
 322                                                 &icmp_type);
 323
 324                 if (!icmp_typep)
 325                         return false;
 326
 327                 if (*icmp_typep > NR_ICMP_TYPES
 328                         || (*icmp_typep <= ICMP_PARAMETERPROB
 329                                 && *icmp_typep != ICMP_ECHOREPLY
 330                                 && *icmp_typep != ICMP_ECHO))
 331                         return false;
 332         }
 333
 334         return true;
 335 }
 336
 337 static void
 338 ipv4_build_icmp(struct sk_buff *skb, struct sk_buff *nskb,
 339                 unsigned int mtu, unsigned int payload_length)
 340 {
 341         struct iphdr *iph, *old_iph = ip_hdr(skb);
 342         struct icmphdr *icmph;
 343         u8 *payload;
 344
 345         iph = (struct iphdr *)skb_put(nskb, sizeof(struct iphdr));
 346         icmph = (struct icmphdr *)skb_put(nskb, sizeof(struct icmphdr));
 347         payload = skb_put(nskb, payload_length);
 348
 349         /* IP */
 350         iph->version            =       4;
 351         iph->ihl                =       sizeof(struct iphdr) >> 2;
 352         iph->tos                =       (old_iph->tos & IPTOS_TOS_MASK) |
 353                                         IPTOS_PREC_INTERNETCONTROL;
 354         iph->tot_len            =       htons(sizeof(struct iphdr)
 355                                               + sizeof(struct icmphdr)
 356                                               + payload_length);
 357         get_random_bytes(&iph->id, sizeof(iph->id));
 358         iph->frag_off           =       0;
 359         iph->ttl                =       IPDEFTTL;
 360         iph->protocol           =       IPPROTO_ICMP;
 361         iph->daddr              =       old_iph->saddr;
 362         iph->saddr              =       old_iph->daddr;
 363
 364         ip_send_check(iph);
 365
 366         /* ICMP */
 367         icmph->type             =       ICMP_DEST_UNREACH;
 368         icmph->code             =       ICMP_FRAG_NEEDED;
 369         icmph->un.gateway       =       htonl(mtu);
 370         icmph->checksum         =       0;
 371
 372         nskb->csum = csum_partial((u8 *)icmph, sizeof(struct icmphdr), 0);
 373         nskb->csum = skb_copy_and_csum_bits(skb, (u8 *)old_iph - skb->data,
 374                                             payload, payload_length,
 375                                             nskb->csum);
 376         icmph->checksum = csum_fold(nskb->csum);
 377 }
 378
 379 static bool
 380 ipv6_should_icmp(struct sk_buff *skb)
 381 {
 382         struct ipv6hdr *old_ipv6h = ipv6_hdr(skb);
 383         int addr_type;
 384         int payload_off = (u8 *)(old_ipv6h + 1) - skb->data;
 385         u8 nexthdr = ipv6_hdr(skb)->nexthdr;
 386
 387         /* Check source address is valid. */
 388         addr_type = ipv6_addr_type(&old_ipv6h->saddr);
 389         if (addr_type & IPV6_ADDR_MULTICAST || addr_type == IPV6_ADDR_ANY)
 390                 return false;
 391
 392         /* Don't reply to unspecified addresses. */
 393         if (ipv6_addr_type(&old_ipv6h->daddr) == IPV6_ADDR_ANY)
 394                 return false;
 395
 396         /* Don't respond to ICMP error messages. */
 397         payload_off = ipv6_skip_exthdr(skb, payload_off, &nexthdr);
 398         if (payload_off < 0)
 399                 return false;
 400
 401         if (nexthdr == NEXTHDR_ICMP) {
 402                 u8 icmp_type, *icmp_typep;
 403
 404                 icmp_typep = skb_header_pointer(skb, payload_off +
 405                                                 offsetof(struct icmp6hdr,
 406                                                         icmp6_type),
 407                                                 sizeof(icmp_type), &icmp_type);
 408
 409                 if (!icmp_typep || !(*icmp_typep & ICMPV6_INFOMSG_MASK))
 410                         return false;
 411         }
 412
 413         return true;
 414 }
 415
 416 static void
 417 ipv6_build_icmp(struct sk_buff *skb, struct sk_buff *nskb, unsigned int mtu,
 418                 unsigned int payload_length)
 419 {
 420         struct ipv6hdr *ipv6h, *old_ipv6h = ipv6_hdr(skb);
 421         struct icmp6hdr *icmp6h;
 422         u8 *payload;
 423
 424         ipv6h = (struct ipv6hdr *)skb_put(nskb, sizeof(struct ipv6hdr));
 425         icmp6h = (struct icmp6hdr *)skb_put(nskb, sizeof(struct icmp6hdr));
 426         payload = skb_put(nskb, payload_length);
 427
 428         /* IPv6 */
 429         ipv6h->version          =       6;
 430         ipv6h->priority         =       0;
 431         memset(&ipv6h->flow_lbl, 0, sizeof(ipv6h->flow_lbl));
 432         ipv6h->payload_len      =       htons(sizeof(struct icmp6hdr)
 433                                               + payload_length);
 434         ipv6h->nexthdr          =       NEXTHDR_ICMP;
 435         ipv6h->hop_limit        =       IPV6_DEFAULT_HOPLIMIT;
 436         ipv6_addr_copy(&ipv6h->daddr, &old_ipv6h->saddr);
 437         ipv6_addr_copy(&ipv6h->saddr, &old_ipv6h->daddr);
 438
 439         /* ICMPv6 */
 440         icmp6h->icmp6_type      =       ICMPV6_PKT_TOOBIG;
 441         icmp6h->icmp6_code      =       0;
 442         icmp6h->icmp6_cksum     =       0;
 443         icmp6h->icmp6_mtu       =       htonl(mtu);
 444
 445         nskb->csum = csum_partial((u8 *)icmp6h, sizeof(struct icmp6hdr), 0);
 446         nskb->csum = skb_copy_and_csum_bits(skb, (u8 *)old_ipv6h - skb->data,
 447                                             payload, payload_length,
 448                                             nskb->csum);
 449         icmp6h->icmp6_cksum = csum_ipv6_magic(&ipv6h->saddr, &ipv6h->daddr,
 450                                                 sizeof(struct icmp6hdr)
 451                                                 + payload_length,
 452                                                 ipv6h->nexthdr, nskb->csum);
 453 }
 454
 455 static bool
 456 send_frag_needed(struct vport *vport, const struct mutable_config *mutable,
 457                  struct sk_buff *skb, unsigned int mtu, __be32 flow_key)
 458 {
 459         unsigned int eth_hdr_len = ETH_HLEN;
 460         unsigned int total_length, header_length, payload_length;
 461         struct ethhdr *eh, *old_eh = eth_hdr(skb);
 462         struct sk_buff *nskb;
 463
 464         /* Sanity check */
 465         if (skb->protocol == htons(ETH_P_IP)) {
 466                 if (mtu < IP_MIN_MTU)
 467                         return false;
 468
 469                 if (!ipv4_should_icmp(skb))
 470                         return true;
 471         } else {
 472                 if (mtu < IPV6_MIN_MTU)
 473                         return false;
 474
 475                 /* In theory we should do PMTUD on IPv6 multicast messages but
 476                  * we don't have an address to send from so just fragment. */
 477                 if (ipv6_addr_type(&ipv6_hdr(skb)->daddr) & IPV6_ADDR_MULTICAST)
 478                         return false;
 479
 480                 if (!ipv6_should_icmp(skb))
 481                         return true;
 482         }
 483
 484         /* Allocate */
 485         if (old_eh->h_proto == htons(ETH_P_8021Q))
 486                 eth_hdr_len = VLAN_ETH_HLEN;
 487
 488         payload_length = skb->len - eth_hdr_len;
 489         if (skb->protocol == htons(ETH_P_IP)) {
 490                 header_length = sizeof(struct iphdr) + sizeof(struct icmphdr);
 491                 total_length = min_t(unsigned int, header_length +
 492                                                    payload_length, 576);
 493         } else {
 494                 header_length = sizeof(struct ipv6hdr) +
 495                                 sizeof(struct icmp6hdr);
 496                 total_length = min_t(unsigned int, header_length +
 497                                                   payload_length, IPV6_MIN_MTU);
 498         }
 499         total_length = min(total_length, mutable->mtu);
 500         payload_length = total_length - header_length;
 501
 502         nskb = dev_alloc_skb(NET_IP_ALIGN + eth_hdr_len + header_length +
 503                              payload_length);
 504         if (!nskb)
 505                 return false;
 506
 507         skb_reserve(nskb, NET_IP_ALIGN);
 508
 509         /* Ethernet / VLAN */
 510         eh = (struct ethhdr *)skb_put(nskb, eth_hdr_len);
 511         memcpy(eh->h_dest, old_eh->h_source, ETH_ALEN);
 512         memcpy(eh->h_source, mutable->eth_addr, ETH_ALEN);
 513         nskb->protocol = eh->h_proto = old_eh->h_proto;
 514         if (old_eh->h_proto == htons(ETH_P_8021Q)) {
 515                 struct vlan_ethhdr *vh = (struct vlan_ethhdr *)eh;
 516
 517                 vh->h_vlan_TCI = vlan_eth_hdr(skb)->h_vlan_TCI;
 518                 vh->h_vlan_encapsulated_proto = skb->protocol;
 519         }
 520         skb_reset_mac_header(nskb);
 521
 522         /* Protocol */
 523         if (skb->protocol == htons(ETH_P_IP))
 524                 ipv4_build_icmp(skb, nskb, mtu, payload_length);
 525         else
 526                 ipv6_build_icmp(skb, nskb, mtu, payload_length);
 527
 528         /* Assume that flow based keys are symmetric with respect to input
 529          * and output and use the key that we were going to put on the
 530          * outgoing packet for the fake received packet.  If the keys are
 531          * not symmetric then PMTUD needs to be disabled since we won't have
 532          * any way of synthesizing packets. */
 533         if (mutable->port_config.flags & GRE_F_IN_KEY_MATCH &&
 534             mutable->port_config.flags & GRE_F_OUT_KEY_ACTION)
 535                 OVS_CB(nskb)->tun_id = flow_key;
 536
 537         compute_ip_summed(nskb, false);
 538         vport_receive(vport, nskb);
 539
 540         return true;
 541 }
 542
 543 static struct sk_buff *
 544 check_headroom(struct sk_buff *skb, int headroom)
 545 {
 546         if (skb_headroom(skb) < headroom ||
 547             (skb_cloned(skb) && !skb_clone_writable(skb, 0))) {
 548                 struct sk_buff *nskb = skb_realloc_headroom(skb, headroom);
 549                 if (!nskb) {
 550                         kfree_skb(skb);
 551                         return ERR_PTR(-ENOMEM);
 552                 }
 553
 554                 set_skb_csum_bits(skb, nskb);
 555
 556                 if (skb->sk)
 557                         skb_set_owner_w(nskb, skb->sk);
 558
 559                 dev_kfree_skb(skb);
 560                 return nskb;
 561         }
 562
 563         return skb;
 564 }
 565
 566 static void
 567 create_gre_header(struct sk_buff *skb, const struct mutable_config *mutable)
 568 {
 569         struct iphdr *iph = ip_hdr(skb);
 570         __be16 *flags = (__be16 *)(iph + 1);
 571         __be16 *protocol = flags + 1;
 572         __be32 *options = (__be32 *)((u8 *)iph + mutable->tunnel_hlen
 573                                                - GRE_HEADER_SECTION);
 574
 575         *protocol = htons(ETH_P_TEB);
 576         *flags = 0;
 577
 578         /* Work backwards over the options so the checksum is last. */
 579         if (mutable->port_config.out_key ||
 580             mutable->port_config.flags & GRE_F_OUT_KEY_ACTION) {
 581                 *flags |= GRE_KEY;
 582
 583                 if (mutable->port_config.flags & GRE_F_OUT_KEY_ACTION)
 584                         *options = OVS_CB(skb)->tun_id;
 585                 else
 586                         *options = mutable->port_config.out_key;
 587
 588                 options--;
 589         }
 590
 591         if (mutable->port_config.flags & GRE_F_OUT_CSUM) {
 592                 *flags |= GRE_CSUM;
 593
 594                 *options = 0;
 595                 *(__sum16 *)options = csum_fold(skb_checksum(skb,
 596                                                 sizeof(struct iphdr),
 597                                                 skb->len - sizeof(struct iphdr),
 598                                                 0));
 599         }
 600 }
 601
 602 static int
 603 check_checksum(struct sk_buff *skb)
 604 {
 605         struct iphdr *iph = ip_hdr(skb);
 606         __be16 flags = *(__be16 *)(iph + 1);
 607         __sum16 csum = 0;
 608
 609         if (flags & GRE_CSUM) {
 610                 switch (skb->ip_summed) {
 611                 case CHECKSUM_COMPLETE:
 612                         csum = csum_fold(skb->csum);
 613
 614                         if (!csum)
 615                                 break;
 616                         /* Fall through. */
 617
 618                 case CHECKSUM_NONE:
 619                         skb->csum = 0;
 620                         csum = __skb_checksum_complete(skb);
 621                         skb->ip_summed = CHECKSUM_COMPLETE;
 622                         break;
 623                 }
 624         }
 625
 626         return (csum == 0);
 627 }
 628
 629 static int
 630 parse_gre_header(struct iphdr *iph, __be16 *flags, __be32 *key)
 631 {
 632         /* IP and ICMP protocol handlers check that the IHL is valid. */
 633         __be16 *flagsp = (__be16 *)((u8 *)iph + (iph->ihl << 2));
 634         __be16 *protocol = flagsp + 1;
 635         __be32 *options = (__be32 *)(protocol + 1);
 636         int hdr_len;
 637
 638         *flags = *flagsp;
 639
 640         if (*flags & (GRE_VERSION | GRE_ROUTING))
 641                 return -EINVAL;
 642
 643         if (*protocol != htons(ETH_P_TEB))
 644                 return -EINVAL;
 645
 646         hdr_len = GRE_HEADER_SECTION;
 647
 648         if (*flags & GRE_CSUM) {
 649                 hdr_len += GRE_HEADER_SECTION;
 650                 options++;
 651         }
 652
 653         if (*flags & GRE_KEY) {
 654                 hdr_len += GRE_HEADER_SECTION;
 655
 656                 *key = *options;
 657                 options++;
 658         } else
 659                 *key = 0;
 660
 661         if (*flags & GRE_SEQ)
 662                 hdr_len += GRE_HEADER_SECTION;
 663
 664         return hdr_len;
 665 }
 666
 667 static inline u8
 668 ecn_encapsulate(u8 tos, struct sk_buff *skb)
 669 {
 670         u8 inner;
 671
 672         if (skb->protocol == htons(ETH_P_IP))
 673                 inner = ((struct iphdr *)skb_network_header(skb))->tos;
 674         else if (skb->protocol == htons(ETH_P_IPV6))
 675                 inner = ipv6_get_dsfield((struct ipv6hdr *)skb_network_header(skb));
 676         else
 677                 inner = 0;
 678
 679         return INET_ECN_encapsulate(tos, inner);
 680 }
 681
 682 static inline void
 683 ecn_decapsulate(u8 tos, struct sk_buff *skb)
 684 {
 685         if (INET_ECN_is_ce(tos)) {
 686                 __be16 protocol = skb->protocol;
 687                 unsigned int nw_header = skb_network_header(skb) - skb->data;
 688
 689                 if (skb->protocol == htons(ETH_P_8021Q)) {
 690                         if (unlikely(!pskb_may_pull(skb, VLAN_ETH_HLEN)))
 691                                 return;
 692
 693                         protocol = vlan_eth_hdr(skb)->h_vlan_encapsulated_proto;
 694                         nw_header += VLAN_HLEN;
 695                 }
 696
 697                 if (protocol == htons(ETH_P_IP)) {
 698                         if (unlikely(!pskb_may_pull(skb, nw_header
 699                             + sizeof(struct iphdr))))
 700                                 return;
 701
 702                         IP_ECN_set_ce((struct iphdr *)(nw_header + skb->data));
 703                 } else if (protocol == htons(ETH_P_IPV6)) {
 704                         if (unlikely(!pskb_may_pull(skb, nw_header
 705                             + sizeof(struct ipv6hdr))))
 706                                 return;
 707
 708                         IP6_ECN_set_ce((struct ipv6hdr *)(nw_header
 709                                                           + skb->data));
 710                 }
 711         }
 712 }
 713
 714 static struct sk_buff *
 715 handle_gso(struct sk_buff *skb)
 716 {
 717         if (skb_is_gso(skb)) {
 718                 struct sk_buff *nskb = skb_gso_segment(skb, NETIF_F_SG);
 719
 720                 dev_kfree_skb(skb);
 721                 return nskb;
 722         }
 723
 724         return skb;
 725 }
 726
 727 static int
 728 handle_csum_offload(struct sk_buff *skb)
 729 {
 730         if (skb->ip_summed == CHECKSUM_PARTIAL)
 731                 return skb_checksum_help(skb);
 732         else {
 733                 skb->ip_summed = CHECKSUM_NONE;
 734                 return 0;
 735         }
 736 }
 737
 738 /* Called with rcu_read_lock and bottom-halves disabled. */
 739 static void
 740 gre_err(struct sk_buff *skb, u32 info)
 741 {
 742         struct vport *vport;
 743         const struct mutable_config *mutable;
 744         const int type = icmp_hdr(skb)->type;
 745         const int code = icmp_hdr(skb)->code;
 746         int mtu = ntohs(icmp_hdr(skb)->un.frag.mtu);
 747
 748         struct iphdr *iph;
 749         __be16 flags;
 750         __be32 key;
 751         int tunnel_hdr_len, tot_hdr_len;
 752         unsigned int orig_mac_header;
 753         unsigned int orig_nw_header;
 754
 755         if (type != ICMP_DEST_UNREACH || code != ICMP_FRAG_NEEDED)
 756                 return;
 757
 758         /* The mimimum size packet that we would actually be able to process:
 759          * encapsulating IP header, minimum GRE header, Ethernet header,
 760          * inner IPv4 header. */
 761         if (!pskb_may_pull(skb, sizeof(struct iphdr) + GRE_HEADER_SECTION +
 762                                 ETH_HLEN + sizeof(struct iphdr)))
 763                 return;
 764
 765         iph = (struct iphdr *)skb->data;
 766
 767         tunnel_hdr_len = parse_gre_header(iph, &flags, &key);
 768         if (tunnel_hdr_len < 0)
 769                 return;
 770
 771         vport = find_port(iph->saddr, iph->daddr, key, FIND_PORT_ANY, &mutable);
 772         if (!vport)
 773                 return;
 774
 775         /* Packets received by this function were previously sent by us, so
 776          * any comparisons should be to the output values, not the input.
 777          * However, it's not really worth it to have a hash table based on
 778          * output keys (especially since ICMP error handling of tunneled packets
 779          * isn't that reliable anyways).  Therefore, we do a lookup based on the
 780          * out key as if it were the in key and then check to see if the input
 781          * and output keys are the same. */
 782         if (mutable->port_config.in_key != mutable->port_config.out_key)
 783                 return;
 784
 785         if (!!(mutable->port_config.flags & GRE_F_IN_KEY_MATCH) !=
 786             !!(mutable->port_config.flags & GRE_F_OUT_KEY_ACTION))
 787                 return;
 788
 789         if ((mutable->port_config.flags & GRE_F_OUT_CSUM) && !(flags & GRE_CSUM))
 790                 return;
 791
 792         tunnel_hdr_len += iph->ihl << 2;
 793
 794         orig_mac_header = skb_mac_header(skb) - skb->data;
 795         orig_nw_header = skb_network_header(skb) - skb->data;
 796         skb_set_mac_header(skb, tunnel_hdr_len);
 797
 798         tot_hdr_len = tunnel_hdr_len + ETH_HLEN;
 799
 800         skb->protocol = eth_hdr(skb)->h_proto;
 801         if (skb->protocol == htons(ETH_P_8021Q)) {
 802                 tot_hdr_len += VLAN_HLEN;
 803                 skb->protocol = vlan_eth_hdr(skb)->h_vlan_encapsulated_proto;
 804         }
 805
 806         skb_set_network_header(skb, tot_hdr_len);
 807         mtu -= tot_hdr_len;
 808
 809         if (skb->protocol == htons(ETH_P_IP))
 810                 tot_hdr_len += sizeof(struct iphdr);
 811         else if (skb->protocol == htons(ETH_P_IPV6))
 812                 tot_hdr_len += sizeof(struct ipv6hdr);
 813         else
 814                 goto out;
 815
 816         if (!pskb_may_pull(skb, tot_hdr_len))
 817                 goto out;
 818
 819         if (skb->protocol == htons(ETH_P_IP)) {
 820                 if (mtu < IP_MIN_MTU) {
 821                         if (ntohs(ip_hdr(skb)->tot_len) >= IP_MIN_MTU)
 822                                 mtu = IP_MIN_MTU;
 823                         else
 824                                 goto out;
 825                 }
 826
 827         } else if (skb->protocol == htons(ETH_P_IPV6)) {
 828                 if (mtu < IPV6_MIN_MTU) {
 829                         unsigned int packet_length = sizeof(struct ipv6hdr) +
 830                                               ntohs(ipv6_hdr(skb)->payload_len);
 831
 832                         if (packet_length >= IPV6_MIN_MTU
 833                             || ntohs(ipv6_hdr(skb)->payload_len) == 0)
 834                                 mtu = IPV6_MIN_MTU;
 835                         else
 836                                 goto out;
 837                 }
 838         }
 839
 840         __pskb_pull(skb, tunnel_hdr_len);
 841         send_frag_needed(vport, mutable, skb, mtu, key);
 842         skb_push(skb, tunnel_hdr_len);
 843
 844 out:
 845         skb_set_mac_header(skb, orig_mac_header);
 846         skb_set_network_header(skb, orig_nw_header);
 847         skb->protocol = htons(ETH_P_IP);
 848 }
 849
 850 /* Called with rcu_read_lock and bottom-halves disabled. */
 851 static int
 852 gre_rcv(struct sk_buff *skb)
 853 {
 854         struct vport *vport;
 855         const struct mutable_config *mutable;
 856         int hdr_len;
 857         struct iphdr *iph;
 858         __be16 flags;
 859         __be32 key;
 860
 861         if (!pskb_may_pull(skb, GRE_HEADER_SECTION + ETH_HLEN))
 862                 goto error;
 863
 864         if (!check_checksum(skb))
 865                 goto error;
 866
 867         iph = ip_hdr(skb);
 868
 869         hdr_len = parse_gre_header(iph, &flags, &key);
 870         if (hdr_len < 0)
 871                 goto error;
 872
 873         vport = find_port(iph->daddr, iph->saddr, key, FIND_PORT_ANY, &mutable);
 874         if (!vport) {
 875                 icmp_send(skb, ICMP_DEST_UNREACH, ICMP_PORT_UNREACH, 0);
 876                 goto error;
 877         }
 878
 879         if ((mutable->port_config.flags & GRE_F_IN_CSUM) && !(flags & GRE_CSUM)) {
 880                 vport_record_error(vport, VPORT_E_RX_CRC);
 881                 goto error;
 882         }
 883
 884         if (!pskb_pull(skb, hdr_len) || !pskb_may_pull(skb, ETH_HLEN)) {
 885                 vport_record_error(vport, VPORT_E_RX_ERROR);
 886                 goto error;
 887         }
 888
 889         skb->pkt_type = PACKET_HOST;
 890         skb->protocol = eth_type_trans(skb, skb->dev);
 891         skb_postpull_rcsum(skb, skb_transport_header(skb), hdr_len + ETH_HLEN);
 892
 893         skb_dst_drop(skb);
 894         nf_reset(skb);
 895         secpath_reset(skb);
 896         skb_reset_network_header(skb);
 897
 898         ecn_decapsulate(iph->tos, skb);
 899
 900         if (mutable->port_config.flags & GRE_F_IN_KEY_MATCH)
 901                 OVS_CB(skb)->tun_id = key;
 902         else
 903                 OVS_CB(skb)->tun_id = 0;
 904
 905         skb_push(skb, ETH_HLEN);
 906         compute_ip_summed(skb, false);
 907
 908         vport_receive(vport, skb);
 909
 910         return 0;
 911
 912 error:
 913         kfree_skb(skb);
 914         return 0;
 915 }
 916
 917 static int
 918 build_packet(struct vport *vport, const struct mutable_config *mutable,
 919              struct iphdr *iph, struct rtable *rt, int max_headroom, int mtu,
 920              struct sk_buff *skb)
 921 {
 922         int err;
 923         struct iphdr *new_iph;
 924         int orig_len = skb->len;
 925         __be16 frag_off = iph->frag_off;
 926
 927         skb = check_headroom(skb, max_headroom);
 928         if (unlikely(IS_ERR(skb)))
 929                 goto error;
 930
 931         err = handle_csum_offload(skb);
 932         if (err)
 933                 goto error_free;
 934
 935         if (skb->protocol == htons(ETH_P_IP)) {
 936                 struct iphdr *old_iph = ip_hdr(skb);
 937
 938                 if ((old_iph->frag_off & htons(IP_DF)) &&
 939                     mtu < ntohs(old_iph->tot_len)) {
 940                         if (send_frag_needed(vport, mutable, skb, mtu, OVS_CB(skb)->tun_id))
 941                                 goto error_free;
 942                 }
 943
 944         } else if (skb->protocol == htons(ETH_P_IPV6)) {
 945                 unsigned int packet_length = skb->len - ETH_HLEN
 946                         - (eth_hdr(skb)->h_proto == htons(ETH_P_8021Q) ? VLAN_HLEN : 0);
 947
 948                 /* IPv6 requires PMTUD if the packet is above the minimum MTU. */
 949                 if (packet_length > IPV6_MIN_MTU)
 950                         frag_off = htons(IP_DF);
 951
 952                 if (mtu < packet_length) {
 953                         if (send_frag_needed(vport, mutable, skb, mtu, OVS_CB(skb)->tun_id))
 954                                 goto error_free;
 955                 }
 956         }
 957
 958         skb_reset_transport_header(skb);
 959         new_iph = (struct iphdr *)skb_push(skb, mutable->tunnel_hlen);
 960         skb_reset_network_header(skb);
 961
 962         memcpy(new_iph, iph, sizeof(struct iphdr));
 963         new_iph->frag_off = frag_off;
 964         ip_select_ident(new_iph, &rt->u.dst, NULL);
 965
 966         create_gre_header(skb, mutable);
 967
 968         /* Allow our local IP stack to fragment the outer packet even if the
 969          * DF bit is set as a last resort. */
 970         skb->local_df = 1;
 971
 972         memset(&(IPCB(skb)->opt), 0, sizeof(IPCB(skb)->opt));
 973         IPCB(skb)->flags = 0;
 974
 975         err = ip_local_out(skb);
 976         if (likely(net_xmit_eval(err) == 0))
 977                 return orig_len;
 978         else {
 979                 vport_record_error(vport, VPORT_E_TX_ERROR);
 980                 return 0;
 981         }
 982
 983 error_free:
 984         kfree_skb(skb);
 985 error:
 986         vport_record_error(vport, VPORT_E_TX_DROPPED);
 987
 988         return 0;
 989 }
 990
 991 static int
 992 gre_send(struct vport *vport, struct sk_buff *skb)
 993 {
 994         struct gre_vport *gre_vport = gre_vport_priv(vport);
 995         const struct mutable_config *mutable = rcu_dereference(gre_vport->mutable);
 996
 997         struct iphdr *old_iph;
 998         struct ipv6hdr *old_ipv6h;
 999         int orig_len;
1000         struct iphdr iph;
1001         struct rtable *rt;
1002         int max_headroom;
1003         int mtu;
1004
1005         /* Validate the protocol headers before we try to use them. */
1006         if (skb->protocol == htons(ETH_P_8021Q)) {
1007                 if (unlikely(!pskb_may_pull(skb, VLAN_ETH_HLEN)))
1008                         goto error_free;
1009
1010                 skb->protocol = vlan_eth_hdr(skb)->h_vlan_encapsulated_proto;
1011                 skb_set_network_header(skb, VLAN_ETH_HLEN);
1012         }
1013
1014         if (skb->protocol == htons(ETH_P_IP)) {
1015                 if (unlikely(!pskb_may_pull(skb, skb_network_header(skb)
1016                     + sizeof(struct iphdr) - skb->data)))
1017                         skb->protocol = 0;
1018         } else if (skb->protocol == htons(ETH_P_IPV6)) {
1019                 if (unlikely(!pskb_may_pull(skb, skb_network_header(skb)
1020                     + sizeof(struct ipv6hdr) - skb->data)))
1021                         skb->protocol = 0;
1022         }
1023
1024         old_iph = ip_hdr(skb);
1025         old_ipv6h = ipv6_hdr(skb);
1026
1027         iph.tos = mutable->port_config.tos;
1028         if (mutable->port_config.flags & GRE_F_TOS_INHERIT) {
1029                 if (skb->protocol == htons(ETH_P_IP))
1030                         iph.tos = old_iph->tos;
1031                 else if (skb->protocol == htons(ETH_P_IPV6))
1032                         iph.tos = ipv6_get_dsfield(ipv6_hdr(skb));
1033         }
1034         iph.tos = ecn_encapsulate(iph.tos, skb);
1035
1036         {
1037                 struct flowi fl = { .nl_u = { .ip4_u =
1038                                               { .daddr = mutable->port_config.daddr,
1039                                                 .saddr = mutable->port_config.saddr,
1040                                                 .tos = RT_TOS(iph.tos) } },
1041                                     .proto = IPPROTO_GRE };
1042
1043                 if (ip_route_output_key(&init_net, &rt, &fl))
1044                         goto error_free;
1045         }
1046
1047         iph.ttl = mutable->port_config.ttl;
1048         if (mutable->port_config.flags & GRE_F_TTL_INHERIT) {
1049                 if (skb->protocol == htons(ETH_P_IP))
1050                         iph.ttl = old_iph->ttl;
1051                 else if (skb->protocol == htons(ETH_P_IPV6))
1052                         iph.ttl = old_ipv6h->hop_limit;
1053         }
1054         if (!iph.ttl)
1055                 iph.ttl = dst_metric(&rt->u.dst, RTAX_HOPLIMIT);
1056
1057         iph.frag_off = (mutable->port_config.flags & GRE_F_PMTUD) ? htons(IP_DF) : 0;
1058         if (iph.frag_off)
1059                 mtu = dst_mtu(&rt->u.dst)
1060                         - ETH_HLEN
1061                         - mutable->tunnel_hlen
1062                         - (eth_hdr(skb)->h_proto == htons(ETH_P_8021Q) ? VLAN_HLEN : 0);
1063         else
1064                 mtu = mutable->mtu;
1065
1066         if (skb->protocol == htons(ETH_P_IP)) {
1067                 iph.frag_off |= old_iph->frag_off & htons(IP_DF);
1068                 mtu = max(mtu, IP_MIN_MTU);
1069
1070         } else if (skb->protocol == htons(ETH_P_IPV6))
1071                 mtu = max(mtu, IPV6_MIN_MTU);
1072
1073         iph.version = 4;
1074         iph.ihl = sizeof(struct iphdr) >> 2;
1075         iph.protocol = IPPROTO_GRE;
1076         iph.daddr = rt->rt_dst;
1077         iph.saddr = rt->rt_src;
1078
1079         nf_reset(skb);
1080         secpath_reset(skb);
1081         skb_dst_drop(skb);
1082         skb_dst_set(skb, &rt->u.dst);
1083
1084         /* If we are doing GSO on a pskb it is better to make sure that the
1085          * headroom is correct now.  We will only have to copy the portion in
1086          * the linear data area and GSO will preserve headroom when it creates
1087          * the segments.  This is particularly beneficial on Xen where we get
1088          * lots of GSO pskbs.  Conversely, we delay copying if it is just to
1089          * get our own writable clone because GSO may do the copy for us. */
1090         max_headroom = LL_RESERVED_SPACE(rt->u.dst.dev) + rt->u.dst.header_len
1091                         + mutable->tunnel_hlen;
1092
1093         if (skb_headroom(skb) < max_headroom) {
1094                 skb = check_headroom(skb, max_headroom);
1095                 if (unlikely(IS_ERR(skb))) {
1096                         vport_record_error(vport, VPORT_E_TX_DROPPED);
1097                         goto error;
1098                 }
1099         }
1100
1101         forward_ip_summed(skb);
1102         vswitch_skb_checksum_setup(skb);
1103
1104         skb = handle_gso(skb);
1105         if (unlikely(IS_ERR(skb))) {
1106                 vport_record_error(vport, VPORT_E_TX_DROPPED);
1107                 goto error;
1108         }
1109
1110         /* Process GSO segments.  Try to do any work for the entire packet that
1111          * doesn't involve actually writing to it before this point. */
1112         orig_len = 0;
1113         do {
1114                 struct sk_buff *next_skb = skb->next;
1115                 skb->next = NULL;
1116
1117                 orig_len += build_packet(vport, mutable, &iph, rt, max_headroom, mtu, skb);
1118
1119                 skb = next_skb;
1120         } while (skb);
1121
1122         return orig_len;
1123
1124 error_free:
1125         kfree_skb(skb);
1126         vport_record_error(vport, VPORT_E_TX_ERROR);
1127 error:
1128         return 0;
1129 }
1130
1131 static struct net_protocol gre_protocol_handlers = {
1132         .handler        =       gre_rcv,
1133         .err_handler    =       gre_err,
1134 };
1135
1136 static int
1137 gre_init(void)
1138 {
1139         int err;
1140
1141         err = inet_add_protocol(&gre_protocol_handlers, IPPROTO_GRE);
1142         if (err)
1143                 printk(KERN_WARNING "openvswitch: cannot register gre protocol handler\n");
1144
1145         return err;
1146 }
1147
1148 static void
1149 gre_exit(void)
1150 {
1151         tbl_destroy(port_table, NULL);
1152         inet_del_protocol(&gre_protocol_handlers, IPPROTO_GRE);
1153 }
1154
1155 static int
1156 set_config(const struct vport *cur_vport, struct mutable_config *mutable,
1157            const void __user *uconfig)
1158 {
1159         const struct vport *old_vport;
1160         const struct mutable_config *old_mutable;
1161         int port_type;
1162
1163         if (copy_from_user(&mutable->port_config, uconfig, sizeof(struct gre_port_config)))
1164                 return -EFAULT;
1165
1166         if (mutable->port_config.daddr == 0)
1167                 return -EINVAL;
1168
1169         if (mutable->port_config.flags & GRE_F_IN_KEY_MATCH) {
1170                 port_type = FIND_PORT_MATCH;
1171                 mutable->port_config.in_key = 0;
1172         } else
1173                 port_type = FIND_PORT_KEY;
1174
1175         old_vport = find_port(mutable->port_config.saddr,
1176                               mutable->port_config.daddr,
1177                               mutable->port_config.in_key, port_type,
1178                               &old_mutable);
1179
1180         if (old_vport && old_vport != cur_vport)
1181                 return -EEXIST;
1182
1183         if (mutable->port_config.flags & GRE_F_OUT_KEY_ACTION)
1184                 mutable->port_config.out_key = 0;
1185
1186         mutable->tunnel_hlen = sizeof(struct iphdr) + GRE_HEADER_SECTION;
1187
1188         if (mutable->port_config.flags & GRE_F_OUT_CSUM)
1189                 mutable->tunnel_hlen += GRE_HEADER_SECTION;
1190
1191         if (mutable->port_config.out_key ||
1192             mutable->port_config.flags & GRE_F_OUT_KEY_ACTION)
1193                 mutable->tunnel_hlen += GRE_HEADER_SECTION;
1194
1195         return 0;
1196 }
1197
1198 static struct vport *
1199 gre_create(const char *name, const void __user *config)
1200 {
1201         struct vport *vport;
1202         struct gre_vport *gre_vport;
1203         int err;
1204
1205         vport = vport_alloc(sizeof(struct gre_vport), &gre_vport_ops);
1206         if (IS_ERR(vport)) {
1207                 err = PTR_ERR(vport);
1208                 goto error;
1209         }
1210
1211         gre_vport = gre_vport_priv(vport);
1212
1213         strcpy(gre_vport->name, name);
1214
1215         gre_vport->mutable = kmalloc(sizeof(struct mutable_config), GFP_KERNEL);
1216         if (!gre_vport->mutable) {
1217                 err = -ENOMEM;
1218                 goto error_free_vport;
1219         }
1220
1221         vport_gen_ether_addr(gre_vport->mutable->eth_addr);
1222         gre_vport->mutable->mtu = ETH_DATA_LEN;
1223
1224         err = set_config(NULL, gre_vport->mutable, config);
1225         if (err)
1226                 goto error_free_mutable;
1227
1228         err = add_port(vport);
1229         if (err)
1230                 goto error_free_mutable;
1231
1232         return vport;
1233
1234 error_free_mutable:
1235         kfree(gre_vport->mutable);
1236 error_free_vport:
1237         vport_free(vport);
1238 error:
1239         return ERR_PTR(err);
1240 }
1241
1242 static int
1243 gre_modify(struct vport *vport, const void __user *config)
1244 {
1245         struct gre_vport *gre_vport = gre_vport_priv(vport);
1246         struct mutable_config *mutable;
1247         int err;
1248         int update_hash = 0;
1249
1250         mutable = kmemdup(gre_vport->mutable, sizeof(struct mutable_config), GFP_KERNEL);
1251         if (!mutable) {
1252                 err = -ENOMEM;
1253                 goto error;
1254         }
1255
1256         err = set_config(vport, mutable, config);
1257         if (err)
1258                 goto error_free;
1259
1260         /* Only remove the port from the hash table if something that would
1261          * affect the lookup has changed. */
1262         if (gre_vport->mutable->port_config.saddr != mutable->port_config.saddr ||
1263             gre_vport->mutable->port_config.daddr != mutable->port_config.daddr ||
1264             gre_vport->mutable->port_config.in_key != mutable->port_config.in_key ||
1265             (gre_vport->mutable->port_config.flags & GRE_F_IN_KEY_MATCH) !=
1266             (mutable->port_config.flags & GRE_F_IN_KEY_MATCH))
1267                 update_hash = 1;
1268
1269
1270         /* This update is not atomic but the lookup uses the config, which
1271          * serves as an inherent double check. */
1272         if (update_hash) {
1273                 err = del_port(vport);
1274                 if (err)
1275                         goto error_free;
1276         }
1277
1278         assign_config_rcu(vport, mutable);
1279
1280         if (update_hash) {
1281                 err = add_port(vport);
1282                 if (err)
1283                         goto error_free;
1284         }
1285
1286         return 0;
1287
1288 error_free:
1289         kfree(mutable);
1290 error:
1291         return err;
1292 }
1293
1294 static int
1295 gre_destroy(struct vport *vport)
1296 {
1297         struct gre_vport *gre_vport = gre_vport_priv(vport);
1298         int port_type;
1299         const struct mutable_config *old_mutable;
1300
1301         /* Do a hash table lookup to make sure that the port exists.  It should
1302          * exist but might not if a modify failed earlier. */
1303         if (gre_vport->mutable->port_config.flags & GRE_F_IN_KEY_MATCH)
1304                 port_type = FIND_PORT_MATCH;
1305         else
1306                 port_type = FIND_PORT_KEY;
1307
1308         if (vport == find_port(gre_vport->mutable->port_config.saddr,
1309             gre_vport->mutable->port_config.daddr,
1310             gre_vport->mutable->port_config.in_key, port_type, &old_mutable))
1311                 del_port(vport);
1312
1313         kfree(gre_vport->mutable);
1314         vport_free(vport);
1315
1316         return 0;
1317 }
1318
1319 static int
1320 gre_set_mtu(struct vport *vport, int mtu)
1321 {
1322         struct gre_vport *gre_vport = gre_vport_priv(vport);
1323         struct mutable_config *mutable;
1324         struct dp_port *dp_port;
1325
1326         mutable = kmemdup(gre_vport->mutable, sizeof(struct mutable_config), GFP_KERNEL);
1327         if (!mutable)
1328                 return -ENOMEM;
1329
1330         mutable->mtu = mtu;
1331         assign_config_rcu(vport, mutable);
1332
1333         dp_port = vport_get_dp_port(vport);
1334         if (dp_port)
1335                 set_internal_devs_mtu(dp_port->dp);
1336
1337         return 0;
1338 }
1339
1340 static int
1341 gre_set_addr(struct vport *vport, const unsigned char *addr)
1342 {
1343         struct gre_vport *gre_vport = gre_vport_priv(vport);
1344         struct mutable_config *mutable;
1345
1346         mutable = kmemdup(gre_vport->mutable, sizeof(struct mutable_config), GFP_KERNEL);
1347         if (!mutable)
1348                 return -ENOMEM;
1349
1350         memcpy(mutable->eth_addr, addr, ETH_ALEN);
1351         assign_config_rcu(vport, mutable);
1352
1353         return 0;
1354 }
1355
1356
1357 static const char *
1358 gre_get_name(const struct vport *vport)
1359 {
1360         const struct gre_vport *gre_vport = gre_vport_priv(vport);
1361         return gre_vport->name;
1362 }
1363
1364 static const unsigned char *
1365 gre_get_addr(const struct vport *vport)
1366 {
1367         const struct gre_vport *gre_vport = gre_vport_priv(vport);
1368         return rcu_dereference(gre_vport->mutable)->eth_addr;
1369 }
1370
1371 static unsigned
1372 gre_get_dev_flags(const struct vport *vport)
1373 {
1374         return IFF_UP | IFF_RUNNING | IFF_LOWER_UP;
1375 }
1376
1377 static int
1378 gre_is_running(const struct vport *vport)
1379 {
1380         return 1;
1381 }
1382
1383 static unsigned char
1384 gre_get_operstate(const struct vport *vport)
1385 {
1386         return IF_OPER_UP;
1387 }
1388
1389 static int
1390 gre_get_mtu(const struct vport *vport)
1391 {
1392         const struct gre_vport *gre_vport = gre_vport_priv(vport);
1393         return rcu_dereference(gre_vport->mutable)->mtu;
1394 }
1395
1396 struct vport_ops gre_vport_ops = {
1397         .type           = "gre",
1398         .flags          = VPORT_F_GEN_STATS | VPORT_F_TUN_ID,
1399         .init           = gre_init,
1400         .exit           = gre_exit,
1401         .create         = gre_create,
1402         .modify         = gre_modify,
1403         .destroy        = gre_destroy,
1404         .set_mtu        = gre_set_mtu,
1405         .set_addr       = gre_set_addr,
1406         .get_name       = gre_get_name,
1407         .get_addr       = gre_get_addr,
1408         .get_dev_flags  = gre_get_dev_flags,
1409         .is_running     = gre_is_running,
1410         .get_operstate  = gre_get_operstate,
1411         .get_mtu        = gre_get_mtu,
1412         .send           = gre_send,
1413 };