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