check vnode status for poll msg

586175ec · Liu Jicong · d41ce958 · 586175ec
隐藏空白更改
内联并排

Showing with 5 addition and 0 deletion

source/dnode/vnode/src/vnd/vnodeSvr.c source/dnode/vnode/src/vnd/vnodeSvr.c +5 -0

未找到文件。
--- a/source/dnode/vnode/src/vnd/vnodeSvr.c
+++ b/source/dnode/vnode/src/vnd/vnodeSvr.c
@@ -316,6 +316,11 @@ int32_t vnodeProcessFetchMsg(SVnode *pVnode, SRpcMsg *pMsg, SQueueInfo *pInfo) {
    return 0;
  }

+  if (pMsg->msgType == TDMT_VND_CONSUME && !pVnode->restored) {
+    vnodeRedirectRpcMsg(pVnode, pMsg);
+    return 0;
+  }
+
  char   *msgstr = POINTER_SHIFT(pMsg->pCont, sizeof(SMsgHead));
  int32_t msgLen = pMsg->contLen - sizeof(SMsgHead);