Lines Matching refs:my_join

1036     static void add_input_nodes(join_node_type &my_join, tbb::flow::graph &g, int nInputs) {
1039             tbb::flow::make_edge(*new_node, tbb::flow::input_port<ELEM-1>(my_join));
1044         input_node_helper<ELEM-1, JNT>::add_input_nodes(my_join, g, nInputs);
1047 …static void add_recirc_func_nodes(join_node_type &my_join, input_join_type &my_input, tbb::flow::g…
1049         tbb::flow::make_edge(*new_node, tbb::flow::input_port<ELEM-1>(my_join));
1052         input_node_helper<ELEM-1, JNT>::add_recirc_func_nodes(my_join, my_input, g);
1072     static void remove_input_nodes(join_node_type& my_join, int nInputs) {
1075             tbb::flow::remove_edge(*dp, tbb::flow::input_port<ELEM-1>(my_join));
1078         input_node_helper<ELEM-1, JNT>::remove_input_nodes(my_join, nInputs);
1081     static void remove_recirc_func_nodes(join_node_type& my_join, input_join_type &my_input) {
1083         tbb::flow::remove_edge(*fn, tbb::flow::input_port<ELEM-1>(my_join));
1086         input_node_helper<ELEM-1, JNT>::remove_recirc_func_nodes(my_join, my_input);
1103     static void add_input_nodes(join_node_type &my_join, tbb::flow::graph &g, int nInputs) {
1106             tbb::flow::make_edge(*new_node, tbb::flow::input_port<0>(my_join));
1112 …static void add_recirc_func_nodes(join_node_type &my_join, input_join_type &my_input, tbb::flow::g…
1114         tbb::flow::make_edge(*new_node, tbb::flow::input_port<0>(my_join));
1132     static void remove_input_nodes(join_node_type& my_join, int nInputs) {
1135             tbb::flow::remove_edge(*dp, tbb::flow::input_port<0>(my_join));
1140     static void remove_recirc_func_nodes(join_node_type& my_join, input_join_type &my_input) {
1142         tbb::flow::remove_edge(*fn, tbb::flow::input_port<0>(my_join));
1181             JType* my_join = makeJoin<TUPLE_SIZE, JType, JP>::create(g);
1185             tbb::flow::make_edge(*my_join, outq1);
1186             tbb::flow::make_edge(*my_join, outq2);
1188             input_node_helper<TUPLE_SIZE, JType>::add_input_nodes((*my_join), g, nInputs);
1210             input_node_helper<TUPLE_SIZE, JType>::remove_input_nodes((*my_join), nInputs);
1211             tbb::flow::remove_edge(*my_join, outq1);
1212             tbb::flow::remove_edge(*my_join, outq2);
1213             makeJoin<TUPLE_SIZE, JType, JP>::destroy(my_join);
1229     static void add_queue_nodes(tbb::flow::graph &g, JType &my_join) {
1230         serial_queue_helper<ELEM-1, JType>::add_queue_nodes(g, my_join);
1232         tbb::flow::make_edge(*new_node, std::get<ELEM-1>(my_join.input_ports()));
1257     static void remove_queue_nodes(JType &my_join) {
1259         tbb::flow::remove_edge(*vptr, std::get<ELEM-1>(my_join.input_ports()));
1260         serial_queue_helper<ELEM-1, JType>::remove_queue_nodes(my_join);
1275     static void add_queue_nodes(tbb::flow::graph &g, JType &my_join) {
1277         tbb::flow::make_edge(*new_node, tbb::flow::input_port<0>(my_join));
1298     static void remove_queue_nodes(JType &my_join) {
1300         tbb::flow::remove_edge(*vptr, std::get<0>(my_join.input_ports()));
1311 void test_one_serial(JType &my_join, tbb::flow::graph &g) {
1316     serial_queue_helper<TUPLE_SIZE, JType>::add_queue_nodes(g, my_join);
1320     tbb::flow::make_edge(my_join, q3);
1352     tbb::flow::remove_edge(my_join, q3);
1354     tbb::flow::make_edge(my_join, limiter);
1379     serial_queue_helper<TUPLE_SIZE, JType>::remove_queue_nodes(my_join);
1395         JType* my_join = makeJoin<TUPLE_SIZE, JType, JP>::create(g);
1396         test_input_ports_return_ref(*my_join);
1406         test_one_serial<JType, JP>(*my_join, g);
1408         std::vector<JType>join_vector(ELEMS, *my_join);
1410         makeJoin<TUPLE_SIZE, JType, JP>::destroy(my_join);