socket-util: Move get_mtime() here from stream-ssl.
[openvswitch] / 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         vport_receive(vport, nskb);
538
539         return true;
540 }
541
542 static struct sk_buff *
543 check_headroom(struct sk_buff *skb, int headroom)
544 {
545         if (skb_headroom(skb) < headroom ||
546             (skb_cloned(skb) && !skb_clone_writable(skb, 0))) {
547                 struct sk_buff *nskb = skb_realloc_headroom(skb, headroom);
548                 if (!nskb) {
549                         kfree_skb(skb);
550                         return ERR_PTR(-ENOMEM);
551                 }
552
553                 set_skb_csum_bits(skb, nskb);
554
555                 if (skb->sk)
556                         skb_set_owner_w(nskb, skb->sk);
557
558                 dev_kfree_skb(skb);
559                 return nskb;
560         }
561
562         return skb;
563 }
564
565 static void
566 create_gre_header(struct sk_buff *skb, const struct mutable_config *mutable)
567 {
568         struct iphdr *iph = ip_hdr(skb);
569         __be16 *flags = (__be16 *)(iph + 1);
570         __be16 *protocol = flags + 1;
571         __be32 *options = (__be32 *)((u8 *)iph + mutable->tunnel_hlen
572                                                - GRE_HEADER_SECTION);
573
574         *protocol = htons(ETH_P_TEB);
575         *flags = 0;
576
577         /* Work backwards over the options so the checksum is last. */
578         if (mutable->port_config.out_key ||
579             mutable->port_config.flags & GRE_F_OUT_KEY_ACTION) {
580                 *flags |= GRE_KEY;
581
582                 if (mutable->port_config.flags & GRE_F_OUT_KEY_ACTION)
583                         *options = OVS_CB(skb)->tun_id;
584                 else
585                         *options = mutable->port_config.out_key;
586
587                 options--;
588         }
589
590         if (mutable->port_config.flags & GRE_F_OUT_CSUM) {
591                 *flags |= GRE_CSUM;
592
593                 *options = 0;
594                 *(__sum16 *)options = csum_fold(skb_checksum(skb,
595                                                 sizeof(struct iphdr),
596                                                 skb->len - sizeof(struct iphdr),
597                                                 0));
598         }
599 }
600
601 static int
602 check_checksum(struct sk_buff *skb)
603 {
604         struct iphdr *iph = ip_hdr(skb);
605         __be16 flags = *(__be16 *)(iph + 1);
606         __sum16 csum = 0;
607
608         if (flags & GRE_CSUM) {
609                 switch (skb->ip_summed) {
610                 case CHECKSUM_COMPLETE:
611                         csum = csum_fold(skb->csum);
612
613                         if (!csum)
614                                 break;
615                         /* Fall through. */
616
617                 case CHECKSUM_NONE:
618                         skb->csum = 0;
619                         csum = __skb_checksum_complete(skb);
620                         skb->ip_summed = CHECKSUM_COMPLETE;
621                         break;
622                 }
623         }
624
625         return (csum == 0);
626 }
627
628 static int
629 parse_gre_header(struct iphdr *iph, __be16 *flags, __be32 *key)
630 {
631         /* IP and ICMP protocol handlers check that the IHL is valid. */
632         __be16 *flagsp = (__be16 *)((u8 *)iph + (iph->ihl << 2));
633         __be16 *protocol = flagsp + 1;
634         __be32 *options = (__be32 *)(protocol + 1);
635         int hdr_len;
636
637         *flags = *flagsp;
638
639         if (*flags & (GRE_VERSION | GRE_ROUTING))
640                 return -EINVAL;
641
642         if (*protocol != htons(ETH_P_TEB))
643                 return -EINVAL;
644
645         hdr_len = GRE_HEADER_SECTION;
646
647         if (*flags & GRE_CSUM) {
648                 hdr_len += GRE_HEADER_SECTION;
649                 options++;
650         }
651
652         if (*flags & GRE_KEY) {
653                 hdr_len += GRE_HEADER_SECTION;
654
655                 *key = *options;
656                 options++;
657         } else
658                 *key = 0;
659
660         if (*flags & GRE_SEQ)
661                 hdr_len += GRE_HEADER_SECTION;
662
663         return hdr_len;
664 }
665
666 static inline u8
667 ecn_encapsulate(u8 tos, struct sk_buff *skb)
668 {
669         u8 inner;
670
671         if (skb->protocol == htons(ETH_P_IP))
672                 inner = ((struct iphdr *)skb_network_header(skb))->tos;
673         else if (skb->protocol == htons(ETH_P_IPV6))
674                 inner = ipv6_get_dsfield((struct ipv6hdr *)skb_network_header(skb));
675         else
676                 inner = 0;
677
678         return INET_ECN_encapsulate(tos, inner);
679 }
680
681 static inline void
682 ecn_decapsulate(u8 tos, struct sk_buff *skb)
683 {
684         if (INET_ECN_is_ce(tos)) {
685                 __be16 protocol = skb->protocol;
686                 unsigned int nw_header = skb_network_header(skb) - skb->data;
687
688                 if (skb->protocol == htons(ETH_P_8021Q)) {
689                         if (unlikely(!pskb_may_pull(skb, VLAN_ETH_HLEN)))
690                                 return;
691
692                         protocol = vlan_eth_hdr(skb)->h_vlan_encapsulated_proto;
693                         nw_header += VLAN_HLEN;
694                 }
695
696                 if (protocol == htons(ETH_P_IP)) {
697                         if (unlikely(!pskb_may_pull(skb, nw_header
698                             + sizeof(struct iphdr))))
699                                 return;
700
701                         IP_ECN_set_ce((struct iphdr *)(nw_header + skb->data));
702                 } else if (protocol == htons(ETH_P_IPV6)) {
703                         if (unlikely(!pskb_may_pull(skb, nw_header
704                             + sizeof(struct ipv6hdr))))
705                                 return;
706
707                         IP6_ECN_set_ce((struct ipv6hdr *)(nw_header
708                                                           + skb->data));
709                 }
710         }
711 }
712
713 static struct sk_buff *
714 handle_gso(struct sk_buff *skb)
715 {
716         if (skb_is_gso(skb)) {
717                 struct sk_buff *nskb = skb_gso_segment(skb, NETIF_F_SG);
718
719                 dev_kfree_skb(skb);
720                 return nskb;
721         }
722
723         return skb;
724 }
725
726 static int
727 handle_csum_offload(struct sk_buff *skb)
728 {
729         if (skb->ip_summed == CHECKSUM_PARTIAL)
730                 return skb_checksum_help(skb);
731         else {
732                 skb->ip_summed = CHECKSUM_NONE;
733                 return 0;
734         }
735 }
736
737 /* Called with rcu_read_lock and bottom-halves disabled. */
738 static void
739 gre_err(struct sk_buff *skb, u32 info)
740 {
741         struct vport *vport;
742         const struct mutable_config *mutable;
743         const int type = icmp_hdr(skb)->type;
744         const int code = icmp_hdr(skb)->code;
745         int mtu = ntohs(icmp_hdr(skb)->un.frag.mtu);
746
747         struct iphdr *iph;
748         __be16 flags;
749         __be32 key;
750         int tunnel_hdr_len, tot_hdr_len;
751         unsigned int orig_mac_header;
752         unsigned int orig_nw_header;
753
754         if (type != ICMP_DEST_UNREACH || code != ICMP_FRAG_NEEDED)
755                 return;
756
757         /* The mimimum size packet that we would actually be able to process:
758          * encapsulating IP header, minimum GRE header, Ethernet header,
759          * inner IPv4 header. */
760         if (!pskb_may_pull(skb, sizeof(struct iphdr) + GRE_HEADER_SECTION +
761                                 ETH_HLEN + sizeof(struct iphdr)))
762                 return;
763
764         iph = (struct iphdr *)skb->data;
765
766         tunnel_hdr_len = parse_gre_header(iph, &flags, &key);
767         if (tunnel_hdr_len < 0)
768                 return;
769
770         vport = find_port(iph->saddr, iph->daddr, key, FIND_PORT_ANY, &mutable);
771         if (!vport)
772                 return;
773
774         /* Packets received by this function were previously sent by us, so
775          * any comparisons should be to the output values, not the input.
776          * However, it's not really worth it to have a hash table based on
777          * output keys (especially since ICMP error handling of tunneled packets
778          * isn't that reliable anyways).  Therefore, we do a lookup based on the
779          * out key as if it were the in key and then check to see if the input
780          * and output keys are the same. */
781         if (mutable->port_config.in_key != mutable->port_config.out_key)
782                 return;
783
784         if (!!(mutable->port_config.flags & GRE_F_IN_KEY_MATCH) !=
785             !!(mutable->port_config.flags & GRE_F_OUT_KEY_ACTION))
786                 return;
787
788         if ((mutable->port_config.flags & GRE_F_OUT_CSUM) && !(flags & GRE_CSUM))
789                 return;
790
791         tunnel_hdr_len += iph->ihl << 2;
792
793         orig_mac_header = skb_mac_header(skb) - skb->data;
794         orig_nw_header = skb_network_header(skb) - skb->data;
795         skb_set_mac_header(skb, tunnel_hdr_len);
796
797         tot_hdr_len = tunnel_hdr_len + ETH_HLEN;
798
799         skb->protocol = eth_hdr(skb)->h_proto;
800         if (skb->protocol == htons(ETH_P_8021Q)) {
801                 tot_hdr_len += VLAN_HLEN;
802                 skb->protocol = vlan_eth_hdr(skb)->h_vlan_encapsulated_proto;
803         }
804
805         skb_set_network_header(skb, tot_hdr_len);
806         mtu -= tot_hdr_len;
807
808         if (skb->protocol == htons(ETH_P_IP))
809                 tot_hdr_len += sizeof(struct iphdr);
810         else if (skb->protocol == htons(ETH_P_IPV6))
811                 tot_hdr_len += sizeof(struct ipv6hdr);
812         else
813                 goto out;
814
815         if (!pskb_may_pull(skb, tot_hdr_len))
816                 goto out;
817
818         if (skb->protocol == htons(ETH_P_IP)) {
819                 if (mtu < IP_MIN_MTU) {
820                         if (ntohs(ip_hdr(skb)->tot_len) >= IP_MIN_MTU)
821                                 mtu = IP_MIN_MTU;
822                         else
823                                 goto out;
824                 }
825
826         } else if (skb->protocol == htons(ETH_P_IPV6)) {
827                 if (mtu < IPV6_MIN_MTU) {
828                         unsigned int packet_length = sizeof(struct ipv6hdr) +
829                                               ntohs(ipv6_hdr(skb)->payload_len);
830
831                         if (packet_length >= IPV6_MIN_MTU
832                             || ntohs(ipv6_hdr(skb)->payload_len) == 0)
833                                 mtu = IPV6_MIN_MTU;
834                         else
835                                 goto out;
836                 }
837         }
838
839         __pskb_pull(skb, tunnel_hdr_len);
840         send_frag_needed(vport, mutable, skb, mtu, key);
841         skb_push(skb, tunnel_hdr_len);
842
843 out:
844         skb_set_mac_header(skb, orig_mac_header);
845         skb_set_network_header(skb, orig_nw_header);
846         skb->protocol = htons(ETH_P_IP);
847 }
848
849 /* Called with rcu_read_lock and bottom-halves disabled. */
850 static int
851 gre_rcv(struct sk_buff *skb)
852 {
853         struct vport *vport;
854         const struct mutable_config *mutable;
855         int hdr_len;
856         struct iphdr *iph;
857         __be16 flags;
858         __be32 key;
859
860         if (!pskb_may_pull(skb, GRE_HEADER_SECTION + ETH_HLEN))
861                 goto error;
862
863         if (!check_checksum(skb))
864                 goto error;
865
866         iph = ip_hdr(skb);
867
868         hdr_len = parse_gre_header(iph, &flags, &key);
869         if (hdr_len < 0)
870                 goto error;
871
872         vport = find_port(iph->daddr, iph->saddr, key, FIND_PORT_ANY, &mutable);
873         if (!vport) {
874                 icmp_send(skb, ICMP_DEST_UNREACH, ICMP_PORT_UNREACH, 0);
875                 goto error;
876         }
877
878         if ((mutable->port_config.flags & GRE_F_IN_CSUM) && !(flags & GRE_CSUM)) {
879                 vport_record_error(vport, VPORT_E_RX_CRC);
880                 goto error;
881         }
882
883         if (!pskb_pull(skb, hdr_len) || !pskb_may_pull(skb, ETH_HLEN)) {
884                 vport_record_error(vport, VPORT_E_RX_ERROR);
885                 goto error;
886         }
887
888         skb->pkt_type = PACKET_HOST;
889         skb->protocol = eth_type_trans(skb, skb->dev);
890         skb_postpull_rcsum(skb, skb_transport_header(skb), hdr_len + ETH_HLEN);
891
892         skb_dst_drop(skb);
893         nf_reset(skb);
894         secpath_reset(skb);
895         skb_reset_network_header(skb);
896
897         ecn_decapsulate(iph->tos, skb);
898
899         if (mutable->port_config.flags & GRE_F_IN_KEY_MATCH)
900                 OVS_CB(skb)->tun_id = key;
901         else
902                 OVS_CB(skb)->tun_id = 0;
903
904         skb_push(skb, ETH_HLEN);
905         vport_receive(vport, skb);
906
907         return 0;
908
909 error:
910         kfree_skb(skb);
911         return 0;
912 }
913
914 static int
915 build_packet(struct vport *vport, const struct mutable_config *mutable,
916              struct iphdr *iph, struct rtable *rt, int max_headroom, int mtu,
917              struct sk_buff *skb)
918 {
919         int err;
920         struct iphdr *new_iph;
921         int orig_len = skb->len;
922         __be16 frag_off = iph->frag_off;
923
924         skb = check_headroom(skb, max_headroom);
925         if (unlikely(IS_ERR(skb)))
926                 goto error;
927
928         err = handle_csum_offload(skb);
929         if (err)
930                 goto error_free;
931
932         if (skb->protocol == htons(ETH_P_IP)) {
933                 struct iphdr *old_iph = ip_hdr(skb);
934
935                 if ((old_iph->frag_off & htons(IP_DF)) &&
936                     mtu < ntohs(old_iph->tot_len)) {
937                         if (send_frag_needed(vport, mutable, skb, mtu, OVS_CB(skb)->tun_id))
938                                 goto error_free;
939                 }
940
941         } else if (skb->protocol == htons(ETH_P_IPV6)) {
942                 unsigned int packet_length = skb->len - ETH_HLEN
943                         - (eth_hdr(skb)->h_proto == htons(ETH_P_8021Q) ? VLAN_HLEN : 0);
944
945                 /* IPv6 requires PMTUD if the packet is above the minimum MTU. */
946                 if (packet_length > IPV6_MIN_MTU)
947                         frag_off = htons(IP_DF);
948
949                 if (mtu < packet_length) {
950                         if (send_frag_needed(vport, mutable, skb, mtu, OVS_CB(skb)->tun_id))
951                                 goto error_free;
952                 }
953         }
954
955         skb_reset_transport_header(skb);
956         new_iph = (struct iphdr *)skb_push(skb, mutable->tunnel_hlen);
957         skb_reset_network_header(skb);
958
959         memcpy(new_iph, iph, sizeof(struct iphdr));
960         new_iph->frag_off = frag_off;
961         ip_select_ident(new_iph, &rt->u.dst, NULL);
962
963         create_gre_header(skb, mutable);
964
965         /* Allow our local IP stack to fragment the outer packet even if the
966          * DF bit is set as a last resort. */
967         skb->local_df = 1;
968
969         memset(&(IPCB(skb)->opt), 0, sizeof(IPCB(skb)->opt));
970         IPCB(skb)->flags = 0;
971
972         err = ip_local_out(skb);
973         if (likely(net_xmit_eval(err) == 0))
974                 return orig_len;
975         else {
976                 vport_record_error(vport, VPORT_E_TX_ERROR);
977                 return 0;
978         }
979
980 error_free:
981         kfree_skb(skb);
982 error:
983         vport_record_error(vport, VPORT_E_TX_DROPPED);
984
985         return 0;
986 }
987
988 static int
989 gre_send(struct vport *vport, struct sk_buff *skb)
990 {
991         struct gre_vport *gre_vport = gre_vport_priv(vport);
992         const struct mutable_config *mutable = rcu_dereference(gre_vport->mutable);
993
994         struct iphdr *old_iph;
995         struct ipv6hdr *old_ipv6h;
996         int orig_len;
997         struct iphdr iph;
998         struct rtable *rt;
999         int max_headroom;
1000         int mtu;
1001
1002         /* Validate the protocol headers before we try to use them. */
1003         if (skb->protocol == htons(ETH_P_8021Q)) {
1004                 if (unlikely(!pskb_may_pull(skb, VLAN_ETH_HLEN)))
1005                         goto error_free;
1006
1007                 skb->protocol = vlan_eth_hdr(skb)->h_vlan_encapsulated_proto;
1008                 skb_set_network_header(skb, VLAN_ETH_HLEN);
1009         }
1010
1011         if (skb->protocol == htons(ETH_P_IP)) {
1012                 if (unlikely(!pskb_may_pull(skb, skb_network_header(skb)
1013                     + sizeof(struct iphdr) - skb->data)))
1014                         skb->protocol = 0;
1015         } else if (skb->protocol == htons(ETH_P_IPV6)) {
1016                 if (unlikely(!pskb_may_pull(skb, skb_network_header(skb)
1017                     + sizeof(struct ipv6hdr) - skb->data)))
1018                         skb->protocol = 0;
1019         }
1020
1021         old_iph = ip_hdr(skb);
1022         old_ipv6h = ipv6_hdr(skb);
1023
1024         iph.tos = mutable->port_config.tos;
1025         if (mutable->port_config.flags & GRE_F_TOS_INHERIT) {
1026                 if (skb->protocol == htons(ETH_P_IP))
1027                         iph.tos = old_iph->tos;
1028                 else if (skb->protocol == htons(ETH_P_IPV6))
1029                         iph.tos = ipv6_get_dsfield(ipv6_hdr(skb));
1030         }
1031         iph.tos = ecn_encapsulate(iph.tos, skb);
1032
1033         {
1034                 struct flowi fl = { .nl_u = { .ip4_u =
1035                                               { .daddr = mutable->port_config.daddr,
1036                                                 .saddr = mutable->port_config.saddr,
1037                                                 .tos = RT_TOS(iph.tos) } },
1038                                     .proto = IPPROTO_GRE };
1039
1040                 if (ip_route_output_key(&init_net, &rt, &fl))
1041                         goto error_free;
1042         }
1043
1044         iph.ttl = mutable->port_config.ttl;
1045         if (mutable->port_config.flags & GRE_F_TTL_INHERIT) {
1046                 if (skb->protocol == htons(ETH_P_IP))
1047                         iph.ttl = old_iph->ttl;
1048                 else if (skb->protocol == htons(ETH_P_IPV6))
1049                         iph.ttl = old_ipv6h->hop_limit;
1050         }
1051         if (!iph.ttl)
1052                 iph.ttl = dst_metric(&rt->u.dst, RTAX_HOPLIMIT);
1053
1054         iph.frag_off = (mutable->port_config.flags & GRE_F_PMTUD) ? htons(IP_DF) : 0;
1055         if (iph.frag_off)
1056                 mtu = dst_mtu(&rt->u.dst)
1057                         - ETH_HLEN
1058                         - mutable->tunnel_hlen
1059                         - (eth_hdr(skb)->h_proto == htons(ETH_P_8021Q) ? VLAN_HLEN : 0);
1060         else
1061                 mtu = mutable->mtu;
1062
1063         if (skb->protocol == htons(ETH_P_IP)) {
1064                 iph.frag_off |= old_iph->frag_off & htons(IP_DF);
1065                 mtu = max(mtu, IP_MIN_MTU);
1066
1067         } else if (skb->protocol == htons(ETH_P_IPV6))
1068                 mtu = max(mtu, IPV6_MIN_MTU);
1069
1070         iph.version = 4;
1071         iph.ihl = sizeof(struct iphdr) >> 2;
1072         iph.protocol = IPPROTO_GRE;
1073         iph.daddr = rt->rt_dst;
1074         iph.saddr = rt->rt_src;
1075
1076         nf_reset(skb);
1077         secpath_reset(skb);
1078         skb_dst_drop(skb);
1079         skb_dst_set(skb, &rt->u.dst);
1080
1081         /* If we are doing GSO on a pskb it is better to make sure that the
1082          * headroom is correct now.  We will only have to copy the portion in
1083          * the linear data area and GSO will preserve headroom when it creates
1084          * the segments.  This is particularly beneficial on Xen where we get
1085          * lots of GSO pskbs.  Conversely, we delay copying if it is just to
1086          * get our own writable clone because GSO may do the copy for us. */
1087         max_headroom = LL_RESERVED_SPACE(rt->u.dst.dev) + mutable->tunnel_hlen;
1088         if (skb_headroom(skb) < max_headroom) {
1089                 skb = check_headroom(skb, max_headroom);
1090                 if (unlikely(IS_ERR(skb))) {
1091                         vport_record_error(vport, VPORT_E_TX_DROPPED);
1092                         goto error;
1093                 }
1094         }
1095
1096         forward_ip_summed(skb);
1097         vswitch_skb_checksum_setup(skb);
1098
1099         skb = handle_gso(skb);
1100         if (unlikely(IS_ERR(skb))) {
1101                 vport_record_error(vport, VPORT_E_TX_DROPPED);
1102                 goto error;
1103         }
1104
1105         /* Process GSO segments.  Try to do any work for the entire packet that
1106          * doesn't involve actually writing to it before this point. */
1107         orig_len = 0;
1108         do {
1109                 struct sk_buff *next_skb = skb->next;
1110                 skb->next = NULL;
1111
1112                 orig_len += build_packet(vport, mutable, &iph, rt, max_headroom, mtu, skb);
1113
1114                 skb = next_skb;
1115         } while (skb);
1116
1117         return orig_len;
1118
1119 error_free:
1120         kfree_skb(skb);
1121         vport_record_error(vport, VPORT_E_TX_ERROR);
1122 error:
1123         return 0;
1124 }
1125
1126 static struct net_protocol gre_protocol_handlers = {
1127         .handler        =       gre_rcv,
1128         .err_handler    =       gre_err,
1129 };
1130
1131 static int
1132 gre_init(void)
1133 {
1134         int err;
1135
1136         err = inet_add_protocol(&gre_protocol_handlers, IPPROTO_GRE);
1137         if (err)
1138                 printk(KERN_WARNING "openvswitch: cannot register gre protocol handler\n");
1139
1140         return err;
1141 }
1142
1143 static void
1144 gre_exit(void)
1145 {
1146         tbl_destroy(port_table, NULL);
1147         inet_del_protocol(&gre_protocol_handlers, IPPROTO_GRE);
1148 }
1149
1150 static int
1151 set_config(const struct vport *cur_vport, struct mutable_config *mutable,
1152            const void __user *uconfig)
1153 {
1154         const struct vport *old_vport;
1155         const struct mutable_config *old_mutable;
1156         int port_type;
1157
1158         if (copy_from_user(&mutable->port_config, uconfig, sizeof(struct gre_port_config)))
1159                 return -EFAULT;
1160
1161         if (mutable->port_config.daddr == 0)
1162                 return -EINVAL;
1163
1164         if (mutable->port_config.flags & GRE_F_IN_KEY_MATCH) {
1165                 port_type = FIND_PORT_MATCH;
1166                 mutable->port_config.in_key = 0;
1167         } else
1168                 port_type = FIND_PORT_KEY;
1169
1170         old_vport = find_port(mutable->port_config.saddr,
1171                               mutable->port_config.daddr,
1172                               mutable->port_config.in_key, port_type,
1173                               &old_mutable);
1174
1175         if (old_vport && old_vport != cur_vport)
1176                 return -EEXIST;
1177
1178         if (mutable->port_config.flags & GRE_F_OUT_KEY_ACTION)
1179                 mutable->port_config.out_key = 0;
1180
1181         mutable->tunnel_hlen = sizeof(struct iphdr) + GRE_HEADER_SECTION;
1182
1183         if (mutable->port_config.flags & GRE_F_OUT_CSUM)
1184                 mutable->tunnel_hlen += GRE_HEADER_SECTION;
1185
1186         if (mutable->port_config.out_key ||
1187             mutable->port_config.flags & GRE_F_OUT_KEY_ACTION)
1188                 mutable->tunnel_hlen += GRE_HEADER_SECTION;
1189
1190         return 0;
1191 }
1192
1193 static struct vport *
1194 gre_create(const char *name, const void __user *config)
1195 {
1196         struct vport *vport;
1197         struct gre_vport *gre_vport;
1198         int err;
1199
1200         vport = vport_alloc(sizeof(struct gre_vport), &gre_vport_ops);
1201         if (IS_ERR(vport)) {
1202                 err = PTR_ERR(vport);
1203                 goto error;
1204         }
1205
1206         gre_vport = gre_vport_priv(vport);
1207
1208         strcpy(gre_vport->name, name);
1209
1210         gre_vport->mutable = kmalloc(sizeof(struct mutable_config), GFP_KERNEL);
1211         if (!gre_vport->mutable) {
1212                 err = -ENOMEM;
1213                 goto error_free_vport;
1214         }
1215
1216         vport_gen_ether_addr(gre_vport->mutable->eth_addr);
1217         gre_vport->mutable->mtu = ETH_DATA_LEN;
1218
1219         err = set_config(NULL, gre_vport->mutable, config);
1220         if (err)
1221                 goto error_free_mutable;
1222
1223         err = add_port(vport);
1224         if (err)
1225                 goto error_free_mutable;
1226
1227         return vport;
1228
1229 error_free_mutable:
1230         kfree(gre_vport->mutable);
1231 error_free_vport:
1232         vport_free(vport);
1233 error:
1234         return ERR_PTR(err);
1235 }
1236
1237 static int
1238 gre_modify(struct vport *vport, const void __user *config)
1239 {
1240         struct gre_vport *gre_vport = gre_vport_priv(vport);
1241         struct mutable_config *mutable;
1242         int err;
1243         int update_hash = 0;
1244
1245         mutable = kmemdup(gre_vport->mutable, sizeof(struct mutable_config), GFP_KERNEL);
1246         if (!mutable) {
1247                 err = -ENOMEM;
1248                 goto error;
1249         }
1250
1251         err = set_config(vport, mutable, config);
1252         if (err)
1253                 goto error_free;
1254
1255         /* Only remove the port from the hash table if something that would
1256          * affect the lookup has changed. */
1257         if (gre_vport->mutable->port_config.saddr != mutable->port_config.saddr ||
1258             gre_vport->mutable->port_config.daddr != mutable->port_config.daddr ||
1259             gre_vport->mutable->port_config.in_key != mutable->port_config.in_key ||
1260             (gre_vport->mutable->port_config.flags & GRE_F_IN_KEY_MATCH) !=
1261             (mutable->port_config.flags & GRE_F_IN_KEY_MATCH))
1262                 update_hash = 1;
1263
1264
1265         /* This update is not atomic but the lookup uses the config, which
1266          * serves as an inherent double check. */
1267         if (update_hash) {
1268                 err = del_port(vport);
1269                 if (err)
1270                         goto error_free;
1271         }
1272
1273         assign_config_rcu(vport, mutable);
1274
1275         if (update_hash) {
1276                 err = add_port(vport);
1277                 if (err)
1278                         goto error_free;
1279         }
1280
1281         return 0;
1282
1283 error_free:
1284         kfree(mutable);
1285 error:
1286         return err;
1287 }
1288
1289 static int
1290 gre_destroy(struct vport *vport)
1291 {
1292         struct gre_vport *gre_vport = gre_vport_priv(vport);
1293         int port_type;
1294         const struct mutable_config *old_mutable;
1295
1296         /* Do a hash table lookup to make sure that the port exists.  It should
1297          * exist but might not if a modify failed earlier. */
1298         if (gre_vport->mutable->port_config.flags & GRE_F_IN_KEY_MATCH)
1299                 port_type = FIND_PORT_MATCH;
1300         else
1301                 port_type = FIND_PORT_KEY;
1302
1303         if (vport == find_port(gre_vport->mutable->port_config.saddr,
1304             gre_vport->mutable->port_config.daddr,
1305             gre_vport->mutable->port_config.in_key, port_type, &old_mutable))
1306                 del_port(vport);
1307
1308         kfree(gre_vport->mutable);
1309         vport_free(vport);
1310
1311         return 0;
1312 }
1313
1314 static int
1315 gre_set_mtu(struct vport *vport, int mtu)
1316 {
1317         struct gre_vport *gre_vport = gre_vport_priv(vport);
1318         struct mutable_config *mutable;
1319         struct dp_port *dp_port;
1320
1321         mutable = kmemdup(gre_vport->mutable, sizeof(struct mutable_config), GFP_KERNEL);
1322         if (!mutable)
1323                 return -ENOMEM;
1324
1325         mutable->mtu = mtu;
1326         assign_config_rcu(vport, mutable);
1327
1328         dp_port = vport_get_dp_port(vport);
1329         if (dp_port)
1330                 set_internal_devs_mtu(dp_port->dp);
1331
1332         return 0;
1333 }
1334
1335 static int
1336 gre_set_addr(struct vport *vport, const unsigned char *addr)
1337 {
1338         struct gre_vport *gre_vport = gre_vport_priv(vport);
1339         struct mutable_config *mutable;
1340
1341         mutable = kmemdup(gre_vport->mutable, sizeof(struct mutable_config), GFP_KERNEL);
1342         if (!mutable)
1343                 return -ENOMEM;
1344
1345         memcpy(mutable->eth_addr, addr, ETH_ALEN);
1346         assign_config_rcu(vport, mutable);
1347
1348         return 0;
1349 }
1350
1351
1352 static const char *
1353 gre_get_name(const struct vport *vport)
1354 {
1355         const struct gre_vport *gre_vport = gre_vport_priv(vport);
1356         return gre_vport->name;
1357 }
1358
1359 static const unsigned char *
1360 gre_get_addr(const struct vport *vport)
1361 {
1362         const struct gre_vport *gre_vport = gre_vport_priv(vport);
1363         return rcu_dereference(gre_vport->mutable)->eth_addr;
1364 }
1365
1366 static unsigned
1367 gre_get_dev_flags(const struct vport *vport)
1368 {
1369         return IFF_UP | IFF_RUNNING | IFF_LOWER_UP;
1370 }
1371
1372 static int
1373 gre_is_running(const struct vport *vport)
1374 {
1375         return 1;
1376 }
1377
1378 static unsigned char
1379 gre_get_operstate(const struct vport *vport)
1380 {
1381         return IF_OPER_UP;
1382 }
1383
1384 static int
1385 gre_get_mtu(const struct vport *vport)
1386 {
1387         const struct gre_vport *gre_vport = gre_vport_priv(vport);
1388         return rcu_dereference(gre_vport->mutable)->mtu;
1389 }
1390
1391 struct vport_ops gre_vport_ops = {
1392         .type           = "gre",
1393         .flags          = VPORT_F_GEN_STATS | VPORT_F_TUN_ID,
1394         .init           = gre_init,
1395         .exit           = gre_exit,
1396         .create         = gre_create,
1397         .modify         = gre_modify,
1398         .destroy        = gre_destroy,
1399         .set_mtu        = gre_set_mtu,
1400         .set_addr       = gre_set_addr,
1401         .get_name       = gre_get_name,
1402         .get_addr       = gre_get_addr,
1403         .get_dev_flags  = gre_get_dev_flags,
1404         .is_running     = gre_is_running,
1405         .get_operstate  = gre_get_operstate,
1406         .get_mtu        = gre_get_mtu,
1407         .send           = gre_send,
1408 };