52        CHECK_MESSAGE( next_value++  == v, "" );  in try_put_task()
141     CHECK_MESSAGE( c == N*num_threads, "" );  in test_puts_with_decrements()
142     CHECK_MESSAGE( r.my_count == N*num_threads, "" );  in test_puts_with_decrements()
167        CHECK_MESSAGE( c == i, "" );  in test_parallel()
199            CHECK_MESSAGE( (( j < i && msg == true ) || ( j >= i && msg == false )), "" );  in test_serial()
214            CHECK_MESSAGE( (( j < i && msg == true ) || ( j >= i && msg == false )), "" );  in test_serial()
218                CHECK_MESSAGE( msg == true, "" );  in test_serial()
247             CHECK_MESSAGE( (false),"Unexpected rejection of decrement");  in operator ()()
295     CHECK_MESSAGE( (emit_count == receive_count), "counts do not match");  in test_multifunction_to_limiter()
296     CHECK_MESSAGE( (emit_sum == receive_sum), "sums do not match");  in test_multifunction_to_limiter()
307     CHECK_MESSAGE( (emit_count == receive_count), "counts do not match");  in test_multifunction_to_limiter()
308     CHECK_MESSAGE( (emit_sum == receive_sum), "sums do not match");  in test_multifunction_to_limiter()
322     CHECK_MESSAGE( (qn.try_get(outint) && outint == 42), "initial put to decrement stops node");  in test_continue_msg_reception()
370         CHECK_MESSAGE( (var==list[i]), "some data dropped, input does not match output");  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()
395         CHECK_MESSAGE( actual == expected[m++], "" );  in test_decrementer()
396 …CHECK_MESSAGE( ( sizeof(expected) / sizeof(expected[0]) == m), "Not all messages have been process…  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()
413         CHECK_MESSAGE( actual == expected2[m++], "" );  in test_decrementer()
414 …CHECK_MESSAGE( ( sizeof(expected2) / sizeof(expected2[0]) == m), "Not all messages have been proce…  in test_decrementer()
421     CHECK_MESSAGE( limit3.decrementer().try_put( -decrement_value3 ),  in test_decrementer()
426     CHECK_MESSAGE( m == threshold3 - decrement_value3, "Not all messages have been accepted." );  in test_decrementer()
430         CHECK_MESSAGE( actual == m++, "Not all messages have been processed." );  in test_decrementer()
434     CHECK_MESSAGE( m == threshold3 - decrement_value3, "Not all messages have been processed." );  in test_decrementer()
534     CHECK_MESSAGE(processed.load() == threshold, "decrementer terminate flow graph work");  in test_decrement_while_try_put_task()