From 76859f822e82fd1c79940f45aec10f89542091b8 Mon Sep 17 00:00:00 2001
From: woodser <woodser@protonmail.com>
Date: Thu, 16 May 2024 12:42:05 -0400
Subject: [PATCH] ignore failure after task runner canceled

---
 common/src/main/java/haveno/common/taskrunner/Task.java      | 1 +
 .../src/main/java/haveno/common/taskrunner/TaskRunner.java   | 5 +++++
 .../haveno/core/offer/placeoffer/PlaceOfferProtocol.java     | 4 +++-
 3 files changed, 9 insertions(+), 1 deletion(-)

diff --git a/common/src/main/java/haveno/common/taskrunner/Task.java b/common/src/main/java/haveno/common/taskrunner/Task.java
index 79904de23af..f990f511d8a 100644
--- a/common/src/main/java/haveno/common/taskrunner/Task.java
+++ b/common/src/main/java/haveno/common/taskrunner/Task.java
@@ -74,6 +74,7 @@ protected void failed(Throwable t) {
 //        t.printStackTrace(pw);
 //        errorMessage = sw.toString();
         
+        if (taskHandler.isCanceled()) return;
         errorMessage = t.getMessage() + " (task " + getClass().getSimpleName() + ")";
         log.error(errorMessage, t);
         taskHandler.handleErrorMessage(errorMessage);
diff --git a/common/src/main/java/haveno/common/taskrunner/TaskRunner.java b/common/src/main/java/haveno/common/taskrunner/TaskRunner.java
index 65cbf08e656..e49b4ccd913 100644
--- a/common/src/main/java/haveno/common/taskrunner/TaskRunner.java
+++ b/common/src/main/java/haveno/common/taskrunner/TaskRunner.java
@@ -80,11 +80,16 @@ public void cancel() {
         isCanceled = true;
     }
 
+    public boolean isCanceled() {
+        return isCanceled;
+    }
+
     void handleComplete() {
         next();
     }
 
     void handleErrorMessage(String errorMessage) {
+        if (isCanceled) return;
         log.error("Task failed: " + currentTask.getSimpleName() + " / errorMessage: " + errorMessage);
         failed = true;
         errorMessageHandler.handleErrorMessage(errorMessage);
diff --git a/core/src/main/java/haveno/core/offer/placeoffer/PlaceOfferProtocol.java b/core/src/main/java/haveno/core/offer/placeoffer/PlaceOfferProtocol.java
index 0fbd7efef1a..32426b80d56 100644
--- a/core/src/main/java/haveno/core/offer/placeoffer/PlaceOfferProtocol.java
+++ b/core/src/main/java/haveno/core/offer/placeoffer/PlaceOfferProtocol.java
@@ -41,6 +41,7 @@ public class PlaceOfferProtocol {
     private Timer timeoutTimer;
     private final TransactionResultHandler resultHandler;
     private final ErrorMessageHandler errorMessageHandler;
+    private TaskRunner<PlaceOfferModel> taskRunner;
 
 
     ///////////////////////////////////////////////////////////////////////////////////////////
@@ -65,7 +66,7 @@ public void placeOffer() {
 
         startTimeoutTimer();
 
-        TaskRunner<PlaceOfferModel> taskRunner = new TaskRunner<>(model,
+        taskRunner = new TaskRunner<>(model,
                 () -> {
 
                     // reset timer if response not yet received
@@ -145,6 +146,7 @@ private void stopTimeoutTimer() {
 
     private void handleError(String errorMessage) {
         if (timeoutTimer != null) {
+            taskRunner.cancel();
             log.error(errorMessage);
             stopTimeoutTimer();
             model.getOpenOffer().getOffer().setErrorMessage(errorMessage);