diff --git a/.gitignore b/.gitignore index 3045a5720dd..22cd919de36 100644 --- a/.gitignore +++ b/.gitignore @@ -49,5 +49,5 @@ src/main/resources/META-INF/ /output_manager/ /output_witness/ - +output* nodeId.properties diff --git a/src/test/java/org/tron/core/net/node/BroadTest.java b/src/test/java/org/tron/core/net/node/BroadTest.java index 74390920a2a..fdf1d220c9e 100644 --- a/src/test/java/org/tron/core/net/node/BroadTest.java +++ b/src/test/java/org/tron/core/net/node/BroadTest.java @@ -46,7 +46,6 @@ @Slf4j public class BroadTest { - private static String dbPath = "output-nodeImplTest/broad"; private static AnnotationConfigApplicationContext context; private NodeImpl node; RpcApiService rpcApiService; @@ -167,7 +166,7 @@ public void init() { @Override public void run() { logger.info("Full node running."); - Args.setParam(new String[]{"--output-directory", dbPath}, "config.conf"); + Args.setParam(new String[]{"-d", "output-BroadTest-test"}, "config.conf"); Args cfgArgs = Args.getInstance(); cfgArgs.setNodeListenPort(17889); cfgArgs.setNodeDiscoveryEnable(false); @@ -220,8 +219,8 @@ public void run() { @AfterClass public static void destroy() { Args.clearParam(); - FileUtil.deleteDir(new File(dbPath)); - context.destroy(); + FileUtil.deleteDir(new File("output-BroadTest-test")); +// context.destroy(); } private void prepare() { diff --git a/src/test/java/org/tron/core/net/node/HandleSyncBlockTest.java b/src/test/java/org/tron/core/net/node/HandleSyncBlockTest.java index b5d422ced4d..533988d287f 100644 --- a/src/test/java/org/tron/core/net/node/HandleSyncBlockTest.java +++ b/src/test/java/org/tron/core/net/node/HandleSyncBlockTest.java @@ -4,6 +4,7 @@ import io.netty.util.internal.ConcurrentSet; import lombok.extern.slf4j.Slf4j; import org.apache.commons.collections4.CollectionUtils; +import org.junit.AfterClass; import org.junit.Assert; import org.junit.Before; import org.junit.Test; @@ -18,6 +19,7 @@ import org.tron.common.overlay.server.ChannelManager; import org.tron.common.overlay.server.SyncPool; import org.tron.common.utils.ByteArray; +import org.tron.common.utils.FileUtil; import org.tron.common.utils.ReflectUtils; import org.tron.common.utils.Sha256Hash; import org.tron.core.capsule.BlockCapsule; @@ -32,6 +34,7 @@ import org.tron.core.services.WitnessService; import org.tron.protos.Protocol; +import java.io.File; import java.lang.reflect.Field; import java.util.*; import java.util.concurrent.ConcurrentHashMap; @@ -40,6 +43,7 @@ @Slf4j public class HandleSyncBlockTest { + private static AnnotationConfigApplicationContext context; private NodeImpl node; RpcApiService rpcApiService; PeerClient peerClient; @@ -147,7 +151,7 @@ public void init() { @Override public void run() { logger.info("Full node running."); - Args.setParam(new String[]{"-d","output-nodeImplTest/handleSyncBlock"}, "config.conf"); + Args.setParam(new String[]{"-d","output-handleSyncBlock-test"}, "config.conf"); Args cfgArgs = Args.getInstance(); cfgArgs.setNodeListenPort(17889); cfgArgs.setNodeDiscoveryEnable(false); @@ -155,7 +159,7 @@ public void run() { cfgArgs.setNeedSyncCheck(false); cfgArgs.setNodeExternalIp("127.0.0.1"); - ApplicationContext context = new AnnotationConfigApplicationContext(DefaultConfig.class); + context = new AnnotationConfigApplicationContext(DefaultConfig.class); if (cfgArgs.isHelp()) { logger.info("Here is the help message."); @@ -196,6 +200,14 @@ public void run() { } } + @AfterClass + public static void destroy() { + Args.clearParam(); + FileUtil.deleteDir(new File("output-handleSyncBlock-test")); +// context.destroy(); + } + + private void prepare() { try { ExecutorService advertiseLoopThread = ReflectUtils.getFieldValue(node, "broadPool"); diff --git a/src/test/java/org/tron/core/net/node/StartFetchSyncBlockTest.java b/src/test/java/org/tron/core/net/node/StartFetchSyncBlockTest.java index dbbca5c5e5b..71c56b28617 100644 --- a/src/test/java/org/tron/core/net/node/StartFetchSyncBlockTest.java +++ b/src/test/java/org/tron/core/net/node/StartFetchSyncBlockTest.java @@ -2,6 +2,7 @@ import lombok.extern.slf4j.Slf4j; import org.apache.commons.collections4.CollectionUtils; +import org.junit.AfterClass; import org.junit.Assert; import org.junit.Before; import org.junit.Test; @@ -14,6 +15,7 @@ import org.tron.common.overlay.server.Channel; import org.tron.common.overlay.server.ChannelManager; import org.tron.common.overlay.server.SyncPool; +import org.tron.common.utils.FileUtil; import org.tron.common.utils.ReflectUtils; import org.tron.common.utils.Sha256Hash; import org.tron.core.capsule.BlockCapsule; @@ -27,6 +29,7 @@ import org.tron.core.services.WitnessService; import org.tron.protos.Protocol; +import java.io.File; import java.lang.reflect.Field; import java.util.*; import java.util.concurrent.ConcurrentHashMap; @@ -35,6 +38,7 @@ @Slf4j public class StartFetchSyncBlockTest { + private static AnnotationConfigApplicationContext context; private NodeImpl node; RpcApiService rpcApiService; PeerClient peerClient; @@ -111,7 +115,7 @@ public void init() { @Override public void run() { logger.info("Full node running."); - Args.setParam(new String[]{"-d","output-nodeImplTest/startFetchSyncBlock"}, "config.conf"); + Args.setParam(new String[]{"-d","output-startFetchSyncBlock-test"}, "config.conf"); Args cfgArgs = Args.getInstance(); cfgArgs.setNodeListenPort(17889); cfgArgs.setNodeDiscoveryEnable(false); @@ -119,7 +123,7 @@ public void run() { cfgArgs.setNeedSyncCheck(false); cfgArgs.setNodeExternalIp("127.0.0.1"); - ApplicationContext context = new AnnotationConfigApplicationContext(DefaultConfig.class); + context = new AnnotationConfigApplicationContext(DefaultConfig.class); if (cfgArgs.isHelp()) { logger.info("Here is the help message."); @@ -166,6 +170,14 @@ public void run() { } } + @AfterClass + public static void destroy() { + Args.clearParam(); + FileUtil.deleteDir(new File("output-startFetchSyncBlock-test")); +// context.destroy(); + + } + private void prepare() { try { ExecutorService advertiseLoopThread = ReflectUtils.getFieldValue(node, "broadPool");