mir/ovs
2
0
Fork 0
mirror of https://github.com/openvswitch/ovs synced 2025-08-31 06:15:47 +00:00
Code Issues Releases Wiki Activity

dpif-netdev: Use one or more offload threads.

Browse Source 
Read the user configuration in the netdev-offload module to modify the
number of threads used to manage hardware offload requests.

This allows processing insertion, deletion and modification
concurrently.

The offload thread structure was modified to contain all needed
elements. This structure is multiplied by the number of requested
threads and used separately.

Signed-off-by: Gaetan Rivet <grive@u256.net>
Reviewed-by: Eli Britstein <elibr@nvidia.com>
Reviewed-by: Maxime Coquelin <maxime.coquelin@redhat.com>
Signed-off-by: Ilya Maximets <i.maximets@ovn.org>
This commit is contained in:
Gaetan Rivet
2021-09-08 11:47:50 +02:00
committed by Ilya Maximets
parent 7daa503468
commit b0b6b7b465
2 changed files with 194 additions and 105 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
lib/netdev-offload-dpdk.c
View File

@@ -63,6 +63,7 @@ struct ufid_to_rte_flow_data {
struct dpif_flow_stats stats;
struct netdev *physdev;
struct ovs_mutex lock;
unsigned int creation_tid;
bool dead;
};
@@ -241,6 +242,7 @@ ufid_to_rte_flow_associate(const ovs_u128 *ufid, struct netdev *netdev,
data->physdev = netdev != physdev ? netdev_ref(physdev) : physdev;
data->rte_flow = rte_flow;
data->actions_offloaded = actions_offloaded;
data->creation_tid = netdev_offload_thread_id();
ovs_mutex_init(&data->lock);
cmap_insert(map, CONST_CAST(struct cmap_node *, &data->node), hash);
@@ -2505,6 +2507,7 @@ netdev_offload_dpdk_flow_flush(struct netdev *netdev)
{
struct cmap *map = offload_data_map(netdev);
struct ufid_to_rte_flow_data *data;
unsigned int tid = netdev_offload_thread_id();
if (!map) {
return -1;
@@ -2514,7 +2517,9 @@ netdev_offload_dpdk_flow_flush(struct netdev *netdev)
if (data->netdev != netdev && data->physdev != netdev) {
continue;
}
netdev_offload_dpdk_flow_destroy(data);
if (data->creation_tid == tid) {
netdev_offload_dpdk_flow_destroy(data);
}
}
return 0;