Home
last modified time | relevance | path

Searched refs:continue_msg (Results 1 – 25 of 46) sorted by relevance

12

/oneTBB/test/common/
H A Dtest_join_node_multiple_predecessors.h27 using join_node_t = join_node<std::tuple<continue_msg, continue_msg, continue_msg>, reserving>;
28 using queue_node_t = queue_node<std::tuple<continue_msg, continue_msg, continue_msg>>;
31 buffer_node<continue_msg>& bn1, buffer_node<continue_msg>& bn2, buffer_node<continue_msg>& bn3, in twist_join_connections()
47 graph& g, buffer_node<continue_msg>& bn1, buffer_node<continue_msg>& bn2, in connect_join_via_make_edge()
58 graph&, buffer_node<continue_msg>& bn1, buffer_node<continue_msg>& bn2, in connect_join_via_follows()
68 graph&, buffer_node<continue_msg>& bn1, buffer_node<continue_msg>& bn2, in connect_join_via_precedes()
80 graph& g, buffer_node<continue_msg>& bn1, buffer_node<continue_msg>& bn2, in run_and_check()
83 std::tuple<continue_msg, continue_msg, continue_msg> msg; in run_and_check()
85 bn1.try_put(continue_msg()); in run_and_check()
86 bn2.try_put(continue_msg()); in run_and_check()
[all …]
H A Dgraph_utils.h51 struct converter<InputType,tbb::flow::continue_msg> {
52 static tbb::flow::continue_msg convert_value(const InputType &/*i*/) {
53 return tbb::flow::continue_msg();
58 struct converter<tbb::flow::continue_msg,OutputType> {
92 static OutputType construct( tbb::flow::continue_msg ) {
99 static tbb::flow::continue_msg construct( InputType ) {
100 return tbb::flow::continue_msg();
105 struct harness_graph_default_functor< tbb::flow::continue_msg, tbb::flow::continue_msg > {
106 static tbb::flow::continue_msg construct( tbb::flow::continue_msg ) {
107 return tbb::flow::continue_msg();
[all …]
/oneTBB/test/conformance/
H A Dconformance_continue_node.cpp62 broadcast_node<continue_msg> b(g); in test_deduction_guides_common()
97 using tbb::flow::continue_msg; in test_deduction_guides()
99 test_deduction_guides_common<continue_msg>([](const continue_msg&) {}); in test_deduction_guides() argument
102 test_deduction_guides_common<continue_msg>([](const continue_msg&) mutable {}); in test_deduction_guides() argument
211 node1.try_put(oneapi::tbb::flow::continue_msg());
212 node1.try_put(oneapi::tbb::flow::continue_msg());
213 node0.try_put(oneapi::tbb::flow::continue_msg());
237 node3.try_put(oneapi::tbb::flow::continue_msg());
238 node2.try_put(oneapi::tbb::flow::continue_msg());
239 node1.try_put(oneapi::tbb::flow::continue_msg());
[all …]
H A Dconformance_join_node.cpp75 [](oneapi::tbb::flow::continue_msg) { return 1; } ); in __anon798ebb9d0102() argument
93 node0.try_put(oneapi::tbb::flow::continue_msg());
162 c1.try_put(oneapi::tbb::flow::continue_msg());
167 c1.try_put(oneapi::tbb::flow::continue_msg());
171 c1.try_put(oneapi::tbb::flow::continue_msg());
175 c1.try_put(oneapi::tbb::flow::continue_msg());
184 c1.try_put(oneapi::tbb::flow::continue_msg());
215 auto body1 = [](const oneapi::tbb::flow::continue_msg &) -> int { return 1; }; in __anon798ebb9d0602() argument
218 oneapi::tbb::flow::join_node<std::tuple<oneapi::tbb::flow::continue_msg, float>,
226 std::tuple<oneapi::tbb::flow::continue_msg, float> tmp;
[all …]
H A Dconformance_indexer_node.cpp98 [](oneapi::tbb::flow::continue_msg) { return input_msg(5); } ); in __anon3412adbc0302() argument
125 c1.try_put(oneapi::tbb::flow::continue_msg());
135 [](oneapi::tbb::flow::continue_msg) { return 1; } ); in __anon3412adbc0502() argument
153 node0.try_put(oneapi::tbb::flow::continue_msg());
H A Dconformance_graph.cpp31 continue_node<int> source(g, 2, [&](const continue_msg&){ flag = true; return 1;}); in test_continue_node_rf_reset_protocol() argument
33 source.try_put(continue_msg()); in test_continue_node_rf_reset_protocol()
40 source.try_put(continue_msg()); in test_continue_node_rf_reset_protocol()
44 source.try_put(continue_msg()); in test_continue_node_rf_reset_protocol()
227 ct.try_put(oneapi::tbb::flow::continue_msg());
253 test_nodes_with_body_rf_reset_bodies<continue_node<int>, continue_msg>(serial);
H A Dconformance_split_node.cpp97 … [](oneapi::tbb::flow::continue_msg) { return std::tuple<int>(1); } ); in __anoned94b1790102() argument
115 node0.try_put(oneapi::tbb::flow::continue_msg());
/oneTBB/test/tbb/
H A Dtest_continue_node.cpp222 broadcast_node<continue_msg> start_g(g); in test_two_graphs()
227 broadcast_node<continue_msg> start_h(h); in test_two_graphs()
234 start_g.try_put(continue_msg()); in test_two_graphs()
235 start_h.try_put(continue_msg()); in test_two_graphs()
241 start_h.try_put(continue_msg()); in test_two_graphs()
242 start_h.try_put(continue_msg()); in test_two_graphs()
248 start_g.try_put(continue_msg()); in test_two_graphs()
299 using msg_t = tbb::flow::continue_msg; in test_follows_and_precedes_api()
338 continue_node<continue_msg> node(g, passing_body<continue_msg>()); in test_successor_cache_specialization()
343 buffer_node<continue_msg> buf(g); in test_successor_cache_specialization()
[all …]
H A Dtest_flow_graph_priorities.cpp126 continue_msg operator()( T ) const { return continue_msg(); } in operator ()()
209 call_within_arena< continue_node<continue_msg>, Body<continue_msg> >( arena ); in test()
433 continue_msg operator()( const continue_msg& msg ) const { in operator ()()
554 continue_msg operator()( const continue_msg& ) const { in operator ()()
555 return continue_msg(); in operator ()()
660 continue_msg operator()(const continue_msg&) { in operator ()()
662 return continue_msg(); in operator ()()
673 return continue_msg(); in operator ()()
679 return continue_msg(); in operator ()()
689 input_node<continue_msg> create_starter_node<input_node<continue_msg>>(graph& g) { in create_starter_node()
[all …]
H A Dtest_eh_flow_graph.cpp209 tbb::flow::continue_msg operator()( tbb::flow_control & fc) { in operator ()()
215 return tbb::flow::continue_msg(); in operator ()()
218 return tbb::flow::continue_msg(); in operator ()()
598 typedef tbb::flow::function_node<Item23,tbb::flow::continue_msg> SnkType; in run_function_node_test()
809 tbb::flow::broadcast_node<tbb::flow::continue_msg> b1(g), b2(g), b3(g); in run_one_continue_node_test()
866 typedef test_input_body<tbb::flow::continue_msg,IType> IBodyType; in run_continue_node_test()
870 typedef tbb::flow::input_node<tbb::flow::continue_msg> InputType; in run_continue_node_test()
1924 void operator() (tbb::flow::continue_msg) const { in operator ()()
1943 tbb::flow::broadcast_node<tbb::flow::continue_msg> start(g); in test_flow_graph_exception0()
1944 tbb::flow::continue_node<tbb::flow::continue_msg> fooNode(g, f); in test_flow_graph_exception0()
[all …]
H A Dtest_flow_graph.cpp181 tbb::flow::continue_msg operator()(const T& /*arg*/) { in operator ()()
183 return tbb::flow::continue_msg(); in operator ()()
219 …tbb::flow::continue_node< tbb::flow::continue_msg > c_n(my_graph, function_body<tbb::flow::continu… in operator ()()
261 c_n.try_put( tbb::flow::continue_msg() ); in operator ()()
353 continue_node<int> n(g, [](const continue_msg &){return 1;}); in __anon515993d30502() argument
368 continue_node<int> n2(g, [](const continue_msg &){return 1;}); in __anon515993d30602() argument
H A Dtest_limiter_node.cpp122 my_lim.decrementer().try_put( tbb::flow::continue_msg() ); in operator ()()
132 empty_sender< tbb::flow::continue_msg > s; in test_puts_with_decrements()
209 empty_sender< tbb::flow::continue_msg > s; in test_serial()
216 lim.decrementer().try_put( tbb::flow::continue_msg() ); in test_serial()
229 typedef tbb::flow::multifunction_node<int, std::tuple<int,tbb::flow::continue_msg> > mfnode_type;
246 if(!std::get<DECREMENT_OUTPUT>(out).try_put(tbb::flow::continue_msg())) { in operator ()()
318 ln.decrementer().try_put(tbb::flow::continue_msg()); in test_continue_msg_reception()
464 ln.decrementer().try_put(tbb::flow::continue_msg()); in test_try_put_without_successors()
475 using msg_t = tbb::flow::continue_msg; in test_follows_and_precedes_api()
H A Dtest_function_node.cpp418 int operator()(tbb::flow::continue_msg) { return my_int; } in operator ()()
425 tbb::flow::broadcast_node<tbb::flow::continue_msg> Start(g); in test_function_node_with_continue_msg_as_input()
427 …tbb::flow::function_node<tbb::flow::continue_msg, int, tbb::flow::rejecting> FN1( g, tbb::flow::se… in test_function_node_with_continue_msg_as_input()
428 …tbb::flow::function_node<tbb::flow::continue_msg, int, tbb::flow::rejecting> FN2( g, tbb::flow::se… in test_function_node_with_continue_msg_as_input()
433 Start.try_put( tbb::flow::continue_msg() ); in test_function_node_with_continue_msg_as_input()
441 run_concurrency_levels<int,tbb::flow::continue_msg>(num_threads); in test_concurrency()
447 run_unlimited_concurrency<int,tbb::flow::continue_msg>(); in test_concurrency()
448 run_unlimited_concurrency<empty_no_assign,tbb::flow::continue_msg>(); in test_concurrency()
456 using msg_t = tbb::flow::continue_msg; in test_follows_and_precedes_api()
H A Dtest_profiling.cpp115 tbb::flow::continue_node<tbb::flow::continue_msg> node(g,
116 [](const tbb::flow::continue_msg& val) -> const tbb::flow::continue_msg&
H A Dtest_flow_graph_whitebox.cpp51 tbb::flow::continue_msg operator()(const T &/*in*/) { in operator ()()
52 return tbb::flow::continue_msg(); in operator ()()
446 using dtype = tbb::flow::continue_msg;
459 struct DecrementerHelper<tbb::flow::continue_msg> {
467 static tbb::flow::continue_msg makeDType() { in makeDType()
468 return tbb::flow::continue_msg(); in makeDType()
819 TestLimiterNode<tbb::flow::continue_msg>();
863 tbb::flow::continue_node<int> c(g, [](const tbb::flow::continue_msg&){ return 1; }); in __anon8a33875c0b02() argument
867 c.try_put(tbb::flow::continue_msg());
931 continue_node<int> c(g, [](const continue_msg&){ return 1; }); in __anon8a33875c0c02() argument
[all …]
H A Dtest_join_node.cpp52 typedef typename std::tuple<int, tbb::flow::continue_msg> input_tuple_type;
65 tbb::flow::input_node<tbb::flow::continue_msg> snode(g, recirc_input_node_body()); in test()
/oneTBB/doc/main/tbb_userguide/
H A DFlow_Graph_Single_Vs_Broadcast.rst35 continue_msg operator()( continue_msg /*dont_care*/) {
38 return continue_msg();
48 function_node<continue_msg> f1(g,serial,fn_body1(b1));
51 buffer_node<continue_msg> buf1(g);
59 buf1.try_put(continue_msg());
60 buf1.try_put(continue_msg());
61 buf1.try_put(continue_msg());
70 broadcast_node<continue_msg> bn(g);
75 bn.try_put(continue_msg());
76 bn.try_put(continue_msg());
[all …]
H A Duse_concurrency_limits.rst24 typename Output = continue_msg,
57 function_node< big_object *, continue_msg, rejecting > f( g, 3,
58 []( big_object *v ) -> continue_msg {
61 return continue_msg();
H A DDependence_Graph.rst29 passed between nodes are of type oneapi::tbb::flow::continue_msg. Unlike a
61 the nodes and continue_msg objects as the messages. A continue_node
84 typedef continue_node< continue_msg > node_t;
85 typedef const continue_msg & msg_t;
102 A.try_put( continue_msg() );
130 lambda expressions and then put a continue_msg to all successor nodes,
H A Duse_limiter_node.rst59 function_node< big_object *, continue_msg > f( g, unlimited,
60 []( big_object *v ) -> continue_msg {
63 return continue_msg();
80 value. The ``function_node`` has its output, a ``continue_msg``, sent to the
/oneTBB/include/oneapi/tbb/detail/
H A D_flow_graph_body_impl.h123 class function_body_leaf< continue_msg, continue_msg, B> : public function_body< continue_msg, cont…
126 continue_msg operator()( const continue_msg &i ) override {
132 return new function_body_leaf< continue_msg, continue_msg, B >(body);
140 class function_body_leaf< Input, continue_msg, B> : public function_body< Input, continue_msg > {
143 continue_msg operator()(const Input &i) override {
145 return continue_msg();
149 return new function_body_leaf< Input, continue_msg, B >(body);
157 class function_body_leaf< continue_msg, Output, B > : public function_body< continue_msg, Output > {
160 Output operator()(const continue_msg &i) override {
376 typedef continue_msg input_type;
[all …]
H A D_flow_graph_cache_impl.h275 class successor_cache< continue_msg, M > : no_copy {
281 typedef receiver<continue_msg> successor_type;
282 typedef receiver<continue_msg>* pointer_type;
283 typedef sender<continue_msg> owner_type;
289 successor_cache( sender<continue_msg>* owner ) : my_owner(owner) { in successor_cache()
329 virtual graph_task* try_put_task( const continue_msg& t ) = 0;
H A D_flow_graph_nodes_deduction.h231 using type = continue_msg;
240 ->continue_node<continue_output_t<std::invoke_result_t<Body, continue_msg>>,
247 ->continue_node<continue_output_t<std::invoke_result_t<Body, continue_msg>>,
253 ->continue_node<continue_output_t<std::invoke_result_t<Body, continue_msg>>, Policy<void>>;
258 ->continue_node<continue_output_t<std::invoke_result_t<Body, continue_msg>>,
/oneTBB/examples/graph/dining_philosophers/
H A Ddining_philosophers.cpp110 typedef oneapi::tbb::flow::function_node<oneapi::tbb::flow::continue_msg,
111 oneapi::tbb::flow::continue_msg>
141 void forward(const oneapi::tbb::flow::continue_msg &in,
158 oneapi::tbb::flow::continue_msg operator()(oneapi::tbb::flow::continue_msg /*m*/) { in operator ()() argument
160 return oneapi::tbb::flow::continue_msg(); in operator ()()
170 oneapi::tbb::flow::continue_msg operator()(const join_output &in) { in operator ()()
172 return oneapi::tbb::flow::continue_msg(); in operator ()()
182 void operator()(const oneapi::tbb::flow::continue_msg &in, in operator ()()
195 void philosopher::forward(const oneapi::tbb::flow::continue_msg & /*in*/, in forward() argument
204 oneapi::tbb::flow::continue_msg()); //start thinking again in forward()
[all …]
/oneTBB/examples/graph/fgbzip2/
H A Dfgbzip2.cpp140 typedef oneapi::tbb::flow::async_node<oneapi::tbb::flow::continue_msg, BufferMsg>
142 typedef oneapi::tbb::flow::async_node<BufferMsg, oneapi::tbb::flow::continue_msg>
208 [&asyncNodeActivity](const oneapi::tbb::flow::continue_msg& msg, in fgCompressionAsyncNode()
234 file_reader.try_put(oneapi::tbb::flow::continue_msg()); in fgCompressionAsyncNode()

12