806     InputNodeType input(g, InputNodeBodyType(input_count));  in run_one_continue_node_test()  local
810     make_edge(input, b1);  in run_one_continue_node_test()
820                 input.activate();  in run_one_continue_node_test()
826                 input.activate();  in run_one_continue_node_test()
831         int ib_cnt = tbb::flow::copy_body<InputNodeBodyType>(input).count_value();  in run_one_continue_node_test()
851 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<InputNodeBodyType>(input).count_value()),"Reset input fa…  in run_one_continue_node_test()
926     InputNodeType input(g, InputNodeBodyType(input_count));  in run_one_buffer_node_test()  local
929     make_edge(input,node_to_test);  in run_one_buffer_node_test()
935                 input.activate();  in run_one_buffer_node_test()
941                 input.activate();  in run_one_buffer_node_test()
946         int ib_cnt = tbb::flow::copy_body<InputNodeBodyType>(input).count_value();  in run_one_buffer_node_test()
975 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<InputNodeBodyType>(input).count_value()),"Reset input fa…  in run_one_buffer_node_test()
1060     InputNodeType input(g, InputNodeBodyType(input_count));  in run_one_sequencer_node_test()  local
1063     make_edge(input,node_to_test);  in run_one_sequencer_node_test()
1069                 input.activate();  in run_one_sequencer_node_test()
1075                 input.activate();  in run_one_sequencer_node_test()
1080         int ib_cnt = tbb::flow::copy_body<InputNodeBodyType>(input).count_value();  in run_one_sequencer_node_test()
1108 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<InputNodeBodyType>(input).count_value()),"Reset input fa…  in run_one_sequencer_node_test()
1180     InputNodeType input(g, InputNodeBodyType(input_count));  in run_one_priority_queue_node_test()  local
1186     make_edge(input,node_to_test);  in run_one_priority_queue_node_test()
1192                 input.activate();  in run_one_priority_queue_node_test()
1198                 input.activate();  in run_one_priority_queue_node_test()
1203         int ib_cnt = tbb::flow::copy_body<InputNodeBodyType>(input).count_value();  in run_one_priority_queue_node_test()
1232 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<InputNodeBodyType>(input).count_value()),"Reset input fa…  in run_one_priority_queue_node_test()
1567     InputNodeType input(g, InputNodeBodyType(input_count));  in run_one_limiter_node_test()  local
1570     make_edge(input,node_to_test);  in run_one_limiter_node_test()
1576                 input.activate();  in run_one_limiter_node_test()
1582                 input.activate();  in run_one_limiter_node_test()
1587         int ib_cnt = tbb::flow::copy_body<InputNodeBodyType>(input).count_value();  in run_one_limiter_node_test()
1619 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<InputNodeBodyType>(input).count_value()),"Reset input fa…  in run_one_limiter_node_test()
1690     InputType input(g, InputBodyType(input_count));  in run_one_split_node_test()  local
1694     make_edge(input, node_to_test);  in run_one_split_node_test()
1702                 input.activate();  in run_one_split_node_test()
1708                 input.activate();  in run_one_split_node_test()
1713         int ib_cnt = tbb::flow::copy_body<InputBodyType>(input).count_value();  in run_one_split_node_test()
1730 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<InputBodyType>(input).count_value()),"Reset input failed…  in run_one_split_node_test()