diff options
author | Shauren <shauren.trinity@gmail.com> | 2020-04-14 16:23:44 +0200 |
---|---|---|
committer | Shauren <shauren.trinity@gmail.com> | 2020-04-14 16:23:44 +0200 |
commit | 0f0ca3a9194d76afa0227943e86469ad8368c5e2 (patch) | |
tree | ca267417fdb6be1eb9c78dfd05b7449376a0eaf9 /src/server/database/Database/QueryCallback.cpp | |
parent | 34b393ab64d1c53e7e5828e735b4c31e61eaf950 (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.cpp | 10 |
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; } |