Lines Matching refs:limit

33     constexpr int limit = 5;  variable
34     oneapi::tbb::flow::limiter_node<input_msg> node1(g, limit);
39     for(int i = 0; i < limit * 2; ++i)
43 …CHECK_MESSAGE((conformance::get_values(node2).size() == limit), "Descendant of the node needs be r…
108     oneapi::tbb::flow::limiter_node<int, int> limit(g, threshold);
110     make_edge(limit, queue);
112 …CHECK_MESSAGE(( limit.try_put( m++ )), "Newly constructed limiter node does not accept message." );
113     CHECK_MESSAGE(limit.decrementer().try_put( -threshold ), // close limiter's gate
115     CHECK_MESSAGE(( !limit.try_put( m++ )), "Closed limiter node's accepts message." );
116     CHECK_MESSAGE(limit.decrementer().try_put( threshold + 5 ),  // open limiter's gate
119         CHECK_MESSAGE(( limit.try_put( m++ )), "Limiter node does not accept message while open." );
120     CHECK_MESSAGE(( !limit.try_put( m )), "Limiter node's gate is not closed." );