feat(db): optimize the auto-stop logic

1. provide data query service when auto stop

Author: morgan.peng

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

@@ -403,6 +403,11 @@ public class CommonParameter {
   public GenesisBlock genesisBlock;
   @Getter
   @Setter
+  @Parameter(names = {"--p2p-disable"}, description = "Switch for p2p module initialization. "
+      + "(defalut: false)", arity = 1)
+  public boolean p2pDisable = false;
+  @Getter
+  @Setter
   public List<InetSocketAddress> activeNodes;
   @Getter
   @Setter

framework/src/main/java/org/tron/common/application/ApplicationImpl.java

@@ -57,7 +57,7 @@ public void initServices(CommonParameter parameter) {
    * start up the app.
    */
   public void startup() {
-    if (!Args.getInstance().isSolidityNode()) {
+    if ((!Args.getInstance().isSolidityNode()) && (!Args.getInstance().isP2pDisable())) {
       tronNetService.start();
     }
     consensusService.start();
@@ -67,7 +67,7 @@ public void startup() {
   @Override
   public void shutdown() {
     logger.info("******** start to shutdown ********");
-    if (!Args.getInstance().isSolidityNode()) {
+    if (!Args.getInstance().isSolidityNode() && (!Args.getInstance().p2pDisable)) {
       tronNetService.close();
     }
     consensusService.stop();

framework/src/main/java/org/tron/core/Wallet.java

@@ -2633,13 +2633,15 @@ public TransactionInfoList getTransactionInfoByBlockNum(long blockNum) {
 
   public NodeList listNodes() {
     NodeList.Builder nodeListBuilder = NodeList.newBuilder();
-    TronNetService.getP2pService().getConnectableNodes().forEach(node -> {
-      nodeListBuilder.addNodes(Node.newBuilder().setAddress(
-              Address.newBuilder()
-                      .setHost(ByteString
-                              .copyFrom(ByteArray.fromString(node.getHost())))
-                      .setPort(node.getPort())));
-    });
+    if (!Args.getInstance().p2pDisable) {
+      TronNetService.getP2pService().getConnectableNodes().forEach(node -> {
+        nodeListBuilder.addNodes(Node.newBuilder().setAddress(
+            Address.newBuilder()
+                .setHost(ByteString
+                    .copyFrom(ByteArray.fromString(node.getHost())))
+                .setPort(node.getPort())));
+      });
+    }
     return nodeListBuilder.build();
   }
 

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

@@ -221,6 +221,7 @@ public static void clearParam() {
     PARAMETER.allowNewRewardAlgorithm = 0;
     PARAMETER.allowNewReward = 0;
     PARAMETER.memoFee = 0;
+    PARAMETER.p2pDisable = false;
   }
 
   /**

framework/src/main/java/org/tron/core/db/Manager.java

@@ -714,7 +714,7 @@ private void initAutoStop() {
               exitCount, blockTime));
     }
 
-    if (exitHeight == headNum) {
+    if (exitHeight == headNum && (!Args.getInstance().isP2pDisable())) {
       logger.info("Auto-stop hit: shutDownBlockHeight: {}, currentHeaderNum: {}, exit now",
           exitHeight, headNum);
       System.exit(0);

framework/src/main/java/org/tron/core/services/RpcApiService.java

@@ -1736,14 +1736,7 @@ public void getTransactionCountByBlockNum(NumberMessage request,
 
     @Override
     public void listNodes(EmptyMessage request, StreamObserver<NodeList> responseObserver) {
-      NodeList.Builder nodeListBuilder = NodeList.newBuilder();
-      TronNetService.getP2pService().getConnectableNodes().forEach(node -> {
-        nodeListBuilder.addNodes(Node.newBuilder().setAddress(
-                Address.newBuilder()
-                        .setHost(ByteString.copyFrom(ByteArray.fromString(node.getHost())))
-                        .setPort(node.getPort())));
-      });
-      responseObserver.onNext(nodeListBuilder.build());
+      responseObserver.onNext(wallet.listNodes());
       responseObserver.onCompleted();
     }
 

framework/src/test/java/org/tron/common/config/args/ArgsTest.java

@@ -13,8 +13,8 @@ public class ArgsTest {
 
   @Before
   public void init() {
-    Args.setParam(new String[]{"--output-directory", "output-directory", "--debug"},
-        Constant.TEST_CONF);
+    Args.setParam(new String[]{"--output-directory", "output-directory", "--p2p-disable", "true",
+        "--debug"}, Constant.TEST_CONF);
   }
 
   @After
@@ -30,5 +30,6 @@ public void testConfig() {
     Assert.assertEquals(Args.getInstance().getNodeDiscoveryPingTimeout(), 15_000);
     Assert.assertEquals(Args.getInstance().getMaxFastForwardNum(), 3);
     Assert.assertEquals(Args.getInstance().getBlockCacheTimeout(), 60);
+    Assert.assertEquals(Args.getInstance().p2pDisable, true);
   }
 }