X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=datapath%2Fvport-gre.c;h=0f45f8f705027bf2239045df62eb900c7391c99c;hb=f915f1a8ca180828983ef22cf2fd21b8f010b972;hp=10ee63fecef9777039ad21844a57283a18d4fe16;hpb=15d90bb6c970eb1c96f8ffada260780a03660a8a;p=sliver-openvswitch.git diff --git a/datapath/vport-gre.c b/datapath/vport-gre.c index 10ee63fec..0f45f8f70 100644 --- a/datapath/vport-gre.c +++ b/datapath/vport-gre.c @@ -1,5 +1,5 @@ /* - * Copyright (c) 2010 Nicira Networks. + * Copyright (c) 2010, 2011 Nicira Networks. * Distributed under the terms of the GNU GPL version 2. * * Significant portions of this file may be copied from parts of the Linux @@ -34,22 +34,31 @@ struct gre_base_hdr { __be16 protocol; }; -static int gre_hdr_len(const struct tnl_port_config *port_config) +static int gre_hdr_len(const struct tnl_mutable_config *mutable) { int len; len = GRE_HEADER_SECTION; - if (port_config->flags & TNL_F_CSUM) + if (mutable->flags & TNL_F_CSUM) len += GRE_HEADER_SECTION; - if (port_config->out_key || - port_config->flags & TNL_F_OUT_KEY_ACTION) + if (mutable->out_key || mutable->flags & TNL_F_OUT_KEY_ACTION) len += GRE_HEADER_SECTION; return len; } +/* Returns the least-significant 32 bits of a __be64. */ +static __be32 be64_get_low32(__be64 x) +{ +#ifdef __BIG_ENDIAN + return (__force __be32)x; +#else + return (__force __be32)((__force u64)x >> 32); +#endif +} + static void gre_build_header(const struct vport *vport, const struct tnl_mutable_config *mutable, void *header) @@ -60,18 +69,17 @@ static void gre_build_header(const struct vport *vport, greh->protocol = htons(ETH_P_TEB); greh->flags = 0; - if (mutable->port_config.flags & TNL_F_CSUM) { + if (mutable->flags & TNL_F_CSUM) { greh->flags |= GRE_CSUM; *options = 0; options++; } - if (mutable->port_config.out_key || - mutable->port_config.flags & TNL_F_OUT_KEY_ACTION) + if (mutable->out_key || mutable->flags & TNL_F_OUT_KEY_ACTION) greh->flags |= GRE_KEY; - if (mutable->port_config.out_key) - *options = mutable->port_config.out_key; + if (mutable->out_key) + *options = be64_get_low32(mutable->out_key); } static struct sk_buff *gre_update_header(const struct vport *vport, @@ -83,12 +91,12 @@ static struct sk_buff *gre_update_header(const struct vport *vport, - GRE_HEADER_SECTION); /* Work backwards over the options so the checksum is last. */ - if (mutable->port_config.flags & TNL_F_OUT_KEY_ACTION) { - *options = OVS_CB(skb)->tun_id; + if (mutable->flags & TNL_F_OUT_KEY_ACTION) { + *options = be64_get_low32(OVS_CB(skb)->tun_id); options--; } - if (mutable->port_config.flags & TNL_F_CSUM) + if (mutable->flags & TNL_F_CSUM) *(__sum16 *)options = csum_fold(skb_checksum(skb, skb_transport_offset(skb), skb->len - skb_transport_offset(skb), @@ -102,7 +110,17 @@ static struct sk_buff *gre_update_header(const struct vport *vport, return skb; } -static int parse_header(struct iphdr *iph, __be16 *flags, __be32 *key) +/* Zero-extends a __be32 into the least-significant 32 bits of a __be64. */ +static __be64 be32_extend_to_be64(__be32 x) +{ +#ifdef __BIG_ENDIAN + return (__force __be64)x; +#else + return (__force __be64)((__force u64)x << 32); +#endif +} + +static int parse_header(struct iphdr *iph, __be16 *flags, __be64 *key) { /* IP and ICMP protocol handlers check that the IHL is valid. */ struct gre_base_hdr *greh = (struct gre_base_hdr *)((u8 *)iph + (iph->ihl << 2)); @@ -127,7 +145,7 @@ static int parse_header(struct iphdr *iph, __be16 *flags, __be32 *key) if (greh->flags & GRE_KEY) { hdr_len += GRE_HEADER_SECTION; - *key = *options; + *key = be32_extend_to_be64(*options); options++; } else *key = 0; @@ -149,7 +167,7 @@ static void gre_err(struct sk_buff *skb, u32 info) struct iphdr *iph; __be16 flags; - __be32 key; + __be64 key; int tunnel_hdr_len, tot_hdr_len; unsigned int orig_mac_header; unsigned int orig_nw_header; @@ -186,14 +204,14 @@ static void gre_err(struct sk_buff *skb, u32 info) * out key as if it were the in key and then check to see if the input * and output keys are the same. */ - if (mutable->port_config.in_key != mutable->port_config.out_key) + if (mutable->in_key != mutable->out_key) return; - if (!!(mutable->port_config.flags & TNL_F_IN_KEY_MATCH) != - !!(mutable->port_config.flags & TNL_F_OUT_KEY_ACTION)) + if (!!(mutable->flags & TNL_F_IN_KEY_MATCH) != + !!(mutable->flags & TNL_F_OUT_KEY_ACTION)) return; - if ((mutable->port_config.flags & TNL_F_CSUM) && !(flags & GRE_CSUM)) + if ((mutable->flags & TNL_F_CSUM) && !(flags & GRE_CSUM)) return; tunnel_hdr_len += iph->ihl << 2; @@ -293,7 +311,7 @@ static int gre_rcv(struct sk_buff *skb) int hdr_len; struct iphdr *iph; __be16 flags; - __be32 key; + __be64 key; if (unlikely(!pskb_may_pull(skb, sizeof(struct gre_base_hdr) + ETH_HLEN))) goto error; @@ -316,7 +334,7 @@ static int gre_rcv(struct sk_buff *skb) goto error; } - if (mutable->port_config.flags & TNL_F_IN_KEY_MATCH) + if (mutable->flags & TNL_F_IN_KEY_MATCH) OVS_CB(skb)->tun_id = key; else OVS_CB(skb)->tun_id = 0; @@ -340,9 +358,9 @@ static const struct tnl_ops gre_tnl_ops = { .update_header = gre_update_header, }; -static struct vport *gre_create(const char *name, const void __user *config) +static struct vport *gre_create(const struct vport_parms *parms) { - return tnl_create(name, config, &gre_vport_ops, &gre_tnl_ops); + return tnl_create(parms, &gre_vport_ops, &gre_tnl_ops); } static const struct net_protocol gre_protocol_handlers = { @@ -367,20 +385,19 @@ static void gre_exit(void) } const struct vport_ops gre_vport_ops = { - .type = "gre", + .type = ODP_VPORT_TYPE_GRE, .flags = VPORT_F_GEN_STATS | VPORT_F_TUN_ID, .init = gre_init, .exit = gre_exit, .create = gre_create, - .modify = tnl_modify, .destroy = tnl_destroy, - .set_mtu = tnl_set_mtu, .set_addr = tnl_set_addr, .get_name = tnl_get_name, .get_addr = tnl_get_addr, + .get_options = tnl_get_options, + .set_options = tnl_set_options, .get_dev_flags = vport_gen_get_dev_flags, .is_running = vport_gen_is_running, .get_operstate = vport_gen_get_operstate, - .get_mtu = tnl_get_mtu, .send = tnl_send, };