add switch for transaction cache initialization optimization (#5543)

Author: halibobo1205

chainbase/src/main/java/org/tron/core/db2/common/TxCacheDB.java

@@ -89,6 +89,7 @@ public class TxCacheDB implements DB<byte[], byte[]>, Flusher {
   private final Path cacheProperties;
   private final Path cacheDir;
   private AtomicBoolean isValid = new AtomicBoolean(false);
+  private boolean txCacheInitOptimization;
 
   @Getter
   @Setter
@@ -128,6 +129,8 @@ public TxCacheDB(String name, RecentTransactionStore recentTransactionStore,
     this.cacheFile0 = Paths.get(cacheDir.toString(), "bloomFilters_0");
     this.cacheFile1 = Paths.get(cacheDir.toString(), "bloomFilters_1");
     this.cacheProperties = Paths.get(cacheDir.toString(), "txCache.properties");
+    this.txCacheInitOptimization = CommonParameter.getInstance()
+        .getStorage().isTxCacheInitOptimization();
 
   }
 
@@ -280,6 +283,12 @@ public void reset() {
   }
 
   private boolean recovery() {
+    if (!txCacheInitOptimization) {
+      logger.info("txCache init optimization is disabled, skip fast recovery mode.");
+      logger.info("If you want fast recovery mode,"
+          + " please set `storage.txCache.initOptimization = true` in config.conf.");
+      return false;
+    }
     FileUtil.createDirIfNotExists(this.cacheDir.toString());
     logger.info("recovery bloomFilters start.");
     CompletableFuture<Boolean> loadProperties = CompletableFuture.supplyAsync(this::loadProperties);

common/src/main/java/org/tron/core/config/args/Storage.java

@@ -77,6 +77,7 @@ public class Storage {
   private static final String CHECKPOINT_SYNC_KEY = "storage.checkpoint.sync";
 
   private static final String CACHE_STRATEGIES = "storage.cache.strategies";
+  public static final String TX_CACHE_INIT_OPTIMIZATION = "storage.txCache.initOptimization";
 
   /**
    * Default values of directory
@@ -145,6 +146,10 @@ public class Storage {
   @Setter
   private int estimatedBlockTransactions;
 
+  @Getter
+  @Setter
+  private boolean txCacheInitOptimization = false;
+
   // second cache
   private final Map<CacheType, String> cacheStrategies = Maps.newConcurrentMap();
 
@@ -235,6 +240,11 @@ public static int getEstimatedTransactionsFromConfig(final Config config) {
     return estimatedTransactions;
   }
 
+  public static boolean getTxCacheInitOptimizationFromConfig(final Config config) {
+    return config.hasPath(TX_CACHE_INIT_OPTIMIZATION)
+        && config.getBoolean(TX_CACHE_INIT_OPTIMIZATION);
+  }
+
 
   public  void setCacheStrategies(Config config) {
     if (config.hasPath(CACHE_STRATEGIES)) {

framework/src/main/java/org/tron/core/config/args/Args.java

@@ -520,6 +520,8 @@ public static void setParam(final String[] args, final String confFileName) {
 
     PARAMETER.storage.setEstimatedBlockTransactions(
         Storage.getEstimatedTransactionsFromConfig(config));
+    PARAMETER.storage.setTxCacheInitOptimization(
+        Storage.getTxCacheInitOptimizationFromConfig(config));
     PARAMETER.storage.setMaxFlushCount(Storage.getSnapshotMaxFlushCountFromConfig(config));
 
     PARAMETER.storage.setDefaultDbOptions(config);

framework/src/main/resources/config.conf

@@ -95,6 +95,8 @@ storage {
   # the estimated number of block transactions (default 1000, min 100, max 10000).
   # so the total number of cached transactions is 65536 * txCache.estimatedTransactions
   # txCache.estimatedTransactions = 1000
+  # if true, transaction cache initialization will be faster. default false
+  # txCache.initOptimization = true
 }
 
 node.discovery = {

framework/src/test/resources/config-test.conf

@@ -66,6 +66,8 @@ storage {
   # the estimated number of block transactions (default 1000, min 100, max 10000).
   # so the total number of cached transactions is 65536 * txCache.estimatedTransactions
   txCache.estimatedTransactions = 50
+  # if true, transaction cache initialization will be faster. default false
+  txCache.initOptimization = true
 
 }