Lines Matching refs:NUMBER_OF_MSGS

99 const int NUMBER_OF_MSGS = 10;  variable
145     const int N = NUMBER_OF_MSGS;  in test_reset()
450         for (int i = 0; i < NUMBER_OF_MSGS; ++i) {  in run()
454 …CHECK_MESSAGE( ( async_body_exec_count == NUMBER_OF_MSGS), "AsyncBody processed wrong number of si…  in run()
455 …CHECK_MESSAGE( ( async_activity_processed_msg_count == NUMBER_OF_MSGS), "AsyncActivity processed w…  in run()
456 …CHECK_MESSAGE( ( end_body_exec_count == NUMBER_OF_MSGS), "EndBody processed wrong number of signal…  in run()
467     const int N = NUMBER_OF_MSGS;  in test_copy_ctor()
489 …CHECK_MESSAGE( ( int(async_body_exec_count) == NUMBER_OF_MSGS), "AsyncBody processed wrong number …  in test_copy_ctor()
500 …CHECK_MESSAGE( ( int(async_body_exec_count) == 2*NUMBER_OF_MSGS), "AsyncBody processed wrong numbe…  in test_copy_ctor()
535         const int overall_message_count = nthreads * NUMBER_OF_MSGS;  in run()
600     basic_test<Input, Output>::run(NUMBER_OF_MSGS);  in run_tests()
602     basic_test<place_wrapper<Input>, place_wrapper<Output> >::run(NUMBER_OF_MSGS);  in run_tests()
806     lightweight_testing::test<tbb::flow::async_node>(NUMBER_OF_MSGS);