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_LIB_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); 198