copyset schedule select copyset random

Signed-off-by: chenwei <461432360@qq.com>
opencurve · Aug 12, 2022 · e71aa51 · e71aa51
1 parent afc19d5
commit e71aa51
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/curvefs/src/mds/schedule/copysetSchedule.cpp b/curvefs/src/mds/schedule/copysetSchedule.cpp
@@ -218,6 +218,11 @@ int CopySetScheduler::CheckAndBalanceZoneByMetaserverUsage(ZoneIdType zoneId) {
 
         std::vector<CopySetInfo> copysetVector =
             topo_->GetCopySetInfosInMetaServer(sourceId);
+
+        thread_local static std::random_device rd;
+        thread_local static std::mt19937 randomGenerator(rd());
+        std::shuffle(copysetVector.begin(), copysetVector.end(),
+                     randomGenerator);
         for (const auto &copyset : copysetVector) {
             if (!IsCopysetCanTransfer(copyset)) {
                 continue;
@@ -276,6 +281,11 @@ int CopySetScheduler::CheckAndBalanceZoneByCopysetNum(ZoneIdType zoneId) {
 
         std::vector<CopySetInfo> copysetVector =
             topo_->GetCopySetInfosInMetaServer(sourceId);
+
+        thread_local static std::random_device rd;
+        thread_local static std::mt19937 randomGenerator(rd());
+        std::shuffle(copysetVector.begin(), copysetVector.end(),
+                     randomGenerator);
         for (const auto &copyset : copysetVector) {
             if (!IsCopysetCanTransfer(copyset)) {
                 continue;