Merge branch 'master' into fix-login-check

vesoft-inc · Jan 5, 2022 · 0de100b · 0de100b
2 parents 9dcb7c8 + 80b7052
commit 0de100b
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/src/meta/processors/parts/CreateSpaceProcessor.cpp b/src/meta/processors/parts/CreateSpaceProcessor.cpp
@@ -192,6 +192,12 @@ void CreateSpaceProcessor::process(const cpp2::CreateSpaceReq& req) {
     for (auto& host : hosts) {
       auto key = MetaKeyUtils::hostKey(host.host, host.port);
       auto ret = doGet(key);
+      if (!nebula::ok(ret)) {
+        code = nebula::error(zoneValueRet);
+        LOG(ERROR) << "Get host " << host << " failed.";
+        break;
+      }
+
       HostInfo info = HostInfo::decode(nebula::value(ret));
       if (now - info.lastHBTimeInMilliSec_ <
           FLAGS_heartbeat_interval_secs * FLAGS_expired_time_factor * 1000) {
@@ -206,6 +212,8 @@ void CreateSpaceProcessor::process(const cpp2::CreateSpaceReq& req) {
         LOG(WARNING) << "Host " << host << " expired";
       }
     }
+
+    CHECK_CODE_AND_BREAK();
     zoneHosts[zone] = std::move(hosts);
   }