fix curvefs mds get metaserver

Signed-off-by: wanghai01 <seanhaizi@163.com>
opencurve · Sep 12, 2023 · 0897e58 · 0897e58
1 parent 30ce10b
commit 0897e58
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/curvefs/src/mds/topology/topology.cpp b/curvefs/src/mds/topology/topology.cpp
@@ -532,15 +532,19 @@ bool TopologyImpl::GetMetaServer(MetaServerIdType metaserverId,
 bool TopologyImpl::GetMetaServer(const std::string &hostIp, uint32_t port,
                                  MetaServer *out) const {
     ReadLockGuard rlockMetaServerMap(metaServerMutex_);
+    bool find = false;
     for (auto it = metaServerMap_.begin(); it != metaServerMap_.end(); it++) {
         ReadLockGuard rlockMetaServer(it->second.GetRWLockRef());
         if (it->second.GetInternalIp() == hostIp &&
             it->second.GetInternalPort() == port) {
             *out = it->second;
-            return true;
+            find = true;
+            if (it->second.GetOnlineState() == OnlineState::ONLINE) {
+                return find;
+            }
         }
     }
-    return false;
+    return find;
 }
 
 TopoStatusCode TopologyImpl::AddPartition(const Partition &data) {
@@ -1628,6 +1632,7 @@ uint32_t TopologyImpl::GetPartitionIndexOfFS(FsIdType fsId) {
 
 std::vector<CopySetInfo> TopologyImpl::ListCopysetInfo() const {
     std::vector<CopySetInfo> ret;
+    ReadLockGuard rlockCopySet(copySetMutex_);
     for (auto const &i : copySetMap_) {
         ret.emplace_back(i.second);
     }