1 /* SPDX-License-Identifier: BSD-3-Clause
2 * Copyright(c) 2010-2014 Intel Corporation
3 */
4
5 #include <rte_byteorder.h>
6 #include <rte_hexdump.h>
7 #include <rte_string_fns.h>
8 #include <string.h>
9 #include "test.h"
10
11 #ifdef RTE_EXEC_ENV_WINDOWS
12 static int
test_table(void)13 test_table(void)
14 {
15 printf("table not supported on Windows, skipping test\n");
16 return TEST_SKIPPED;
17 }
18 #else
19
20 #include "test_table.h"
21 #include "test_table_pipeline.h"
22 #include "test_table_ports.h"
23 #include "test_table_tables.h"
24 #include "test_table_combined.h"
25 #include "test_table_acl.h"
26
27 /* Global variables */
28 struct rte_pipeline *p;
29 struct rte_ring *rings_rx[N_PORTS];
30 struct rte_ring *rings_tx[N_PORTS];
31 struct rte_mempool *pool = NULL;
32
33 uint32_t port_in_id[N_PORTS];
34 uint32_t port_out_id[N_PORTS];
35 uint32_t port_out_id_type[3];
36 uint32_t table_id[N_PORTS*2];
37 uint64_t override_hit_mask = 0xFFFFFFFF;
38 uint64_t override_miss_mask = 0xFFFFFFFF;
39 uint64_t non_reserved_actions_hit = 0;
40 uint64_t non_reserved_actions_miss = 0;
41 uint8_t connect_miss_action_to_port_out = 0;
42 uint8_t connect_miss_action_to_table = 0;
43 uint32_t table_entry_default_action = RTE_PIPELINE_ACTION_DROP;
44 uint32_t table_entry_hit_action = RTE_PIPELINE_ACTION_PORT;
45 uint32_t table_entry_miss_action = RTE_PIPELINE_ACTION_DROP;
46 rte_pipeline_port_in_action_handler port_in_action = NULL;
47 rte_pipeline_port_out_action_handler port_out_action = NULL;
48 rte_pipeline_table_action_handler_hit action_handler_hit = NULL;
49 rte_pipeline_table_action_handler_miss action_handler_miss = NULL;
50
51 /* Function prototypes */
52 static void app_init_rings(void);
53 static void app_init_mbuf_pools(void);
54
pipeline_test_hash(void * key,__rte_unused void * key_mask,__rte_unused uint32_t key_size,__rte_unused uint64_t seed)55 uint64_t pipeline_test_hash(void *key,
56 __rte_unused void *key_mask,
57 __rte_unused uint32_t key_size,
58 __rte_unused uint64_t seed)
59 {
60 uint32_t *k32 = key;
61 uint32_t ip_dst = rte_be_to_cpu_32(k32[0]);
62 uint64_t signature = ip_dst;
63
64 return signature;
65 }
66
pipeline_test_hash_cuckoo(const void * key,__rte_unused uint32_t key_size,__rte_unused uint32_t seed)67 uint32_t pipeline_test_hash_cuckoo(const void *key,
68 __rte_unused uint32_t key_size,
69 __rte_unused uint32_t seed)
70 {
71 const uint32_t *k32 = key;
72 uint32_t ip_dst = rte_be_to_cpu_32(k32[0]);
73 uint32_t signature = ip_dst;
74
75 return signature;
76 }
77
78 static void
app_free_resources(void)79 app_free_resources(void) {
80 int i;
81 for (i = 0; i < N_PORTS; i++)
82 rte_ring_free(rings_rx[i]);
83 rte_mempool_free(pool);
84 }
85
86 static void
app_init_mbuf_pools(void)87 app_init_mbuf_pools(void)
88 {
89 /* Init the buffer pool */
90 printf("Getting/Creating the mempool ...\n");
91 pool = rte_mempool_lookup("mempool");
92 if (!pool) {
93 pool = rte_pktmbuf_pool_create(
94 "mempool",
95 POOL_SIZE,
96 POOL_CACHE_SIZE, 0, POOL_BUFFER_SIZE,
97 0);
98 if (pool == NULL)
99 rte_panic("Cannot create mbuf pool\n");
100 }
101 }
102
103 static void
app_init_rings(void)104 app_init_rings(void)
105 {
106 uint32_t i;
107
108 for (i = 0; i < N_PORTS; i++) {
109 char name[32];
110
111 snprintf(name, sizeof(name), "app_ring_rx_%u", i);
112 rings_rx[i] = rte_ring_lookup(name);
113 if (rings_rx[i] == NULL) {
114 rings_rx[i] = rte_ring_create(
115 name,
116 RING_RX_SIZE,
117 0,
118 RING_F_SP_ENQ | RING_F_SC_DEQ);
119 }
120 if (rings_rx[i] == NULL)
121 rte_panic("Cannot create RX ring %u\n", i);
122 }
123
124 for (i = 0; i < N_PORTS; i++) {
125 char name[32];
126
127 snprintf(name, sizeof(name), "app_ring_tx_%u", i);
128 rings_tx[i] = rte_ring_lookup(name);
129 if (rings_tx[i] == NULL) {
130 rings_tx[i] = rte_ring_create(
131 name,
132 RING_TX_SIZE,
133 0,
134 RING_F_SP_ENQ | RING_F_SC_DEQ);
135 }
136 if (rings_tx[i] == NULL)
137 rte_panic("Cannot create TX ring %u\n", i);
138 }
139
140 }
141
142 static int
test_table(void)143 test_table(void)
144 {
145 int status, ret;
146 unsigned i;
147
148 ret = TEST_SUCCESS;
149
150 app_init_rings();
151 app_init_mbuf_pools();
152
153 printf("\n\n\n\n************Pipeline tests************\n");
154
155 if (test_table_pipeline() < 0) {
156 ret = TEST_FAILED;
157 goto end;
158 }
159
160 printf("\n\n\n\n************Port tests************\n");
161 for (i = 0; i < n_port_tests; i++) {
162 status = port_tests[i]();
163 if (status < 0) {
164 printf("\nPort test number %d failed (%d).\n", i,
165 status);
166 ret = TEST_FAILED;
167 goto end;
168 }
169 }
170
171 printf("\n\n\n\n************Table tests************\n");
172 for (i = 0; i < n_table_tests; i++) {
173 status = table_tests[i]();
174 if (status < 0) {
175 printf("\nTable test number %d failed (%d).\n", i,
176 status);
177 ret = TEST_FAILED;
178 goto end;
179 }
180 }
181
182 printf("\n\n\n\n************Table tests************\n");
183 for (i = 0; i < n_table_tests_combined; i++) {
184 status = table_tests_combined[i]();
185 if (status < 0) {
186 printf("\nCombined table test number %d failed with "
187 "reason number %d.\n", i, status);
188 ret = TEST_FAILED;
189 goto end;
190 }
191 }
192
193 #ifdef RTE_LIB_ACL
194 printf("\n\n\n\n************ACL tests************\n");
195 if (test_table_acl() < 0) {
196 ret = TEST_FAILED;
197 goto end;
198 }
199 #endif
200
201 end:
202 app_free_resources();
203
204 return ret;
205 }
206
207 #endif /* !RTE_EXEC_ENV_WINDOWS */
208
209 REGISTER_FAST_TEST(table_autotest, true, true, test_table);
210