keepAliveInterval configurable

Author: tomos01

common/src/main/java/org/tron/common/parameter/CommonParameter.java

@@ -309,6 +309,10 @@ public class CommonParameter {
   @Setter
   protected int backupPort;
 
+  @Getter
+  @Setter
+  protected int keepAliveInterval;
+
   @Getter
   @Setter
   protected List<String> backupMembers;

common/src/main/java/org/tron/core/Constant.java

@@ -217,6 +217,7 @@ public class Constant {
 
   public static final String NODE_BACKUP_PRIORITY = "node.backup.priority";
   public static final String NODE_BACKUP_PORT = "node.backup.port";
+  public static final String NODE_BACKUP_KEEPALIVEINTERVAL = "node.backup.keepAliveInterval";
   public static final String NODE_BACKUP_MEMBERS = "node.backup.members";
 
   public static final String STORAGE_BACKUP_ENABLE = "storage.backup.enable";

framework/src/main/java/org/tron/common/backup/BackupManager.java

@@ -31,6 +31,8 @@ public class BackupManager implements EventHandler {
 
   private int port = args.getBackupPort();
 
+  private int keepAliveInterval = args.getKeepAliveInterval();
+
   private String localIp = "";
 
   private Set<String> members = new ConcurrentSet<>();
@@ -43,7 +45,7 @@ public class BackupManager implements EventHandler {
 
   private volatile long lastKeepAliveTime;
 
-  private volatile long keepAliveTimeout = 10_000;
+  private volatile long keepAliveTimeout = keepAliveInterval * 6;
 
   private volatile boolean isInit = false;
 
@@ -105,7 +107,7 @@ public void init() {
       } catch (Throwable t) {
         logger.error("Exception in send keep alive message:{}", t.getMessage());
       }
-    }, 1, 1, TimeUnit.SECONDS);
+    }, 1000, keepAliveInterval, TimeUnit.MILLISECONDS);
   }
 
   @Override

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

@@ -968,6 +968,8 @@ private static void initBackupProperty(Config config) {
         ? config.getInt(Constant.NODE_BACKUP_PRIORITY) : 0;
     INSTANCE.backupPort = config.hasPath(Constant.NODE_BACKUP_PORT)
         ? config.getInt(Constant.NODE_BACKUP_PORT) : 10001;
+    INSTANCE.keepAliveInterval = config.hasPath(Constant.NODE_BACKUP_KEEPALIVEINTERVAL)
+        ? config.getInt(Constant.NODE_BACKUP_KEEPALIVEINTERVAL) : 3000;
     INSTANCE.backupMembers = config.hasPath(Constant.NODE_BACKUP_MEMBERS)
         ? config.getStringList(Constant.NODE_BACKUP_MEMBERS) : new ArrayList<>();
   }
@@ -989,9 +991,10 @@ private static void logConfig() {
     logger.info("Max connection with same IP: {}", args.getNodeMaxActiveNodesWithSameIp());
     logger.info("Solidity threads: {}", args.getSolidityThreads());
     logger.info("************************ Backup config ************************");
+    logger.info("Backup priority: {}", args.getBackupPriority());
     logger.info("Backup listen port: {}", args.getBackupPort());
+    logger.info("Backup listen keepAliveInterval: {}", args.getKeepAliveInterval());
     logger.info("Backup member size: {}", args.getBackupMembers().size());
-    logger.info("Backup priority: {}", args.getBackupPriority());
     logger.info("************************ Code version *************************");
     logger.info("Code version : {}", Version.getVersion());
     logger.info("Version name: {}", Version.versionName);

framework/src/main/resources/config.conf

@@ -82,11 +82,15 @@ node.discovery = {
 }
 
 node.backup {
-  port = 10001
-
   # my priority, each member should use different priority
   priority = 8
 
+  # udp listen port, each member should have the save configuration
+  port = 10001
+
+  # time interval to send keepAlive message, each member should have the save configuration
+  keepAliveInterval = 3000
+
   # peer's ip list, can't contain mine
   members = [
     # "ip",