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

netdev-dpdk: Introduce DPDK tunnel APIs.

Browse Source 
As a pre-step towards tunnel offloads, introduce DPDK APIs.

Signed-off-by: Eli Britstein <elibr@nvidia.com>
Reviewed-by: Gaetan Rivet <gaetanr@nvidia.com>
Acked-by: Sriharsha Basavapatna <sriharsha.basavapatna@broadcom.com>
Tested-by: Emma Finn <emma.finn@intel.com>
Tested-by: Marko Kovacevic <marko.kovacevic@intel.com>
Signed-off-by: Ilya Maximets <i.maximets@ovn.org>
This commit is contained in:
Eli Britstein
2021-06-23 15:52:41 +00:00
committed by Ilya Maximets
parent f36e7438fa
commit 6f50f28b99
2 changed files with 209 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

112
lib/netdev-dpdk.c
View File

@@ -5291,6 +5291,118 @@ netdev_dpdk_rte_flow_query_count(struct netdev *netdev,
return ret; return ret;
} }
#ifdef ALLOW_EXPERIMENTAL_API
int
netdev_dpdk_rte_flow_tunnel_decap_set(struct netdev *netdev,
struct rte_flow_tunnel *tunnel,
struct rte_flow_action **actions,
uint32_t *num_of_actions,
struct rte_flow_error *error)
{
struct netdev_dpdk *dev;
int ret;
if (!is_dpdk_class(netdev->netdev_class)) {
return -1;
}
dev = netdev_dpdk_cast(netdev);
ovs_mutex_lock(&dev->mutex);
ret = rte_flow_tunnel_decap_set(dev->port_id, tunnel, actions,
num_of_actions, error);
ovs_mutex_unlock(&dev->mutex);
return ret;
}
int
netdev_dpdk_rte_flow_tunnel_match(struct netdev *netdev,
struct rte_flow_tunnel *tunnel,
struct rte_flow_item **items,
uint32_t *num_of_items,
struct rte_flow_error *error)
{
struct netdev_dpdk *dev;
int ret;
if (!is_dpdk_class(netdev->netdev_class)) {
return -1;
}
dev = netdev_dpdk_cast(netdev);
ovs_mutex_lock(&dev->mutex);
ret = rte_flow_tunnel_match(dev->port_id, tunnel, items, num_of_items,
error);
ovs_mutex_unlock(&dev->mutex);
return ret;
}
int
netdev_dpdk_rte_flow_get_restore_info(struct netdev *netdev,
struct dp_packet *p,
struct rte_flow_restore_info *info,
struct rte_flow_error *error)
{
struct rte_mbuf *m = (struct rte_mbuf *) p;
struct netdev_dpdk *dev;
int ret;
if (!is_dpdk_class(netdev->netdev_class)) {
return -1;
}
dev = netdev_dpdk_cast(netdev);
ovs_mutex_lock(&dev->mutex);
ret = rte_flow_get_restore_info(dev->port_id, m, info, error);
ovs_mutex_unlock(&dev->mutex);
return ret;
}
int
netdev_dpdk_rte_flow_tunnel_action_decap_release(
struct netdev *netdev,
struct rte_flow_action *actions,
uint32_t num_of_actions,
struct rte_flow_error *error)
{
struct netdev_dpdk *dev;
int ret;
if (!is_dpdk_class(netdev->netdev_class)) {
return -1;
}
dev = netdev_dpdk_cast(netdev);
ovs_mutex_lock(&dev->mutex);
ret = rte_flow_tunnel_action_decap_release(dev->port_id, actions,
num_of_actions, error);
ovs_mutex_unlock(&dev->mutex);
return ret;
}
int
netdev_dpdk_rte_flow_tunnel_item_release(struct netdev *netdev,
struct rte_flow_item *items,
uint32_t num_of_items,
struct rte_flow_error *error)
{
struct netdev_dpdk *dev;
int ret;
if (!is_dpdk_class(netdev->netdev_class)) {
return -1;
}
dev = netdev_dpdk_cast(netdev);
ovs_mutex_lock(&dev->mutex);
ret = rte_flow_tunnel_item_release(dev->port_id, items, num_of_items,
error);
ovs_mutex_unlock(&dev->mutex);
return ret;
}
#endif /* ALLOW_EXPERIMENTAL_API */
#define NETDEV_DPDK_CLASS_COMMON \ #define NETDEV_DPDK_CLASS_COMMON \
.is_pmd = true, \ .is_pmd = true, \
.alloc = netdev_dpdk_alloc, \ .alloc = netdev_dpdk_alloc, \

