Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
taosdata
TDengine
提交
7e67dc03
T
TDengine
项目概览
taosdata
/
TDengine
大约 1 年 前同步成功
通知
1184
Star
22015
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看板
体验新版 GitCode,发现更多精彩内容 >>
提交
7e67dc03
编写于
12月 29, 2022
作者:
S
Shengliang Guan
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
refact: rename variables
上级
6e9b5d1b
变更
2
隐藏空白更改
内联
并排
Showing
2 changed file
with
79 addition
and
83 deletion
+79
-83
source/libs/sync/inc/syncIndexMgr.h
source/libs/sync/inc/syncIndexMgr.h
+18
-20
source/libs/sync/src/syncIndexMgr.c
source/libs/sync/src/syncIndexMgr.c
+61
-63
未找到文件。
source/libs/sync/inc/syncIndexMgr.h
浏览文件 @
7e67dc03
...
...
@@ -25,29 +25,27 @@ extern "C" {
// SIndexMgr -----------------------------
typedef
struct
SSyncIndexMgr
{
SRaftId
(
*
replicas
)[
TSDB_MAX_REPLICA
];
SyncIndex
index
[
TSDB_MAX_REPLICA
];
SyncTerm
privateTerm
[
TSDB_MAX_REPLICA
];
// for advanced function
int64_t
startTimeArr
[
TSDB_MAX_REPLICA
];
int64_t
recvTimeArr
[
TSDB_MAX_REPLICA
];
SyncIndex
index
[
TSDB_MAX_REPLICA
];
SyncTerm
privateTerm
[
TSDB_MAX_REPLICA
];
// for advanced function
int64_t
startTimeArr
[
TSDB_MAX_REPLICA
];
int64_t
recvTimeArr
[
TSDB_MAX_REPLICA
];
int32_t
replicaNum
;
SSyncNode
*
p
Sync
Node
;
SSyncNode
*
pNode
;
}
SSyncIndexMgr
;
SSyncIndexMgr
*
syncIndexMgrCreate
(
SSyncNode
*
p
Sync
Node
);
void
syncIndexMgrUpdate
(
SSyncIndexMgr
*
p
SyncIndexMgr
,
SSyncNode
*
pSync
Node
);
void
syncIndexMgrDestroy
(
SSyncIndexMgr
*
p
Sync
IndexMgr
);
void
syncIndexMgrClear
(
SSyncIndexMgr
*
p
Sync
IndexMgr
);
void
syncIndexMgrSetIndex
(
SSyncIndexMgr
*
p
Sync
IndexMgr
,
const
SRaftId
*
pRaftId
,
SyncIndex
index
);
SyncIndex
syncIndexMgrGetIndex
(
SSyncIndexMgr
*
p
Sync
IndexMgr
,
const
SRaftId
*
pRaftId
);
void
syncIndexMgrSetStartTime
(
SSyncIndexMgr
*
p
Sync
IndexMgr
,
const
SRaftId
*
pRaftId
,
int64_t
startTime
);
int64_t
syncIndexMgrGetStartTime
(
SSyncIndexMgr
*
p
Sync
IndexMgr
,
const
SRaftId
*
pRaftId
);
void
syncIndexMgrSetRecvTime
(
SSyncIndexMgr
*
p
Sync
IndexMgr
,
const
SRaftId
*
pRaftId
,
int64_t
recvTime
);
int64_t
syncIndexMgrGetRecvTime
(
SSyncIndexMgr
*
p
Sync
IndexMgr
,
const
SRaftId
*
pRaftId
);
void
syncIndexMgrSetTerm
(
SSyncIndexMgr
*
p
Sync
IndexMgr
,
const
SRaftId
*
pRaftId
,
SyncTerm
term
);
SyncTerm
syncIndexMgrGetTerm
(
SSyncIndexMgr
*
p
Sync
IndexMgr
,
const
SRaftId
*
pRaftId
);
SSyncIndexMgr
*
syncIndexMgrCreate
(
SSyncNode
*
pNode
);
void
syncIndexMgrUpdate
(
SSyncIndexMgr
*
p
IndexMgr
,
SSyncNode
*
p
Node
);
void
syncIndexMgrDestroy
(
SSyncIndexMgr
*
pIndexMgr
);
void
syncIndexMgrClear
(
SSyncIndexMgr
*
pIndexMgr
);
void
syncIndexMgrSetIndex
(
SSyncIndexMgr
*
pIndexMgr
,
const
SRaftId
*
pRaftId
,
SyncIndex
index
);
SyncIndex
syncIndexMgrGetIndex
(
SSyncIndexMgr
*
pIndexMgr
,
const
SRaftId
*
pRaftId
);
void
syncIndexMgrSetStartTime
(
SSyncIndexMgr
*
pIndexMgr
,
const
SRaftId
*
pRaftId
,
int64_t
startTime
);
int64_t
syncIndexMgrGetStartTime
(
SSyncIndexMgr
*
pIndexMgr
,
const
SRaftId
*
pRaftId
);
void
syncIndexMgrSetRecvTime
(
SSyncIndexMgr
*
pIndexMgr
,
const
SRaftId
*
pRaftId
,
int64_t
recvTime
);
int64_t
syncIndexMgrGetRecvTime
(
SSyncIndexMgr
*
pIndexMgr
,
const
SRaftId
*
pRaftId
);
void
syncIndexMgrSetTerm
(
SSyncIndexMgr
*
pIndexMgr
,
const
SRaftId
*
pRaftId
,
SyncTerm
term
);
SyncTerm
syncIndexMgrGetTerm
(
SSyncIndexMgr
*
pIndexMgr
,
const
SRaftId
*
pRaftId
);
#ifdef __cplusplus
}
...
...
source/libs/sync/src/syncIndexMgr.c
浏览文件 @
7e67dc03
...
...
@@ -17,56 +17,56 @@
#include "syncIndexMgr.h"
#include "syncUtil.h"
SSyncIndexMgr
*
syncIndexMgrCreate
(
SSyncNode
*
p
Sync
Node
)
{
SSyncIndexMgr
*
p
Sync
IndexMgr
=
taosMemoryCalloc
(
1
,
sizeof
(
SSyncIndexMgr
));
if
(
p
Sync
IndexMgr
==
NULL
)
{
SSyncIndexMgr
*
syncIndexMgrCreate
(
SSyncNode
*
pNode
)
{
SSyncIndexMgr
*
pIndexMgr
=
taosMemoryCalloc
(
1
,
sizeof
(
SSyncIndexMgr
));
if
(
pIndexMgr
==
NULL
)
{
terrno
=
TSDB_CODE_OUT_OF_MEMORY
;
return
NULL
;
}
p
SyncIndexMgr
->
replicas
=
&
(
pSync
Node
->
replicasId
);
p
SyncIndexMgr
->
replicaNum
=
pSync
Node
->
replicaNum
;
p
SyncIndexMgr
->
pSyncNode
=
pSync
Node
;
syncIndexMgrClear
(
p
Sync
IndexMgr
);
p
IndexMgr
->
replicas
=
&
(
p
Node
->
replicasId
);
p
IndexMgr
->
replicaNum
=
p
Node
->
replicaNum
;
p
IndexMgr
->
pNode
=
p
Node
;
syncIndexMgrClear
(
pIndexMgr
);
return
p
Sync
IndexMgr
;
return
pIndexMgr
;
}
void
syncIndexMgrUpdate
(
SSyncIndexMgr
*
p
SyncIndexMgr
,
SSyncNode
*
pSync
Node
)
{
p
SyncIndexMgr
->
replicas
=
&
(
pSync
Node
->
replicasId
);
p
SyncIndexMgr
->
replicaNum
=
pSync
Node
->
replicaNum
;
p
SyncIndexMgr
->
pSyncNode
=
pSync
Node
;
syncIndexMgrClear
(
p
Sync
IndexMgr
);
void
syncIndexMgrUpdate
(
SSyncIndexMgr
*
p
IndexMgr
,
SSyncNode
*
p
Node
)
{
p
IndexMgr
->
replicas
=
&
(
p
Node
->
replicasId
);
p
IndexMgr
->
replicaNum
=
p
Node
->
replicaNum
;
p
IndexMgr
->
pNode
=
p
Node
;
syncIndexMgrClear
(
pIndexMgr
);
}
void
syncIndexMgrDestroy
(
SSyncIndexMgr
*
p
Sync
IndexMgr
)
{
if
(
p
Sync
IndexMgr
!=
NULL
)
{
taosMemoryFree
(
p
Sync
IndexMgr
);
void
syncIndexMgrDestroy
(
SSyncIndexMgr
*
pIndexMgr
)
{
if
(
pIndexMgr
!=
NULL
)
{
taosMemoryFree
(
pIndexMgr
);
}
}
void
syncIndexMgrClear
(
SSyncIndexMgr
*
p
Sync
IndexMgr
)
{
memset
(
p
SyncIndexMgr
->
index
,
0
,
sizeof
(
pSync
IndexMgr
->
index
));
memset
(
p
SyncIndexMgr
->
privateTerm
,
0
,
sizeof
(
pSync
IndexMgr
->
privateTerm
));
void
syncIndexMgrClear
(
SSyncIndexMgr
*
pIndexMgr
)
{
memset
(
p
IndexMgr
->
index
,
0
,
sizeof
(
p
IndexMgr
->
index
));
memset
(
p
IndexMgr
->
privateTerm
,
0
,
sizeof
(
p
IndexMgr
->
privateTerm
));
// int64_t timeNow = taosGetMonotonicMs();
int64_t
timeNow
=
taosGetTimestampMs
();
for
(
int
i
=
0
;
i
<
p
Sync
IndexMgr
->
replicaNum
;
++
i
)
{
p
Sync
IndexMgr
->
startTimeArr
[
i
]
=
0
;
p
Sync
IndexMgr
->
recvTimeArr
[
i
]
=
timeNow
;
for
(
int
i
=
0
;
i
<
pIndexMgr
->
replicaNum
;
++
i
)
{
pIndexMgr
->
startTimeArr
[
i
]
=
0
;
pIndexMgr
->
recvTimeArr
[
i
]
=
timeNow
;
}
/*
for (int i = 0; i < p
Sync
IndexMgr->replicaNum; ++i) {
p
Sync
IndexMgr->index[i] = 0;
for (int i = 0; i < pIndexMgr->replicaNum; ++i) {
pIndexMgr->index[i] = 0;
}
*/
}
void
syncIndexMgrSetIndex
(
SSyncIndexMgr
*
p
Sync
IndexMgr
,
const
SRaftId
*
pRaftId
,
SyncIndex
index
)
{
for
(
int
i
=
0
;
i
<
p
Sync
IndexMgr
->
replicaNum
;
++
i
)
{
if
(
syncUtilSameId
(
&
((
*
(
p
Sync
IndexMgr
->
replicas
))[
i
]),
pRaftId
))
{
(
p
Sync
IndexMgr
->
index
)[
i
]
=
index
;
void
syncIndexMgrSetIndex
(
SSyncIndexMgr
*
pIndexMgr
,
const
SRaftId
*
pRaftId
,
SyncIndex
index
)
{
for
(
int
i
=
0
;
i
<
pIndexMgr
->
replicaNum
;
++
i
)
{
if
(
syncUtilSameId
(
&
((
*
(
pIndexMgr
->
replicas
))[
i
]),
pRaftId
))
{
(
pIndexMgr
->
index
)[
i
]
=
index
;
return
;
}
}
...
...
@@ -77,8 +77,7 @@ void syncIndexMgrSetIndex(SSyncIndexMgr *pSyncIndexMgr, const SRaftId *pRaftId,
char
host
[
128
];
uint16_t
port
;
syncUtilU642Addr
(
pRaftId
->
addr
,
host
,
sizeof
(
host
),
&
port
);
sError
(
"vgId:%d, index mgr set for %s:%d, index:%"
PRId64
" error"
,
pSyncIndexMgr
->
pSyncNode
->
vgId
,
host
,
port
,
index
);
sError
(
"vgId:%d, index mgr set for %s:%d, index:%"
PRId64
" error"
,
pIndexMgr
->
pNode
->
vgId
,
host
,
port
,
index
);
}
SSyncLogReplMgr
*
syncNodeGetLogReplMgr
(
SSyncNode
*
pNode
,
SRaftId
*
pDestId
)
{
...
...
@@ -90,14 +89,14 @@ SSyncLogReplMgr *syncNodeGetLogReplMgr(SSyncNode *pNode, SRaftId *pDestId) {
return
NULL
;
}
SyncIndex
syncIndexMgrGetIndex
(
SSyncIndexMgr
*
p
Sync
IndexMgr
,
const
SRaftId
*
pRaftId
)
{
if
(
p
Sync
IndexMgr
==
NULL
)
{
SyncIndex
syncIndexMgrGetIndex
(
SSyncIndexMgr
*
pIndexMgr
,
const
SRaftId
*
pRaftId
)
{
if
(
pIndexMgr
==
NULL
)
{
return
SYNC_INDEX_INVALID
;
}
for
(
int
i
=
0
;
i
<
p
Sync
IndexMgr
->
replicaNum
;
++
i
)
{
if
(
syncUtilSameId
(
&
((
*
(
p
Sync
IndexMgr
->
replicas
))[
i
]),
pRaftId
))
{
SyncIndex
idx
=
(
p
Sync
IndexMgr
->
index
)[
i
];
for
(
int
i
=
0
;
i
<
pIndexMgr
->
replicaNum
;
++
i
)
{
if
(
syncUtilSameId
(
&
((
*
(
pIndexMgr
->
replicas
))[
i
]),
pRaftId
))
{
SyncIndex
idx
=
(
pIndexMgr
->
index
)[
i
];
return
idx
;
}
}
...
...
@@ -105,10 +104,10 @@ SyncIndex syncIndexMgrGetIndex(SSyncIndexMgr *pSyncIndexMgr, const SRaftId *pRaf
return
SYNC_INDEX_INVALID
;
}
void
syncIndexMgrSetStartTime
(
SSyncIndexMgr
*
p
Sync
IndexMgr
,
const
SRaftId
*
pRaftId
,
int64_t
startTime
)
{
for
(
int
i
=
0
;
i
<
p
Sync
IndexMgr
->
replicaNum
;
++
i
)
{
if
(
syncUtilSameId
(
&
((
*
(
p
Sync
IndexMgr
->
replicas
))[
i
]),
pRaftId
))
{
(
p
Sync
IndexMgr
->
startTimeArr
)[
i
]
=
startTime
;
void
syncIndexMgrSetStartTime
(
SSyncIndexMgr
*
pIndexMgr
,
const
SRaftId
*
pRaftId
,
int64_t
startTime
)
{
for
(
int
i
=
0
;
i
<
pIndexMgr
->
replicaNum
;
++
i
)
{
if
(
syncUtilSameId
(
&
((
*
(
pIndexMgr
->
replicas
))[
i
]),
pRaftId
))
{
(
pIndexMgr
->
startTimeArr
)[
i
]
=
startTime
;
return
;
}
}
...
...
@@ -118,14 +117,14 @@ void syncIndexMgrSetStartTime(SSyncIndexMgr *pSyncIndexMgr, const SRaftId *pRaft
char
host
[
128
];
uint16_t
port
;
syncUtilU642Addr
(
pRaftId
->
addr
,
host
,
sizeof
(
host
),
&
port
);
sError
(
"vgId:%d, index mgr set for %s:%d, start-time:%"
PRId64
" error"
,
p
SyncIndexMgr
->
pSync
Node
->
vgId
,
host
,
port
,
sError
(
"vgId:%d, index mgr set for %s:%d, start-time:%"
PRId64
" error"
,
p
IndexMgr
->
p
Node
->
vgId
,
host
,
port
,
startTime
);
}
int64_t
syncIndexMgrGetStartTime
(
SSyncIndexMgr
*
p
Sync
IndexMgr
,
const
SRaftId
*
pRaftId
)
{
for
(
int
i
=
0
;
i
<
p
Sync
IndexMgr
->
replicaNum
;
++
i
)
{
if
(
syncUtilSameId
(
&
((
*
(
p
Sync
IndexMgr
->
replicas
))[
i
]),
pRaftId
))
{
int64_t
startTime
=
(
p
Sync
IndexMgr
->
startTimeArr
)[
i
];
int64_t
syncIndexMgrGetStartTime
(
SSyncIndexMgr
*
pIndexMgr
,
const
SRaftId
*
pRaftId
)
{
for
(
int
i
=
0
;
i
<
pIndexMgr
->
replicaNum
;
++
i
)
{
if
(
syncUtilSameId
(
&
((
*
(
pIndexMgr
->
replicas
))[
i
]),
pRaftId
))
{
int64_t
startTime
=
(
pIndexMgr
->
startTimeArr
)[
i
];
return
startTime
;
}
}
...
...
@@ -133,10 +132,10 @@ int64_t syncIndexMgrGetStartTime(SSyncIndexMgr *pSyncIndexMgr, const SRaftId *pR
return
-
1
;
}
void
syncIndexMgrSetRecvTime
(
SSyncIndexMgr
*
p
Sync
IndexMgr
,
const
SRaftId
*
pRaftId
,
int64_t
recvTime
)
{
for
(
int
i
=
0
;
i
<
p
Sync
IndexMgr
->
replicaNum
;
++
i
)
{
if
(
syncUtilSameId
(
&
((
*
(
p
Sync
IndexMgr
->
replicas
))[
i
]),
pRaftId
))
{
(
p
Sync
IndexMgr
->
recvTimeArr
)[
i
]
=
recvTime
;
void
syncIndexMgrSetRecvTime
(
SSyncIndexMgr
*
pIndexMgr
,
const
SRaftId
*
pRaftId
,
int64_t
recvTime
)
{
for
(
int
i
=
0
;
i
<
pIndexMgr
->
replicaNum
;
++
i
)
{
if
(
syncUtilSameId
(
&
((
*
(
pIndexMgr
->
replicas
))[
i
]),
pRaftId
))
{
(
pIndexMgr
->
recvTimeArr
)[
i
]
=
recvTime
;
return
;
}
}
...
...
@@ -146,14 +145,13 @@ void syncIndexMgrSetRecvTime(SSyncIndexMgr *pSyncIndexMgr, const SRaftId *pRaftI
char
host
[
128
];
uint16_t
port
;
syncUtilU642Addr
(
pRaftId
->
addr
,
host
,
sizeof
(
host
),
&
port
);
sError
(
"vgId:%d, index mgr set for %s:%d, recv-time:%"
PRId64
" error"
,
pSyncIndexMgr
->
pSyncNode
->
vgId
,
host
,
port
,
recvTime
);
sError
(
"vgId:%d, index mgr set for %s:%d, recv-time:%"
PRId64
" error"
,
pIndexMgr
->
pNode
->
vgId
,
host
,
port
,
recvTime
);
}
int64_t
syncIndexMgrGetRecvTime
(
SSyncIndexMgr
*
p
Sync
IndexMgr
,
const
SRaftId
*
pRaftId
)
{
for
(
int
i
=
0
;
i
<
p
Sync
IndexMgr
->
replicaNum
;
++
i
)
{
if
(
syncUtilSameId
(
&
((
*
(
p
Sync
IndexMgr
->
replicas
))[
i
]),
pRaftId
))
{
int64_t
recvTime
=
(
p
Sync
IndexMgr
->
recvTimeArr
)[
i
];
int64_t
syncIndexMgrGetRecvTime
(
SSyncIndexMgr
*
pIndexMgr
,
const
SRaftId
*
pRaftId
)
{
for
(
int
i
=
0
;
i
<
pIndexMgr
->
replicaNum
;
++
i
)
{
if
(
syncUtilSameId
(
&
((
*
(
pIndexMgr
->
replicas
))[
i
]),
pRaftId
))
{
int64_t
recvTime
=
(
pIndexMgr
->
recvTimeArr
)[
i
];
return
recvTime
;
}
}
...
...
@@ -161,10 +159,10 @@ int64_t syncIndexMgrGetRecvTime(SSyncIndexMgr *pSyncIndexMgr, const SRaftId *pRa
return
-
1
;
}
void
syncIndexMgrSetTerm
(
SSyncIndexMgr
*
p
Sync
IndexMgr
,
const
SRaftId
*
pRaftId
,
SyncTerm
term
)
{
for
(
int
i
=
0
;
i
<
p
Sync
IndexMgr
->
replicaNum
;
++
i
)
{
if
(
syncUtilSameId
(
&
((
*
(
p
Sync
IndexMgr
->
replicas
))[
i
]),
pRaftId
))
{
(
p
Sync
IndexMgr
->
privateTerm
)[
i
]
=
term
;
void
syncIndexMgrSetTerm
(
SSyncIndexMgr
*
pIndexMgr
,
const
SRaftId
*
pRaftId
,
SyncTerm
term
)
{
for
(
int
i
=
0
;
i
<
pIndexMgr
->
replicaNum
;
++
i
)
{
if
(
syncUtilSameId
(
&
((
*
(
pIndexMgr
->
replicas
))[
i
]),
pRaftId
))
{
(
pIndexMgr
->
privateTerm
)[
i
]
=
term
;
return
;
}
}
...
...
@@ -174,13 +172,13 @@ void syncIndexMgrSetTerm(SSyncIndexMgr *pSyncIndexMgr, const SRaftId *pRaftId, S
char
host
[
128
];
uint16_t
port
;
syncUtilU642Addr
(
pRaftId
->
addr
,
host
,
sizeof
(
host
),
&
port
);
sError
(
"vgId:%d, index mgr set for %s:%d, term:%"
PRIu64
" error"
,
p
SyncIndexMgr
->
pSync
Node
->
vgId
,
host
,
port
,
term
);
sError
(
"vgId:%d, index mgr set for %s:%d, term:%"
PRIu64
" error"
,
p
IndexMgr
->
p
Node
->
vgId
,
host
,
port
,
term
);
}
SyncTerm
syncIndexMgrGetTerm
(
SSyncIndexMgr
*
p
Sync
IndexMgr
,
const
SRaftId
*
pRaftId
)
{
for
(
int
i
=
0
;
i
<
p
Sync
IndexMgr
->
replicaNum
;
++
i
)
{
if
(
syncUtilSameId
(
&
((
*
(
p
Sync
IndexMgr
->
replicas
))[
i
]),
pRaftId
))
{
SyncTerm
term
=
(
p
Sync
IndexMgr
->
privateTerm
)[
i
];
SyncTerm
syncIndexMgrGetTerm
(
SSyncIndexMgr
*
pIndexMgr
,
const
SRaftId
*
pRaftId
)
{
for
(
int
i
=
0
;
i
<
pIndexMgr
->
replicaNum
;
++
i
)
{
if
(
syncUtilSameId
(
&
((
*
(
pIndexMgr
->
replicas
))[
i
]),
pRaftId
))
{
SyncTerm
term
=
(
pIndexMgr
->
privateTerm
)[
i
];
return
term
;
}
}
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录