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

telemetry refactor

This commit is contained in:
yihaoDeng 2024-12-14 21:37:45 +08:00
parent cd4f92ebf2
commit f09b6d6c53
2 changed files with 12 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
source/libs/transport/src/thttp.c
View File

@ -859,7 +859,11 @@ int32_t taosSendRecvHttpReportWithQID(const char* server, const char* uri, uint1
static void transHttpDestroyHandle(void* handle) { taosMemoryFree(handle); } static void transHttpDestroyHandle(void* handle) { taosMemoryFree(handle); }
static void transHttpDestroyRecvHandle(void* handle) { taosMemoryFree(handle); } static void transHttpDestroyRecvHandle(void* handle) {
SHttpRecvBuf* p = handle;
taosMemoryFree(p->pBuf);
taosMemoryFree(p);
}
int64_t transInitHttpChanImpl(); int64_t transInitHttpChanImpl();

7
source/libs/transport/test/transUT2.cpp
View File

@ -533,7 +533,14 @@ TEST_F(TransEnv, http) {
STelemAddrMgmt mgt; STelemAddrMgmt mgt;
taosTelemetryMgtInit(&mgt, "telemetry.tdengine.com"); taosTelemetryMgtInit(&mgt, "telemetry.tdengine.com");
int32_t code = taosSendTelemReport(&mgt,tsTelemUri, tsTelemPort, "test", strlen("test"),HTTP_FLAT); int32_t code = taosSendTelemReport(&mgt,tsTelemUri, tsTelemPort, "test", strlen("test"),HTTP_FLAT);
taosMsleep(10000); taosMsleep(10000);
code = taosSendTelemReport(&mgt,tsTelemUri, tsTelemPort, "test", strlen("test"),HTTP_FLAT);
for (int32_t i = 0; i < 10; i++) {
code = taosSendTelemReport(&mgt,tsTelemUri, tsTelemPort, "test", strlen("test"),HTTP_FLAT);
taosMsleep(10000);
}
taosTelemetryDestroy(&mgt); taosTelemetryDestroy(&mgt);
} }