refactor(sync): adjust elect timer
This commit is contained in:
parent
96a8a80cd7
commit
9caea0f944
|
@ -2802,6 +2802,7 @@ static void syncNodeEqElectTimer(void* param, void* tmrId) {
|
||||||
}
|
}
|
||||||
syncTimeoutDestroy(pSyncMsg);
|
syncTimeoutDestroy(pSyncMsg);
|
||||||
|
|
||||||
|
#if 0
|
||||||
// reset timer ms
|
// reset timer ms
|
||||||
if (syncEnvIsStart() && pSyncNode->electBaseLine > 0) {
|
if (syncEnvIsStart() && pSyncNode->electBaseLine > 0) {
|
||||||
pSyncNode->electTimerMS = syncUtilElectRandomMS(pSyncNode->electBaseLine, 2 * pSyncNode->electBaseLine);
|
pSyncNode->electTimerMS = syncUtilElectRandomMS(pSyncNode->electBaseLine, 2 * pSyncNode->electBaseLine);
|
||||||
|
@ -2810,6 +2811,7 @@ static void syncNodeEqElectTimer(void* param, void* tmrId) {
|
||||||
} else {
|
} else {
|
||||||
sError("sync env is stop, syncNodeEqElectTimer");
|
sError("sync env is stop, syncNodeEqElectTimer");
|
||||||
}
|
}
|
||||||
|
#endif
|
||||||
}
|
}
|
||||||
|
|
||||||
static void syncNodeEqHeartbeatTimer(void* param, void* tmrId) {
|
static void syncNodeEqHeartbeatTimer(void* param, void* tmrId) {
|
||||||
|
|
Loading…
Reference in New Issue