@@ -7,33 +7,21 @@ if not is_linux
endif
sources = files(
'rte_eth_tap.c',
- 'tap_bpf_api.c',
'tap_flow.c',
'tap_intr.c',
'tap_netlink.c',
'tap_tcmsgs.c',
)
+subdir('bpf')
+if enable_tap_rss
+ cflags += '-DHAVE_BPF_RSS'
+ ext_deps += libbpf
+ sources += tap_rss_skel_h
+endif
+
deps = ['bus_vdev', 'gso', 'hash']
cflags += '-DTAP_MAX_QUEUES=16'
-# input array for meson symbol search:
-# [ "MACRO to define if found", "header for the search",
-# "enum/define", "symbol to search" ]
-#
-args = [
- [ 'HAVE_TC_FLOWER', 'linux/pkt_cls.h', 'TCA_FLOWER_UNSPEC' ],
- [ 'HAVE_TC_VLAN_ID', 'linux/pkt_cls.h', 'TCA_FLOWER_KEY_VLAN_PRIO' ],
- [ 'HAVE_TC_BPF', 'linux/pkt_cls.h', 'TCA_BPF_UNSPEC' ],
- [ 'HAVE_TC_BPF_FD', 'linux/pkt_cls.h', 'TCA_BPF_FD' ],
- [ 'HAVE_TC_ACT_BPF', 'linux/tc_act/tc_bpf.h', 'TCA_ACT_BPF_UNSPEC' ],
- [ 'HAVE_TC_ACT_BPF_FD', 'linux/tc_act/tc_bpf.h', 'TCA_ACT_BPF_FD' ],
-]
-config = configuration_data()
-foreach arg:args
- config.set(arg[0], cc.has_header_symbol(arg[1], arg[2]))
-endforeach
-configure_file(output : 'tap_autoconf.h', configuration : config)
-
require_iova_in_mbuf = false
@@ -1138,6 +1138,7 @@ tap_dev_close(struct rte_eth_dev *dev)
tap_flow_implicit_flush(internals, NULL);
tap_nl_final(internals->nlsk_fd);
internals->nlsk_fd = -1;
+ tap_flow_bpf_destroy(internals);
}
for (i = 0; i < RTE_PMD_TAP_MAX_QUEUES; i++) {
@@ -1959,6 +1960,7 @@ eth_dev_tap_create(struct rte_vdev_device *vdev, const char *tap_name,
strlcpy(pmd->name, tap_name, sizeof(pmd->name));
pmd->type = type;
pmd->ka_fd = -1;
+ pmd->rss = NULL;
pmd->nlsk_fd = -1;
pmd->gso_ctx_mp = NULL;
@@ -79,12 +79,11 @@ struct pmd_internals {
int flow_isolate; /* 1 if flow isolation is enabled */
int flower_support; /* 1 if kernel supports, else 0 */
int flower_vlan_support; /* 1 if kernel supports, else 0 */
- int rss_enabled; /* 1 if RSS is enabled, else 0 */
int persist; /* 1 if keep link up, else 0 */
- /* implicit rules set when RSS is enabled */
- int map_fd; /* BPF RSS map fd */
- int bpf_fd[RTE_PMD_TAP_MAX_QUEUES];/* List of bpf fds per queue */
- LIST_HEAD(tap_rss_flows, rte_flow) rss_flows;
+
+ struct tap_rss *rss; /* BPF program */
+ uint16_t bpf_flowid; /* next BPF class id */
+
LIST_HEAD(tap_flows, rte_flow) flows; /* rte_flow rules */
/* implicit rte_flow rules set when a remote device is active */
LIST_HEAD(tap_implicit_flows, rte_flow) implicit_flows;
@@ -16,24 +16,19 @@
#include <rte_eth_tap.h>
#include <tap_flow.h>
-#include <tap_autoconf.h>
#include <tap_tcmsgs.h>
#include <tap_rss.h>
-
-/* RSS key management */
-enum bpf_rss_key_e {
- KEY_CMD_GET = 1,
- KEY_CMD_RELEASE,
- KEY_CMD_INIT,
- KEY_CMD_DEINIT,
-};
-
-enum key_status_e {
- KEY_STAT_UNSPEC,
- KEY_STAT_USED,
- KEY_STAT_AVAILABLE,
-};
+#pragma GCC diagnostic push
+#ifdef HAVE_BPF_RSS
+/* Workaround for warning in bpftool generated skeleton code */
+#pragma GCC diagnostic ignored "-Wcast-qual"
+#include "tap_rss.skel.h"
+#else
+#pragma GCC diagnostic ignored "-Wunused-parameter"
+#include "tap_rss.stub.h"
+#endif
+#pragma GCC diagnostic pop
#define ISOLATE_HANDLE 1
#define REMOTE_PROMISCUOUS_HANDLE 2
@@ -41,8 +36,7 @@ enum key_status_e {
struct rte_flow {
LIST_ENTRY(rte_flow) next; /* Pointer to the next rte_flow structure */
struct rte_flow *remote_flow; /* associated remote flow */
- int bpf_fd[SEC_MAX]; /* list of bfs fds per ELF section */
- uint32_t key_idx; /* RSS rule key index into BPF map */
+ uint16_t flowid;
struct nlmsg msg;
};
@@ -72,7 +66,7 @@ struct action_data {
} skbedit;
struct bpf {
struct tc_act_bpf bpf;
- int bpf_fd;
+ uint16_t classid;
const char *annotation;
} bpf;
};
@@ -112,10 +106,7 @@ tap_flow_isolate(struct rte_eth_dev *dev,
int set,
struct rte_flow_error *error);
-static int bpf_rss_key(enum bpf_rss_key_e cmd, __u32 *key_idx);
-static int rss_enable(struct pmd_internals *pmd,
- const struct rte_flow_attr *attr,
- struct rte_flow_error *error);
+static int rss_enable(struct pmd_internals *pmd, struct rte_flow_error *error);
static int rss_add_actions(struct rte_flow *flow, struct pmd_internals *pmd,
const struct rte_flow_action_rss *rss,
struct rte_flow_error *error);
@@ -829,7 +820,8 @@ tap_flow_item_validate(const struct rte_flow_item *item,
* -1 on failure, 0 on success
*/
static int
-add_action(struct rte_flow *flow, size_t *act_index, struct action_data *adata)
+add_action(struct rte_flow *flow, struct pmd_internals *pmd,
+ size_t *act_index, struct action_data *adata)
{
struct nlmsg *msg = &flow->msg;
@@ -858,13 +850,18 @@ add_action(struct rte_flow *flow, size_t *act_index, struct action_data *adata)
tap_nlattr_add16(&msg->nh, TCA_SKBEDIT_QUEUE_MAPPING,
adata->skbedit.queue);
} else if (strcmp("bpf", adata->id) == 0) {
- tap_nlattr_add32(&msg->nh, TCA_ACT_BPF_FD, adata->bpf.bpf_fd);
+ struct bpf_program *rss_prog = pmd->rss->progs.rss_flow_action;
+
+ tap_nlattr_add32(&msg->nh, TCA_ACT_BPF_FD, bpf_program__fd(rss_prog));
tap_nlattr_add(&msg->nh, TCA_ACT_BPF_NAME,
strlen(adata->bpf.annotation) + 1,
adata->bpf.annotation);
tap_nlattr_add(&msg->nh, TCA_ACT_BPF_PARMS,
sizeof(adata->bpf.bpf),
&adata->bpf.bpf);
+ tap_nlattr_add(&msg->nh, TCA_BPF_CLASSID,
+ sizeof(adata->bpf.classid),
+ &adata->bpf.classid);
} else {
return -1;
}
@@ -892,7 +889,8 @@ add_action(struct rte_flow *flow, size_t *act_index, struct action_data *adata)
* -1 on failure, 0 on success
*/
static int
-add_actions(struct rte_flow *flow, int nb_actions, struct action_data *data,
+add_actions(struct rte_flow *flow, struct pmd_internals *pmd,
+ int nb_actions, struct action_data *data,
int classifier_action)
{
struct nlmsg *msg = &flow->msg;
@@ -902,7 +900,7 @@ add_actions(struct rte_flow *flow, int nb_actions, struct action_data *data,
if (tap_nlattr_nested_start(msg, classifier_action) < 0)
return -1;
for (i = 0; i < nb_actions; i++)
- if (add_action(flow, &act_index, data + i) < 0)
+ if (add_action(flow, pmd, &act_index, data + i) < 0)
return -1;
tap_nlattr_nested_finish(msg); /* nested TCA_FLOWER_ACT */
return 0;
@@ -1062,7 +1060,7 @@ priv_flow_process(struct pmd_internals *pmd,
adata.mirred.action = TC_ACT_PIPE;
else
adata.mirred.action = TC_ACT_STOLEN;
- if (add_actions(flow, 1, &adata, TCA_FLOWER_ACT) < 0)
+ if (add_actions(flow, pmd, 1, &adata, TCA_FLOWER_ACT) < 0)
goto exit_action_not_supported;
else
goto end;
@@ -1085,7 +1083,7 @@ priv_flow_process(struct pmd_internals *pmd,
},
};
- err = add_actions(flow, 1, &adata,
+ err = add_actions(flow, pmd, 1, &adata,
TCA_FLOWER_ACT);
}
} else if (actions->type == RTE_FLOW_ACTION_TYPE_PASSTHRU) {
@@ -1101,7 +1099,7 @@ priv_flow_process(struct pmd_internals *pmd,
},
};
- err = add_actions(flow, 1, &adata,
+ err = add_actions(flow, pmd, 1, &adata,
TCA_FLOWER_ACT);
}
} else if (actions->type == RTE_FLOW_ACTION_TYPE_QUEUE) {
@@ -1126,8 +1124,8 @@ priv_flow_process(struct pmd_internals *pmd,
},
};
- err = add_actions(flow, 1, &adata,
- TCA_FLOWER_ACT);
+ err = add_actions(flow, pmd, 1, &adata,
+ TCA_FLOWER_ACT);
}
} else if (actions->type == RTE_FLOW_ACTION_TYPE_RSS) {
const struct rte_flow_action_rss *rss =
@@ -1137,8 +1135,8 @@ priv_flow_process(struct pmd_internals *pmd,
if (action++)
goto exit_action_not_supported;
- if (!pmd->rss_enabled) {
- err = rss_enable(pmd, attr, error);
+ if (pmd->rss == NULL) {
+ err = rss_enable(pmd, error);
if (err)
goto exit_action_not_supported;
}
@@ -1241,23 +1239,14 @@ tap_flow_set_handle(struct rte_flow *flow)
static void
tap_flow_free(struct pmd_internals *pmd, struct rte_flow *flow)
{
- int i;
+ struct tap_rss *rss = pmd->rss;
if (!flow)
return;
- if (pmd->rss_enabled) {
- /* Close flow BPF file descriptors */
- for (i = 0; i < SEC_MAX; i++)
- if (flow->bpf_fd[i] != 0) {
- close(flow->bpf_fd[i]);
- flow->bpf_fd[i] = 0;
- }
-
- /* Release the map key for this RSS rule */
- bpf_rss_key(KEY_CMD_RELEASE, &flow->key_idx);
- flow->key_idx = 0;
- }
+ if (rss)
+ bpf_map__delete_elem(rss->maps.rss_map, &flow->flowid,
+ sizeof(flow->flowid), 0);
/* Free flow allocated memory */
rte_free(flow);
@@ -1725,13 +1714,16 @@ tap_flow_implicit_flush(struct pmd_internals *pmd, struct rte_flow_error *error)
return 0;
}
-#define MAX_RSS_KEYS 256
-#define KEY_IDX_OFFSET (3 * MAX_RSS_KEYS)
-#define SEC_NAME_CLS_Q "cls_q"
-
-static const char *sec_name[SEC_MAX] = {
- [SEC_L3_L4] = "l3_l4",
-};
+/**
+ * Cleanup when device is closed
+ */
+void tap_flow_bpf_destroy(struct pmd_internals *pmd)
+{
+ if (pmd->rss == NULL)
+ return;
+ tap_rss__destroy(pmd->rss);
+ pmd->rss = NULL;
+}
/**
* Enable RSS on tap: create TC rules for queuing.
@@ -1747,226 +1739,62 @@ static const char *sec_name[SEC_MAX] = {
*
* @return 0 on success, negative value on failure.
*/
-static int rss_enable(struct pmd_internals *pmd,
- const struct rte_flow_attr *attr,
- struct rte_flow_error *error)
+static int rss_enable(struct pmd_internals *pmd, struct rte_flow_error *error)
{
- struct rte_flow *rss_flow = NULL;
- struct nlmsg *msg = NULL;
- /* 4096 is the maximum number of instructions for a BPF program */
- char annotation[64];
- int i;
- int err = 0;
-
- /* unlimit locked memory */
- struct rlimit memlock_limit = {
- .rlim_cur = RLIM_INFINITY,
- .rlim_max = RLIM_INFINITY,
- };
- setrlimit(RLIMIT_MEMLOCK, &memlock_limit);
-
- /* Get a new map key for a new RSS rule */
- err = bpf_rss_key(KEY_CMD_INIT, NULL);
- if (err < 0) {
- rte_flow_error_set(
- error, EINVAL, RTE_FLOW_ERROR_TYPE_HANDLE, NULL,
- "Failed to initialize BPF RSS keys");
-
- return -1;
- }
-
- /*
- * Create BPF RSS MAP
- */
- pmd->map_fd = tap_flow_bpf_rss_map_create(sizeof(__u32), /* key size */
- sizeof(struct rss_key),
- MAX_RSS_KEYS);
- if (pmd->map_fd < 0) {
- TAP_LOG(ERR,
- "Failed to create BPF map (%d): %s",
- errno, strerror(errno));
- rte_flow_error_set(
- error, ENOTSUP, RTE_FLOW_ERROR_TYPE_HANDLE, NULL,
- "Kernel too old or not configured "
- "to support BPF maps");
+ int err;
- return -ENOTSUP;
+ /* Load the BPF program (defined in tap_bpf.h from skeleton) */
+ pmd->rss = tap_rss__open_and_load();
+ if (pmd->rss == NULL) {
+ TAP_LOG(ERR, "Failed to load BPF object: %s", strerror(errno));
+ rte_flow_error_set(error, errno, RTE_FLOW_ERROR_TYPE_HANDLE, NULL,
+ "BPF object could not be loaded");
+ return -errno;
}
- /*
- * Add a rule per queue to match reclassified packets and direct them to
- * the correct queue.
- */
- for (i = 0; i < pmd->dev->data->nb_rx_queues; i++) {
- pmd->bpf_fd[i] = tap_flow_bpf_cls_q(i);
- if (pmd->bpf_fd[i] < 0) {
- TAP_LOG(ERR,
- "Failed to load BPF section %s for queue %d",
- SEC_NAME_CLS_Q, i);
- rte_flow_error_set(
- error, ENOTSUP, RTE_FLOW_ERROR_TYPE_HANDLE,
- NULL,
- "Kernel too old or not configured "
- "to support BPF programs loading");
-
- return -ENOTSUP;
- }
-
- rss_flow = rte_zmalloc(__func__, sizeof(struct rte_flow), 0);
- if (!rss_flow) {
- TAP_LOG(ERR,
- "Cannot allocate memory for rte_flow");
- return -1;
- }
- msg = &rss_flow->msg;
- tc_init_msg(msg, pmd->if_index, RTM_NEWTFILTER, NLM_F_REQUEST |
- NLM_F_ACK | NLM_F_EXCL | NLM_F_CREATE);
- msg->t.tcm_info = TC_H_MAKE(0, htons(ETH_P_ALL));
- tap_flow_set_handle(rss_flow);
- uint16_t group = attr->group << GROUP_SHIFT;
- uint16_t prio = group | (i + PRIORITY_OFFSET);
- msg->t.tcm_info = TC_H_MAKE(prio << 16, msg->t.tcm_info);
- msg->t.tcm_parent = TC_H_MAKE(MULTIQ_MAJOR_HANDLE, 0);
-
- tap_nlattr_add(&msg->nh, TCA_KIND, sizeof("bpf"), "bpf");
- if (tap_nlattr_nested_start(msg, TCA_OPTIONS) < 0)
- return -1;
- tap_nlattr_add32(&msg->nh, TCA_BPF_FD, pmd->bpf_fd[i]);
- snprintf(annotation, sizeof(annotation), "[%s%d]",
- SEC_NAME_CLS_Q, i);
- tap_nlattr_add(&msg->nh, TCA_BPF_NAME, strlen(annotation) + 1,
- annotation);
- /* Actions */
- {
- struct action_data adata = {
- .id = "skbedit",
- .skbedit = {
- .skbedit = {
- .action = TC_ACT_PIPE,
- },
- .queue = i,
- },
- };
- if (add_actions(rss_flow, 1, &adata, TCA_BPF_ACT) < 0)
- return -1;
- }
- tap_nlattr_nested_finish(msg); /* nested TCA_OPTIONS */
-
- /* Netlink message is now ready to be sent */
- if (tap_nl_send(pmd->nlsk_fd, &msg->nh) < 0)
- return -1;
- err = tap_nl_recv_ack(pmd->nlsk_fd);
- if (err < 0) {
- TAP_LOG(ERR,
- "Kernel refused TC filter rule creation (%d): %s",
- errno, strerror(errno));
- return err;
- }
- LIST_INSERT_HEAD(&pmd->rss_flows, rss_flow, next);
+ /* Attach the maps defined in BPF program */
+ err = tap_rss__attach(pmd->rss);
+ if (err < 0) {
+ TAP_LOG(ERR, "Failed to attach BPF object: %d", err);
+ rte_flow_error_set(error, -err, RTE_FLOW_ERROR_TYPE_HANDLE, NULL,
+ "BPF object could not be attached");
+ tap_flow_bpf_destroy(pmd);
+ return err;
}
- pmd->rss_enabled = 1;
- return err;
+ return 0;
}
-/**
- * Manage bpf RSS keys repository with operations: init, get, release
- *
- * @param[in] cmd
- * Command on RSS keys: init, get, release
- *
- * @param[in, out] key_idx
- * Pointer to RSS Key index (out for get command, in for release command)
- *
- * @return -1 if couldn't get, release or init the RSS keys, 0 otherwise.
- */
-static int bpf_rss_key(enum bpf_rss_key_e cmd, __u32 *key_idx)
-{
- __u32 i;
- int err = 0;
- static __u32 num_used_keys;
- static __u32 rss_keys[MAX_RSS_KEYS] = {KEY_STAT_UNSPEC};
- static __u32 rss_keys_initialized;
- __u32 key;
-
- switch (cmd) {
- case KEY_CMD_GET:
- if (!rss_keys_initialized) {
- err = -1;
- break;
- }
-
- if (num_used_keys == RTE_DIM(rss_keys)) {
- err = -1;
- break;
- }
-
- *key_idx = num_used_keys % RTE_DIM(rss_keys);
- while (rss_keys[*key_idx] == KEY_STAT_USED)
- *key_idx = (*key_idx + 1) % RTE_DIM(rss_keys);
-
- rss_keys[*key_idx] = KEY_STAT_USED;
-
- /*
- * Add an offset to key_idx in order to handle a case of
- * RSS and non RSS flows mixture.
- * If a non RSS flow is destroyed it has an eBPF map
- * index 0 (initialized on flow creation) and might
- * unintentionally remove RSS entry 0 from eBPF map.
- * To avoid this issue, add an offset to the real index
- * during a KEY_CMD_GET operation and subtract this offset
- * during a KEY_CMD_RELEASE operation in order to restore
- * the real index.
- */
- *key_idx += KEY_IDX_OFFSET;
- num_used_keys++;
- break;
-
- case KEY_CMD_RELEASE:
- if (!rss_keys_initialized)
- break;
-
- /*
- * Subtract offset to restore real key index
- * If a non RSS flow is falsely trying to release map
- * entry 0 - the offset subtraction will calculate the real
- * map index as an out-of-range value and the release operation
- * will be silently ignored.
- */
- key = *key_idx - KEY_IDX_OFFSET;
- if (key >= RTE_DIM(rss_keys))
- break;
- if (rss_keys[key] == KEY_STAT_USED) {
- rss_keys[key] = KEY_STAT_AVAILABLE;
- num_used_keys--;
- }
- break;
-
- case KEY_CMD_INIT:
- for (i = 0; i < RTE_DIM(rss_keys); i++)
- rss_keys[i] = KEY_STAT_AVAILABLE;
+/* Choose next flow id to use for BPF action */
+static int tap_rss_flow_assign(struct pmd_internals *pmd, uint16_t *flow_id)
+{
+ struct rte_flow *flow;
+ uint16_t id;
- rss_keys_initialized = 1;
- num_used_keys = 0;
- break;
+ id = pmd->bpf_flowid;
- case KEY_CMD_DEINIT:
- for (i = 0; i < RTE_DIM(rss_keys); i++)
- rss_keys[i] = KEY_STAT_UNSPEC;
+next_id:
+ /* Skip 0xffff and 0 as id's */
+ if (++id == UINT16_MAX)
+ id = 1;
- rss_keys_initialized = 0;
- num_used_keys = 0;
- break;
+ /* Wrapped around, all id's have been used */
+ if (id == pmd->bpf_flowid)
+ return -1;
- default:
- break;
+ /* Make sure this id has not been used already */
+ for (flow = LIST_FIRST(&pmd->flows); flow; flow = LIST_NEXT(flow, next)) {
+ if (flow->flowid == id)
+ goto next_id;
}
- return err;
+ /* Record starting point for next time */
+ pmd->bpf_flowid = id;
+ *flow_id = id;
+ return 0;
}
-
/* Default RSS hash key also used by mlx devices */
static const uint8_t rss_hash_default_key[] = {
0x2c, 0xc6, 0x81, 0xd1,
@@ -2050,34 +1878,34 @@ static int rss_add_actions(struct rte_flow *flow, struct pmd_internals *pmd,
else if (rss->types & (RTE_ETH_RSS_IPV6 | RTE_ETH_RSS_FRAG_IPV6 | RTE_ETH_RSS_IPV6_EX))
hash_type |= RTE_BIT32(HASH_FIELD_IPV6_L3);
- /* Get a new map key for a new RSS rule */
- err = bpf_rss_key(KEY_CMD_GET, &flow->key_idx);
+
+ /* Choose new flow id, which is used as index into the BPF map */
+ err = tap_rss_flow_assign(pmd, &flow->flowid);
if (err < 0) {
rte_flow_error_set(
error, EINVAL, RTE_FLOW_ERROR_TYPE_HANDLE, NULL,
- "Failed to get BPF RSS key");
+ "Failed to get BPF flowid");
return -1;
}
- /* Update RSS map entry with queues */
- rss_entry.nb_queues = rss->queue_num;
- for (i = 0; i < rss->queue_num; i++)
- rss_entry.queues[i] = rss->queue[i];
-
rss_entry.hash_fields = hash_type;
rte_convert_rss_key((const uint32_t *)key_in, (uint32_t *)rss_entry.key,
TAP_RSS_HASH_KEY_SIZE);
+ /* Update RSS map entry with queues */
+ rss_entry.nb_queues = rss->queue_num;
+ for (i = 0; i < rss->queue_num; i++)
+ rss_entry.queues[i] = rss->queue[i];
/* Add this RSS entry to map */
- err = tap_flow_bpf_update_rss_elem(pmd->map_fd,
- &flow->key_idx, &rss_entry);
-
+ err = bpf_map__update_elem(pmd->rss->maps.rss_map,
+ &flow->flowid, sizeof(uint16_t),
+ &rss_entry, sizeof(rss_entry), 0);
if (err) {
TAP_LOG(ERR,
"Failed to update BPF map entry #%u (%d): %s",
- flow->key_idx, errno, strerror(errno));
+ flow->flowid, errno, strerror(errno));
rte_flow_error_set(
error, ENOTSUP, RTE_FLOW_ERROR_TYPE_HANDLE, NULL,
"Kernel too old or not configured "
@@ -2086,33 +1914,14 @@ static int rss_add_actions(struct rte_flow *flow, struct pmd_internals *pmd,
return -ENOTSUP;
}
-
- /*
- * Load bpf rules to calculate hash for this key_idx
- */
-
- flow->bpf_fd[SEC_L3_L4] =
- tap_flow_bpf_calc_l3_l4_hash(flow->key_idx, pmd->map_fd);
- if (flow->bpf_fd[SEC_L3_L4] < 0) {
- TAP_LOG(ERR,
- "Failed to load BPF section %s (%d): %s",
- sec_name[SEC_L3_L4], errno, strerror(errno));
- rte_flow_error_set(
- error, ENOTSUP, RTE_FLOW_ERROR_TYPE_HANDLE, NULL,
- "Kernel too old or not configured "
- "to support BPF program loading");
-
- return -ENOTSUP;
- }
-
/* Actions */
{
struct action_data adata[] = {
{
.id = "bpf",
.bpf = {
- .bpf_fd = flow->bpf_fd[SEC_L3_L4],
- .annotation = sec_name[SEC_L3_L4],
+ .annotation = "tap_rss",
+ .classid = flow->flowid,
.bpf = {
.action = TC_ACT_PIPE,
},
@@ -2120,8 +1929,8 @@ static int rss_add_actions(struct rte_flow *flow, struct pmd_internals *pmd,
},
};
- if (add_actions(flow, RTE_DIM(adata), adata,
- TCA_FLOWER_ACT) < 0)
+ if (add_actions(flow, pmd, RTE_DIM(adata), adata,
+ TCA_FLOWER_ACT) < 0)
return -1;
}
@@ -9,7 +9,6 @@
#include <rte_flow.h>
#include <rte_flow_driver.h>
#include <rte_eth_tap.h>
-#include <tap_autoconf.h>
/**
* In TC, priority 0 means we require the kernel to allocate one for us.
@@ -41,10 +40,6 @@ enum implicit_rule_index {
TAP_REMOTE_MAX_IDX,
};
-enum bpf_fd_idx {
- SEC_L3_L4,
- SEC_MAX,
-};
int tap_dev_flow_ops_get(struct rte_eth_dev *dev,
const struct rte_flow_ops **ops);
@@ -57,10 +52,6 @@ int tap_flow_implicit_destroy(struct pmd_internals *pmd,
int tap_flow_implicit_flush(struct pmd_internals *pmd,
struct rte_flow_error *error);
-int tap_flow_bpf_cls_q(__u32 queue_idx);
-int tap_flow_bpf_calc_l3_l4_hash(__u32 key_idx, int map_fd);
-int tap_flow_bpf_rss_map_create(unsigned int key_size, unsigned int value_size,
- unsigned int max_entries);
-int tap_flow_bpf_update_rss_elem(int fd, void *key, void *value);
+void tap_flow_bpf_destroy(struct pmd_internals *pmd);
#endif /* _TAP_FLOW_H_ */
@@ -9,6 +9,9 @@
#define TAP_MAX_QUEUES 16
#endif
+/* Size of the map from BPF classid to queue table */
+#define TAP_RSS_MAX TAP_MAX_QUEUES
+
/* Fixed RSS hash key size in bytes. */
#define TAP_RSS_HASH_KEY_SIZE 40
new file mode 100644
@@ -0,0 +1,45 @@
+/* SPDX-License-Identifier: BSD-3-Clause
+ * Stub if libbpf is not available
+ */
+
+struct bpf_object;
+struct bpf_map;
+
+struct tap_rss {
+ struct bpf_object *obj;
+ struct {
+ struct bpf_map *rss_map;
+ } maps;
+};
+
+static struct tap_rss *tap_rss__open_and_load(void)
+{
+ errno = ENOTSUP;
+ return NULL;
+}
+
+static void tap_rss__destroy(struct tap_rss *obj)
+{
+}
+
+static int tap_rss__attach(struct tap_rss *obj)
+{
+ return -1;
+}
+
+static int bpf_object__btf_fd(struct bpf_object *obj)
+{
+ return -1;
+}
+
+static int bpf_map__update_elem(const struct bpf_map *map, const void *key, size_t key_size,
+ const void *value, size_t value_size, int flags)
+{
+ return -1;
+}
+
+static int bpf_map__delete_elem(const struct bpf_map *map,
+ const void *key, size_t key_size, int flags)
+{
+ return -1;
+}
@@ -6,7 +6,6 @@
#ifndef _TAP_TCMSGS_H_
#define _TAP_TCMSGS_H_
-#include <tap_autoconf.h>
#include <linux/if_ether.h>
#include <linux/rtnetlink.h>
#include <linux/pkt_sched.h>
@@ -14,9 +13,8 @@
#include <linux/tc_act/tc_mirred.h>
#include <linux/tc_act/tc_gact.h>
#include <linux/tc_act/tc_skbedit.h>
-#ifdef HAVE_TC_ACT_BPF
#include <linux/tc_act/tc_bpf.h>
-#endif
+
#include <inttypes.h>
#include <rte_ether.h>