37 struct fake_continue_sender : public tbb::flow::sender<tbb::flow::continue_msg>
39     typedef tbb::flow::sender<tbb::flow::continue_msg>::successor_type successor_type;
74         harness_graph_executor<tbb::flow::continue_msg, OutputType>::execute_count = 0;  in run_continue_nodes()
80         utils::NativeParallelFor( p, parallel_puts<tbb::flow::continue_msg>(n) );  in run_continue_nodes()
84         size_t ec = harness_graph_executor<tbb::flow::continue_msg, OutputType>::execute_count;  in run_continue_nodes()
104         exe_node.try_put(tbb::flow::continue_msg());  in continue_nodes()
121     OutputType operator()( tbb::flow::continue_msg ) {  in operator ()()
154             utils::NativeParallelFor( p, parallel_puts<tbb::flow::continue_msg>(exe_node) );  in continue_nodes_with_copy()
185     harness_graph_executor< tbb::flow::continue_msg, OutputType>::max_executors = 0;  in run_continue_nodes()
186 …odes<OutputType>( []( tbb::flow::continue_msg i ) -> OutputType { return harness_graph_executor<tb…  in run_continue_nodes()
187 …  continue_nodes<OutputType>( &harness_graph_executor<tbb::flow::continue_msg, OutputType>::func );  in run_continue_nodes()
188 …continue_nodes<OutputType>( typename harness_graph_executor<tbb::flow::continue_msg, OutputType>::…  in run_continue_nodes()
197             run_continue_nodes<tbb::flow::continue_msg>();  in test_concurrency()
214     void operator()(continue_msg){*counter+=1;}  in operator ()()
222     broadcast_node<continue_msg> start_g(g);  in test_two_graphs()
223     continue_node<continue_msg> first_g(g, add_to_counter(count));  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()
266     void operator()( tbb::flow::continue_msg ) {  in operator ()()
277     tbb::flow::continue_node<tbb::flow::continue_msg, tbb::flow::lightweight>  in test_lightweight_policy()
279     tbb::flow::continue_node<tbb::flow::continue_msg, tbb::flow::lightweight>  in test_lightweight_policy()
285         node1.try_put(tbb::flow::continue_msg());  in test_lightweight_policy()
299     using msg_t = tbb::flow::continue_msg;  in test_follows_and_precedes_api()
335     broadcast_node<continue_msg> node_with_default_mutex_type(g);  in test_successor_cache_specialization()
336     buffer_node<continue_msg> node_with_non_default_mutex_type(g);  in test_successor_cache_specialization()
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()
347     node_with_default_mutex_type.try_put(continue_msg());  in test_successor_cache_specialization()
348     node_with_non_default_mutex_type.try_put(continue_msg());  in test_successor_cache_specialization()
352     continue_msg storage;  in test_successor_cache_specialization()