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 12:52:07 +08:00
parent 19db047e37
commit cf2b2ba9c8
1 changed files with 72 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -23,6 +23,7 @@
#include "trpc.h" #include "trpc.h"
#include "tversion.h" #include "tversion.h"
#include "thttp.h" #include "thttp.h"
#include "tjson.h"
using namespace std; using namespace std;
const char *label = "APP"; const char *label = "APP";
@ -500,7 +501,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 < 500; i++) { for (int i = 0; i < 500i00; 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 +517,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 < 500; i++) { for (int i = 0; i < 50000; 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,35 +531,88 @@ TEST_F(TransEnv, noResp) {
} }
TEST_F(TransEnv, http) { TEST_F(TransEnv, http) {
int32_t code = 0;
char tmp[4096] = {0};
int32_t lino = 0;
SJson* pJson = tjsonCreateObject();
char clusterName[64] = {0};
tjsonAddStringToObject(pJson, "instanceId", clusterName);
tjsonAddDoubleToObject(pJson, "reportVersion", 1);
if (taosGetOsReleaseName(tmp, NULL, NULL, sizeof(tmp)) == 0) {
tjsonAddStringToObject(pJson, "os", tmp);
}
char *pCont = NULL;
int32_t len = 0;
float numOfCores = 0;
if (taosGetCpuInfo(tmp, sizeof(tmp), &numOfCores) == 0) {
TAOS_CHECK_GOTO(tjsonAddStringToObject(pJson, "cpuModel", tmp), &lino, _OVER);
TAOS_CHECK_GOTO(tjsonAddDoubleToObject(pJson, "numOfCpu", numOfCores), &lino, _OVER);
} else {
TAOS_CHECK_GOTO(tjsonAddDoubleToObject(pJson, "numOfCpu", tsNumOfCores), &lino, _OVER);
}
snprintf(tmp, sizeof(tmp), "%" PRId64 " kB", tsTotalMemoryKB);
TAOS_CHECK_GOTO(tjsonAddStringToObject(pJson, "memory", tmp), &lino, _OVER);
TAOS_CHECK_GOTO(tjsonAddStringToObject(pJson, "version", td_version), &lino, _OVER);
TAOS_CHECK_GOTO(tjsonAddStringToObject(pJson, "buildInfo", td_buildinfo), &lino, _OVER);
TAOS_CHECK_GOTO(tjsonAddStringToObject(pJson, "gitInfo", td_gitinfo), &lino, _OVER);
TAOS_CHECK_GOTO(tjsonAddStringToObject(pJson, "email", "test126.com"), &lino, _OVER);
TAOS_CHECK_GOTO(tjsonAddDoubleToObject(pJson, "numOfDnode",1 ), &lino, _OVER);
TAOS_CHECK_GOTO(tjsonAddDoubleToObject(pJson, "numOfMnode", 1), &lino, _OVER);
TAOS_CHECK_GOTO(tjsonAddDoubleToObject(pJson, "numOfVgroup", 1), &lino, _OVER);
TAOS_CHECK_GOTO(tjsonAddDoubleToObject(pJson, "numOfDatabase", 1), &lino, _OVER);
TAOS_CHECK_GOTO(tjsonAddDoubleToObject(pJson, "numOfSuperTable", 1), &lino, _OVER);
TAOS_CHECK_GOTO(tjsonAddDoubleToObject(pJson, "numOfChildTable", 1), &lino, _OVER);
TAOS_CHECK_GOTO(tjsonAddDoubleToObject(pJson, "numOfColumn", 1), &lino, _OVER);
TAOS_CHECK_GOTO(tjsonAddDoubleToObject(pJson, "numOfPoint", 1), &lino, _OVER);
TAOS_CHECK_GOTO(tjsonAddDoubleToObject(pJson, "totalStorage", 1), &lino, _OVER);
TAOS_CHECK_GOTO(tjsonAddDoubleToObject(pJson, "compStorage", 1), &lino, _OVER);
pCont = tjsonToString(pJson);
len = strlen(pCont);
tjsonDelete(pJson);
{ {
#if 0
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, pCont, len,HTTP_FLAT);
taosMsleep(10000); taosMsleep(2000);
code = taosSendTelemReport(&mgt,tsTelemUri, tsTelemPort, "test", strlen("test"),HTTP_FLAT); code = taosSendTelemReport(&mgt,tsTelemUri, tsTelemPort, pCont, len,HTTP_FLAT);
printf("old addr:%s new addr:%s\n",mgt.defaultAddr, mgt.cachedAddr);
for (int32_t i = 0; i < 10; i++) { for (int32_t i = 0; i < 10; i++) {
code = taosSendTelemReport(&mgt,tsTelemUri, tsTelemPort, "test", strlen("test"),HTTP_FLAT); code = taosSendTelemReport(&mgt,tsTelemUri, tsTelemPort, pCont, len,HTTP_FLAT);
printf("old addr:%s new addr:%s\n",mgt.defaultAddr, mgt.cachedAddr); printf("old addr:%s new addr:%s\n",mgt.defaultAddr, mgt.cachedAddr);
taosMsleep(10000); taosMsleep(2000);
} }
taosTelemetryDestroy(&mgt); taosTelemetryDestroy(&mgt);
#endif
} }
{ {
#if 0
STelemAddrMgmt mgt; STelemAddrMgmt mgt;
taosTelemetryMgtInit(&mgt, "telemetry.taosdata.com"); taosTelemetryMgtInit(&mgt, "telemetry.taosdata.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); printf("old addr:%s new addr:%s\n",mgt.defaultAddr, mgt.cachedAddr);
taosMsleep(10000);
taosMsleep(2000);
code = taosSendTelemReport(&mgt,tsTelemUri, tsTelemPort, pCont, len,HTTP_FLAT);
for (int32_t i = 0; i < 10; i++) {
code = taosSendTelemReport(&mgt,tsTelemUri, tsTelemPort, pCont, len,HTTP_FLAT);
printf("old addr:%s new addr:%s\n",mgt.defaultAddr, mgt.cachedAddr);
taosMsleep(2000);
} }
taosTelemetryDestroy(&mgt); taosTelemetryDestroy(&mgt);
#endif
} }
{ {
@ -566,14 +620,16 @@ TEST_F(TransEnv, http) {
taosTelemetryMgtInit(&mgt, "error"); taosTelemetryMgtInit(&mgt, "error");
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(2000);
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++) {
code = taosSendTelemReport(&mgt,tsTelemUri, tsTelemPort, "test", strlen("test"),HTTP_FLAT); code = taosSendTelemReport(&mgt,tsTelemUri, tsTelemPort, "test", strlen("test"),HTTP_FLAT);
taosMsleep(10000); taosMsleep(2000);
} }
taosTelemetryDestroy(&mgt); taosTelemetryDestroy(&mgt);
} }
_OVER:
return;
} }