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

refactor(sync): make leader life longer

This commit is contained in:
Minghao Li 2022-08-06 21:41:03 +08:00
parent f8b0c98a71
commit 2f1bf1eba9
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
source/libs/sync/src/syncAppendEntries.c
View File

@ -570,7 +570,7 @@ int32_t syncNodeOnAppendEntriesSnapshot2Cb(SSyncNode* ths, SyncAppendEntriesBatc
// append entry batch // append entry batch
if (pass == 0) { if (pass == 0) {
// assert! no batch // assert! no batch
ASSERT(pMsg->dataCount == 1); ASSERT(pMsg->dataCount <= 1);
for (int32_t i = 0; i < pMsg->dataCount; ++i) { for (int32_t i = 0; i < pMsg->dataCount; ++i) {
SSyncRaftEntry* pAppendEntry = (SSyncRaftEntry*)(pMsg->data + metaTableArr[i].offset); SSyncRaftEntry* pAppendEntry = (SSyncRaftEntry*)(pMsg->data + metaTableArr[i].offset);
@ -698,7 +698,7 @@ int32_t syncNodeOnAppendEntriesSnapshot2Cb(SSyncNode* ths, SyncAppendEntriesBatc
// append entry batch // append entry batch
if (pass == 0) { if (pass == 0) {
// assert! no batch // assert! no batch
ASSERT(pMsg->dataCount == 1); ASSERT(pMsg->dataCount <= 1);
// append entry batch // append entry batch
for (int32_t i = 0; i < pMsg->dataCount; ++i) { for (int32_t i = 0; i < pMsg->dataCount; ++i) {