808     SinkNodeType sink(g,tbb::flow::unlimited,SinkNodeBodyType(sink_count));  in run_one_continue_node_test()  local
815     make_edge(node_to_test, sink);  in run_one_continue_node_test()
833         int nb_cnt = tbb::flow::copy_body<SinkNodeBodyType>(sink).count_value();  in run_one_continue_node_test()
853 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<SinkNodeBodyType>(sink).count_value()),"Reset sink faile…  in run_one_continue_node_test()
928     SinkNodeType sink(g,tbb::flow::unlimited,SinkNodeBodyType(sink_count));  in run_one_buffer_node_test()  local
930     make_edge(node_to_test, sink);  in run_one_buffer_node_test()
947         int nb_cnt = tbb::flow::copy_body<SinkNodeBodyType>(sink).count_value();  in run_one_buffer_node_test()
961             remove_edge(node_to_test, sink);  in run_one_buffer_node_test()
968             make_edge(node_to_test, sink);  in run_one_buffer_node_test()
976 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<SinkNodeBodyType>(sink).count_value()),"Reset sink faile…  in run_one_buffer_node_test()
1062     SinkNodeType sink(g,tbb::flow::unlimited,SinkNodeBodyType(sink_count));  in run_one_sequencer_node_test()  local
1064     make_edge(node_to_test, sink);  in run_one_sequencer_node_test()
1081         int nb_cnt = tbb::flow::copy_body<SinkNodeBodyType>(sink).count_value();  in run_one_sequencer_node_test()
1095             remove_edge(node_to_test, sink);  in run_one_sequencer_node_test()
1101             make_edge(node_to_test, sink);  in run_one_sequencer_node_test()
1109 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<SinkNodeBodyType>(sink).count_value()),"Reset sink faile…  in run_one_sequencer_node_test()
1184     SinkNodeType sink(g,tbb::flow::unlimited,SinkNodeBodyType(sink_count));  in run_one_priority_queue_node_test()  local
1187     make_edge(node_to_test, sink);  in run_one_priority_queue_node_test()
1204         int nb_cnt = tbb::flow::copy_body<SinkNodeBodyType>(sink).count_value();  in run_one_priority_queue_node_test()
1218             remove_edge(node_to_test, sink);  in run_one_priority_queue_node_test()
1225             make_edge(node_to_test, sink);  in run_one_priority_queue_node_test()
1233 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<SinkNodeBodyType>(sink).count_value()),"Reset sink faile…  in run_one_priority_queue_node_test()
1326         SinkType sink(g,tbb::flow::unlimited,SinkBodyType(sink_count));  in execute_test()  local
1329         make_edge(node_to_test, sink);  in execute_test()
1349             int nb_cnt = tbb::flow::copy_body<SinkBodyType>(sink).count_value();  in execute_test()
1370                 remove_edge(node_to_test, sink);  in execute_test()
1376                 make_edge(node_to_test, sink);  in execute_test()
1386             nb_cnt = tbb::flow::copy_body<SinkBodyType>(sink).count_value();  in execute_test()
1387 … CHECK_MESSAGE( (0 == tbb::flow::copy_body<SinkBodyType>(sink).count_value()),"Reset sink failed");  in execute_test()
1436         SinkType sink(g,tbb::flow::unlimited,SinkBodyType(sink_count));  in execute_test()  local
1439         make_edge(node_to_test, sink);  in execute_test()
1459             int nb_cnt = tbb::flow::copy_body<SinkBodyType>(sink).count_value();  in execute_test()
1474                 remove_edge(node_to_test, sink);  in execute_test()
1480                 make_edge(node_to_test, sink);  in execute_test()
1490             nb_cnt = tbb::flow::copy_body<SinkBodyType>(sink).count_value();  in execute_test()
1491 … CHECK_MESSAGE( (0 == tbb::flow::copy_body<SinkBodyType>(sink).count_value()),"Reset sink failed");  in execute_test()
1569     SinkNodeType sink(g,tbb::flow::unlimited,SinkNodeBodyType(sink_count));  in run_one_limiter_node_test()  local
1571     make_edge(node_to_test, sink);  in run_one_limiter_node_test()
1588         int nb_cnt = tbb::flow::copy_body<SinkNodeBodyType>(sink).count_value();  in run_one_limiter_node_test()
1604             remove_edge(node_to_test, sink);  in run_one_limiter_node_test()
1612             make_edge(node_to_test, sink);  in run_one_limiter_node_test()
1620 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<SinkNodeBodyType>(sink).count_value()),"Reset sink faile…  in run_one_limiter_node_test()
1810     SinkType sink(g,tbb::flow::unlimited,SinkBodyType(sink_count));  in run_one_indexer_node_test()  local
1813     make_edge(node_to_test, sink);  in run_one_indexer_node_test()
1833         int nb_cnt = tbb::flow::copy_body<SinkBodyType>(sink).count_value();  in run_one_indexer_node_test()
1848             remove_edge(node_to_test, sink);  in run_one_indexer_node_test()
1854             make_edge(node_to_test, sink);  in run_one_indexer_node_test()
1864         nb_cnt = tbb::flow::copy_body<SinkBodyType>(sink).count_value();  in run_one_indexer_node_test()
1865 … CHECK_MESSAGE( (0 == tbb::flow::copy_body<SinkBodyType>(sink).count_value()),"Reset sink failed");  in run_one_indexer_node_test()