Searched refs:test_push_receiver (Results 1 – 10 of 10) sorted by relevance
67 conformance::test_push_receiver<int> node2(g);68 conformance::test_push_receiver<float> node3(g);69 conformance::test_push_receiver<input_msg> node4(g);100 conformance::test_push_receiver<int> node2(g);101 conformance::test_push_receiver<int> node3(g);
34 using test_push_receiver = oneapi::tbb::flow::queue_node<V>; variable505 test_push_receiver<int> suc_node1(g); in test_forwarding_single_push()506 test_push_receiver<int> suc_node2(g); in test_forwarding_single_push()558 test_push_receiver<int> suc_node1(g); in test_copy_ctor()559 test_push_receiver<int> suc_node2(g); in test_copy_ctor()591 test_push_receiver<int> suc_node1(g); in test_copy_ctor_for_buffering_nodes()592 test_push_receiver<int> suc_node2(g); in test_copy_ctor_for_buffering_nodes()682 test_push_receiver<int> suc_node(g); in test_concurrency()700 test_push_receiver<int> suc_node(g); in test_rejecting()722 test_push_receiver<CountingBody> suc_node(g); in test_output_input_class()[all …]
36 std::vector<conformance::test_push_receiver<my_output_type>*> receiver_nodes;39 receiver_nodes.emplace_back(new conformance::test_push_receiver<my_output_type>(g));138 conformance::test_push_receiver<my_output_type> node2(g);139 conformance::test_push_receiver<my_output_type> node3(g);
97 conformance::test_push_receiver<output_msg> node2(g);98 conformance::test_push_receiver<output_msg> node3(g);151 conformance::test_push_receiver<output_msg> node2(g);182 conformance::test_push_receiver<int> sink(g);
58 conformance::test_push_receiver<int> node2(g);59 conformance::test_push_receiver<int> node3(g);
35 conformance::test_push_receiver<input_msg> node2(g);69 conformance::test_push_receiver<int> node2(g);70 conformance::test_push_receiver<int> node3(g);
30 std::vector<my_input_tuple> get_values( conformance::test_push_receiver<my_input_tuple>& rr ) { in get_values()78 conformance::test_push_receiver<std::tuple<int>> node2(g);79 conformance::test_push_receiver<std::tuple<int>> node3(g);132 conformance::test_push_receiver<my_input_tuple> q_node(g);
187 conformance::test_push_receiver<output_msg> node2(g);188 conformance::test_push_receiver<output_msg> node3(g);
128 conformance::test_push_receiver<int> suc_node(g); in test_limiter_node_rf_reset_protocol()
39 class test_push_receiver : public tbb::flow::receiver<T>, utils::NoAssign { class46 test_push_receiver(tbb::flow::graph& g) : my_graph(g) { in test_push_receiver() function in test_push_receiver117 test_push_receiver<T> dest(g); in test_single_dest()156 test_push_receiver<T> dest_c(g); in test_single_dest()