Lines Matching refs:try_put

40         node1.try_put(input_msg(1));
79     node_copy.try_put(1);
84     node_copy.try_put(1);
89     node0.try_put(1);
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." );
132 … CHECK_MESSAGE(( limit2.try_put( 1 )), "Newly constructed limiter node does not accept message." );
134     CHECK_MESSAGE(limit2.decrementer().try_put( -decrement_value ),
136     CHECK_MESSAGE(( limit2.try_put( 2 )), "Limiter's gate should not be closed yet." );
137     CHECK_MESSAGE(limit2.decrementer().try_put( -decrement_value ),
139     CHECK_MESSAGE(( !limit2.try_put( 3 )), "Overflow happened for internal counter." );
151     CHECK_MESSAGE(limit3.decrementer().try_put( -decrement_value3 ),
155     while( limit3.try_put( m ) ){ m++; };
170     limit4.try_put(-1);
171     CHECK_MESSAGE(limit4.decrementer().try_put(oneapi::tbb::flow::continue_msg()),
175     while( limit4.try_put( m ) ){ m++; };