ignore task cancelled error in broadcast handler after shut down

haveno-dex · Jan 10, 2025 · 1ac4c45 · 1ac4c45
1 parent e426f4d
commit 1ac4c45
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/p2p/src/main/java/haveno/network/p2p/peers/BroadcastHandler.java b/p2p/src/main/java/haveno/network/p2p/peers/BroadcastHandler.java
@@ -277,9 +277,6 @@ public void onSuccess(Connection connection) {
 
             @Override
             public void onFailure(@NotNull Throwable throwable) {
-                log.warn("Broadcast to " + connection.getPeersNodeAddressOptional() + " failed. ", throwable);
-                numOfFailedBroadcasts.incrementAndGet();
-
                 if (stopped.get()) {
                     return;
                 }
@@ -356,7 +353,8 @@ private void cleanup() {
                     try {
                         future.cancel(true);
                     } catch (Exception e) {
-                        if (!networkNode.isShutDownStarted()) throw e;
+                        if (networkNode.isShutDownStarted()) return; // ignore if shut down
+                        throw e;
                     }
                 });
         sendMessageFutures.clear();