831         int ib_cnt = tbb::flow::copy_body<InputNodeBodyType>(input).count_value();  in run_one_continue_node_test()  local
837             CHECK_MESSAGE( (ib_cnt <= g_NumItems), "Too many items sent by inputs");  in run_one_continue_node_test()
838             CHECK_MESSAGE( (ib_cnt >= t_cnt), "Too many items received by test node");  in run_one_continue_node_test()
844             CHECK_MESSAGE( (ib_cnt == g_NumItems), "Missing invocations of input_node");  in run_one_continue_node_test()
946         int ib_cnt = tbb::flow::copy_body<InputNodeBodyType>(input).count_value();  in run_one_buffer_node_test()  local
951             CHECK_MESSAGE( (ib_cnt <= g_NumItems), "Too many items sent by inputs");  in run_one_buffer_node_test()
952             CHECK_MESSAGE( (nb_cnt <= ib_cnt), "Too many items received by sink nodes");  in run_one_buffer_node_test()
957             CHECK_MESSAGE( (ib_cnt == g_NumItems), "Missing invocations of input_node");  in run_one_buffer_node_test()
1080         int ib_cnt = tbb::flow::copy_body<InputNodeBodyType>(input).count_value();  in run_one_sequencer_node_test()  local
1085             CHECK_MESSAGE( (ib_cnt <= g_NumItems), "Too many items sent by inputs");  in run_one_sequencer_node_test()
1086             CHECK_MESSAGE( (nb_cnt <= ib_cnt), "Too many items received by sink nodes");  in run_one_sequencer_node_test()
1091             CHECK_MESSAGE( (ib_cnt == g_NumItems), "Missing invocations of input_node");  in run_one_sequencer_node_test()
1203         int ib_cnt = tbb::flow::copy_body<InputNodeBodyType>(input).count_value();  in run_one_priority_queue_node_test()  local
1208             CHECK_MESSAGE( (ib_cnt <= g_NumItems), "Too many items sent by inputs");  in run_one_priority_queue_node_test()
1209             CHECK_MESSAGE( (nb_cnt <= ib_cnt), "Too many items received by sink nodes");  in run_one_priority_queue_node_test()
1214             CHECK_MESSAGE( (ib_cnt == g_NumItems), "Missing invocations of input_node");  in run_one_priority_queue_node_test()
1587         int ib_cnt = tbb::flow::copy_body<InputNodeBodyType>(input).count_value();  in run_one_limiter_node_test()  local
1592             CHECK_MESSAGE( (ib_cnt <= g_NumItems), "Too many items sent by inputs");  in run_one_limiter_node_test()
1593             CHECK_MESSAGE( (nb_cnt <= ib_cnt), "Too many items received by sink nodes");  in run_one_limiter_node_test()
1600             CHECK_MESSAGE( (ib_cnt == g_NumThreads + 2), "Missing invocations of input_node");  in run_one_limiter_node_test()
1713         int ib_cnt = tbb::flow::copy_body<InputBodyType>(input).count_value();  in run_one_split_node_test()  local
1719             CHECK_MESSAGE( (ib_cnt <= 2*g_NumItems), "Too many items sent by input");  in run_one_split_node_test()
1720 …          CHECK_MESSAGE( (nb0_cnt + nb1_cnt <= ib_cnt*2), "Too many items received by sink nodes");  in run_one_split_node_test()
1725             CHECK_MESSAGE( (ib_cnt == g_NumItems), "Missing invocations of input_nodes");  in run_one_split_node_test()