Lines Matching refs:testing_node
89 Node testing_node(g, node_body...); in test_buffering_nodes_rf_reset_protocol() local
92 CHECK_MESSAGE((testing_node.try_get(tmp) == false), "try_get should not succeed"); in test_buffering_nodes_rf_reset_protocol()
95 testing_node.try_put(1); in test_buffering_nodes_rf_reset_protocol()
100 CHECK_MESSAGE((testing_node.try_get(tmp) == false), "try_get should not succeed"); in test_buffering_nodes_rf_reset_protocol()
109 Node testing_node(g, node_args..., counting_body); in test_nodes_with_body_rf_reset_bodies() local
111 testing_node.try_put(InputType()); in test_nodes_with_body_rf_reset_bodies()
117 testing_node.try_put(InputType()); in test_nodes_with_body_rf_reset_bodies()
127 oneapi::tbb::flow::limiter_node<int> testing_node(g, limit); in test_limiter_node_rf_reset_protocol() local
130 oneapi::tbb::flow::make_edge(testing_node, suc_node); in test_limiter_node_rf_reset_protocol()
133 testing_node.try_put(1); in test_limiter_node_rf_reset_protocol()
141 testing_node.try_put(1); in test_limiter_node_rf_reset_protocol()
150 oneapi::tbb::flow::join_node<std::tuple<int>, oneapi::tbb::flow::queueing> testing_node(g); in test_join_node_rf_reset_protocol() local
152 oneapi::tbb::flow::input_port<0>(testing_node).try_put(1); in test_join_node_rf_reset_protocol()
158 CHECK_MESSAGE((!testing_node.try_get(tmp)), "All buffers must be emptied"); in test_join_node_rf_reset_protocol()
260 input_node<int> testing_node(g,counting_body);
263 make_edge(testing_node, q_node);
265 testing_node.activate();
271 testing_node.activate();