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

feat[client]: update retryWaitTime minValue

This commit is contained in:
yihaoDeng 2025-03-05 09:51:29 +08:00
parent 542f54297d
commit b1b4bc806e
1 changed files with 9 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
source/client/src/clientEnv.c
View File

@ -27,6 +27,7 @@
#include "scheduler.h" #include "scheduler.h"
#include "tcache.h" #include "tcache.h"
#include "tcompare.h" #include "tcompare.h"
#include "tconv.h"
#include "tglobal.h" #include "tglobal.h"
#include "thttp.h" #include "thttp.h"
#include "tmsg.h" #include "tmsg.h"
@ -36,7 +37,6 @@
#include "tsched.h" #include "tsched.h"
#include "ttime.h" #include "ttime.h"
#include "tversion.h" #include "tversion.h"
#include "tconv.h"
#include "cus_name.h" #include "cus_name.h"
@ -63,13 +63,13 @@
} \ } \
} while (0) } while (0)
STscDbg tscDbg = {0}; STscDbg tscDbg = {0};
SAppInfo appInfo; SAppInfo appInfo;
int64_t lastClusterId = 0; int64_t lastClusterId = 0;
int32_t clientReqRefPool = -1; int32_t clientReqRefPool = -1;
int32_t clientConnRefPool = -1; int32_t clientConnRefPool = -1;
int32_t clientStop = -1; int32_t clientStop = -1;
SHashObj* pTimezoneMap = NULL; SHashObj *pTimezoneMap = NULL;
int32_t timestampDeltaLimit = 900; // s int32_t timestampDeltaLimit = 900; // s
@ -380,7 +380,6 @@ int32_t openTransporter(const char *user, const char *auth, int32_t numOfThread,
tscError("invalid version string."); tscError("invalid version string.");
return code; return code;
} }
*pDnodeConn = rpcOpen(&rpcInit); *pDnodeConn = rpcOpen(&rpcInit);
if (*pDnodeConn == NULL) { if (*pDnodeConn == NULL) {
tscError("failed to init connection to server since %s", tstrerror(terrno)); tscError("failed to init connection to server since %s", tstrerror(terrno));
@ -968,7 +967,7 @@ void taos_init_imp(void) {
ENV_ERR_RET(taosInitCfg(configDir, NULL, NULL, NULL, NULL, 1), "failed to init cfg"); ENV_ERR_RET(taosInitCfg(configDir, NULL, NULL, NULL, NULL, 1), "failed to init cfg");
initQueryModuleMsgHandle(); initQueryModuleMsgHandle();
if ((tsCharsetCxt = taosConvInit(tsCharset)) == NULL){ if ((tsCharsetCxt = taosConvInit(tsCharset)) == NULL) {
tscInitRes = terrno; tscInitRes = terrno;
tscError("failed to init conv"); tscError("failed to init conv");
return; return;