| /oneTBB/examples/graph/logic_sim/ |
| H A D | test_all.cpp | 80 g.wait_for_all(); in main()
85 g.wait_for_all(); in main()
102 g.wait_for_all(); in main()
107 g.wait_for_all(); in main()
127 g.wait_for_all(); in main()
132 g.wait_for_all(); in main()
138 g.wait_for_all(); in main()
143 g.wait_for_all(); in main()
166 g.wait_for_all(); in main()
171 g.wait_for_all(); in main()
[all …]
|
| /oneTBB/test/tbb/ |
| H A D | test_priority_queue_node.cpp | 181 g.wait_for_all(); in test_parallel()
186 g.wait_for_all(); in test_parallel()
188 g.wait_for_all(); in test_parallel()
194 g.wait_for_all(); in test_parallel()
202 g.wait_for_all(); in test_parallel()
204 g.wait_for_all(); in test_parallel()
217 g.wait_for_all(); in test_parallel()
226 g.wait_for_all(); in test_parallel()
274 g.wait_for_all(); in test_serial()
282 g.wait_for_all(); in test_serial()
[all …]
|
| H A D | test_buffer_node.cpp | 164 g.wait_for_all(); in test_reservation()
169 g.wait_for_all(); in test_reservation()
174 g.wait_for_all(); in test_reservation()
179 g.wait_for_all(); in test_reservation()
185 g.wait_for_all(); in test_reservation()
222 g.wait_for_all(); in test_parallel()
238 g.wait_for_all(); in test_parallel()
260 g.wait_for_all(); in test_parallel()
262 g.wait_for_all(); in test_parallel()
264 g.wait_for_all(); in test_parallel()
[all …]
|
| H A D | test_queue_node.cpp | 217 g.wait_for_all(); in test_reservation()
222 g.wait_for_all(); in test_reservation()
227 g.wait_for_all(); in test_reservation()
233 g.wait_for_all(); in test_reservation()
238 g.wait_for_all(); in test_reservation()
277 g.wait_for_all(); in test_parallel()
293 g.wait_for_all(); in test_parallel()
315 g.wait_for_all(); in test_parallel()
317 g.wait_for_all(); in test_parallel()
493 g.wait_for_all(); in test_deduction_guides()
[all …]
|
| H A D | test_flow_graph_whitebox.cpp | 70 g.wait_for_all(); in TestSplitNode()
120 g.wait_for_all(); in TestBufferingNode()
124 g.wait_for_all(); in TestBufferingNode()
127 g.wait_for_all(); in TestBufferingNode()
136 g.wait_for_all(); in TestBufferingNode()
143 g.wait_for_all(); in TestBufferingNode()
247 g.wait_for_all(); in TestFunctionNode()
258 g.wait_for_all(); in TestFunctionNode()
303 g.wait_for_all(); in TestFunctionNode()
489 g.wait_for_all(); in TestLimiterNode()
[all …]
|
| H A D | test_input_node.cpp | 120 g.wait_for_all(); in test_single_dest()
133 g.wait_for_all(); in test_single_dest()
147 g.wait_for_all(); in test_single_dest()
158 g.wait_for_all(); in test_single_dest()
175 g.wait_for_all(); in test_reset()
187 g.wait_for_all(); in test_reset()
197 g.wait_for_all(); in test_reset()
208 g.wait_for_all(); in test_reset()
216 g.wait_for_all(); in test_reset()
225 g.wait_for_all(); in test_reset()
[all …]
|
| H A D | test_limiter_node.cpp | 294 g.wait_for_all(); in test_multifunction_to_limiter()
306 g.wait_for_all(); in test_multifunction_to_limiter()
320 g.wait_for_all(); in test_continue_msg_reception()
351 g.wait_for_all(); in test_reserve_release_messages()
357 g.wait_for_all(); in test_reserve_release_messages()
364 g.wait_for_all(); in test_reserve_release_messages()
391 g.wait_for_all(); in test_decrementer()
397 g.wait_for_all(); in test_decrementer()
415 g.wait_for_all(); in test_decrementer()
433 g.wait_for_all(); in test_decrementer()
[all …]
|
| H A D | test_sequencer_node.cpp | 46 g.wait_for_all(); in wait_try_get()
203 g.wait_for_all(); in test_parallel()
210 g.wait_for_all(); in test_parallel()
226 g.wait_for_all(); in test_parallel()
228 g.wait_for_all(); in test_parallel()
230 g.wait_for_all(); in test_parallel()
243 g.wait_for_all(); in test_parallel()
297 g.wait_for_all(); in test_serial()
316 g.wait_for_all(); in test_serial()
346 g.wait_for_all(); in test_serial()
[all …]
|
| H A D | test_eh_flow_graph.cpp | 963 g.wait_for_all(); in run_one_buffer_node_test()
969 g.wait_for_all(); in run_one_buffer_node_test()
1098 g.wait_for_all(); in run_one_sequencer_node_test()
1102 g.wait_for_all(); in run_one_sequencer_node_test()
1222 g.wait_for_all(); in run_one_priority_queue_node_test()
1226 g.wait_for_all(); in run_one_priority_queue_node_test()
1607 g.wait_for_all(); in run_one_limiter_node_test()
1613 g.wait_for_all(); in run_one_limiter_node_test()
1851 g.wait_for_all(); in run_one_indexer_node_test()
1855 g.wait_for_all(); in run_one_indexer_node_test()
[all …]
|
| H A D | test_async_node.cpp | 167 g.wait_for_all(); in test_reset()
186 g.wait_for_all(); in test_reset()
207 g.wait_for_all(); in test_reset()
226 g.wait_for_all(); in test_reset()
245 g.wait_for_all(); in test_reset()
265 g.wait_for_all(); in test_reset()
453 g.wait_for_all(); in run()
485 g.wait_for_all(); in test_copy_ctor()
496 g.wait_for_all(); in test_copy_ctor()
743 g.wait_for_all(); in test_follows()
[all …]
|
| H A D | test_composite_node.cpp | 139 g.wait_for_all(); in test_tiny()
146 g.wait_for_all(); in test_tiny()
156 g.wait_for_all(); in test_tiny()
245 g.wait_for_all(); in test_adder()
253 g.wait_for_all(); in test_adder()
269 g.wait_for_all(); in test_adder()
276 g.wait_for_all(); in test_adder()
337 g.wait_for_all(); in test_nested_adder()
412 g.wait_for_all(); in test_prefix()
480 g.wait_for_all(); in input_only_output_only_composite()
[all …]
|
| /oneTBB/test/conformance/ |
| H A D | conformance_graph.cpp | 34 g.wait_for_all(); in test_continue_node_rf_reset_protocol()
41 g.wait_for_all(); in test_continue_node_rf_reset_protocol()
45 g.wait_for_all(); in test_continue_node_rf_reset_protocol()
60 g.wait_for_all(); in test_input_node_rf_reset_protocol()
82 g.wait_for_all(); in test_functional_nodes_rf_reset_protocol()
96 g.wait_for_all(); in test_buffering_nodes_rf_reset_protocol()
102 g.wait_for_all(); in test_buffering_nodes_rf_reset_protocol()
112 g.wait_for_all(); in test_nodes_with_body_rf_reset_bodies()
118 g.wait_for_all(); in test_nodes_with_body_rf_reset_bodies()
134 g.wait_for_all(); in test_limiter_node_rf_reset_protocol()
[all …]
|
| H A D | conformance_limiter_node.cpp | 41 g.wait_for_all();
80 g.wait_for_all();
85 g.wait_for_all();
90 g.wait_for_all();
121 g.wait_for_all();
127 g.wait_for_all();
145 g.wait_for_all();
163 g.wait_for_all();
183 g.wait_for_all();
|
| H A D | conformance_join_node.cpp | 88 g.wait_for_all();
94 g.wait_for_all();
100 g.wait_for_all();
104 g.wait_for_all();
152 g.wait_for_all();
157 g.wait_for_all();
163 g.wait_for_all();
168 g.wait_for_all();
172 g.wait_for_all();
176 g.wait_for_all();
[all …]
|
| H A D | conformance_input_node.cpp | 66 g.wait_for_all(); in test_deduction_guides()
111 g.wait_for_all();
116 g.wait_for_all();
156 g.wait_for_all();
187 g.wait_for_all();
239 g.wait_for_all();
|
| H A D | conformance_sequencer_node.cpp | 106 g.wait_for_all();
120 g.wait_for_all();
163 g.wait_for_all();
195 g.wait_for_all();
209 g.wait_for_all();
|
| H A D | conformance_indexer_node.cpp | 46 g.wait_for_all();
86 g.wait_for_all();
126 g.wait_for_all();
149 g.wait_for_all();
154 g.wait_for_all();
|
| H A D | conformance_flowgraph.h | 426 g.wait_for_all(); in test_body_exec()
457 g.wait_for_all(); in test_buffering()
492 g.wait_for_all(); in test_forwarding()
512 g.wait_for_all(); in test_forwarding_single_push()
520 g.wait_for_all(); in test_forwarding_single_push()
573 g.wait_for_all(); in test_copy_ctor()
578 g.wait_for_all(); in test_copy_ctor()
612 g.wait_for_all(); in test_copy_ctor_for_buffering_nodes()
622 g.wait_for_all(); in test_copy_ctor_for_buffering_nodes()
710 g.wait_for_all(); in test_rejecting()
[all …]
|
| /oneTBB/doc/main/tbb_userguide/ |
| H A D | always_use_wait_for_all.rst | 3 Always Use wait_for_all()
8 forget to call wait_for_all. The function graph::wait_for_all blocks
11 necessary to call wait_for_all before destroying the graph, or any of
37 g.wait_for_all() at the end of the function prevents the premature
42 that you have called wait_for_all.
|
| H A D | communicate_with_nodes.rst | 12 operations, such as calls to graph::wait_for_all and exception handling.
61 g.wait_for_all();
63 g2.wait_for_all();
67 // even though wait_for_all was called on both graphs
78 done, you need to call the function wait_for_all on both graphs.
81 call to g.wait_for_all() returns immediately because there are no tasks
83 g2. The call to g2.wait_for_all returns after both m1 and m2 are done,
89 If the calls to wait_for_all are swapped, the code works as expected:
95 g2.wait_for_all();
96 g.wait_for_all();
|
| H A D | use_nested_flow_graphs.rst | 29 h.wait_for_all();
55 h.wait_for_all();
62 g.wait_for_all();
110 h.wait_for_all();
115 h.wait_for_all(); // optional since h is not destroyed
122 g.wait_for_all();
125 It is only necessary to call ``h.wait_for_all()`` at the end of each
128 of ``b``, it was necessary to call ``h.wait_for_all`` at the end of each
|
| H A D | catching_exceptions.rst | 11 call site of graph::wait_for_all(). Take the graph below as an example:
37 g.wait_for_all();
43 g.wait_for_all(). Since it is not handled there either, the program will
64 instead to catch the exception at the call to wait_for_all:
71 g.wait_for_all();
|
| H A D | destroy_graphs_outside_main_thread.rst | 9 wait_for_all(). However, it is safest to call wait_for_all on a graph
12 not want to call a wait_for_all in the example from :ref:`always_use_wait_for_all`,
27 g.wait_for_all();
|
| H A D | Mapping_Nodes2Tasks.rst | 13 are enough threads available. The call to ``g.wait_for_all()`` blocks until
14 there are no tasks executing in the graph. As with other ``wait_for_all``
15 functions in oneTBB, the thread that calls ``wait_for_all`` is not spinning
37 call to ``wait_for_all`` returns.
45 the result to any successor nodes. Only the call to ``wait_for_all``
|
| /oneTBB/test/common/ |
| H A D | test_follows_and_precedes_api.h | 68 g.wait_for_all();
85 g.wait_for_all();
100 g.wait_for_all();
117 g.wait_for_all();
163 g.wait_for_all();
185 g.wait_for_all();
215 g.wait_for_all();
|