Home
last modified time | relevance | path

Searched refs:my_predecessors (Results 1 – 4 of 4) sorted by relevance

/oneTBB/test/tbb/
H A Dtest_flow_graph_whitebox.cpp289 CHECK_MESSAGE( (fnode0.my_predecessors.empty()), "predecessor not reversed"); in TestFunctionNode()
301 CHECK_MESSAGE( (!fnode1.my_predecessors.empty()), "Missing predecessor"); in TestFunctionNode()
306 CHECK_MESSAGE( (fnode1.my_predecessors.empty()), "predecessor not reversed"); in TestFunctionNode()
491 CHECK_MESSAGE( (ln.my_predecessors.empty()), "input edge reversed"); in TestLimiterNode()
495 CHECK_MESSAGE( (ln.my_predecessors.empty()), "input edge reversed"); in TestLimiterNode()
499 CHECK_MESSAGE( (!ln.my_predecessors.empty()), "input edge to limiter_node not reversed"); in TestLimiterNode()
506 CHECK_MESSAGE( (ln.my_predecessors.empty()), "input edge not reset"); in TestLimiterNode()
516 CHECK_MESSAGE( (ln.my_predecessors.empty()), "preds not reset(rf_clear_edges)"); in TestLimiterNode()
558 bool operator()(T& node) const { return node.my_predecessors.empty(); } in operator ()()
564 bool operator()(T& node) const { return !node.my_predecessors.empty(); } in operator ()()
[all …]
/oneTBB/include/oneapi/tbb/detail/
H A D_flow_graph_node_impl.h70 , my_predecessors(this) in function_input_base()
129 predecessor_cache<input_type, null_mutex > my_predecessors; variable
132 if( f & rf_clear_edges) my_predecessors.clear(); in reset_receiver()
134 my_predecessors.reset(); in reset_receiver()
135 …__TBB_ASSERT(!(f & rf_clear_edges) || my_predecessors.empty(), "function_input_base reset failed"); in reset_receiver()
183 if(my_predecessors.get_item(i)) { in perform_queued_requests()
197 my_predecessors.add(*(tmp->r)); in handle_operations()
205 my_predecessors.remove(*(tmp->r)); in handle_operations()
H A D_flow_graph_join_impl.h245 was_missing_predecessors = my_predecessors.empty();
246 my_predecessors.add(*(current->my_pred));
253 if ( !my_predecessors.empty() ) {
254 my_predecessors.remove(*(current->my_pred));
255 if ( my_predecessors.empty() ) // was the last predecessor
269 if ( my_predecessors.empty() ) {
277 my_predecessors.try_release( );
282 my_predecessors.try_consume( );
349 if(f & rf_clear_edges) my_predecessors.clear();
351 my_predecessors.reset();
[all …]
/oneTBB/include/oneapi/tbb/
H A Dflow_graph.h776 using input_impl_type::my_predecessors; in __TBB_requires()
834 my_predecessors.clear(); in __TBB_requires()
873 using input_impl_type::my_predecessors; in __TBB_requires()
1890 reservable_predecessor_cache< T, spin_mutex > my_predecessors; variable
1947 if ( (my_predecessors.try_reserve(v)) == true ) { in forward_task()
1964 my_predecessors.try_consume(); in forward_task()
1984 if (reserved) my_predecessors.try_release(); in forward_task()
2060 my_predecessors.add( src ); in register_predecessor()
2073 my_predecessors.remove( src ); in remove_predecessor()
2126 my_predecessors.clear(); in reset_node()
[all …]