xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

add http test

This commit is contained in:
yihaoDeng 2023-11-22 20:24:08 +08:00
parent 40f6de4fc8
commit 557db1c3cc
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
source/libs/transport/test/http_test.c
View File

@ -26,7 +26,7 @@ void initLogEnv() {
const char * defaultLogFileNamePrefix = "taoslog"; const char * defaultLogFileNamePrefix = "taoslog";
const int32_t maxLogFileNum = 10000; const int32_t maxLogFileNum = 10000;
tsAsyncLog = 0; tsAsyncLog = 0;
// idxDebugFlag = 143; // rpcDebugflag = 143;
strcpy(tsLogDir, (char *)logDir); strcpy(tsLogDir, (char *)logDir);
taosRemoveDir(tsLogDir); taosRemoveDir(tsLogDir);
taosMkDir(tsLogDir); taosMkDir(tsLogDir);
@ -48,12 +48,12 @@ void *proces(void *arg) {
memset(msg, 1, len); memset(msg, 1, len);
int32_t code = taosSendHttpReport(monitor, "/crash", 6050, msg, 10, HTTP_FLAT); int32_t code = taosSendHttpReport(monitor, "/crash", 6050, msg, 10, HTTP_FLAT);
taosMemoryFree(msg); taosMemoryFree(msg);
taosUsleep(100 * 10); taosUsleep(10);
} }
} }
int main(int argc, char *argv[]) { int main(int argc, char *argv[]) {
initLogEnv(); initLogEnv();
int32_t numOfThreads = 16; int32_t numOfThreads = 3;
TThread *thread = taosMemoryCalloc(1, sizeof(TThread) * numOfThreads); TThread *thread = taosMemoryCalloc(1, sizeof(TThread) * numOfThreads);
for (int i = 0; i < numOfThreads; i++) { for (int i = 0; i < numOfThreads; i++) {