Fetch the repository succeeded.
This action will force synchronization from compile_success/gazelle_kylin_src, which will overwrite any changes that you have made since you forked the repository, and can not be recovered!!!
Synchronous operation will process in the background and will refresh the page when finishing processing. Please be patient.
From 4154201d36719047c7a74d5b6d495228234ff54a Mon Sep 17 00:00:00 2001
From: jiangheng <jiangheng14@huawei.com>
Date: Wed, 1 Feb 2023 15:58:00 +0800
Subject: [PATCH] add unitest
---
src/lstack/include/lstack_protocol_stack.h | 1 +
test/unitest/CMakeLists.txt | 17 ++
test/unitest/lstack/CMakeLists.txt | 29 ++
test/unitest/lstack/config/lstack.conf | 21 ++
test/unitest/lstack/lstack_param_test.c | 206 +++++++++++++
test/unitest/lstack/lstack_test_case.h | 24 ++
test/unitest/lstack/lstack_unit_test.c | 206 +++++++++++++
test/unitest/lstack/main.c | 75 +++++
test/unitest/lstack/stub.c | 110 +++++++
test/unitest/ltran/CMakeLists.txt | 58 ++++
test/unitest/ltran/config/ltran.conf | 23 ++
test/unitest/ltran/libnet_tcp_test.c | 133 +++++++++
test/unitest/ltran/ltran_instance_test.c | 75 +++++
test/unitest/ltran/ltran_param_test.c | 320 +++++++++++++++++++++
test/unitest/ltran/ltran_stack_test.c | 75 +++++
test/unitest/ltran/ltran_test_case.h | 29 ++
test/unitest/ltran/main.c | 80 ++++++
test/unitest/stub.c | 34 +++
test/unitest/test.sh | 279 ++++++++++++++++++
19 files changed, 1795 insertions(+)
create mode 100644 test/unitest/CMakeLists.txt
create mode 100644 test/unitest/lstack/CMakeLists.txt
create mode 100644 test/unitest/lstack/config/lstack.conf
create mode 100644 test/unitest/lstack/lstack_param_test.c
create mode 100644 test/unitest/lstack/lstack_test_case.h
create mode 100644 test/unitest/lstack/lstack_unit_test.c
create mode 100644 test/unitest/lstack/main.c
create mode 100644 test/unitest/lstack/stub.c
create mode 100644 test/unitest/ltran/CMakeLists.txt
create mode 100644 test/unitest/ltran/config/ltran.conf
create mode 100644 test/unitest/ltran/libnet_tcp_test.c
create mode 100644 test/unitest/ltran/ltran_instance_test.c
create mode 100644 test/unitest/ltran/ltran_param_test.c
create mode 100644 test/unitest/ltran/ltran_stack_test.c
create mode 100644 test/unitest/ltran/ltran_test_case.h
create mode 100644 test/unitest/ltran/main.c
create mode 100644 test/unitest/stub.c
create mode 100644 test/unitest/test.sh
diff --git a/src/lstack/include/lstack_protocol_stack.h b/src/lstack/include/lstack_protocol_stack.h
index 4fe06cd..b093362 100644
--- a/src/lstack/include/lstack_protocol_stack.h
+++ b/src/lstack/include/lstack_protocol_stack.h
@@ -15,6 +15,7 @@
#include <semaphore.h>
#include <sys/epoll.h>
+#include <stdbool.h>
#include <lwip/list.h>
#include <lwip/netif.h>
diff --git a/test/unitest/CMakeLists.txt b/test/unitest/CMakeLists.txt
new file mode 100644
index 0000000..e4946e8
--- /dev/null
+++ b/test/unitest/CMakeLists.txt
@@ -0,0 +1,17 @@
+# Copyright (c) Huawei Technologies Co., Ltd. 2020-2021. All rights reserved.
+# gazelle is licensed under the Mulan PSL v2.
+# You can use this software according to the terms and conditions of the Mulan PSL v2.
+# You may obtain a copy of Mulan PSL v2 at:
+# http://license.coscl.org.cn/MulanPSL2
+# THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND, EITHER EXPRESS OR
+# IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT, MERCHANTABILITY OR FIT FOR A PARTICULAR
+# PURPOSE.
+# See the Mulan PSL v2 for more details.
+
+cmake_minimum_required(VERSION 3.12.1)
+project(gazelle_unittest)
+
+set(CMAKE_C_FLAGS "-g -D_FORTIFY_SOURCE=2 -O3 -fPIE -fstack-protector-strong -msse4.1")
+
+add_subdirectory(lstack)
+add_subdirectory(ltran)
diff --git a/test/unitest/lstack/CMakeLists.txt b/test/unitest/lstack/CMakeLists.txt
new file mode 100644
index 0000000..66dac0f
--- /dev/null
+++ b/test/unitest/lstack/CMakeLists.txt
@@ -0,0 +1,29 @@
+# Copyright (c) Huawei Technologies Co., Ltd. 2020-2021. All rights reserved.
+# gazelle is licensed under the Mulan PSL v2.
+# You can use this software according to the terms and conditions of the Mulan PSL v2.
+# You may obtain a copy of Mulan PSL v2 at:
+# http://license.coscl.org.cn/MulanPSL2
+# THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND, EITHER EXPRESS OR
+# IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT, MERCHANTABILITY OR FIT FOR A PARTICULAR
+# PURPOSE.
+# See the Mulan PSL v2 for more details.
+
+cmake_minimum_required(VERSION 3.12.1)
+project(gazelle_unittest)
+
+set(SRC_PATH ../../../src/lstack/core)
+set(COMMON_PATH ../../../src/common)
+set(LIB_PATH ../../../src/lstack /usr/include/dpdk /usr/include/lwip ${COMMON_PATH} ../../../src/lstack/include /usr/lib64)
+set(EXECUTABLE_OUTPUT_PATH ../)
+
+set(CMAKE_C_FLAGS "${CMAKE_C_FLAGS} -fprofile-arcs -ftest-coverage")
+set(CMAKE_EXE_LINKER_FLAGS "${CMAKE_EXE_LINKER_FLAGS} -g -fprofile-arcs -ftest-coverage -lgcov")
+
+set(LIBRTE_LIB rte_pci rte_bus_pci rte_cmdline rte_hash rte_mempool rte_mempool_ring rte_timer rte_eal rte_ring rte_mbuf rte_kni rte_net_ixgbe rte_ethdev rte_net rte_kvargs)
+
+add_executable(lstack_test lstack_param_test.c stub.c main.c ${SRC_PATH}/lstack_cfg.c ${COMMON_PATH}/gazelle_parse_config.c)
+target_include_directories(lstack_test PRIVATE ${LIB_PATH})
+target_link_libraries(lstack_test PRIVATE config boundscheck cunit lwip pthread ${LIBRTE_LIB})
+#target_link_libraries(lstack_param_test PRIVATE config cunit)
+
+target_compile_options(lstack_test PRIVATE -DUSE_LIBOS_MEM)
diff --git a/test/unitest/lstack/config/lstack.conf b/test/unitest/lstack/config/lstack.conf
new file mode 100644
index 0000000..4be9173
--- /dev/null
+++ b/test/unitest/lstack/config/lstack.conf
@@ -0,0 +1,21 @@
+# Copyright (c) Huawei Technologies Co., Ltd. 2020-2021. All rights reserved.
+# gazelle is licensed under the Mulan PSL v2.
+# You can use this software according to the terms and conditions of the Mulan PSL v2.
+# You may obtain a copy of Mulan PSL v2 at:
+# http://license.coscl.org.cn/MulanPSL2
+# THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND, EITHER EXPRESS OR
+# IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT, MERCHANTABILITY OR FIT FOR A PARTICULAR
+# PURPOSE.
+# See the Mulan PSL v2 for more details.
+
+dpdk_args=["--socket-mem", "2048,0,0,0", "--huge-dir", "/mnt/hugepages-2M", "--proc-type", "primary"]
+use_ltran=0
+low_power_mode=0
+num_cpus="0,2,4"
+num_weakup="1,3,5"
+
+numa_bind=1
+host_addr="192.168.1.10"
+mask_addr="255.255.255.0"
+gateway_addr="192.168.1.1"
+devices="aa:bb:cc:dd:ee:ff"
diff --git a/test/unitest/lstack/lstack_param_test.c b/test/unitest/lstack/lstack_param_test.c
new file mode 100644
index 0000000..efd07a2
--- /dev/null
+++ b/test/unitest/lstack/lstack_param_test.c
@@ -0,0 +1,206 @@
+/*
+ * Copyright (c) Huawei Technologies Co., Ltd. 2020-2021. All rights reserved.
+ * gazelle is licensed under the Mulan PSL v2.
+ * You can use this software according to the terms and conditions of the Mulan PSL v2.
+ * You may obtain a copy of Mulan PSL v2 at:
+ * http://license.coscl.org.cn/MulanPSL2
+ * THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND, EITHER EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT, MERCHANTABILITY OR FIT FOR A PARTICULAR
+ * PURPOSE.
+ * See the Mulan PSL v2 for more details.
+ */
+
+#include <stdlib.h>
+#include <CUnit/Basic.h>
+#include <CUnit/Automated.h>
+#include <CUnit/Console.h>
+#include <unistd.h>
+#include <string.h>
+#include <sys/socket.h>
+#include <netinet/in.h>
+#include <arpa/inet.h>
+#include <securec.h>
+#include "lstack_cfg.h"
+
+#define MAX_CMD_LEN 1024
+
+int parse_conf_file(const char *path);
+
+static int execute_cmd(const char *cmd)
+{
+ int result;
+ result = system(cmd);
+ if (result < 0) {
+ printf("Executing cmd: %s error!!!\n", cmd);
+ }
+ return result;
+}
+
+static int lstack_bad_param(const char *conf_file_filed)
+{
+ int ret;
+ const char *conf_file_path = "../lstack/config/lstack_tmp.conf";
+ char cmd[MAX_CMD_LEN];
+
+ execute_cmd("rm -rf ../lstack/config/lstack_tmp.conf");
+ execute_cmd("cp -f ../lstack/config/lstack.conf ../lstack/config/lstack_tmp.conf");
+
+ ret = sprintf_s(cmd, MAX_CMD_LEN, "sed -i '%s' %s", conf_file_filed, conf_file_path);
+ if (ret < 0) {
+ printf("sprintf_s cmd error %s %s!!!\n", conf_file_filed, conf_file_path);
+ return ret;
+ }
+
+ execute_cmd(cmd);
+
+ ret = parse_conf_file(conf_file_path);
+
+ return ret;
+}
+
+void test_lstack_bad_params_lowpower(void)
+{
+ /* lstack start lowpower empty */
+ CU_ASSERT(lstack_bad_param("/^low_power_mode/clow_power_mode=/") != 0);
+
+ /* lstack start lowpower none */
+ CU_ASSERT(lstack_bad_param("/low_power_mode/d") == 0);
+
+ /* lstack start lowpower exceed str */
+ CU_ASSERT(lstack_bad_param("/^low_power_mode/clow_power_mode=aaa/") != 0);
+}
+
+void test_lstack_bad_params_num_cpus(void)
+{
+ /* lstack start num_cpus empty */
+ CU_ASSERT(lstack_bad_param("/^num_cpus/cnum_cpus=/") != 0);
+
+ /* lstack start num_cpus none */
+ CU_ASSERT(lstack_bad_param("/num_cpus/d") != 0);
+
+ /* lstack start num_cpus exceed str */
+ CU_ASSERT(lstack_bad_param("/^num_cpus/cnum_cpus=aaa/") != 0);
+}
+
+void test_lstack_bad_params_host_addr(void)
+{
+ /* lstack start host_addr empty */
+ CU_ASSERT(lstack_bad_param("/^host_addr/chost_addr=/") != 0);
+
+ /* lstack start host_addr none */
+ CU_ASSERT(lstack_bad_param("/^host_addr/d") != 0);
+
+ /* lstack start host_addr invaild str */
+ CU_ASSERT(lstack_bad_param("/^host_addr/chost_addr=\"aaa\"/") != 0);
+
+ /* lstack start host_addr exceed str */
+ CU_ASSERT(lstack_bad_param("/^host_addr/chost_addr=\"192.168.1.256\"/") != 0);
+}
+
+void test_lstack_bad_params_mask_addr(void)
+{
+ /* lstack start mask_addr empty */
+ CU_ASSERT(lstack_bad_param("/^mask_addr/cmask_addr=/") != 0);
+
+ /* lstack start mask_addr none */
+ CU_ASSERT(lstack_bad_param("/^mask_addr/d") != 0);
+
+ /* lstack start mask_addr invaild str */
+ CU_ASSERT(lstack_bad_param("/^mask_addr/cmask_addr=\"aaa\"/") != 0);
+
+ /* lstack start mask_addr exceed str */
+ CU_ASSERT(lstack_bad_param("/^mask_addr/cmask_addr=\"256.255.255.0\"/") != 0);
+
+ /* lstack start mask_addr exceed str */
+ CU_ASSERT(lstack_bad_param("/^mask_addr/cmask_addr=\"255.254.255.0\"/") != 0);
+}
+
+void test_lstack_bad_params_gateway_addr(void)
+{
+ /* lstack start gateway_addr empty */
+ CU_ASSERT(lstack_bad_param("/^gateway_addr/cgateway_addr=/") != 0);
+
+ /* lstack start gateway_addr none */
+ CU_ASSERT(lstack_bad_param("/^gateway_addr/d") != 0);
+
+ /* lstack start gateway_addr invaild str */
+ CU_ASSERT(lstack_bad_param("/^gateway_addr/cgateway_addr=\"aaa\"/") != 0);
+
+ /* lstack start gateway_addr exceed str */
+ CU_ASSERT(lstack_bad_param("/^gateway_addr/cgateway_addr=\"192.168.1.256\"/") != 0);
+}
+
+void test_lstack_bad_params_devices(void)
+{
+ /* lstack start devices empty */
+ CU_ASSERT(lstack_bad_param("/^devices/cdevices=/") != 0);
+
+ /* lstack start devices none */
+ CU_ASSERT(lstack_bad_param("/^devices/d") != 0);
+
+ /* lstack start devices invaild str */
+ CU_ASSERT(lstack_bad_param("/^devices/cdevices=\"aaa\"/") != 0);
+
+ /* lstack start devices exceed str */
+ CU_ASSERT(lstack_bad_param("/^devices/cdevices=\"ff:ff:ff:ff:ff:ff:ff\"/") != 0);
+
+ /* lstack start devices exceed str */
+ CU_ASSERT(lstack_bad_param("/^devices/cdevices=\"ff:ff:ff:ff:ff-ff\"/") != 0);
+
+ /* lstack start devices exceed str */
+ CU_ASSERT(lstack_bad_param("/^devices/cdevices=\"ff:ff:ff:ff:ff:fg\"/") != 0);
+}
+
+void test_lstack_normal_param(void)
+{
+ int ret;
+ char ip_str[16] = {0}; /* 16:IP max len */
+ char str[18] = {0};
+ const char *config_file_path = "../lstack/config/lstack.conf";
+
+ ret = parse_conf_file(config_file_path);
+ CU_ASSERT(ret == 0);
+ struct cfg_params *global_params = get_global_cfg_params();
+ for (int i =0; i< global_params->dpdk_argc; i++)
+ printf("arcv is %s\n", global_params->dpdk_argv[i]);
+
+ CU_ASSERT(global_params->dpdk_argc == 9); /* 9:参数个数 */
+ CU_ASSERT(strcmp(global_params->dpdk_argv[0], "lstack") == 0);
+ CU_ASSERT(strcmp(global_params->dpdk_argv[1], "--socket-mem") == 0); /* 1:lstack 参数 */
+ CU_ASSERT(strcmp(global_params->dpdk_argv[2], "2048,0,0,0") == 0); /* 2:lstack 参数 */
+ CU_ASSERT(strcmp(global_params->dpdk_argv[3], "--huge-dir") == 0); /* 3:lstack socket内存参数 */
+ CU_ASSERT(strcmp(global_params->dpdk_argv[4], "/mnt/hugepages-2M") == 0); /* 4:lstack socket内存值 */
+ CU_ASSERT(strcmp(global_params->dpdk_argv[5], "--proc-type") == 0); /* 5:lstack huge路径参数 */
+ CU_ASSERT(strcmp(global_params->dpdk_argv[6], "primary") == 0); /* 6:lstack huge路径值 */
+ CU_ASSERT(strcmp(global_params->dpdk_argv[7], "-l") == 0); /* 7:lstack进程类型参数 */
+ CU_ASSERT(strcmp(global_params->dpdk_argv[8], "0,2,4") == 0); /* 8:lstack参数 */
+
+ struct in_addr tmp_subnet;
+ tmp_subnet.s_addr = global_params->host_addr.addr;
+ char *subnet_str = strdup(inet_ntop(AF_INET, &tmp_subnet, ip_str, sizeof(ip_str)));
+ CU_ASSERT(subnet_str != NULL);
+ CU_ASSERT(strcmp(subnet_str, "192.168.1.10") == 0);
+ free(subnet_str);
+
+ tmp_subnet.s_addr = global_params->netmask.addr;
+ subnet_str = strdup(inet_ntop(AF_INET, &tmp_subnet, ip_str, sizeof(ip_str)));
+ CU_ASSERT(subnet_str != NULL);
+ CU_ASSERT(strcmp(subnet_str, "255.255.255.0") == 0);
+ free(subnet_str);
+
+ tmp_subnet.s_addr = global_params->gateway_addr.addr;
+ subnet_str = strdup(inet_ntop(AF_INET, &tmp_subnet, ip_str, sizeof(ip_str)));
+ CU_ASSERT(subnet_str != NULL);
+ CU_ASSERT(strcmp(subnet_str, "192.168.1.1") == 0);
+ free(subnet_str);
+
+ /* MAC地址转换为字符串 */
+ ret = sprintf_s(str, sizeof(str), "%hhx:%hhx:%hhx:%hhx:%hhx:%hhx", global_params->mac_addr[0],
+ global_params->mac_addr[1],
+ global_params->mac_addr[2], // 2mac地址
+ global_params->mac_addr[3], // 3mac地址
+ global_params->mac_addr[4], // 4mac地址
+ global_params->mac_addr[5]); // 5mac地址
+ CU_ASSERT(ret > 0);
+ CU_ASSERT(strcmp(str, "aa:bb:cc:dd:ee:ff") == 0); /* 匹配的MAC地址 */
+}
diff --git a/test/unitest/lstack/lstack_test_case.h b/test/unitest/lstack/lstack_test_case.h
new file mode 100644
index 0000000..cdb2550
--- /dev/null
+++ b/test/unitest/lstack/lstack_test_case.h
@@ -0,0 +1,24 @@
+/*
+ * Copyright (c) Huawei Technologies Co., Ltd. 2020-2021. All rights reserved.
+ * gazelle is licensed under the Mulan PSL v2.
+ * You can use this software according to the terms and conditions of the Mulan PSL v2.
+ * You may obtain a copy of Mulan PSL v2 at:
+ * http://license.coscl.org.cn/MulanPSL2
+ * THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND, EITHER EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT, MERCHANTABILITY OR FIT FOR A PARTICULAR
+ * PURPOSE.
+ * See the Mulan PSL v2 for more details.
+ */
+
+#ifndef __LSTACK_TEST_CASE_H__
+#define __LSTACK_TEST_CASE_H__
+
+void test_lstack_normal_param(void);
+void test_lstack_bad_params_devices(void);
+void test_lstack_bad_params_gateway_addr(void);
+void test_lstack_bad_params_mask_addr(void);
+void test_lstack_bad_params_host_addr(void);
+void test_lstack_bad_params_num_cpus(void);
+void test_lstack_bad_params_lowpower(void);
+
+#endif
diff --git a/test/unitest/lstack/lstack_unit_test.c b/test/unitest/lstack/lstack_unit_test.c
new file mode 100644
index 0000000..041a7cc
--- /dev/null
+++ b/test/unitest/lstack/lstack_unit_test.c
@@ -0,0 +1,206 @@
+/*
+ * Copyright (c) Huawei Technologies Co., Ltd. 2020-2021. All rights reserved.
+ * gazelle is licensed under the Mulan PSL v2.
+ * You can use this software according to the terms and conditions of the Mulan PSL v2.
+ * You may obtain a copy of Mulan PSL v2 at:
+ * http://license.coscl.org.cn/MulanPSL2
+ * THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND, EITHER EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT, MERCHANTABILITY OR FIT FOR A PARTICULAR
+ * PURPOSE.
+ * See the Mulan PSL v2 for more details.
+ */
+
+#include <stdlib.h>
+#include <CUnit/Basic.h>
+#include <CUnit/Automated.h>
+#include <CUnit/Console.h>
+#include <unistd.h>
+#include <string.h>
+#include <sys/socket.h>
+#include <netinet/in.h>
+#include <arpa/inet.h>
+#include <securec.h>
+#include "lstack_cfg.h"
+
+#define MAX_CMD_LEN 1024
+
+int parse_conf_file(const char *path);
+
+static int execute_cmd(const char *cmd)
+{
+ int result;
+ result = system(cmd);
+ if (result < 0) {
+ printf("Executing cmd: %s error!!!\n", cmd);
+ }
+ return result;
+}
+
+static int lstack_bad_param(const char *conf_file_filed)
+{
+ int ret;
+ const char *conf_file_path = "../lstack/config/lstack_tmp.conf";
+ char cmd[MAX_CMD_LEN];
+
+ execute_cmd("rm -rf ../lstack/config/lstack_tmp.conf");
+ execute_cmd("cp -f ../lstack/config/lstack.conf ../lstack/config/lstack_tmp.conf");
+
+ ret = sprintf_s(cmd, MAX_CMD_LEN, "sed -i '%s' %s", conf_file_filed, conf_file_path);
+ if (ret < 0) {
+ printf("sprintf_s cmd error %s %s!!!\n", conf_file_filed, conf_file_path);
+ return ret;
+ }
+
+ execute_cmd(cmd);
+
+ ret = parse_conf_file(conf_file_path);
+
+ return ret;
+}
+
+void test_lstack_bad_params_lowpower(void)
+{
+ /* lstack start lowpower empty */
+ CU_ASSERT(lstack_bad_param("/^low_power_mode/clow_power_mode=/") != 0);
+
+ /* lstack start lowpower none */
+ CU_ASSERT(lstack_bad_param("/low_power_mode/d") == 0);
+
+ /* lstack start lowpower exceed str */
+ CU_ASSERT(lstack_bad_param("/^low_power_mode/clow_power_mode=aaa/") != 0);
+}
+
+void test_lstack_bad_params_num_cpus(void)
+{
+ /* lstack start num_cpus empty */
+ CU_ASSERT(lstack_bad_param("/^num_cpus/cnum_cpus=/") != 0);
+
+ /* lstack start num_cpus none */
+ CU_ASSERT(lstack_bad_param("/num_cpus/d") != 0);
+
+ /* lstack start num_cpus exceed str */
+ CU_ASSERT(lstack_bad_param("/^num_cpus/cnum_cpus=aaa/") != 0);
+}
+
+void test_lstack_bad_params_host_addr(void)
+{
+ /* lstack start host_addr empty */
+ CU_ASSERT(lstack_bad_param("/^host_addr/chost_addr=/") != 0);
+
+ /* lstack start host_addr none */
+ CU_ASSERT(lstack_bad_param("/^host_addr/d") != 0);
+
+ /* lstack start host_addr invaild str */
+ CU_ASSERT(lstack_bad_param("/^host_addr/chost_addr=\"aaa\"/") != 0);
+
+ /* lstack start host_addr exceed str */
+ CU_ASSERT(lstack_bad_param("/^host_addr/chost_addr=\"192.168.1.256\"/") != 0);
+}
+
+void test_lstack_bad_params_mask_addr(void)
+{
+ /* lstack start mask_addr empty */
+ CU_ASSERT(lstack_bad_param("/^mask_addr/cmask_addr=/") != 0);
+
+ /* lstack start mask_addr none */
+ CU_ASSERT(lstack_bad_param("/^mask_addr/d") != 0);
+
+ /* lstack start mask_addr invaild str */
+ CU_ASSERT(lstack_bad_param("/^mask_addr/cmask_addr=\"aaa\"/") != 0);
+
+ /* lstack start mask_addr exceed str */
+ CU_ASSERT(lstack_bad_param("/^mask_addr/cmask_addr=\"256.255.255.0\"/") != 0);
+
+ /* lstack start mask_addr exceed str */
+ CU_ASSERT(lstack_bad_param("/^mask_addr/cmask_addr=\"255.254.255.0\"/") != 0);
+}
+
+void test_lstack_bad_params_gateway_addr(void)
+{
+ /* lstack start gateway_addr empty */
+ CU_ASSERT(lstack_bad_param("/^gateway_addr/cgateway_addr=/") != 0);
+
+ /* lstack start gateway_addr none */
+ CU_ASSERT(lstack_bad_param("/^gateway_addr/d") != 0);
+
+ /* lstack start gateway_addr invaild str */
+ CU_ASSERT(lstack_bad_param("/^gateway_addr/cgateway_addr=\"aaa\"/") != 0);
+
+ /* lstack start gateway_addr exceed str */
+ CU_ASSERT(lstack_bad_param("/^gateway_addr/cgateway_addr=\"192.168.1.256\"/") != 0);
+}
+
+void test_lstack_bad_params_devices(void)
+{
+ /* lstack start devices empty */
+ CU_ASSERT(lstack_bad_param("/^devices/cdevices=/") != 0);
+
+ /* lstack start devices none */
+ CU_ASSERT(lstack_bad_param("/^devices/d") != 0);
+
+ /* lstack start devices invaild str */
+ CU_ASSERT(lstack_bad_param("/^devices/cdevices=\"aaa\"/") != 0);
+
+ /* lstack start devices exceed str */
+ CU_ASSERT(lstack_bad_param("/^devices/cdevices=\"ff:ff:ff:ff:ff:ff:ff\"/") != 0);
+
+ /* lstack start devices exceed str */
+ CU_ASSERT(lstack_bad_param("/^devices/cdevices=\"ff:ff:ff:ff:ff-ff\"/") != 0);
+
+ /* lstack start devices exceed str */
+ CU_ASSERT(lstack_bad_param("/^devices/cdevices=\"ff:ff:ff:ff:ff:fg\"/") != 0);
+}
+
+void test_lstack_normal_param(void)
+{
+ int ret;
+ char ip_str[16] = {0}; /* 16:IP max len */
+ char str[18] = {0};
+ const char *config_file_path = "../lstack/config/lstack.conf";
+
+ ret = parse_conf_file(config_file_path);
+ CU_ASSERT(ret == 0);
+ struct cfg_params *global_params = get_global_cfg_params();
+ for (int i =0; i< global_params->dpdk_argc; i++)
+ printf("arcv is %s\n", global_params->dpdk_argv[i]);
+
+ CU_ASSERT(global_params->dpdk_argc == 9); /* 9:参数个数 */
+ CU_ASSERT(strcmp(global_params->dpdk_argv[0], "lstack") == 0);
+ CU_ASSERT(strcmp(global_params->dpdk_argv[1], "--socket-mem") == 0); /* 1:lstack 参数 */
+ CU_ASSERT(strcmp(global_params->dpdk_argv[2], "2048,0,0,0") == 0); /* 2:lstack 参数 */
+ CU_ASSERT(strcmp(global_params->dpdk_argv[3], "--huge-dir") == 0); /* 3:lstack socket内存参数 */
+ CU_ASSERT(strcmp(global_params->dpdk_argv[4], "/mnt/hugepages-2M") == 0); /* 4:lstack socket内存值 */
+ CU_ASSERT(strcmp(global_params->dpdk_argv[5], "--proc-type") == 0); /* 5:lstack huge路径参数 */
+ CU_ASSERT(strcmp(global_params->dpdk_argv[6], "primary") == 0); /* 6:lstack huge路径值 */
+ CU_ASSERT(strcmp(global_params->dpdk_argv[7], "-l") == 0); /* 7:lstack进程类型参数 */
+ CU_ASSERT(strcmp(global_params->dpdk_argv[8], "0,2,4") == 0); /* 8:lstack参数 */
+
+ struct in_addr tmp_subnet;
+ tmp_subnet.s_addr = global_params->host_addr.addr;
+ char *subnet_str = strdup(inet_ntop(AF_INET, &tmp_subnet, ip_str, sizeof(ip_str)));
+ CU_ASSERT(subnet_str != NULL);
+ CU_ASSERT(strcmp(subnet_str, "192.168.1.10") == 0);
+ free(subnet_str);
+
+ tmp_subnet.s_addr = global_params->netmask.addr;
+ subnet_str = strdup(inet_ntop(AF_INET, &tmp_subnet, ip_str, sizeof(ip_str)));
+ CU_ASSERT(subnet_str != NULL);
+ CU_ASSERT(strcmp(subnet_str, "255.255.255.0") == 0);
+ free(subnet_str);
+
+ tmp_subnet.s_addr = global_params->gateway_addr.addr;
+ subnet_str = strdup(inet_ntop(AF_INET, &tmp_subnet, ip_str, sizeof(ip_str)));
+ CU_ASSERT(subnet_str != NULL);
+ CU_ASSERT(strcmp(subnet_str, "192.168.1.1") == 0);
+ free(subnet_str);
+
+ /* MAC地址转换为字符串 */
+ ret = sprintf_s(str, sizeof(str), "%hhx:%hhx:%hhx:%hhx:%hhx:%hhx", global_params->ethdev.addr_bytes[0],
+ global_params->ethdev.addr_bytes[1],
+ global_params->ethdev.addr_bytes[2], // 2mac地址
+ global_params->ethdev.addr_bytes[3], // 3mac地址
+ global_params->ethdev.addr_bytes[4], // 4mac地址
+ global_params->ethdev.addr_bytes[5]); // 5mac地址
+ CU_ASSERT(ret > 0);
+ CU_ASSERT(strcmp(str, "aa:bb:cc:dd:ee:ff") == 0); /* 匹配的MAC地址 */
+}
diff --git a/test/unitest/lstack/main.c b/test/unitest/lstack/main.c
new file mode 100644
index 0000000..84285dd
--- /dev/null
+++ b/test/unitest/lstack/main.c
@@ -0,0 +1,75 @@
+/*
+ * Copyright (c) Huawei Technologies Co., Ltd. 2020-2021. All rights reserved.
+ * gazelle is licensed under the Mulan PSL v2.
+ * You can use this software according to the terms and conditions of the Mulan PSL v2.
+ * You may obtain a copy of Mulan PSL v2 at:
+ * http://license.coscl.org.cn/MulanPSL2
+ * THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND, EITHER EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT, MERCHANTABILITY OR FIT FOR A PARTICULAR
+ * PURPOSE.
+ * See the Mulan PSL v2 for more details.
+ */
+
+#include <stdlib.h>
+#include <CUnit/Basic.h>
+#include <CUnit/Automated.h>
+#include <CUnit/Console.h>
+#include "lstack_test_case.h"
+
+typedef enum {
+ LSTACK_SCREEN = 0,
+ LSTACK_XMLFILE,
+ LSTACK_CONSOLE
+} CU_RunMode;
+
+int main(int argc, char **argv)
+{
+ CU_pSuite suite;
+ int num_failures;
+ CU_RunMode g_cunit_mode = LSTACK_SCREEN;
+
+ if (argc > 1) {
+ g_cunit_mode = atoi(argv[1]);
+ }
+
+ if (CU_initialize_registry() != CUE_SUCCESS) {
+ return CU_get_error();
+ }
+
+ suite = CU_add_suite("lstack", NULL, NULL);
+ if (suite == NULL) {
+ CU_cleanup_registry();
+ return CU_get_error();
+ }
+
+ (void)CU_ADD_TEST(suite, test_lstack_normal_param);
+ (void)CU_ADD_TEST(suite, test_lstack_bad_params_devices);
+ (void)CU_ADD_TEST(suite, test_lstack_bad_params_gateway_addr);
+ (void)CU_ADD_TEST(suite, test_lstack_bad_params_mask_addr);
+ (void)CU_ADD_TEST(suite, test_lstack_bad_params_host_addr);
+ (void)CU_ADD_TEST(suite, test_lstack_bad_params_num_cpus);
+ (void)CU_ADD_TEST(suite, test_lstack_bad_params_lowpower);
+
+ switch (g_cunit_mode) {
+ case LSTACK_SCREEN:
+ CU_basic_set_mode(CU_BRM_VERBOSE);
+ CU_basic_run_tests();
+ break;
+ case LSTACK_XMLFILE:
+ CU_set_output_filename("param");
+ CU_list_tests_to_file();
+ CU_automated_run_tests();
+ break;
+ case LSTACK_CONSOLE:
+ CU_console_run_tests();
+ break;
+ default:
+ (void)printf("not suport cunit mode, only suport: 0 or 1\n");
+ CU_cleanup_registry();
+ return CU_get_error();
+ }
+
+ num_failures = (int)CU_get_number_of_failures();
+ CU_cleanup_registry();
+ return num_failures;
+}
diff --git a/test/unitest/lstack/stub.c b/test/unitest/lstack/stub.c
new file mode 100644
index 0000000..f1a3a84
--- /dev/null
+++ b/test/unitest/lstack/stub.c
@@ -0,0 +1,110 @@
+/*
+ * Copyright (c) Huawei Technologies Co., Ltd. 2020-2021. All rights reserved.
+ * gazelle is licensed under the Mulan PSL v2.
+ * You can use this software according to the terms and conditions of the Mulan PSL v2.
+ * You may obtain a copy of Mulan PSL v2 at:
+ * http://license.coscl.org.cn/MulanPSL2
+ * THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND, EITHER EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT, MERCHANTABILITY OR FIT FOR A PARTICULAR
+ * PURPOSE.
+ * See the Mulan PSL v2 for more details.
+ */
+
+#include <stdio.h>
+#include <stdlib.h>
+#include <unistd.h>
+
+#include <arch/sys_arch.h>
+#include <lwip/sys.h>
+#include <lwip/api.h>
+
+int lwip_epoll_create(int size)
+{
+ return 0;
+}
+int lwip_epoll_ctl(int epfd, int op, int fd, const void *event)
+{
+ return 0;
+}
+int lwip_epoll_wait(int epfd, const void* events, int maxevents, int timeout)
+{
+ return 0;
+}
+void libnet_per_thread_init(void)
+{
+ return;
+}
+int lwip_sigaction(int signum, const void *act, const void *oldact)
+{
+ return 0;
+}
+int lwip_fork(void)
+{
+ return 0;
+}
+int del_epoll_event(const void *conn, int event)
+{
+ return 0;
+}
+int add_epoll_event(const void *conn, int event)
+{
+ return 0;
+}
+int rearm_accept_fd(int fd)
+{
+ return 0;
+}
+void clean_host_fd(int fd)
+{
+ return;
+}
+int rearm_host_fd(int fd)
+{
+ return 0;
+}
+int lwip_is_epfd(int epfd)
+{
+ return 0;
+}
+int lwip_epoll_close(int epfd)
+{
+ return 0;
+}
+int eth_dev_poll(void)
+{
+ return 0;
+}
+int vdev_reg_xmit(int type, const void *qtuple)
+{
+ return 0;
+}
+
+void *__wrap_memp_malloc(int type)
+{
+ void *memp;
+
+ memp = malloc(5 * 1024 * 1024); /* 5 * 1024 * 1024 = 5M */
+
+ return memp;
+}
+
+int __wrap_sys_mbox_new(const struct sys_mbox **mb, int size)
+{
+ return 0;
+}
+
+int __wrap_netconn_prepare_delete(const struct netconn *conn)
+{
+ return 0;
+}
+
+int __wrap_netconn_delete(struct netconn *conn)
+{
+ if (conn != NULL) {
+ free(conn->pcb.tcp);
+ free(conn->op_completed);
+ free(conn);
+ conn = NULL;
+ }
+ return 0;
+}
diff --git a/test/unitest/ltran/CMakeLists.txt b/test/unitest/ltran/CMakeLists.txt
new file mode 100644
index 0000000..9496053
--- /dev/null
+++ b/test/unitest/ltran/CMakeLists.txt
@@ -0,0 +1,58 @@
+# Copyright (c) Huawei Technologies Co., Ltd. 2020-2021. All rights reserved.
+# gazelle is licensed under the Mulan PSL v2.
+# You can use this software according to the terms and conditions of the Mulan PSL v2.
+# You may obtain a copy of Mulan PSL v2 at:
+# http://license.coscl.org.cn/MulanPSL2
+# THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND, EITHER EXPRESS OR
+# IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT, MERCHANTABILITY OR FIT FOR A PARTICULAR
+# PURPOSE.
+# See the Mulan PSL v2 for more details.
+
+cmake_minimum_required(VERSION 3.12.1)
+project(gazelle_unittest)
+
+set(LIB_PATH ../../../src/ltran /usr/include/dpdk ../../../src/common ../../../src/lstack/include)
+set(SRC_PATH_LTRAN ../../../src/ltran)
+set(EXECUTABLE_OUTPUT_PATH ../)
+
+set(CMAKE_C_FLAGS "${CMAKE_C_FLAGS} -fprofile-arcs -ftest-coverage")
+set(CMAKE_EXE_LINKER_FLAGS "${CMAKE_EXE_LINKER_FLAGS} -g -fprofile-arcs -ftest-coverage -lgcov")
+
+add_executable(ltran_test
+ ltran_instance_test.c
+ ltran_param_test.c
+ ltran_stack_test.c
+ libnet_tcp_test.c
+ main.c
+ ../stub.c
+ ${SRC_PATH_LTRAN}/ltran_param.c
+ ${SRC_PATH_LTRAN}/ltran_errno.c
+ ${SRC_PATH_LTRAN}/ltran_instance.c
+ ${SRC_PATH_LTRAN}/ltran_stack.c
+ ${SRC_PATH_LTRAN}/ltran_tcp_sock.c
+ ${SRC_PATH_LTRAN}/ltran_tcp_conn.c
+ ${SRC_PATH_LTRAN}/../common/gazelle_dfx_msg.c
+ ${SRC_PATH_LTRAN}/../common/gazelle_parse_config.c
+)
+
+set_target_properties(ltran_test PROPERTIES LINK_FLAGS "-L$ENV{DPDK_LIB_PATH} -Wl,--whole-archive -Wl,-lrte_pipeline -Wl,--wrap=rte_free -Wl,--wrap=rte_malloc \
+ -Wl,--no-whole-archive -Wl,--whole-archive -Wl,-lrte_table -Wl,--no-whole-archive -Wl,--whole-archive -Wl,-lrte_port -Wl,--no-whole-archive \
+ -Wl,-lrte_distributor -Wl,-lrte_ip_frag -Wl,-lrte_meter -Wl,-lrte_lpm -Wl,--whole-archive -Wl,-lrte_acl -Wl,--no-whole-archive \
+ -Wl,-lrte_jobstats -Wl,-lrte_bitratestats -Wl,-lrte_metrics -Wl,-lrte_latencystats -Wl,-lrte_power -Wl,-lrte_efd -Wl,-lrte_bpf \
+ -Wl,--whole-archive -Wl,-lrte_gro -Wl,-lrte_cfgfile -Wl,-lrte_gso -Wl,-lrte_hash -Wl,-lrte_member -Wl,-lrte_vhost -Wl,-lrte_kvargs \
+ -Wl,-lrte_mbuf -Wl,-lrte_ethdev -Wl,-lrte_net -Wl,-lrte_bbdev -Wl,-lrte_cryptodev -Wl,-lrte_security -Wl,-lrte_compressdev -Wl,-lrte_eventdev \
+ -Wl,-lrte_rawdev -Wl,-lrte_timer -Wl,-lrte_mempool -Wl,-lrte_mempool_ring -Wl,-lrte_ring -Wl,-lrte_pci \
+ -Wl,-Bstatic -lrte_eal -Wl,-Bdynamic -Wl,-lrte_cmdline \
+ -Wl,-lrte_sched -Wl,-lrte_reorder -Wl,-lrte_kni -Wl,-lrte_common_cpt -Wl,-lrte_common_octeontx -Wl,-lrte_common_dpaax -Wl,-lrte_bus_pci \
+ -Wl,-lrte_bus_dpaa -Wl,-lrte_bus_vdev -Wl,-lrte_bus_fslmc -Wl,-lrte_mempool_bucket -Wl,-lrte_mempool_stack -Wl,-lrte_mempool_dpaa \
+ -Wl,-lrte_mempool_dpaa2 -Wl,-lrte_net_af_packet -Wl,-lrte_net_ark -Wl,-lrte_net_atlantic -Wl,-lrte_net_axgbe \
+ -Wl,-lrte_net_bnxt -Wl,-lrte_net_bond -Wl,-lrte_net_cxgbe -Wl,-lrte_net_dpaa -Wl,-lrte_net_dpaa2 -Wl,-lrte_net_e1000 -Wl,-lrte_net_ena \
+ -Wl,-lrte_net_enetc -Wl,-lrte_net_enic -Wl,-lrte_net_failsafe -Wl,-lrte_net_i40e -Wl,-lrte_net_hinic -Wl,-lrte_net_ixgbe -Wl,-lrte_net_kni \
+ -Wl,-lrte_net_nfp -Wl,-lrte_net_null -Wl,-lpcap -Wl,-lrte_net_qede -Wl,-lrte_net_ring -Wl,-lrte_net_softnic \
+ -Wl,-lrte_net_tap -Wl,-lrte_net_vdev_netvsc -Wl,-lrte_net_virtio -Wl,-lrte_net_vhost \
+ -Wl,-lrte_bus_vmbus -Wl,-lrte_net_netvsc -Wl,-lrte_mempool_octeontx -Wl,-lrte_net_octeontx \
+ -Wl,-lrte_bus_ifpga -Wl,-lrte_stack -Wl,-lrte_telemetry\
+ -Wl,--no-whole-archive -Wl,-lm -Wl,-lrt -Wl,-lnuma -Wl,-ldl -Wl,-export-dynamic -Wl,-export-dynamic \
+ -Wl,--as-needed -Wl,-export-dynamic -Wl,-Map=ltran.map -Wl,--cref")
+target_include_directories(ltran_test PRIVATE ${LIB_PATH})
+target_link_libraries(ltran_test PRIVATE config boundscheck cunit pthread)
diff --git a/test/unitest/ltran/config/ltran.conf b/test/unitest/ltran/config/ltran.conf
new file mode 100644
index 0000000..bbab844
--- /dev/null
+++ b/test/unitest/ltran/config/ltran.conf
@@ -0,0 +1,23 @@
+# Copyright (c) Huawei Technologies Co., Ltd. 2020-2021. All rights reserved.
+# gazelle is licensed under the Mulan PSL v2.
+# You can use this software according to the terms and conditions of the Mulan PSL v2.
+# You may obtain a copy of Mulan PSL v2 at:
+# http://license.coscl.org.cn/MulanPSL2
+# THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND, EITHER EXPRESS OR
+# IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT, MERCHANTABILITY OR FIT FOR A PARTICULAR
+# PURPOSE.
+# See the Mulan PSL v2 for more details.
+
+forward_kit = "dpdk"
+forward_kit_args = "-l 0,1 --socket-mem 1024,0,0,0 --huge-dir /mnt/hugepages --proc-type auto -n 4"
+kni_switch = 0
+
+dispatch_subnet = "192.168.1.0"
+dispatch_subnet_length = 8
+dispatch_max_clients = 32
+
+bond_mode = 1
+bond_miimon = 100
+bond_mtu = 1500
+bond_ports = "0x3, 0xC"
+bond_macs = "52:54:00:25:ef:e0, aa:bb:cc:dd:ee:ff"
diff --git a/test/unitest/ltran/libnet_tcp_test.c b/test/unitest/ltran/libnet_tcp_test.c
new file mode 100644
index 0000000..6a6eadc
--- /dev/null
+++ b/test/unitest/ltran/libnet_tcp_test.c
@@ -0,0 +1,133 @@
+/*
+ * Copyright (c) Huawei Technologies Co., Ltd. 2020-2021. All rights reserved.
+ * gazelle is licensed under the Mulan PSL v2.
+ * You can use this software according to the terms and conditions of the Mulan PSL v2.
+ * You may obtain a copy of Mulan PSL v2 at:
+ * http://license.coscl.org.cn/MulanPSL2
+ * THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND, EITHER EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT, MERCHANTABILITY OR FIT FOR A PARTICULAR
+ * PURPOSE.
+ * See the Mulan PSL v2 for more details.
+ */
+
+#include <stdlib.h>
+#include <CUnit/Basic.h>
+#include <CUnit/Automated.h>
+#include <CUnit/Console.h>
+#include <unistd.h>
+#include <string.h>
+#include <sys/socket.h>
+#include <netinet/in.h>
+#include <arpa/inet.h>
+#include <securec.h>
+#include "ltran_tcp_sock.h"
+#include "ltran_tcp_conn.h"
+
+#define MAX_CONN 10
+#define MAX_SOCK 10
+void test_tcp_conn(void)
+{
+ struct gazelle_tcp_conn_htable *tcp_conn_htable = NULL;
+ struct gazelle_tcp_conn *tcp_conn = NULL;
+ struct gazelle_tcp_conn *exist_tcp_conn = NULL;
+ struct gazelle_quintuple quintuple;
+ /* 1: set instance on */
+ int32_t instance_cur_tick = 1;
+
+ tcp_conn_htable = gazelle_tcp_conn_htable_create(MAX_CONN);
+ CU_ASSERT(tcp_conn_htable != NULL);
+ gazelle_set_tcp_conn_htable(tcp_conn_htable);
+
+ quintuple.src_ip = inet_addr("192.168.1.1");
+ quintuple.dst_ip = inet_addr("192.168.1.2");
+ quintuple.src_port = 22; /* 22:src port id */
+ quintuple.dst_port = 23; /* 23:dst port id */
+ quintuple.protocol = 0;
+ tcp_conn = gazelle_conn_add_by_quintuple(gazelle_get_tcp_conn_htable(), &quintuple);
+ CU_ASSERT(tcp_conn != NULL);
+ tcp_conn->instance_cur_tick = &instance_cur_tick;
+ /* 1: set instacn_cur_tick = instance_reg_tick indicate instance is on */
+ tcp_conn->instance_reg_tick = 1;
+
+ exist_tcp_conn = gazelle_conn_get_by_quintuple(gazelle_get_tcp_conn_htable(), &quintuple);
+ CU_ASSERT(exist_tcp_conn != NULL);
+
+ gazelle_conn_del_by_quintuple(gazelle_get_tcp_conn_htable(), &quintuple);
+ exist_tcp_conn = gazelle_conn_get_by_quintuple(gazelle_get_tcp_conn_htable(), &quintuple);
+ CU_ASSERT(exist_tcp_conn == NULL);
+
+ gazelle_conn_del_by_quintuple(gazelle_get_tcp_conn_htable(), &quintuple);
+
+ for (int i = 0; i <= MAX_CONN; i++) {
+ quintuple.src_port++;
+ tcp_conn = gazelle_conn_add_by_quintuple(gazelle_get_tcp_conn_htable(), &quintuple);
+ if (i < MAX_CONN) {
+ CU_ASSERT(tcp_conn != NULL);
+ tcp_conn->instance_cur_tick = &instance_cur_tick;
+ /* 1: set instacn_cur_tick = instance_reg_tick indicate instance is on */
+ tcp_conn->instance_reg_tick = 1;
+ } else {
+ CU_ASSERT(tcp_conn == NULL);
+ }
+
+ tcp_conn = gazelle_conn_get_by_quintuple(gazelle_get_tcp_conn_htable(), &quintuple);
+ if (i < MAX_CONN) {
+ CU_ASSERT(tcp_conn != NULL);
+ } else {
+ CU_ASSERT(tcp_conn == NULL);
+ }
+ }
+
+ gazelle_tcp_conn_htable_destroy();
+}
+
+void test_tcp_sock(void)
+{
+ char ip_str[16] = {0};
+ struct in_addr tmp_subnet;
+ struct gazelle_tcp_sock *tcp_sock = NULL;
+ struct gazelle_tcp_sock *exist_tcp_sock = NULL;
+ /* 1: set instance on */
+ int32_t instance_cur_tick = 1;
+
+ gazelle_set_tcp_sock_htable(gazelle_tcp_sock_htable_create(MAX_SOCK));
+ gazelle_set_tcp_conn_htable(gazelle_tcp_conn_htable_create(GAZELLE_MAX_CONN_NUM));
+
+ /* 22:dst port id 1111:dst tid number */
+ tcp_sock = gazelle_sock_add_by_ipporttid(gazelle_get_tcp_sock_htable(), inet_addr("192.168.1.1"), 22, 1111);
+ CU_ASSERT(tcp_sock != NULL);
+ CU_ASSERT(tcp_sock->tid == 1111); /* 1111:tid number */
+ CU_ASSERT(tcp_sock->port == 22); /* 22:port id */
+
+ tmp_subnet.s_addr = tcp_sock->ip;
+ CU_ASSERT(strcmp(inet_ntoa(tmp_subnet), "192.168.1.1") == 0);
+ tcp_sock->instance_cur_tick = &instance_cur_tick;
+ /* 1: set instacn_cur_tick = instance_reg_tick indicate instance is on */
+ tcp_sock->instance_reg_tick = 1;
+
+ /* 22:port id */
+ exist_tcp_sock = gazelle_sock_get_by_min_conn(gazelle_get_tcp_sock_htable(), inet_addr("192.168.1.1"), 22);
+ CU_ASSERT(exist_tcp_sock != NULL);
+ CU_ASSERT(exist_tcp_sock->tid == 1111); /* 1111:tid number */
+
+ /* 22:dst port id 1111:dst tid number */
+ gazelle_sock_del_by_ipporttid(gazelle_get_tcp_sock_htable(), inet_addr("192.168.1.1"), 22, 1111);
+ /* 22:dst port id */
+ exist_tcp_sock = gazelle_sock_get_by_min_conn(gazelle_get_tcp_sock_htable(), inet_addr("192.168.1.1"), 22);
+ CU_ASSERT(exist_tcp_sock == NULL);
+
+ /* 22:port id 1111:dst tid number */
+ gazelle_sock_del_by_ipporttid(gazelle_get_tcp_sock_htable(), inet_addr("192.168.1.1"), 22, 1111);
+
+ for (int i = 0; i <= MAX_CONN; i++) {
+ /* 22:dst port id 1111:dst tid number */
+ tcp_sock = gazelle_sock_add_by_ipporttid(gazelle_get_tcp_sock_htable(), inet_addr("192.168.1.1"), 22, i);
+ if (i < MAX_CONN) {
+ CU_ASSERT(tcp_sock != NULL);
+ } else {
+ CU_ASSERT(tcp_sock == NULL);
+ }
+ }
+
+ gazelle_tcp_sock_htable_destroy();
+}
diff --git a/test/unitest/ltran/ltran_instance_test.c b/test/unitest/ltran/ltran_instance_test.c
new file mode 100644
index 0000000..53acea1
--- /dev/null
+++ b/test/unitest/ltran/ltran_instance_test.c
@@ -0,0 +1,75 @@
+/*
+ * Copyright (c) Huawei Technologies Co., Ltd. 2020-2021. All rights reserved.
+ * gazelle is licensed under the Mulan PSL v2.
+ * You can use this software according to the terms and conditions of the Mulan PSL v2.
+ * You may obtain a copy of Mulan PSL v2 at:
+ * http://license.coscl.org.cn/MulanPSL2
+ * THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND, EITHER EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT, MERCHANTABILITY OR FIT FOR A PARTICULAR
+ * PURPOSE.
+ * See the Mulan PSL v2 for more details.
+ */
+
+#include <stdlib.h>
+#include <CUnit/Basic.h>
+#include <CUnit/Automated.h>
+#include <CUnit/Console.h>
+#include <unistd.h>
+#include <string.h>
+#include <sys/socket.h>
+#include <netinet/in.h>
+#include <arpa/inet.h>
+#include <securec.h>
+#include "ltran_instance.h"
+#include "ltran_param.h"
+#include "ltran_stack.h"
+
+void test_ltran_instance(void)
+{
+ struct gazelle_instance *instance = NULL;
+ uint32_t ret;
+
+ get_ltran_config()->dispatcher.num_clients = 30; /* 30:clients num */
+ get_ltran_config()->dispatcher.ipv4_subnet_size = 256; /* 256:ipv4 subnet size */
+ get_ltran_config()->dispatcher.ipv4_net_mask = get_ltran_config()->dispatcher.ipv4_subnet_size - 1;
+ set_instance_mgr(gazelle_instance_mgr_create());
+ CU_ASSERT(get_instance_mgr() != NULL);
+
+ instance = gazelle_instance_add_by_pid(get_instance_mgr(), 1111); /* 1111:test pid */
+ CU_ASSERT(instance != NULL);
+ CU_ASSERT(instance->pid == 1111); /* 1111:test pid */
+
+ instance = gazelle_instance_get_by_pid(get_instance_mgr(), 1111); /* 1111:test pid */
+ CU_ASSERT(instance != NULL);
+ CU_ASSERT(instance->pid == 1111); /* 1111:test pid */
+
+ instance->ip_addr.s_addr = inet_addr("192.168.1.1");
+
+ instance = gazelle_instance_get_by_ip(get_instance_mgr(), inet_addr("192.168.1.1"));
+ CU_ASSERT(instance != NULL);
+ CU_ASSERT(instance->pid == 1111); /* 1111:test pid */
+ CU_ASSERT(instance->ip_addr.s_addr == inet_addr("192.168.1.1"));
+
+ instance = gazelle_instance_get_by_ip(get_instance_mgr(), inet_addr("192.168.1.2"));
+ CU_ASSERT(instance == NULL);
+
+ instance = gazelle_instance_get_by_pid(get_instance_mgr(), 1112); /* 1112:test pid */
+ CU_ASSERT(instance == NULL);
+
+ for (int i = 1; i <= get_instance_mgr()->max_instance_num; i++) {
+ instance = gazelle_instance_add_by_pid(get_instance_mgr(), i);
+ if (i < get_instance_mgr()->max_instance_num) {
+ CU_ASSERT(instance != NULL);
+ } else {
+ CU_ASSERT(instance == NULL);
+ }
+ instance = gazelle_instance_get_by_pid(get_instance_mgr(), i);
+ if (i < get_instance_mgr()->max_instance_num) {
+ CU_ASSERT(instance != NULL);
+ } else {
+ CU_ASSERT(instance == NULL);
+ }
+ }
+
+ gazelle_instance_mgr_destroy();
+}
diff --git a/test/unitest/ltran/ltran_param_test.c b/test/unitest/ltran/ltran_param_test.c
new file mode 100644
index 0000000..3b2a24d
--- /dev/null
+++ b/test/unitest/ltran/ltran_param_test.c
@@ -0,0 +1,320 @@
+/*
+ * Copyright (c) Huawei Technologies Co., Ltd. 2020-2021. All rights reserved.
+ * gazelle is licensed under the Mulan PSL v2.
+ * You can use this software according to the terms and conditions of the Mulan PSL v2.
+ * You may obtain a copy of Mulan PSL v2 at:
+ * http://license.coscl.org.cn/MulanPSL2
+ * THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND, EITHER EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT, MERCHANTABILITY OR FIT FOR A PARTICULAR
+ * PURPOSE.
+ * See the Mulan PSL v2 for more details.
+ */
+
+#include <stdlib.h>
+#include <CUnit/Basic.h>
+#include <CUnit/Automated.h>
+#include <CUnit/Console.h>
+#include <unistd.h>
+#include <string.h>
+#include <sys/socket.h>
+#include <netinet/in.h>
+#include <arpa/inet.h>
+#include <securec.h>
+#include "ltran_param.h"
+
+#define MAX_CMD_LEN 1024
+
+static int execute_cmd(const char *cmd)
+{
+ int ret;
+ ret = system(cmd);
+ if (ret < 0) {
+ printf("Executing cmd: %s error!!!\n", cmd);
+ abort();
+ }
+ return ret;
+}
+
+static void restore_tmp_config(void)
+{
+ execute_cmd("rm -rf ../ltran/config/ltran_tmp.conf");
+ execute_cmd("cp -f ../ltran/config/ltran.conf ../ltran/config/ltran_tmp.conf");
+}
+
+static int ltran_bad_param(const char *conf_file_filed)
+{
+ int ret;
+ struct ltran_config ltran_conf;
+ const char *conf_file_path = "../ltran/config/ltran_tmp.conf";
+ char cmd[MAX_CMD_LEN];
+
+ restore_tmp_config();
+ gazelle_set_errno(GAZELLE_SUCCESS);
+
+ ret = sprintf_s(cmd, MAX_CMD_LEN, "sed -i '%s' %s", conf_file_filed, conf_file_path);
+ if (ret < 0) {
+ printf("sprintf_s return error!!!\n");
+ return ret;
+ }
+
+ execute_cmd(cmd);
+
+ ret = parse_config_file_args(conf_file_path, <ran_conf);
+
+ return ret;
+}
+
+void test_ltran_bad_params_clients(void)
+{
+ /* ltran start negative client */
+ CU_ASSERT(ltran_bad_param("s/dispatch_max_clients = 32/dispatch_max_clients = -1/") != 0);
+ CU_ASSERT(gazelle_get_errno() == GAZELLE_ERANGE);
+
+ /* ltran start 0 client */
+ CU_ASSERT(ltran_bad_param("s/dispatch_max_clients = 32/dispatch_max_clients = 0/") != 0);
+ CU_ASSERT(gazelle_get_errno() == GAZELLE_ERANGE);
+
+ /* ltran start 999 clinet */
+ CU_ASSERT(ltran_bad_param("s/dispatch_max_clients = 32/dispatch_max_clients = 999/") != 0);
+ CU_ASSERT(gazelle_get_errno() == GAZELLE_ERANGE);
+
+ /* ltran start str client */
+ CU_ASSERT(ltran_bad_param("s/dispatch_max_clients = 32/dispatch_max_clients = \"aaa\"/") != 0);
+ CU_ASSERT(gazelle_get_errno() == GAZELLE_EPARAM);
+
+ /* ltran start none client */
+ CU_ASSERT(ltran_bad_param("s/dispatch_max_clients = 32//") != 0);
+ CU_ASSERT(gazelle_get_errno() == GAZELLE_EPARAM);
+
+ /* ltran start empty client */
+ CU_ASSERT(ltran_bad_param("s/dispatch_max_clients = 32/dispatch_max_clients = /") == -GAZELLE_EPATH);
+}
+
+void test_ltran_bad_params_port(void)
+{
+ /* ltran start zero port */
+ CU_ASSERT(ltran_bad_param("s/0x3/0x0/") != 0);
+ CU_ASSERT(gazelle_get_errno() == GAZELLE_ERANGE);
+
+ /* ltran start max port */
+ CU_ASSERT(ltran_bad_param("s/0x3/0xff/") == 0);
+ CU_ASSERT(gazelle_get_errno() == GAZELLE_SUCCESS);
+
+ /* ltran start str port */
+ CU_ASSERT(ltran_bad_param("s/0x3/aaa/") != 0);
+ CU_ASSERT(gazelle_get_errno() == GAZELLE_EPARAM);
+
+ /* ltran start none port */
+ CU_ASSERT(ltran_bad_param("s/bond_ports = \"0x3, 0xC\"//") != 0);
+ CU_ASSERT(gazelle_get_errno() == GAZELLE_EPARAM);
+
+ /* ltran start empty port */
+ CU_ASSERT(ltran_bad_param("s/bond_ports = \"0x3, 0xC\"/bond_ports = /") == -GAZELLE_EPATH);
+
+ /* ltran start exceed max port */
+ CU_ASSERT(ltran_bad_param("s/bond_ports = \"0x3, 0xC\"/bond_ports = \"0xffffffff\"/") != 0);
+ CU_ASSERT(gazelle_get_errno() == GAZELLE_ERANGE);
+}
+
+void test_ltran_bad_params_subnet(void)
+{
+ /* ltran start bad subnet */
+ CU_ASSERT(ltran_bad_param("s/dispatch_subnet =/cdispatch_subnet = \"aaa\"/") != 0);
+ CU_ASSERT(gazelle_get_errno() == GAZELLE_EPARAM);
+
+ /* ltran start empty subnet */
+ CU_ASSERT(ltran_bad_param("/^dispatch_subnet /cdispatch_subnet=") == -GAZELLE_EPATH);
+
+ /* ltran start none subnet */
+ CU_ASSERT(ltran_bad_param("/dispatch_subnet =/d") != 0);
+ CU_ASSERT(gazelle_get_errno() == GAZELLE_EPARAM);
+
+ /* ltran start not match subnet */
+ CU_ASSERT(ltran_bad_param("s/.0\"/.1\"/") != 0);
+ CU_ASSERT(gazelle_get_errno() == GAZELLE_EHOSTADDR);
+
+ /* ltran start error subnet */
+ CU_ASSERT(ltran_bad_param("s/1.0\"/288.0\"/") != 0);
+ CU_ASSERT(gazelle_get_errno() == GAZELLE_EINETATON);
+
+ /* ltran start exceed subnet length */
+ CU_ASSERT(ltran_bad_param("s/dispatch_subnet_length = 8/dispatch_subnet_length = 17/") != 0);
+ CU_ASSERT(gazelle_get_errno() == GAZELLE_ERANGE);
+
+ /* ltran start exceed subnet length */
+ CU_ASSERT(ltran_bad_param("s/dispatch_subnet_length = 8/dispatch_subnet_length = 0/") != 0);
+ CU_ASSERT(gazelle_get_errno() == GAZELLE_ERANGE);
+
+ /* ltran start str subnet length */
+ CU_ASSERT(ltran_bad_param("s/dispatch_subnet_length = 8/dispatch_subnet_length = aaa/") == -GAZELLE_EPATH);
+
+ /* ltran start empty subnet length */
+ CU_ASSERT(ltran_bad_param("s/dispatch_subnet_length = 8/dispatch_subnet_length = /") == -GAZELLE_EPATH);
+
+ /* ltran start none subnet length */
+ CU_ASSERT(ltran_bad_param("s/dispatch_subnet_length = 8//") != 0);
+ CU_ASSERT(gazelle_get_errno() == GAZELLE_EPARAM);
+}
+
+void test_ltran_bad_params_bond_mode(void)
+{
+ /* ltran start negative bond mode */
+ CU_ASSERT(ltran_bad_param("s/bond_mode = 1/bond_mode = -1/") != 0);
+ CU_ASSERT(gazelle_get_errno() == GAZELLE_ERANGE);
+
+ /* ltran start unsupport bond mode0 */
+ CU_ASSERT(ltran_bad_param("s/bond_mode = 1/bond_mode = 0/") != 0);
+ CU_ASSERT(gazelle_get_errno() == GAZELLE_ERANGE);
+
+ /* ltran start unsupport bond mode2 */
+ CU_ASSERT(ltran_bad_param("s/bond_mode = 1/bond_mode = 2/") != 0);
+ CU_ASSERT(gazelle_get_errno() == GAZELLE_ERANGE);
+
+ /* ltran start empty bond mode */
+ CU_ASSERT(ltran_bad_param("/^bond_mode /cbond_mode =") == -GAZELLE_EPATH);
+
+ /* ltran start unsupport none mode2 */
+ CU_ASSERT(ltran_bad_param("s/bond_mode = 1//") != 0);
+ CU_ASSERT(gazelle_get_errno() == GAZELLE_EPARAM);
+}
+
+void test_ltran_bad_params_bond_miimon(void)
+{
+ /* ltran start negative bond miimon */
+ CU_ASSERT(ltran_bad_param("s/bond_miimon = 100/bond_miimon = -1/") != 0);
+ CU_ASSERT(gazelle_get_errno() == GAZELLE_ERANGE);
+
+ /* ltran start zero bond miimon */
+ CU_ASSERT(ltran_bad_param("s/bond_miimon = 100/bond_miimon = 0/") != 0);
+ CU_ASSERT(gazelle_get_errno() == GAZELLE_ERANGE);
+
+ /* ltran start max bond miimon */
+ CU_ASSERT(ltran_bad_param("s/bond_miimon = 100/bond_miimon = 2147483647/") == 0);
+ CU_ASSERT(gazelle_get_errno() == GAZELLE_SUCCESS);
+
+ /* ltran start exceed str bond miimon */
+ CU_ASSERT(ltran_bad_param("s/bond_miimon = 100/bond_miimon = aaa/") == -GAZELLE_EPATH);
+
+ /* ltran start empty bond miimon */
+ CU_ASSERT(ltran_bad_param("s/bond_miimon = 100/bond_miimon = /") == -GAZELLE_EPATH);
+
+ /* ltran start none bond miimon */
+ CU_ASSERT(ltran_bad_param("s/bond_miimon = 100//") != 0);
+ CU_ASSERT(gazelle_get_errno() == GAZELLE_EPARAM);
+}
+
+void test_ltran_bad_params_bond_mtu(void)
+{
+ /* ltran start negative bond mtu */
+ CU_ASSERT(ltran_bad_param("s/bond_mtu = 1500/bond_mtu = -1/") != 0);
+ CU_ASSERT(gazelle_get_errno() == GAZELLE_ERANGE);
+
+ /* ltran start exceed min bond mtu */
+ CU_ASSERT(ltran_bad_param("s/bond_mtu = 1500/bond_mtu = 67/") != 0);
+ CU_ASSERT(gazelle_get_errno() == GAZELLE_ERANGE);
+
+ /* ltran start exceed max bond mtu */
+ CU_ASSERT(ltran_bad_param("s/bond_mtu = 1500/bond_mtu = 1501/") != 0);
+ CU_ASSERT(gazelle_get_errno() == GAZELLE_ERANGE);
+
+ /* ltran start str bond mtu */
+ CU_ASSERT(ltran_bad_param("s/bond_mtu = 1500/bond_mtu = aaa/") == -GAZELLE_EPATH);
+
+ /* ltran start empty bond mtu */
+ CU_ASSERT(ltran_bad_param("s/bond_mtu = 1500/bond_mtu = /") == -GAZELLE_EPATH);
+
+ /* ltran start none bond mtu */
+ CU_ASSERT(ltran_bad_param("s/bond_mtu = 1500//") != 0);
+ CU_ASSERT(gazelle_get_errno() == GAZELLE_EPARAM);
+}
+
+void test_ltran_bad_params_macs(void)
+{
+ /* ltran start max macs */
+ CU_ASSERT(ltran_bad_param("s/52:54:00:25:ef:e0/ff:ff:ff:ff:ff:ff/") == 0);
+ CU_ASSERT(gazelle_get_errno() == GAZELLE_SUCCESS);
+
+ /* ltran start error macs */
+ CU_ASSERT(ltran_bad_param("s/52:54:00:25:ef:e0/ff:ff:ff:ff:ff:fg/") != 0);
+ CU_ASSERT(gazelle_get_errno() == GAZELLE_ECONSIST);
+
+ /* ltran start error macs */
+ CU_ASSERT(ltran_bad_param("s/52:54:00:25:ef:e0/ff:ff:ff:ff:ff:ff:ff/") != 0);
+ CU_ASSERT(gazelle_get_errno() == GAZELLE_ECONSIST);
+
+ /* ltran start error macs */
+ CU_ASSERT(ltran_bad_param("s/52:54:00:25:ef:e0/ff:ff:ff:ff:ff-ff/") != 0);
+ CU_ASSERT(gazelle_get_errno() == GAZELLE_ECONSIST);
+
+ /* ltran start empty macs */
+ CU_ASSERT(ltran_bad_param("s/52:54:00:25:ef:e0, aa:bb:cc:dd:ee:ff//") != 0);
+ CU_ASSERT(gazelle_get_errno() == GAZELLE_ECONSIST);
+
+ /* ltran start none macs */
+ CU_ASSERT(ltran_bad_param("s/bond_macs = \"52:54:00:25:ef:e0, aa:bb:cc:dd:ee:ff\"//") != 0);
+ CU_ASSERT(gazelle_get_errno() == GAZELLE_EPARAM);
+
+ /* ltran start duplicated macs */
+ CU_ASSERT(ltran_bad_param("/bond_macs/cbond_macs = \"52:54:00:25:ef:e0, 52:54:00:25:ef:e0\"") != 0);
+ CU_ASSERT(gazelle_get_errno() == GAZELLE_EMAC);
+}
+
+void check_bond_param(const struct ltran_config *ltran_conf)
+{
+ CU_ASSERT(ltran_conf->bond.mode == 1);
+ CU_ASSERT(ltran_conf->bond.miimon == 100); /* 100:bond链路监控时间 */
+ CU_ASSERT(ltran_conf->bond.mtu == 1500); /* 1500:bond mtu值 */
+ CU_ASSERT(ltran_conf->bond.port_num == 2); /* 2:bond port数目 */
+ CU_ASSERT(ltran_conf->bond.portmask[0] == 3); /* 3:bond mac端口掩码 */
+ CU_ASSERT(ltran_conf->bond.portmask[1] == 12); /* 12:bond mac端口掩码 */
+ CU_ASSERT(ltran_conf->bond.mac_num == 2); /* 2:bond mac地址数目 */
+ CU_ASSERT(ltran_conf->bond.mac[0].addr_bytes[0] == 82); /* 82:bond mac地址 */
+ CU_ASSERT(ltran_conf->bond.mac[0].addr_bytes[1] == 84); /* 84:bond mac地址 */
+ CU_ASSERT(ltran_conf->bond.mac[0].addr_bytes[2] == 0); /* 2:bond mac地址 */
+ CU_ASSERT(ltran_conf->bond.mac[0].addr_bytes[3] == 37); /* 3:37:bond mac地址 */
+ CU_ASSERT(ltran_conf->bond.mac[0].addr_bytes[4] == 239); /* 4:239:bond mac地址 */
+ CU_ASSERT(ltran_conf->bond.mac[0].addr_bytes[5] == 224); /* 5:224:bond mac地址 */
+ CU_ASSERT(ltran_conf->bond.mac[1].addr_bytes[0] == 170); /* 170:bond mac地址 */
+ CU_ASSERT(ltran_conf->bond.mac[1].addr_bytes[1] == 187); /* 187:bond mac地址 */
+ CU_ASSERT(ltran_conf->bond.mac[1].addr_bytes[2] == 204); /* 2:204:bond mac地址 */
+ CU_ASSERT(ltran_conf->bond.mac[1].addr_bytes[3] == 221); /* 3:221:bond mac地址 */
+ CU_ASSERT(ltran_conf->bond.mac[1].addr_bytes[4] == 238); /* 4:238:bond mac地址 */
+ CU_ASSERT(ltran_conf->bond.mac[1].addr_bytes[5] == 255); /* 5:255:bond mac地址 */
+}
+
+void test_ltran_normal_param(void)
+{
+ int ret;
+ struct ltran_config ltran_conf;
+ char ip_str[16] = {0}; /* 16:IP max len */
+ const char *config_file_path = "../ltran/config/ltran.conf";
+
+ (void)memset_s(<ran_conf, sizeof(struct ltran_config), 0, sizeof(struct ltran_config));
+ ret = parse_config_file_args(config_file_path, <ran_conf);
+ CU_ASSERT(ret == GAZELLE_OK);
+
+ struct in_addr tmp_subnet;
+ tmp_subnet.s_addr = ntohl(ltran_conf.dispatcher.ipv4_subnet_addr.s_addr);
+ char *subnet_str = strdup(inet_ntop(AF_INET, &tmp_subnet, ip_str, sizeof(ip_str)));
+ CU_ASSERT(subnet_str != NULL);
+ CU_ASSERT(ltran_conf.dpdk.dpdk_argc == 11); /* 11:参数个数 */
+ CU_ASSERT(strcmp(ltran_conf.dpdk.dpdk_argv[0], "ltran") == 0);
+ CU_ASSERT(strcmp(ltran_conf.dpdk.dpdk_argv[1], "-l") == 0);
+ CU_ASSERT(strcmp(ltran_conf.dpdk.dpdk_argv[2], "0,1") == 0); /* 2:ltran绑在0,1核 */
+ CU_ASSERT(strcmp(ltran_conf.dpdk.dpdk_argv[3], "--socket-mem") == 0); /* 3:ltran socket内存参数 */
+ CU_ASSERT(strcmp(ltran_conf.dpdk.dpdk_argv[4], "1024,0,0,0") == 0); /* 4:ltran socket内存值 */
+ CU_ASSERT(strcmp(ltran_conf.dpdk.dpdk_argv[5], "--huge-dir") == 0); /* 5:ltran huge路径参数 */
+ CU_ASSERT(strcmp(ltran_conf.dpdk.dpdk_argv[6], "/mnt/hugepages") == 0); /* 6:ltran huge路径值 */
+ CU_ASSERT(strcmp(ltran_conf.dpdk.dpdk_argv[7], "--proc-type") == 0); /* 7:ltran进程类型参数 */
+ CU_ASSERT(strcmp(ltran_conf.dpdk.dpdk_argv[8], "auto") == 0); /* 8:ltran进程类型值 */
+ CU_ASSERT(strcmp(ltran_conf.dpdk.dpdk_argv[9], "-n") == 0); /* 9:ltran处理器socket内存通道数目 */
+ CU_ASSERT(strcmp(ltran_conf.dpdk.dpdk_argv[10], "4") == 0); /* 10:ltran处理器socket内存通道数值 */
+ CU_ASSERT(ltran_conf.dpdk.kni_switch == 0);
+ CU_ASSERT(strcmp(subnet_str, "192.168.1.0") == 0);
+ CU_ASSERT(ltran_conf.dispatcher.ipv4_subnet_length == 8); /* 8:ipv4子网长度, 表示ltran能识别的子网长度 */
+ CU_ASSERT(ltran_conf.dispatcher.ipv4_subnet_size == 256); /* 256:ipv4子网大小 */
+ CU_ASSERT(ltran_conf.dispatcher.ipv4_net_mask == 255); /* 255:ipv4掩码 */
+ CU_ASSERT(ltran_conf.dispatcher.num_clients == 32); /* 32:client 数目 */
+ check_bond_param(<ran_conf);
+ free(subnet_str);
+}
diff --git a/test/unitest/ltran/ltran_stack_test.c b/test/unitest/ltran/ltran_stack_test.c
new file mode 100644
index 0000000..72af3ef
--- /dev/null
+++ b/test/unitest/ltran/ltran_stack_test.c
@@ -0,0 +1,75 @@
+/*
+ * Copyright (c) Huawei Technologies Co., Ltd. 2020-2021. All rights reserved.
+ * gazelle is licensed under the Mulan PSL v2.
+ * You can use this software according to the terms and conditions of the Mulan PSL v2.
+ * You may obtain a copy of Mulan PSL v2 at:
+ * http://license.coscl.org.cn/MulanPSL2
+ * THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND, EITHER EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT, MERCHANTABILITY OR FIT FOR A PARTICULAR
+ * PURPOSE.
+ * See the Mulan PSL v2 for more details.
+ */
+
+#include <stdlib.h>
+#include <CUnit/Basic.h>
+#include <CUnit/Automated.h>
+#include <CUnit/Console.h>
+#include <unistd.h>
+#include <string.h>
+#include <sys/socket.h>
+#include <netinet/in.h>
+#include <arpa/inet.h>
+#include <securec.h>
+#include "ltran_stack.h"
+
+void test_ltran_stack(void)
+{
+ struct gazelle_stack *stack = NULL;
+ const struct gazelle_stack *exist_stack = NULL;
+ struct gazelle_stack_htable *stack_htable;
+ /* 1: tick init val */
+ int32_t instance_cur_tick = 1;
+
+ stack_htable = gazelle_stack_htable_create(GAZELLE_MAX_STACK_NUM);
+ CU_ASSERT(stack_htable != NULL);
+ gazelle_set_stack_htable(stack_htable);
+
+ stack = gazelle_stack_add_by_tid(gazelle_get_stack_htable(), 1111); /* 1111:tid number */
+ CU_ASSERT(stack != NULL);
+ CU_ASSERT(stack->tid == 1111); /* 1111: tid number */
+ stack->instance_cur_tick = &instance_cur_tick;
+ /* 1: set instacn_cur_tick = instance_reg_tick indicate instance is on */
+ stack->instance_reg_tick = 1;
+
+ exist_stack = gazelle_stack_get_by_tid(gazelle_get_stack_htable(), 1111); /* 1111: tid number */
+
+ CU_ASSERT(exist_stack != NULL);
+ CU_ASSERT(exist_stack->tid == 1111); /* 1111:tid number */
+
+ gazelle_stack_del_by_tid(gazelle_get_stack_htable(), 1111); /* 1111:tid number */
+ exist_stack = gazelle_stack_get_by_tid(gazelle_get_stack_htable(), 1111); /* 1111:tid number */
+
+ CU_ASSERT(exist_stack == NULL);
+
+ gazelle_stack_del_by_tid(gazelle_get_stack_htable(), 1111);
+
+ for (int i = 0; i <= stack_htable->max_stack_num; i++) {
+ stack = gazelle_stack_add_by_tid(gazelle_get_stack_htable(), i);
+ if (i < stack_htable->max_stack_num) {
+ CU_ASSERT(stack != NULL);
+ stack->instance_cur_tick = &instance_cur_tick;
+ /* 1: set instacn_cur_tick = instance_reg_tick indicate instance is on */
+ stack->instance_reg_tick = 1;
+ } else {
+ CU_ASSERT(stack == NULL);
+ }
+ exist_stack = gazelle_stack_get_by_tid(gazelle_get_stack_htable(), i);
+ if (i < stack_htable->max_stack_num) {
+ CU_ASSERT(exist_stack != NULL);
+ } else {
+ CU_ASSERT(exist_stack == NULL);
+ }
+ }
+
+ gazelle_stack_htable_destroy();
+}
diff --git a/test/unitest/ltran/ltran_test_case.h b/test/unitest/ltran/ltran_test_case.h
new file mode 100644
index 0000000..fd81a1b
--- /dev/null
+++ b/test/unitest/ltran/ltran_test_case.h
@@ -0,0 +1,29 @@
+/*
+ * Copyright (c) Huawei Technologies Co., Ltd. 2020-2021. All rights reserved.
+ * gazelle is licensed under the Mulan PSL v2.
+ * You can use this software according to the terms and conditions of the Mulan PSL v2.
+ * You may obtain a copy of Mulan PSL v2 at:
+ * http://license.coscl.org.cn/MulanPSL2
+ * THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND, EITHER EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT, MERCHANTABILITY OR FIT FOR A PARTICULAR
+ * PURPOSE.
+ * See the Mulan PSL v2 for more details.
+ */
+
+#ifndef __LTRAN_TEST_CASE_H__
+#define __LTRAN_TEST_CASE_H__
+
+void test_ltran_stack(void);
+void test_ltran_instance(void);
+void test_ltran_normal_param(void);
+void test_ltran_bad_params_clients(void);
+void test_ltran_bad_params_port(void);
+void test_ltran_bad_params_subnet(void);
+void test_ltran_bad_params_bond_mode(void);
+void test_ltran_bad_params_bond_miimon(void);
+void test_ltran_bad_params_bond_mtu(void);
+void test_ltran_bad_params_macs(void);
+void test_tcp_conn(void);
+void test_tcp_sock(void);
+
+#endif
diff --git a/test/unitest/ltran/main.c b/test/unitest/ltran/main.c
new file mode 100644
index 0000000..c9d04f5
--- /dev/null
+++ b/test/unitest/ltran/main.c
@@ -0,0 +1,80 @@
+/*
+ * Copyright (c) Huawei Technologies Co., Ltd. 2020-2021. All rights reserved.
+ * gazelle is licensed under the Mulan PSL v2.
+ * You can use this software according to the terms and conditions of the Mulan PSL v2.
+ * You may obtain a copy of Mulan PSL v2 at:
+ * http://license.coscl.org.cn/MulanPSL2
+ * THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND, EITHER EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT, MERCHANTABILITY OR FIT FOR A PARTICULAR
+ * PURPOSE.
+ * See the Mulan PSL v2 for more details.
+ */
+
+#include <stdlib.h>
+#include <CUnit/Basic.h>
+#include <CUnit/Automated.h>
+#include <CUnit/Console.h>
+#include "ltran_test_case.h"
+
+typedef enum {
+ CUNIT_SCREEN = 0,
+ CUNIT_XMLFILE,
+ CUNIT_CONSOLE
+} CU_RunMode;
+
+int main(int argc, char **argv)
+{
+ CU_pSuite suite;
+ int num_failures;
+ CU_RunMode g_cunit_mode = CUNIT_SCREEN;
+
+ if (argc > 1) {
+ g_cunit_mode = atoi(argv[1]);
+ }
+
+ if (CU_initialize_registry() != CUE_SUCCESS) {
+ return CU_get_error();
+ }
+
+ suite = CU_add_suite("ltran", NULL, NULL);
+ if (suite == NULL) {
+ CU_cleanup_registry();
+ return CU_get_error();
+ }
+
+ (void)CU_ADD_TEST(suite, test_ltran_instance);
+ (void)CU_ADD_TEST(suite, test_ltran_stack);
+ (void)CU_ADD_TEST(suite, test_ltran_normal_param);
+ (void)CU_ADD_TEST(suite, test_ltran_bad_params_clients);
+ (void)CU_ADD_TEST(suite, test_ltran_bad_params_port);
+ (void)CU_ADD_TEST(suite, test_ltran_bad_params_subnet);
+ (void)CU_ADD_TEST(suite, test_ltran_bad_params_bond_mode);
+ (void)CU_ADD_TEST(suite, test_ltran_bad_params_bond_miimon);
+ (void)CU_ADD_TEST(suite, test_ltran_bad_params_bond_mtu);
+ (void)CU_ADD_TEST(suite, test_ltran_bad_params_macs);
+ (void)CU_ADD_TEST(suite, test_tcp_conn);
+ (void)CU_ADD_TEST(suite, test_tcp_sock);
+
+ switch (g_cunit_mode) {
+ case CUNIT_SCREEN:
+ CU_basic_set_mode(CU_BRM_VERBOSE);
+ CU_basic_run_tests();
+ break;
+ case CUNIT_XMLFILE:
+ CU_set_output_filename("instance");
+ CU_list_tests_to_file();
+ CU_automated_run_tests();
+ break;
+ case CUNIT_CONSOLE:
+ CU_console_run_tests();
+ break;
+ default:
+ (void)printf("not suport mode=%d\n", g_cunit_mode);
+ CU_cleanup_registry();
+ return CU_get_error();
+ }
+
+ num_failures = (int)CU_get_number_of_failures();
+ CU_cleanup_registry();
+ return num_failures;
+}
diff --git a/test/unitest/stub.c b/test/unitest/stub.c
new file mode 100644
index 0000000..8f37c90
--- /dev/null
+++ b/test/unitest/stub.c
@@ -0,0 +1,34 @@
+/*
+ * Copyright (c) Huawei Technologies Co., Ltd. 2020-2021. All rights reserved.
+ * gazelle is licensed under the Mulan PSL v2.
+ * You can use this software according to the terms and conditions of the Mulan PSL v2.
+ * You may obtain a copy of Mulan PSL v2 at:
+ * http://license.coscl.org.cn/MulanPSL2
+ * THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND, EITHER EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT, MERCHANTABILITY OR FIT FOR A PARTICULAR
+ * PURPOSE.
+ * See the Mulan PSL v2 for more details.
+ */
+
+#include <stdint.h>
+#include <stdlib.h>
+
+uint64_t get_current_time(void)
+{
+ return 0;
+}
+
+int rte_pdump_init(void)
+{
+ return 0;
+}
+
+void *__wrap_rte_malloc(const char *type, size_t size, unsigned align)
+{
+ return malloc(size);
+}
+
+void __wrap_rte_free(void *ptr)
+{
+ free(ptr);
+}
diff --git a/test/unitest/test.sh b/test/unitest/test.sh
new file mode 100644
index 0000000..90fbbe6
--- /dev/null
+++ b/test/unitest/test.sh
@@ -0,0 +1,279 @@
+# Copyright (c) Huawei Technologies Co., Ltd. 2020-2021. All rights reserved.
+# gazelle is licensed under the Mulan PSL v2.
+# You can use this software according to the terms and conditions of the Mulan PSL v2.
+# You may obtain a copy of Mulan PSL v2 at:
+# http://license.coscl.org.cn/MulanPSL2
+# THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND, EITHER EXPRESS OR
+# IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT, MERCHANTABILITY OR FIT FOR A PARTICULAR
+# PURPOSE.
+# See the Mulan PSL v2 for more details.
+
+usage()
+{
+ echo "Usage: sh llt.sh [OPTIONS]"
+ echo "Use llt.sh to control llt operation"
+ echo
+ echo "Misc:"
+ echo " -h, --help Print this help, then exit"
+ echo
+ echo "Compile Options:"
+ echo " -m, --cmake <option> use cmake genenate Makefile, eg: -m(default), -mcoverage, -masan, --cmake, --cmake=coverage"
+ echo " -c, --compile Enable compile"
+ echo " -e, --empty Enable compile empty(make clean)"
+ echo
+ echo "TestRun Options"
+ echo " -r, --run-llt <option> Run all llt, eg: -r, -rscreen(default), -rxml, --run-llt, --run-llt=screen, --run-llt=xml"
+ echo " -s, --specify-llt FILE Only Run specify llt executable FILE, eg: -smain_llt, --specify-llt=main_llt"
+ echo
+ echo "Coverage Options"
+ echo " -t, --cover-report <option> Enable coverage report. eg: -t, -thtml(default), -ttxt, --cover-report, --cover-report=html, --cover-report=txt"
+ echo " -f, --cover-file FILE Specified FILE coverage report, eg: -fmain.c, --cover-file=main.c"
+ echo
+}
+
+ARGS=`getopt -o "hcer::m::t::s:f:" -l "help,cmake::,empty,cover-report::,run-llt::,specify-llt:,cover-file:" -n "run_llt.sh" -- "$@"`
+if [ $? != 0 ]; then
+ usage
+ exit 1
+fi
+
+eval set -- "${ARGS}"
+
+if [ x"$ARGS" = x" --" ]; then
+ #set default value
+ COMPILE_ENABLE=no
+ COVERAGE_ENABLE=no
+ ASAN_ENABLE=no
+ EMPTY_ENABLE=no
+ RUN_LLT=yes
+ RUN_MODE=screen #value: screen or xml
+ COVER_REPORT_ENABLE=no
+fi
+
+while true; do
+ case "${1}" in
+ -m|--cmake)
+ CMAKE_ENABLE=yes
+ case "$2" in
+ "") shift 2;;
+ coverage) COVERAGE_ENABLE=yes; shift 2;;
+ asan) ASAN_ENABLE=yes; shift 2;;
+ *) echo "Error param: $2"; exit 1;;
+ esac;;
+ -h|--help)
+ usage; exit 0;;
+ -c|--compile)
+ COMPILE_ENABLE=yes
+ shift;;
+ -e|--empty)
+ EMPTY_ENABLE=yes
+ shift;;
+ -r|--run-llt)
+ RUN_LLT=yes
+ case "$2" in
+ "") RUN_MODE=screen; shift 2;;
+ screen) RUN_MODE=screen; shift 2;;
+ xml) RUN_MODE=xml; shift 2;;
+ *)echo "Error param: $2"; exit 1;;
+ esac;;
+ -t|--cover-report)
+ COVER_REPORT_ENABLE=yes
+ case "$2" in
+ "") COVER_STYLE=html;shift 2;;
+ html) COVER_STYLE=html;shift 2;;
+ txt) COVER_STYLE=txt;shift 2;;
+ *)echo "Error param: $2"; exit 1;;
+ esac;;
+ -s|--specify-llt)
+ SPECIFY_CASES=$2
+ shift 2;;
+ -f|--cover-file)
+ COVER_FILE=$2
+ shift 2;;
+ --)
+ shift; break;;
+ esac
+done
+
+function test_empty()
+{
+ echo ---------------------- llt empty begin ----------------------
+ set -x
+ echo "remove directory build"
+ rm -rf build
+ set +x
+ echo ---------------------- llt empty end ------------------------
+}
+
+function test_cmake()
+{
+ local CMAKE_OPTION="-DCMAKE_BUILD_TYPE=Debug"
+
+ echo ---------------------- llt cmake begin ----------------------
+ if [ ! -d "build" ]; then
+ mkdir build
+ fi
+ chmod 755 build
+ cd build
+ if [ x"${COVERAGE_ENABLE}" = x"yes" ]; then
+ CMAKE_OPTION="${CMAKE_OPTION} -DCOVERAGE_ENABLE=1"
+ fi
+
+ if [ x"${ASAN_ENABLE}" = x"yes" ]; then
+ CMAKE_OPTION="${CMAKE_OPTION} -DASAN_ENABLE=1"
+ fi
+
+ cmake .. ${CMAKE_OPTION}
+ cd -
+ echo ---------------------- llt cmake end ------------------------
+ echo
+}
+
+function test_compile()
+{
+ echo ---------------------- llt compile begin ----------------------
+ cd build
+ make -j
+ cd -
+ echo ---------------------- llt compile end ------------------------
+ echo
+}
+
+function test_run_all_test()
+{
+ ret=1
+ echo ---------------------- llt run begin --------------------------
+ if [ x"${RUN_MODE}" = x"screen" ]; then
+ RUN_MODE=0
+ elif [ x"${RUN_MODE}" = x"xml" ]; then
+ RUN_MODE=1
+ elif [ x"${RUN_MODE}" = x"" ]; then
+ RUN_MODE=0
+ else
+ echo "not suport run mode <${RUN_MODE}>"
+ usage
+ exit 1
+ fi
+
+ cd build
+ if [ x"${SPECIFY_CASES}" = x"" ]; then
+ SPECIFY_CASES=`find -name "*_test"` # run all test
+ else
+ SPECIFY_CASES=`find -name "${SPECIFY_CASES}"`
+ fi
+
+ TEST_LOG=test_result.log
+ >$TEST_LOG
+
+ for TEST in $SPECIFY_CASES; do
+ echo $TEST
+ $TEST $RUN_MODE
+ if [ $? != 0 ];then
+ echo $TEST FAILED >> $TEST_LOG
+ ret=1
+ else
+ echo $TEST success >> $TEST_LOG
+ ret=0
+ fi
+ done
+ echo ""
+ echo '######################test result begin######################'
+ cat $TEST_LOG
+ echo '#######################test result end#######################'
+ echo ""
+ cd -
+ echo ---------------------- llt run end --------------------------
+ return $ret
+}
+
+function test_coverage()
+{
+ echo ------------------ llt generate coverage begin --------------
+ cd build
+ if [ x"${COVER_STYLE}" = x"txt" ]; then
+ GCDAS=`find -name "${COVER_FILE}.gcda"`
+ if [ x"$GCDAS" = x"" ]; then
+ echo "not find ${COVER_FILE}.gcda"
+ echo
+ exit 1
+ fi
+
+ for GCDA in $GCDAS; do
+ gcov $GCDA
+ done
+
+ find -name "*.h.gcov" | xargs rm -f
+ echo '#################################'
+ find -name "${COVER_FILE}.gcov"
+ echo '#################################'
+ elif [ x"${COVER_STYLE}" = x"html" ]; then
+ if [ -d coverage ]; then
+ rm -rf coverage
+ fi
+ mkdir coverage
+ if [ x"${COVER_FILE}" = x"" ]; then
+ LCOV_CMD="-d ./"
+ else
+ GCDAS=`find -name "${COVER_FILE}.gcda"`
+ if [ $? != 0 ]; then
+ echo "not match ${COVER_FILE}.gcda"
+ exit 1
+ fi
+
+ for GCDA in ${GCDAS}; do
+ TMP_STR=" -d ${GCDA}";
+ LCOV_CMD="${LCOV_CMD} ${TMP_STR}";
+ done
+ fi
+
+ lcov -c -d . -o coverage/coverage.info --exclude "/usr/*" --exclude "*stub*" --exclude "*test*" --exclude "libnet_dfx_msg.c" --rc lcov_branch_coverage=1 --ignore-errors gcov --ignore-errors source --ignore-errors graph
+ if [ $? != 0 ]; then
+ echo "lcov generate coverage.info fail."
+ exit 1
+ fi
+
+ genhtml coverage/coverage.info -o coverage/html --branch-coverage --rc lcov_branch_coverage=1 -s --legend --ignore-errors source
+ if [ $? != 0 ]; then
+ echo "genhtml fail."
+ exit 1
+ fi
+ chmod 755 -R coverage
+ fi
+ cd -
+ echo ------------------ llt generate coverage end ----------------
+}
+
+exit_ret=0
+
+starttime=`date +'%Y-%m-%d %H:%M:%S'`
+sed -i "s/^static int32_t parse_conf_file/int32_t parse_conf_file/" ../../src/lstack/core/lstack_cfg.c
+sed -i "s/^ get_protocol_stack_group/ \/\/get_protocol_stack_group/" ../../src/lstack/core/lstack_cfg.c
+sed -i "/int32_t init_stack_numa_cpuset/i\ #if 0" ../../src/lstack/core/lstack_cfg.c
+sed -i "/static int32_t gazelle_parse_base_virtaddr/i\ #endif" ../../src/lstack/core/lstack_cfg.c
+if [ x"${EMPTY_ENABLE}" = x"yes" ]; then
+ test_empty
+fi
+
+if [ x"${CMAKE_ENABLE}" = x"yes" ]; then
+ test_cmake
+fi
+
+if [ x"${COMPILE_ENABLE}" = x"yes" ]; then
+ test_compile
+fi
+
+if [ x"${RUN_LLT}" = x"yes" ]; then
+ test_run_all_test
+ exit_val=$?
+fi
+
+if [ x"${COVER_REPORT_ENABLE}" = x"yes" ]; then
+ test_coverage
+fi
+git checkout HEAD -- ../../src/lstack/core/lstack_cfg.c
+
+endtime=`date +'%Y-%m-%d %H:%M:%S'`
+start_seconds=$(date --date="$starttime" +%s);
+end_seconds=$(date --date="$endtime" +%s);
+echo "Running time： "$((end_seconds-start_seconds))"s"
+exit $exit_val
--
2.23.0
此处可能存在不合适展示的内容，页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容，可点击提交进行申诉，我们将尽快为您处理。
马建仓 AI 助手