X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;ds=sidebyside;f=ofproto%2Ftunnel.c;h=b238cd06044ca736491e3b06f18f827f027bd130;hb=0386824614e9739d4b20b8355cfe973d0a3655c7;hp=bcc90cab25abacb1af5e4c3d0c0c8994cd046511;hpb=1362e248d68a8b7de3e6ec3689245e4dc882292b;p=sliver-openvswitch.git diff --git a/ofproto/tunnel.c b/ofproto/tunnel.c index bcc90cab2..b238cd060 100644 --- a/ofproto/tunnel.c +++ b/ofproto/tunnel.c @@ -31,6 +31,9 @@ VLOG_DEFINE_THIS_MODULE(tunnel); +/* skb mark used for IPsec tunnel packets */ +#define IPSEC_MARK 1 + struct tnl_match { ovs_be64 in_key; ovs_be32 ip_src; @@ -64,7 +67,7 @@ static struct hmap *ofport_map OVS_GUARDED_BY(rwlock) = &ofport_map__; static struct vlog_rate_limit rl = VLOG_RATE_LIMIT_INIT(1, 5); static struct vlog_rate_limit dbg_rl = VLOG_RATE_LIMIT_INIT(60, 60); -static struct tnl_port *tnl_find(struct tnl_match *) OVS_REQ_RDLOCK(rwlock); +static struct tnl_port *tnl_find(const struct flow *) OVS_REQ_RDLOCK(rwlock); static struct tnl_port *tnl_find_exact(struct tnl_match *) OVS_REQ_RDLOCK(rwlock); static struct tnl_port *tnl_find_ofport(const struct ofport_dpif *) @@ -206,24 +209,15 @@ tnl_port_receive(const struct flow *flow) OVS_EXCLUDED(rwlock) char *pre_flow_str = NULL; const struct ofport_dpif *ofport; struct tnl_port *tnl_port; - struct tnl_match match; - - memset(&match, 0, sizeof match); - match.odp_port = flow->in_port.odp_port; - match.ip_src = flow->tunnel.ip_dst; - match.ip_dst = flow->tunnel.ip_src; - match.in_key = flow->tunnel.tun_id; - match.pkt_mark = flow->pkt_mark; ovs_rwlock_rdlock(&rwlock); - tnl_port = tnl_find(&match); + tnl_port = tnl_find(flow); ofport = tnl_port ? tnl_port->ofport : NULL; if (!tnl_port) { - struct ds ds = DS_EMPTY_INITIALIZER; + char *flow_str = flow_to_string(flow); - tnl_match_fmt(&match, &ds); - VLOG_WARN_RL(&rl, "receive tunnel port not found (%s)", ds_cstr(&ds)); - ds_destroy(&ds); + VLOG_WARN_RL(&rl, "receive tunnel port not found (%s)", flow_str); + free(flow_str); goto out; } @@ -249,6 +243,46 @@ out: return ofport; } +static bool +tnl_ecn_ok(const struct flow *base_flow, struct flow *flow) +{ + if (is_ip_any(base_flow) + && (flow->tunnel.ip_tos & IP_ECN_MASK) == IP_ECN_CE) { + if ((base_flow->nw_tos & IP_ECN_MASK) == IP_ECN_NOT_ECT) { + VLOG_WARN_RL(&rl, "dropping tunnel packet marked ECN CE" + " but is not ECN capable"); + return false; + } else { + /* Set the ECN CE value in the tunneled packet. */ + flow->nw_tos |= IP_ECN_CE; + } + } + + return true; +} + +/* Should be called at the beginning of action translation to initialize + * wildcards and perform any actions based on receiving on tunnel port. + * + * Returns false if the packet must be dropped. */ +bool +tnl_xlate_init(const struct flow *base_flow, struct flow *flow, + struct flow_wildcards *wc) +{ + if (tnl_port_should_receive(flow)) { + memset(&wc->masks.tunnel, 0xff, sizeof wc->masks.tunnel); + memset(&wc->masks.pkt_mark, 0xff, sizeof wc->masks.pkt_mark); + + if (!tnl_ecn_ok(base_flow, flow)) { + return false; + } + + flow->pkt_mark &= ~IPSEC_MARK; + } + + return true; +} + /* Given that 'flow' should be output to the ofport corresponding to * 'tnl_port', updates 'flow''s tunnel headers and returns the actual datapath * port that the output should happen on. May return ODPP_NONE if the output @@ -370,55 +404,55 @@ tnl_find_exact(struct tnl_match *match) OVS_REQ_RDLOCK(rwlock) return NULL; } +/* Returns the tnl_port that is the best match for the tunnel data in 'flow', + * or NULL if no tnl_port matches 'flow'. */ static struct tnl_port * -tnl_find(struct tnl_match *match_) OVS_REQ_RDLOCK(rwlock) +tnl_find(const struct flow *flow) OVS_REQ_RDLOCK(rwlock) { - struct tnl_match match = *match_; - struct tnl_port *tnl_port; + enum ip_src_type { + IP_SRC_CFG, /* ip_src must equal configured address. */ + IP_SRC_ANY, /* Any ip_src is acceptable. */ + IP_SRC_FLOW /* ip_src is handled in flow table. */ + }; + + struct tnl_match_pattern { + bool in_key_flow; + bool ip_dst_flow; + enum ip_src_type ip_src; + }; + + static const struct tnl_match_pattern patterns[] = { + { false, false, IP_SRC_CFG }, /* remote_ip, local_ip, in_key. */ + { false, false, IP_SRC_ANY }, /* remote_ip, in_key. */ + { true, false, IP_SRC_CFG }, /* remote_ip, local_ip. */ + { true, false, IP_SRC_ANY }, /* remote_ip. */ + { true, true, IP_SRC_ANY }, /* Flow-based remote. */ + { true, true, IP_SRC_FLOW }, /* Flow-based everything. */ + }; + + const struct tnl_match_pattern *p; + struct tnl_match match; - /* remote_ip, local_ip, in_key */ - tnl_port = tnl_find_exact(&match); - if (tnl_port) { - return tnl_port; - } + memset(&match, 0, sizeof match); + match.odp_port = flow->in_port.odp_port; + match.pkt_mark = flow->pkt_mark; - /* remote_ip, in_key */ - match.ip_src = 0; - tnl_port = tnl_find_exact(&match); - if (tnl_port) { - return tnl_port; - } - match.ip_src = match_->ip_src; + for (p = patterns; p < &patterns[ARRAY_SIZE(patterns)]; p++) { + struct tnl_port *tnl_port; - /* remote_ip, local_ip */ - match.in_key = 0; - match.in_key_flow = true; - tnl_port = tnl_find_exact(&match); - if (tnl_port) { - return tnl_port; - } + match.in_key_flow = p->in_key_flow; + match.in_key = p->in_key_flow ? 0 : flow->tunnel.tun_id; - /* remote_ip */ - match.ip_src = 0; - tnl_port = tnl_find_exact(&match); - if (tnl_port) { - return tnl_port; - } + match.ip_dst_flow = p->ip_dst_flow; + match.ip_dst = p->ip_dst_flow ? 0 : flow->tunnel.ip_src; - /* Flow-based remote */ - match.ip_dst = 0; - match.ip_dst_flow = true; - tnl_port = tnl_find_exact(&match); - if (tnl_port) { - return tnl_port; - } + match.ip_src_flow = p->ip_src == IP_SRC_FLOW; + match.ip_src = p->ip_src == IP_SRC_CFG ? flow->tunnel.ip_dst : 0; - /* Flow-based everything */ - match.ip_src = 0; - match.ip_src_flow = true; - tnl_port = tnl_find_exact(&match); - if (tnl_port) { - return tnl_port; + tnl_port = tnl_find_exact(&match); + if (tnl_port) { + return tnl_port; + } } return NULL;