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

update test case

This commit is contained in:
yihaoDeng 2024-12-15 11:46:03 +08:00
parent f09b6d6c53
commit 820d8cd454
1 changed files with 20 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -500,7 +500,7 @@ TEST_F(TransEnv, queryExcept) {
TEST_F(TransEnv, idTest) { TEST_F(TransEnv, idTest) {
SRpcMsg resp = {0}; SRpcMsg resp = {0};
SRpcMsg req = {0}; SRpcMsg req = {0};
for (int i = 0; i < 50000; i++) { for (int i = 0; i < 500; i++) {
memset(&req, 0, sizeof(req)); memset(&req, 0, sizeof(req));
req.info.noResp = 0; req.info.noResp = 0;
req.msgType = 3; req.msgType = 3;
@ -516,7 +516,7 @@ TEST_F(TransEnv, idTest) {
TEST_F(TransEnv, noResp) { TEST_F(TransEnv, noResp) {
SRpcMsg resp = {0}; SRpcMsg resp = {0};
SRpcMsg req = {0}; SRpcMsg req = {0};
for (int i = 0; i < 500000; i++) { for (int i = 0; i < 500; i++) {
memset(&req, 0, sizeof(req)); memset(&req, 0, sizeof(req));
req.info.noResp = 0; req.info.noResp = 0;
req.msgType = 3; req.msgType = 3;
@ -530,10 +530,26 @@ TEST_F(TransEnv, noResp) {
} }
TEST_F(TransEnv, http) { 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);
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);
printf("old addr:%s new addr:%s\n",mgt.defaultAddr, mgt.cachedAddr);
taosMsleep(10000);
}
taosTelemetryDestroy(&mgt);
}
{
STelemAddrMgmt mgt;
taosTelemetryMgtInit(&mgt, "error");
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); code = taosSendTelemReport(&mgt,tsTelemUri, tsTelemPort, "test", strlen("test"),HTTP_FLAT);
for (int32_t i = 0; i < 10; i++) { for (int32_t i = 0; i < 10; i++) {
@ -541,6 +557,7 @@ TEST_F(TransEnv, http) {
taosMsleep(10000); taosMsleep(10000);
} }
taosTelemetryDestroy(&mgt); taosTelemetryDestroy(&mgt);
}
} }