This is an automated email from the ASF dual-hosted git repository. saipranav pushed a commit to branch QueccBranch in repository https://gitbox.apache.org/repos/asf/incubator-resilientdb.git
commit 09aafc9ae3025d40c79249292f9942bd53288377 Author: Saipranav Kotamreddy <[email protected]> AuthorDate: Mon Jan 22 09:33:14 2024 -0800 "Placeholder for thread" --- executor/kv/quecc_executor.cpp | 12 ++++++++++++ 1 file changed, 12 insertions(+) diff --git a/executor/kv/quecc_executor.cpp b/executor/kv/quecc_executor.cpp index 119fd9d6..3a854617 100644 --- a/executor/kv/quecc_executor.cpp +++ b/executor/kv/quecc_executor.cpp @@ -146,6 +146,17 @@ void QueccExecutor::PlannerThread(const int thread_number) { } } + if(multi_op_ready_.load()){ + //Process multi_op distributions for wait positions + + ready_planner_count_.fetch_sub(1); + if (ready_planner_count_.load() == 0) { + cv2_.notify_all(); + } + batch_ready_[thread_number] = false; + continue; + } + // Planner std::vector<KVOperation> batch = std::move(batch_array_[thread_number]); @@ -301,6 +312,7 @@ std::unique_ptr<BatchUserResponse> QueccExecutor::ExecuteBatch( return std::move(this->batch_response_); } } + multi_op_ready_.store(false); } ready_planner_count_.fetch_add(thread_count_);
