From 31fbf9c4e826bdb21069c25584f40e1d8e1227c6 Mon Sep 17 00:00:00 2001 From: woodser <13068859+woodser@users.noreply.github.com> Date: Wed, 9 Apr 2025 10:22:10 -0400 Subject: [PATCH] ignore fault on mailbox message task after shut down --- .../core/trade/protocol/tasks/SendMailboxMessageTask.java | 1 + p2p/src/main/java/haveno/network/p2p/P2PService.java | 3 +++ 2 files changed, 4 insertions(+) diff --git a/core/src/main/java/haveno/core/trade/protocol/tasks/SendMailboxMessageTask.java b/core/src/main/java/haveno/core/trade/protocol/tasks/SendMailboxMessageTask.java index 157d7974..24638c5e 100644 --- a/core/src/main/java/haveno/core/trade/protocol/tasks/SendMailboxMessageTask.java +++ b/core/src/main/java/haveno/core/trade/protocol/tasks/SendMailboxMessageTask.java @@ -82,6 +82,7 @@ public abstract class SendMailboxMessageTask extends TradeTask { @Override public void onFault(String errorMessage) { + if (processModel.getP2PService().isShutDownStarted()) return; log.error("{} failed: Peer {}. tradeId={}, uid={}, errorMessage={}", message.getClass().getSimpleName(), peersNodeAddress, message.getOfferId(), message.getUid(), errorMessage); SendMailboxMessageTask.this.onFault(errorMessage, message); } diff --git a/p2p/src/main/java/haveno/network/p2p/P2PService.java b/p2p/src/main/java/haveno/network/p2p/P2PService.java index 117ed4a4..e7a81033 100644 --- a/p2p/src/main/java/haveno/network/p2p/P2PService.java +++ b/p2p/src/main/java/haveno/network/p2p/P2PService.java @@ -109,6 +109,8 @@ public class P2PService implements SetupListener, MessageListener, ConnectionLis @Getter private static NodeAddress myNodeAddress; + @Getter + private boolean isShutDownStarted = false; /////////////////////////////////////////////////////////////////////////////////////////// @@ -192,6 +194,7 @@ public class P2PService implements SetupListener, MessageListener, ConnectionLis private void doShutDown() { log.info("P2PService doShutDown started"); + isShutDownStarted = true; if (p2PDataStorage != null) { p2PDataStorage.shutDown();