From 33357cfc8dfcaba85be0bc62f41bfb347004a9bf Mon Sep 17 00:00:00 2001 From: HenrikJannsen Date: Thu, 5 Jan 2023 00:27:29 -0500 Subject: [PATCH] Remove debug logs Signed-off-by: HenrikJannsen --- .../main/java/bisq/network/p2p/peers/Broadcaster.java | 9 --------- 1 file changed, 9 deletions(-) diff --git a/p2p/src/main/java/bisq/network/p2p/peers/Broadcaster.java b/p2p/src/main/java/bisq/network/p2p/peers/Broadcaster.java index dee52c2f87..4c194d5c65 100644 --- a/p2p/src/main/java/bisq/network/p2p/peers/Broadcaster.java +++ b/p2p/src/main/java/bisq/network/p2p/peers/Broadcaster.java @@ -38,7 +38,6 @@ import java.util.Set; import java.util.concurrent.CopyOnWriteArraySet; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; -import java.util.stream.Collectors; import lombok.Value; import lombok.extern.slf4j.Slf4j; @@ -119,11 +118,6 @@ public class Broadcaster implements BroadcastHandler.ResultHandler { @Nullable NodeAddress sender, @Nullable BroadcastHandler.Listener listener) { broadcastRequests.add(new BroadcastRequest(message, sender, listener)); - // Keep that log on INFO for better debugging if the feature works as expected. Later it can - // be remove or set to DEBUG - log.debug("Broadcast requested for {}. We queue it up for next bundled broadcast.", - message.getClass().getSimpleName()); - if (timer == null) { timer = UserThread.runAfter(this::maybeBroadcastBundle, BROADCAST_INTERVAL_MS, TimeUnit.MILLISECONDS); } @@ -131,9 +125,6 @@ public class Broadcaster implements BroadcastHandler.ResultHandler { private void maybeBroadcastBundle() { if (!broadcastRequests.isEmpty()) { - log.debug("Broadcast bundled requests of {} messages. Message types: {}", - broadcastRequests.size(), - broadcastRequests.stream().map(e -> e.getMessage().getClass().getSimpleName()).collect(Collectors.toList())); BroadcastHandler broadcastHandler = new BroadcastHandler(networkNode, peerManager, this); broadcastHandlers.add(broadcastHandler); broadcastHandler.broadcast(new ArrayList<>(broadcastRequests), shutDownRequested, executor);