提交 96e70c27 编写于 作者: B Benguang Zhao

enh: update logging msg in vnodeRestoreFinish

上级 5e53b122
...@@ -529,13 +529,12 @@ static void vnodeRestoreFinish(const SSyncFSM *pFsm, const SyncIndex commitIdx) ...@@ -529,13 +529,12 @@ static void vnodeRestoreFinish(const SSyncFSM *pFsm, const SyncIndex commitIdx)
appliedIdx = vnodeSyncAppliedIndex(pFsm); appliedIdx = vnodeSyncAppliedIndex(pFsm);
ASSERT(appliedIdx <= commitIdx); ASSERT(appliedIdx <= commitIdx);
if (appliedIdx == commitIdx) { if (appliedIdx == commitIdx) {
vInfo("vgId:%d, no more items to be applied, restore finish", pVnode->config.vgId); vInfo("vgId:%d, no items to be applied, restore finish", pVnode->config.vgId);
break; break;
} else { } else {
int32_t itemSize = tmsgGetQueueSize(&pVnode->msgCb, pVnode->config.vgId, APPLY_QUEUE); vInfo("vgId:%d, restore not finish since %" PRId64 " items to be applied. commit-index:%" PRId64
vInfo("vgId:%d, restore not finish since %" PRId64 ", applied-index:%" PRId64,
" items to be applied, and %d in apply queue. commit-index:%" PRId64 ", applied-index:%" PRId64, pVnode->config.vgId, commitIdx - appliedIdx, commitIdx, appliedIdx);
pVnode->config.vgId, commitIdx - appliedIdx, itemSize, commitIdx, appliedIdx);
taosMsleep(10); taosMsleep(10);
} }
} while (true); } while (true);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册