Lines Matching refs:testing_node

130     oneapi::tbb::flow::join_node<my_input_tuple, oneapi::tbb::flow::queueing> testing_node(g);
145     oneapi::tbb::flow::make_edge(f1, oneapi::tbb::flow::input_port<0>(testing_node));
146     oneapi::tbb::flow::make_edge(f2, oneapi::tbb::flow::input_port<1>(testing_node));
147     oneapi::tbb::flow::make_edge(c1, oneapi::tbb::flow::input_port<2>(testing_node));
148     make_edge(testing_node, f3);
180     oneapi::tbb::flow::remove_edge(testing_node, f3);
188     CHECK_MESSAGE((testing_node.try_get(tmp)), "If no one successor accepts the tuple the messages\
219         oneapi::tbb::flow::key_matching<int, MyHash<int>>> testing_node(g, body1, body2);
221     oneapi::tbb::flow::input_port<0>(testing_node).try_put(oneapi::tbb::flow::continue_msg());
222     oneapi::tbb::flow::input_port<1>(testing_node).try_put(1.3f);
227     CHECK_MESSAGE((testing_node.try_get(tmp)), "Mapped keys should match.\
229     CHECK_MESSAGE((!testing_node.try_get(tmp)), "Message should not exist after item is consumed");
240         oneapi::tbb::flow::tag_matching> testing_node(g, body1, body2);
242     oneapi::tbb::flow::input_port<0>(testing_node).try_put(oneapi::tbb::flow::continue_msg());
243     oneapi::tbb::flow::input_port<1>(testing_node).try_put(1.3f);
248     CHECK_MESSAGE((testing_node.try_get(tmp) == true), "Mapped keys should match");