fix pipeline

baidu · Sep 20, 2024 · ab62019 · ab62019
1 parent d464587
commit ab62019
Show file tree

Hide file tree

Showing 6 changed files with 9 additions and 5 deletions.
diff --git a/src/babylon/anyflow/builtin/alias.cpp b/src/babylon/anyflow/builtin/alias.cpp
@@ -45,7 +45,7 @@ void AliasProcessor::apply(GraphBuilder& builder, const ::std::string& alias,
   vertex.anonymous_emit().to(alias);
 }
 
-::std::atomic<size_t> AliasProcessor::_s_idx = ATOMIC_VAR_INIT(0);
+::std::atomic<size_t> AliasProcessor::_s_idx {0};
 
 } // namespace builtin
 } // namespace anyflow

diff --git a/src/babylon/anyflow/builtin/const.cpp b/src/babylon/anyflow/builtin/const.cpp
@@ -32,7 +32,7 @@ GraphVertexBuilder& ConstProcessor::apply_without_value(
   return vertex;
 }
 
-::std::atomic<size_t> ConstProcessor::_s_idx = ATOMIC_VAR_INIT(0);
+::std::atomic<size_t> ConstProcessor::_s_idx {0};
 
 } // namespace builtin
 } // namespace anyflow

diff --git a/src/babylon/anyflow/builtin/expression.cpp b/src/babylon/anyflow/builtin/expression.cpp
@@ -1007,7 +1007,7 @@ int32_t ExpressionProcessor::expend_non_conditional_expression(
   return 0;
 }
 
-::std::atomic<size_t> ExpressionProcessor::_s_idx = ATOMIC_VAR_INIT(0);
+::std::atomic<size_t> ExpressionProcessor::_s_idx {0};
 // ExpressionProcessor end
 ///////////////////////////////////////////////////////////////////////////////
 

diff --git a/src/babylon/anyflow/builtin/select.cpp b/src/babylon/anyflow/builtin/select.cpp
@@ -56,7 +56,7 @@ void SelectProcessor::apply(GraphBuilder& builder, const ::std::string& dest,
   vertex.anonymous_emit().to(dest);
 }
 
-::std::atomic<size_t> SelectProcessor::_s_idx = ATOMIC_VAR_INIT(0);
+::std::atomic<size_t> SelectProcessor::_s_idx {0};
 // SelectProcessor end
 ///////////////////////////////////////////////////////////////////////////////
 

diff --git a/src/babylon/concurrent/execution_queue.h b/src/babylon/concurrent/execution_queue.h
@@ -68,7 +68,7 @@ class ConcurrentExecutionQueue {
   void consume_until_empty() noexcept;
 
   Queue _queue;
-  ::std::atomic<size_t> _events = ATOMIC_VAR_INIT(0);
+  ::std::atomic<size_t> _events {0};
   Executor* _executor {nullptr};
   ConsumeFunction _consume_function;
 };

diff --git a/src/babylon/executor.h b/src/babylon/executor.h
@@ -5,6 +5,10 @@
 #include "babylon/future.h"                   // Future
 #include "babylon/move_only_function.h"       // MoveOnlyFunction
 
+#if __cpp_lib_coroutine
+#include <coroutine> // std::coroutine_handle
+#endif
+
 #include <thread> // std::thread
 #include <vector> // std::vector