Lines Matching refs:count_value
199 int count_value() { return (int)*my_current_val; } in count_value() function in test_input_body
221 int count_value() { return (int)*my_current_val; } in count_value() function in test_input_body
237 int count_value() { return *my_count; } in count_value() function in absorber_body
279 int count_value() { return *my_count; } in count_value() function in multifunction_node_body
334 int count_value() { return (int)*my_current_val; } in count_value() function in tuple_test_input_body
386 int src_cnt = tbb::flow::copy_body<src_body_type>(sn).count_value(); in run_one_input_node_test()
387 int sink_cnt = tbb::flow::copy_body<parallel_absorb_body_type>(parallel_fn).count_value(); in run_one_input_node_test()
405 src_cnt = tbb::flow::copy_body<src_body_type>(sn).count_value(); 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()
531 int ib0_cnt = tbb::flow::copy_body<InputNodeBodyType0>(input0).count_value(); in run_one_functype_node_test()
532 int ib1_cnt = tbb::flow::copy_body<InputNodeBodyType1>(input1).count_value(); in run_one_functype_node_test()
533 int t_cnt = tbb::flow::copy_body<TestNodeBodyType>(node_to_test).count_value(); in run_one_functype_node_test()
534 int nb0_cnt = tbb::flow::copy_body<SinkNodeBodyType0>(sink0).count_value(); in run_one_functype_node_test()
535 int nb1_cnt = tbb::flow::copy_body<SinkNodeBodyType1>(sink1).count_value(); in run_one_functype_node_test()
552 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<InputNodeBodyType0>(input0).count_value()),"Reset input … in run_one_functype_node_test()
553 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<InputNodeBodyType1>(input1).count_value()),"Reset input … in run_one_functype_node_test()
554 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<TestNodeBodyType>(node_to_test).count_value()),"Reset te… in run_one_functype_node_test()
555 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<SinkNodeBodyType0>(sink0).count_value()),"Reset sink 0 f… in run_one_functype_node_test()
556 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<SinkNodeBodyType1>(sink1).count_value()),"Reset sink 1 f… in run_one_functype_node_test()
831 int ib_cnt = tbb::flow::copy_body<InputNodeBodyType>(input).count_value(); in run_one_continue_node_test()
832 int t_cnt = tbb::flow::copy_body<TestNodeBodyType>(node_to_test).count_value(); in run_one_continue_node_test()
833 int nb_cnt = tbb::flow::copy_body<SinkNodeBodyType>(sink).count_value(); in run_one_continue_node_test()
851 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<InputNodeBodyType>(input).count_value()),"Reset input fa… in run_one_continue_node_test()
852 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<TestNodeBodyType>(node_to_test).count_value()),"Reset te… 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()
946 int ib_cnt = tbb::flow::copy_body<InputNodeBodyType>(input).count_value(); in run_one_buffer_node_test()
947 int nb_cnt = tbb::flow::copy_body<SinkNodeBodyType>(sink).count_value(); in run_one_buffer_node_test()
975 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<InputNodeBodyType>(input).count_value()),"Reset input fa… 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()
1080 int ib_cnt = tbb::flow::copy_body<InputNodeBodyType>(input).count_value(); in run_one_sequencer_node_test()
1081 int nb_cnt = tbb::flow::copy_body<SinkNodeBodyType>(sink).count_value(); in run_one_sequencer_node_test()
1108 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<InputNodeBodyType>(input).count_value()),"Reset input fa… 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()
1203 int ib_cnt = tbb::flow::copy_body<InputNodeBodyType>(input).count_value(); 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()
1232 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<InputNodeBodyType>(input).count_value()),"Reset input fa… 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()
1347 int ib0_cnt = tbb::flow::copy_body<InputBodyType0>(input0).count_value(); in execute_test()
1348 int ib1_cnt = tbb::flow::copy_body<InputBodyType1>(input1).count_value(); in execute_test()
1349 int nb_cnt = tbb::flow::copy_body<SinkBodyType>(sink).count_value(); in execute_test()
1384 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<InputBodyType0>(input0).count_value()),"Reset input fail… in execute_test()
1385 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<InputBodyType1>(input1).count_value()),"Reset input fail… 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()
1457 int ib0_cnt = tbb::flow::copy_body<InputBodyType0>(input0).count_value(); in execute_test()
1458 int ib1_cnt = tbb::flow::copy_body<InputBodyType1>(input1).count_value(); in execute_test()
1459 int nb_cnt = tbb::flow::copy_body<SinkBodyType>(sink).count_value(); in execute_test()
1488 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<InputBodyType0>(input0).count_value()),"Reset input fail… in execute_test()
1489 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<InputBodyType1>(input1).count_value()),"Reset input fail… 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()
1587 int ib_cnt = tbb::flow::copy_body<InputNodeBodyType>(input).count_value(); in run_one_limiter_node_test()
1588 int nb_cnt = tbb::flow::copy_body<SinkNodeBodyType>(sink).count_value(); in run_one_limiter_node_test()
1619 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<InputNodeBodyType>(input).count_value()),"Reset input fa… 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()
1713 int ib_cnt = tbb::flow::copy_body<InputBodyType>(input).count_value(); in run_one_split_node_test()
1714 int nb0_cnt = tbb::flow::copy_body<SinkBodyType0>(sink0).count_value(); in run_one_split_node_test()
1715 int nb1_cnt = tbb::flow::copy_body<SinkBodyType1>(sink1).count_value(); in run_one_split_node_test()
1730 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<InputBodyType>(input).count_value()),"Reset input failed… in run_one_split_node_test()
1731 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<SinkBodyType0>(sink0).count_value()),"Reset sink 0 faile… in run_one_split_node_test()
1732 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<SinkBodyType1>(sink1).count_value()),"Reset sink 1 faile… in run_one_split_node_test()
1831 int ib0_cnt = tbb::flow::copy_body<InputBodyType0>(input0).count_value(); in run_one_indexer_node_test()
1832 int ib1_cnt = tbb::flow::copy_body<InputBodyType1>(input1).count_value(); in run_one_indexer_node_test()
1833 int nb_cnt = tbb::flow::copy_body<SinkBodyType>(sink).count_value(); in run_one_indexer_node_test()
1862 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<InputBodyType0>(input0).count_value()),"Reset input fail… in run_one_indexer_node_test()
1863 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<InputBodyType1>(input1).count_value()),"Reset input fail… 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()