Home
last modified time | relevance | path

Searched refs:g (Results 1 – 25 of 147) sorted by relevance

123456

/oneTBB/test/conformance/
H A Dconformance_graph.cpp28 graph g; in test_continue_node_rf_reset_protocol() local
34 g.wait_for_all(); in test_continue_node_rf_reset_protocol()
41 g.wait_for_all(); in test_continue_node_rf_reset_protocol()
45 g.wait_for_all(); in test_continue_node_rf_reset_protocol()
60 g.wait_for_all(); in test_input_node_rf_reset_protocol()
82 g.wait_for_all(); in test_functional_nodes_rf_reset_protocol()
96 g.wait_for_all(); in test_buffering_nodes_rf_reset_protocol()
102 g.wait_for_all(); in test_buffering_nodes_rf_reset_protocol()
258 graph g; variable
283 g.cancel();
[all …]
H A Dconformance_flowgraph.h426 g.wait_for_all(); in test_body_exec()
437 graph g; in test_copy_body_function() local
457 g.wait_for_all(); in test_buffering()
492 g.wait_for_all(); in test_forwarding()
512 g.wait_for_all(); in test_forwarding_single_push()
520 g.wait_for_all(); in test_forwarding_single_push()
551 graph g; in test_copy_ctor() local
720 graph g; in test_output_input_class() local
739 graph g; in test_output_class() local
760 graph g; in test_with_reserving_join_node_class() local
[all …]
H A Dconformance_join_node.cpp43 graph g; in test_deduction_guides() local
45 broadcast_node<int> b1(g), b2(g), b3(g); in test_deduction_guides()
88 g.wait_for_all();
94 g.wait_for_all();
100 g.wait_for_all();
104 g.wait_for_all();
152 g.wait_for_all();
157 g.wait_for_all();
163 g.wait_for_all();
168 g.wait_for_all();
[all …]
H A Dconformance_split_node.cpp33 oneapi::tbb::flow::graph g; variable
35 my_split_type testing_node(g);
47 g.wait_for_all();
64 oneapi::tbb::flow::graph g; variable
66 my_split_type testing_node(g);
78 g.wait_for_all();
95 oneapi::tbb::flow::graph g; variable
111 g.wait_for_all();
116 g.wait_for_all();
131 oneapi::tbb::flow::graph g; variable
[all …]
H A Dconformance_sequencer_node.cpp34 graph g; in test_deduction_guides_common() local
35 broadcast_node<int> br(g); in test_deduction_guides_common()
37 sequencer_node s1(g, body); in test_deduction_guides_common()
98 oneapi::tbb::flow::graph g; variable
106 g.wait_for_all();
120 g.wait_for_all();
140 graph g; variable
163 g.wait_for_all();
172 graph g; variable
195 g.wait_for_all();
[all …]
H A Dconformance_limiter_node.cpp31 oneapi::tbb::flow::graph g; variable
41 g.wait_for_all();
65 graph g; variable
80 g.wait_for_all();
85 g.wait_for_all();
90 g.wait_for_all();
121 g.wait_for_all();
127 g.wait_for_all();
145 g.wait_for_all();
163 g.wait_for_all();
[all …]
H A Dconformance_input_node.cpp35 graph g; in test_deduction_guides() local
41 input_node s1(g, lambda); in test_deduction_guides()
54 broadcast_node<int> bc(g); in test_deduction_guides()
66 g.wait_for_all(); in test_deduction_guides()
92 graph g; variable
111 g.wait_for_all();
116 g.wait_for_all();
146 oneapi::tbb::flow::graph g; variable
156 g.wait_for_all();
187 g.wait_for_all();
[all …]
H A Dconformance_continue_node.cpp35 graph g; in test_deduction_guides_common() local
37 continue_node c1(g, body); in test_deduction_guides_common()
43 continue_node c3(g, 5, body); in test_deduction_guides_common()
158 graph g; variable
179 graph g; variable
202 g.wait_for_all();
207 g.wait_for_all();
214 g.wait_for_all();
222 oneapi::tbb::flow::graph g; variable
241 g.wait_for_all();
[all …]
H A Dconformance_composite_node.cpp40 …adder(oneapi::tbb::flow::graph &g) : base_type(g), j(g), f(g, oneapi::tbb::flow::unlimited, f_body… in adder() argument
74 oneapi::tbb::flow::graph g; variable
116 input_output_type a_node(g);
131 input_only_type b_node(g);
142 output_only_type c_node(g);
146 g.reset();
161 graph g; variable
163 adder a0(g);
164 adder a1(g);
165 adder a2(g);
[all …]
H A Dconformance_indexer_node.cpp33 oneapi::tbb::flow::graph g; variable
35 my_indexer_type testing_node(g);
46 g.wait_for_all();
73 oneapi::tbb::flow::graph g; variable
86 g.wait_for_all();
92 oneapi::tbb::flow::graph g; variable
126 g.wait_for_all();
133 oneapi::tbb::flow::graph g; variable
137 my_indexer_type node1(g);
149 g.wait_for_all();
[all …]
/oneTBB/test/tbb/
H A Dtest_profiling.cpp69 tbb::flow::graph g; variable
82 tbb::flow::graph g; variable
90 tbb::flow::graph g; variable
98 tbb::flow::graph g; variable
106 tbb::flow::graph g; variable
114 tbb::flow::graph g; variable
126 tbb::flow::graph g; variable
134 tbb::flow::graph g; variable
160 tbb::flow::graph g; variable
168 tbb::flow::graph g; variable
[all …]
H A Dtest_flow_graph_whitebox.cpp71 g.reset(); in TestSplitNode()
83 B bnode(g); in TestBufferingNode()
365 g.reset(); in TestSimpleSuccessorArc()
505 g.reset(); in TestLimiterNode()
632 g.reset(); in TestIndexerNode()
643 Node on(g); in TestScalarNode()
649 g.reset(); in TestScalarNode()
734 g.reset(); in TestInputNode()
748 g.reset(); in TestInputNode()
929 graph g; variable
[all …]
H A Dtest_limiter_node.cpp49 serial_receiver(tbb::flow::graph& g) : next_value(T(0)), my_graph(g) {} in serial_receiver()
67 parallel_receiver(tbb::flow::graph& g) : my_graph(g) { my_count = 0; } in parallel_receiver()
294 g.wait_for_all(); in test_multifunction_to_limiter()
299 g.reset(); in test_multifunction_to_limiter()
306 g.wait_for_all(); in test_multifunction_to_limiter()
320 g.wait_for_all(); in test_continue_msg_reception()
333 graph g; in test_reserve_release_messages() local
351 g.wait_for_all(); in test_reserve_release_messages()
357 g.wait_for_all(); in test_reserve_release_messages()
364 g.wait_for_all(); in test_reserve_release_messages()
[all …]
H A Dtest_input_node.cpp46 test_push_receiver(tbb::flow::graph& g) : my_graph(g) { in test_push_receiver() argument
120 g.wait_for_all(); in test_single_dest()
133 g.wait_for_all(); in test_single_dest()
147 g.wait_for_all(); in test_single_dest()
158 g.wait_for_all(); in test_single_dest()
175 g.wait_for_all(); in test_reset()
187 g.wait_for_all(); in test_reset()
197 g.wait_for_all(); in test_reset()
208 g.wait_for_all(); in test_reset()
216 g.wait_for_all(); in test_reset()
[all …]
H A Dtest_flow_graph.cpp88 tbb::flow::graph g; in test_iterator() local
97 for (tbb::flow::graph::iterator it = g.begin(); it != g.end(); ++it) { in test_iterator()
105 for (tbb::flow::graph::iterator it = g.begin(); it != g.end(); ++it) { in test_iterator()
113 for (tbb::flow::graph::iterator it = g.begin(); it != g.end(); ++it) { in test_iterator()
120 tbb::flow::graph& g; member in AddRemoveBody
134 for (tbb::flow::graph::iterator it = g.begin(); it != g.end(); ++it) { in operator ()()
143 for (tbb::flow::graph::iterator it = g.begin(); it != g.end(); ++it) { in operator ()()
152 tbb::flow::graph g; in test_parallel() local
348 graph g; variable
357 for(auto it = g.cbegin(); it != g.cend(); it++)
[all …]
H A Dtest_priority_queue_node.cpp181 g.wait_for_all(); in test_parallel()
186 g.wait_for_all(); in test_parallel()
188 g.wait_for_all(); in test_parallel()
194 g.wait_for_all(); in test_parallel()
202 g.wait_for_all(); in test_parallel()
204 g.wait_for_all(); in test_parallel()
217 g.wait_for_all(); in test_parallel()
226 g.wait_for_all(); in test_parallel()
274 g.wait_for_all(); in test_serial()
282 g.wait_for_all(); in test_serial()
[all …]
H A Dtest_sequencer_node.cpp46 g.wait_for_all(); in wait_try_get()
210 g.wait_for_all(); in test_parallel()
226 g.wait_for_all(); in test_parallel()
228 g.wait_for_all(); in test_parallel()
230 g.wait_for_all(); in test_parallel()
243 g.wait_for_all(); in test_parallel()
297 g.wait_for_all(); in test_serial()
316 g.wait_for_all(); in test_serial()
346 g.wait_for_all(); in test_serial()
382 g.wait_for_all(); in test_serial()
[all …]
H A Dtest_eh_flow_graph.cpp357 tbb::flow::graph g; in run_one_input_node_test() local
486 tbb::flow::graph g; in run_one_functype_node_test() local
809 tbb::flow::broadcast_node<tbb::flow::continue_msg> b1(g), b2(g), b3(g); in run_one_continue_node_test()
964 g.reset(); in run_one_buffer_node_test()
972 g.reset(); in run_one_buffer_node_test()
1099 g.reset(); in run_one_sequencer_node_test()
1105 g.reset(); in run_one_sequencer_node_test()
1223 g.reset(); in run_one_priority_queue_node_test()
1229 g.reset(); in run_one_priority_queue_node_test()
1608 g.reset(); in run_one_limiter_node_test()
[all …]
H A Dtest_composite_node.cpp98 …tiny_node(tbb::flow::graph &g, bool hidden = false) : base_type(g), f1(g, tbb::flow::unlimited, pa… in tiny_node()
114 tbb::flow::graph g; in test_tiny() local
139 g.wait_for_all(); in test_tiny()
146 g.wait_for_all(); in test_tiny()
156 g.wait_for_all(); in test_tiny()
180 …adder_node(tbb::flow::graph &g, bool hidden = false) : base_type(g), j(g), f(g, tbb::flow::unlimit… in adder_node() argument
253 g.wait_for_all(); in test_adder()
276 g.wait_for_all(); in test_adder()
337 g.wait_for_all(); in test_nested_adder()
363 …prefix_node(tbb::flow::graph &g, bool hidden = false ) : base_type(g), j(g), s(g), f(g, tbb::flow:… in prefix_node() argument
[all …]
H A Dtest_buffer_node.cpp164 g.wait_for_all(); in test_reservation()
169 g.wait_for_all(); in test_reservation()
174 g.wait_for_all(); in test_reservation()
179 g.wait_for_all(); in test_reservation()
185 g.wait_for_all(); in test_reservation()
222 g.wait_for_all(); in test_parallel()
238 g.wait_for_all(); in test_parallel()
260 g.wait_for_all(); in test_parallel()
262 g.wait_for_all(); in test_parallel()
264 g.wait_for_all(); in test_parallel()
[all …]
/oneTBB/examples/parallel_for/tachyon/src/
H A Dgrid.cpp77 grid *g; in newgrid() local
92 VSub(&g->max, &g->min, &g->voxsize); in newgrid()
93 g->voxsize.x /= (flt)g->xsize; in newgrid()
94 g->voxsize.y /= (flt)g->ysize; in newgrid()
95 g->voxsize.z /= (flt)g->zsize; in newgrid()
119 numvoxels = g->xsize * g->ysize * g->zsize; in grid_free()
181 cur = g->cells[index->z * g->xsize * g->ysize + index->y * g->xsize + index->x]; in cellbound()
430 zindex = z * g->xsize * g->ysize; in engrid_object()
462 if (pos->x < g->min.x || pos->x > g->max.x || pos->y < g->min.y || pos->y > g->max.y || in pos2grid()
463 pos->z < g->min.z || pos->z > g->max.z) in pos2grid()
[all …]
H A Dgrid.hpp87 #define voxel2x(g, X) ((X) * (g->voxsize.x) + (g->min.x)) argument
88 #define voxel2y(g, Y) ((Y) * (g->voxsize.y) + (g->min.y)) argument
89 #define voxel2z(g, Z) ((Z) * (g->voxsize.z) + (g->min.z)) argument
94 #define x2voxel(g, x) (((x)-g->min.x) / g->voxsize.x) argument
95 #define y2voxel(g, y) (((y)-g->min.y) / g->voxsize.y) argument
96 #define z2voxel(g, z) (((z)-g->min.z) / g->voxsize.z) argument
103 void engrid_objlist(grid *g, object **list);
104 static int engrid_object(grid *g, object *obj);
106 static int engrid_objectlist(grid *g, objectlist **list);
109 static int pos2grid(grid *g, vector *pos, gridindex *index);
[all …]
/oneTBB/examples/graph/logic_sim/
H A Dtest_all.cpp69 buffer b(g); in main()
70 toggle input(g); in main()
80 g.wait_for_all(); in main()
85 g.wait_for_all(); in main()
92 not_gate n(g); in main()
93 toggle input(g); in main()
150 or_gate<3> o(g); in main()
322 buffer b(g); in main()
339 toggle A(g); in main()
340 toggle B(g); in main()
[all …]
/oneTBB/include/oneapi/tbb/detail/
H A D_flow_graph_impl.h116 void activate_graph(graph& g);
131 : my_graph(g) in my_graph() argument
373 graph& g = my_graph; in finalize() local
375 g.release_wait(); in finalize()
416 g.my_is_active = true; in activate_graph()
420 g.my_is_active = false; in deactivate_graph()
424 return g.my_is_active; in is_graph_active()
439 submit( *critical_task, *g.my_task_arena, *g.my_context, /*as_critical=*/true ); in prioritize_task()
450 __TBB_ASSERT(g.my_task_arena && g.my_task_arena->is_active(), nullptr); in spawn_in_graph_arena()
451 submit( *gt, *g.my_task_arena, *g.my_context in spawn_in_graph_arena()
[all …]
/oneTBB/test/common/
H A Dtest_follows_and_precedes_api.h68 g.wait_for_all();
85 g.wait_for_all();
100 g.wait_for_all();
117 g.wait_for_all();
163 g.wait_for_all();
185 g.wait_for_all();
215 g.wait_for_all();
233 graph g;
238 PredecessorType(g)
255 graph g;
[all …]

123456