Lines Matching refs:receivers
88 std::vector< std::shared_ptr<counting_array_receiver<T>> > receivers; in test_serial_broadcasts() local
90 receivers.push_back( std::make_shared<counting_array_receiver<T>>(g) ); in test_serial_broadcasts()
93 tbb::flow::make_edge( b, *receivers[r] ); in test_serial_broadcasts()
102 CHECK_MESSAGE( (*receivers[r])[n] == 1, "" ); in test_serial_broadcasts()
104 tbb::flow::remove_edge( b, *receivers[r] ); in test_serial_broadcasts()
108 CHECK_MESSAGE( (*receivers[0])[0] == 1, "" ); in test_serial_broadcasts()
133 std::vector< std::shared_ptr<counting_array_receiver<T>> > receivers; in run_parallel_broadcasts() local
135 receivers.push_back( std::make_shared< counting_array_receiver<T> >(g) ); in run_parallel_broadcasts()
138 tbb::flow::make_edge( b, *receivers[r] ); in run_parallel_broadcasts()
145 CHECK_MESSAGE( (int)(*receivers[r])[n] == p, "" ); in run_parallel_broadcasts()
147 tbb::flow::remove_edge( b, *receivers[r] ); in run_parallel_broadcasts()
151 CHECK_MESSAGE( (int)(*receivers[r])[0] == p, "" ); in run_parallel_broadcasts()