14418919fSjohnjiang /* SPDX-License-Identifier: BSD-3-Clause
24418919fSjohnjiang * Copyright(c) 2017 Intel Corporation
34418919fSjohnjiang */
44418919fSjohnjiang
54418919fSjohnjiang /* This test is for membership library's simple feature test */
64418919fSjohnjiang
74418919fSjohnjiang #include <rte_memcpy.h>
84418919fSjohnjiang #include <rte_malloc.h>
94418919fSjohnjiang #include <rte_member.h>
104418919fSjohnjiang #include <rte_byteorder.h>
114418919fSjohnjiang #include <rte_random.h>
124418919fSjohnjiang #include <rte_debug.h>
134418919fSjohnjiang #include <rte_ip.h>
144418919fSjohnjiang
154418919fSjohnjiang #include "test.h"
164418919fSjohnjiang
174418919fSjohnjiang struct rte_member_setsum *setsum_ht;
184418919fSjohnjiang struct rte_member_setsum *setsum_cache;
194418919fSjohnjiang struct rte_member_setsum *setsum_vbf;
204418919fSjohnjiang
214418919fSjohnjiang /* 5-tuple key type */
224418919fSjohnjiang struct flow_key {
234418919fSjohnjiang uint32_t ip_src;
244418919fSjohnjiang uint32_t ip_dst;
254418919fSjohnjiang uint16_t port_src;
264418919fSjohnjiang uint16_t port_dst;
274418919fSjohnjiang uint8_t proto;
28*2d9fd380Sjfb8856606 } __rte_packed;
294418919fSjohnjiang
304418919fSjohnjiang /* Set ID Macros for multimatch test usage */
314418919fSjohnjiang #define M_MATCH_S 1 /* Not start with 0 since by default 0 means no match */
324418919fSjohnjiang #define M_MATCH_E 15
334418919fSjohnjiang #define M_MATCH_STEP 2
344418919fSjohnjiang #define M_MATCH_CNT \
354418919fSjohnjiang (1 + (M_MATCH_E - M_MATCH_S) / M_MATCH_STEP)
364418919fSjohnjiang
374418919fSjohnjiang
384418919fSjohnjiang #define NUM_SAMPLES 5
394418919fSjohnjiang #define MAX_MATCH 32
404418919fSjohnjiang
414418919fSjohnjiang /* Keys used by unit test functions */
424418919fSjohnjiang static struct flow_key keys[NUM_SAMPLES] = {
434418919fSjohnjiang {
444418919fSjohnjiang .ip_src = RTE_IPV4(0x03, 0x02, 0x01, 0x00),
454418919fSjohnjiang .ip_dst = RTE_IPV4(0x07, 0x06, 0x05, 0x04),
464418919fSjohnjiang .port_src = 0x0908,
474418919fSjohnjiang .port_dst = 0x0b0a,
484418919fSjohnjiang .proto = 0x0c,
494418919fSjohnjiang },
504418919fSjohnjiang {
514418919fSjohnjiang .ip_src = RTE_IPV4(0x13, 0x12, 0x11, 0x10),
524418919fSjohnjiang .ip_dst = RTE_IPV4(0x17, 0x16, 0x15, 0x14),
534418919fSjohnjiang .port_src = 0x1918,
544418919fSjohnjiang .port_dst = 0x1b1a,
554418919fSjohnjiang .proto = 0x1c,
564418919fSjohnjiang },
574418919fSjohnjiang {
584418919fSjohnjiang .ip_src = RTE_IPV4(0x23, 0x22, 0x21, 0x20),
594418919fSjohnjiang .ip_dst = RTE_IPV4(0x27, 0x26, 0x25, 0x24),
604418919fSjohnjiang .port_src = 0x2928,
614418919fSjohnjiang .port_dst = 0x2b2a,
624418919fSjohnjiang .proto = 0x2c,
634418919fSjohnjiang },
644418919fSjohnjiang {
654418919fSjohnjiang .ip_src = RTE_IPV4(0x33, 0x32, 0x31, 0x30),
664418919fSjohnjiang .ip_dst = RTE_IPV4(0x37, 0x36, 0x35, 0x34),
674418919fSjohnjiang .port_src = 0x3938,
684418919fSjohnjiang .port_dst = 0x3b3a,
694418919fSjohnjiang .proto = 0x3c,
704418919fSjohnjiang },
714418919fSjohnjiang {
724418919fSjohnjiang .ip_src = RTE_IPV4(0x43, 0x42, 0x41, 0x40),
734418919fSjohnjiang .ip_dst = RTE_IPV4(0x47, 0x46, 0x45, 0x44),
744418919fSjohnjiang .port_src = 0x4948,
754418919fSjohnjiang .port_dst = 0x4b4a,
764418919fSjohnjiang .proto = 0x4c,
774418919fSjohnjiang }
784418919fSjohnjiang };
794418919fSjohnjiang
804418919fSjohnjiang uint32_t test_set[NUM_SAMPLES] = {1, 2, 3, 4, 5};
814418919fSjohnjiang
824418919fSjohnjiang #define ITERATIONS 3
834418919fSjohnjiang #define KEY_SIZE 4
844418919fSjohnjiang
854418919fSjohnjiang #define MAX_ENTRIES (1 << 16)
864418919fSjohnjiang uint8_t generated_keys[MAX_ENTRIES][KEY_SIZE];
874418919fSjohnjiang
884418919fSjohnjiang static struct rte_member_parameters params = {
894418919fSjohnjiang .num_keys = MAX_ENTRIES, /* Total hash table entries. */
904418919fSjohnjiang .key_len = KEY_SIZE, /* Length of hash key. */
914418919fSjohnjiang
924418919fSjohnjiang /* num_set and false_positive_rate only relevant to vBF */
934418919fSjohnjiang .num_set = 16,
944418919fSjohnjiang .false_positive_rate = 0.03,
954418919fSjohnjiang .prim_hash_seed = 1,
964418919fSjohnjiang .sec_hash_seed = 11,
974418919fSjohnjiang .socket_id = 0 /* NUMA Socket ID for memory. */
984418919fSjohnjiang };
994418919fSjohnjiang
1004418919fSjohnjiang /*
1014418919fSjohnjiang * Sequence of operations for find existing setsummary
1024418919fSjohnjiang *
1034418919fSjohnjiang * - create setsum
1044418919fSjohnjiang * - find existing setsum: hit
1054418919fSjohnjiang * - find non-existing setsum: miss
1064418919fSjohnjiang *
1074418919fSjohnjiang */
1084418919fSjohnjiang static int
test_member_find_existing(void)1094418919fSjohnjiang test_member_find_existing(void)
1104418919fSjohnjiang {
1114418919fSjohnjiang struct rte_member_setsum *tmp_setsum = NULL, *result = NULL;
1124418919fSjohnjiang struct rte_member_parameters tmp_params = {
1134418919fSjohnjiang .name = "member_find_existing",
1144418919fSjohnjiang .num_keys = MAX_ENTRIES, /* Total hash table entries. */
1154418919fSjohnjiang .key_len = KEY_SIZE, /* Length of hash key. */
1164418919fSjohnjiang .type = RTE_MEMBER_TYPE_HT,
1174418919fSjohnjiang .num_set = 32,
1184418919fSjohnjiang .false_positive_rate = 0.03,
1194418919fSjohnjiang .prim_hash_seed = 1,
1204418919fSjohnjiang .sec_hash_seed = 11,
1214418919fSjohnjiang .socket_id = 0 /* NUMA Socket ID for memory. */
1224418919fSjohnjiang };
1234418919fSjohnjiang
1244418919fSjohnjiang /* Create */
1254418919fSjohnjiang tmp_setsum = rte_member_create(&tmp_params);
1264418919fSjohnjiang TEST_ASSERT(tmp_setsum != NULL, "setsum creation failed");
1274418919fSjohnjiang
1284418919fSjohnjiang /* Try to find existing hash table */
1294418919fSjohnjiang result = rte_member_find_existing("member_find_existing");
1304418919fSjohnjiang TEST_ASSERT(result == tmp_setsum, "could not find existing setsum");
1314418919fSjohnjiang
1324418919fSjohnjiang /* Try to find non-existing hash table */
1334418919fSjohnjiang result = rte_member_find_existing("member_find_non_existing");
1344418919fSjohnjiang TEST_ASSERT(result == NULL, "found setsum that shouldn't exist");
1354418919fSjohnjiang
1364418919fSjohnjiang /* Cleanup. */
1374418919fSjohnjiang rte_member_free(tmp_setsum);
1384418919fSjohnjiang
1394418919fSjohnjiang return 0;
1404418919fSjohnjiang }
1414418919fSjohnjiang
1424418919fSjohnjiang /*
1434418919fSjohnjiang * Test for bad creating parameters
1444418919fSjohnjiang */
1454418919fSjohnjiang static int
test_member_create_bad_param(void)1464418919fSjohnjiang test_member_create_bad_param(void)
1474418919fSjohnjiang {
1484418919fSjohnjiang struct rte_member_setsum *bad_setsum = NULL;
1494418919fSjohnjiang struct rte_member_parameters bad_params = {
1504418919fSjohnjiang .num_keys = MAX_ENTRIES, /* Total hash table entries. */
1514418919fSjohnjiang .key_len = KEY_SIZE, /* Length of hash key. */
1524418919fSjohnjiang .type = RTE_MEMBER_TYPE_HT,
1534418919fSjohnjiang .num_set = 32,
1544418919fSjohnjiang .false_positive_rate = 0.03,
1554418919fSjohnjiang .prim_hash_seed = 1,
1564418919fSjohnjiang .sec_hash_seed = 11,
1574418919fSjohnjiang .socket_id = 0 /* NUMA Socket ID for memory. */
1584418919fSjohnjiang };
1594418919fSjohnjiang
1604418919fSjohnjiang printf("Expected error section begin...\n");
1614418919fSjohnjiang bad_params.name = "bad_param1";
1624418919fSjohnjiang bad_params.num_set = 0;
1634418919fSjohnjiang bad_params.type = RTE_MEMBER_TYPE_VBF;
1644418919fSjohnjiang /* Test with 0 set for vBF should fail */
1654418919fSjohnjiang bad_setsum = rte_member_create(&bad_params);
1664418919fSjohnjiang if (bad_setsum != NULL) {
1674418919fSjohnjiang rte_member_free(bad_setsum);
1684418919fSjohnjiang printf("Impossible creating setsum successfully with invalid "
1694418919fSjohnjiang "number of set for vBF\n");
1704418919fSjohnjiang return -1;
1714418919fSjohnjiang }
1724418919fSjohnjiang
1734418919fSjohnjiang bad_params.name = "bad_param2";
1744418919fSjohnjiang bad_params.false_positive_rate = 0;
1754418919fSjohnjiang bad_params.num_set = 32;
1764418919fSjohnjiang /* Test with 0 false positive for vBF should fail */
1774418919fSjohnjiang bad_setsum = rte_member_create(&bad_params);
1784418919fSjohnjiang if (bad_setsum != NULL) {
1794418919fSjohnjiang rte_member_free(bad_setsum);
1804418919fSjohnjiang printf("Impossible creating setsum successfully with invalid "
1814418919fSjohnjiang "false positive rate for vBF\n");
1824418919fSjohnjiang return -1;
1834418919fSjohnjiang }
1844418919fSjohnjiang
1854418919fSjohnjiang bad_params.name = "bad_param3";
1864418919fSjohnjiang bad_params.false_positive_rate = 0.03;
1874418919fSjohnjiang bad_params.num_keys = 0;
1884418919fSjohnjiang /* Test with 0 key per BF for vBF should fail */
1894418919fSjohnjiang bad_setsum = rte_member_create(&bad_params);
1904418919fSjohnjiang if (bad_setsum != NULL) {
1914418919fSjohnjiang rte_member_free(bad_setsum);
1924418919fSjohnjiang printf("Impossible creating setsum successfully with invalid "
1934418919fSjohnjiang "num_keys for vBF\n");
1944418919fSjohnjiang return -1;
1954418919fSjohnjiang }
1964418919fSjohnjiang
1974418919fSjohnjiang bad_params.name = "bad_param4";
1984418919fSjohnjiang bad_params.type = RTE_MEMBER_TYPE_HT;
1994418919fSjohnjiang bad_params.num_keys = RTE_MEMBER_BUCKET_ENTRIES / 2;
2004418919fSjohnjiang /* Test with less than 1 bucket for HTSS should fail */
2014418919fSjohnjiang bad_setsum = rte_member_create(&bad_params);
2024418919fSjohnjiang if (bad_setsum != NULL) {
2034418919fSjohnjiang rte_member_free(bad_setsum);
2044418919fSjohnjiang printf("Impossible creating setsum successfully with too few "
2054418919fSjohnjiang "number of keys(entries) for HT\n");
2064418919fSjohnjiang return -1;
2074418919fSjohnjiang }
2084418919fSjohnjiang
2094418919fSjohnjiang bad_params.name = "bad_param5";
2104418919fSjohnjiang bad_params.num_keys = RTE_MEMBER_ENTRIES_MAX + 1;
2114418919fSjohnjiang /* Test with more than maximum entries for HTSS should fail */
2124418919fSjohnjiang bad_setsum = rte_member_create(&bad_params);
2134418919fSjohnjiang if (bad_setsum != NULL) {
2144418919fSjohnjiang rte_member_free(bad_setsum);
2154418919fSjohnjiang printf("Impossible creating setsum successfully with to many "
2164418919fSjohnjiang "number of keys(entries) for HT\n");
2174418919fSjohnjiang return -1;
2184418919fSjohnjiang }
2194418919fSjohnjiang
2204418919fSjohnjiang bad_params.name = "bad_param5";
2214418919fSjohnjiang /* Test with same name should fail */
2224418919fSjohnjiang bad_setsum = rte_member_create(&bad_params);
2234418919fSjohnjiang if (bad_setsum != NULL) {
2244418919fSjohnjiang rte_member_free(bad_setsum);
2254418919fSjohnjiang printf("Impossible creating setsum successfully with existed "
2264418919fSjohnjiang "name\n");
2274418919fSjohnjiang return -1;
2284418919fSjohnjiang }
2294418919fSjohnjiang printf("Expected error section end...\n");
2304418919fSjohnjiang rte_member_free(bad_setsum);
2314418919fSjohnjiang return 0;
2324418919fSjohnjiang }
2334418919fSjohnjiang
2344418919fSjohnjiang /* Create test setsummaries. */
test_member_create(void)2354418919fSjohnjiang static int test_member_create(void)
2364418919fSjohnjiang {
2374418919fSjohnjiang params.key_len = sizeof(struct flow_key);
2384418919fSjohnjiang
2394418919fSjohnjiang params.name = "test_member_ht";
2404418919fSjohnjiang params.is_cache = 0;
2414418919fSjohnjiang params.type = RTE_MEMBER_TYPE_HT;
2424418919fSjohnjiang setsum_ht = rte_member_create(¶ms);
2434418919fSjohnjiang
2444418919fSjohnjiang params.name = "test_member_cache";
2454418919fSjohnjiang params.is_cache = 1;
2464418919fSjohnjiang setsum_cache = rte_member_create(¶ms);
2474418919fSjohnjiang
2484418919fSjohnjiang params.name = "test_member_vbf";
2494418919fSjohnjiang params.type = RTE_MEMBER_TYPE_VBF;
2504418919fSjohnjiang setsum_vbf = rte_member_create(¶ms);
2514418919fSjohnjiang
2524418919fSjohnjiang if (setsum_ht == NULL || setsum_cache == NULL || setsum_vbf == NULL) {
2534418919fSjohnjiang printf("Creation of setsums fail\n");
2544418919fSjohnjiang return -1;
2554418919fSjohnjiang }
2564418919fSjohnjiang printf("Creation of setsums success\n");
2574418919fSjohnjiang return 0;
2584418919fSjohnjiang }
2594418919fSjohnjiang
test_member_insert(void)2604418919fSjohnjiang static int test_member_insert(void)
2614418919fSjohnjiang {
2624418919fSjohnjiang int ret_ht, ret_cache, ret_vbf, i;
2634418919fSjohnjiang
2644418919fSjohnjiang for (i = 0; i < NUM_SAMPLES; i++) {
2654418919fSjohnjiang ret_ht = rte_member_add(setsum_ht, &keys[i], test_set[i]);
2664418919fSjohnjiang ret_cache = rte_member_add(setsum_cache, &keys[i],
2674418919fSjohnjiang test_set[i]);
2684418919fSjohnjiang ret_vbf = rte_member_add(setsum_vbf, &keys[i], test_set[i]);
2694418919fSjohnjiang TEST_ASSERT(ret_ht >= 0 && ret_cache >= 0 && ret_vbf >= 0,
2704418919fSjohnjiang "insert error");
2714418919fSjohnjiang }
2724418919fSjohnjiang printf("insert key success\n");
2734418919fSjohnjiang return 0;
2744418919fSjohnjiang }
2754418919fSjohnjiang
test_member_lookup(void)2764418919fSjohnjiang static int test_member_lookup(void)
2774418919fSjohnjiang {
2784418919fSjohnjiang int ret_ht, ret_cache, ret_vbf, i;
2794418919fSjohnjiang uint16_t set_ht, set_cache, set_vbf;
2804418919fSjohnjiang member_set_t set_ids_ht[NUM_SAMPLES] = {0};
2814418919fSjohnjiang member_set_t set_ids_cache[NUM_SAMPLES] = {0};
2824418919fSjohnjiang member_set_t set_ids_vbf[NUM_SAMPLES] = {0};
2834418919fSjohnjiang
2844418919fSjohnjiang uint32_t num_key_ht = NUM_SAMPLES;
2854418919fSjohnjiang uint32_t num_key_cache = NUM_SAMPLES;
2864418919fSjohnjiang uint32_t num_key_vbf = NUM_SAMPLES;
2874418919fSjohnjiang
2884418919fSjohnjiang const void *key_array[NUM_SAMPLES];
2894418919fSjohnjiang
2904418919fSjohnjiang /* Single lookup test */
2914418919fSjohnjiang for (i = 0; i < NUM_SAMPLES; i++) {
2924418919fSjohnjiang ret_ht = rte_member_lookup(setsum_ht, &keys[i], &set_ht);
2934418919fSjohnjiang ret_cache = rte_member_lookup(setsum_cache, &keys[i],
2944418919fSjohnjiang &set_cache);
2954418919fSjohnjiang ret_vbf = rte_member_lookup(setsum_vbf, &keys[i], &set_vbf);
2964418919fSjohnjiang TEST_ASSERT(ret_ht >= 0 && ret_cache >= 0 && ret_vbf >= 0,
2974418919fSjohnjiang "single lookup function error");
2984418919fSjohnjiang
2994418919fSjohnjiang TEST_ASSERT(set_ht == test_set[i] &&
3004418919fSjohnjiang set_cache == test_set[i] &&
3014418919fSjohnjiang set_vbf == test_set[i],
3024418919fSjohnjiang "single lookup set value error");
3034418919fSjohnjiang }
3044418919fSjohnjiang printf("lookup single key success\n");
3054418919fSjohnjiang
3064418919fSjohnjiang /* Bulk lookup test */
3074418919fSjohnjiang for (i = 0; i < NUM_SAMPLES; i++)
3084418919fSjohnjiang key_array[i] = &keys[i];
3094418919fSjohnjiang
3104418919fSjohnjiang ret_ht = rte_member_lookup_bulk(setsum_ht, key_array,
3114418919fSjohnjiang num_key_ht, set_ids_ht);
3124418919fSjohnjiang
3134418919fSjohnjiang ret_cache = rte_member_lookup_bulk(setsum_cache, key_array,
3144418919fSjohnjiang num_key_cache, set_ids_cache);
3154418919fSjohnjiang
3164418919fSjohnjiang ret_vbf = rte_member_lookup_bulk(setsum_vbf, key_array,
3174418919fSjohnjiang num_key_vbf, set_ids_vbf);
3184418919fSjohnjiang
3194418919fSjohnjiang TEST_ASSERT(ret_ht >= 0 && ret_cache >= 0 && ret_vbf >= 0,
3204418919fSjohnjiang "bulk lookup function error");
3214418919fSjohnjiang
3224418919fSjohnjiang for (i = 0; i < NUM_SAMPLES; i++) {
3234418919fSjohnjiang TEST_ASSERT((set_ids_ht[i] == test_set[i]) &&
3244418919fSjohnjiang (set_ids_cache[i] == test_set[i]) &&
3254418919fSjohnjiang (set_ids_vbf[i] == test_set[i]),
3264418919fSjohnjiang "bulk lookup result error");
3274418919fSjohnjiang }
3284418919fSjohnjiang
3294418919fSjohnjiang return 0;
3304418919fSjohnjiang }
3314418919fSjohnjiang
test_member_delete(void)3324418919fSjohnjiang static int test_member_delete(void)
3334418919fSjohnjiang {
3344418919fSjohnjiang int ret_ht, ret_cache, ret_vbf, i;
3354418919fSjohnjiang uint16_t set_ht, set_cache, set_vbf;
3364418919fSjohnjiang const void *key_array[NUM_SAMPLES];
3374418919fSjohnjiang member_set_t set_ids_ht[NUM_SAMPLES] = {0};
3384418919fSjohnjiang member_set_t set_ids_cache[NUM_SAMPLES] = {0};
3394418919fSjohnjiang member_set_t set_ids_vbf[NUM_SAMPLES] = {0};
3404418919fSjohnjiang uint32_t num_key_ht = NUM_SAMPLES;
3414418919fSjohnjiang uint32_t num_key_cache = NUM_SAMPLES;
3424418919fSjohnjiang uint32_t num_key_vbf = NUM_SAMPLES;
3434418919fSjohnjiang
3444418919fSjohnjiang /* Delete part of all inserted keys */
3454418919fSjohnjiang for (i = 0; i < NUM_SAMPLES / 2; i++) {
3464418919fSjohnjiang ret_ht = rte_member_delete(setsum_ht, &keys[i], test_set[i]);
3474418919fSjohnjiang ret_cache = rte_member_delete(setsum_cache, &keys[i],
3484418919fSjohnjiang test_set[i]);
3494418919fSjohnjiang ret_vbf = rte_member_delete(setsum_vbf, &keys[i], test_set[i]);
3504418919fSjohnjiang /* VBF does not support delete yet, so return error code */
3514418919fSjohnjiang TEST_ASSERT(ret_ht >= 0 && ret_cache >= 0,
3524418919fSjohnjiang "key deletion function error");
3534418919fSjohnjiang TEST_ASSERT(ret_vbf < 0,
3544418919fSjohnjiang "vbf does not support deletion, error");
3554418919fSjohnjiang }
3564418919fSjohnjiang
3574418919fSjohnjiang for (i = 0; i < NUM_SAMPLES; i++)
3584418919fSjohnjiang key_array[i] = &keys[i];
3594418919fSjohnjiang
3604418919fSjohnjiang ret_ht = rte_member_lookup_bulk(setsum_ht, key_array,
3614418919fSjohnjiang num_key_ht, set_ids_ht);
3624418919fSjohnjiang
3634418919fSjohnjiang ret_cache = rte_member_lookup_bulk(setsum_cache, key_array,
3644418919fSjohnjiang num_key_cache, set_ids_cache);
3654418919fSjohnjiang
3664418919fSjohnjiang ret_vbf = rte_member_lookup_bulk(setsum_vbf, key_array,
3674418919fSjohnjiang num_key_vbf, set_ids_vbf);
3684418919fSjohnjiang
3694418919fSjohnjiang TEST_ASSERT(ret_ht >= 0 && ret_cache >= 0 && ret_vbf >= 0,
3704418919fSjohnjiang "bulk lookup function error");
3714418919fSjohnjiang
3724418919fSjohnjiang for (i = 0; i < NUM_SAMPLES / 2; i++) {
3734418919fSjohnjiang TEST_ASSERT((set_ids_ht[i] == RTE_MEMBER_NO_MATCH) &&
3744418919fSjohnjiang (set_ids_cache[i] == RTE_MEMBER_NO_MATCH),
3754418919fSjohnjiang "bulk lookup result error");
3764418919fSjohnjiang }
3774418919fSjohnjiang
3784418919fSjohnjiang for (i = NUM_SAMPLES / 2; i < NUM_SAMPLES; i++) {
3794418919fSjohnjiang TEST_ASSERT((set_ids_ht[i] == test_set[i]) &&
3804418919fSjohnjiang (set_ids_cache[i] == test_set[i]) &&
3814418919fSjohnjiang (set_ids_vbf[i] == test_set[i]),
3824418919fSjohnjiang "bulk lookup result error");
3834418919fSjohnjiang }
3844418919fSjohnjiang
3854418919fSjohnjiang /* Delete the left of inserted keys */
3864418919fSjohnjiang for (i = NUM_SAMPLES / 2; i < NUM_SAMPLES; i++) {
3874418919fSjohnjiang ret_ht = rte_member_delete(setsum_ht, &keys[i], test_set[i]);
3884418919fSjohnjiang ret_cache = rte_member_delete(setsum_cache, &keys[i],
3894418919fSjohnjiang test_set[i]);
3904418919fSjohnjiang ret_vbf = rte_member_delete(setsum_vbf, &keys[i], test_set[i]);
3914418919fSjohnjiang /* VBF does not support delete yet, so return error code */
3924418919fSjohnjiang TEST_ASSERT(ret_ht >= 0 && ret_cache >= 0,
3934418919fSjohnjiang "key deletion function error");
3944418919fSjohnjiang TEST_ASSERT(ret_vbf < 0,
3954418919fSjohnjiang "vbf does not support deletion, error");
3964418919fSjohnjiang }
3974418919fSjohnjiang
3984418919fSjohnjiang for (i = 0; i < NUM_SAMPLES; i++) {
3994418919fSjohnjiang ret_ht = rte_member_lookup(setsum_ht, &keys[i], &set_ht);
4004418919fSjohnjiang ret_cache = rte_member_lookup(setsum_cache, &keys[i],
4014418919fSjohnjiang &set_cache);
4024418919fSjohnjiang ret_vbf = rte_member_lookup(setsum_vbf, &keys[i], &set_vbf);
4034418919fSjohnjiang TEST_ASSERT(ret_ht >= 0 && ret_cache >= 0,
4044418919fSjohnjiang "key lookup function error");
4054418919fSjohnjiang TEST_ASSERT(set_ht == RTE_MEMBER_NO_MATCH &&
4064418919fSjohnjiang ret_cache == RTE_MEMBER_NO_MATCH,
4074418919fSjohnjiang "key deletion failed");
4084418919fSjohnjiang }
4094418919fSjohnjiang /* Reset vbf for other following tests */
4104418919fSjohnjiang rte_member_reset(setsum_vbf);
4114418919fSjohnjiang
4124418919fSjohnjiang printf("delete success\n");
4134418919fSjohnjiang return 0;
4144418919fSjohnjiang }
4154418919fSjohnjiang
test_member_multimatch(void)4164418919fSjohnjiang static int test_member_multimatch(void)
4174418919fSjohnjiang {
4184418919fSjohnjiang int ret_ht, ret_vbf, ret_cache;
4194418919fSjohnjiang member_set_t set_ids_ht[MAX_MATCH] = {0};
4204418919fSjohnjiang member_set_t set_ids_vbf[MAX_MATCH] = {0};
4214418919fSjohnjiang member_set_t set_ids_cache[MAX_MATCH] = {0};
4224418919fSjohnjiang
4234418919fSjohnjiang member_set_t set_ids_ht_m[NUM_SAMPLES][MAX_MATCH] = {{0} };
4244418919fSjohnjiang member_set_t set_ids_vbf_m[NUM_SAMPLES][MAX_MATCH] = {{0} };
4254418919fSjohnjiang member_set_t set_ids_cache_m[NUM_SAMPLES][MAX_MATCH] = {{0} };
4264418919fSjohnjiang
4274418919fSjohnjiang uint32_t match_count_ht[NUM_SAMPLES];
4284418919fSjohnjiang uint32_t match_count_vbf[NUM_SAMPLES];
4294418919fSjohnjiang uint32_t match_count_cache[NUM_SAMPLES];
4304418919fSjohnjiang
4314418919fSjohnjiang uint32_t num_key_ht = NUM_SAMPLES;
4324418919fSjohnjiang uint32_t num_key_vbf = NUM_SAMPLES;
4334418919fSjohnjiang uint32_t num_key_cache = NUM_SAMPLES;
4344418919fSjohnjiang
4354418919fSjohnjiang const void *key_array[NUM_SAMPLES];
4364418919fSjohnjiang
4374418919fSjohnjiang uint32_t i, j;
4384418919fSjohnjiang
4394418919fSjohnjiang /* Same key at most inserted 2*entry_per_bucket times for HT mode */
4404418919fSjohnjiang for (i = M_MATCH_S; i <= M_MATCH_E; i += M_MATCH_STEP) {
4414418919fSjohnjiang for (j = 0; j < NUM_SAMPLES; j++) {
4424418919fSjohnjiang ret_ht = rte_member_add(setsum_ht, &keys[j], i);
4434418919fSjohnjiang ret_vbf = rte_member_add(setsum_vbf, &keys[j], i);
4444418919fSjohnjiang ret_cache = rte_member_add(setsum_cache, &keys[j], i);
4454418919fSjohnjiang
4464418919fSjohnjiang TEST_ASSERT(ret_ht >= 0 && ret_vbf >= 0 &&
4474418919fSjohnjiang ret_cache >= 0,
4484418919fSjohnjiang "insert function error");
4494418919fSjohnjiang }
4504418919fSjohnjiang }
4514418919fSjohnjiang
4524418919fSjohnjiang /* Single multimatch test */
4534418919fSjohnjiang for (i = 0; i < NUM_SAMPLES; i++) {
4544418919fSjohnjiang ret_vbf = rte_member_lookup_multi(setsum_vbf, &keys[i],
4554418919fSjohnjiang MAX_MATCH, set_ids_vbf);
4564418919fSjohnjiang ret_ht = rte_member_lookup_multi(setsum_ht, &keys[i],
4574418919fSjohnjiang MAX_MATCH, set_ids_ht);
4584418919fSjohnjiang ret_cache = rte_member_lookup_multi(setsum_cache, &keys[i],
4594418919fSjohnjiang MAX_MATCH, set_ids_cache);
4604418919fSjohnjiang /*
4614418919fSjohnjiang * For cache mode, keys overwrite when signature same.
4624418919fSjohnjiang * the mutimatch should work like single match.
4634418919fSjohnjiang */
4644418919fSjohnjiang TEST_ASSERT(ret_ht == M_MATCH_CNT && ret_vbf == M_MATCH_CNT &&
4654418919fSjohnjiang ret_cache == 1,
4664418919fSjohnjiang "single lookup_multi error");
4674418919fSjohnjiang TEST_ASSERT(set_ids_cache[0] == M_MATCH_E,
4684418919fSjohnjiang "single lookup_multi cache error");
4694418919fSjohnjiang
4704418919fSjohnjiang for (j = 1; j <= M_MATCH_CNT; j++) {
4714418919fSjohnjiang TEST_ASSERT(set_ids_ht[j-1] == j * M_MATCH_STEP - 1 &&
4724418919fSjohnjiang set_ids_vbf[j-1] ==
4734418919fSjohnjiang j * M_MATCH_STEP - 1,
4744418919fSjohnjiang "single multimatch lookup error");
4754418919fSjohnjiang }
4764418919fSjohnjiang }
4774418919fSjohnjiang printf("lookup single key for multimatch success\n");
4784418919fSjohnjiang
4794418919fSjohnjiang /* Bulk multimatch test */
4804418919fSjohnjiang for (i = 0; i < NUM_SAMPLES; i++)
4814418919fSjohnjiang key_array[i] = &keys[i];
4824418919fSjohnjiang ret_vbf = rte_member_lookup_multi_bulk(setsum_vbf,
4834418919fSjohnjiang &key_array[0], num_key_ht, MAX_MATCH, match_count_vbf,
4844418919fSjohnjiang (member_set_t *)set_ids_vbf_m);
4854418919fSjohnjiang
4864418919fSjohnjiang ret_ht = rte_member_lookup_multi_bulk(setsum_ht,
4874418919fSjohnjiang &key_array[0], num_key_vbf, MAX_MATCH, match_count_ht,
4884418919fSjohnjiang (member_set_t *)set_ids_ht_m);
4894418919fSjohnjiang
4904418919fSjohnjiang ret_cache = rte_member_lookup_multi_bulk(setsum_cache,
4914418919fSjohnjiang &key_array[0], num_key_cache, MAX_MATCH,
4924418919fSjohnjiang match_count_cache, (member_set_t *)set_ids_cache_m);
4934418919fSjohnjiang
4944418919fSjohnjiang
4954418919fSjohnjiang for (j = 0; j < NUM_SAMPLES; j++) {
4964418919fSjohnjiang TEST_ASSERT(match_count_ht[j] == M_MATCH_CNT,
4974418919fSjohnjiang "bulk multimatch lookup HT match count error");
4984418919fSjohnjiang TEST_ASSERT(match_count_vbf[j] == M_MATCH_CNT,
4994418919fSjohnjiang "bulk multimatch lookup vBF match count error");
5004418919fSjohnjiang TEST_ASSERT(match_count_cache[j] == 1,
5014418919fSjohnjiang "bulk multimatch lookup CACHE match count error");
5024418919fSjohnjiang TEST_ASSERT(set_ids_cache_m[j][0] == M_MATCH_E,
5034418919fSjohnjiang "bulk multimatch lookup CACHE set value error");
5044418919fSjohnjiang
5054418919fSjohnjiang for (i = 1; i <= M_MATCH_CNT; i++) {
5064418919fSjohnjiang TEST_ASSERT(set_ids_ht_m[j][i-1] ==
5074418919fSjohnjiang i * M_MATCH_STEP - 1,
5084418919fSjohnjiang "bulk multimatch lookup HT set value error");
5094418919fSjohnjiang TEST_ASSERT(set_ids_vbf_m[j][i-1] ==
5104418919fSjohnjiang i * M_MATCH_STEP - 1,
5114418919fSjohnjiang "bulk multimatch lookup vBF set value error");
5124418919fSjohnjiang }
5134418919fSjohnjiang }
5144418919fSjohnjiang
5154418919fSjohnjiang printf("lookup for bulk multimatch success\n");
5164418919fSjohnjiang
5174418919fSjohnjiang return 0;
5184418919fSjohnjiang }
5194418919fSjohnjiang
key_compare(const void * key1,const void * key2)5204418919fSjohnjiang static int key_compare(const void *key1, const void *key2)
5214418919fSjohnjiang {
5224418919fSjohnjiang return memcmp(key1, key2, KEY_SIZE);
5234418919fSjohnjiang }
5244418919fSjohnjiang
5254418919fSjohnjiang static void
setup_keys_and_data(void)5264418919fSjohnjiang setup_keys_and_data(void)
5274418919fSjohnjiang {
5284418919fSjohnjiang unsigned int i, j;
5294418919fSjohnjiang int num_duplicates;
5304418919fSjohnjiang
5314418919fSjohnjiang /* Reset all arrays */
5324418919fSjohnjiang for (i = 0; i < KEY_SIZE; i++)
5334418919fSjohnjiang generated_keys[0][i] = 0;
5344418919fSjohnjiang
5354418919fSjohnjiang /* Generate a list of keys, some of which may be duplicates */
5364418919fSjohnjiang for (i = 0; i < MAX_ENTRIES; i++) {
5374418919fSjohnjiang for (j = 0; j < KEY_SIZE; j++)
5384418919fSjohnjiang generated_keys[i][j] = rte_rand() & 0xFF;
5394418919fSjohnjiang }
5404418919fSjohnjiang
5414418919fSjohnjiang /* Remove duplicates from the keys array */
5424418919fSjohnjiang do {
5434418919fSjohnjiang num_duplicates = 0;
5444418919fSjohnjiang /* Sort the list of keys to make it easier to find duplicates */
5454418919fSjohnjiang qsort(generated_keys, MAX_ENTRIES, KEY_SIZE, key_compare);
5464418919fSjohnjiang
5474418919fSjohnjiang /* Sift through the list of keys and look for duplicates */
5484418919fSjohnjiang int num_duplicates = 0;
5494418919fSjohnjiang for (i = 0; i < MAX_ENTRIES - 1; i++) {
5504418919fSjohnjiang if (memcmp(generated_keys[i], generated_keys[i + 1],
5514418919fSjohnjiang KEY_SIZE) == 0) {
5524418919fSjohnjiang /* This key already exists, try again */
5534418919fSjohnjiang num_duplicates++;
5544418919fSjohnjiang for (j = 0; j < KEY_SIZE; j++)
5554418919fSjohnjiang generated_keys[i][j] =
5564418919fSjohnjiang rte_rand() & 0xFF;
5574418919fSjohnjiang }
5584418919fSjohnjiang }
5594418919fSjohnjiang } while (num_duplicates != 0);
5604418919fSjohnjiang }
5614418919fSjohnjiang
5624418919fSjohnjiang static inline int
add_generated_keys(struct rte_member_setsum * setsum,unsigned int * added_keys)5634418919fSjohnjiang add_generated_keys(struct rte_member_setsum *setsum, unsigned int *added_keys)
5644418919fSjohnjiang {
5654418919fSjohnjiang int ret = 0;
5664418919fSjohnjiang
5674418919fSjohnjiang for (*added_keys = 0; ret >= 0 && *added_keys < MAX_ENTRIES;
5684418919fSjohnjiang (*added_keys)++) {
5694418919fSjohnjiang uint16_t set = (rte_rand() & 0xf) + 1;
5704418919fSjohnjiang ret = rte_member_add(setsum, &generated_keys[*added_keys], set);
5714418919fSjohnjiang }
5724418919fSjohnjiang return ret;
5734418919fSjohnjiang }
5744418919fSjohnjiang
5754418919fSjohnjiang static inline int
add_generated_keys_cache(struct rte_member_setsum * setsum,unsigned int * added_keys)5764418919fSjohnjiang add_generated_keys_cache(struct rte_member_setsum *setsum,
5774418919fSjohnjiang unsigned int *added_keys)
5784418919fSjohnjiang {
5794418919fSjohnjiang int ret = 0;
5804418919fSjohnjiang
5814418919fSjohnjiang for (*added_keys = 0; ret == 0 && *added_keys < MAX_ENTRIES;
5824418919fSjohnjiang (*added_keys)++) {
5834418919fSjohnjiang uint16_t set = (rte_rand() & 0xf) + 1;
5844418919fSjohnjiang ret = rte_member_add(setsum, &generated_keys[*added_keys], set);
5854418919fSjohnjiang }
5864418919fSjohnjiang return ret;
5874418919fSjohnjiang }
5884418919fSjohnjiang
5894418919fSjohnjiang static int
test_member_loadfactor(void)5904418919fSjohnjiang test_member_loadfactor(void)
5914418919fSjohnjiang {
5924418919fSjohnjiang unsigned int j;
5934418919fSjohnjiang unsigned int added_keys, average_keys_added = 0;
5944418919fSjohnjiang int ret;
5954418919fSjohnjiang
5964418919fSjohnjiang setup_keys_and_data();
5974418919fSjohnjiang
5984418919fSjohnjiang rte_member_free(setsum_ht);
5994418919fSjohnjiang rte_member_free(setsum_cache);
6004418919fSjohnjiang rte_member_free(setsum_vbf);
6014418919fSjohnjiang
6024418919fSjohnjiang params.key_len = KEY_SIZE;
6034418919fSjohnjiang params.name = "test_member_ht";
6044418919fSjohnjiang params.is_cache = 0;
6054418919fSjohnjiang params.type = RTE_MEMBER_TYPE_HT;
6064418919fSjohnjiang setsum_ht = rte_member_create(¶ms);
6074418919fSjohnjiang
6084418919fSjohnjiang params.name = "test_member_cache";
6094418919fSjohnjiang params.is_cache = 1;
6104418919fSjohnjiang setsum_cache = rte_member_create(¶ms);
6114418919fSjohnjiang
6124418919fSjohnjiang
6134418919fSjohnjiang if (setsum_ht == NULL || setsum_cache == NULL) {
6144418919fSjohnjiang printf("Creation of setsums fail\n");
6154418919fSjohnjiang return -1;
6164418919fSjohnjiang }
6174418919fSjohnjiang /* Test HT non-cache mode */
6184418919fSjohnjiang for (j = 0; j < ITERATIONS; j++) {
6194418919fSjohnjiang /* Add random entries until key cannot be added */
6204418919fSjohnjiang ret = add_generated_keys(setsum_ht, &added_keys);
6214418919fSjohnjiang if (ret != -ENOSPC) {
6224418919fSjohnjiang printf("Unexpected error when adding keys\n");
6234418919fSjohnjiang return -1;
6244418919fSjohnjiang }
6254418919fSjohnjiang average_keys_added += added_keys;
6264418919fSjohnjiang
6274418919fSjohnjiang /* Reset the table */
6284418919fSjohnjiang rte_member_reset(setsum_ht);
6294418919fSjohnjiang
6304418919fSjohnjiang /* Print a dot to show progress on operations */
6314418919fSjohnjiang printf(".");
6324418919fSjohnjiang fflush(stdout);
6334418919fSjohnjiang }
6344418919fSjohnjiang
6354418919fSjohnjiang average_keys_added /= ITERATIONS;
6364418919fSjohnjiang
6374418919fSjohnjiang printf("\nKeys inserted when no space(non-cache) = %.2f%% (%u/%u)\n",
6384418919fSjohnjiang ((double) average_keys_added / params.num_keys * 100),
6394418919fSjohnjiang average_keys_added, params.num_keys);
6404418919fSjohnjiang
6414418919fSjohnjiang /* Test cache mode */
6424418919fSjohnjiang added_keys = average_keys_added = 0;
6434418919fSjohnjiang for (j = 0; j < ITERATIONS; j++) {
6444418919fSjohnjiang /* Add random entries until key cannot be added */
6454418919fSjohnjiang ret = add_generated_keys_cache(setsum_cache, &added_keys);
6464418919fSjohnjiang if (ret != 1) {
6474418919fSjohnjiang printf("Unexpected error when adding keys\n");
6484418919fSjohnjiang return -1;
6494418919fSjohnjiang }
6504418919fSjohnjiang average_keys_added += added_keys;
6514418919fSjohnjiang
6524418919fSjohnjiang /* Reset the table */
6534418919fSjohnjiang rte_member_reset(setsum_cache);
6544418919fSjohnjiang
6554418919fSjohnjiang /* Print a dot to show progress on operations */
6564418919fSjohnjiang printf(".");
6574418919fSjohnjiang fflush(stdout);
6584418919fSjohnjiang }
6594418919fSjohnjiang
6604418919fSjohnjiang average_keys_added /= ITERATIONS;
6614418919fSjohnjiang
6624418919fSjohnjiang printf("\nKeys inserted when eviction happens(cache)= %.2f%% (%u/%u)\n",
6634418919fSjohnjiang ((double) average_keys_added / params.num_keys * 100),
6644418919fSjohnjiang average_keys_added, params.num_keys);
6654418919fSjohnjiang return 0;
6664418919fSjohnjiang }
6674418919fSjohnjiang
6684418919fSjohnjiang static void
perform_free(void)6694418919fSjohnjiang perform_free(void)
6704418919fSjohnjiang {
6714418919fSjohnjiang rte_member_free(setsum_ht);
6724418919fSjohnjiang rte_member_free(setsum_cache);
6734418919fSjohnjiang rte_member_free(setsum_vbf);
6744418919fSjohnjiang }
6754418919fSjohnjiang
6764418919fSjohnjiang static int
test_member(void)6774418919fSjohnjiang test_member(void)
6784418919fSjohnjiang {
6794418919fSjohnjiang if (test_member_create_bad_param() < 0)
6804418919fSjohnjiang return -1;
6814418919fSjohnjiang
6824418919fSjohnjiang if (test_member_find_existing() < 0)
6834418919fSjohnjiang return -1;
6844418919fSjohnjiang
6854418919fSjohnjiang if (test_member_create() < 0) {
6864418919fSjohnjiang perform_free();
6874418919fSjohnjiang return -1;
6884418919fSjohnjiang }
6894418919fSjohnjiang if (test_member_insert() < 0) {
6904418919fSjohnjiang perform_free();
6914418919fSjohnjiang return -1;
6924418919fSjohnjiang }
6934418919fSjohnjiang if (test_member_lookup() < 0) {
6944418919fSjohnjiang perform_free();
6954418919fSjohnjiang return -1;
6964418919fSjohnjiang }
6974418919fSjohnjiang if (test_member_delete() < 0) {
6984418919fSjohnjiang perform_free();
6994418919fSjohnjiang return -1;
7004418919fSjohnjiang }
7014418919fSjohnjiang if (test_member_multimatch() < 0) {
7024418919fSjohnjiang perform_free();
7034418919fSjohnjiang return -1;
7044418919fSjohnjiang }
7054418919fSjohnjiang if (test_member_loadfactor() < 0) {
7064418919fSjohnjiang rte_member_free(setsum_ht);
7074418919fSjohnjiang rte_member_free(setsum_cache);
7084418919fSjohnjiang return -1;
7094418919fSjohnjiang }
7104418919fSjohnjiang
7114418919fSjohnjiang perform_free();
7124418919fSjohnjiang return 0;
7134418919fSjohnjiang }
7144418919fSjohnjiang
7154418919fSjohnjiang REGISTER_TEST_COMMAND(member_autotest, test_member);
716