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 fc515a8796..7107791fb6 100644 --- a/p2p/src/main/java/bisq/network/p2p/network/Connection.java +++ b/p2p/src/main/java/bisq/network/p2p/network/Connection.java @@ -627,6 +627,10 @@ public class Connection implements HasCapabilities, Runnable, MessageListener { private void handleException(Throwable e) { CloseConnectionReason closeConnectionReason; + // silent fail if we are shutdown + if (stopped) + return; + if (e instanceof SocketException) { if (socket.isClosed()) closeConnectionReason = CloseConnectionReason.SOCKET_CLOSED; 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 935f9895c3..f924669b7d 100644 --- a/p2p/src/main/java/bisq/network/p2p/network/NetworkNode.java +++ b/p2p/src/main/java/bisq/network/p2p/network/NetworkNode.java @@ -225,7 +225,7 @@ public abstract class NetworkNode implements MessageListener { } public void onFailure(@NotNull Throwable throwable) { - log.info("onFailure at sendMessage: peersNodeAddress={}\n\tmessage={}\n\tthrowable={}", peersNodeAddress, networkEnvelope.getClass().getSimpleName(), throwable.toString()); + log.debug("onFailure at sendMessage: peersNodeAddress={}\n\tmessage={}\n\tthrowable={}", peersNodeAddress, networkEnvelope.getClass().getSimpleName(), throwable.toString()); UserThread.execute(() -> resultFuture.setException(throwable)); } });