mirrors/bisq
1
0
Fork 0
mirror of https://github.com/bisq-network/bisq.git synced 2025-02-24 23:18:17 +01:00
Code Issues Projects Releases Packages Wiki Activity

Better progress reporting in network stress test shutdown

Browse source
This commit is contained in:
Ivan Vilata-i-Balaguer 2016-05-12 08:56:14 +02:00
parent 663cd82432
commit 0e9bcff2c8
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
network/src/test/java/io/bitsquare/p2p/network/NetworkStressTest.java
View file

@ -246,11 +246,10 @@ public class NetworkStressTest {
@After @After
public void tearDown() throws InterruptedException, IOException { public void tearDown() throws InterruptedException, IOException {
print("stopping all local nodes");
/** A barrier to wait for concurrent shutdown of services. */ /** A barrier to wait for concurrent shutdown of services. */
final CountDownLatch shutdownLatch = new CountDownLatch((seedNode != null? 1 : 0) + peerNodes.size()); final CountDownLatch shutdownLatch = new CountDownLatch((seedNode != null? 1 : 0) + peerNodes.size());
print("stopping all local nodes");
// Stop peer nodes. // Stop peer nodes.
for (P2PService peer : peerNodes) { for (P2PService peer : peerNodes) {
peer.shutDown(() -> countDownAndPrint(shutdownLatch, '.')); peer.shutDown(() -> countDownAndPrint(shutdownLatch, '.'));
@ -264,6 +263,7 @@ public class NetworkStressTest {
print("all local nodes stopped"); print("all local nodes stopped");
// Cleanup test data directory. // Cleanup test data directory.
print("cleaning up test data directory");
if (testDataDir != null) { if (testDataDir != null) {
deleteTestDataDirectory(); deleteTestDataDirectory();
} }