Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
taosdata
TDengine
提交
cfb5247e
T
TDengine
项目概览
taosdata
/
TDengine
1 年多 前同步成功
通知
1185
Star
22016
Fork
4786
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
1
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
T
TDengine
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
1
Issue
1
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
提交
cfb5247e
编写于
8月 09, 2023
作者:
dengyihao
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
change var name
上级
bcc7df2d
变更
6
隐藏空白更改
内联
并排
Showing
6 changed file
with
8 addition
and
8 deletion
+8
-8
include/libs/transport/trpc.h
include/libs/transport/trpc.h
+1
-1
source/client/src/clientEnv.c
source/client/src/clientEnv.c
+1
-1
source/dnode/mgmt/node_mgmt/src/dmTransport.c
source/dnode/mgmt/node_mgmt/src/dmTransport.c
+1
-1
source/libs/transport/inc/transportInt.h
source/libs/transport/inc/transportInt.h
+3
-3
source/libs/transport/src/trans.c
source/libs/transport/src/trans.c
+1
-1
source/libs/transport/src/transCli.c
source/libs/transport/src/transCli.c
+1
-1
未找到文件。
include/libs/transport/trpc.h
浏览文件 @
cfb5247e
...
...
@@ -89,7 +89,7 @@ typedef struct SRpcInit {
int32_t
retryMinInterval
;
// retry init interval
int32_t
retryStepFactor
;
// retry interval factor
int32_t
retryMaxInterval
;
// retry max interval
int64_t
retryMaxTim
oue
t
;
int64_t
retryMaxTim
eou
t
;
int32_t
failFastThreshold
;
int32_t
failFastInterval
;
...
...
source/client/src/clientEnv.c
浏览文件 @
cfb5247e
...
...
@@ -169,7 +169,7 @@ void *openTransporter(const char *user, const char *auth, int32_t numOfThread) {
rpcInit
.
retryMinInterval
=
tsRedirectPeriod
;
rpcInit
.
retryStepFactor
=
tsRedirectFactor
;
rpcInit
.
retryMaxInterval
=
tsRedirectMaxPeriod
;
rpcInit
.
retryMaxTim
oue
t
=
tsMaxRetryWaitTime
;
rpcInit
.
retryMaxTim
eou
t
=
tsMaxRetryWaitTime
;
int32_t
connLimitNum
=
tsNumOfRpcSessions
/
(
tsNumOfRpcThreads
*
3
);
connLimitNum
=
TMAX
(
connLimitNum
,
10
);
...
...
source/dnode/mgmt/node_mgmt/src/dmTransport.c
浏览文件 @
cfb5247e
...
...
@@ -299,7 +299,7 @@ int32_t dmInitClient(SDnode *pDnode) {
rpcInit
.
retryMinInterval
=
tsRedirectPeriod
;
rpcInit
.
retryStepFactor
=
tsRedirectFactor
;
rpcInit
.
retryMaxInterval
=
tsRedirectMaxPeriod
;
rpcInit
.
retryMaxTim
oue
t
=
tsMaxRetryWaitTime
;
rpcInit
.
retryMaxTim
eou
t
=
tsMaxRetryWaitTime
;
rpcInit
.
failFastInterval
=
5000
;
// interval threshold(ms)
rpcInit
.
failFastThreshold
=
3
;
// failed threshold
...
...
source/libs/transport/inc/transportInt.h
浏览文件 @
cfb5247e
...
...
@@ -46,14 +46,14 @@ typedef struct {
int8_t
connType
;
char
label
[
TSDB_LABEL_LEN
];
char
user
[
TSDB_UNI_LEN
];
// meter ID
int32_t
compatibilityVer
;
int32_t
compatibilityVer
;
int32_t
compressSize
;
// -1: no compress, 0 : all data compressed, size: compress data if larger than size
int8_t
encryption
;
// encrypt or not
int32_t
retryMinInterval
;
// retry init interval
int32_t
retryStepFactor
;
// retry interval factor
int32_t
retryMaxInterval
;
// retry max interval
int32_t
retryMaxTim
oue
t
;
int32_t
retryMaxTim
eou
t
;
int32_t
failFastThreshold
;
int32_t
failFastInterval
;
...
...
source/libs/transport/src/trans.c
浏览文件 @
cfb5247e
...
...
@@ -55,7 +55,7 @@ void* rpcOpen(const SRpcInit* pInit) {
pRpc
->
retryMinInterval
=
pInit
->
retryMinInterval
;
// retry init interval
pRpc
->
retryStepFactor
=
pInit
->
retryStepFactor
;
pRpc
->
retryMaxInterval
=
pInit
->
retryMaxInterval
;
pRpc
->
retryMaxTim
ouet
=
pInit
->
retryMaxTimoue
t
;
pRpc
->
retryMaxTim
eout
=
pInit
->
retryMaxTimeou
t
;
pRpc
->
failFastThreshold
=
pInit
->
failFastThreshold
;
pRpc
->
failFastInterval
=
pInit
->
failFastInterval
;
...
...
source/libs/transport/src/transCli.c
浏览文件 @
cfb5247e
...
...
@@ -2287,7 +2287,7 @@ bool cliGenRetryRule(SCliConn* pConn, STransMsg* pResp, SCliMsg* pMsg) {
pCtx
->
retryMinInterval
=
pTransInst
->
retryMinInterval
;
pCtx
->
retryMaxInterval
=
pTransInst
->
retryMaxInterval
;
pCtx
->
retryStepFactor
=
pTransInst
->
retryStepFactor
;
pCtx
->
retryMaxTimeout
=
pTransInst
->
retryMaxTim
oue
t
;
pCtx
->
retryMaxTimeout
=
pTransInst
->
retryMaxTim
eou
t
;
pCtx
->
retryInitTimestamp
=
taosGetTimestampMs
();
pCtx
->
retryNextInterval
=
pCtx
->
retryMinInterval
;
pCtx
->
retryStep
=
0
;
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录