apps: use helper to create mbuf pools
[dpdk.git] / app / test / test_table.c
1 /*-
2  *   BSD LICENSE
3  *
4  *   Copyright(c) 2010-2014 Intel Corporation. All rights reserved.
5  *   All rights reserved.
6  *
7  *   Redistribution and use in source and binary forms, with or without
8  *   modification, are permitted provided that the following conditions
9  *   are met:
10  *
11  *     * Redistributions of source code must retain the above copyright
12  *       notice, this list of conditions and the following disclaimer.
13  *     * Redistributions in binary form must reproduce the above copyright
14  *       notice, this list of conditions and the following disclaimer in
15  *       the documentation and/or other materials provided with the
16  *       distribution.
17  *     * Neither the name of Intel Corporation nor the names of its
18  *       contributors may be used to endorse or promote products derived
19  *       from this software without specific prior written permission.
20  *
21  *   THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
22  *   "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
23  *   LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
24  *   A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
25  *   OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
26  *   SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
27  *   LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
28  *   DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
29  *   THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
30  *   (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
31  *   OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
32  */
33
34 #include <rte_byteorder.h>
35 #include <rte_hexdump.h>
36 #include <rte_string_fns.h>
37 #include <string.h>
38 #include "test.h"
39 #include "test_table.h"
40 #include "test_table_pipeline.h"
41 #include "test_table_ports.h"
42 #include "test_table_tables.h"
43 #include "test_table_combined.h"
44 #include "test_table_acl.h"
45
46 /* Global variables */
47 struct rte_pipeline *p;
48 struct rte_ring *rings_rx[N_PORTS];
49 struct rte_ring *rings_tx[N_PORTS];
50 struct rte_mempool *pool = NULL;
51
52 uint32_t port_in_id[N_PORTS];
53 uint32_t port_out_id[N_PORTS];
54 uint32_t port_out_id_type[3];
55 uint32_t table_id[N_PORTS*2];
56 uint64_t override_hit_mask = 0xFFFFFFFF;
57 uint64_t override_miss_mask = 0xFFFFFFFF;
58 uint64_t non_reserved_actions_hit = 0;
59 uint64_t non_reserved_actions_miss = 0;
60 uint8_t connect_miss_action_to_port_out = 0;
61 uint8_t connect_miss_action_to_table = 0;
62 uint32_t table_entry_default_action = RTE_PIPELINE_ACTION_DROP;
63 uint32_t table_entry_hit_action = RTE_PIPELINE_ACTION_PORT;
64 uint32_t table_entry_miss_action = RTE_PIPELINE_ACTION_DROP;
65 rte_pipeline_port_in_action_handler port_in_action = NULL;
66 rte_pipeline_port_out_action_handler port_out_action = NULL;
67 rte_pipeline_table_action_handler_hit action_handler_hit = NULL;
68 rte_pipeline_table_action_handler_miss action_handler_miss = NULL;
69
70 /* Function prototypes */
71 static void app_init_rings(void);
72 static void app_init_mbuf_pools(void);
73
74 uint64_t pipeline_test_hash(void *key,
75                 __attribute__((unused)) uint32_t key_size,
76                 __attribute__((unused)) uint64_t seed)
77 {
78         uint32_t *k32 = (uint32_t *) key;
79         uint32_t ip_dst = rte_be_to_cpu_32(k32[0]);
80         uint64_t signature = ip_dst;
81
82         return signature;
83 }
84
85 static void
86 app_init_mbuf_pools(void)
87 {
88         /* Init the buffer pool */
89         printf("Getting/Creating the mempool ...\n");
90         pool = rte_mempool_lookup("mempool");
91         if (!pool) {
92                 pool = rte_pktmbuf_pool_create(
93                         "mempool",
94                         POOL_SIZE,
95                         POOL_CACHE_SIZE, 0, POOL_BUFFER_SIZE,
96                         0);
97                 if (pool == NULL)
98                         rte_panic("Cannot create mbuf pool\n");
99         }
100 }
101
102 static void
103 app_init_rings(void)
104 {
105         uint32_t i;
106
107         for (i = 0; i < N_PORTS; i++) {
108                 char name[32];
109
110                 snprintf(name, sizeof(name), "app_ring_rx_%u", i);
111                 rings_rx[i] = rte_ring_lookup(name);
112                 if (rings_rx[i] == NULL) {
113                         rings_rx[i] = rte_ring_create(
114                                 name,
115                                 RING_RX_SIZE,
116                                 0,
117                                 RING_F_SP_ENQ | RING_F_SC_DEQ);
118                 }
119                 if (rings_rx[i] == NULL)
120                         rte_panic("Cannot create RX ring %u\n", i);
121         }
122
123         for (i = 0; i < N_PORTS; i++) {
124                 char name[32];
125
126                 snprintf(name, sizeof(name), "app_ring_tx_%u", i);
127                 rings_tx[i] = rte_ring_lookup(name);
128                 if (rings_tx[i] == NULL) {
129                         rings_tx[i] = rte_ring_create(
130                                 name,
131                                 RING_TX_SIZE,
132                                 0,
133                                 RING_F_SP_ENQ | RING_F_SC_DEQ);
134                 }
135                 if (rings_tx[i] == NULL)
136                         rte_panic("Cannot create TX ring %u\n", i);
137         }
138
139 }
140
141 static int
142 test_table(void)
143 {
144         int status, failures;
145         unsigned i;
146
147         failures = 0;
148
149         app_init_rings();
150         app_init_mbuf_pools();
151
152         printf("\n\n\n\n************Pipeline tests************\n");
153
154         if (test_table_pipeline() < 0)
155                 return -1;
156
157         printf("\n\n\n\n************Port tests************\n");
158         for (i = 0; i < n_port_tests; i++) {
159                 status = port_tests[i]();
160                 if (status < 0) {
161                         printf("\nPort test number %d failed (%d).\n", i,
162                                 status);
163                         failures++;
164                         return -1;
165                 }
166         }
167
168         printf("\n\n\n\n************Table tests************\n");
169         for (i = 0; i < n_table_tests; i++) {
170                 status = table_tests[i]();
171                 if (status < 0) {
172                         printf("\nTable test number %d failed (%d).\n", i,
173                                 status);
174                         failures++;
175                         return -1;
176                 }
177         }
178
179         printf("\n\n\n\n************Table tests************\n");
180         for (i = 0; i < n_table_tests_combined; i++) {
181                 status = table_tests_combined[i]();
182                 if (status < 0) {
183                         printf("\nCombined table test number %d failed with "
184                                 "reason number %d.\n", i, status);
185                         failures++;
186                         return -1;
187                 }
188         }
189
190         if (failures)
191                 return -1;
192
193 #ifdef RTE_LIBRTE_ACL
194         printf("\n\n\n\n************ACL tests************\n");
195         if (test_table_ACL() < 0)
196                 return -1;
197 #endif
198
199         return 0;
200 }
201
202 static struct test_command table_cmd = {
203         .command = "table_autotest",
204         .callback = test_table,
205 };
206 REGISTER_TEST_COMMAND(table_cmd);