Merge pull request #5223 from halibobo1205/feat/remove_repair_for_lev…

…ledb feat(db): remove auto-repair for corrupted leveldb
tronprotocol · May 25, 2023 · 0803151 · 0803151
2 parents ad1a1b3 + 8318708
commit 0803151
Showing 1 changed file with 5 additions and 16 deletions.
diff --git a/chainbase/src/main/java/org/tron/common/storage/leveldb/LevelDbDataSourceImpl.java b/chainbase/src/main/java/org/tron/common/storage/leveldb/LevelDbDataSourceImpl.java
@@ -142,22 +142,11 @@ private void openDatabase(Options dbOptions) throws IOException {
     if (!Files.isSymbolicLink(dbPath.getParent())) {
       Files.createDirectories(dbPath.getParent());
     }
-    try {
-      database = factory.open(dbPath.toFile(), dbOptions);
-      if (!this.getDBName().startsWith("checkpoint")) {
-        logger.info("DB {} open success with writeBufferSize {} M, cacheSize {} M, maxOpenFiles {}.",
-            this.getDBName(), dbOptions.writeBufferSize() / 1024 / 1024,
-            dbOptions.cacheSize() / 1024 / 1024, dbOptions.maxOpenFiles());
-      }
-    } catch (IOException e) {
-      if (e.getMessage().contains("Corruption:")) {
-        logger.warn("DB {} corruption detected, try to repair it.", this.getDBName(), e);
-        factory.repair(dbPath.toFile(), dbOptions);
-        logger.warn("DB {} corruption detected, repair done.", this.getDBName());
-        database = factory.open(dbPath.toFile(), dbOptions);
-      } else {
-        throw e;
-      }
+    database = factory.open(dbPath.toFile(), dbOptions);
+    if (!this.getDBName().startsWith("checkpoint")) {
+      logger.info("DB {} open success with writeBufferSize {} M, cacheSize {} M, maxOpenFiles {}.",
+          this.getDBName(), dbOptions.writeBufferSize() / 1024 / 1024,
+          dbOptions.cacheSize() / 1024 / 1024, dbOptions.maxOpenFiles());
     }
   }