From 372ff50b8b2b92e55a809d1087eeecb1411dd184 Mon Sep 17 00:00:00 2001 From: Christoph Sturm Date: Fri, 6 Sep 2019 11:57:15 +0200 Subject: [PATCH] Implement reviewer suggestions also in NetworkNode --- .../bisq/network/p2p/network/Connection.java | 19 +++++++------- .../bisq/network/p2p/network/NetworkNode.java | 25 +++++++++++-------- 2 files changed, 24 insertions(+), 20 deletions(-) diff --git a/p2p/src/main/java/bisq/network/p2p/network/Connection.java b/p2p/src/main/java/bisq/network/p2p/network/Connection.java index b6f49e7adb..ebfd14e9a0 100644 --- a/p2p/src/main/java/bisq/network/p2p/network/Connection.java +++ b/p2p/src/main/java/bisq/network/p2p/network/Connection.java @@ -704,10 +704,9 @@ public class Connection implements HasCapabilities, Runnable, MessageListener { long now = System.currentTimeMillis(); long elapsed = now - lastReadTimeStamp; if (elapsed < 10) { - if (log.isDebugEnabled()) - log.debug("We got 2 network_messages received in less than 10 ms. We set the thread to sleep " + - "for 20 ms to avoid getting flooded by our peer. lastReadTimeStamp={}, now={}, elapsed={}", - lastReadTimeStamp, now, elapsed); + log.debug("We got 2 network_messages received in less than 10 ms. We set the thread to sleep " + + "for 20 ms to avoid getting flooded by our peer. lastReadTimeStamp={}, now={}, elapsed={}", + lastReadTimeStamp, now, elapsed); Thread.sleep(20); } @@ -725,9 +724,7 @@ public class Connection implements HasCapabilities, Runnable, MessageListener { NetworkEnvelope networkEnvelope = networkProtoResolver.fromProto(proto); lastReadTimeStamp = now; - if (log.isDebugEnabled()) - log.debug("<< Received networkEnvelope of type: " + networkEnvelope.getClass().getSimpleName()); - + log.debug("<< Received networkEnvelope of type: {}", networkEnvelope.getClass().getSimpleName()); int size = proto.getSerializedSize(); // We comment out that part as only debug and trace log level is used. For debugging purposes // we leave the code though. @@ -763,8 +760,9 @@ public class Connection implements HasCapabilities, Runnable, MessageListener { boolean exceeds; if (networkEnvelope instanceof ExtendedDataSizePermission) { exceeds = size > MAX_PERMITTED_MESSAGE_SIZE; - if (log.isDebugEnabled()) + if (log.isDebugEnabled()) { log.debug("size={}; object={}", size, Utilities.toTruncatedString(proto, 100)); + } } else { exceeds = size > PERMITTED_MESSAGE_SIZE; } @@ -822,9 +820,10 @@ public class Connection implements HasCapabilities, Runnable, MessageListener { if (networkEnvelope instanceof CloseConnectionMessage) { // If we get a CloseConnectionMessage we shut down - if (log.isDebugEnabled()) + if (log.isDebugEnabled()) { log.debug("CloseConnectionMessage received. Reason={}\n\t" + - "connection={}", proto.getCloseConnectionMessage().getReason(), this); + "connection={}", proto.getCloseConnectionMessage().getReason(), this); + } if (CloseConnectionReason.PEER_BANNED.name().equals(proto.getCloseConnectionMessage().getReason())) { log.warn("We got shut down because we are banned by the other peer. (InputHandler.run CloseConnectionMessage)"); shutDown(CloseConnectionReason.PEER_BANNED); diff --git a/p2p/src/main/java/bisq/network/p2p/network/NetworkNode.java b/p2p/src/main/java/bisq/network/p2p/network/NetworkNode.java index 74adfaf399..94262d8f7f 100644 --- a/p2p/src/main/java/bisq/network/p2p/network/NetworkNode.java +++ b/p2p/src/main/java/bisq/network/p2p/network/NetworkNode.java @@ -98,8 +98,9 @@ public abstract class NetworkNode implements MessageListener { public SettableFuture sendMessage(@NotNull NodeAddress peersNodeAddress, NetworkEnvelope networkEnvelope) { - if (log.isDebugEnabled()) + if (log.isDebugEnabled()) { log.debug("sendMessage: peersNodeAddress=" + peersNodeAddress + "\n\tmessage=" + Utilities.toTruncatedString(networkEnvelope)); + } checkNotNull(peersNodeAddress, "peerAddress must not be null"); Connection connection = getOutboundConnection(peersNodeAddress); @@ -124,13 +125,15 @@ public abstract class NetworkNode implements MessageListener { try { // can take a while when using tor long startTs = System.currentTimeMillis(); - if (log.isDebugEnabled()) + if (log.isDebugEnabled()) { log.debug("Start create socket to peersNodeAddress {}", peersNodeAddress.getFullAddress()); + } Socket socket = createSocket(peersNodeAddress); long duration = System.currentTimeMillis() - startTs; - if (log.isDebugEnabled()) + if (log.isDebugEnabled()) { log.debug("Socket creation to peersNodeAddress {} took {} ms", peersNodeAddress.getFullAddress(), duration); + } if (duration > CREATE_SOCKET_TIMEOUT) throw new TimeoutException("A timeout occurred when creating a socket."); @@ -142,12 +145,14 @@ public abstract class NetworkNode implements MessageListener { existingConnection = getOutboundConnection(peersNodeAddress); if (existingConnection != null) { - if (log.isDebugEnabled()) + if (log.isDebugEnabled()) { log.debug("We found in the meantime a connection for peersNodeAddress {}, " + - "so we use that for sending the message.\n" + - "That can happen if Tor needs long for creating a new outbound connection.\n" + - "We might have got a new inbound or outbound connection.", - peersNodeAddress.getFullAddress()); + "so we use that for sending the message.\n" + + "That can happen if Tor needs long for creating a new outbound connection.\n" + + "We might have got a new inbound or outbound connection.", + peersNodeAddress.getFullAddress()); + + } try { socket.close(); } catch (Throwable throwable) { @@ -188,7 +193,7 @@ public abstract class NetworkNode implements MessageListener { peersNodeAddress, networkProtoResolver); - if (log.isDebugEnabled()) + if (log.isDebugEnabled()) { log.debug("\n\n%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%\n" + "NetworkNode created new outbound connection:" + "\nmyNodeAddress=" + getNodeAddress() @@ -196,7 +201,7 @@ public abstract class NetworkNode implements MessageListener { + "\nuid=" + outboundConnection.getUid() + "\nmessage=" + networkEnvelope + "\n%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%\n"); - + } // can take a while when using tor outboundConnection.sendMessage(networkEnvelope); return outboundConnection;