ceph/src/seastar/dpdk/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                 __attribute__((unused)) void *key_mask,
  47                 __attribute__((unused)) uint32_t key_size,
  48                 __attribute__((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                 __attribute__((unused)) uint32_t key_size,
  59                 __attribute__((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);