From aaa202f27b23cb783d9c2c2b25a49f27c8970ac6 Mon Sep 17 00:00:00 2001
From: yihaoDeng <yhdeng@taosdata.com>
Date: Wed, 22 Nov 2023 17:58:32 +0800
Subject: [PATCH] add http test

---
 source/libs/transport/test/CMakeLists.txt | 21 +++++--
 source/libs/transport/test/http_test.c    | 70 +++++++++++++++++++++++
 2 files changed, 85 insertions(+), 6 deletions(-)
 create mode 100644 source/libs/transport/test/http_test.c

diff --git a/source/libs/transport/test/CMakeLists.txt b/source/libs/transport/test/CMakeLists.txt
index b0548149d0..da4cda5dc7 100644
--- a/source/libs/transport/test/CMakeLists.txt
+++ b/source/libs/transport/test/CMakeLists.txt
@@ -2,6 +2,7 @@ add_executable(transportTest "")
 add_executable(transUT "")
 add_executable(svrBench "")
 add_executable(cliBench "")
+add_executable(httpBench "")
 
 target_sources(transUT
   PRIVATE
@@ -21,6 +22,10 @@ target_sources(cliBench
   PRIVATE
   "cliBench.c"
 )
+target_sources(httpBench
+  PRIVATE
+  "http_test.c"
+) 
 
 target_include_directories(transportTest 
   PUBLIC
@@ -51,11 +56,6 @@ target_include_directories(transUT
   "${CMAKE_CURRENT_SOURCE_DIR}/../inc"
 )
 
-target_include_directories(svrBench
-  PUBLIC
-  "${TD_SOURCE_DIR}/include/libs/transport" 
-  "${CMAKE_CURRENT_SOURCE_DIR}/../inc"
-)
 target_include_directories(svrBench
   PUBLIC
   "${TD_SOURCE_DIR}/include/libs/transport" 
@@ -75,7 +75,8 @@ target_include_directories(cliBench
   "${TD_SOURCE_DIR}/include/libs/transport" 
   "${CMAKE_CURRENT_SOURCE_DIR}/../inc"
 )
-target_include_directories(cliBench
+
+target_include_directories(httpBench
   PUBLIC
   "${TD_SOURCE_DIR}/include/libs/transport" 
   "${CMAKE_CURRENT_SOURCE_DIR}/../inc"
@@ -89,6 +90,14 @@ target_link_libraries (cliBench
   transport 
 )
 
+target_link_libraries(httpBench
+  os  
+  util
+  common
+  gtest_main
+  transport 
+)
+
 add_test(
   NAME transUT 
   COMMAND transUT 
diff --git a/source/libs/transport/test/http_test.c b/source/libs/transport/test/http_test.c
new file mode 100644
index 0000000000..d3b9356a9a
--- /dev/null
+++ b/source/libs/transport/test/http_test.c
@@ -0,0 +1,70 @@
+/*
+ * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
+ *
+ * This program is free software: you can use, redistribute, and/or modify
+ * it under the terms of the GNU Affero General Public License, version 3
+ * or later ("AGPL"), as published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+#include "os.h"
+#include "taoserror.h"
+#include "tglobal.h"
+#include "thttp.h"
+#include "transLog.h"
+#include "trpc.h"
+#include "tutil.h"
+#include "tversion.h"
+
+void initLogEnv() {
+  const char *  logDir = "/tmp/trans_cli";
+  const char *  defaultLogFileNamePrefix = "taoslog";
+  const int32_t maxLogFileNum = 10000;
+  tsAsyncLog = 0;
+  // idxDebugFlag = 143;
+  strcpy(tsLogDir, (char *)logDir);
+  taosRemoveDir(tsLogDir);
+  taosMkDir(tsLogDir);
+
+  if (taosInitLog(defaultLogFileNamePrefix, maxLogFileNum) < 0) {
+    printf("failed to open log file in directory:%s\n", tsLogDir);
+  }
+}
+typedef struct TThread {
+  TdThread thread;
+  int      idx;
+} TThread;
+
+void *proces(void *arg) {
+  char *monitor = "172.26.10.94";
+  while (1) {
+    int32_t len = 512;
+    char *  msg = taosMemoryCalloc(1, len);
+    memset(msg, 1, len);
+    int32_t code = taosSendHttpReport(monitor, "/crash", 6050, msg, 10, HTTP_FLAT);
+    taosMemoryFree(msg);
+    taosUsleep(100 * 10);
+  }
+}
+int main(int argc, char *argv[]) {
+  initLogEnv();
+  int32_t  numOfThreads = 16;
+  TThread *thread = taosMemoryCalloc(1, sizeof(TThread) * numOfThreads);
+
+  for (int i = 0; i < numOfThreads; i++) {
+    thread[i].idx = i;
+    taosThreadCreate(&(thread[i].thread), NULL, proces, (void *)&thread[i]);
+  }
+  while (1) {
+    taosMsleep(5000);
+  }
+
+  taosCloseLog();
+
+  return 0;
+}