提交 f14d00a5 编写于 作者: S Shengliang Guan

fix: do not process query and fetch msg until vnode restore finished

上级 7e85a15c
...@@ -797,6 +797,12 @@ bool vnodeIsLeader(SVnode *pVnode) { ...@@ -797,6 +797,12 @@ bool vnodeIsLeader(SVnode *pVnode) {
} }
bool vnodeIsReadyForRead(SVnode *pVnode) { bool vnodeIsReadyForRead(SVnode *pVnode) {
if (!pVnode->restored) {
vDebug("vgId:%d, vnode restore not finished", pVnode->config.vgId);
terrno = TSDB_CODE_APP_NOT_READY;
return false;
}
if (syncIsReady(pVnode->sync)) { if (syncIsReady(pVnode->sync)) {
return true; return true;
} }
...@@ -805,12 +811,6 @@ bool vnodeIsReadyForRead(SVnode *pVnode) { ...@@ -805,12 +811,6 @@ bool vnodeIsReadyForRead(SVnode *pVnode) {
return true; return true;
} }
if (!pVnode->restored) {
vDebug("vgId:%d, vnode restore not finished", pVnode->config.vgId);
terrno = TSDB_CODE_APP_NOT_READY;
return false;
}
vDebug("vgId:%d, vnode not ready for read, state:%s, last:%ld, cmt:%ld", pVnode->config.vgId, vDebug("vgId:%d, vnode not ready for read, state:%s, last:%ld, cmt:%ld", pVnode->config.vgId,
syncGetMyRoleStr(pVnode->sync), syncGetLastIndex(pVnode->sync), syncGetCommitIndex(pVnode->sync)); syncGetMyRoleStr(pVnode->sync), syncGetLastIndex(pVnode->sync), syncGetCommitIndex(pVnode->sync));
return false; return false;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册