fix(query): VNodeRead.c modify pRead->code

7e2b8350 · Alex Duan · fdbc52bc · 7e2b8350
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

src/vnode/src/vnodeRead.c src/vnode/src/vnodeRead.c +1 -1

未找到文件。
--- a/src/vnode/src/vnodeRead.c
+++ b/src/vnode/src/vnodeRead.c
@@ -145,7 +145,7 @@ int32_t vnodeWriteToRQueue(void *vparam, void *pCont, int32_t contLen, int8_t qt
  atomic_add_fetch_32(&pVnode->queuedRMsg, 1);
-  if (pRead->code == TSDB_CODE_RPC_NETWORK_UNAVAIL || pRead->msgType == TSDB_CODE_RPC_VGROUP_NOT_CONNECTED ||
+  if (pRead->code == TSDB_CODE_RPC_NETWORK_UNAVAIL || pRead->code == TSDB_CODE_RPC_VGROUP_NOT_CONNECTED ||
      pRead->msgType == TSDB_MSG_TYPE_FETCH) {
    vTrace("vgId:%d, write into vfetch queue, refCount:%d queued:%d", pVnode->vgId, pVnode->refCount,
           pVnode->queuedRMsg);