Lines Matching refs:testing_node
419 Node testing_node(g, node_args..., counting_body); in test_body_exec()
423 CHECK_MESSAGE((produce_messages<Node, InputType>(testing_node) == true), in test_body_exec()
439 Node testing_node(g, node_args..., base_body); in test_copy_body_function()
441 Body b2 = copy_body<Body, Node>(testing_node); in test_copy_body_function()
450 Node testing_node(g, node_args...); in test_buffering()
453 oneapi::tbb::flow::make_edge(testing_node, rejecter); in test_buffering()
456 produce_messages<Node, InputType>(testing_node); in test_buffering()
461 CHECK_MESSAGE((testing_node.try_get(tmp) == true), "try_get after rejection should succeed"); 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()
478 Node testing_node(g, node_args...); in test_forwarding()
483 oneapi::tbb::flow::make_edge(testing_node, *receiver_nodes.back()); in test_forwarding()
486 produce_messages<Node, InputType>(testing_node, expected); in test_forwarding()
504 Node testing_node(g, node_args...); in test_forwarding_single_push()
508 oneapi::tbb::flow::make_edge(testing_node, suc_node1); in test_forwarding_single_push()
509 oneapi::tbb::flow::make_edge(testing_node, suc_node2); in test_forwarding_single_push()
511 testing_node.try_put(0); in test_forwarding_single_push()
519 testing_node.try_put(1); in test_forwarding_single_push()
589 Node testing_node(g, node_args...); in test_copy_ctor_for_buffering_nodes()
594 oneapi::tbb::flow::make_edge(pred_node, testing_node); in test_copy_ctor_for_buffering_nodes()
595 oneapi::tbb::flow::make_edge(testing_node, suc_node1); in test_copy_ctor_for_buffering_nodes()
598 testing_node.try_put(1); in test_copy_ctor_for_buffering_nodes()
601 Node node_copy(testing_node); in test_copy_ctor_for_buffering_nodes()
618 testing_node.clear(); in test_copy_ctor_for_buffering_nodes()
769 Node testing_node(g); // for buffering once computed value in test_with_reserving_join_node_class()
788 make_edge(static_result_computer_n, testing_node); in test_with_reserving_join_node_class()
789 make_edge(testing_node, input_port<0>(join_n)); in test_with_reserving_join_node_class()