提交 6cf5becd 编写于 作者: wmmhello's avatar wmmhello

[TD-5838]<feature> add function of speed test

上级 8017ce03
...@@ -570,11 +570,14 @@ static void taosNetTestSpeed(char *host, int32_t port, int32_t pkgLen, ...@@ -570,11 +570,14 @@ static void taosNetTestSpeed(char *host, int32_t port, int32_t pkgLen,
// record config // record config
int32_t compressTmp = tsCompressMsgSize; int32_t compressTmp = tsCompressMsgSize;
int32_t maxUdpSize = tsRpcMaxUdpSize; int32_t maxUdpSize = tsRpcMaxUdpSize;
int32_t forceTcp = tsRpcForceTcp;
tsCompressMsgSize = -1; tsCompressMsgSize = -1;
if (0 == strcmp("TCP", pkgType)){ if (0 == strcmp("TCP", pkgType)){
tsRpcForceTcp = 1;
tsRpcMaxUdpSize = 0; // force tcp tsRpcMaxUdpSize = 0; // force tcp
} else { } else {
tsRpcForceTcp = 0;
tsRpcMaxUdpSize = INT_MAX; tsRpcMaxUdpSize = INT_MAX;
} }
...@@ -622,6 +625,7 @@ static void taosNetTestSpeed(char *host, int32_t port, int32_t pkgLen, ...@@ -622,6 +625,7 @@ static void taosNetTestSpeed(char *host, int32_t port, int32_t pkgLen,
// return config // return config
tsCompressMsgSize = compressTmp; tsCompressMsgSize = compressTmp;
tsRpcMaxUdpSize = maxUdpSize; tsRpcMaxUdpSize = maxUdpSize;
tsRpcForceTcp = forceTcp;
} }
void taosNetTest(char *role, char *host, int32_t port, int32_t pkgLen, void taosNetTest(char *role, char *host, int32_t port, int32_t pkgLen,
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册