Home
last modified time | relevance | path

Searched refs:try_put (Results 1 – 25 of 209) sorted by relevance

123456789

/dports/devel/onetbb/oneTBB-2021.4.0/test/tbb/
H A Dtest_limiter_node.cpp98 bool msg = my_lim.try_put( T(i) ); in operator ()()
197 bool msg = lim.try_put( T(j) ); in test_serial()
212 bool msg = lim.try_put( T(j) ); in test_serial()
216 msg = lim.try_put( T(j) ); in test_serial()
292 mf_node.try_put(1); in test_multifunction_to_limiter()
304 mf_node.try_put(1); in test_multifunction_to_limiter()
318 ln.try_put(42); in test_continue_msg_reception()
367 broad.try_put(1); //drop the count in test_reserve_release_messages()
431 while( limit3.try_put( m ) ){ m++; }; in test_decrementer()
451 bn.try_put(i); in test_try_put_without_successors()
[all …]
H A Dtest_flow_graph_whitebox.cpp246 qnode0.try_put(1); in TestFunctionNode()
257 qnode0.try_put(1); in TestFunctionNode()
409 q0.try_put(1); in TestJoinNode()
416 q1.try_put(2); in TestJoinNode()
492 inq.try_put(1); in TestLimiterNode()
496 inq.try_put(2); in TestLimiterNode()
507 inq.try_put(3); in TestLimiterNode()
523 inq.try_put(4); in TestLimiterNode()
524 inq.try_put(5); in TestLimiterNode()
884 on.try_put(1);
[all …]
/dports/math/stanmath/math-4.2.0/lib/tbb_2020.3/src/test/
H A Dtest_limiter_node.cpp337 mf_node.try_put(1); in test_multifunction_to_limiter()
349 mf_node.try_put(1); in test_multifunction_to_limiter()
363 ln.try_put(42); in test_continue_msg_reception()
372 ASSERT( limit.try_put(1), NULL ); in run_and_check_result()
373 ASSERT( limit.try_put(2), NULL ); in run_and_check_result()
374 ASSERT( !limit.try_put(3), NULL ); in run_and_check_result()
377 ASSERT( limit.try_put(4), NULL ); in run_and_check_result()
378 ASSERT( !limit.try_put(5), NULL ); in run_and_check_result()
441 broad.try_put(1); //drop the count in test_reserve_release_messages()
531 q0.try_put(i); in test_extract()
[all …]
H A Dtest_multifunction_node.cpp557 b0.try_put(3); in test_extract()
562 b1.try_put(3); in test_extract()
585 b0.try_put(1); in test_extract()
586 b0.try_put(1); in test_extract()
589 b1.try_put(3); in test_extract()
611 b0.try_put(1); in test_extract()
612 b0.try_put(1); in test_extract()
615 b1.try_put(2); in test_extract()
643 b0.try_put(1); in test_extract()
709 node.try_put(0); in test_precedes()
[all …]
H A Dtest_flow_graph_whitebox.cpp232 qnode0.try_put(1); in TestFunctionNode()
244 qnode0.try_put(1); in TestFunctionNode()
257 qnode0.try_put(1); in TestFunctionNode()
291 qnode0.try_put(1); in TestFunctionNode()
376 q0.try_put(1); in TestJoinNode()
383 q1.try_put(2); in TestJoinNode()
428 inq.try_put(1); in TestLimiterNode()
432 inq.try_put(2); in TestLimiterNode()
443 inq.try_put(3); in TestLimiterNode()
464 inq.try_put(4); in TestLimiterNode()
[all …]
H A Dtest_streaming_node.cpp244 split_n.try_put(args_tuple); in TestWithoutSetArgs()
249 split_n.try_put(args_tuple); in TestWithoutSetArgs()
275 split_n.try_put(args_tuple); in TestSetArgsOnly()
308 split_n.try_put(args_tuple); in TestSetPortRefOnly()
313 split_n.try_put(args_tuple); in TestSetPortRefOnly()
345 split_n.try_put(args_tuple); in TestSetArgsAndPortRef1()
350 split_n.try_put(args_tuple); in TestSetArgsAndPortRef1()
383 split_n.try_put(args_tuple); in TestSetArgsAndPortRef2()
388 split_n.try_put(args_tuple); in TestSetArgsAndPortRef2()
613 split_n.try_put(args_tuple); in TestSetRange()
[all …]
H A Dtest_continue_node.cpp249 start_g.try_put(continue_msg()); in test_two_graphs()
250 start_h.try_put(continue_msg()); in test_two_graphs()
256 start_h.try_put(continue_msg()); in test_two_graphs()
257 start_h.try_put(continue_msg()); in test_two_graphs()
263 start_g.try_put(continue_msg()); in test_two_graphs()
293 b0.try_put(tbb::flow::continue_msg()); in test_extract()
296 b1.try_put(tbb::flow::continue_msg()); in test_extract()
313 b0.try_put(tbb::flow::continue_msg()); in test_extract()
314 b0.try_put(tbb::flow::continue_msg()); in test_extract()
317 b1.try_put(tbb::flow::continue_msg()); in test_extract()
[all …]
/dports/devel/tbb/oneTBB-2020.3/src/test/
H A Dtest_limiter_node.cpp337 mf_node.try_put(1); in test_multifunction_to_limiter()
349 mf_node.try_put(1); in test_multifunction_to_limiter()
363 ln.try_put(42); in test_continue_msg_reception()
372 ASSERT( limit.try_put(1), NULL ); in run_and_check_result()
373 ASSERT( limit.try_put(2), NULL ); in run_and_check_result()
374 ASSERT( !limit.try_put(3), NULL ); in run_and_check_result()
377 ASSERT( limit.try_put(4), NULL ); in run_and_check_result()
378 ASSERT( !limit.try_put(5), NULL ); in run_and_check_result()
441 broad.try_put(1); //drop the count in test_reserve_release_messages()
531 q0.try_put(i); in test_extract()
[all …]
H A Dtest_multifunction_node.cpp557 b0.try_put(3); in test_extract()
562 b1.try_put(3); in test_extract()
585 b0.try_put(1); in test_extract()
586 b0.try_put(1); in test_extract()
589 b1.try_put(3); in test_extract()
611 b0.try_put(1); in test_extract()
612 b0.try_put(1); in test_extract()
615 b1.try_put(2); in test_extract()
643 b0.try_put(1); in test_extract()
709 node.try_put(0); in test_precedes()
[all …]
H A Dtest_flow_graph_whitebox.cpp232 qnode0.try_put(1); in TestFunctionNode()
244 qnode0.try_put(1); in TestFunctionNode()
257 qnode0.try_put(1); in TestFunctionNode()
291 qnode0.try_put(1); in TestFunctionNode()
376 q0.try_put(1); in TestJoinNode()
383 q1.try_put(2); in TestJoinNode()
428 inq.try_put(1); in TestLimiterNode()
432 inq.try_put(2); in TestLimiterNode()
443 inq.try_put(3); in TestLimiterNode()
464 inq.try_put(4); in TestLimiterNode()
[all …]
H A Dtest_streaming_node.cpp244 split_n.try_put(args_tuple); in TestWithoutSetArgs()
249 split_n.try_put(args_tuple); in TestWithoutSetArgs()
275 split_n.try_put(args_tuple); in TestSetArgsOnly()
308 split_n.try_put(args_tuple); in TestSetPortRefOnly()
313 split_n.try_put(args_tuple); in TestSetPortRefOnly()
345 split_n.try_put(args_tuple); in TestSetArgsAndPortRef1()
350 split_n.try_put(args_tuple); in TestSetArgsAndPortRef1()
383 split_n.try_put(args_tuple); in TestSetArgsAndPortRef2()
388 split_n.try_put(args_tuple); in TestSetArgsAndPortRef2()
613 split_n.try_put(args_tuple); in TestSetRange()
[all …]
H A Dtest_continue_node.cpp249 start_g.try_put(continue_msg()); in test_two_graphs()
250 start_h.try_put(continue_msg()); in test_two_graphs()
256 start_h.try_put(continue_msg()); in test_two_graphs()
257 start_h.try_put(continue_msg()); in test_two_graphs()
263 start_g.try_put(continue_msg()); in test_two_graphs()
293 b0.try_put(tbb::flow::continue_msg()); in test_extract()
296 b1.try_put(tbb::flow::continue_msg()); in test_extract()
313 b0.try_put(tbb::flow::continue_msg()); in test_extract()
314 b0.try_put(tbb::flow::continue_msg()); in test_extract()
317 b1.try_put(tbb::flow::continue_msg()); in test_extract()
[all …]
/dports/devel/taskflow/taskflow-3.2.0/3rd-party/tbb/src/test/
H A Dtest_limiter_node.cpp337 mf_node.try_put(1); in test_multifunction_to_limiter()
349 mf_node.try_put(1); in test_multifunction_to_limiter()
363 ln.try_put(42); in test_continue_msg_reception()
372 ASSERT( limit.try_put(1), NULL ); in run_and_check_result()
373 ASSERT( limit.try_put(2), NULL ); in run_and_check_result()
374 ASSERT( !limit.try_put(3), NULL ); in run_and_check_result()
377 ASSERT( limit.try_put(4), NULL ); in run_and_check_result()
378 ASSERT( !limit.try_put(5), NULL ); in run_and_check_result()
441 broad.try_put(1); //drop the count in test_reserve_release_messages()
531 q0.try_put(i); in test_extract()
[all …]
H A Dtest_multifunction_node.cpp557 b0.try_put(3); in test_extract()
562 b1.try_put(3); in test_extract()
585 b0.try_put(1); in test_extract()
586 b0.try_put(1); in test_extract()
589 b1.try_put(3); in test_extract()
611 b0.try_put(1); in test_extract()
612 b0.try_put(1); in test_extract()
615 b1.try_put(2); in test_extract()
643 b0.try_put(1); in test_extract()
709 node.try_put(0); in test_precedes()
[all …]
H A Dtest_flow_graph_whitebox.cpp232 qnode0.try_put(1); in TestFunctionNode()
244 qnode0.try_put(1); in TestFunctionNode()
257 qnode0.try_put(1); in TestFunctionNode()
291 qnode0.try_put(1); in TestFunctionNode()
376 q0.try_put(1); in TestJoinNode()
383 q1.try_put(2); in TestJoinNode()
428 inq.try_put(1); in TestLimiterNode()
432 inq.try_put(2); in TestLimiterNode()
443 inq.try_put(3); in TestLimiterNode()
464 inq.try_put(4); in TestLimiterNode()
[all …]
H A Dtest_streaming_node.cpp244 split_n.try_put(args_tuple); in TestWithoutSetArgs()
249 split_n.try_put(args_tuple); in TestWithoutSetArgs()
275 split_n.try_put(args_tuple); in TestSetArgsOnly()
308 split_n.try_put(args_tuple); in TestSetPortRefOnly()
313 split_n.try_put(args_tuple); in TestSetPortRefOnly()
345 split_n.try_put(args_tuple); in TestSetArgsAndPortRef1()
350 split_n.try_put(args_tuple); in TestSetArgsAndPortRef1()
383 split_n.try_put(args_tuple); in TestSetArgsAndPortRef2()
388 split_n.try_put(args_tuple); in TestSetArgsAndPortRef2()
613 split_n.try_put(args_tuple); in TestSetRange()
[all …]
H A Dtest_continue_node.cpp249 start_g.try_put(continue_msg()); in test_two_graphs()
250 start_h.try_put(continue_msg()); in test_two_graphs()
256 start_h.try_put(continue_msg()); in test_two_graphs()
257 start_h.try_put(continue_msg()); in test_two_graphs()
263 start_g.try_put(continue_msg()); in test_two_graphs()
293 b0.try_put(tbb::flow::continue_msg()); in test_extract()
296 b1.try_put(tbb::flow::continue_msg()); in test_extract()
313 b0.try_put(tbb::flow::continue_msg()); in test_extract()
314 b0.try_put(tbb::flow::continue_msg()); in test_extract()
317 b1.try_put(tbb::flow::continue_msg()); in test_extract()
[all …]
/dports/devel/onetbb/oneTBB-2021.4.0/test/conformance/
H A Dconformance_graph.cpp52 source.try_put(continue_msg());
59 source.try_put(continue_msg());
63 source.try_put(continue_msg());
71 f.try_put(0);
72 f.try_put(0);
90 buff.try_put(1);
106 q.try_put(1);
120 src.try_put(continue_msg());
131 src.try_put(continue_msg());
166 f.try_put(0);
H A Dconformance_join_node.cpp91 input_port<0>(node1).try_put(1); in test_forwarding()
92 input_port<1>(node1).try_put(1); in test_forwarding()
141 f1.try_put( 3 );
142 f2.try_put( 3 );
158 c.try_put(continue_msg());
168 c.try_put(continue_msg());
185 input_port<0>(jn).try_put(continue_msg());
186 input_port<1>(jn).try_put(1.3);
H A Dconformance_indexer_node.cpp82 input_port<0>(node1).try_put(6); in test_broadcasting()
83 input_port<1>(node1).try_put(1.5); in test_broadcasting()
114 input_port<0>(o).try_put(6);
115 input_port<1>(o).try_put(1.5);
148 f1.try_put( 3 );
149 f2.try_put( 3 );
H A Dconformance_multifunction_node.cpp72 std::get<0>(op).try_put(argument); in operator ()()
94 CHECK_MESSAGE((node1.try_put(1) == true), "try_put needs to return true"); in test_multifunc_body()
115 std::get<0>(op).try_put(argument); in operator ()()
136 std::get<0>(op).try_put(argument); in operator ()()
151 node1.try_put(1); in test_forwarding()
166 node.try_put(1); in test_rejecting_buffering()
203 std::get<0>(op).try_put(argument); in operator ()()
222 fnode.try_put(i); in test_node_concurrency()
238 source.try_put(oneapi::tbb::flow::continue_msg()); in test_priority()
262 … std::get<0>(op).try_put(argument); in test_rejecting()
[all …]
H A Dconformance_priority_queue_node.cpp70 node.try_put(1); in test_buffering()
88 node1.try_put(1); in test_forwarding()
101 node.try_put(2); in test_behavior()
102 node.try_put(3); in test_behavior()
103 node.try_put(1); in test_behavior()
/dports/devel/taskflow/taskflow-3.2.0/3rd-party/tbb/examples/graph/binpack/
H A Dbinpack.cpp91 if (my_used>0) get<1>(p).try_put(my_bin); in operator ()()
98 get<0>(p).try_put(V+1); // send out signal in operator ()()
106 get<0>(p).try_put(my_bin[i]); in operator ()()
109 get<0>(p).try_put(V+1); // send out signal in operator ()()
114 if (my_used>0) get<1>(p).try_put(my_bin); in operator ()()
115 get<0>(p).try_put(V+1); // send out signal in operator ()()
127 get<0>(p).try_put(V+1); // send out signal in operator ()()
130 get<1>(p).try_put(my_bin); in operator ()()
152 get<0>(p).try_put(my_bin[i]); in operator ()()
158 get<1>(p).try_put(my_bin); in operator ()()
[all …]
/dports/devel/tbb/oneTBB-2020.3/examples/graph/binpack/
H A Dbinpack.cpp91 if (my_used>0) get<1>(p).try_put(my_bin); in operator ()()
98 get<0>(p).try_put(V+1); // send out signal in operator ()()
106 get<0>(p).try_put(my_bin[i]); in operator ()()
109 get<0>(p).try_put(V+1); // send out signal in operator ()()
114 if (my_used>0) get<1>(p).try_put(my_bin); in operator ()()
115 get<0>(p).try_put(V+1); // send out signal in operator ()()
127 get<0>(p).try_put(V+1); // send out signal in operator ()()
130 get<1>(p).try_put(my_bin); in operator ()()
152 get<0>(p).try_put(my_bin[i]); in operator ()()
158 get<1>(p).try_put(my_bin); in operator ()()
[all …]
/dports/devel/onetbb/oneTBB-2021.4.0/examples/graph/binpack/
H A Dbinpack.cpp104 std::get<0>(p).try_put(item); in operator ()()
113 std::get<1>(p).try_put(my_bin); in operator ()()
120 std::get<0>(p).try_put(desired_bin_capacity + 1); // send out signal in operator ()()
129 std::get<0>(p).try_put(my_bin[i]); in operator ()()
132 std::get<0>(p).try_put(desired_bin_capacity + 1); // send out signal in operator ()()
139 std::get<1>(p).try_put(my_bin); in operator ()()
153 std::get<0>(p).try_put(desired_bin_capacity + 1); // send out signal in operator ()()
156 std::get<1>(p).try_put(my_bin); in operator ()()
182 std::get<0>(p).try_put(my_bin[i]); in operator ()()
190 std::get<1>(p).try_put(my_bin); in operator ()()
[all …]

123456789