Lines Matching refs:node_to_test
503 TestNodeType node_to_test(g, Conc, TestNodeBodyType(test_count)); in run_one_functype_node_test() local
506 make_edge(input0, node_to_test); in run_one_functype_node_test()
507 make_edge(input1, node_to_test); in run_one_functype_node_test()
508 make_edge(AttachPoint<TestNodeType, TypeToSink0, 0, NFT>::GetSender(node_to_test), sink0); in run_one_functype_node_test()
509 make_edge(AttachPoint<TestNodeType, TypeToSink1, 1, NFT>::GetSender(node_to_test), sink1); in run_one_functype_node_test()
533 int t_cnt = tbb::flow::copy_body<TestNodeBodyType>(node_to_test).count_value(); in run_one_functype_node_test()
554 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<TestNodeBodyType>(node_to_test).count_value()),"Reset te… in run_one_functype_node_test()
807 TTestNodeType node_to_test(g, TestNodeBodyType(test_count)); in run_one_continue_node_test() local
813 make_edge(b2,node_to_test); in run_one_continue_node_test()
814 make_edge(b3,node_to_test); in run_one_continue_node_test()
815 make_edge(node_to_test, sink); in run_one_continue_node_test()
832 int t_cnt = tbb::flow::copy_body<TestNodeBodyType>(node_to_test).count_value(); in run_one_continue_node_test()
852 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<TestNodeBodyType>(node_to_test).count_value()),"Reset te… in run_one_continue_node_test()
927 TestNodeType node_to_test(g); in run_one_buffer_node_test() local
929 make_edge(input,node_to_test); in run_one_buffer_node_test()
930 make_edge(node_to_test, sink); in run_one_buffer_node_test()
961 remove_edge(node_to_test, sink); in run_one_buffer_node_test()
962 node_to_test.try_put(BufferItemType()); in run_one_buffer_node_test()
967 CHECK_MESSAGE( (!node_to_test.try_get(tmp)), "node not empty"); in run_one_buffer_node_test()
968 make_edge(node_to_test, sink); in run_one_buffer_node_test()
1061 TestNodeType node_to_test(g,SeqBodyType()); in run_one_sequencer_node_test() local
1063 make_edge(input,node_to_test); in run_one_sequencer_node_test()
1064 make_edge(node_to_test, sink); in run_one_sequencer_node_test()
1095 remove_edge(node_to_test, sink); in run_one_sequencer_node_test()
1096 node_to_test.try_put(BufferItemType(g_NumItems + 1)); in run_one_sequencer_node_test()
1097 node_to_test.try_put(BufferItemType(1)); in run_one_sequencer_node_test()
1101 make_edge(node_to_test, sink); in run_one_sequencer_node_test()
1182 TestNodeType node_to_test(g); in run_one_priority_queue_node_test() local
1186 make_edge(input,node_to_test); in run_one_priority_queue_node_test()
1187 make_edge(node_to_test, sink); in run_one_priority_queue_node_test()
1218 remove_edge(node_to_test, sink); in run_one_priority_queue_node_test()
1219 node_to_test.try_put(BufferItemType(g_NumItems + 1)); in run_one_priority_queue_node_test()
1220 node_to_test.try_put(BufferItemType(g_NumItems + 2)); in run_one_priority_queue_node_test()
1221 node_to_test.try_put(BufferItemType()); in run_one_priority_queue_node_test()
1225 make_edge(node_to_test, sink); in run_one_priority_queue_node_test()
1325 TestJoinType node_to_test(g); in execute_test() local
1327 make_edge(input0,tbb::flow::input_port<0>(node_to_test)); in execute_test()
1328 make_edge(input1,tbb::flow::input_port<1>(node_to_test)); in execute_test()
1329 make_edge(node_to_test, sink); in execute_test()
1370 remove_edge(node_to_test, sink); in execute_test()
1371 tbb::flow::input_port<0>(node_to_test).try_put(ItemType0(g_NumItems + 1)); in execute_test()
1372 tbb::flow::input_port<1>(node_to_test).try_put(ItemType1(g_NumItems + 2)); in execute_test()
1376 make_edge(node_to_test, sink); in execute_test()
1435 …TestJoinType node_to_test(g, tag_func<ItemType0>(ItemType0(2)), tag_func<ItemType1>(ItemType1(3))); in execute_test() local
1437 make_edge(input0,tbb::flow::input_port<0>(node_to_test)); in execute_test()
1438 make_edge(input1,tbb::flow::input_port<1>(node_to_test)); in execute_test()
1439 make_edge(node_to_test, sink); in execute_test()
1474 remove_edge(node_to_test, sink); in execute_test()
1475 tbb::flow::input_port<0>(node_to_test).try_put(ItemType0(g_NumItems + 4)); in execute_test()
1476 tbb::flow::input_port<1>(node_to_test).try_put(ItemType1(g_NumItems + 2)); in execute_test()
1480 make_edge(node_to_test, sink); in execute_test()
1568 TestNodeType node_to_test(g,g_NumThreads + 1); in run_one_limiter_node_test() local
1570 make_edge(input,node_to_test); in run_one_limiter_node_test()
1571 make_edge(node_to_test, sink); in run_one_limiter_node_test()
1604 remove_edge(node_to_test, sink); in run_one_limiter_node_test()
1605 node_to_test.try_put(BufferItemType()); in run_one_limiter_node_test()
1606 node_to_test.try_put(BufferItemType()); in run_one_limiter_node_test()
1611 CHECK_MESSAGE( (!node_to_test.try_get(tmp)), "node not empty"); in run_one_limiter_node_test()
1612 make_edge(node_to_test, sink); in run_one_limiter_node_test()
1691 TestSplitType node_to_test(g); in run_one_split_node_test() local
1694 make_edge(input, node_to_test); in run_one_split_node_test()
1695 make_edge(tbb::flow::output_port<0>(node_to_test), sink0); in run_one_split_node_test()
1696 make_edge(tbb::flow::output_port<1>(node_to_test), sink1); in run_one_split_node_test()
1809 TestNodeType node_to_test(g); in run_one_indexer_node_test() local
1811 make_edge(input0,tbb::flow::input_port<0>(node_to_test)); in run_one_indexer_node_test()
1812 make_edge(input1,tbb::flow::input_port<1>(node_to_test)); in run_one_indexer_node_test()
1813 make_edge(node_to_test, sink); in run_one_indexer_node_test()
1848 remove_edge(node_to_test, sink); in run_one_indexer_node_test()
1849 tbb::flow::input_port<0>(node_to_test).try_put(ItemType0(g_NumItems + 4)); in run_one_indexer_node_test()
1850 tbb::flow::input_port<1>(node_to_test).try_put(ItemType1(g_NumItems + 2)); in run_one_indexer_node_test()
1854 make_edge(node_to_test, sink); in run_one_indexer_node_test()