refactor(sync): add syncIsReadyForRead, set error code

0838afaa · Minghao Li · a4b54c4f · 0838afaa
隐藏空白更改
内联并排

Showing with 8 addition and 0 deletion

source/libs/sync/src/syncMain.c source/libs/sync/src/syncMain.c +8 -0

未找到文件。
--- a/source/libs/sync/src/syncMain.c
+++ b/source/libs/sync/src/syncMain.c
@@ -466,6 +466,14 @@ bool syncIsReadyForRead(int64_t rid) {
    }
  }

+  if (!ready) {
+    if (pSyncNode->state != TAOS_SYNC_STATE_LEADER) {
+      terrno = TSDB_CODE_SYN_NOT_LEADER;
+    } else {
+      terrno = TSDB_CODE_APP_NOT_READY;
+    }
+  }
+
  syncNodeRelease(pSyncNode);
  return ready;
 }