Lines Matching refs:sink_count
799 std::atomic<int> sink_count; in run_one_continue_node_test() local
800 input_count = test_count = sink_count = 0; in run_one_continue_node_test()
808 SinkNodeType sink(g,tbb::flow::unlimited,SinkNodeBodyType(sink_count)); in run_one_continue_node_test()
849 input_count = test_count = sink_count = 0; in run_one_continue_node_test()
919 std::atomic<int> sink_count; in run_one_buffer_node_test() local
920 input_count = sink_count = 0; in run_one_buffer_node_test()
928 SinkNodeType sink(g,tbb::flow::unlimited,SinkNodeBodyType(sink_count)); in run_one_buffer_node_test()
965 input_count = sink_count = 0; in run_one_buffer_node_test()
973 input_count = sink_count = 0; in run_one_buffer_node_test()
1053 std::atomic<int> sink_count; in run_one_sequencer_node_test() local
1054 input_count = sink_count = 0; in run_one_sequencer_node_test()
1062 SinkNodeType sink(g,tbb::flow::unlimited,SinkNodeBodyType(sink_count)); in run_one_sequencer_node_test()
1100 input_count = sink_count = 0; in run_one_sequencer_node_test()
1106 input_count = sink_count = 0; in run_one_sequencer_node_test()
1173 std::atomic<int> sink_count; in run_one_priority_queue_node_test() local
1174 input_count = sink_count = 0; in run_one_priority_queue_node_test()
1184 SinkNodeType sink(g,tbb::flow::unlimited,SinkNodeBodyType(sink_count)); in run_one_priority_queue_node_test()
1224 input_count = sink_count = 0; in run_one_priority_queue_node_test()
1230 input_count = sink_count = 0; in run_one_priority_queue_node_test()
1316 std::atomic<int>sink_count; in execute_test() local
1317 input0_count = input1_count = sink_count = 0; in execute_test()
1326 SinkType sink(g,tbb::flow::unlimited,SinkBodyType(sink_count)); in execute_test()
1375 input0_count = input1_count = sink_count = 0; in execute_test()
1382 input0_count = input1_count = sink_count = 0; in execute_test()
1426 std::atomic<int>sink_count; in execute_test() local
1427 input0_count = input1_count = sink_count = 0; in execute_test()
1436 SinkType sink(g,tbb::flow::unlimited,SinkBodyType(sink_count)); in execute_test()
1479 input0_count = input1_count = sink_count = 0; in execute_test()
1486 input0_count = input1_count = sink_count = 0; in execute_test()
1560 std::atomic<int> sink_count; in run_one_limiter_node_test() local
1561 input_count = sink_count = 0; in run_one_limiter_node_test()
1569 SinkNodeType sink(g,tbb::flow::unlimited,SinkNodeBodyType(sink_count)); in run_one_limiter_node_test()
1609 input_count = sink_count = 0; in run_one_limiter_node_test()
1617 input_count = sink_count = 0; in run_one_limiter_node_test()
1800 std::atomic<int> sink_count; in run_one_indexer_node_test() local
1801 input0_count = input1_count = sink_count = 0; in run_one_indexer_node_test()
1810 SinkType sink(g,tbb::flow::unlimited,SinkBodyType(sink_count)); in run_one_indexer_node_test()
1853 input0_count = input1_count = sink_count = 0; in run_one_indexer_node_test()
1860 input0_count = input1_count = sink_count = 0; in run_one_indexer_node_test()