From 7a147ff9e87eaeb726d1d25e1afcee09d045a3f1 Mon Sep 17 00:00:00 2001
From: HenrikJannsen <boilingfrog@gmx.com>
Date: Fri, 6 Jan 2023 21:59:24 -0500
Subject: [PATCH] Reduce log level

Signed-off-by: HenrikJannsen <boilingfrog@gmx.com>
---
 .../java/bisq/network/p2p/network/Connection.java     | 11 ++++-------
 .../main/java/bisq/network/p2p/peers/PeerManager.java |  2 +-
 .../p2p/peers/peerexchange/PeerExchangeManager.java   |  2 +-
 3 files changed, 6 insertions(+), 9 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 a6e046b5a1..6765d0f79e 100644
--- a/p2p/src/main/java/bisq/network/p2p/network/Connection.java
+++ b/p2p/src/main/java/bisq/network/p2p/network/Connection.java
@@ -609,13 +609,11 @@ public class Connection implements HasCapabilities, Runnable, MessageListener {
 
         if (numRuleViolations >= ruleViolation.maxTolerance) {
             log.warn("We close connection as we received too many corrupt requests. " +
-                    "numRuleViolations={} " +
-                    "corruptRequest={} " +
-                    "corruptRequests={} " +
-                    "connection with address{} and uid {}", numRuleViolations, ruleViolation, ruleViolations, this.getPeersNodeAddressProperty(), this.getUid());
+                    "ruleViolations={} " +
+                    "connection with address{} and uid {}", ruleViolations, peersNodeAddressProperty, uid);
             this.ruleViolation = ruleViolation;
             if (ruleViolation == RuleViolation.PEER_BANNED) {
-                log.warn("We close connection due RuleViolation.PEER_BANNED. peersNodeAddress={}", getPeersNodeAddressOptional());
+                log.debug("We close connection due RuleViolation.PEER_BANNED. peersNodeAddress={}", getPeersNodeAddressOptional());
                 shutDown(CloseConnectionReason.PEER_BANNED);
             } else if (ruleViolation == RuleViolation.INVALID_CLASS) {
                 log.warn("We close connection due RuleViolation.INVALID_CLASS");
@@ -759,7 +757,7 @@ public class Connection implements HasCapabilities, Runnable, MessageListener {
                     long now = System.currentTimeMillis();
                     long elapsed = now - lastReadTimeStamp;
                     if (elapsed < 10) {
-                        log.info("We got 2 network_messages received in less than 10 ms. We set the thread to sleep " +
+                        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);
@@ -839,7 +837,6 @@ public class Connection implements HasCapabilities, Runnable, MessageListener {
                         if (networkEnvelope instanceof SendersNodeAddressMessage) {
                             boolean isValid = processSendersNodeAddressMessage((SendersNodeAddressMessage) networkEnvelope);
                             if (!isValid) {
-                                log.warn("Received invalid {}", networkEnvelope.getClass().getSimpleName());
                                 return;
                             }
                         }
diff --git a/p2p/src/main/java/bisq/network/p2p/peers/PeerManager.java b/p2p/src/main/java/bisq/network/p2p/peers/PeerManager.java
index 7d9e649b89..3cd8e00ade 100644
--- a/p2p/src/main/java/bisq/network/p2p/peers/PeerManager.java
+++ b/p2p/src/main/java/bisq/network/p2p/peers/PeerManager.java
@@ -234,7 +234,7 @@ public final class PeerManager implements ConnectionListener, PersistedDataHost
 
     @Override
     public void onDisconnect(CloseConnectionReason closeConnectionReason, Connection connection) {
-        log.info("onDisconnect called: nodeAddress={}, closeConnectionReason={}",
+        log.debug("onDisconnect called: nodeAddress={}, closeConnectionReason={}",
                 connection.getPeersNodeAddressOptional(), closeConnectionReason);
         handleConnectionFault(connection);
 
diff --git a/p2p/src/main/java/bisq/network/p2p/peers/peerexchange/PeerExchangeManager.java b/p2p/src/main/java/bisq/network/p2p/peers/peerexchange/PeerExchangeManager.java
index 59e00581bf..e195a34f6f 100644
--- a/p2p/src/main/java/bisq/network/p2p/peers/peerexchange/PeerExchangeManager.java
+++ b/p2p/src/main/java/bisq/network/p2p/peers/peerexchange/PeerExchangeManager.java
@@ -136,7 +136,7 @@ public class PeerExchangeManager implements MessageListener, ConnectionListener,
 
     @Override
     public void onDisconnect(CloseConnectionReason closeConnectionReason, Connection connection) {
-        log.info("onDisconnect closeConnectionReason={}, nodeAddressOpt={}", closeConnectionReason, connection.getPeersNodeAddressOptional());
+        log.debug("onDisconnect closeConnectionReason={}, nodeAddressOpt={}", closeConnectionReason, connection.getPeersNodeAddressOptional());
         closeHandler(connection);
 
         if (retryTimer == null) {