template<typename JP, typename InputTuple, typename OutputTuple>
class internal::join_node_base< JP, InputTuple, OutputTuple >
join_node_base
Definition at line 1264 of file _flow_graph_join_impl.h.
template<typename JP , typename InputTuple , typename OutputTuple >
Definition at line 1315 of file _flow_graph_join_impl.h.
1316 join_node_base_operation *current;
1319 op_list = op_list->next;
1320 switch(current->type) {
1324 task *rtask =
new ( task::allocate_additional_child_of(*(my_graph.root_task())) )
1326 <join_node_base<JP,InputTuple,OutputTuple> >(*
this);
1338 if(tuple_build_may_succeed()) {
1339 if(try_to_make_tuple(*(current->my_arg))) {
1348 bool build_succeeded;
1349 task *last_task = NULL;
1351 if(tuple_build_may_succeed()) {
1353 build_succeeded = try_to_make_tuple(out);
1354 if(build_succeeded) {
1362 build_succeeded =
false;
1365 }
while(build_succeeded);
1367 current->bypass_t = last_task;
1372 #if TBB_DEPRECATED_FLOW_NODE_EXTRACTION
1374 my_successors.internal_add_built_successor(*(current->my_succ));
1378 my_successors.internal_delete_built_successor(*(current->my_succ));
void const char const char int ITT_FORMAT __itt_group_sync x void const char ITT_FORMAT __itt_group_sync s void ITT_FORMAT __itt_group_sync p void ITT_FORMAT p void ITT_FORMAT p no args __itt_suppress_mode_t unsigned int void size_t ITT_FORMAT d void ITT_FORMAT p void ITT_FORMAT p __itt_model_site __itt_model_site_instance ITT_FORMAT p __itt_model_task * task
void __TBB_store_with_release(volatile T &location, V value)
static tbb::task * combine_tasks(graph &g, tbb::task *left, tbb::task *right)
void spawn_in_graph_arena(tbb::flow::interface10::graph &g, tbb::task &arena_task)
Spawns a task inside graph arena.
bool is_graph_active(tbb::flow::interface10::graph &g)
void register_successor(successor_type &r)
void remove_successor(successor_type &r)
task * try_put_task(const T &t) __TBB_override
References tbb::internal::__TBB_store_with_release(), internal::join_node_base< JP, InputTuple, OutputTuple >::join_node_base_operation::bypass_t, tbb::flow::interface11::combine_tasks(), internal::FAILED, tbb::flow::interface11::internal::is_graph_active(), internal::join_node_base< JP, InputTuple, OutputTuple >::join_node_base_operation::my_arg, internal::join_node_base< JP, InputTuple, OutputTuple >::join_node_base_operation::my_succ, tbb::interface6::internal::aggregated_operation< Derived >::next, tbb::flow::interface11::internal::spawn_in_graph_arena(), tbb::interface6::internal::aggregated_operation< Derived >::status, internal::SUCCEEDED, task, and internal::join_node_base< JP, InputTuple, OutputTuple >::join_node_base_operation::type.