Searched refs:sink_cnt (Results 1 – 1 of 1) sorted by relevance
387 int sink_cnt = tbb::flow::copy_body<parallel_absorb_body_type>(parallel_fn).count_value(); in run_one_input_node_test() local392 CHECK_MESSAGE( (sink_cnt <= src_cnt), "Too many input_node items received"); in run_one_input_node_test()398 CHECK_MESSAGE( (sink_cnt == src_cnt), "Incorrect # input_node items received"); in run_one_input_node_test()406 sink_cnt = tbb::flow::copy_body<parallel_absorb_body_type>(parallel_fn).count_value(); in run_one_input_node_test()408 CHECK_MESSAGE( (sink_cnt == 0), "sink_node count not reset"); in run_one_input_node_test()