833         int nb_cnt = tbb::flow::copy_body<SinkNodeBodyType>(sink).count_value();  in run_one_continue_node_test()  local
839             CHECK_MESSAGE( (nb_cnt <= t_cnt), "Too many items received by sink nodes");  in run_one_continue_node_test()
846             CHECK_MESSAGE( (nb_cnt == g_NumItems), "Missing items in absorbers");  in run_one_continue_node_test()
947         int nb_cnt = tbb::flow::copy_body<SinkNodeBodyType>(sink).count_value();  in run_one_buffer_node_test()  local
952             CHECK_MESSAGE( (nb_cnt <= ib_cnt), "Too many items received by sink nodes");  in run_one_buffer_node_test()
958             CHECK_MESSAGE( (nb_cnt == g_NumItems), "Missing items in absorbers");  in run_one_buffer_node_test()
1081         int nb_cnt = tbb::flow::copy_body<SinkNodeBodyType>(sink).count_value();  in run_one_sequencer_node_test()  local
1086             CHECK_MESSAGE( (nb_cnt <= ib_cnt), "Too many items received by sink nodes");  in run_one_sequencer_node_test()
1092             CHECK_MESSAGE( (nb_cnt == g_NumItems), "Missing items in absorbers");  in run_one_sequencer_node_test()
1204         int nb_cnt = tbb::flow::copy_body<SinkNodeBodyType>(sink).count_value();  in run_one_priority_queue_node_test()  local
1209             CHECK_MESSAGE( (nb_cnt <= ib_cnt), "Too many items received by sink nodes");  in run_one_priority_queue_node_test()
1215             CHECK_MESSAGE( (nb_cnt == g_NumItems), "Missing items in absorbers");  in run_one_priority_queue_node_test()
1349             int nb_cnt = tbb::flow::copy_body<SinkBodyType>(sink).count_value();  in execute_test()  local
1354 …CHECK_MESSAGE( (nb_cnt <= ((ib0_cnt < ib1_cnt) ? ib0_cnt : ib1_cnt)), "Too many items received by …  in execute_test()
1367                 CHECK_MESSAGE( (nb_cnt == g_NumItems), "Missing items in absorbers");  in execute_test()
1386             nb_cnt = tbb::flow::copy_body<SinkBodyType>(sink).count_value();  in execute_test()
1459             int nb_cnt = tbb::flow::copy_body<SinkBodyType>(sink).count_value();  in execute_test()  local
1464 …CHECK_MESSAGE( (nb_cnt <= ((ib0_cnt < ib1_cnt) ? ib0_cnt : ib1_cnt)), "Too many items received by …  in execute_test()
1471                 CHECK_MESSAGE( (nb_cnt == g_NumItems), "Missing items in absorbers");  in execute_test()
1490             nb_cnt = tbb::flow::copy_body<SinkBodyType>(sink).count_value();  in execute_test()
1588         int nb_cnt = tbb::flow::copy_body<SinkNodeBodyType>(sink).count_value();  in run_one_limiter_node_test()  local
1593             CHECK_MESSAGE( (nb_cnt <= ib_cnt), "Too many items received by sink nodes");  in run_one_limiter_node_test()
1601             CHECK_MESSAGE( (nb_cnt == g_NumThreads + 1), "Missing items in absorbers");  in run_one_limiter_node_test()
1833         int nb_cnt = tbb::flow::copy_body<SinkBodyType>(sink).count_value();  in run_one_indexer_node_test()  local
1838             CHECK_MESSAGE( (nb_cnt <= ib0_cnt + ib1_cnt), "Too many items received by sink nodes");  in run_one_indexer_node_test()
1845             CHECK_MESSAGE( (nb_cnt == 2*g_NumItems), "Missing items in absorbers");  in run_one_indexer_node_test()
1864         nb_cnt = tbb::flow::copy_body<SinkBodyType>(sink).count_value();  in run_one_indexer_node_test()