2011-10-26 09:26:31 +07:00
|
|
|
/*
|
2017-03-21 06:32:28 +07:00
|
|
|
* Copyright (c) 2007-2017 Nicira, Inc.
|
2011-10-26 09:26:31 +07:00
|
|
|
*
|
|
|
|
* This program is free software; you can redistribute it and/or
|
|
|
|
* modify it under the terms of version 2 of the GNU General Public
|
|
|
|
* License as published by the Free Software Foundation.
|
|
|
|
*
|
|
|
|
* This program is distributed in the hope that it will be useful, but
|
|
|
|
* WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
|
|
|
* General Public License for more details.
|
|
|
|
*
|
|
|
|
* You should have received a copy of the GNU General Public License
|
|
|
|
* along with this program; if not, write to the Free Software
|
|
|
|
* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
|
|
|
|
* 02110-1301, USA
|
|
|
|
*/
|
|
|
|
|
|
|
|
#define pr_fmt(fmt) KBUILD_MODNAME ": " fmt
|
|
|
|
|
|
|
|
#include <linux/skbuff.h>
|
|
|
|
#include <linux/in.h>
|
|
|
|
#include <linux/ip.h>
|
|
|
|
#include <linux/openvswitch.h>
|
2015-08-27 01:31:48 +07:00
|
|
|
#include <linux/netfilter_ipv6.h>
|
2013-08-23 02:30:48 +07:00
|
|
|
#include <linux/sctp.h>
|
2011-10-26 09:26:31 +07:00
|
|
|
#include <linux/tcp.h>
|
|
|
|
#include <linux/udp.h>
|
|
|
|
#include <linux/in6.h>
|
|
|
|
#include <linux/if_arp.h>
|
|
|
|
#include <linux/if_vlan.h>
|
2014-10-06 19:05:13 +07:00
|
|
|
|
2015-08-27 01:31:48 +07:00
|
|
|
#include <net/dst.h>
|
2011-10-26 09:26:31 +07:00
|
|
|
#include <net/ip.h>
|
2012-11-14 06:44:14 +07:00
|
|
|
#include <net/ipv6.h>
|
2015-08-28 05:25:46 +07:00
|
|
|
#include <net/ip6_fib.h>
|
2011-10-26 09:26:31 +07:00
|
|
|
#include <net/checksum.h>
|
|
|
|
#include <net/dsfield.h>
|
2014-10-06 19:05:13 +07:00
|
|
|
#include <net/mpls.h>
|
2013-08-23 02:30:48 +07:00
|
|
|
#include <net/sctp/checksum.h>
|
2011-10-26 09:26:31 +07:00
|
|
|
|
|
|
|
#include "datapath.h"
|
2014-09-16 09:37:25 +07:00
|
|
|
#include "flow.h"
|
2015-08-27 01:31:48 +07:00
|
|
|
#include "conntrack.h"
|
2011-10-26 09:26:31 +07:00
|
|
|
#include "vport.h"
|
2017-11-07 20:07:02 +07:00
|
|
|
#include "flow_netlink.h"
|
2011-10-26 09:26:31 +07:00
|
|
|
|
2014-09-16 09:37:25 +07:00
|
|
|
struct deferred_action {
|
|
|
|
struct sk_buff *skb;
|
|
|
|
const struct nlattr *actions;
|
2017-03-21 06:32:27 +07:00
|
|
|
int actions_len;
|
2014-09-16 09:37:25 +07:00
|
|
|
|
|
|
|
/* Store pkt_key clone when creating deferred action. */
|
|
|
|
struct sw_flow_key pkt_key;
|
|
|
|
};
|
|
|
|
|
2015-08-27 01:31:48 +07:00
|
|
|
#define MAX_L2_LEN (VLAN_ETH_HLEN + 3 * MPLS_HLEN)
|
|
|
|
struct ovs_frag_data {
|
|
|
|
unsigned long dst;
|
|
|
|
struct vport *vport;
|
|
|
|
struct ovs_skb_cb cb;
|
|
|
|
__be16 inner_protocol;
|
2016-10-05 20:01:57 +07:00
|
|
|
u16 network_offset; /* valid only for MPLS */
|
|
|
|
u16 vlan_tci;
|
2015-08-27 01:31:48 +07:00
|
|
|
__be16 vlan_proto;
|
|
|
|
unsigned int l2_len;
|
2016-11-10 22:28:19 +07:00
|
|
|
u8 mac_proto;
|
2015-08-27 01:31:48 +07:00
|
|
|
u8 l2_data[MAX_L2_LEN];
|
|
|
|
};
|
|
|
|
|
|
|
|
static DEFINE_PER_CPU(struct ovs_frag_data, ovs_frag_data_storage);
|
|
|
|
|
2014-09-16 09:37:25 +07:00
|
|
|
#define DEFERRED_ACTION_FIFO_SIZE 10
|
2016-09-13 21:08:54 +07:00
|
|
|
#define OVS_RECURSION_LIMIT 5
|
|
|
|
#define OVS_DEFERRED_ACTION_THRESHOLD (OVS_RECURSION_LIMIT - 2)
|
2014-09-16 09:37:25 +07:00
|
|
|
struct action_fifo {
|
|
|
|
int head;
|
|
|
|
int tail;
|
|
|
|
/* Deferred action fifo queue storage. */
|
|
|
|
struct deferred_action fifo[DEFERRED_ACTION_FIFO_SIZE];
|
|
|
|
};
|
|
|
|
|
2017-03-21 06:32:28 +07:00
|
|
|
struct action_flow_keys {
|
2016-09-13 21:08:54 +07:00
|
|
|
struct sw_flow_key key[OVS_DEFERRED_ACTION_THRESHOLD];
|
|
|
|
};
|
|
|
|
|
2014-09-16 09:37:25 +07:00
|
|
|
static struct action_fifo __percpu *action_fifos;
|
2017-03-21 06:32:28 +07:00
|
|
|
static struct action_flow_keys __percpu *flow_keys;
|
2014-09-16 09:37:25 +07:00
|
|
|
static DEFINE_PER_CPU(int, exec_actions_level);
|
|
|
|
|
2017-03-21 06:32:28 +07:00
|
|
|
/* Make a clone of the 'key', using the pre-allocated percpu 'flow_keys'
|
|
|
|
* space. Return NULL if out of key spaces.
|
|
|
|
*/
|
|
|
|
static struct sw_flow_key *clone_key(const struct sw_flow_key *key_)
|
|
|
|
{
|
|
|
|
struct action_flow_keys *keys = this_cpu_ptr(flow_keys);
|
|
|
|
int level = this_cpu_read(exec_actions_level);
|
|
|
|
struct sw_flow_key *key = NULL;
|
|
|
|
|
|
|
|
if (level <= OVS_DEFERRED_ACTION_THRESHOLD) {
|
|
|
|
key = &keys->key[level - 1];
|
|
|
|
*key = *key_;
|
|
|
|
}
|
|
|
|
|
|
|
|
return key;
|
|
|
|
}
|
|
|
|
|
2014-09-16 09:37:25 +07:00
|
|
|
static void action_fifo_init(struct action_fifo *fifo)
|
|
|
|
{
|
|
|
|
fifo->head = 0;
|
|
|
|
fifo->tail = 0;
|
|
|
|
}
|
|
|
|
|
2014-11-06 21:58:52 +07:00
|
|
|
static bool action_fifo_is_empty(const struct action_fifo *fifo)
|
2014-09-16 09:37:25 +07:00
|
|
|
{
|
|
|
|
return (fifo->head == fifo->tail);
|
|
|
|
}
|
|
|
|
|
|
|
|
static struct deferred_action *action_fifo_get(struct action_fifo *fifo)
|
|
|
|
{
|
|
|
|
if (action_fifo_is_empty(fifo))
|
|
|
|
return NULL;
|
|
|
|
|
|
|
|
return &fifo->fifo[fifo->tail++];
|
|
|
|
}
|
|
|
|
|
|
|
|
static struct deferred_action *action_fifo_put(struct action_fifo *fifo)
|
|
|
|
{
|
|
|
|
if (fifo->head >= DEFERRED_ACTION_FIFO_SIZE - 1)
|
|
|
|
return NULL;
|
|
|
|
|
|
|
|
return &fifo->fifo[fifo->head++];
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Return true if fifo is not full */
|
|
|
|
static struct deferred_action *add_deferred_actions(struct sk_buff *skb,
|
2017-03-21 06:32:27 +07:00
|
|
|
const struct sw_flow_key *key,
|
|
|
|
const struct nlattr *actions,
|
|
|
|
const int actions_len)
|
2014-09-16 09:37:25 +07:00
|
|
|
{
|
|
|
|
struct action_fifo *fifo;
|
|
|
|
struct deferred_action *da;
|
|
|
|
|
|
|
|
fifo = this_cpu_ptr(action_fifos);
|
|
|
|
da = action_fifo_put(fifo);
|
|
|
|
if (da) {
|
|
|
|
da->skb = skb;
|
2017-03-21 06:32:27 +07:00
|
|
|
da->actions = actions;
|
|
|
|
da->actions_len = actions_len;
|
2014-09-16 09:37:25 +07:00
|
|
|
da->pkt_key = *key;
|
|
|
|
}
|
|
|
|
|
|
|
|
return da;
|
|
|
|
}
|
|
|
|
|
2014-11-06 21:55:14 +07:00
|
|
|
static void invalidate_flow_key(struct sw_flow_key *key)
|
|
|
|
{
|
2016-11-10 22:28:18 +07:00
|
|
|
key->mac_proto |= SW_FLOW_KEY_INVALID;
|
2014-11-06 21:55:14 +07:00
|
|
|
}
|
|
|
|
|
|
|
|
static bool is_flow_key_valid(const struct sw_flow_key *key)
|
|
|
|
{
|
2016-11-10 22:28:18 +07:00
|
|
|
return !(key->mac_proto & SW_FLOW_KEY_INVALID);
|
2014-11-06 21:55:14 +07:00
|
|
|
}
|
|
|
|
|
2017-03-21 06:32:30 +07:00
|
|
|
static int clone_execute(struct datapath *dp, struct sk_buff *skb,
|
|
|
|
struct sw_flow_key *key,
|
|
|
|
u32 recirc_id,
|
|
|
|
const struct nlattr *actions, int len,
|
|
|
|
bool last, bool clone_flow_key);
|
|
|
|
|
2016-05-30 12:04:25 +07:00
|
|
|
static void update_ethertype(struct sk_buff *skb, struct ethhdr *hdr,
|
|
|
|
__be16 ethertype)
|
|
|
|
{
|
|
|
|
if (skb->ip_summed == CHECKSUM_COMPLETE) {
|
|
|
|
__be16 diff[] = { ~(hdr->h_proto), ethertype };
|
|
|
|
|
|
|
|
skb->csum = ~csum_partial((char *)diff, sizeof(diff),
|
|
|
|
~skb->csum);
|
|
|
|
}
|
|
|
|
|
|
|
|
hdr->h_proto = ethertype;
|
|
|
|
}
|
|
|
|
|
2014-11-06 21:55:14 +07:00
|
|
|
static int push_mpls(struct sk_buff *skb, struct sw_flow_key *key,
|
2014-10-06 19:05:13 +07:00
|
|
|
const struct ovs_action_push_mpls *mpls)
|
|
|
|
{
|
2016-10-01 00:08:07 +07:00
|
|
|
struct mpls_shim_hdr *new_mpls_lse;
|
2014-10-06 19:05:13 +07:00
|
|
|
|
|
|
|
/* Networking stack do not allow simultaneous Tunnel and MPLS GSO. */
|
|
|
|
if (skb->encapsulation)
|
|
|
|
return -ENOTSUPP;
|
|
|
|
|
|
|
|
if (skb_cow_head(skb, MPLS_HLEN) < 0)
|
|
|
|
return -ENOMEM;
|
|
|
|
|
2016-08-25 10:10:44 +07:00
|
|
|
if (!skb->inner_protocol) {
|
|
|
|
skb_set_inner_network_header(skb, skb->mac_len);
|
|
|
|
skb_set_inner_protocol(skb, skb->protocol);
|
|
|
|
}
|
|
|
|
|
2014-10-06 19:05:13 +07:00
|
|
|
skb_push(skb, MPLS_HLEN);
|
|
|
|
memmove(skb_mac_header(skb) - MPLS_HLEN, skb_mac_header(skb),
|
|
|
|
skb->mac_len);
|
|
|
|
skb_reset_mac_header(skb);
|
2016-08-25 10:10:44 +07:00
|
|
|
skb_set_network_header(skb, skb->mac_len);
|
2014-10-06 19:05:13 +07:00
|
|
|
|
2016-10-01 00:08:07 +07:00
|
|
|
new_mpls_lse = mpls_hdr(skb);
|
|
|
|
new_mpls_lse->label_stack_entry = mpls->mpls_lse;
|
2014-10-06 19:05:13 +07:00
|
|
|
|
2016-02-20 06:29:30 +07:00
|
|
|
skb_postpush_rcsum(skb, new_mpls_lse, MPLS_HLEN);
|
2014-10-06 19:05:13 +07:00
|
|
|
|
2016-11-10 22:28:20 +07:00
|
|
|
if (ovs_key_mac_proto(key) == MAC_PROTO_ETHERNET)
|
|
|
|
update_ethertype(skb, eth_hdr(skb), mpls->mpls_ethertype);
|
2014-10-06 19:05:13 +07:00
|
|
|
skb->protocol = mpls->mpls_ethertype;
|
|
|
|
|
2014-11-06 21:55:14 +07:00
|
|
|
invalidate_flow_key(key);
|
2014-10-06 19:05:13 +07:00
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2014-11-06 21:55:14 +07:00
|
|
|
static int pop_mpls(struct sk_buff *skb, struct sw_flow_key *key,
|
|
|
|
const __be16 ethertype)
|
2014-10-06 19:05:13 +07:00
|
|
|
{
|
|
|
|
int err;
|
|
|
|
|
2014-11-19 20:05:01 +07:00
|
|
|
err = skb_ensure_writable(skb, skb->mac_len + MPLS_HLEN);
|
2014-10-06 19:05:13 +07:00
|
|
|
if (unlikely(err))
|
|
|
|
return err;
|
|
|
|
|
2016-10-01 00:08:07 +07:00
|
|
|
skb_postpull_rcsum(skb, mpls_hdr(skb), MPLS_HLEN);
|
2014-10-06 19:05:13 +07:00
|
|
|
|
|
|
|
memmove(skb_mac_header(skb) + MPLS_HLEN, skb_mac_header(skb),
|
|
|
|
skb->mac_len);
|
|
|
|
|
|
|
|
__skb_pull(skb, MPLS_HLEN);
|
|
|
|
skb_reset_mac_header(skb);
|
2016-08-25 10:10:44 +07:00
|
|
|
skb_set_network_header(skb, skb->mac_len);
|
2014-10-06 19:05:13 +07:00
|
|
|
|
2016-11-10 22:28:20 +07:00
|
|
|
if (ovs_key_mac_proto(key) == MAC_PROTO_ETHERNET) {
|
|
|
|
struct ethhdr *hdr;
|
|
|
|
|
|
|
|
/* mpls_hdr() is used to locate the ethertype field correctly in the
|
|
|
|
* presence of VLAN tags.
|
|
|
|
*/
|
|
|
|
hdr = (struct ethhdr *)((void *)mpls_hdr(skb) - ETH_HLEN);
|
|
|
|
update_ethertype(skb, hdr, ethertype);
|
|
|
|
}
|
2014-10-06 19:05:13 +07:00
|
|
|
if (eth_p_mpls(skb->protocol))
|
|
|
|
skb->protocol = ethertype;
|
2014-11-06 21:55:14 +07:00
|
|
|
|
|
|
|
invalidate_flow_key(key);
|
2014-10-06 19:05:13 +07:00
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2015-02-06 04:40:49 +07:00
|
|
|
static int set_mpls(struct sk_buff *skb, struct sw_flow_key *flow_key,
|
|
|
|
const __be32 *mpls_lse, const __be32 *mask)
|
2014-10-06 19:05:13 +07:00
|
|
|
{
|
2016-10-01 00:08:07 +07:00
|
|
|
struct mpls_shim_hdr *stack;
|
2015-02-06 04:40:49 +07:00
|
|
|
__be32 lse;
|
2014-10-06 19:05:13 +07:00
|
|
|
int err;
|
|
|
|
|
2014-11-19 20:05:01 +07:00
|
|
|
err = skb_ensure_writable(skb, skb->mac_len + MPLS_HLEN);
|
2014-10-06 19:05:13 +07:00
|
|
|
if (unlikely(err))
|
|
|
|
return err;
|
|
|
|
|
2016-10-01 00:08:07 +07:00
|
|
|
stack = mpls_hdr(skb);
|
|
|
|
lse = OVS_MASKED(stack->label_stack_entry, *mpls_lse, *mask);
|
2014-10-06 19:05:13 +07:00
|
|
|
if (skb->ip_summed == CHECKSUM_COMPLETE) {
|
2016-10-01 00:08:07 +07:00
|
|
|
__be32 diff[] = { ~(stack->label_stack_entry), lse };
|
2015-02-06 04:40:49 +07:00
|
|
|
|
2014-10-06 19:05:13 +07:00
|
|
|
skb->csum = ~csum_partial((char *)diff, sizeof(diff),
|
|
|
|
~skb->csum);
|
|
|
|
}
|
|
|
|
|
2016-10-01 00:08:07 +07:00
|
|
|
stack->label_stack_entry = lse;
|
2015-02-06 04:40:49 +07:00
|
|
|
flow_key->mpls.top_lse = lse;
|
2014-10-06 19:05:13 +07:00
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2014-11-06 21:55:14 +07:00
|
|
|
static int pop_vlan(struct sk_buff *skb, struct sw_flow_key *key)
|
2011-10-26 09:26:31 +07:00
|
|
|
{
|
|
|
|
int err;
|
|
|
|
|
2014-11-19 20:05:02 +07:00
|
|
|
err = skb_vlan_pop(skb);
|
2016-09-07 23:56:59 +07:00
|
|
|
if (skb_vlan_tag_present(skb)) {
|
2014-11-19 20:05:02 +07:00
|
|
|
invalidate_flow_key(key);
|
2016-09-07 23:56:59 +07:00
|
|
|
} else {
|
|
|
|
key->eth.vlan.tci = 0;
|
|
|
|
key->eth.vlan.tpid = 0;
|
|
|
|
}
|
2014-11-19 20:05:02 +07:00
|
|
|
return err;
|
2011-10-26 09:26:31 +07:00
|
|
|
}
|
|
|
|
|
2014-11-06 21:55:14 +07:00
|
|
|
static int push_vlan(struct sk_buff *skb, struct sw_flow_key *key,
|
|
|
|
const struct ovs_action_push_vlan *vlan)
|
2011-10-26 09:26:31 +07:00
|
|
|
{
|
2016-09-07 23:56:59 +07:00
|
|
|
if (skb_vlan_tag_present(skb)) {
|
2014-11-06 21:55:14 +07:00
|
|
|
invalidate_flow_key(key);
|
2016-09-07 23:56:59 +07:00
|
|
|
} else {
|
|
|
|
key->eth.vlan.tci = vlan->vlan_tci;
|
|
|
|
key->eth.vlan.tpid = vlan->vlan_tpid;
|
|
|
|
}
|
2014-11-19 20:05:02 +07:00
|
|
|
return skb_vlan_push(skb, vlan->vlan_tpid,
|
|
|
|
ntohs(vlan->vlan_tci) & ~VLAN_TAG_PRESENT);
|
2011-10-26 09:26:31 +07:00
|
|
|
}
|
|
|
|
|
2015-02-06 04:40:49 +07:00
|
|
|
/* 'src' is already properly masked. */
|
|
|
|
static void ether_addr_copy_masked(u8 *dst_, const u8 *src_, const u8 *mask_)
|
|
|
|
{
|
|
|
|
u16 *dst = (u16 *)dst_;
|
|
|
|
const u16 *src = (const u16 *)src_;
|
|
|
|
const u16 *mask = (const u16 *)mask_;
|
|
|
|
|
2015-08-27 01:31:45 +07:00
|
|
|
OVS_SET_MASKED(dst[0], src[0], mask[0]);
|
|
|
|
OVS_SET_MASKED(dst[1], src[1], mask[1]);
|
|
|
|
OVS_SET_MASKED(dst[2], src[2], mask[2]);
|
2015-02-06 04:40:49 +07:00
|
|
|
}
|
|
|
|
|
|
|
|
static int set_eth_addr(struct sk_buff *skb, struct sw_flow_key *flow_key,
|
|
|
|
const struct ovs_key_ethernet *key,
|
|
|
|
const struct ovs_key_ethernet *mask)
|
2011-10-26 09:26:31 +07:00
|
|
|
{
|
|
|
|
int err;
|
2015-02-06 04:40:49 +07:00
|
|
|
|
2014-11-19 20:05:01 +07:00
|
|
|
err = skb_ensure_writable(skb, ETH_HLEN);
|
2011-10-26 09:26:31 +07:00
|
|
|
if (unlikely(err))
|
|
|
|
return err;
|
|
|
|
|
2013-06-14 01:11:44 +07:00
|
|
|
skb_postpull_rcsum(skb, eth_hdr(skb), ETH_ALEN * 2);
|
|
|
|
|
2015-02-06 04:40:49 +07:00
|
|
|
ether_addr_copy_masked(eth_hdr(skb)->h_source, key->eth_src,
|
|
|
|
mask->eth_src);
|
|
|
|
ether_addr_copy_masked(eth_hdr(skb)->h_dest, key->eth_dst,
|
|
|
|
mask->eth_dst);
|
2011-10-26 09:26:31 +07:00
|
|
|
|
2016-02-20 06:29:30 +07:00
|
|
|
skb_postpush_rcsum(skb, eth_hdr(skb), ETH_ALEN * 2);
|
2013-06-14 01:11:44 +07:00
|
|
|
|
2015-02-06 04:40:49 +07:00
|
|
|
ether_addr_copy(flow_key->eth.src, eth_hdr(skb)->h_source);
|
|
|
|
ether_addr_copy(flow_key->eth.dst, eth_hdr(skb)->h_dest);
|
2011-10-26 09:26:31 +07:00
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2016-11-10 22:28:23 +07:00
|
|
|
/* pop_eth does not support VLAN packets as this action is never called
|
|
|
|
* for them.
|
|
|
|
*/
|
|
|
|
static int pop_eth(struct sk_buff *skb, struct sw_flow_key *key)
|
|
|
|
{
|
|
|
|
skb_pull_rcsum(skb, ETH_HLEN);
|
|
|
|
skb_reset_mac_header(skb);
|
|
|
|
skb_reset_mac_len(skb);
|
|
|
|
|
|
|
|
/* safe right before invalidate_flow_key */
|
|
|
|
key->mac_proto = MAC_PROTO_NONE;
|
|
|
|
invalidate_flow_key(key);
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
static int push_eth(struct sk_buff *skb, struct sw_flow_key *key,
|
|
|
|
const struct ovs_action_push_eth *ethh)
|
|
|
|
{
|
|
|
|
struct ethhdr *hdr;
|
|
|
|
|
|
|
|
/* Add the new Ethernet header */
|
|
|
|
if (skb_cow_head(skb, ETH_HLEN) < 0)
|
|
|
|
return -ENOMEM;
|
|
|
|
|
|
|
|
skb_push(skb, ETH_HLEN);
|
|
|
|
skb_reset_mac_header(skb);
|
|
|
|
skb_reset_mac_len(skb);
|
|
|
|
|
|
|
|
hdr = eth_hdr(skb);
|
|
|
|
ether_addr_copy(hdr->h_source, ethh->addresses.eth_src);
|
|
|
|
ether_addr_copy(hdr->h_dest, ethh->addresses.eth_dst);
|
|
|
|
hdr->h_proto = skb->protocol;
|
|
|
|
|
|
|
|
skb_postpush_rcsum(skb, hdr, ETH_HLEN);
|
|
|
|
|
|
|
|
/* safe right before invalidate_flow_key */
|
|
|
|
key->mac_proto = MAC_PROTO_ETHERNET;
|
|
|
|
invalidate_flow_key(key);
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2017-11-07 20:07:02 +07:00
|
|
|
static int push_nsh(struct sk_buff *skb, struct sw_flow_key *key,
|
|
|
|
const struct nshhdr *nh)
|
|
|
|
{
|
|
|
|
int err;
|
|
|
|
|
|
|
|
err = nsh_push(skb, nh);
|
|
|
|
if (err)
|
|
|
|
return err;
|
|
|
|
|
|
|
|
/* safe right before invalidate_flow_key */
|
|
|
|
key->mac_proto = MAC_PROTO_NONE;
|
|
|
|
invalidate_flow_key(key);
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
static int pop_nsh(struct sk_buff *skb, struct sw_flow_key *key)
|
|
|
|
{
|
|
|
|
int err;
|
|
|
|
|
|
|
|
err = nsh_pop(skb);
|
|
|
|
if (err)
|
|
|
|
return err;
|
|
|
|
|
|
|
|
/* safe right before invalidate_flow_key */
|
|
|
|
if (skb->protocol == htons(ETH_P_TEB))
|
|
|
|
key->mac_proto = MAC_PROTO_ETHERNET;
|
|
|
|
else
|
|
|
|
key->mac_proto = MAC_PROTO_NONE;
|
|
|
|
invalidate_flow_key(key);
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2015-08-03 23:56:54 +07:00
|
|
|
static void update_ip_l4_checksum(struct sk_buff *skb, struct iphdr *nh,
|
|
|
|
__be32 addr, __be32 new_addr)
|
2011-10-26 09:26:31 +07:00
|
|
|
{
|
|
|
|
int transport_len = skb->len - skb_transport_offset(skb);
|
|
|
|
|
2015-08-03 23:56:54 +07:00
|
|
|
if (nh->frag_off & htons(IP_OFFSET))
|
|
|
|
return;
|
|
|
|
|
2011-10-26 09:26:31 +07:00
|
|
|
if (nh->protocol == IPPROTO_TCP) {
|
|
|
|
if (likely(transport_len >= sizeof(struct tcphdr)))
|
|
|
|
inet_proto_csum_replace4(&tcp_hdr(skb)->check, skb,
|
2015-08-18 03:42:25 +07:00
|
|
|
addr, new_addr, true);
|
2011-10-26 09:26:31 +07:00
|
|
|
} else if (nh->protocol == IPPROTO_UDP) {
|
2012-03-07 06:05:46 +07:00
|
|
|
if (likely(transport_len >= sizeof(struct udphdr))) {
|
|
|
|
struct udphdr *uh = udp_hdr(skb);
|
|
|
|
|
|
|
|
if (uh->check || skb->ip_summed == CHECKSUM_PARTIAL) {
|
|
|
|
inet_proto_csum_replace4(&uh->check, skb,
|
2015-08-18 03:42:25 +07:00
|
|
|
addr, new_addr, true);
|
2012-03-07 06:05:46 +07:00
|
|
|
if (!uh->check)
|
|
|
|
uh->check = CSUM_MANGLED_0;
|
|
|
|
}
|
|
|
|
}
|
2011-10-26 09:26:31 +07:00
|
|
|
}
|
2015-08-03 23:56:54 +07:00
|
|
|
}
|
2011-10-26 09:26:31 +07:00
|
|
|
|
2015-08-03 23:56:54 +07:00
|
|
|
static void set_ip_addr(struct sk_buff *skb, struct iphdr *nh,
|
|
|
|
__be32 *addr, __be32 new_addr)
|
|
|
|
{
|
|
|
|
update_ip_l4_checksum(skb, nh, *addr, new_addr);
|
2011-10-26 09:26:31 +07:00
|
|
|
csum_replace4(&nh->check, *addr, new_addr);
|
2013-12-16 13:12:18 +07:00
|
|
|
skb_clear_hash(skb);
|
2011-10-26 09:26:31 +07:00
|
|
|
*addr = new_addr;
|
|
|
|
}
|
|
|
|
|
2012-11-14 06:44:14 +07:00
|
|
|
static void update_ipv6_checksum(struct sk_buff *skb, u8 l4_proto,
|
|
|
|
__be32 addr[4], const __be32 new_addr[4])
|
|
|
|
{
|
|
|
|
int transport_len = skb->len - skb_transport_offset(skb);
|
|
|
|
|
2014-11-12 05:32:20 +07:00
|
|
|
if (l4_proto == NEXTHDR_TCP) {
|
2012-11-14 06:44:14 +07:00
|
|
|
if (likely(transport_len >= sizeof(struct tcphdr)))
|
|
|
|
inet_proto_csum_replace16(&tcp_hdr(skb)->check, skb,
|
2015-08-18 03:42:25 +07:00
|
|
|
addr, new_addr, true);
|
2014-11-12 05:32:20 +07:00
|
|
|
} else if (l4_proto == NEXTHDR_UDP) {
|
2012-11-14 06:44:14 +07:00
|
|
|
if (likely(transport_len >= sizeof(struct udphdr))) {
|
|
|
|
struct udphdr *uh = udp_hdr(skb);
|
|
|
|
|
|
|
|
if (uh->check || skb->ip_summed == CHECKSUM_PARTIAL) {
|
|
|
|
inet_proto_csum_replace16(&uh->check, skb,
|
2015-08-18 03:42:25 +07:00
|
|
|
addr, new_addr, true);
|
2012-11-14 06:44:14 +07:00
|
|
|
if (!uh->check)
|
|
|
|
uh->check = CSUM_MANGLED_0;
|
|
|
|
}
|
|
|
|
}
|
2014-11-12 05:32:20 +07:00
|
|
|
} else if (l4_proto == NEXTHDR_ICMP) {
|
|
|
|
if (likely(transport_len >= sizeof(struct icmp6hdr)))
|
|
|
|
inet_proto_csum_replace16(&icmp6_hdr(skb)->icmp6_cksum,
|
2015-08-18 03:42:25 +07:00
|
|
|
skb, addr, new_addr, true);
|
2012-11-14 06:44:14 +07:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2015-02-06 04:40:49 +07:00
|
|
|
static void mask_ipv6_addr(const __be32 old[4], const __be32 addr[4],
|
|
|
|
const __be32 mask[4], __be32 masked[4])
|
|
|
|
{
|
2015-08-27 01:31:45 +07:00
|
|
|
masked[0] = OVS_MASKED(old[0], addr[0], mask[0]);
|
|
|
|
masked[1] = OVS_MASKED(old[1], addr[1], mask[1]);
|
|
|
|
masked[2] = OVS_MASKED(old[2], addr[2], mask[2]);
|
|
|
|
masked[3] = OVS_MASKED(old[3], addr[3], mask[3]);
|
2015-02-06 04:40:49 +07:00
|
|
|
}
|
|
|
|
|
2012-11-14 06:44:14 +07:00
|
|
|
static void set_ipv6_addr(struct sk_buff *skb, u8 l4_proto,
|
|
|
|
__be32 addr[4], const __be32 new_addr[4],
|
|
|
|
bool recalculate_csum)
|
|
|
|
{
|
|
|
|
if (recalculate_csum)
|
|
|
|
update_ipv6_checksum(skb, l4_proto, addr, new_addr);
|
|
|
|
|
2013-12-16 13:12:18 +07:00
|
|
|
skb_clear_hash(skb);
|
2012-11-14 06:44:14 +07:00
|
|
|
memcpy(addr, new_addr, sizeof(__be32[4]));
|
|
|
|
}
|
|
|
|
|
2015-02-06 04:40:49 +07:00
|
|
|
static void set_ipv6_fl(struct ipv6hdr *nh, u32 fl, u32 mask)
|
2012-11-14 06:44:14 +07:00
|
|
|
{
|
2015-02-06 04:40:49 +07:00
|
|
|
/* Bits 21-24 are always unmasked, so this retains their values. */
|
2015-08-27 01:31:45 +07:00
|
|
|
OVS_SET_MASKED(nh->flow_lbl[0], (u8)(fl >> 16), (u8)(mask >> 16));
|
|
|
|
OVS_SET_MASKED(nh->flow_lbl[1], (u8)(fl >> 8), (u8)(mask >> 8));
|
|
|
|
OVS_SET_MASKED(nh->flow_lbl[2], (u8)fl, (u8)mask);
|
2012-11-14 06:44:14 +07:00
|
|
|
}
|
|
|
|
|
2015-02-06 04:40:49 +07:00
|
|
|
static void set_ip_ttl(struct sk_buff *skb, struct iphdr *nh, u8 new_ttl,
|
|
|
|
u8 mask)
|
2012-11-14 06:44:14 +07:00
|
|
|
{
|
2015-08-27 01:31:45 +07:00
|
|
|
new_ttl = OVS_MASKED(nh->ttl, new_ttl, mask);
|
2012-11-14 06:44:14 +07:00
|
|
|
|
2011-10-26 09:26:31 +07:00
|
|
|
csum_replace2(&nh->check, htons(nh->ttl << 8), htons(new_ttl << 8));
|
|
|
|
nh->ttl = new_ttl;
|
|
|
|
}
|
|
|
|
|
2015-02-06 04:40:49 +07:00
|
|
|
static int set_ipv4(struct sk_buff *skb, struct sw_flow_key *flow_key,
|
|
|
|
const struct ovs_key_ipv4 *key,
|
|
|
|
const struct ovs_key_ipv4 *mask)
|
2011-10-26 09:26:31 +07:00
|
|
|
{
|
|
|
|
struct iphdr *nh;
|
2015-02-06 04:40:49 +07:00
|
|
|
__be32 new_addr;
|
2011-10-26 09:26:31 +07:00
|
|
|
int err;
|
|
|
|
|
2014-11-19 20:05:01 +07:00
|
|
|
err = skb_ensure_writable(skb, skb_network_offset(skb) +
|
|
|
|
sizeof(struct iphdr));
|
2011-10-26 09:26:31 +07:00
|
|
|
if (unlikely(err))
|
|
|
|
return err;
|
|
|
|
|
|
|
|
nh = ip_hdr(skb);
|
|
|
|
|
2015-02-06 04:40:49 +07:00
|
|
|
/* Setting an IP addresses is typically only a side effect of
|
|
|
|
* matching on them in the current userspace implementation, so it
|
|
|
|
* makes sense to check if the value actually changed.
|
|
|
|
*/
|
|
|
|
if (mask->ipv4_src) {
|
2015-08-27 01:31:45 +07:00
|
|
|
new_addr = OVS_MASKED(nh->saddr, key->ipv4_src, mask->ipv4_src);
|
2011-10-26 09:26:31 +07:00
|
|
|
|
2015-02-06 04:40:49 +07:00
|
|
|
if (unlikely(new_addr != nh->saddr)) {
|
|
|
|
set_ip_addr(skb, nh, &nh->saddr, new_addr);
|
|
|
|
flow_key->ipv4.addr.src = new_addr;
|
|
|
|
}
|
2014-11-06 21:55:14 +07:00
|
|
|
}
|
2015-02-06 04:40:49 +07:00
|
|
|
if (mask->ipv4_dst) {
|
2015-08-27 01:31:45 +07:00
|
|
|
new_addr = OVS_MASKED(nh->daddr, key->ipv4_dst, mask->ipv4_dst);
|
2011-10-26 09:26:31 +07:00
|
|
|
|
2015-02-06 04:40:49 +07:00
|
|
|
if (unlikely(new_addr != nh->daddr)) {
|
|
|
|
set_ip_addr(skb, nh, &nh->daddr, new_addr);
|
|
|
|
flow_key->ipv4.addr.dst = new_addr;
|
|
|
|
}
|
2014-11-06 21:55:14 +07:00
|
|
|
}
|
2015-02-06 04:40:49 +07:00
|
|
|
if (mask->ipv4_tos) {
|
|
|
|
ipv4_change_dsfield(nh, ~mask->ipv4_tos, key->ipv4_tos);
|
|
|
|
flow_key->ip.tos = nh->tos;
|
|
|
|
}
|
|
|
|
if (mask->ipv4_ttl) {
|
|
|
|
set_ip_ttl(skb, nh, key->ipv4_ttl, mask->ipv4_ttl);
|
|
|
|
flow_key->ip.ttl = nh->ttl;
|
2014-11-06 21:55:14 +07:00
|
|
|
}
|
2011-10-26 09:26:31 +07:00
|
|
|
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2015-02-06 04:40:49 +07:00
|
|
|
static bool is_ipv6_mask_nonzero(const __be32 addr[4])
|
|
|
|
{
|
|
|
|
return !!(addr[0] | addr[1] | addr[2] | addr[3]);
|
|
|
|
}
|
|
|
|
|
|
|
|
static int set_ipv6(struct sk_buff *skb, struct sw_flow_key *flow_key,
|
|
|
|
const struct ovs_key_ipv6 *key,
|
|
|
|
const struct ovs_key_ipv6 *mask)
|
2012-11-14 06:44:14 +07:00
|
|
|
{
|
|
|
|
struct ipv6hdr *nh;
|
|
|
|
int err;
|
|
|
|
|
2014-11-19 20:05:01 +07:00
|
|
|
err = skb_ensure_writable(skb, skb_network_offset(skb) +
|
|
|
|
sizeof(struct ipv6hdr));
|
2012-11-14 06:44:14 +07:00
|
|
|
if (unlikely(err))
|
|
|
|
return err;
|
|
|
|
|
|
|
|
nh = ipv6_hdr(skb);
|
|
|
|
|
2015-02-06 04:40:49 +07:00
|
|
|
/* Setting an IP addresses is typically only a side effect of
|
|
|
|
* matching on them in the current userspace implementation, so it
|
|
|
|
* makes sense to check if the value actually changed.
|
|
|
|
*/
|
|
|
|
if (is_ipv6_mask_nonzero(mask->ipv6_src)) {
|
|
|
|
__be32 *saddr = (__be32 *)&nh->saddr;
|
|
|
|
__be32 masked[4];
|
|
|
|
|
|
|
|
mask_ipv6_addr(saddr, key->ipv6_src, mask->ipv6_src, masked);
|
|
|
|
|
|
|
|
if (unlikely(memcmp(saddr, masked, sizeof(masked)))) {
|
2016-04-21 08:49:15 +07:00
|
|
|
set_ipv6_addr(skb, flow_key->ip.proto, saddr, masked,
|
2015-02-06 04:40:49 +07:00
|
|
|
true);
|
|
|
|
memcpy(&flow_key->ipv6.addr.src, masked,
|
|
|
|
sizeof(flow_key->ipv6.addr.src));
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if (is_ipv6_mask_nonzero(mask->ipv6_dst)) {
|
2012-11-14 06:44:14 +07:00
|
|
|
unsigned int offset = 0;
|
|
|
|
int flags = IP6_FH_F_SKIP_RH;
|
|
|
|
bool recalc_csum = true;
|
2015-02-06 04:40:49 +07:00
|
|
|
__be32 *daddr = (__be32 *)&nh->daddr;
|
|
|
|
__be32 masked[4];
|
|
|
|
|
|
|
|
mask_ipv6_addr(daddr, key->ipv6_dst, mask->ipv6_dst, masked);
|
|
|
|
|
|
|
|
if (unlikely(memcmp(daddr, masked, sizeof(masked)))) {
|
|
|
|
if (ipv6_ext_hdr(nh->nexthdr))
|
|
|
|
recalc_csum = (ipv6_find_hdr(skb, &offset,
|
|
|
|
NEXTHDR_ROUTING,
|
|
|
|
NULL, &flags)
|
|
|
|
!= NEXTHDR_ROUTING);
|
|
|
|
|
2016-04-21 08:49:15 +07:00
|
|
|
set_ipv6_addr(skb, flow_key->ip.proto, daddr, masked,
|
2015-02-06 04:40:49 +07:00
|
|
|
recalc_csum);
|
|
|
|
memcpy(&flow_key->ipv6.addr.dst, masked,
|
|
|
|
sizeof(flow_key->ipv6.addr.dst));
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if (mask->ipv6_tclass) {
|
|
|
|
ipv6_change_dsfield(nh, ~mask->ipv6_tclass, key->ipv6_tclass);
|
|
|
|
flow_key->ip.tos = ipv6_get_dsfield(nh);
|
|
|
|
}
|
|
|
|
if (mask->ipv6_label) {
|
|
|
|
set_ipv6_fl(nh, ntohl(key->ipv6_label),
|
|
|
|
ntohl(mask->ipv6_label));
|
|
|
|
flow_key->ipv6.label =
|
|
|
|
*(__be32 *)nh & htonl(IPV6_FLOWINFO_FLOWLABEL);
|
|
|
|
}
|
|
|
|
if (mask->ipv6_hlimit) {
|
2015-08-27 01:31:45 +07:00
|
|
|
OVS_SET_MASKED(nh->hop_limit, key->ipv6_hlimit,
|
|
|
|
mask->ipv6_hlimit);
|
2015-02-06 04:40:49 +07:00
|
|
|
flow_key->ip.ttl = nh->hop_limit;
|
2012-11-14 06:44:14 +07:00
|
|
|
}
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2017-11-07 20:07:02 +07:00
|
|
|
static int set_nsh(struct sk_buff *skb, struct sw_flow_key *flow_key,
|
|
|
|
const struct nlattr *a)
|
|
|
|
{
|
|
|
|
struct nshhdr *nh;
|
|
|
|
size_t length;
|
|
|
|
int err;
|
|
|
|
u8 flags;
|
|
|
|
u8 ttl;
|
|
|
|
int i;
|
|
|
|
|
|
|
|
struct ovs_key_nsh key;
|
|
|
|
struct ovs_key_nsh mask;
|
|
|
|
|
|
|
|
err = nsh_key_from_nlattr(a, &key, &mask);
|
|
|
|
if (err)
|
|
|
|
return err;
|
|
|
|
|
|
|
|
/* Make sure the NSH base header is there */
|
|
|
|
if (!pskb_may_pull(skb, skb_network_offset(skb) + NSH_BASE_HDR_LEN))
|
|
|
|
return -ENOMEM;
|
|
|
|
|
|
|
|
nh = nsh_hdr(skb);
|
|
|
|
length = nsh_hdr_len(nh);
|
|
|
|
|
|
|
|
/* Make sure the whole NSH header is there */
|
|
|
|
err = skb_ensure_writable(skb, skb_network_offset(skb) +
|
|
|
|
length);
|
|
|
|
if (unlikely(err))
|
|
|
|
return err;
|
|
|
|
|
|
|
|
nh = nsh_hdr(skb);
|
|
|
|
skb_postpull_rcsum(skb, nh, length);
|
|
|
|
flags = nsh_get_flags(nh);
|
|
|
|
flags = OVS_MASKED(flags, key.base.flags, mask.base.flags);
|
|
|
|
flow_key->nsh.base.flags = flags;
|
|
|
|
ttl = nsh_get_ttl(nh);
|
|
|
|
ttl = OVS_MASKED(ttl, key.base.ttl, mask.base.ttl);
|
|
|
|
flow_key->nsh.base.ttl = ttl;
|
|
|
|
nsh_set_flags_and_ttl(nh, flags, ttl);
|
|
|
|
nh->path_hdr = OVS_MASKED(nh->path_hdr, key.base.path_hdr,
|
|
|
|
mask.base.path_hdr);
|
|
|
|
flow_key->nsh.base.path_hdr = nh->path_hdr;
|
|
|
|
switch (nh->mdtype) {
|
|
|
|
case NSH_M_TYPE1:
|
|
|
|
for (i = 0; i < NSH_MD1_CONTEXT_SIZE; i++) {
|
|
|
|
nh->md1.context[i] =
|
|
|
|
OVS_MASKED(nh->md1.context[i], key.context[i],
|
|
|
|
mask.context[i]);
|
|
|
|
}
|
|
|
|
memcpy(flow_key->nsh.context, nh->md1.context,
|
|
|
|
sizeof(nh->md1.context));
|
|
|
|
break;
|
|
|
|
case NSH_M_TYPE2:
|
|
|
|
memset(flow_key->nsh.context, 0,
|
|
|
|
sizeof(flow_key->nsh.context));
|
|
|
|
break;
|
|
|
|
default:
|
|
|
|
return -EINVAL;
|
|
|
|
}
|
|
|
|
skb_postpush_rcsum(skb, nh, length);
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2014-11-19 20:05:01 +07:00
|
|
|
/* Must follow skb_ensure_writable() since that can move the skb data. */
|
2011-10-26 09:26:31 +07:00
|
|
|
static void set_tp_port(struct sk_buff *skb, __be16 *port,
|
2015-02-06 04:40:49 +07:00
|
|
|
__be16 new_port, __sum16 *check)
|
2011-10-26 09:26:31 +07:00
|
|
|
{
|
2015-08-18 03:42:25 +07:00
|
|
|
inet_proto_csum_replace2(check, skb, *port, new_port, false);
|
2011-10-26 09:26:31 +07:00
|
|
|
*port = new_port;
|
2012-03-07 06:05:46 +07:00
|
|
|
}
|
|
|
|
|
2015-02-06 04:40:49 +07:00
|
|
|
static int set_udp(struct sk_buff *skb, struct sw_flow_key *flow_key,
|
|
|
|
const struct ovs_key_udp *key,
|
|
|
|
const struct ovs_key_udp *mask)
|
2011-10-26 09:26:31 +07:00
|
|
|
{
|
|
|
|
struct udphdr *uh;
|
2015-02-06 04:40:49 +07:00
|
|
|
__be16 src, dst;
|
2011-10-26 09:26:31 +07:00
|
|
|
int err;
|
|
|
|
|
2014-11-19 20:05:01 +07:00
|
|
|
err = skb_ensure_writable(skb, skb_transport_offset(skb) +
|
|
|
|
sizeof(struct udphdr));
|
2011-10-26 09:26:31 +07:00
|
|
|
if (unlikely(err))
|
|
|
|
return err;
|
|
|
|
|
|
|
|
uh = udp_hdr(skb);
|
2015-02-06 04:40:49 +07:00
|
|
|
/* Either of the masks is non-zero, so do not bother checking them. */
|
2015-08-27 01:31:45 +07:00
|
|
|
src = OVS_MASKED(uh->source, key->udp_src, mask->udp_src);
|
|
|
|
dst = OVS_MASKED(uh->dest, key->udp_dst, mask->udp_dst);
|
2011-10-26 09:26:31 +07:00
|
|
|
|
2015-02-06 04:40:49 +07:00
|
|
|
if (uh->check && skb->ip_summed != CHECKSUM_PARTIAL) {
|
|
|
|
if (likely(src != uh->source)) {
|
|
|
|
set_tp_port(skb, &uh->source, src, &uh->check);
|
|
|
|
flow_key->tp.src = src;
|
|
|
|
}
|
|
|
|
if (likely(dst != uh->dest)) {
|
|
|
|
set_tp_port(skb, &uh->dest, dst, &uh->check);
|
|
|
|
flow_key->tp.dst = dst;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (unlikely(!uh->check))
|
|
|
|
uh->check = CSUM_MANGLED_0;
|
|
|
|
} else {
|
|
|
|
uh->source = src;
|
|
|
|
uh->dest = dst;
|
|
|
|
flow_key->tp.src = src;
|
|
|
|
flow_key->tp.dst = dst;
|
2014-11-06 21:55:14 +07:00
|
|
|
}
|
2011-10-26 09:26:31 +07:00
|
|
|
|
2015-02-06 04:40:49 +07:00
|
|
|
skb_clear_hash(skb);
|
|
|
|
|
2011-10-26 09:26:31 +07:00
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2015-02-06 04:40:49 +07:00
|
|
|
static int set_tcp(struct sk_buff *skb, struct sw_flow_key *flow_key,
|
|
|
|
const struct ovs_key_tcp *key,
|
|
|
|
const struct ovs_key_tcp *mask)
|
2011-10-26 09:26:31 +07:00
|
|
|
{
|
|
|
|
struct tcphdr *th;
|
2015-02-06 04:40:49 +07:00
|
|
|
__be16 src, dst;
|
2011-10-26 09:26:31 +07:00
|
|
|
int err;
|
|
|
|
|
2014-11-19 20:05:01 +07:00
|
|
|
err = skb_ensure_writable(skb, skb_transport_offset(skb) +
|
|
|
|
sizeof(struct tcphdr));
|
2011-10-26 09:26:31 +07:00
|
|
|
if (unlikely(err))
|
|
|
|
return err;
|
|
|
|
|
|
|
|
th = tcp_hdr(skb);
|
2015-08-27 01:31:45 +07:00
|
|
|
src = OVS_MASKED(th->source, key->tcp_src, mask->tcp_src);
|
2015-02-06 04:40:49 +07:00
|
|
|
if (likely(src != th->source)) {
|
|
|
|
set_tp_port(skb, &th->source, src, &th->check);
|
|
|
|
flow_key->tp.src = src;
|
2014-11-06 21:55:14 +07:00
|
|
|
}
|
2015-08-27 01:31:45 +07:00
|
|
|
dst = OVS_MASKED(th->dest, key->tcp_dst, mask->tcp_dst);
|
2015-02-06 04:40:49 +07:00
|
|
|
if (likely(dst != th->dest)) {
|
|
|
|
set_tp_port(skb, &th->dest, dst, &th->check);
|
|
|
|
flow_key->tp.dst = dst;
|
2014-11-06 21:55:14 +07:00
|
|
|
}
|
2015-02-06 04:40:49 +07:00
|
|
|
skb_clear_hash(skb);
|
2011-10-26 09:26:31 +07:00
|
|
|
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2015-02-06 04:40:49 +07:00
|
|
|
static int set_sctp(struct sk_buff *skb, struct sw_flow_key *flow_key,
|
|
|
|
const struct ovs_key_sctp *key,
|
|
|
|
const struct ovs_key_sctp *mask)
|
2013-08-23 02:30:48 +07:00
|
|
|
{
|
2015-02-06 04:40:49 +07:00
|
|
|
unsigned int sctphoff = skb_transport_offset(skb);
|
2013-08-23 02:30:48 +07:00
|
|
|
struct sctphdr *sh;
|
2015-02-06 04:40:49 +07:00
|
|
|
__le32 old_correct_csum, new_csum, old_csum;
|
2013-08-23 02:30:48 +07:00
|
|
|
int err;
|
|
|
|
|
2014-11-19 20:05:01 +07:00
|
|
|
err = skb_ensure_writable(skb, sctphoff + sizeof(struct sctphdr));
|
2013-08-23 02:30:48 +07:00
|
|
|
if (unlikely(err))
|
|
|
|
return err;
|
|
|
|
|
|
|
|
sh = sctp_hdr(skb);
|
2015-02-06 04:40:49 +07:00
|
|
|
old_csum = sh->checksum;
|
|
|
|
old_correct_csum = sctp_compute_cksum(skb, sctphoff);
|
2013-08-23 02:30:48 +07:00
|
|
|
|
2015-08-27 01:31:45 +07:00
|
|
|
sh->source = OVS_MASKED(sh->source, key->sctp_src, mask->sctp_src);
|
|
|
|
sh->dest = OVS_MASKED(sh->dest, key->sctp_dst, mask->sctp_dst);
|
2013-08-23 02:30:48 +07:00
|
|
|
|
2015-02-06 04:40:49 +07:00
|
|
|
new_csum = sctp_compute_cksum(skb, sctphoff);
|
2013-08-23 02:30:48 +07:00
|
|
|
|
2015-02-06 04:40:49 +07:00
|
|
|
/* Carry any checksum errors through. */
|
|
|
|
sh->checksum = old_csum ^ old_correct_csum ^ new_csum;
|
2013-08-23 02:30:48 +07:00
|
|
|
|
2015-02-06 04:40:49 +07:00
|
|
|
skb_clear_hash(skb);
|
|
|
|
flow_key->tp.src = sh->source;
|
|
|
|
flow_key->tp.dst = sh->dest;
|
2013-08-23 02:30:48 +07:00
|
|
|
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2015-09-15 08:08:51 +07:00
|
|
|
static int ovs_vport_output(struct net *net, struct sock *sk, struct sk_buff *skb)
|
2015-08-27 01:31:48 +07:00
|
|
|
{
|
|
|
|
struct ovs_frag_data *data = this_cpu_ptr(&ovs_frag_data_storage);
|
|
|
|
struct vport *vport = data->vport;
|
|
|
|
|
|
|
|
if (skb_cow_head(skb, data->l2_len) < 0) {
|
|
|
|
kfree_skb(skb);
|
|
|
|
return -ENOMEM;
|
|
|
|
}
|
|
|
|
|
|
|
|
__skb_dst_copy(skb, data->dst);
|
|
|
|
*OVS_CB(skb) = data->cb;
|
|
|
|
skb->inner_protocol = data->inner_protocol;
|
|
|
|
skb->vlan_tci = data->vlan_tci;
|
|
|
|
skb->vlan_proto = data->vlan_proto;
|
|
|
|
|
|
|
|
/* Reconstruct the MAC header. */
|
|
|
|
skb_push(skb, data->l2_len);
|
|
|
|
memcpy(skb->data, &data->l2_data, data->l2_len);
|
2016-02-20 06:29:30 +07:00
|
|
|
skb_postpush_rcsum(skb, skb->data, data->l2_len);
|
2015-08-27 01:31:48 +07:00
|
|
|
skb_reset_mac_header(skb);
|
|
|
|
|
2016-10-05 20:01:57 +07:00
|
|
|
if (eth_p_mpls(skb->protocol)) {
|
|
|
|
skb->inner_network_header = skb->network_header;
|
|
|
|
skb_set_network_header(skb, data->network_offset);
|
|
|
|
skb_reset_mac_len(skb);
|
|
|
|
}
|
|
|
|
|
2016-11-10 22:28:19 +07:00
|
|
|
ovs_vport_send(vport, skb, data->mac_proto);
|
2015-08-27 01:31:48 +07:00
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
static unsigned int
|
|
|
|
ovs_dst_get_mtu(const struct dst_entry *dst)
|
|
|
|
{
|
|
|
|
return dst->dev->mtu;
|
|
|
|
}
|
|
|
|
|
|
|
|
static struct dst_ops ovs_dst_ops = {
|
|
|
|
.family = AF_UNSPEC,
|
|
|
|
.mtu = ovs_dst_get_mtu,
|
|
|
|
};
|
|
|
|
|
|
|
|
/* prepare_frag() is called once per (larger-than-MTU) frame; its inverse is
|
|
|
|
* ovs_vport_output(), which is called once per fragmented packet.
|
|
|
|
*/
|
2016-10-05 20:01:57 +07:00
|
|
|
static void prepare_frag(struct vport *vport, struct sk_buff *skb,
|
2016-11-10 22:28:19 +07:00
|
|
|
u16 orig_network_offset, u8 mac_proto)
|
2015-08-27 01:31:48 +07:00
|
|
|
{
|
|
|
|
unsigned int hlen = skb_network_offset(skb);
|
|
|
|
struct ovs_frag_data *data;
|
|
|
|
|
|
|
|
data = this_cpu_ptr(&ovs_frag_data_storage);
|
|
|
|
data->dst = skb->_skb_refdst;
|
|
|
|
data->vport = vport;
|
|
|
|
data->cb = *OVS_CB(skb);
|
|
|
|
data->inner_protocol = skb->inner_protocol;
|
2016-10-05 20:01:57 +07:00
|
|
|
data->network_offset = orig_network_offset;
|
2015-08-27 01:31:48 +07:00
|
|
|
data->vlan_tci = skb->vlan_tci;
|
|
|
|
data->vlan_proto = skb->vlan_proto;
|
2016-11-10 22:28:19 +07:00
|
|
|
data->mac_proto = mac_proto;
|
2015-08-27 01:31:48 +07:00
|
|
|
data->l2_len = hlen;
|
|
|
|
memcpy(&data->l2_data, skb->data, hlen);
|
|
|
|
|
|
|
|
memset(IPCB(skb), 0, sizeof(struct inet_skb_parm));
|
|
|
|
skb_pull(skb, hlen);
|
|
|
|
}
|
|
|
|
|
2015-09-15 08:10:28 +07:00
|
|
|
static void ovs_fragment(struct net *net, struct vport *vport,
|
2016-11-10 22:28:19 +07:00
|
|
|
struct sk_buff *skb, u16 mru,
|
|
|
|
struct sw_flow_key *key)
|
2015-08-27 01:31:48 +07:00
|
|
|
{
|
2016-10-05 20:01:57 +07:00
|
|
|
u16 orig_network_offset = 0;
|
|
|
|
|
|
|
|
if (eth_p_mpls(skb->protocol)) {
|
|
|
|
orig_network_offset = skb_network_offset(skb);
|
|
|
|
skb->network_header = skb->inner_network_header;
|
|
|
|
}
|
|
|
|
|
2015-08-27 01:31:48 +07:00
|
|
|
if (skb_network_offset(skb) > MAX_L2_LEN) {
|
|
|
|
OVS_NLERR(1, "L2 header too long to fragment");
|
2015-10-07 00:59:57 +07:00
|
|
|
goto err;
|
2015-08-27 01:31:48 +07:00
|
|
|
}
|
|
|
|
|
2016-11-10 22:28:19 +07:00
|
|
|
if (key->eth.type == htons(ETH_P_IP)) {
|
2015-08-27 01:31:48 +07:00
|
|
|
struct dst_entry ovs_dst;
|
|
|
|
unsigned long orig_dst;
|
|
|
|
|
2016-11-10 22:28:19 +07:00
|
|
|
prepare_frag(vport, skb, orig_network_offset,
|
|
|
|
ovs_key_mac_proto(key));
|
2015-08-27 01:31:48 +07:00
|
|
|
dst_init(&ovs_dst, &ovs_dst_ops, NULL, 1,
|
|
|
|
DST_OBSOLETE_NONE, DST_NOCOUNT);
|
|
|
|
ovs_dst.dev = vport->dev;
|
|
|
|
|
|
|
|
orig_dst = skb->_skb_refdst;
|
|
|
|
skb_dst_set_noref(skb, &ovs_dst);
|
|
|
|
IPCB(skb)->frag_max_size = mru;
|
|
|
|
|
2015-06-13 09:55:31 +07:00
|
|
|
ip_do_fragment(net, skb->sk, skb, ovs_vport_output);
|
2015-08-27 01:31:48 +07:00
|
|
|
refdst_drop(orig_dst);
|
2016-11-10 22:28:19 +07:00
|
|
|
} else if (key->eth.type == htons(ETH_P_IPV6)) {
|
2015-08-27 01:31:48 +07:00
|
|
|
const struct nf_ipv6_ops *v6ops = nf_get_ipv6_ops();
|
|
|
|
unsigned long orig_dst;
|
|
|
|
struct rt6_info ovs_rt;
|
|
|
|
|
2017-03-01 16:01:17 +07:00
|
|
|
if (!v6ops)
|
2015-10-07 00:59:57 +07:00
|
|
|
goto err;
|
2015-08-27 01:31:48 +07:00
|
|
|
|
2016-11-10 22:28:19 +07:00
|
|
|
prepare_frag(vport, skb, orig_network_offset,
|
|
|
|
ovs_key_mac_proto(key));
|
2015-08-27 01:31:48 +07:00
|
|
|
memset(&ovs_rt, 0, sizeof(ovs_rt));
|
|
|
|
dst_init(&ovs_rt.dst, &ovs_dst_ops, NULL, 1,
|
|
|
|
DST_OBSOLETE_NONE, DST_NOCOUNT);
|
|
|
|
ovs_rt.dst.dev = vport->dev;
|
|
|
|
|
|
|
|
orig_dst = skb->_skb_refdst;
|
|
|
|
skb_dst_set_noref(skb, &ovs_rt.dst);
|
|
|
|
IP6CB(skb)->frag_max_size = mru;
|
|
|
|
|
2015-06-13 10:12:04 +07:00
|
|
|
v6ops->fragment(net, skb->sk, skb, ovs_vport_output);
|
2015-08-27 01:31:48 +07:00
|
|
|
refdst_drop(orig_dst);
|
|
|
|
} else {
|
|
|
|
WARN_ONCE(1, "Failed fragment ->%s: eth=%04x, MRU=%d, MTU=%d.",
|
2016-11-10 22:28:19 +07:00
|
|
|
ovs_vport_name(vport), ntohs(key->eth.type), mru,
|
2015-08-27 01:31:48 +07:00
|
|
|
vport->dev->mtu);
|
2015-10-07 00:59:57 +07:00
|
|
|
goto err;
|
2015-08-27 01:31:48 +07:00
|
|
|
}
|
2015-10-07 00:59:57 +07:00
|
|
|
|
|
|
|
return;
|
|
|
|
err:
|
|
|
|
kfree_skb(skb);
|
2015-08-27 01:31:48 +07:00
|
|
|
}
|
|
|
|
|
|
|
|
static void do_output(struct datapath *dp, struct sk_buff *skb, int out_port,
|
|
|
|
struct sw_flow_key *key)
|
2011-10-26 09:26:31 +07:00
|
|
|
{
|
2014-09-08 14:35:02 +07:00
|
|
|
struct vport *vport = ovs_vport_rcu(dp, out_port);
|
2011-10-26 09:26:31 +07:00
|
|
|
|
2015-08-27 01:31:48 +07:00
|
|
|
if (likely(vport)) {
|
|
|
|
u16 mru = OVS_CB(skb)->mru;
|
2016-06-11 01:49:33 +07:00
|
|
|
u32 cutlen = OVS_CB(skb)->cutlen;
|
|
|
|
|
|
|
|
if (unlikely(cutlen > 0)) {
|
2016-11-10 22:28:19 +07:00
|
|
|
if (skb->len - cutlen > ovs_mac_header_len(key))
|
2016-06-11 01:49:33 +07:00
|
|
|
pskb_trim(skb, skb->len - cutlen);
|
|
|
|
else
|
2016-11-10 22:28:19 +07:00
|
|
|
pskb_trim(skb, ovs_mac_header_len(key));
|
2016-06-11 01:49:33 +07:00
|
|
|
}
|
2015-08-27 01:31:48 +07:00
|
|
|
|
2016-11-10 22:28:17 +07:00
|
|
|
if (likely(!mru ||
|
|
|
|
(skb->len <= mru + vport->dev->hard_header_len))) {
|
2016-11-10 22:28:19 +07:00
|
|
|
ovs_vport_send(vport, skb, ovs_key_mac_proto(key));
|
2015-08-27 01:31:48 +07:00
|
|
|
} else if (mru <= vport->dev->mtu) {
|
2015-09-15 08:10:28 +07:00
|
|
|
struct net *net = read_pnet(&dp->net);
|
2015-08-27 01:31:48 +07:00
|
|
|
|
2016-11-10 22:28:19 +07:00
|
|
|
ovs_fragment(net, vport, skb, mru, key);
|
2015-08-27 01:31:48 +07:00
|
|
|
} else {
|
|
|
|
kfree_skb(skb);
|
|
|
|
}
|
|
|
|
} else {
|
2011-10-26 09:26:31 +07:00
|
|
|
kfree_skb(skb);
|
2015-08-27 01:31:48 +07:00
|
|
|
}
|
2011-10-26 09:26:31 +07:00
|
|
|
}
|
|
|
|
|
|
|
|
static int output_userspace(struct datapath *dp, struct sk_buff *skb,
|
2015-05-27 10:59:43 +07:00
|
|
|
struct sw_flow_key *key, const struct nlattr *attr,
|
2016-06-11 01:49:33 +07:00
|
|
|
const struct nlattr *actions, int actions_len,
|
|
|
|
uint32_t cutlen)
|
2011-10-26 09:26:31 +07:00
|
|
|
{
|
|
|
|
struct dp_upcall_info upcall;
|
|
|
|
const struct nlattr *a;
|
|
|
|
int rem;
|
|
|
|
|
2015-05-27 10:59:43 +07:00
|
|
|
memset(&upcall, 0, sizeof(upcall));
|
2011-10-26 09:26:31 +07:00
|
|
|
upcall.cmd = OVS_PACKET_CMD_ACTION;
|
2015-08-27 01:31:48 +07:00
|
|
|
upcall.mru = OVS_CB(skb)->mru;
|
2011-10-26 09:26:31 +07:00
|
|
|
|
|
|
|
for (a = nla_data(attr), rem = nla_len(attr); rem > 0;
|
|
|
|
a = nla_next(a, &rem)) {
|
|
|
|
switch (nla_type(a)) {
|
|
|
|
case OVS_USERSPACE_ATTR_USERDATA:
|
|
|
|
upcall.userdata = a;
|
|
|
|
break;
|
|
|
|
|
|
|
|
case OVS_USERSPACE_ATTR_PID:
|
2012-09-08 03:12:54 +07:00
|
|
|
upcall.portid = nla_get_u32(a);
|
2011-10-26 09:26:31 +07:00
|
|
|
break;
|
2014-11-06 21:51:24 +07:00
|
|
|
|
|
|
|
case OVS_USERSPACE_ATTR_EGRESS_TUN_PORT: {
|
|
|
|
/* Get out tunnel info. */
|
|
|
|
struct vport *vport;
|
|
|
|
|
|
|
|
vport = ovs_vport_rcu(dp, nla_get_u32(a));
|
|
|
|
if (vport) {
|
|
|
|
int err;
|
|
|
|
|
2015-10-23 08:17:16 +07:00
|
|
|
err = dev_fill_metadata_dst(vport->dev, skb);
|
|
|
|
if (!err)
|
|
|
|
upcall.egress_tun_info = skb_tunnel_info(skb);
|
2014-11-06 21:51:24 +07:00
|
|
|
}
|
2015-08-31 08:09:38 +07:00
|
|
|
|
2014-11-06 21:51:24 +07:00
|
|
|
break;
|
2011-10-26 09:26:31 +07:00
|
|
|
}
|
2014-11-06 21:51:24 +07:00
|
|
|
|
2015-05-27 10:59:43 +07:00
|
|
|
case OVS_USERSPACE_ATTR_ACTIONS: {
|
|
|
|
/* Include actions. */
|
|
|
|
upcall.actions = actions;
|
|
|
|
upcall.actions_len = actions_len;
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
|
2014-11-06 21:51:24 +07:00
|
|
|
} /* End of switch. */
|
2011-10-26 09:26:31 +07:00
|
|
|
}
|
|
|
|
|
2016-06-11 01:49:33 +07:00
|
|
|
return ovs_dp_upcall(dp, skb, key, &upcall, cutlen);
|
2011-10-26 09:26:31 +07:00
|
|
|
}
|
|
|
|
|
openvswitch: Optimize sample action for the clone use cases
With the introduction of open flow 'clone' action, the OVS user space
can now translate the 'clone' action into kernel datapath 'sample'
action, with 100% probability, to ensure that the clone semantics,
which is that the packet seen by the clone action is the same as the
packet seen by the action after clone, is faithfully carried out
in the datapath.
While the sample action in the datpath has the matching semantics,
its implementation is only optimized for its original use.
Specifically, there are two limitation: First, there is a 3 level of
nesting restriction, enforced at the flow downloading time. This
limit turns out to be too restrictive for the 'clone' use case.
Second, the implementation avoid recursive call only if the sample
action list has a single userspace action.
The main optimization implemented in this series removes the static
nesting limit check, instead, implement the run time recursion limit
check, and recursion avoidance similar to that of the 'recirc' action.
This optimization solve both #1 and #2 issues above.
One related optimization attempts to avoid copying flow key as
long as the actions enclosed does not change the flow key. The
detection is performed only once at the flow downloading time.
Another related optimization is to rewrite the action list
at flow downloading time in order to save the fast path from parsing
the sample action list in its original form repeatedly.
Signed-off-by: Andy Zhou <azhou@ovn.org>
Acked-by: Pravin B Shelar <pshelar@ovn.org>
Signed-off-by: David S. Miller <davem@davemloft.net>
2017-03-21 06:32:29 +07:00
|
|
|
/* When 'last' is true, sample() should always consume the 'skb'.
|
|
|
|
* Otherwise, sample() should keep 'skb' intact regardless what
|
|
|
|
* actions are executed within sample().
|
|
|
|
*/
|
2011-10-26 09:26:31 +07:00
|
|
|
static int sample(struct datapath *dp, struct sk_buff *skb,
|
2015-05-27 10:59:43 +07:00
|
|
|
struct sw_flow_key *key, const struct nlattr *attr,
|
openvswitch: Optimize sample action for the clone use cases
With the introduction of open flow 'clone' action, the OVS user space
can now translate the 'clone' action into kernel datapath 'sample'
action, with 100% probability, to ensure that the clone semantics,
which is that the packet seen by the clone action is the same as the
packet seen by the action after clone, is faithfully carried out
in the datapath.
While the sample action in the datpath has the matching semantics,
its implementation is only optimized for its original use.
Specifically, there are two limitation: First, there is a 3 level of
nesting restriction, enforced at the flow downloading time. This
limit turns out to be too restrictive for the 'clone' use case.
Second, the implementation avoid recursive call only if the sample
action list has a single userspace action.
The main optimization implemented in this series removes the static
nesting limit check, instead, implement the run time recursion limit
check, and recursion avoidance similar to that of the 'recirc' action.
This optimization solve both #1 and #2 issues above.
One related optimization attempts to avoid copying flow key as
long as the actions enclosed does not change the flow key. The
detection is performed only once at the flow downloading time.
Another related optimization is to rewrite the action list
at flow downloading time in order to save the fast path from parsing
the sample action list in its original form repeatedly.
Signed-off-by: Andy Zhou <azhou@ovn.org>
Acked-by: Pravin B Shelar <pshelar@ovn.org>
Signed-off-by: David S. Miller <davem@davemloft.net>
2017-03-21 06:32:29 +07:00
|
|
|
bool last)
|
2011-10-26 09:26:31 +07:00
|
|
|
{
|
openvswitch: Optimize sample action for the clone use cases
With the introduction of open flow 'clone' action, the OVS user space
can now translate the 'clone' action into kernel datapath 'sample'
action, with 100% probability, to ensure that the clone semantics,
which is that the packet seen by the clone action is the same as the
packet seen by the action after clone, is faithfully carried out
in the datapath.
While the sample action in the datpath has the matching semantics,
its implementation is only optimized for its original use.
Specifically, there are two limitation: First, there is a 3 level of
nesting restriction, enforced at the flow downloading time. This
limit turns out to be too restrictive for the 'clone' use case.
Second, the implementation avoid recursive call only if the sample
action list has a single userspace action.
The main optimization implemented in this series removes the static
nesting limit check, instead, implement the run time recursion limit
check, and recursion avoidance similar to that of the 'recirc' action.
This optimization solve both #1 and #2 issues above.
One related optimization attempts to avoid copying flow key as
long as the actions enclosed does not change the flow key. The
detection is performed only once at the flow downloading time.
Another related optimization is to rewrite the action list
at flow downloading time in order to save the fast path from parsing
the sample action list in its original form repeatedly.
Signed-off-by: Andy Zhou <azhou@ovn.org>
Acked-by: Pravin B Shelar <pshelar@ovn.org>
Signed-off-by: David S. Miller <davem@davemloft.net>
2017-03-21 06:32:29 +07:00
|
|
|
struct nlattr *actions;
|
|
|
|
struct nlattr *sample_arg;
|
|
|
|
int rem = nla_len(attr);
|
|
|
|
const struct sample_arg *arg;
|
2017-03-21 06:32:30 +07:00
|
|
|
bool clone_flow_key;
|
2011-10-26 09:26:31 +07:00
|
|
|
|
openvswitch: Optimize sample action for the clone use cases
With the introduction of open flow 'clone' action, the OVS user space
can now translate the 'clone' action into kernel datapath 'sample'
action, with 100% probability, to ensure that the clone semantics,
which is that the packet seen by the clone action is the same as the
packet seen by the action after clone, is faithfully carried out
in the datapath.
While the sample action in the datpath has the matching semantics,
its implementation is only optimized for its original use.
Specifically, there are two limitation: First, there is a 3 level of
nesting restriction, enforced at the flow downloading time. This
limit turns out to be too restrictive for the 'clone' use case.
Second, the implementation avoid recursive call only if the sample
action list has a single userspace action.
The main optimization implemented in this series removes the static
nesting limit check, instead, implement the run time recursion limit
check, and recursion avoidance similar to that of the 'recirc' action.
This optimization solve both #1 and #2 issues above.
One related optimization attempts to avoid copying flow key as
long as the actions enclosed does not change the flow key. The
detection is performed only once at the flow downloading time.
Another related optimization is to rewrite the action list
at flow downloading time in order to save the fast path from parsing
the sample action list in its original form repeatedly.
Signed-off-by: Andy Zhou <azhou@ovn.org>
Acked-by: Pravin B Shelar <pshelar@ovn.org>
Signed-off-by: David S. Miller <davem@davemloft.net>
2017-03-21 06:32:29 +07:00
|
|
|
/* The first action is always 'OVS_SAMPLE_ATTR_ARG'. */
|
|
|
|
sample_arg = nla_data(attr);
|
|
|
|
arg = nla_data(sample_arg);
|
|
|
|
actions = nla_next(sample_arg, &rem);
|
2015-08-05 14:30:47 +07:00
|
|
|
|
openvswitch: Optimize sample action for the clone use cases
With the introduction of open flow 'clone' action, the OVS user space
can now translate the 'clone' action into kernel datapath 'sample'
action, with 100% probability, to ensure that the clone semantics,
which is that the packet seen by the clone action is the same as the
packet seen by the action after clone, is faithfully carried out
in the datapath.
While the sample action in the datpath has the matching semantics,
its implementation is only optimized for its original use.
Specifically, there are two limitation: First, there is a 3 level of
nesting restriction, enforced at the flow downloading time. This
limit turns out to be too restrictive for the 'clone' use case.
Second, the implementation avoid recursive call only if the sample
action list has a single userspace action.
The main optimization implemented in this series removes the static
nesting limit check, instead, implement the run time recursion limit
check, and recursion avoidance similar to that of the 'recirc' action.
This optimization solve both #1 and #2 issues above.
One related optimization attempts to avoid copying flow key as
long as the actions enclosed does not change the flow key. The
detection is performed only once at the flow downloading time.
Another related optimization is to rewrite the action list
at flow downloading time in order to save the fast path from parsing
the sample action list in its original form repeatedly.
Signed-off-by: Andy Zhou <azhou@ovn.org>
Acked-by: Pravin B Shelar <pshelar@ovn.org>
Signed-off-by: David S. Miller <davem@davemloft.net>
2017-03-21 06:32:29 +07:00
|
|
|
if ((arg->probability != U32_MAX) &&
|
|
|
|
(!arg->probability || prandom_u32() > arg->probability)) {
|
|
|
|
if (last)
|
|
|
|
consume_skb(skb);
|
|
|
|
return 0;
|
2011-10-26 09:26:31 +07:00
|
|
|
}
|
|
|
|
|
2017-03-21 06:32:30 +07:00
|
|
|
clone_flow_key = !arg->exec;
|
|
|
|
return clone_execute(dp, skb, key, 0, actions, rem, last,
|
|
|
|
clone_flow_key);
|
2014-09-16 09:37:25 +07:00
|
|
|
}
|
|
|
|
|
2018-07-02 22:18:03 +07:00
|
|
|
/* When 'last' is true, clone() should always consume the 'skb'.
|
|
|
|
* Otherwise, clone() should keep 'skb' intact regardless what
|
|
|
|
* actions are executed within clone().
|
|
|
|
*/
|
|
|
|
static int clone(struct datapath *dp, struct sk_buff *skb,
|
|
|
|
struct sw_flow_key *key, const struct nlattr *attr,
|
|
|
|
bool last)
|
|
|
|
{
|
|
|
|
struct nlattr *actions;
|
|
|
|
struct nlattr *clone_arg;
|
|
|
|
int rem = nla_len(attr);
|
|
|
|
bool dont_clone_flow_key;
|
|
|
|
|
|
|
|
/* The first action is always 'OVS_CLONE_ATTR_ARG'. */
|
|
|
|
clone_arg = nla_data(attr);
|
|
|
|
dont_clone_flow_key = nla_get_u32(clone_arg);
|
|
|
|
actions = nla_next(clone_arg, &rem);
|
|
|
|
|
|
|
|
return clone_execute(dp, skb, key, 0, actions, rem, last,
|
|
|
|
!dont_clone_flow_key);
|
|
|
|
}
|
|
|
|
|
2014-09-16 09:37:25 +07:00
|
|
|
static void execute_hash(struct sk_buff *skb, struct sw_flow_key *key,
|
|
|
|
const struct nlattr *attr)
|
|
|
|
{
|
|
|
|
struct ovs_action_hash *hash_act = nla_data(attr);
|
|
|
|
u32 hash = 0;
|
|
|
|
|
|
|
|
/* OVS_HASH_ALG_L4 is the only possible hash algorithm. */
|
|
|
|
hash = skb_get_hash(skb);
|
|
|
|
hash = jhash_1word(hash, hash_act->hash_basis);
|
|
|
|
if (!hash)
|
|
|
|
hash = 0x1;
|
|
|
|
|
|
|
|
key->ovs_flow_hash = hash;
|
2011-10-26 09:26:31 +07:00
|
|
|
}
|
|
|
|
|
2015-02-06 04:40:49 +07:00
|
|
|
static int execute_set_action(struct sk_buff *skb,
|
|
|
|
struct sw_flow_key *flow_key,
|
|
|
|
const struct nlattr *a)
|
|
|
|
{
|
|
|
|
/* Only tunnel set execution is supported without a mask. */
|
|
|
|
if (nla_type(a) == OVS_KEY_ATTR_TUNNEL_INFO) {
|
2015-07-21 15:44:03 +07:00
|
|
|
struct ovs_tunnel_info *tun = nla_data(a);
|
|
|
|
|
|
|
|
skb_dst_drop(skb);
|
|
|
|
dst_hold((struct dst_entry *)tun->tun_dst);
|
|
|
|
skb_dst_set(skb, (struct dst_entry *)tun->tun_dst);
|
2015-02-06 04:40:49 +07:00
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
return -EINVAL;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Mask is at the midpoint of the data. */
|
|
|
|
#define get_mask(a, type) ((const type)nla_data(a) + 1)
|
|
|
|
|
|
|
|
static int execute_masked_set_action(struct sk_buff *skb,
|
|
|
|
struct sw_flow_key *flow_key,
|
|
|
|
const struct nlattr *a)
|
2011-10-26 09:26:31 +07:00
|
|
|
{
|
|
|
|
int err = 0;
|
|
|
|
|
2015-02-06 04:40:49 +07:00
|
|
|
switch (nla_type(a)) {
|
2011-10-26 09:26:31 +07:00
|
|
|
case OVS_KEY_ATTR_PRIORITY:
|
2015-08-27 01:31:45 +07:00
|
|
|
OVS_SET_MASKED(skb->priority, nla_get_u32(a),
|
|
|
|
*get_mask(a, u32 *));
|
2015-02-06 04:40:49 +07:00
|
|
|
flow_key->phy.priority = skb->priority;
|
2011-10-26 09:26:31 +07:00
|
|
|
break;
|
|
|
|
|
2012-11-27 02:24:11 +07:00
|
|
|
case OVS_KEY_ATTR_SKB_MARK:
|
2015-08-27 01:31:45 +07:00
|
|
|
OVS_SET_MASKED(skb->mark, nla_get_u32(a), *get_mask(a, u32 *));
|
2015-02-06 04:40:49 +07:00
|
|
|
flow_key->phy.skb_mark = skb->mark;
|
2012-11-27 02:24:11 +07:00
|
|
|
break;
|
|
|
|
|
2014-10-04 05:35:31 +07:00
|
|
|
case OVS_KEY_ATTR_TUNNEL_INFO:
|
2015-02-06 04:40:49 +07:00
|
|
|
/* Masked data not supported for tunnel. */
|
|
|
|
err = -EINVAL;
|
2013-06-18 07:50:18 +07:00
|
|
|
break;
|
|
|
|
|
2011-10-26 09:26:31 +07:00
|
|
|
case OVS_KEY_ATTR_ETHERNET:
|
2015-02-06 04:40:49 +07:00
|
|
|
err = set_eth_addr(skb, flow_key, nla_data(a),
|
|
|
|
get_mask(a, struct ovs_key_ethernet *));
|
2011-10-26 09:26:31 +07:00
|
|
|
break;
|
|
|
|
|
2017-11-07 20:07:02 +07:00
|
|
|
case OVS_KEY_ATTR_NSH:
|
|
|
|
err = set_nsh(skb, flow_key, a);
|
|
|
|
break;
|
|
|
|
|
2011-10-26 09:26:31 +07:00
|
|
|
case OVS_KEY_ATTR_IPV4:
|
2015-02-06 04:40:49 +07:00
|
|
|
err = set_ipv4(skb, flow_key, nla_data(a),
|
|
|
|
get_mask(a, struct ovs_key_ipv4 *));
|
2011-10-26 09:26:31 +07:00
|
|
|
break;
|
|
|
|
|
2012-11-14 06:44:14 +07:00
|
|
|
case OVS_KEY_ATTR_IPV6:
|
2015-02-06 04:40:49 +07:00
|
|
|
err = set_ipv6(skb, flow_key, nla_data(a),
|
|
|
|
get_mask(a, struct ovs_key_ipv6 *));
|
2012-11-14 06:44:14 +07:00
|
|
|
break;
|
|
|
|
|
2011-10-26 09:26:31 +07:00
|
|
|
case OVS_KEY_ATTR_TCP:
|
2015-02-06 04:40:49 +07:00
|
|
|
err = set_tcp(skb, flow_key, nla_data(a),
|
|
|
|
get_mask(a, struct ovs_key_tcp *));
|
2011-10-26 09:26:31 +07:00
|
|
|
break;
|
|
|
|
|
|
|
|
case OVS_KEY_ATTR_UDP:
|
2015-02-06 04:40:49 +07:00
|
|
|
err = set_udp(skb, flow_key, nla_data(a),
|
|
|
|
get_mask(a, struct ovs_key_udp *));
|
2011-10-26 09:26:31 +07:00
|
|
|
break;
|
2013-08-23 02:30:48 +07:00
|
|
|
|
|
|
|
case OVS_KEY_ATTR_SCTP:
|
2015-02-06 04:40:49 +07:00
|
|
|
err = set_sctp(skb, flow_key, nla_data(a),
|
|
|
|
get_mask(a, struct ovs_key_sctp *));
|
2013-08-23 02:30:48 +07:00
|
|
|
break;
|
2014-10-06 19:05:13 +07:00
|
|
|
|
|
|
|
case OVS_KEY_ATTR_MPLS:
|
2015-02-06 04:40:49 +07:00
|
|
|
err = set_mpls(skb, flow_key, nla_data(a), get_mask(a,
|
|
|
|
__be32 *));
|
2014-10-06 19:05:13 +07:00
|
|
|
break;
|
2015-08-27 01:31:48 +07:00
|
|
|
|
|
|
|
case OVS_KEY_ATTR_CT_STATE:
|
|
|
|
case OVS_KEY_ATTR_CT_ZONE:
|
2015-08-27 01:31:49 +07:00
|
|
|
case OVS_KEY_ATTR_CT_MARK:
|
2015-10-02 05:00:37 +07:00
|
|
|
case OVS_KEY_ATTR_CT_LABELS:
|
openvswitch: Add original direction conntrack tuple to sw_flow_key.
Add the fields of the conntrack original direction 5-tuple to struct
sw_flow_key. The new fields are initially marked as non-existent, and
are populated whenever a conntrack action is executed and either finds
or generates a conntrack entry. This means that these fields exist
for all packets that were not rejected by conntrack as untrackable.
The original tuple fields in the sw_flow_key are filled from the
original direction tuple of the conntrack entry relating to the
current packet, or from the original direction tuple of the master
conntrack entry, if the current conntrack entry has a master.
Generally, expected connections of connections having an assigned
helper (e.g., FTP), have a master conntrack entry.
The main purpose of the new conntrack original tuple fields is to
allow matching on them for policy decision purposes, with the premise
that the admissibility of tracked connections reply packets (as well
as original direction packets), and both direction packets of any
related connections may be based on ACL rules applying to the master
connection's original direction 5-tuple. This also makes it easier to
make policy decisions when the actual packet headers might have been
transformed by NAT, as the original direction 5-tuple represents the
packet headers before any such transformation.
When using the original direction 5-tuple the admissibility of return
and/or related packets need not be based on the mere existence of a
conntrack entry, allowing separation of admission policy from the
established conntrack state. While existence of a conntrack entry is
required for admission of the return or related packets, policy
changes can render connections that were initially admitted to be
rejected or dropped afterwards. If the admission of the return and
related packets was based on mere conntrack state (e.g., connection
being in an established state), a policy change that would make the
connection rejected or dropped would need to find and delete all
conntrack entries affected by such a change. When using the original
direction 5-tuple matching the affected conntrack entries can be
allowed to time out instead, as the established state of the
connection would not need to be the basis for packet admission any
more.
It should be noted that the directionality of related connections may
be the same or different than that of the master connection, and
neither the original direction 5-tuple nor the conntrack state bits
carry this information. If needed, the directionality of the master
connection can be stored in master's conntrack mark or labels, which
are automatically inherited by the expected related connections.
The fact that neither ARP nor ND packets are trackable by conntrack
allows mutual exclusion between ARP/ND and the new conntrack original
tuple fields. Hence, the IP addresses are overlaid in union with ARP
and ND fields. This allows the sw_flow_key to not grow much due to
this patch, but it also means that we must be careful to never use the
new key fields with ARP or ND packets. ARP is easy to distinguish and
keep mutually exclusive based on the ethernet type, but ND being an
ICMPv6 protocol requires a bit more attention.
Signed-off-by: Jarno Rajahalme <jarno@ovn.org>
Acked-by: Joe Stringer <joe@ovn.org>
Acked-by: Pravin B Shelar <pshelar@ovn.org>
Signed-off-by: David S. Miller <davem@davemloft.net>
2017-02-10 02:21:59 +07:00
|
|
|
case OVS_KEY_ATTR_CT_ORIG_TUPLE_IPV4:
|
|
|
|
case OVS_KEY_ATTR_CT_ORIG_TUPLE_IPV6:
|
2015-08-27 01:31:48 +07:00
|
|
|
err = -EINVAL;
|
|
|
|
break;
|
2011-10-26 09:26:31 +07:00
|
|
|
}
|
|
|
|
|
|
|
|
return err;
|
|
|
|
}
|
|
|
|
|
2014-09-16 09:37:25 +07:00
|
|
|
static int execute_recirc(struct datapath *dp, struct sk_buff *skb,
|
|
|
|
struct sw_flow_key *key,
|
2017-03-21 06:32:30 +07:00
|
|
|
const struct nlattr *a, bool last)
|
2014-09-16 09:37:25 +07:00
|
|
|
{
|
2017-03-21 06:32:30 +07:00
|
|
|
u32 recirc_id;
|
2014-09-16 09:37:25 +07:00
|
|
|
|
2014-11-06 21:55:14 +07:00
|
|
|
if (!is_flow_key_valid(key)) {
|
|
|
|
int err;
|
|
|
|
|
|
|
|
err = ovs_flow_key_update(skb, key);
|
|
|
|
if (err)
|
|
|
|
return err;
|
|
|
|
}
|
|
|
|
BUG_ON(!is_flow_key_valid(key));
|
2014-09-16 09:37:25 +07:00
|
|
|
|
2017-03-21 06:32:30 +07:00
|
|
|
recirc_id = nla_get_u32(a);
|
|
|
|
return clone_execute(dp, skb, key, recirc_id, NULL, 0, last, true);
|
2014-09-16 09:37:25 +07:00
|
|
|
}
|
|
|
|
|
2011-10-26 09:26:31 +07:00
|
|
|
/* Execute a list of actions against 'skb'. */
|
|
|
|
static int do_execute_actions(struct datapath *dp, struct sk_buff *skb,
|
2014-09-16 09:15:28 +07:00
|
|
|
struct sw_flow_key *key,
|
2014-07-22 05:12:34 +07:00
|
|
|
const struct nlattr *attr, int len)
|
2011-10-26 09:26:31 +07:00
|
|
|
{
|
|
|
|
const struct nlattr *a;
|
|
|
|
int rem;
|
|
|
|
|
|
|
|
for (a = attr, rem = len; rem > 0;
|
|
|
|
a = nla_next(a, &rem)) {
|
|
|
|
int err = 0;
|
|
|
|
|
2017-01-28 04:45:28 +07:00
|
|
|
switch (nla_type(a)) {
|
|
|
|
case OVS_ACTION_ATTR_OUTPUT: {
|
|
|
|
int port = nla_get_u32(a);
|
|
|
|
struct sk_buff *clone;
|
|
|
|
|
|
|
|
/* Every output action needs a separate clone
|
|
|
|
* of 'skb', In case the output action is the
|
|
|
|
* last action, cloning can be avoided.
|
|
|
|
*/
|
|
|
|
if (nla_is_last(a, rem)) {
|
|
|
|
do_output(dp, skb, port, key);
|
|
|
|
/* 'skb' has been used for output.
|
|
|
|
*/
|
|
|
|
return 0;
|
|
|
|
}
|
2014-09-08 14:35:02 +07:00
|
|
|
|
2017-01-28 04:45:28 +07:00
|
|
|
clone = skb_clone(skb, GFP_ATOMIC);
|
|
|
|
if (clone)
|
|
|
|
do_output(dp, clone, port, key);
|
2016-06-11 01:49:33 +07:00
|
|
|
OVS_CB(skb)->cutlen = 0;
|
2011-10-26 09:26:31 +07:00
|
|
|
break;
|
2017-01-28 04:45:28 +07:00
|
|
|
}
|
2011-10-26 09:26:31 +07:00
|
|
|
|
2016-06-11 01:49:33 +07:00
|
|
|
case OVS_ACTION_ATTR_TRUNC: {
|
|
|
|
struct ovs_action_trunc *trunc = nla_data(a);
|
|
|
|
|
|
|
|
if (skb->len > trunc->max_len)
|
|
|
|
OVS_CB(skb)->cutlen = skb->len - trunc->max_len;
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
|
2011-10-26 09:26:31 +07:00
|
|
|
case OVS_ACTION_ATTR_USERSPACE:
|
2016-06-11 01:49:33 +07:00
|
|
|
output_userspace(dp, skb, key, a, attr,
|
|
|
|
len, OVS_CB(skb)->cutlen);
|
|
|
|
OVS_CB(skb)->cutlen = 0;
|
2011-10-26 09:26:31 +07:00
|
|
|
break;
|
|
|
|
|
2014-09-16 09:37:25 +07:00
|
|
|
case OVS_ACTION_ATTR_HASH:
|
|
|
|
execute_hash(skb, key, a);
|
|
|
|
break;
|
|
|
|
|
2014-10-06 19:05:13 +07:00
|
|
|
case OVS_ACTION_ATTR_PUSH_MPLS:
|
2014-11-06 21:55:14 +07:00
|
|
|
err = push_mpls(skb, key, nla_data(a));
|
2014-10-06 19:05:13 +07:00
|
|
|
break;
|
|
|
|
|
|
|
|
case OVS_ACTION_ATTR_POP_MPLS:
|
2014-11-06 21:55:14 +07:00
|
|
|
err = pop_mpls(skb, key, nla_get_be16(a));
|
2014-10-06 19:05:13 +07:00
|
|
|
break;
|
|
|
|
|
2011-10-26 09:26:31 +07:00
|
|
|
case OVS_ACTION_ATTR_PUSH_VLAN:
|
2014-11-06 21:55:14 +07:00
|
|
|
err = push_vlan(skb, key, nla_data(a));
|
2011-10-26 09:26:31 +07:00
|
|
|
break;
|
|
|
|
|
|
|
|
case OVS_ACTION_ATTR_POP_VLAN:
|
2014-11-06 21:55:14 +07:00
|
|
|
err = pop_vlan(skb, key);
|
2011-10-26 09:26:31 +07:00
|
|
|
break;
|
|
|
|
|
2017-03-21 06:32:30 +07:00
|
|
|
case OVS_ACTION_ATTR_RECIRC: {
|
|
|
|
bool last = nla_is_last(a, rem);
|
|
|
|
|
|
|
|
err = execute_recirc(dp, skb, key, a, last);
|
|
|
|
if (last) {
|
2014-09-16 09:37:25 +07:00
|
|
|
/* If this is the last action, the skb has
|
|
|
|
* been consumed or freed.
|
|
|
|
* Return immediately.
|
|
|
|
*/
|
|
|
|
return err;
|
|
|
|
}
|
|
|
|
break;
|
2017-03-21 06:32:30 +07:00
|
|
|
}
|
2014-09-16 09:37:25 +07:00
|
|
|
|
2011-10-26 09:26:31 +07:00
|
|
|
case OVS_ACTION_ATTR_SET:
|
2014-11-06 21:55:14 +07:00
|
|
|
err = execute_set_action(skb, key, nla_data(a));
|
2011-10-26 09:26:31 +07:00
|
|
|
break;
|
|
|
|
|
2015-02-06 04:40:49 +07:00
|
|
|
case OVS_ACTION_ATTR_SET_MASKED:
|
|
|
|
case OVS_ACTION_ATTR_SET_TO_MASKED:
|
|
|
|
err = execute_masked_set_action(skb, key, nla_data(a));
|
|
|
|
break;
|
|
|
|
|
openvswitch: Optimize sample action for the clone use cases
With the introduction of open flow 'clone' action, the OVS user space
can now translate the 'clone' action into kernel datapath 'sample'
action, with 100% probability, to ensure that the clone semantics,
which is that the packet seen by the clone action is the same as the
packet seen by the action after clone, is faithfully carried out
in the datapath.
While the sample action in the datpath has the matching semantics,
its implementation is only optimized for its original use.
Specifically, there are two limitation: First, there is a 3 level of
nesting restriction, enforced at the flow downloading time. This
limit turns out to be too restrictive for the 'clone' use case.
Second, the implementation avoid recursive call only if the sample
action list has a single userspace action.
The main optimization implemented in this series removes the static
nesting limit check, instead, implement the run time recursion limit
check, and recursion avoidance similar to that of the 'recirc' action.
This optimization solve both #1 and #2 issues above.
One related optimization attempts to avoid copying flow key as
long as the actions enclosed does not change the flow key. The
detection is performed only once at the flow downloading time.
Another related optimization is to rewrite the action list
at flow downloading time in order to save the fast path from parsing
the sample action list in its original form repeatedly.
Signed-off-by: Andy Zhou <azhou@ovn.org>
Acked-by: Pravin B Shelar <pshelar@ovn.org>
Signed-off-by: David S. Miller <davem@davemloft.net>
2017-03-21 06:32:29 +07:00
|
|
|
case OVS_ACTION_ATTR_SAMPLE: {
|
|
|
|
bool last = nla_is_last(a, rem);
|
|
|
|
|
|
|
|
err = sample(dp, skb, key, a, last);
|
|
|
|
if (last)
|
|
|
|
return err;
|
|
|
|
|
2011-10-26 09:26:31 +07:00
|
|
|
break;
|
openvswitch: Optimize sample action for the clone use cases
With the introduction of open flow 'clone' action, the OVS user space
can now translate the 'clone' action into kernel datapath 'sample'
action, with 100% probability, to ensure that the clone semantics,
which is that the packet seen by the clone action is the same as the
packet seen by the action after clone, is faithfully carried out
in the datapath.
While the sample action in the datpath has the matching semantics,
its implementation is only optimized for its original use.
Specifically, there are two limitation: First, there is a 3 level of
nesting restriction, enforced at the flow downloading time. This
limit turns out to be too restrictive for the 'clone' use case.
Second, the implementation avoid recursive call only if the sample
action list has a single userspace action.
The main optimization implemented in this series removes the static
nesting limit check, instead, implement the run time recursion limit
check, and recursion avoidance similar to that of the 'recirc' action.
This optimization solve both #1 and #2 issues above.
One related optimization attempts to avoid copying flow key as
long as the actions enclosed does not change the flow key. The
detection is performed only once at the flow downloading time.
Another related optimization is to rewrite the action list
at flow downloading time in order to save the fast path from parsing
the sample action list in its original form repeatedly.
Signed-off-by: Andy Zhou <azhou@ovn.org>
Acked-by: Pravin B Shelar <pshelar@ovn.org>
Signed-off-by: David S. Miller <davem@davemloft.net>
2017-03-21 06:32:29 +07:00
|
|
|
}
|
2015-08-27 01:31:48 +07:00
|
|
|
|
|
|
|
case OVS_ACTION_ATTR_CT:
|
2015-10-07 00:59:58 +07:00
|
|
|
if (!is_flow_key_valid(key)) {
|
|
|
|
err = ovs_flow_key_update(skb, key);
|
|
|
|
if (err)
|
|
|
|
return err;
|
|
|
|
}
|
|
|
|
|
2015-08-27 01:31:48 +07:00
|
|
|
err = ovs_ct_execute(ovs_dp_get_net(dp), skb, key,
|
|
|
|
nla_data(a));
|
|
|
|
|
|
|
|
/* Hide stolen IP fragments from user space. */
|
2015-10-26 10:21:48 +07:00
|
|
|
if (err)
|
|
|
|
return err == -EINPROGRESS ? 0 : err;
|
2015-08-27 01:31:48 +07:00
|
|
|
break;
|
2016-11-10 22:28:23 +07:00
|
|
|
|
2017-10-11 03:54:44 +07:00
|
|
|
case OVS_ACTION_ATTR_CT_CLEAR:
|
|
|
|
err = ovs_ct_clear(skb, key);
|
|
|
|
break;
|
|
|
|
|
2016-11-10 22:28:23 +07:00
|
|
|
case OVS_ACTION_ATTR_PUSH_ETH:
|
|
|
|
err = push_eth(skb, key, nla_data(a));
|
|
|
|
break;
|
|
|
|
|
|
|
|
case OVS_ACTION_ATTR_POP_ETH:
|
|
|
|
err = pop_eth(skb, key);
|
|
|
|
break;
|
2017-11-07 20:07:02 +07:00
|
|
|
|
|
|
|
case OVS_ACTION_ATTR_PUSH_NSH: {
|
|
|
|
u8 buffer[NSH_HDR_MAX_LEN];
|
|
|
|
struct nshhdr *nh = (struct nshhdr *)buffer;
|
|
|
|
|
|
|
|
err = nsh_hdr_from_nlattr(nla_data(a), nh,
|
|
|
|
NSH_HDR_MAX_LEN);
|
|
|
|
if (unlikely(err))
|
|
|
|
break;
|
|
|
|
err = push_nsh(skb, key, nh);
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
|
|
|
|
case OVS_ACTION_ATTR_POP_NSH:
|
|
|
|
err = pop_nsh(skb, key);
|
|
|
|
break;
|
2017-11-11 03:09:43 +07:00
|
|
|
|
|
|
|
case OVS_ACTION_ATTR_METER:
|
|
|
|
if (ovs_meter_execute(dp, skb, key, nla_get_u32(a))) {
|
|
|
|
consume_skb(skb);
|
|
|
|
return 0;
|
|
|
|
}
|
2018-07-02 22:18:03 +07:00
|
|
|
break;
|
|
|
|
|
|
|
|
case OVS_ACTION_ATTR_CLONE: {
|
|
|
|
bool last = nla_is_last(a, rem);
|
|
|
|
|
|
|
|
err = clone(dp, skb, key, a, last);
|
|
|
|
if (last)
|
|
|
|
return err;
|
|
|
|
|
|
|
|
break;
|
|
|
|
}
|
2011-10-26 09:26:31 +07:00
|
|
|
}
|
|
|
|
|
|
|
|
if (unlikely(err)) {
|
|
|
|
kfree_skb(skb);
|
|
|
|
return err;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2017-01-28 04:45:28 +07:00
|
|
|
consume_skb(skb);
|
2011-10-26 09:26:31 +07:00
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2017-03-21 06:32:30 +07:00
|
|
|
/* Execute the actions on the clone of the packet. The effect of the
|
|
|
|
* execution does not affect the original 'skb' nor the original 'key'.
|
|
|
|
*
|
|
|
|
* The execution may be deferred in case the actions can not be executed
|
|
|
|
* immediately.
|
|
|
|
*/
|
|
|
|
static int clone_execute(struct datapath *dp, struct sk_buff *skb,
|
|
|
|
struct sw_flow_key *key, u32 recirc_id,
|
|
|
|
const struct nlattr *actions, int len,
|
|
|
|
bool last, bool clone_flow_key)
|
|
|
|
{
|
|
|
|
struct deferred_action *da;
|
|
|
|
struct sw_flow_key *clone;
|
|
|
|
|
|
|
|
skb = last ? skb : skb_clone(skb, GFP_ATOMIC);
|
|
|
|
if (!skb) {
|
|
|
|
/* Out of memory, skip this action.
|
|
|
|
*/
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* When clone_flow_key is false, the 'key' will not be change
|
|
|
|
* by the actions, then the 'key' can be used directly.
|
|
|
|
* Otherwise, try to clone key from the next recursion level of
|
|
|
|
* 'flow_keys'. If clone is successful, execute the actions
|
|
|
|
* without deferring.
|
|
|
|
*/
|
|
|
|
clone = clone_flow_key ? clone_key(key) : key;
|
|
|
|
if (clone) {
|
|
|
|
int err = 0;
|
|
|
|
|
|
|
|
if (actions) { /* Sample action */
|
|
|
|
if (clone_flow_key)
|
|
|
|
__this_cpu_inc(exec_actions_level);
|
|
|
|
|
|
|
|
err = do_execute_actions(dp, skb, clone,
|
|
|
|
actions, len);
|
|
|
|
|
|
|
|
if (clone_flow_key)
|
|
|
|
__this_cpu_dec(exec_actions_level);
|
|
|
|
} else { /* Recirc action */
|
|
|
|
clone->recirc_id = recirc_id;
|
|
|
|
ovs_dp_process_packet(skb, clone);
|
|
|
|
}
|
|
|
|
return err;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Out of 'flow_keys' space. Defer actions */
|
|
|
|
da = add_deferred_actions(skb, key, actions, len);
|
|
|
|
if (da) {
|
|
|
|
if (!actions) { /* Recirc action */
|
|
|
|
key = &da->pkt_key;
|
|
|
|
key->recirc_id = recirc_id;
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
/* Out of per CPU action FIFO space. Drop the 'skb' and
|
|
|
|
* log an error.
|
|
|
|
*/
|
|
|
|
kfree_skb(skb);
|
|
|
|
|
|
|
|
if (net_ratelimit()) {
|
|
|
|
if (actions) { /* Sample action */
|
|
|
|
pr_warn("%s: deferred action limit reached, drop sample action\n",
|
|
|
|
ovs_dp_name(dp));
|
|
|
|
} else { /* Recirc action */
|
|
|
|
pr_warn("%s: deferred action limit reached, drop recirc action\n",
|
|
|
|
ovs_dp_name(dp));
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2014-09-16 09:37:25 +07:00
|
|
|
static void process_deferred_actions(struct datapath *dp)
|
|
|
|
{
|
|
|
|
struct action_fifo *fifo = this_cpu_ptr(action_fifos);
|
|
|
|
|
|
|
|
/* Do not touch the FIFO in case there is no deferred actions. */
|
|
|
|
if (action_fifo_is_empty(fifo))
|
|
|
|
return;
|
|
|
|
|
|
|
|
/* Finishing executing all deferred actions. */
|
|
|
|
do {
|
|
|
|
struct deferred_action *da = action_fifo_get(fifo);
|
|
|
|
struct sk_buff *skb = da->skb;
|
|
|
|
struct sw_flow_key *key = &da->pkt_key;
|
|
|
|
const struct nlattr *actions = da->actions;
|
2017-03-21 06:32:27 +07:00
|
|
|
int actions_len = da->actions_len;
|
2014-09-16 09:37:25 +07:00
|
|
|
|
|
|
|
if (actions)
|
2017-03-21 06:32:27 +07:00
|
|
|
do_execute_actions(dp, skb, key, actions, actions_len);
|
2014-09-16 09:37:25 +07:00
|
|
|
else
|
|
|
|
ovs_dp_process_packet(skb, key);
|
|
|
|
} while (!action_fifo_is_empty(fifo));
|
|
|
|
|
|
|
|
/* Reset FIFO for the next packet. */
|
|
|
|
action_fifo_init(fifo);
|
|
|
|
}
|
|
|
|
|
2011-10-26 09:26:31 +07:00
|
|
|
/* Execute a list of actions against 'skb'. */
|
2014-09-16 09:15:28 +07:00
|
|
|
int ovs_execute_actions(struct datapath *dp, struct sk_buff *skb,
|
2014-11-06 21:58:52 +07:00
|
|
|
const struct sw_flow_actions *acts,
|
|
|
|
struct sw_flow_key *key)
|
2011-10-26 09:26:31 +07:00
|
|
|
{
|
2016-01-19 00:03:48 +07:00
|
|
|
int err, level;
|
|
|
|
|
|
|
|
level = __this_cpu_inc_return(exec_actions_level);
|
2016-09-13 21:08:54 +07:00
|
|
|
if (unlikely(level > OVS_RECURSION_LIMIT)) {
|
2016-01-19 00:03:48 +07:00
|
|
|
net_crit_ratelimited("ovs: recursion limit reached on datapath %s, probable configuration error\n",
|
|
|
|
ovs_dp_name(dp));
|
|
|
|
kfree_skb(skb);
|
|
|
|
err = -ENETDOWN;
|
|
|
|
goto out;
|
|
|
|
}
|
2014-09-16 09:37:25 +07:00
|
|
|
|
openvswitch: fix skb_panic due to the incorrect actions attrlen
For sw_flow_actions, the actions_len only represents the kernel part's
size, and when we dump the actions to the userspace, we will do the
convertions, so it's true size may become bigger than the actions_len.
But unfortunately, for OVS_PACKET_ATTR_ACTIONS, we use the actions_len
to alloc the skbuff, so the user_skb's size may become insufficient and
oops will happen like this:
skbuff: skb_over_panic: text:ffffffff8148fabf len:1749 put:157 head:
ffff881300f39000 data:ffff881300f39000 tail:0x6d5 end:0x6c0 dev:<NULL>
------------[ cut here ]------------
kernel BUG at net/core/skbuff.c:129!
[...]
Call Trace:
<IRQ>
[<ffffffff8148be82>] skb_put+0x43/0x44
[<ffffffff8148fabf>] skb_zerocopy+0x6c/0x1f4
[<ffffffffa0290d36>] queue_userspace_packet+0x3a3/0x448 [openvswitch]
[<ffffffffa0292023>] ovs_dp_upcall+0x30/0x5c [openvswitch]
[<ffffffffa028d435>] output_userspace+0x132/0x158 [openvswitch]
[<ffffffffa01e6890>] ? ip6_rcv_finish+0x74/0x77 [ipv6]
[<ffffffffa028e277>] do_execute_actions+0xcc1/0xdc8 [openvswitch]
[<ffffffffa028e3f2>] ovs_execute_actions+0x74/0x106 [openvswitch]
[<ffffffffa0292130>] ovs_dp_process_packet+0xe1/0xfd [openvswitch]
[<ffffffffa0292b77>] ? key_extract+0x63c/0x8d5 [openvswitch]
[<ffffffffa029848b>] ovs_vport_receive+0xa1/0xc3 [openvswitch]
[...]
Also we can find that the actions_len is much little than the orig_len:
crash> struct sw_flow_actions 0xffff8812f539d000
struct sw_flow_actions {
rcu = {
next = 0xffff8812f5398800,
func = 0xffffe3b00035db32
},
orig_len = 1384,
actions_len = 592,
actions = 0xffff8812f539d01c
}
So as a quick fix, use the orig_len instead of the actions_len to alloc
the user_skb.
Last, this oops happened on our system running a relative old kernel, but
the same risk still exists on the mainline, since we use the wrong
actions_len from the beginning.
Fixes: ccea74457bbd ("openvswitch: include datapath actions with sampled-packet upcall to userspace")
Cc: Neil McKee <neil.mckee@inmon.com>
Signed-off-by: Liping Zhang <zlpnobody@gmail.com>
Acked-by: Pravin B Shelar <pshelar@ovn.org>
Signed-off-by: David S. Miller <davem@davemloft.net>
2017-08-16 12:30:07 +07:00
|
|
|
OVS_CB(skb)->acts_origlen = acts->orig_len;
|
2014-09-16 09:37:25 +07:00
|
|
|
err = do_execute_actions(dp, skb, key,
|
|
|
|
acts->actions, acts->actions_len);
|
|
|
|
|
2016-01-19 00:03:48 +07:00
|
|
|
if (level == 1)
|
2014-09-16 09:37:25 +07:00
|
|
|
process_deferred_actions(dp);
|
|
|
|
|
2016-01-19 00:03:48 +07:00
|
|
|
out:
|
|
|
|
__this_cpu_dec(exec_actions_level);
|
2014-09-16 09:37:25 +07:00
|
|
|
return err;
|
|
|
|
}
|
|
|
|
|
|
|
|
int action_fifos_init(void)
|
|
|
|
{
|
|
|
|
action_fifos = alloc_percpu(struct action_fifo);
|
|
|
|
if (!action_fifos)
|
|
|
|
return -ENOMEM;
|
2011-10-26 09:26:31 +07:00
|
|
|
|
2017-03-21 06:32:28 +07:00
|
|
|
flow_keys = alloc_percpu(struct action_flow_keys);
|
|
|
|
if (!flow_keys) {
|
2016-09-13 21:08:54 +07:00
|
|
|
free_percpu(action_fifos);
|
|
|
|
return -ENOMEM;
|
|
|
|
}
|
|
|
|
|
2014-09-16 09:37:25 +07:00
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
void action_fifos_exit(void)
|
|
|
|
{
|
|
|
|
free_percpu(action_fifos);
|
2017-03-21 06:32:28 +07:00
|
|
|
free_percpu(flow_keys);
|
2011-10-26 09:26:31 +07:00
|
|
|
}
|