haveno-network/haveno-core
haveno-network/haveno-core
1
0
Fork 1
Code Issues 4 Pull requests Projects 5 Releases 1 Packages Wiki Activity Actions 2

ignore fault on mailbox message task after shut down

Browse source
This commit is contained in:
woodser 2025-04-09 10:22:10 -04:00 committed by woodser
parent 765a32fd9f
commit 31fbf9c4e8
2 changed files with 4 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
core/src/main/java/haveno/core/trade/protocol/tasks/SendMailboxMessageTask.java
View file

@ -82,6 +82,7 @@ public abstract class SendMailboxMessageTask extends TradeTask {
@Override @Override
public void onFault(String errorMessage) { 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); log.error("{} failed: Peer {}. tradeId={}, uid={}, errorMessage={}", message.getClass().getSimpleName(), peersNodeAddress, message.getOfferId(), message.getUid(), errorMessage);
SendMailboxMessageTask.this.onFault(errorMessage, message); SendMailboxMessageTask.this.onFault(errorMessage, message);
} }

3
p2p/src/main/java/haveno/network/p2p/P2PService.java
View file

@ -109,6 +109,8 @@ public class P2PService implements SetupListener, MessageListener, ConnectionLis
@Getter @Getter
private static NodeAddress myNodeAddress; private static NodeAddress myNodeAddress;
@Getter
private boolean isShutDownStarted = false;
/////////////////////////////////////////////////////////////////////////////////////////// ///////////////////////////////////////////////////////////////////////////////////////////
@ -192,6 +194,7 @@ public class P2PService implements SetupListener, MessageListener, ConnectionLis
private void doShutDown() { private void doShutDown() {
log.info("P2PService doShutDown started"); log.info("P2PService doShutDown started");
isShutDownStarted = true;
if (p2PDataStorage != null) { if (p2PDataStorage != null) {
p2PDataStorage.shutDown(); p2PDataStorage.shutDown();