Lines Matching refs:try_put
33 source.try_put(continue_msg()); in test_continue_node_rf_reset_protocol()
40 source.try_put(continue_msg()); in test_continue_node_rf_reset_protocol()
44 source.try_put(continue_msg()); in test_continue_node_rf_reset_protocol()
77 f.try_put(0); in test_functional_nodes_rf_reset_protocol()
78 f.try_put(0); in test_functional_nodes_rf_reset_protocol()
95 testing_node.try_put(1); in test_buffering_nodes_rf_reset_protocol()
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()
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()
152 oneapi::tbb::flow::input_port<0>(testing_node).try_put(1); in test_join_node_rf_reset_protocol()
227 ct.try_put(oneapi::tbb::flow::continue_msg());
228 s.try_put(std::tuple<int>{1});
230 fxn.try_put(1);
231 m_fxn.try_put(1);
232 bc.try_put(1);
233 lim.try_put(1);
234 oneapi::tbb::flow::input_port<0>(ind).try_put(1);
235 oneapi::tbb::flow::input_port<0>(j).try_put(1);
236 bf.try_put(1);
237 pq.try_put(1);
238 wo.try_put(1);
239 ovw.try_put(1);
240 seq.try_put(0);
302 f.try_put(0);