Lines Matching refs:limit
339 limiter_node<int, int> limit(g,2); //threshold of 2 in test_reserve_release_messages() local
342 make_edge(input_queue, limit); in test_reserve_release_messages()
343 make_edge(limit, output_queue); in test_reserve_release_messages()
344 make_edge(broad,limit.decrementer()); in test_reserve_release_messages()
353 remove_edge(limit, output_queue); //remove successor in test_reserve_release_messages()
359 tbb::flow::make_edge(limit, output_queue); //putting the successor back in test_reserve_release_messages()
378 tbb::flow::limiter_node<int, int> limit(g, threshold); in test_decrementer() local
380 make_edge(limit, queue); in test_decrementer()
382 …CHECK_MESSAGE( ( limit.try_put( m++ )), "Newly constructed limiter node does not accept message." … in test_decrementer()
383 CHECK_MESSAGE( limit.decrementer().try_put( -threshold ), // close limiter's gate in test_decrementer()
385 CHECK_MESSAGE( ( !limit.try_put( m++ )), "Closed limiter node's accepts message." ); in test_decrementer()
386 CHECK_MESSAGE( limit.decrementer().try_put( threshold + 5 ), // open limiter's gate in test_decrementer()
389 … CHECK_MESSAGE( ( limit.try_put( m++ )), "Limiter node does not accept message while open." ); in test_decrementer()
390 CHECK_MESSAGE( ( !limit.try_put( m )), "Limiter node's gate is not closed." ); in test_decrementer()