mir/openvswitch
2
0
Fork 0
mirror of https://github.com/openvswitch/ovs synced 2025-10-23 14:57:06 +00:00
Code Issues Releases Wiki Activity

netdev-tc-offloads: Add ufid to tc/netdev map

Browse Source 
Flows offloaded to tc are identified by priority
and handle pair while OVS flows are identified by ufid.
Added a hash map to convert between the two for later
retrieval and deleting of offloaded flows.

Signed-off-by: Paul Blakey <paulb@mellanox.com>
Reviewed-by: Roi Dayan <roid@mellanox.com>
Acked-by: Flavio Leitner <fbl@sysclose.org>
Signed-off-by: Simon Horman <simon.horman@netronome.com>
This commit is contained in:
Paul Blakey
2017-06-13 18:03:35 +03:00
committed by Simon Horman
parent f2280b4198
commit 9116730dbb
1 changed files with 132 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

132
lib/netdev-tc-offloads.c
View File

@@ -38,6 +38,138 @@ VLOG_DEFINE_THIS_MODULE(netdev_tc_offloads);
static struct vlog_rate_limit error_rl = VLOG_RATE_LIMIT_INIT(60, 5);
static struct hmap ufid_tc = HMAP_INITIALIZER(&ufid_tc);
static struct ovs_mutex ufid_lock = OVS_MUTEX_INITIALIZER;
/**
* struct ufid_tc_data - data entry for ufid_tc hmap.
* @ufid_node: Element in @ufid_tc hash table by ufid key.
* @tc_node: Element in @ufid_tc hash table by prio/handle/ifindex key.
* @ufid: ufid assigned to the flow
* @prio: tc priority
* @handle: tc handle
* @ifindex: netdev ifindex.
* @netdev: netdev associated with the tc rule
*/
struct ufid_tc_data {
struct hmap_node ufid_node;
struct hmap_node tc_node;
ovs_u128 ufid;
uint16_t prio;
uint32_t handle;
int ifindex;
struct netdev *netdev;
};
/* Remove matching ufid entry from ufid_tc hashmap. */
static void
del_ufid_tc_mapping(const ovs_u128 *ufid)
{
size_t ufid_hash = hash_bytes(ufid, sizeof *ufid, 0);
struct ufid_tc_data *data;
ovs_mutex_lock(&ufid_lock);
HMAP_FOR_EACH_WITH_HASH(data, ufid_node, ufid_hash, &ufid_tc) {
if (ovs_u128_equals(*ufid, data->ufid)) {
break;
}
}
if (!data) {
ovs_mutex_unlock(&ufid_lock);
return;
}
hmap_remove(&ufid_tc, &data->ufid_node);
hmap_remove(&ufid_tc, &data->tc_node);
netdev_close(data->netdev);
free(data);
ovs_mutex_unlock(&ufid_lock);
}
/* Add ufid entry to ufid_tc hashmap.
* If entry exists already it will be replaced. */
static void OVS_UNUSED
add_ufid_tc_mapping(const ovs_u128 *ufid, int prio, int handle,
struct netdev *netdev, int ifindex)
{
size_t ufid_hash = hash_bytes(ufid, sizeof *ufid, 0);
size_t tc_hash = hash_int(hash_int(prio, handle), ifindex);
struct ufid_tc_data *new_data = xzalloc(sizeof *new_data);
del_ufid_tc_mapping(ufid);
new_data->ufid = *ufid;
new_data->prio = prio;
new_data->handle = handle;
new_data->netdev = netdev_ref(netdev);
new_data->ifindex = ifindex;
ovs_mutex_lock(&ufid_lock);
hmap_insert(&ufid_tc, &new_data->ufid_node, ufid_hash);
hmap_insert(&ufid_tc, &new_data->tc_node, tc_hash);
ovs_mutex_unlock(&ufid_lock);
}
/* Get ufid from ufid_tc hashmap.
*
* If netdev output param is not NULL then the function will return
* associated netdev on success and a refcount is taken on that netdev.
* The caller is then responsible to close the netdev.
*
* Returns handle if successful and fill prio and netdev for that ufid.
* Otherwise returns 0.
*/
static int OVS_UNUSED
get_ufid_tc_mapping(const ovs_u128 *ufid, int *prio, struct netdev **netdev)
{
size_t ufid_hash = hash_bytes(ufid, sizeof *ufid, 0);
struct ufid_tc_data *data;
int handle = 0;
ovs_mutex_lock(&ufid_lock);
HMAP_FOR_EACH_WITH_HASH(data, ufid_node, ufid_hash, &ufid_tc) {
if (ovs_u128_equals(*ufid, data->ufid)) {
if (prio) {
*prio = data->prio;
}
if (netdev) {
*netdev = netdev_ref(data->netdev);
}
handle = data->handle;
break;
}
}
ovs_mutex_unlock(&ufid_lock);
return handle;
}
/* Find ufid entry in ufid_tc hashmap using prio, handle and netdev.
* The result is saved in ufid.
*
* Returns true on success.
*/
static bool OVS_UNUSED
find_ufid(int prio, int handle, struct netdev *netdev, ovs_u128 *ufid)
{
int ifindex = netdev_get_ifindex(netdev);
struct ufid_tc_data *data;
size_t tc_hash = hash_int(hash_int(prio, handle), ifindex);
ovs_mutex_lock(&ufid_lock);
HMAP_FOR_EACH_WITH_HASH(data, tc_node, tc_hash, &ufid_tc) {
if (data->prio == prio && data->handle == handle
&& data->ifindex == ifindex) {
*ufid = data->ufid;
break;
}
}
ovs_mutex_unlock(&ufid_lock);
return (data != NULL);
}
int
netdev_tc_flow_flush(struct netdev *netdev)
{