ignore network node error if shutting down

haveno-dex · Jul 5, 2024 · 485428e · 485428e
1 parent ec9f91e
commit 485428e
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/p2p/src/main/java/haveno/network/p2p/network/NetworkNode.java b/p2p/src/main/java/haveno/network/p2p/network/NetworkNode.java
@@ -239,7 +239,9 @@ public void onDisconnect(CloseConnectionReason closeConnectionReason,
             future.exceptionally(throwable -> {
                 log.debug("onFailure at sendMessage: peersNodeAddress={}\n\tmessage={}\n\tthrowable={}", peersNodeAddress, networkEnvelope.getClass().getSimpleName(), throwable.toString());
                 UserThread.execute(() -> {
-                    if (!resultFuture.setException(throwable)) {
+                    if (isShutDownStarted) {
+                        resultFuture.cancel(true); // ignore if shutting down
+                    } else  if (!resultFuture.setException(throwable)) {
                         // In case the setException returns false we need to cancel the future.
                         resultFuture.cancel(true);
                     }