Home
last modified time | relevance | path

Searched refs:bn (Results 1 – 7 of 7) sorted by relevance

/oneTBB/doc/main/tbb_userguide/
H A DFlow_Graph_Single_Vs_Broadcast.rst70 broadcast_node<continue_msg> bn(g);
72 make_edge(bn,f1);
73 make_edge(bn,f2);
74 make_edge(bn,f3);
75 bn.try_put(continue_msg());
76 bn.try_put(continue_msg());
77 bn.try_put(continue_msg());
H A DFlow_Graph_Reservation.rst63 broadcast_node<int> bn(g);
75 make_edge(bn,input_port<0>(jn)); // attach a broadcast_node
78 bn.try_put(2);
95 ``bn``. Port 1 of the ``join_node`` has one predecessor, ``buffer_node``
116 bn.try_put(2);
119 ``bn`` attempts to forward 2 to ``jn``. ``jn`` does not accept the value
120 and the arc from ``bn`` to ``jn`` reverses. Because neither bn nor jn
209 - ``jn`` tries to reserve ``bn``, which fails. The arc to ``bn``
236 - No attempt to pull from ``bn`` is made, because the edge from ``bn``
/oneTBB/test/tbb/
H A Dtest_flow_graph_priorities.cpp134 broadcast_node<typename NodeType::input_type> bn(g); in test_node() local
141 make_edge( bn, *nodes.back() ); in test_node()
153 bn.try_put( typename NodeType::input_type{} ); in test_node()
532 broadcast_node<continue_msg> bn(g); in test() local
535 make_edge( bn, *nodes[i] ); in test()
539 bn.try_put( continue_msg() ); in test()
762 broadcast_node<continue_msg> bn(g); in test() local
785 make_edge(bn, *n); in test()
786 bn.try_put(continue_msg()); in test()
789 remove_edge(bn, *n); in test()
H A Dtest_limiter_node.cpp440 tbb::flow::buffer_node<int> bn(g); in test_try_put_without_successors() local
443 tbb::flow::make_edge(bn, ln); in test_try_put_without_successors()
447 bn.try_put(i); in test_try_put_without_successors()
463 tbb::flow::remove_edge(bn, ln); in test_try_put_without_successors()
465 bn.try_put(try_put_num + 1); in test_try_put_without_successors()
H A Dtest_indexer_node.cpp578 void check_edge(tbb::flow::graph& g, BN& bn, tbb::flow::buffer_node<indexer_output_t>& buf, Type, t… in check_edge() argument
579 …sink(check_edge<indexer_output_t>(g, std::get<Seq>(bn), buf, typename std::tuple_element<Seq, Type… in check_edge()
588 auto bn = std::make_tuple(broadcast_node<Args>(g)...); in test_follows_impl() local
590 indexer_node<Args...> my_indexer(follows(std::get<Seq>(bn)...)); in test_follows_impl()
595 check_edge<indexer_output_t>(g, bn, buf, t, seq); in test_follows_impl()
H A Dtest_flow_graph_whitebox.cpp483 tbb::flow::broadcast_node<dtype> bn(g); in TestLimiterNode() local
487 tbb::flow::make_edge(bn,ln.decrementer()); in TestLimiterNode()
500 bn.try_put(DecrementerHelper<dtype>::makeDType()); in TestLimiterNode()
520 CHECK_MESSAGE( (bn.my_successors.empty()), "control edge not removed on reset(rf_clear_edges)"); in TestLimiterNode()
528 bn.try_put(DecrementerHelper<dtype>::makeDType()); in TestLimiterNode()
/oneTBB/test/common/
H A Dgraph_utils.h631 …erving_node, tbb::flow::buffer_node<DataType> &bn) : my_reserving_node(reserving_node), my_buffer_…