99             bool msg = my_lim.try_put( T(i) );  in operator ()()
118             bool msg = my_lim.try_put( T(local_accept_count) );  in operator ()()
122                 my_lim.decrementer().try_put( tbb::flow::continue_msg() );  in operator ()()
198            bool msg = lim.try_put( T(j) );  in test_serial()
213            bool msg = lim.try_put( T(j) );  in test_serial()
216                lim.decrementer().try_put( tbb::flow::continue_msg() );  in test_serial()
217                msg = lim.try_put( T(j) );  in test_serial()
246         if(!std::get<DECREMENT_OUTPUT>(out).try_put(tbb::flow::continue_msg())) {  in operator ()()
251             while( std::get<LIMITER_OUTPUT>(out).try_put(lcnt) ) {  in operator ()()
293     mf_node.try_put(1);  in test_multifunction_to_limiter()
305     mf_node.try_put(1);  in test_multifunction_to_limiter()
318     ln.decrementer().try_put(tbb::flow::continue_msg());  in test_continue_msg_reception()
319     ln.try_put(42);  in test_continue_msg_reception()
348     input_queue.try_put(list[0]); // succeeds  in test_reserve_release_messages()
349     input_queue.try_put(list[1]); // succeeds  in test_reserve_release_messages()
350     input_queue.try_put(list[2]); // fails, stored in upstream buffer  in test_reserve_release_messages()
356     broad.try_put(1); //failed message retrieved.  in test_reserve_release_messages()
361     broad.try_put(1);  //drop the count  in test_reserve_release_messages()
363     input_queue.try_put(list[3]);  //success  in test_reserve_release_messages()
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()
402 …CHECK_MESSAGE( ( limit2.try_put( 1 )), "Newly constructed limiter node does not accept message." );  in test_decrementer()
404     CHECK_MESSAGE( limit2.decrementer().try_put( -decrement_value ),  in test_decrementer()
406     CHECK_MESSAGE( ( limit2.try_put( 2 )), "Limiter's gate should not be closed yet." );  in test_decrementer()
407     CHECK_MESSAGE( limit2.decrementer().try_put( -decrement_value ),  in test_decrementer()
409     CHECK_MESSAGE( ( !limit2.try_put( 3 )), "Overflow happened for internal counter." );  in test_decrementer()
421     CHECK_MESSAGE( limit3.decrementer().try_put( -decrement_value3 ),  in test_decrementer()
425     while( limit3.try_put( m ) ){ m++; };  in test_decrementer()
447         bn.try_put(i);  in test_try_put_without_successors()
464     ln.decrementer().try_put(tbb::flow::continue_msg());  in test_try_put_without_successors()
465     bn.try_put(try_put_num + 1);  in test_try_put_without_successors()
523                 std::get<0>(out).try_put(1);  in test_decrement_while_try_put_task()
620     CHECK( input_node.try_put( TestLargeStruct{} ) );