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