curvefs/mds: fix create partition error at parallel case

opencurve · May 26, 2022 · fc2a7dd · fc2a7dd
1 parent 9da8b12
commit fc2a7dd
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 0 deletions.
diff --git a/curvefs/src/mds/topology/topology_manager.cpp b/curvefs/src/mds/topology/topology_manager.cpp
@@ -632,6 +632,9 @@ void TopologyManager::CreatePartitions(const CreatePartitionRequest *request,
     auto partitionInfoList = response->mutable_partitioninfolist();
     response->set_statuscode(TopoStatusCode::TOPO_OK);
 
+    // get lock and avoid multiMountpoint create concurrently
+    NameLockGuard lock(createPartitionMutex_, std::to_string(fsId));
+
     while (partitionInfoList->size() < count) {
         if (topology_->GetAvailableCopysetNum()
                             < option_.minAvailableCopysetNum) {

diff --git a/curvefs/src/mds/topology/topology_manager.h b/curvefs/src/mds/topology/topology_manager.h
@@ -186,6 +186,8 @@ class TopologyManager {
      */
     NameLock registMsMutex;
 
+    NameLock createPartitionMutex_;
+
     /**
      * @brief topology options
      */
-Original file line number
+Diff line change
@@ Expand Up / @@ -186,6 +186,8 @@ class TopologyManager { @@
          */
         NameLock registMsMutex;
+        NameLock createPartitionMutex_;
         /**
          * @brief topology options
          */
@@ Expand Down @@