1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
|
/* SPDX-License-Identifier: BSD-3-Clause
* Copyright 2020 Mellanox Technologies, Ltd
*
* The file contains the implementations of the method to
* fill items, actions & attributes in their corresponding
* arrays, and then generate rte_flow rule.
*
* After the generation. The rule goes to validation then
* creation state and then return the results.
*/
#include <stdint.h>
#include "flow_gen.h"
#include "items_gen.h"
#include "actions_gen.h"
#include "config.h"
static void
fill_attributes(struct rte_flow_attr *attr,
uint64_t *flow_attrs, uint16_t group, uint8_t max_priority)
{
uint8_t i;
for (i = 0; i < MAX_ATTRS_NUM; i++) {
if (flow_attrs[i] == 0)
break;
if (flow_attrs[i] & INGRESS)
attr->ingress = 1;
else if (flow_attrs[i] & EGRESS)
attr->egress = 1;
else if (flow_attrs[i] & TRANSFER)
attr->transfer = 1;
}
attr->group = group;
attr->priority = rte_rand_max(max_priority);
}
struct rte_flow *
generate_flow(uint16_t port_id,
uint16_t group,
uint64_t *flow_attrs,
uint64_t *flow_items,
uint64_t *flow_actions,
uint16_t next_table,
uint32_t outer_ip_src,
uint16_t hairpinq,
uint64_t encap_data,
uint64_t decap_data,
uint16_t dst_port,
uint8_t core_idx,
uint8_t rx_queues_count,
bool unique_data,
uint8_t max_priority,
struct rte_flow_error *error)
{
struct rte_flow_attr attr;
struct rte_flow_item items[MAX_ITEMS_NUM];
struct rte_flow_action actions[MAX_ACTIONS_NUM];
struct rte_flow *flow = NULL;
memset(items, 0, sizeof(items));
memset(actions, 0, sizeof(actions));
memset(&attr, 0, sizeof(struct rte_flow_attr));
fill_attributes(&attr, flow_attrs, group, max_priority);
fill_actions(actions, flow_actions,
outer_ip_src, next_table, hairpinq,
encap_data, decap_data, core_idx,
unique_data, rx_queues_count, dst_port);
fill_items(items, flow_items, outer_ip_src, core_idx);
flow = rte_flow_create(port_id, &attr, items, actions, error);
return flow;
}
|
