add function

guohao-rosicky · Nov 8, 2023 · c5fef92 · c5fef92
1 parent 2e6732b
commit c5fef92
Showing 1 changed file with 15 additions and 11 deletions.
diff --git a/...-service/src/main/java/org/apache/hadoop/ozone/container/common/utils/HddsVolumeUtil.java b/...-service/src/main/java/org/apache/hadoop/ozone/container/common/utils/HddsVolumeUtil.java
@@ -93,17 +93,8 @@ public static void loadAllHddsVolumeDbStore(MutableVolumeSet hddsVolumeSet,
         hddsVolumeSet.getVolumesList());
     long start = System.currentTimeMillis();
     for (HddsVolume volume : hddsVolumes) {
-      futures.add(CompletableFuture.runAsync(() -> {
-        try {
-          volume.loadDbStore(readOnly);
-        } catch (IOException e) {
-          onFailure(volume);
-          if (logger != null) {
-            logger.error("Load db store for HddsVolume {} failed",
-                volume.getStorageDir().getAbsolutePath(), e);
-          }
-        }
-      }));
+      futures.add(CompletableFuture.runAsync(
+          () -> loadVolume(volume, readOnly, logger)));
     }
     for (CompletableFuture<Void> future : futures) {
       future.join();
@@ -114,6 +105,19 @@ public static void loadAllHddsVolumeDbStore(MutableVolumeSet hddsVolumeSet,
     }
   }
 
+  private static void loadVolume(HddsVolume volume, boolean readOnly,
+      Logger logger) {
+    try {
+      volume.loadDbStore(readOnly);
+    } catch (IOException e) {
+      onFailure(volume);
+      if (logger != null) {
+        logger.error("Load db store for HddsVolume {} failed",
+            volume.getStorageDir().getAbsolutePath(), e);
+      }
+    }
+  }
+
   private static void mapDbVolumesToDataVolumesIfNeeded(
       MutableVolumeSet hddsVolumeSet, MutableVolumeSet dbVolumeSet) {
     if (dbVolumeSet == null || dbVolumeSet.getVolumesList().isEmpty()) {