Home
last modified time | relevance | path

Searched refs:try_get (Results 1 – 25 of 44) sorted by relevance

12

/oneTBB/test/tbb/
H A Dtest_priority_queue_node.cpp43 while ( q.try_get(value) != true ) ; in spin_try_get()
134 CHECK_MESSAGE( q.try_get(v) == true, "" ); in test_reservation()
182 CHECK_MESSAGE( q.try_get( j ) == false, "" ); in test_parallel()
190 CHECK_MESSAGE( q.try_get( j ) == false, "" ); in test_parallel()
196 CHECK_MESSAGE( q.try_get( j ) == false, "" ); in test_parallel()
206 CHECK_MESSAGE( q.try_get( j ) == false, "" ); in test_parallel()
227 CHECK_MESSAGE( q.try_get( j ) == false, "" ); in test_parallel()
259 CHECK_MESSAGE( q.try_get( j ) == false, "" ); in test_serial()
275 CHECK_MESSAGE( q.try_get( j ) == false, "" ); in test_serial()
301 CHECK_MESSAGE( q.try_get( j ) == true, "" ); in test_serial()
[all …]
H A Dtest_buffer_node.cpp37 while ( b.try_get(value) != true ) {} in spin_try_get()
171 CHECK_MESSAGE( b.try_get(v) == true, "" ); in test_reservation()
223 CHECK_MESSAGE( b.try_get( j ) == false, "" ); in test_parallel()
235 CHECK_MESSAGE( b.try_get( j ) == false, "" ); in test_parallel()
246 CHECK_MESSAGE( b.try_get( j ) == false, "" ); in test_parallel()
261 CHECK_MESSAGE( b.try_get( j ) == false, "" ); in test_parallel()
292 CHECK_MESSAGE( b.try_get( j ) == false, "" ); in test_parallel()
329 CHECK_MESSAGE( b.try_get( j ) == false, "" ); in test_serial()
350 CHECK_MESSAGE( b.try_get( j ) == false, "" ); in test_serial()
380 CHECK_MESSAGE( b.try_get( j ) == true, "" ); in test_serial()
[all …]
H A Dtest_queue_node.cpp44 while ( q.try_get(value) != true ) { in spin_try_get()
224 CHECK_MESSAGE( q.try_get(v) == true, "" ); in test_reservation()
278 CHECK_MESSAGE( q.try_get( j ) == false, "" ); in test_parallel()
290 CHECK_MESSAGE( q.try_get( j ) == false, "" ); in test_parallel()
301 CHECK_MESSAGE( q.try_get( j ) == false, "" ); in test_parallel()
316 CHECK_MESSAGE( q.try_get( j ) == false, "" ); in test_parallel()
338 CHECK_MESSAGE( q.try_get( j ) == false, "" ); in test_parallel()
373 CHECK_MESSAGE( q.try_get( j ) == false, "" ); in test_serial()
393 CHECK_MESSAGE( q.try_get( j ) == false, "" ); in test_serial()
422 CHECK_MESSAGE( q.try_get( j ) == true, "" ); in test_serial()
[all …]
H A Dtest_write_once_node.cpp51 CHECK_MESSAGE( n.try_get( v0 ) == false, "" ); in simple_read_write_tests()
56 CHECK_MESSAGE( n.try_get( v0 ) == true, "" ); in simple_read_write_tests()
84 CHECK_MESSAGE( n.try_get( v2 ), "" ); in simple_read_write_tests()
105 CHECK_MESSAGE( n.try_get( v0 ) == false, "" ); in simple_read_write_tests()
121 CHECK_MESSAGE( my_node.try_get( v1 ) == true, "" ); in operator ()()
146 CHECK_MESSAGE( wo_vec[node_idx].try_get( v0 ) == false, "" ); in parallel_read_write_tests()
170 CHECK_MESSAGE( wo_vec[node_idx].try_get( v0 ) == false, "" ); in parallel_read_write_tests()
H A Dtest_overwrite_node.cpp49 CHECK_MESSAGE( n.try_get( v0 ) == false, "" ); in simple_read_write_tests()
53 CHECK_MESSAGE( n.try_get( v0 ) == true, "" ); in simple_read_write_tests()
67 CHECK_MESSAGE( n.try_get( v2 ), "" ); in simple_read_write_tests()
85 CHECK_MESSAGE( n.try_get( v0 ) == false, "" ); in simple_read_write_tests()
123 CHECK_MESSAGE( ow_vec[node_idx].try_get( v0 ) == false, "" ); in parallel_read_write_tests()
146 CHECK_MESSAGE( ow_vec[node_idx].try_get( v0 ) == false, "" ); in parallel_read_write_tests()
H A Dtest_sequencer_node.cpp47 return q.try_get(value); in wait_try_get()
52 while ( q.try_get(value) != true ) ; in spin_try_get()
208 CHECK_MESSAGE( s.try_get( j ) == false, "" ); in test_parallel()
227 CHECK_MESSAGE( s1.try_get( j ) == false, "" ); in test_parallel()
229 CHECK_MESSAGE( s2.try_get( j ) == false, "" ); in test_parallel()
231 CHECK_MESSAGE( s3.try_get( j ) == false, "" ); in test_parallel()
244 CHECK_MESSAGE( s_copy.try_get( j ) == false, "" ); in test_parallel()
276 CHECK_MESSAGE( s.try_get( j ) == false, "" ); in test_serial()
298 CHECK_MESSAGE( s.try_get( j ) == false, "" ); in test_serial()
317 CHECK_MESSAGE( s2.try_get( j ) == false, "" ); in test_serial()
H A Dtest_composite_node.cpp142 q.try_get(i); in test_tiny()
144 q.try_get(j); in test_tiny()
158 q.try_get(i); in test_tiny()
160 q.try_get(j); in test_tiny()
250 q.try_get(j); in test_adder()
273 q.try_get(j); in test_adder()
333 output.try_get(out); in test_nested_adder()
334 …CHECK_MESSAGE( (tbb::flow::output_port<0>(outer_node).try_get(out) == output.try_get(out)), "outpu… in test_nested_adder()
415 while ( v[0].try_get(x) ) { in test_prefix()
418 v[i].try_get(x); in test_prefix()
[all …]
H A Dtest_join_node.h1194 CHECK_MESSAGE(outq1.try_get(v), "");
1202 CHECK_MESSAGE(outq2.try_get(v), "");
1207 CHECK_MESSAGE(!outq1.try_get(v), "");
1208 CHECK_MESSAGE(!outq2.try_get(v), "");
1333 CHECK_MESSAGE( (q3.try_get(v)), "Error in try_get()");
1364 CHECK_MESSAGE( (q3.try_get(v)), "Error in try_get()");
1496 CHECK_MESSAGE( (!oq0.try_get(t1)&&!oq1.try_get(t1)), "oq0 and oq1 not empty");
1517 CHECK_MESSAGE( (!qnp.try_get(i)), "iq0 still had value in it");
1518 CHECK_MESSAGE( (!qnq.try_get(i)), "iq1 still had value in it");
1573 CHECK_MESSAGE( (!qnp.try_get(i)), "Item was received by qnp");
[all …]
H A Dtest_flow_graph_whitebox.cpp177 CHECK_MESSAGE( (!cnode.try_get(i)), "try_get not rejected"); in TestContinueNode()
249 CHECK_MESSAGE( (qnode1.try_get(ii) && ii == 1), "output not passed" ); in TestFunctionNode()
259 CHECK_MESSAGE( (qnode1.try_get(ii) && ii == 1), "output not passed" ); in TestFunctionNode()
498 CHECK_MESSAGE( (!outq.try_get(out_int)), "limiter_node incorrectly passed second input"); in TestLimiterNode()
526 CHECK_MESSAGE( (outq.try_get(out_int)),"missing output after reset(rf_clear_edges)"); in TestLimiterNode()
530 CHECK_MESSAGE( (!outq.try_get(out_int)),"second output incorrectly passed (rf_clear_edges)"); in TestLimiterNode()
851 CHECK_MESSAGE((src.try_get(tmp) == false), "try_get can not succeed");
855 CHECK_MESSAGE((src.try_get(tmp) == false), "try_get can not succeed");
892 CHECK_MESSAGE((q.try_get(tmp) == false), "Message should not be passed on");
942 CHECK_MESSAGE((b.try_get(tmp) == false), "Message should not arrive");
[all …]
H A Dtest_multifunction_node.cpp443 CHECK_MESSAGE( q0.try_get(e), "" ); in run_multiport_test()
445 CHECK_MESSAGE( q1.try_get(o), "" ); in run_multiport_test()
510 …CHECK_MESSAGE((b1.try_get(storage) && !b1.try_get(storage) && b2.try_get(storage) && !b2.try_get(s… in test_precedes()
581 …CHECK_MESSAGE((b1.try_get(storage) && !b1.try_get(storage) && b2.try_get(storage) && !b2.try_get(s…
H A Dtest_indexer_node.cpp275 CHECK_MESSAGE(outq1.try_get(v), ""); in test()
283 CHECK_MESSAGE(outq2.try_get(v), ""); in test()
288 CHECK_MESSAGE(!outq1.try_get(v), ""); in test()
289 CHECK_MESSAGE(!outq2.try_get(v), ""); in test()
379 CHECK_MESSAGE( (q3.try_get( v )), "Error in try_get()"); in test_one_serial()
384 CHECK_MESSAGE( (!q3.try_get( v )), "extra values in output queue"); in test_one_serial()
393 CHECK_MESSAGE( (q3.try_get( v )), "Error in try_get()"); in test_one_serial()
398 CHECK_MESSAGE( (!q3.try_get( v )), "extra values in output queue"); in test_one_serial()
567 bool is_get_succeeded = buf.try_get(msg); in check_edge()
H A Dtest_broadcast_node.cpp186 CHECK_MESSAGE( (q0.try_get(j) && j == i), "Bad value in queue"); in test_resets()
188 CHECK_MESSAGE( (!q0.try_get(j)), "extra value in queue"); in test_resets()
199 CHECK_MESSAGE( (!q0.try_get(j)), "edge between nodes not removed"); in test_resets()
204 CHECK_MESSAGE( (!q0.try_get(j)), "edge between nodes not removed"); in test_resets()
/oneTBB/test/common/
H A Dtest_follows_and_precedes_api.h71 …CHECK_MESSAGE((buffer.try_get(storage) && !buffer.try_get(storage)), "Not exact edge quantity was …
89 …CHECK_MESSAGE((buffer.try_get(storage) && !buffer.try_get(storage)), "Not exact edge quantity was …
103 CHECK_MESSAGE((node.try_get(storage)), "Not exact edge quantity was made");
120 …CHECK_MESSAGE((buf.try_get(storage) && ! buf.try_get(storage)), "Not exact edge quantity was made"…
167 CHECK_MESSAGE((successor.try_get(storage) && !successor.try_get(storage)),
188 CHECK_MESSAGE((buffer.try_get(storage)), "Not exact edge quantity was made");
220 CHECK_MESSAGE((successor.try_get(storage) && !successor.try_get(storage)),
H A Dgraph_utils.h396 bool try_get( T & v ) override {
506 CHECK_MESSAGE(!b0.try_get(j), "reset did not empty buffer");
519 CHECK_MESSAGE(q0.try_get(j), "Missing value from buffer");
527 CHECK_MESSAGE(!q0.try_get(j), "Extra values in output");
563 bool got_item1 = outq.try_get(outt);
564 bool got_item2 = outq.try_get(outt2);
572 got_item1 = b0.try_get(outt);
604 … bool is_successful_operation = b0.try_get(outt) && (T)23 == outt && !outq.try_get(outt);
/oneTBB/test/conformance/
H A Dconformance_queue_node.cpp64 …CHECK_MESSAGE((!testing_node.try_get(tmp1) && tmp1 == -1), "`try_get` must returns false if there …
70 testing_node.try_get(tmp1);
73 testing_node.try_get(tmp2);
H A Dconformance_buffer_node.cpp63 …CHECK_MESSAGE((!testing_node.try_get(tmp1) && tmp1 == -1), "`try_get` must returns false if there …
69 testing_node.try_get(tmp1);
72 testing_node.try_get(tmp2);
H A Dconformance_priority_queue_node.cpp68 CHECK_MESSAGE((testing_node.try_get(tmp)), "Get should succeed");
70 CHECK_MESSAGE((testing_node.try_get(tmp)), "Get should succeed");
72 CHECK_MESSAGE((testing_node.try_get(tmp)), "Get should succeed");
H A Dconformance_overwrite_node.cpp40 CHECK_MESSAGE((testing_node.try_get(tmp) == true), "Descendant needs to receive a message");
46 CHECK_MESSAGE((testing_node.try_get(tmp) == true), "Descendant needs to receive a message");
84 …CHECK_MESSAGE((!testing_node.try_get(tmp)), "Gets from the node are non-destructive, but the first…
H A Dconformance_limiter_node.cpp124 while( queue.try_get(actual) )
142 while( queue.try_get(actual) )
159 while( queue.try_get(actual) ){
179 while( queue.try_get(actual) ){
H A Dconformance_split_node.cpp52 CHECK_MESSAGE((oneapi::tbb::flow::output_port<0>(testing_node).try_get(tmp1) == false
54 CHECK_MESSAGE((oneapi::tbb::flow::output_port<1>(testing_node).try_get(tmp2) == false
56 CHECK_MESSAGE((oneapi::tbb::flow::output_port<2>(testing_node).try_get(tmp3) == false
H A Dconformance_join_node.cpp33 while(rr.try_get(tmp)) { in get_values()
188 CHECK_MESSAGE((testing_node.try_get(tmp)), "If no one successor accepts the tuple the messages\
227 CHECK_MESSAGE((testing_node.try_get(tmp)), "Mapped keys should match.\
229 CHECK_MESSAGE((!testing_node.try_get(tmp)), "Message should not exist after item is consumed");
248 CHECK_MESSAGE((testing_node.try_get(tmp) == true), "Mapped keys should match");
304 while(buf.try_get(tpl)) { in test_invoke_basic()
H A Dconformance_sequencer_node.cpp123 CHECK_MESSAGE((node.try_get(tmp) == true), "Getting from sequencer should succeed");
127 CHECK_MESSAGE((node.try_get(tmp) == true), "Getting from sequencer should succeed");
131 CHECK_MESSAGE((node.try_get(tmp) == false), "Getting from sequencer should not succeed");
H A Dconformance_flowgraph.h84 while (rr.try_get(tmp)) { in get_values()
95 while (rr.try_get(tmp)) { in get_values()
461 CHECK_MESSAGE((testing_node.try_get(tmp) == true), "try_get after rejection should succeed"); in test_buffering()
465 …CHECK_MESSAGE((std::get<0>(testing_node.output_ports()).try_get(tmp) == false), "try_get after rej… in test_buffering()
467 … CHECK_MESSAGE((testing_node.try_get(tmp) == false), "try_get after rejection should not succeed"); in test_buffering()
605 …CHECK_MESSAGE((!node_copy.is_valid() && !node_copy.try_get(tmp)), "The buffered value is not copie… in test_copy_ctor_for_buffering_nodes()
728 suc_node.try_get(b2); in test_output_input_class()
752 suc_node.try_get(b); in test_output_class()
H A Dconformance_graph.cpp65 CHECK_MESSAGE((node.try_get(tmp) == false), "Should be false"); in test_input_node_rf_reset_protocol()
92 CHECK_MESSAGE((testing_node.try_get(tmp) == false), "try_get should not succeed"); in test_buffering_nodes_rf_reset_protocol()
100 CHECK_MESSAGE((testing_node.try_get(tmp) == false), "try_get should not succeed"); in test_buffering_nodes_rf_reset_protocol()
158 CHECK_MESSAGE((!testing_node.try_get(tmp)), "All buffers must be emptied"); in test_join_node_rf_reset_protocol()
/oneTBB/doc/main/tbb_userguide/
H A DFlow_Graph_Buffering_in_Nodes.rst34 - A successor to the node can pull the message using ``try_get()`` or
39 If a ``try_get()`` successfully forwards a message, it is removed from

12