aboutsummaryrefslogtreecommitdiff
path: root/src/server/database/Database/QueryCallback.cpp
diff options
context:
space:
mode:
authorShauren <shauren.trinity@gmail.com>2020-04-14 16:23:44 +0200
committerShauren <shauren.trinity@gmail.com>2020-04-14 16:23:44 +0200
commit0f0ca3a9194d76afa0227943e86469ad8368c5e2 (patch)
treeca267417fdb6be1eb9c78dfd05b7449376a0eaf9 /src/server/database/Database/QueryCallback.cpp
parent34b393ab64d1c53e7e5828e735b4c31e61eaf950 (diff)
Core/DBLayer: Implement async transaction completion callbacks
Diffstat (limited to 'src/server/database/Database/QueryCallback.cpp')
-rw-r--r--src/server/database/Database/QueryCallback.cpp10
1 files changed, 5 insertions, 5 deletions
diff --git a/src/server/database/Database/QueryCallback.cpp b/src/server/database/Database/QueryCallback.cpp
index 65b52ff7627..02365a76fe7 100644
--- a/src/server/database/Database/QueryCallback.cpp
+++ b/src/server/database/Database/QueryCallback.cpp
@@ -175,7 +175,7 @@ void QueryCallback::SetNextQuery(QueryCallback&& next)
MoveFrom(this, std::move(next));
}
-QueryCallback::Status QueryCallback::InvokeIfReady()
+bool QueryCallback::InvokeIfReady()
{
QueryCallbackData& callback = _callbacks.front();
auto checkStateAndReturnCompletion = [this]()
@@ -185,15 +185,15 @@ QueryCallback::Status QueryCallback::InvokeIfReady()
if (_callbacks.empty())
{
ASSERT(!hasNext);
- return Completed;
+ return true;
}
// abort chain
if (!hasNext)
- return Completed;
+ return true;
ASSERT(_isPrepared == _callbacks.front()._isPrepared);
- return NextStep;
+ return false;
};
if (!_isPrepared)
@@ -217,5 +217,5 @@ QueryCallback::Status QueryCallback::InvokeIfReady()
}
}
- return NotReady;
+ return false;
}