Lines Matching refs:try_put

108     return node.try_put(InputType());
110 return node.try_put(InputType(arg));
163 g.try_put(operator()(OutputType(0))); in operator()
168 std::get<0>(op).try_put(operator()(OutputType(0))); in operator()
198 std::get<0>(op).try_put(return_value); in operator()
213 g.try_put(return_value); in operator()
233 std::get<0>(op).try_put(OutputType(0)); in operator()
238 g.try_put(OutputType(0)); in operator()
276 std::get<0>(op).try_put(argument); in operator()
282 g.try_put(argument); in operator()
323 std::get<0>(op).try_put(argument); in operator()
331 g.try_put(argument); in operator()
364 std::get<0>(op).try_put(OutputType(1)); in operator()
368 g.try_put(OutputType(1)); in operator()
405 std::get<0>(op).try_put(argument); in operator()
409 g.try_put(argument); in operator()
511 testing_node.try_put(0); in test_forwarding_single_push()
519 testing_node.try_put(1); in test_forwarding_single_push()
572 node_copy.try_put(1); in test_copy_ctor()
577 node0.try_put(1); in test_copy_ctor()
598 testing_node.try_put(1); in test_copy_ctor_for_buffering_nodes()
611 node_copy.try_put(0); in test_copy_ctor_for_buffering_nodes()
621 pred_node.try_put(oneapi::tbb::flow::continue_msg()); in test_copy_ctor_for_buffering_nodes()
648 source.try_put(oneapi::tbb::flow::continue_msg()); in test_priority()
687 fnode.try_put(i); in test_concurrency()
704 fnode.try_put(0); in test_rejecting()
706 …CHECK_MESSAGE((!fnode.try_put(1)), "Messages should be rejected while the first is being processed… in test_rejecting()
726 node1.try_put(b1); in test_output_input_class()
747 node1.try_put(oneapi::tbb::flow::continue_msg()); in test_output_class()
794 static_result_computer_n.try_put(number); in test_with_reserving_join_node_class()
798 buffer_n.try_put(i); in test_with_reserving_join_node_class()
803 static_result_computer_n.try_put(number); in test_with_reserving_join_node_class()
805 buffer_n.try_put(i); in test_with_reserving_join_node_class()