103
lib/netdev-dpdk.h
View File

@@ -26,12 +26,7 @@ struct netdev;
#ifdef DPDK_NETDEV #ifdef DPDK_NETDEV
struct rte_flow; #include <rte_flow.h>
struct rte_flow_error;
struct rte_flow_attr;
struct rte_flow_item;
struct rte_flow_action;
struct rte_flow_query_count;
void netdev_dpdk_register(void); void netdev_dpdk_register(void);
void free_dpdk_buf(struct dp_packet *); void free_dpdk_buf(struct dp_packet *);
@@ -56,6 +51,102 @@ netdev_dpdk_rte_flow_query_count(struct netdev *netdev,
int int
netdev_dpdk_get_port_id(struct netdev *netdev); netdev_dpdk_get_port_id(struct netdev *netdev);
#ifdef ALLOW_EXPERIMENTAL_API
int netdev_dpdk_rte_flow_tunnel_decap_set(struct netdev *,
struct rte_flow_tunnel *,
struct rte_flow_action **,
uint32_t *num_of_actions,
struct rte_flow_error *);
int netdev_dpdk_rte_flow_tunnel_match(struct netdev *,
struct rte_flow_tunnel *,
struct rte_flow_item **,
uint32_t *num_of_items,
struct rte_flow_error *);
int netdev_dpdk_rte_flow_get_restore_info(struct netdev *,
struct dp_packet *,
struct rte_flow_restore_info *,
struct rte_flow_error *);
int netdev_dpdk_rte_flow_tunnel_action_decap_release(struct netdev *,
struct rte_flow_action *,
uint32_t num_of_actions,
struct rte_flow_error *);
int netdev_dpdk_rte_flow_tunnel_item_release(struct netdev *,
struct rte_flow_item *,
uint32_t num_of_items,
struct rte_flow_error *);
#else
static inline void
set_error(struct rte_flow_error *error, enum rte_flow_error_type type)
{
if (!error) {
return;
}
error->type = type;
error->cause = NULL;
error->message = NULL;
}
static inline int
netdev_dpdk_rte_flow_tunnel_decap_set(
struct netdev *netdev OVS_UNUSED,
struct rte_flow_tunnel *tunnel OVS_UNUSED,
struct rte_flow_action **actions OVS_UNUSED,
uint32_t *num_of_actions OVS_UNUSED,
struct rte_flow_error *error)
{
set_error(error, RTE_FLOW_ERROR_TYPE_ACTION);
return -1;
}
static inline int
netdev_dpdk_rte_flow_tunnel_match(struct netdev *netdev OVS_UNUSED,
struct rte_flow_tunnel *tunnel OVS_UNUSED,
struct rte_flow_item **items OVS_UNUSED,
uint32_t *num_of_items OVS_UNUSED,
struct rte_flow_error *error)
{
set_error(error, RTE_FLOW_ERROR_TYPE_ITEM);
return -1;
}
static inline int
netdev_dpdk_rte_flow_get_restore_info(
struct netdev *netdev OVS_UNUSED,
struct dp_packet *p OVS_UNUSED,
struct rte_flow_restore_info *info OVS_UNUSED,
struct rte_flow_error *error)
{
set_error(error, RTE_FLOW_ERROR_TYPE_ATTR);
return -1;
}
static inline int
netdev_dpdk_rte_flow_tunnel_action_decap_release(
struct netdev *netdev OVS_UNUSED,
struct rte_flow_action *actions OVS_UNUSED,
uint32_t num_of_actions OVS_UNUSED,
struct rte_flow_error *error)
{
set_error(error, RTE_FLOW_ERROR_TYPE_NONE);
return 0;
}
static inline int
netdev_dpdk_rte_flow_tunnel_item_release(
struct netdev *netdev OVS_UNUSED,
struct rte_flow_item *items OVS_UNUSED,
uint32_t num_of_items OVS_UNUSED,
struct rte_flow_error *error)
{
set_error(error, RTE_FLOW_ERROR_TYPE_NONE);
return 0;
}
#endif /* ALLOW_EXPERIMENTAL_API */
#else #else
static inline void static inline void