net/cnxk: support to read/update meter stats

[dpdk.git] / drivers / net / cnxk / cn9k_rte_flow.c

diff --git a/drivers/net/cnxk/cn9k_rte_flow.c b/drivers/net/cnxk/cn9k_rte_flow.c
index 24e1b92..b94d29e 100644 (file)
--- a/drivers/net/cnxk/cn9k_rte_flow.c
+++ b/drivers/net/cnxk/cn9k_rte_flow.c
@@ -4,6 +4,7 @@
 #include <cnxk_rte_flow.h>
 #include "cn9k_ethdev.h"
 #include "cn9k_rte_flow.h"
+#include "cn9k_rx.h"
 
 struct rte_flow *
 cn9k_flow_create(struct rte_eth_dev *eth_dev, const struct rte_flow_attr *attr,
@@ -11,12 +12,29 @@ cn9k_flow_create(struct rte_eth_dev *eth_dev, const struct rte_flow_attr *attr,
                 const struct rte_flow_action actions[],
                 struct rte_flow_error *error)
 {
+       struct cnxk_eth_dev *dev = cnxk_eth_pmd_priv(eth_dev);
+       int mark_actions = 0, vtag_actions = 0;
+       struct roc_npc *npc = &dev->npc;
        struct roc_npc_flow *flow;
 
        flow = cnxk_flow_create(eth_dev, attr, pattern, actions, error);
        if (!flow)
                return NULL;
 
+       mark_actions = roc_npc_mark_actions_get(npc);
+
+       if (mark_actions) {
+               dev->rx_offload_flags |= NIX_RX_OFFLOAD_MARK_UPDATE_F;
+               cn9k_eth_set_rx_function(eth_dev);
+       }
+
+       vtag_actions = roc_npc_vtag_actions_get(npc);
+
+       if (vtag_actions) {
+               dev->rx_offload_flags |= NIX_RX_OFFLOAD_VLAN_STRIP_F;
+               cn9k_eth_set_rx_function(eth_dev);
+       }
+
        return (struct rte_flow *)flow;
 }
 
@@ -25,6 +43,30 @@ cn9k_flow_destroy(struct rte_eth_dev *eth_dev, struct rte_flow *rte_flow,
                  struct rte_flow_error *error)
 {
        struct roc_npc_flow *flow = (struct roc_npc_flow *)rte_flow;
+       struct cnxk_eth_dev *dev = cnxk_eth_pmd_priv(eth_dev);
+       int mark_actions = 0, vtag_actions = 0;
+       struct roc_npc *npc = &dev->npc;
+
+       mark_actions = roc_npc_mark_actions_get(npc);
+       if (mark_actions) {
+               mark_actions = roc_npc_mark_actions_sub_return(npc, 1);
+               if (mark_actions == 0) {
+                       dev->rx_offload_flags &= ~NIX_RX_OFFLOAD_MARK_UPDATE_F;
+                       cn9k_eth_set_rx_function(eth_dev);
+               }
+       }
+
+       vtag_actions = roc_npc_vtag_actions_get(npc);
+       if (vtag_actions) {
+               if (flow->nix_intf == ROC_NPC_INTF_RX) {
+                       vtag_actions = roc_npc_vtag_actions_sub_return(npc, 1);
+                       if (vtag_actions == 0) {
+                               dev->rx_offload_flags &=
+                                       ~NIX_RX_OFFLOAD_VLAN_STRIP_F;
+                               cn9k_eth_set_rx_function(eth_dev);
+                       }
+               }
+       }
 
        return cnxk_flow_destroy(eth_dev, flow, error);
 }