We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 754b19e commit d25dff5Copy full SHA for d25dff5
curvefs/src/mds/topology/topology.cpp
@@ -227,6 +227,7 @@ TopoStatusCode TopologyImpl::RemoveServer(ServerIdType id) {
227
}
228
229
TopoStatusCode TopologyImpl::RemoveMetaServer(MetaServerIdType id) {
230
+ WriteLockGuard wlockPool(poolMutex_);
231
WriteLockGuard wlockServer(serverMutex_);
232
WriteLockGuard wlockMetaServer(metaServerMutex_);
233
auto it = metaServerMap_.find(id);
@@ -243,7 +244,6 @@ TopoStatusCode TopologyImpl::RemoveMetaServer(MetaServerIdType id) {
243
244
metaServerMap_.erase(it);
245
246
// update pool
- WriteLockGuard wlockPool(poolMutex_);
247
PoolIdType poolId = ix->second.GetPoolId();
248
auto it = poolMap_.find(poolId);
249
if (it != poolMap_.end()) {
0 commit comments