Searched refs:suc_node (Results 1 – 2 of 2) sorted by relevance
682 test_push_receiver<int> suc_node(g); in test_concurrency()684 make_edge(fnode, suc_node); in test_concurrency()700 test_push_receiver<int> suc_node(g); in test_rejecting()702 make_edge(fnode, suc_node); in test_rejecting()711 …CHECK_MESSAGE((get_values(suc_node).size() == 1), "Messages should be rejected while the first is … in test_rejecting()722 test_push_receiver<CountingBody> suc_node(g); in test_output_input_class()723 make_edge(node1, suc_node); in test_output_input_class()728 suc_node.try_get(b2); in test_output_input_class()741 test_push_receiver<Output> suc_node(g); in test_output_class()742 make_edge(node1, suc_node); in test_output_class()[all …]
128 conformance::test_push_receiver<int> suc_node(g); in test_limiter_node_rf_reset_protocol() local130 oneapi::tbb::flow::make_edge(testing_node, suc_node); in test_limiter_node_rf_reset_protocol()136 …CHECK_MESSAGE((conformance::get_values(suc_node).size() == limit), "Descendant of the node needs b… in test_limiter_node_rf_reset_protocol()144 …CHECK_MESSAGE((conformance::get_values(suc_node).size() == limit), "Descendant of the node needs b… in test_limiter_node_rf_reset_protocol()