Use WaitIfUpstreamIdle

2025-09-15 20:48:12 -04:00
parent 917066d8c0
commit 345d8e21b2
1 changed files with 1 additions and 1 deletions
--- a/src/commit_pipeline.hpp
+++ b/src/commit_pipeline.hpp
@@ -93,7 +93,7 @@ private:

  // Lock-free pipeline configuration
  static constexpr int lg_size = 16; // Ring buffer size (2^16 slots)
-  static constexpr auto wait_strategy = WaitStrategy::WaitIfStageEmpty;
+  static constexpr auto wait_strategy = WaitStrategy::WaitIfUpstreamIdle;

  // 4-stage pipeline: sequence -> resolve -> persist -> release
  StaticThreadPipeline<PipelineEntry, wait_strategy, 1, 1, 1, 2> pipeline_;