Lines Matching refs:tbb
38 typedef typename tbb::flow::join_node<OutputTupleType, tbb::flow::tag_matching> join_node_type;
52 typedef typename std::tuple<int, tbb::flow::continue_msg> input_tuple_type;
53 typedef tbb::flow::join_node<input_tuple_type, tbb::flow::reserving> input_join_type;
61 tbb::flow::graph g; in test()
63 JType * my_join = makeJoin<N, JType, tbb::flow::tag_matching>::create(g); in test()
65 tbb::flow::input_node<tbb::flow::continue_msg> snode(g, recirc_input_node_body()); in test()
67 … input_join_type * my_input_join = makeJoin<2, input_join_type, tbb::flow::reserving>::create(g); in test()
69 tbb::flow::make_edge(snode, std::get<1>(my_input_join->input_ports())); in test()
71 tbb::flow::queue_node<int> tag_queue(g); in test()
72 tbb::flow::make_edge(tag_queue, tbb::flow::input_port<0>(*my_input_join)); in test()
76 …tbb::flow::function_node<TType, int> recreate_tag(g, tbb::flow::unlimited, recirc_output_func_body… in test()
77 tbb::flow::make_edge(*my_join, recreate_tag); in test()
79 tbb::flow::make_edge(recreate_tag, tag_queue); in test()
107 tbb::flow::remove_edge(*my_join, recreate_tag); in test()
108 makeJoin<N, JType, tbb::flow::tag_matching>::destroy(my_join); in test()
109 tbb::flow::remove_edge(tag_queue, tbb::flow::input_port<0>(*my_input_join)); in test()
110 tbb::flow::remove_edge(snode, tbb::flow::input_port<1>(*my_input_join)); in test()
111 makeJoin<2, input_join_type, tbb::flow::reserving>::destroy(my_input_join); in test()
119 typedef tbb::flow::join_node<JType, tbb::flow::tag_matching> join_node_type;
134 test_main<tbb::flow::queueing>();
135 test_main<tbb::flow::reserving>();
136 test_main<tbb::flow::tag_matching>();