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

Merge pull request #18563 from taosdata/feature/3.0_mhli 

refactor(sync): modify info log
This commit is contained in:
Shengliang Guan 2022-11-30 14:08:51 +08:00 committed by GitHub
parent d20d1e07a7 a8832e8814
commit 822aecea9f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
source/libs/sync/inc/syncInt.h
View File

@ -197,6 +197,7 @@ typedef struct SSyncNode {
int32_t configChangeNum; int32_t configChangeNum;
int32_t hbSlowNum; int32_t hbSlowNum;
int32_t hbrSlowNum; int32_t hbrSlowNum;
int32_t tmrRoutineNum;
bool isStart; bool isStart;

1
source/libs/sync/src/syncMain.c
View File

@ -1037,6 +1037,7 @@ SSyncNode* syncNodeOpen(SSyncInfo* pSyncInfo) {
pSyncNode->configChangeNum = 0; pSyncNode->configChangeNum = 0;
pSyncNode->hbSlowNum = 0; pSyncNode->hbSlowNum = 0;
pSyncNode->hbrSlowNum = 0; pSyncNode->hbrSlowNum = 0;
pSyncNode->tmrRoutineNum = 0;
sNTrace(pSyncNode, "sync open, node:%p", pSyncNode); sNTrace(pSyncNode, "sync open, node:%p", pSyncNode);

8
source/libs/sync/src/syncTimeout.c
View File

@ -52,7 +52,13 @@ static void syncNodeCleanConfigIndex(SSyncNode* ths) {
} }
static int32_t syncNodeTimerRoutine(SSyncNode* ths) { static int32_t syncNodeTimerRoutine(SSyncNode* ths) {
sNInfo(ths, "timer routines"); ths->tmrRoutineNum++;
if (ths->tmrRoutineNum % 60 == 0 && ths->replicaNum > 1) {
sNInfo(ths, "timer routines");
} else {
sNTrace(ths, "timer routines");
}
// timer replicate // timer replicate
syncNodeReplicate(ths); syncNodeReplicate(ths);