Searched refs:qn (Results 1 – 3 of 3) sorted by relevance
| /oneTBB/test/common/ |
| H A D | test_join_node_multiple_predecessors.h | 48 buffer_node<continue_msg>& bn3, queue_node_t& qn) in connect_join_via_make_edge() argument
52 make_edge(*jn, qn); in connect_join_via_make_edge()
59 buffer_node<continue_msg>& bn3, queue_node_t& qn) in connect_join_via_follows() argument
63 make_edge(*jn, qn); in connect_join_via_follows()
69 buffer_node<continue_msg>& bn3, queue_node_t& qn) in connect_join_via_precedes() argument
71 auto qn_set = make_node_set(qn); in connect_join_via_precedes()
91 (qn.try_get(msg) == expected), in run_and_check()
102 queue_node_t qn(g); in test()
104 auto jn = connect_join_node(g, bn1, bn2, bn3, qn); in test()
106 run_and_check(g, bn1, bn2, bn3, qn, /*expected=*/true); in test()
[all …]
|
| /oneTBB/test/conformance/ |
| H A D | conformance_composite_node.cpp | 29 oneapi::tbb::flow::queue_node<int> qn; member in adder
40 …i::tbb::flow::graph &g) : base_type(g), j(g), f(g, oneapi::tbb::flow::unlimited, f_body()), qn(g) { in adder()
42 make_edge(f, qn); in adder()
45 base_type::output_ports_type output_tuple(qn); in adder()
|
| /oneTBB/test/tbb/ |
| H A D | test_limiter_node.cpp | 316 tbb::flow::queue_node<int> qn(g); in test_continue_msg_reception() local
317 tbb::flow::make_edge(ln, qn); in test_continue_msg_reception()
322 CHECK_MESSAGE( (qn.try_get(outint) && outint == 42), "initial put to decrement stops node"); in test_continue_msg_reception()
|