diff --git a/common/src/main/java/io/bitsquare/app/Log.java b/common/src/main/java/io/bitsquare/app/Log.java index 535c84c07b..ccd882aba0 100644 --- a/common/src/main/java/io/bitsquare/app/Log.java +++ b/common/src/main/java/io/bitsquare/app/Log.java @@ -113,7 +113,7 @@ public class Log { public static void logIfStressTests(String msg) { if (DevFlags.STRESS_TEST_MODE) System.err.println(new SimpleDateFormat("HH:mm:ss.SSS").format(new Date()) + - msg + + " - " + msg + " / Memory(MB): " + Profiler.getUsedMemory()); } } diff --git a/network/src/main/java/io/bitsquare/p2p/peers/PeerManager.java b/network/src/main/java/io/bitsquare/p2p/peers/PeerManager.java index 1ca1f30c60..533a33d9e2 100644 --- a/network/src/main/java/io/bitsquare/p2p/peers/PeerManager.java +++ b/network/src/main/java/io/bitsquare/p2p/peers/PeerManager.java @@ -155,7 +155,9 @@ public class PeerManager implements ConnectionListener { @Override public void onConnection(Connection connection) { - Log.logIfStressTests("onConnection to peer " + networkNode.getAllConnections().size() + (connection.getPeersNodeAddressOptional().isPresent() ? connection.getPeersNodeAddressOptional().get() : "PeersNode unknown")); + Log.logIfStressTests("onConnection to peer " + + (connection.getPeersNodeAddressOptional().isPresent() ? connection.getPeersNodeAddressOptional().get() : "PeersNode unknown") + + " / Nr. of connections: " + networkNode.getAllConnections().size()); if (isSeedNode(connection)) connection.setPeerType(Connection.PeerType.SEED_NODE); @@ -170,7 +172,9 @@ public class PeerManager implements ConnectionListener { @Override public void onDisconnect(CloseConnectionReason closeConnectionReason, Connection connection) { - Log.logIfStressTests("onDisconnect of peer " + networkNode.getAllConnections().size() + (connection.getPeersNodeAddressOptional().isPresent() ? connection.getPeersNodeAddressOptional().get() : "PeersNode unknown")); + Log.logIfStressTests("onDisconnect of peer " + + (connection.getPeersNodeAddressOptional().isPresent() ? connection.getPeersNodeAddressOptional().get() : "PeersNode unknown") + + " / Nr. of connections: " + networkNode.getAllConnections().size()); handleConnectionFault(connection); lostAllConnections = networkNode.getAllConnections().isEmpty(); diff --git a/network/src/main/java/io/bitsquare/p2p/storage/P2PDataStorage.java b/network/src/main/java/io/bitsquare/p2p/storage/P2PDataStorage.java index 9fd5e8284f..70f1471e3b 100644 --- a/network/src/main/java/io/bitsquare/p2p/storage/P2PDataStorage.java +++ b/network/src/main/java/io/bitsquare/p2p/storage/P2PDataStorage.java @@ -159,9 +159,11 @@ public class P2PDataStorage implements MessageListener, ConnectionListener { if (containsKey) { log.info("We remove the data as the data owner got disconnected with " + "closeConnectionReason=" + closeConnectionReason); + Log.logIfStressTests("We remove the data as the data owner got disconnected with " + "closeConnectionReason=" + closeConnectionReason + - " / isIntended=" + closeConnectionReason.isIntended); + " / isIntended=" + closeConnectionReason.isIntended + + " / peer=" + (connection.getPeersNodeAddressOptional().isPresent() ? connection.getPeersNodeAddressOptional().get() : "PeersNode unknown")); // TODO We get closeConnectionReason TERMINATED which removes offers which should not be removed // TODO investigate why EOFException happens