Async: improve error handling and error propagation

The error is now propagated to the top-most (user-owned) Future. When
an error occurs, no further tasks are executed. The first error handler
function in the chain is also called, if there's any.

1 files changed, 46 insertions, 0 deletions

diff --git a/async/src/async.cpp b/async/src/async.cpp
index 5e26bd8..c780878 100644
--- a/async/src/async.cpp
+++ b/async/src/async.cpp
@@ -24,6 +24,50 @@
 
 using namespace Async;
 
+Private::Execution::Execution(const Private::ExecutorBasePtr &executor)
+    : executor(executor)
+    , resultBase(nullptr)
+    , isRunning(false)
+    , isFinished(false)
+{
+}
+
+Private::Execution::~Execution()
+{
+    if (resultBase) {
+        resultBase->releaseExecution();
+        delete resultBase;
+    }
+    prevExecution.reset();
+}
+
+void Private::Execution::setFinished()
+{
+    isFinished = true;
+    //executor.clear();
+}
+
+void Private::Execution::releaseFuture()
+{
+    resultBase = 0;
+}
+
+bool Private::Execution::errorWasHandled() const
+{
+    Execution * const exec = this;
+    while (exec) {
+        if (exec->executor->hasErrorFunc()) {
+            return true;
+        }
+        exec = exec->prevExecution.data();
+    }
+    return false;
+}
+
+
+
+
+
 Private::ExecutorBase::ExecutorBase(const ExecutorBasePtr &parent)
     : mPrev(parent)
 {
@@ -34,6 +78,8 @@ Private::ExecutorBase::~ExecutorBase()
 }
 
 
+
+
 JobBase::JobBase(const Private::ExecutorBasePtr &executor)
     : mExecutor(executor)
 {