aboutsummaryrefslogtreecommitdiffhomepage
path: root/Firestore/core/src/firebase/firestore/util/async_queue.cc
diff options
context:
space:
mode:
Diffstat (limited to 'Firestore/core/src/firebase/firestore/util/async_queue.cc')
-rw-r--r--Firestore/core/src/firebase/firestore/util/async_queue.cc6
1 files changed, 4 insertions, 2 deletions
diff --git a/Firestore/core/src/firebase/firestore/util/async_queue.cc b/Firestore/core/src/firebase/firestore/util/async_queue.cc
index 71f5cc5..81aac7c 100644
--- a/Firestore/core/src/firebase/firestore/util/async_queue.cc
+++ b/Firestore/core/src/firebase/firestore/util/async_queue.cc
@@ -32,6 +32,8 @@ AsyncQueue::AsyncQueue(std::unique_ptr<Executor> executor)
is_operation_in_progress_ = false;
}
+// TODO(varconst): assert in destructor that the queue is empty.
+
void AsyncQueue::VerifyIsCurrentExecutor() const {
FIREBASE_ASSERT_MESSAGE(
executor_->IsCurrentExecutor(),
@@ -97,8 +99,8 @@ void AsyncQueue::VerifySequentialOrder() const {
// This is the inverse of `VerifyIsCurrentQueue`.
FIREBASE_ASSERT_MESSAGE(
!is_operation_in_progress_ || !executor_->IsCurrentExecutor(),
- "Enforcing sequential order failed: currently executing operations "
- "cannot enqueue more operations "
+ "Enqueue methods cannot be called when we are already running on "
+ "target executor"
"(this queue's executor: '%s', current executor: '%s')",
executor_->Name().c_str(), executor_->CurrentExecutorName().c_str());
}