From 0e9bcff2c894ad75a0d44cfcea287341a27e5558 Mon Sep 17 00:00:00 2001 From: Ivan Vilata-i-Balaguer Date: Thu, 12 May 2016 08:56:14 +0200 Subject: [PATCH] Better progress reporting in network stress test shutdown --- .../test/java/io/bitsquare/p2p/network/NetworkStressTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/network/src/test/java/io/bitsquare/p2p/network/NetworkStressTest.java b/network/src/test/java/io/bitsquare/p2p/network/NetworkStressTest.java index 01bea548ab..723ef56f9d 100644 --- a/network/src/test/java/io/bitsquare/p2p/network/NetworkStressTest.java +++ b/network/src/test/java/io/bitsquare/p2p/network/NetworkStressTest.java @@ -246,11 +246,10 @@ public class NetworkStressTest { @After public void tearDown() throws InterruptedException, IOException { - print("stopping all local nodes"); - /** A barrier to wait for concurrent shutdown of services. */ final CountDownLatch shutdownLatch = new CountDownLatch((seedNode != null? 1 : 0) + peerNodes.size()); + print("stopping all local nodes"); // Stop peer nodes. for (P2PService peer : peerNodes) { peer.shutDown(() -> countDownAndPrint(shutdownLatch, '.')); @@ -264,6 +263,7 @@ public class NetworkStressTest { print("all local nodes stopped"); // Cleanup test data directory. + print("cleaning up test data directory"); if (testDataDir != null) { deleteTestDataDirectory(); }