Lines Matching refs:g
46 test_push_receiver(tbb::flow::graph& g) : my_graph(g) { in test_push_receiver() argument
115 tbb::flow::graph g; in test_single_dest() local
116 tbb::flow::input_node<T> src(g, my_input_body<T>() ); in test_single_dest()
117 test_push_receiver<T> dest(g); in test_single_dest()
120 g.wait_for_all(); in test_single_dest()
127 tbb::flow::input_node<T> src3(g, my_input_body<T>() ); in test_single_dest()
131 tbb::flow::function_node<T,bool> dest3(g, tbb::flow::unlimited, b3 ); in test_single_dest()
133 g.wait_for_all(); in test_single_dest()
140 tbb::flow::input_node<T> src2(g, my_input_body<T>() ); in test_single_dest()
145 tbb::flow::function_node<T,bool,tbb::flow::rejecting> dest2(g, tbb::flow::serial, b2 ); in test_single_dest()
147 g.wait_for_all(); in test_single_dest()
156 test_push_receiver<T> dest_c(g); in test_single_dest()
158 g.wait_for_all(); in test_single_dest()
166 tbb::flow::graph g; in test_reset() local
168 tbb::flow::input_node<int> src3(g, my_input_body<int>()); in test_reset()
170 tbb::flow::input_node<int> src_inactive(g, my_input_body<int>()); in test_reset()
172 tbb::flow::function_node<int,bool> dest3(g, tbb::flow::unlimited, b3); in test_reset()
175 g.wait_for_all(); in test_reset()
183 g.reset(tbb::flow::rf_reset_bodies); // <-- re-initializes the counts. in test_reset()
187 g.wait_for_all(); in test_reset()
194 g.reset(); // doesn't reset the input_node_body to initial state, but does spawn a task 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()
223 g.reset(tbb::flow::rf_reset_bodies); // <-- reinitializes the counts in test_reset()
225 g.wait_for_all(); in test_reset()
233 g.wait_for_all(); in test_reset()
239 g.reset(); // doesn't reset the input_node_body to initial state, and doesn't in test_reset()
242 g.wait_for_all(); in test_reset()
250 g.wait_for_all(); in test_reset()
262 graph g; in test_follows_and_precedes_api() local
265 buffer_node<bool>(g), in test_follows_and_precedes_api()
266 buffer_node<bool>(g), in test_follows_and_precedes_api()
267 buffer_node<bool>(g) in test_follows_and_precedes_api()
282 g.wait_for_all(); in test_follows_and_precedes_api()
323 tbb::flow::graph g; variable
324 tbb::flow::input_node<int> in(g, [&](tbb::flow_control& fc) { fc.stop(); return 0;}); in __anone180743f0302()