305         CHECK_MESSAGE((int)utils::ConcurrencyTracker::PeakParallelism() <= required_max_concurrency,  in operator()
313         CHECK_MESSAGE((int)utils::ConcurrencyTracker::PeakParallelism() <= required_max_concurrency,  in operator()
321         CHECK_MESSAGE((int)utils::ConcurrencyTracker::PeakParallelism() <= required_max_concurrency,  in operator()
329         CHECK_MESSAGE((int)utils::ConcurrencyTracker::PeakParallelism() <= required_max_concurrency,  in operator()
423         CHECK_MESSAGE((produce_messages<Node, InputType>(testing_node) == true),  in test_body_exec()
428 …CHECK_MESSAGE((counting_body.execute_count == n), "Body of the first node needs to be executed N t…  in test_body_exec()
443 …CHECK_MESSAGE((base_body.copy_count + 1 < b2.copy_count), "copy_body and constructor should copy b…  in test_copy_body_function()
461     CHECK_MESSAGE((testing_node.try_get(tmp) == true), "try_get after rejection should succeed");  in test_buffering()
462     CHECK_MESSAGE((tmp == 1), "try_get after rejection should set value");  in test_buffering()
465 …CHECK_MESSAGE((std::get<0>(testing_node.output_ports()).try_get(tmp) == false), "try_get after rej…  in test_buffering()
467 … CHECK_MESSAGE((testing_node.try_get(tmp) == false), "try_get after rejection should not succeed");  in test_buffering()
469     CHECK_MESSAGE((tmp == -1), "try_get after rejection should not alter passed value");  in test_buffering()
489     CHECK_MESSAGE(expected == messages_received, "For correct execution of test");  in test_forwarding()
495 …CHECK_MESSAGE((values.size() == messages_received), std::string("Descendant of the node must recei…  in test_forwarding()
496         CHECK_MESSAGE((values[0] == expected), "Value passed is the actual one received.");  in test_forwarding()
516 …CHECK_MESSAGE((values1.size() != values2.size()), "Only one descendant the node needs to receive");  in test_forwarding_single_push()
517     CHECK_MESSAGE((values1.size() + values2.size() == 1), "All messages need to be received");  in test_forwarding_single_push()
524 …CHECK_MESSAGE((values3.size() != values4.size()), "Only one descendant the node needs to receive");  in test_forwarding_single_push()
525     CHECK_MESSAGE((values3.size() + values4.size() == 1), "All messages need to be received");  in test_forwarding_single_push()
528     CHECK_MESSAGE((values1[0] == 0), "Value passed is the actual one received");  in test_forwarding_single_push()
529     CHECK_MESSAGE((values3[0] == 1), "Value passed is the actual one received");  in test_forwarding_single_push()
532         CHECK_MESSAGE((values1[0] == 0), "Value passed is the actual one received");  in test_forwarding_single_push()
534         CHECK_MESSAGE((values2[0] == 0), "Value passed is the actual one received");  in test_forwarding_single_push()
543 …CHECK_MESSAGE((std::is_base_of<graph_node, Node>::value), "Node should be derived from graph_node"…  in test_inheritance()
544 …CHECK_MESSAGE((std::is_base_of<receiver<InputType>, Node>::value), "Node should be derived from re…  in test_inheritance()
545 …CHECK_MESSAGE((std::is_base_of<sender<OutputType>, Node>::value), "Node should be derived from sen…  in test_inheritance()
568     CHECK_MESSAGE((fun2.copy_count + 1 < b2.copy_count), "constructor should copy bodies");  in test_copy_ctor()
575 …CHECK_MESSAGE((get_values(suc_node1).size() == 0 && get_values(suc_node2).size() == 1), "Copied no…  in test_copy_ctor()
580 …CHECK_MESSAGE((get_values(suc_node1).size() == 1 && get_values(suc_node2).size() == 0), "Copied no…  in test_copy_ctor()
605 …CHECK_MESSAGE((!node_copy.is_valid() && !node_copy.try_get(tmp)), "The buffered value is not copie…  in test_copy_ctor_for_buffering_nodes()
614 …CHECK_MESSAGE((get_values(suc_node1).size() == 0 && get_values(suc_node2).size() == 1), "Copied no…  in test_copy_ctor_for_buffering_nodes()
624 …CHECK_MESSAGE((get_values(suc_node1).size() == 1 && get_values(suc_node2).size() == 0), "Copied no…  in test_copy_ctor_for_buffering_nodes()
652 …CHECK_MESSAGE((track_first_id_functor<int>::first_id == 2), "High priority node should execute fir…  in test_priority()
706 …CHECK_MESSAGE((!fnode.try_put(1)), "Messages should be rejected while the first is being processed…  in test_rejecting()
711 …CHECK_MESSAGE((get_values(suc_node).size() == 1), "Messages should be rejected while the first is …  in test_rejecting()
782 …CHECK_MESSAGE((std::get<0>(arg) == int((number >> 2) / 4)), "A overwrite_node store a single item …  in test_with_reserving_join_node_class()
784 …CHECK_MESSAGE((std::get<0>(arg) == int((number >> 2) / 4)), "A write_once_node store a single item…  in test_with_reserving_join_node_class()
809     CHECK_MESSAGE((counter == put_count), "join_node with reserving policy \  in test_with_reserving_join_node_class()