1 /* SPDX-License-Identifier: BSD-3-Clause
2 * Copyright(C) 2021 Marvell.
6 const struct cnxk_rte_flow_term_info term[] = {
7 [RTE_FLOW_ITEM_TYPE_ETH] = {ROC_NPC_ITEM_TYPE_ETH,
8 sizeof(struct rte_flow_item_eth)},
9 [RTE_FLOW_ITEM_TYPE_VLAN] = {ROC_NPC_ITEM_TYPE_VLAN,
10 sizeof(struct rte_flow_item_vlan)},
11 [RTE_FLOW_ITEM_TYPE_E_TAG] = {ROC_NPC_ITEM_TYPE_E_TAG,
12 sizeof(struct rte_flow_item_e_tag)},
13 [RTE_FLOW_ITEM_TYPE_IPV4] = {ROC_NPC_ITEM_TYPE_IPV4,
14 sizeof(struct rte_flow_item_ipv4)},
15 [RTE_FLOW_ITEM_TYPE_IPV6] = {ROC_NPC_ITEM_TYPE_IPV6,
16 sizeof(struct rte_flow_item_ipv6)},
17 [RTE_FLOW_ITEM_TYPE_ARP_ETH_IPV4] = {
18 ROC_NPC_ITEM_TYPE_ARP_ETH_IPV4,
19 sizeof(struct rte_flow_item_arp_eth_ipv4)},
20 [RTE_FLOW_ITEM_TYPE_MPLS] = {ROC_NPC_ITEM_TYPE_MPLS,
21 sizeof(struct rte_flow_item_mpls)},
22 [RTE_FLOW_ITEM_TYPE_ICMP] = {ROC_NPC_ITEM_TYPE_ICMP,
23 sizeof(struct rte_flow_item_icmp)},
24 [RTE_FLOW_ITEM_TYPE_UDP] = {ROC_NPC_ITEM_TYPE_UDP,
25 sizeof(struct rte_flow_item_udp)},
26 [RTE_FLOW_ITEM_TYPE_TCP] = {ROC_NPC_ITEM_TYPE_TCP,
27 sizeof(struct rte_flow_item_tcp)},
28 [RTE_FLOW_ITEM_TYPE_SCTP] = {ROC_NPC_ITEM_TYPE_SCTP,
29 sizeof(struct rte_flow_item_sctp)},
30 [RTE_FLOW_ITEM_TYPE_ESP] = {ROC_NPC_ITEM_TYPE_ESP,
31 sizeof(struct rte_flow_item_esp)},
32 [RTE_FLOW_ITEM_TYPE_GRE] = {ROC_NPC_ITEM_TYPE_GRE,
33 sizeof(struct rte_flow_item_gre)},
34 [RTE_FLOW_ITEM_TYPE_NVGRE] = {ROC_NPC_ITEM_TYPE_NVGRE,
35 sizeof(struct rte_flow_item_nvgre)},
36 [RTE_FLOW_ITEM_TYPE_VXLAN] = {ROC_NPC_ITEM_TYPE_VXLAN,
37 sizeof(struct rte_flow_item_vxlan)},
38 [RTE_FLOW_ITEM_TYPE_GTPC] = {ROC_NPC_ITEM_TYPE_GTPC,
39 sizeof(struct rte_flow_item_gtp)},
40 [RTE_FLOW_ITEM_TYPE_GTPU] = {ROC_NPC_ITEM_TYPE_GTPU,
41 sizeof(struct rte_flow_item_gtp)},
42 [RTE_FLOW_ITEM_TYPE_GENEVE] = {ROC_NPC_ITEM_TYPE_GENEVE,
43 sizeof(struct rte_flow_item_geneve)},
44 [RTE_FLOW_ITEM_TYPE_VXLAN_GPE] = {
45 ROC_NPC_ITEM_TYPE_VXLAN_GPE,
46 sizeof(struct rte_flow_item_vxlan_gpe)},
47 [RTE_FLOW_ITEM_TYPE_IPV6_EXT] = {ROC_NPC_ITEM_TYPE_IPV6_EXT,
48 sizeof(struct rte_flow_item_ipv6_ext)},
49 [RTE_FLOW_ITEM_TYPE_VOID] = {ROC_NPC_ITEM_TYPE_VOID, 0},
50 [RTE_FLOW_ITEM_TYPE_ANY] = {ROC_NPC_ITEM_TYPE_ANY, 0},
51 [RTE_FLOW_ITEM_TYPE_GRE_KEY] = {ROC_NPC_ITEM_TYPE_GRE_KEY,
53 [RTE_FLOW_ITEM_TYPE_HIGIG2] = {ROC_NPC_ITEM_TYPE_HIGIG2,
54 sizeof(struct rte_flow_item_higig2_hdr)},
55 [RTE_FLOW_ITEM_TYPE_RAW] = {ROC_NPC_ITEM_TYPE_RAW,
56 sizeof(struct rte_flow_item_raw)},
57 [RTE_FLOW_ITEM_TYPE_MARK] = {ROC_NPC_ITEM_TYPE_MARK,
58 sizeof(struct rte_flow_item_mark)}};
61 npc_rss_action_validate(struct rte_eth_dev *eth_dev,
62 const struct rte_flow_attr *attr,
63 const struct rte_flow_action *act)
65 const struct rte_flow_action_rss *rss;
67 rss = (const struct rte_flow_action_rss *)act->conf;
70 plt_err("No support of RSS in egress");
74 if (eth_dev->data->dev_conf.rxmode.mq_mode != RTE_ETH_MQ_RX_RSS) {
75 plt_err("multi-queue mode is disabled");
79 if (!rss || !rss->queue_num) {
80 plt_err("no valid queues");
84 if (rss->func != RTE_ETH_HASH_FUNCTION_DEFAULT) {
85 plt_err("non-default RSS hash functions are not supported");
89 if (rss->key_len && rss->key_len > ROC_NIX_RSS_KEY_LEN) {
90 plt_err("RSS hash key too large");
98 npc_rss_flowkey_get(struct cnxk_eth_dev *eth_dev,
99 const struct roc_npc_action *rss_action,
100 uint32_t *flowkey_cfg)
102 const struct roc_npc_action_rss *rss;
104 rss = (const struct roc_npc_action_rss *)rss_action->conf;
106 *flowkey_cfg = cnxk_rss_ethdev_to_nix(eth_dev, rss->types, rss->level);
110 cnxk_map_actions(struct rte_eth_dev *eth_dev, const struct rte_flow_attr *attr,
111 const struct rte_flow_action actions[],
112 struct roc_npc_action in_actions[], uint32_t *flowkey_cfg)
114 struct cnxk_eth_dev *dev = cnxk_eth_pmd_priv(eth_dev);
115 const struct rte_flow_action_port_id *port_act;
116 const struct rte_flow_action_queue *act_q;
117 struct roc_npc *roc_npc_src = &dev->npc;
118 struct rte_eth_dev *portid_eth_dev;
119 char if_name[RTE_ETH_NAME_MAX_LEN];
120 struct cnxk_eth_dev *hw_dst;
121 struct roc_npc *roc_npc_dst;
125 for (; actions->type != RTE_FLOW_ACTION_TYPE_END; actions++) {
126 switch (actions->type) {
127 case RTE_FLOW_ACTION_TYPE_VOID:
128 in_actions[i].type = ROC_NPC_ACTION_TYPE_VOID;
131 case RTE_FLOW_ACTION_TYPE_MARK:
132 in_actions[i].type = ROC_NPC_ACTION_TYPE_MARK;
133 in_actions[i].conf = actions->conf;
136 case RTE_FLOW_ACTION_TYPE_FLAG:
137 in_actions[i].type = ROC_NPC_ACTION_TYPE_FLAG;
140 case RTE_FLOW_ACTION_TYPE_COUNT:
141 in_actions[i].type = ROC_NPC_ACTION_TYPE_COUNT;
144 case RTE_FLOW_ACTION_TYPE_DROP:
145 in_actions[i].type = ROC_NPC_ACTION_TYPE_DROP;
148 case RTE_FLOW_ACTION_TYPE_PF:
149 in_actions[i].type = ROC_NPC_ACTION_TYPE_PF;
152 case RTE_FLOW_ACTION_TYPE_VF:
153 in_actions[i].type = ROC_NPC_ACTION_TYPE_VF;
154 in_actions[i].conf = actions->conf;
157 case RTE_FLOW_ACTION_TYPE_PORT_ID:
158 in_actions[i].type = ROC_NPC_ACTION_TYPE_PORT_ID;
159 in_actions[i].conf = actions->conf;
160 port_act = (const struct rte_flow_action_port_id *)
162 if (rte_eth_dev_get_name_by_port(port_act->id,
164 plt_err("Name not found for output port id");
167 portid_eth_dev = rte_eth_dev_allocated(if_name);
168 if (!portid_eth_dev) {
169 plt_err("eth_dev not found for output port id");
172 if (strcmp(portid_eth_dev->device->driver->name,
173 eth_dev->device->driver->name) != 0) {
174 plt_err("Output port not under same driver");
177 hw_dst = portid_eth_dev->data->dev_private;
178 roc_npc_dst = &hw_dst->npc;
180 rc = roc_npc_validate_portid_action(roc_npc_src,
187 case RTE_FLOW_ACTION_TYPE_QUEUE:
188 act_q = (const struct rte_flow_action_queue *)
191 if (rq >= eth_dev->data->nb_rx_queues) {
192 plt_npc_dbg("Invalid queue index");
195 in_actions[i].type = ROC_NPC_ACTION_TYPE_QUEUE;
196 in_actions[i].conf = actions->conf;
199 case RTE_FLOW_ACTION_TYPE_RSS:
200 rc = npc_rss_action_validate(eth_dev, attr, actions);
203 in_actions[i].type = ROC_NPC_ACTION_TYPE_RSS;
204 in_actions[i].conf = actions->conf;
205 npc_rss_flowkey_get(dev, &in_actions[i], flowkey_cfg);
208 case RTE_FLOW_ACTION_TYPE_SECURITY:
209 in_actions[i].type = ROC_NPC_ACTION_TYPE_SEC;
211 case RTE_FLOW_ACTION_TYPE_OF_POP_VLAN:
212 in_actions[i].type = ROC_NPC_ACTION_TYPE_VLAN_STRIP;
214 case RTE_FLOW_ACTION_TYPE_OF_SET_VLAN_VID:
215 in_actions[i].type = ROC_NPC_ACTION_TYPE_VLAN_INSERT;
216 in_actions[i].conf = actions->conf;
218 case RTE_FLOW_ACTION_TYPE_OF_PUSH_VLAN:
220 ROC_NPC_ACTION_TYPE_VLAN_ETHTYPE_INSERT;
221 in_actions[i].conf = actions->conf;
223 case RTE_FLOW_ACTION_TYPE_OF_SET_VLAN_PCP:
225 ROC_NPC_ACTION_TYPE_VLAN_PCP_INSERT;
226 in_actions[i].conf = actions->conf;
228 case RTE_FLOW_ACTION_TYPE_METER:
229 in_actions[i].type = ROC_NPC_ACTION_TYPE_METER;
230 in_actions[i].conf = actions->conf;
233 plt_npc_dbg("Action is not supported = %d",
239 in_actions[i].type = ROC_NPC_ACTION_TYPE_END;
247 cnxk_map_flow_data(struct rte_eth_dev *eth_dev,
248 const struct rte_flow_attr *attr,
249 const struct rte_flow_item pattern[],
250 const struct rte_flow_action actions[],
251 struct roc_npc_attr *in_attr,
252 struct roc_npc_item_info in_pattern[],
253 struct roc_npc_action in_actions[], uint32_t *flowkey_cfg)
257 in_attr->priority = attr->priority;
258 in_attr->ingress = attr->ingress;
259 in_attr->egress = attr->egress;
261 while (pattern->type != RTE_FLOW_ITEM_TYPE_END) {
262 in_pattern[i].spec = pattern->spec;
263 in_pattern[i].last = pattern->last;
264 in_pattern[i].mask = pattern->mask;
265 in_pattern[i].type = term[pattern->type].item_type;
266 in_pattern[i].size = term[pattern->type].item_size;
270 in_pattern[i].type = ROC_NPC_ITEM_TYPE_END;
272 return cnxk_map_actions(eth_dev, attr, actions, in_actions,
277 cnxk_flow_validate(struct rte_eth_dev *eth_dev,
278 const struct rte_flow_attr *attr,
279 const struct rte_flow_item pattern[],
280 const struct rte_flow_action actions[],
281 struct rte_flow_error *error)
283 struct roc_npc_item_info in_pattern[ROC_NPC_ITEM_TYPE_END + 1];
284 struct roc_npc_action in_actions[ROC_NPC_MAX_ACTION_COUNT];
285 struct cnxk_eth_dev *dev = cnxk_eth_pmd_priv(eth_dev);
286 struct roc_npc *npc = &dev->npc;
287 struct roc_npc_attr in_attr;
288 struct roc_npc_flow flow;
289 uint32_t flowkey_cfg = 0;
292 memset(&flow, 0, sizeof(flow));
294 rc = cnxk_map_flow_data(eth_dev, attr, pattern, actions, &in_attr,
295 in_pattern, in_actions, &flowkey_cfg);
297 rte_flow_error_set(error, 0, RTE_FLOW_ERROR_TYPE_ACTION_NUM,
298 NULL, "Failed to map flow data");
302 rc = roc_npc_flow_parse(npc, &in_attr, in_pattern, in_actions, &flow);
305 rte_flow_error_set(error, 0, rc, NULL,
306 "Flow validation failed");
312 struct roc_npc_flow *
313 cnxk_flow_create(struct rte_eth_dev *eth_dev, const struct rte_flow_attr *attr,
314 const struct rte_flow_item pattern[],
315 const struct rte_flow_action actions[],
316 struct rte_flow_error *error)
318 struct cnxk_eth_dev *dev = cnxk_eth_pmd_priv(eth_dev);
319 struct roc_npc_item_info in_pattern[ROC_NPC_ITEM_TYPE_END + 1];
320 struct roc_npc_action in_actions[ROC_NPC_MAX_ACTION_COUNT];
321 struct roc_npc *npc = &dev->npc;
322 struct roc_npc_attr in_attr;
323 struct roc_npc_flow *flow;
327 rc = cnxk_map_flow_data(eth_dev, attr, pattern, actions, &in_attr,
328 in_pattern, in_actions,
329 &npc->flowkey_cfg_state);
331 rte_flow_error_set(error, 0, RTE_FLOW_ERROR_TYPE_ACTION_NUM,
332 NULL, "Failed to map flow data");
336 flow = roc_npc_flow_create(npc, &in_attr, in_pattern, in_actions,
339 rte_flow_error_set(error, errcode, errcode, NULL,
340 roc_error_msg_get(errcode));
348 cnxk_flow_destroy(struct rte_eth_dev *eth_dev, struct roc_npc_flow *flow,
349 struct rte_flow_error *error)
351 struct cnxk_eth_dev *dev = cnxk_eth_pmd_priv(eth_dev);
352 struct roc_npc *npc = &dev->npc;
355 rc = roc_npc_flow_destroy(npc, flow);
357 rte_flow_error_set(error, rc, RTE_FLOW_ERROR_TYPE_UNSPECIFIED,
358 NULL, "Flow Destroy failed");
363 cnxk_flow_flush(struct rte_eth_dev *eth_dev, struct rte_flow_error *error)
365 struct cnxk_eth_dev *dev = cnxk_eth_pmd_priv(eth_dev);
366 struct roc_npc *npc = &dev->npc;
369 rc = roc_npc_mcam_free_all_resources(npc);
371 rte_flow_error_set(error, EIO, RTE_FLOW_ERROR_TYPE_UNSPECIFIED,
372 NULL, "Failed to flush filter");
380 cnxk_flow_query(struct rte_eth_dev *eth_dev, struct rte_flow *flow,
381 const struct rte_flow_action *action, void *data,
382 struct rte_flow_error *error)
384 struct roc_npc_flow *in_flow = (struct roc_npc_flow *)flow;
385 struct cnxk_eth_dev *dev = cnxk_eth_pmd_priv(eth_dev);
386 struct roc_npc *npc = &dev->npc;
387 struct rte_flow_query_count *query = data;
388 const char *errmsg = NULL;
389 int errcode = ENOTSUP;
392 if (action->type != RTE_FLOW_ACTION_TYPE_COUNT) {
393 errmsg = "Only COUNT is supported in query";
397 if (in_flow->ctr_id == NPC_COUNTER_NONE) {
398 errmsg = "Counter is not available";
402 rc = roc_npc_mcam_read_counter(npc, in_flow->ctr_id, &query->hits);
405 errmsg = "Error reading flow counter";
409 query->bytes_set = 0;
412 rc = roc_npc_mcam_clear_counter(npc, in_flow->ctr_id);
415 errmsg = "Error clearing flow counter";
422 rte_flow_error_set(error, errcode, RTE_FLOW_ERROR_TYPE_UNSPECIFIED,
428 cnxk_flow_isolate(struct rte_eth_dev *eth_dev __rte_unused,
429 int enable __rte_unused, struct rte_flow_error *error)
431 /* If we support, we need to un-install the default mcam
432 * entry for this port.
435 rte_flow_error_set(error, ENOTSUP, RTE_FLOW_ERROR_TYPE_UNSPECIFIED,
436 NULL, "Flow isolation not supported");
442 cnxk_flow_dev_dump(struct rte_eth_dev *eth_dev, struct rte_flow *flow,
443 FILE *file, struct rte_flow_error *error)
445 struct cnxk_eth_dev *dev = cnxk_eth_pmd_priv(eth_dev);
446 struct roc_npc *npc = &dev->npc;
449 rte_flow_error_set(error, EINVAL,
450 RTE_FLOW_ERROR_TYPE_UNSPECIFIED, NULL,
456 rte_flow_error_set(error, EINVAL,
457 RTE_FLOW_ERROR_TYPE_HANDLE,
463 roc_npc_flow_dump(file, npc);
468 struct rte_flow_ops cnxk_flow_ops = {
469 .validate = cnxk_flow_validate,
470 .flush = cnxk_flow_flush,
471 .query = cnxk_flow_query,
472 .isolate = cnxk_flow_isolate,
473 .dev_dump = cnxk_flow_dev_dump,