提交 56253aed 编写于 作者: M Minghao Li

refactor: snapshotReSend

上级 5f0d2342
......@@ -116,6 +116,7 @@ void snapshotSenderStart(SSyncSnapshotSender *pSender) {
// start again
snapshotSenderDoStart(pSender);
pSender->start = true;
} else {
// current term, do nothing
ASSERT(pSender->pSyncNode->pRaftStore->currentTerm == pSender->term);
......@@ -297,6 +298,7 @@ void snapshotReceiverStart(SSyncSnapshotReceiver *pReceiver) {
if (!(pReceiver->start)) {
// start
snapshotReceiverDoStart(pReceiver);
pReceiver->start = true;
} else {
// already start
......@@ -309,6 +311,7 @@ void snapshotReceiverStart(SSyncSnapshotReceiver *pReceiver) {
// start again
snapshotReceiverDoStart(pReceiver);
pReceiver->start = true;
ASSERT(0);
}
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册