Lines Matching refs:graph

47    tbb::flow::graph& my_graph;
49 serial_receiver(tbb::flow::graph& g) : next_value(T(0)), my_graph(g) {} in serial_receiver()
56 tbb::flow::graph& graph_reference() const override { in graph_reference()
65 tbb::flow::graph& my_graph;
67 parallel_receiver(tbb::flow::graph& g) : my_graph(g) { my_count = 0; } in parallel_receiver()
74 tbb::flow::graph& graph_reference() const override { in graph_reference()
130 …t_puts_with_decrements( int num_threads, tbb::flow::limiter_node< T >& lim , tbb::flow::graph& g) { in test_puts_with_decrements()
157 tbb::flow::graph g; in test_parallel()
172 tbb::flow::graph g; in test_parallel()
193 tbb::flow::graph g; in test_serial()
206 tbb::flow::graph g; in test_serial()
278 tbb::flow::graph g; in test_multifunction_to_limiter()
314 tbb::flow::graph g; in test_continue_msg_reception()
333 graph g; in test_reserve_release_messages()
377 tbb::flow::graph g; in test_decrementer()
438 tbb::flow::graph g; in test_try_put_without_successors()
492 graph g; in test_deduction_guides()
512 tbb::flow::graph graph{}; in test_decrement_while_try_put_task() local
514 tbb::flow::input_node<int> input{ graph, [&](tbb::flow_control & fc) -> int { in test_decrement_while_try_put_task()
519 tbb::flow::limiter_node<int, int> blockingNode{ graph, 1 }; in test_decrement_while_try_put_task()
520 tbb::flow::multifunction_node<int, std::tuple<int>> processing{ graph, tbb::flow::serial, in test_decrement_while_try_put_task()
533 graph.wait_for_all(); in test_decrement_while_try_put_task()
614 tbb::flow::graph graph; variable
615 tbb::flow::queue_node<TestLargeStruct> input_node( graph );
616 tbb::flow::function_node<TestLargeStruct> func( graph, tbb::flow::serial,
621 graph.wait_for_all();