Home
last modified time | relevance | path

Searched refs:tbb (Results 1 – 25 of 493) sorted by relevance

12345678910>>...20

/oneTBB/test/tbb/
H A Dtest_profiling.cpp69 tbb::flow::graph g;
82 tbb::flow::graph g;
90 tbb::flow::graph g;
98 tbb::flow::graph g;
106 tbb::flow::graph g;
114 tbb::flow::graph g;
115 tbb::flow::continue_node<tbb::flow::continue_msg> node(g,
126 tbb::flow::graph g;
134 tbb::flow::graph g;
160 tbb::flow::graph g;
[all …]
H A Dtest_composite_node.cpp227 tbb::flow::make_edge( s, tbb::flow::input_port<0>(a0) ); in test_adder()
228 tbb::flow::make_edge( c, tbb::flow::input_port<1>(a0) ); in test_adder()
230 tbb::flow::make_edge( c, tbb::flow::input_port<0>(a1) ); in test_adder()
231 tbb::flow::make_edge( c, tbb::flow::input_port<1>(a1) ); in test_adder()
233 tbb::flow::make_edge( tbb::flow::output_port<0>(a0), tbb::flow::input_port<0>(a2) ); in test_adder()
234 tbb::flow::make_edge( tbb::flow::output_port<0>(a1), tbb::flow::input_port<1>(a2) ); in test_adder()
236 tbb::flow::make_edge( tbb::flow::output_port<0>(a2), s2 ); in test_adder()
259 tbb::flow::make_edge( a1, tbb::flow::input_port<1>(a3) ); in test_adder()
346 tbb::flow::join_node< my_tuple_t, tbb::flow::queueing > j;
367 …type input_tuple(tbb::flow::input_port<0>(j), tbb::flow::input_port<1>(j), tbb::flow::input_port<2… in prefix_node()
[all …]
H A Dtest_tbb_header.cpp110 Body2 ( const Body2&, tbb::split ) {} in Body2()
119 Body3 ( const Body3&, tbb::split ) {} in Body3()
120 void operator() ( const tbb::blocked_range2d<int>&, tbb::pre_scan_tag ) const {} in operator ()()
121 void operator() ( const tbb::blocked_range2d<int>&, tbb::final_scan_tag ) const {} in operator ()()
159 TestExceptionClassExports( tbb::bad_last_alloc(), tbb::detail::exception_id::bad_last_alloc ); in TestExceptionClassesExports()
162 TestExceptionClassExports( tbb::missing_wait(), tbb::detail::exception_id::missing_wait ); in TestExceptionClassesExports()
166 TestExceptionClassExports( tbb::user_abort(), tbb::detail::exception_id::user_abort ); in TestExceptionClassesExports()
202 …TestFuncDefinitionPresence( flow::make_edge, (tbb::flow::sender<Msg>&, tbb::flow::receiver<Msg>&),… in DefinitionPresence()
203 …TestFuncDefinitionPresence( flow::remove_edge, (tbb::flow::sender<Msg>&, tbb::flow::receiver<Msg>&… in DefinitionPresence()
261 …efinitionPresence( parallel_reduce, (const tbb::blocked_range<int>&, Body2&, const tbb::auto_parti… in DefinitionPresence()
[all …]
H A Dtest_flow_graph_whitebox.cpp67 tbb::flow::make_edge(tbb::flow::output_port<0>(snode), rcvr); in TestSplitNode()
84 …tbb::flow::function_node<int,int,tbb::flow::rejecting> fnode(g, tbb::flow::serial, serial_fn_body<… in TestBufferingNode()
350 tbb::flow::tag_value t = tbb::flow::tag_value(v / my_mult); in operator ()()
407 tbb::flow::make_edge(q0,tbb::flow::input_port<0>(rj)); in TestJoinNode()
408 tbb::flow::make_edge(q1,tbb::flow::input_port<1>(rj)); in TestJoinNode()
579 tbb::flow::make_edge(tbb::flow::output_port<0>(mf), qeven_out); in TestMultifunctionNode()
580 tbb::flow::make_edge(tbb::flow::output_port<1>(mf), qodd_out); in TestMultifunctionNode()
729 tbb::flow::make_edge(in, tbb::flow::input_port<0>(jn)); in TestInputNode()
730 tbb::flow::make_edge(qin, tbb::flow::input_port<1>(jn)); in TestInputNode()
739 tbb::flow::make_edge(in, tbb::flow::input_port<0>(jn)); in TestInputNode()
[all …]
H A Dtest_hw_concurrency.cpp61 tbb::combinable<std::size_t> comb;
77 tbb::tbb_allocator<std::size_t> ta;
78 tbb::null_mutex nm;
79 tbb::null_rw_mutex nrwm;
80 tbb::queuing_mutex qm;
81 tbb::queuing_rw_mutex qrwm;
82 tbb::spin_mutex sm;
83 tbb::spin_rw_mutex srwm;
84 tbb::speculative_spin_mutex ssm;
85 tbb::speculative_spin_rw_mutex ssrwm;
[all …]
H A Dtest_mutex.cpp106 …tbb::parallel_for(tbb::blocked_range<std::size_t>(0, n, 2), AddOne_CheckTransaction<utils::Counter… in TestTransaction()
124 test_rwm_upgrade_downgrade<tbb::spin_rw_mutex>();
134 test_rwm_upgrade_downgrade<tbb::rw_mutex>();
144 test_with_native_threads::test<tbb::spin_mutex>();
154 test_with_native_threads::test<tbb::mutex>();
171 test_with_native_threads::test<tbb::rw_mutex>();
182 TestIsWriter<oneapi::tbb::rw_mutex>("rw_mutex");
194 …static_assert(mutexes<tbb::spin_mutex, oneapi::tbb::mutex, tbb::speculative_spin_mutex, tbb::null_…
195 …tbb::spin_rw_mutex, oneapi::tbb::rw_mutex, tbb::speculative_spin_rw_mutex, tbb::null_rw_mutex, tbb…
196 …static_assert(rw_mutexes<tbb::spin_rw_mutex, oneapi::tbb::rw_mutex, tbb::speculative_spin_rw_mutex,
[all …]
H A Dtest_flow_graph.cpp53 tbb::flow::graph h; in test_wait_count()
73 tbb::flow::buffer_node<int> *b;
74 tbb::flow::graph& my_graph;
88 tbb::flow::graph g; in test_iterator()
120 tbb::flow::graph& g;
152 tbb::flow::graph g; in test_parallel()
212 tbb::flow::graph& my_graph;
219 …tbb::flow::continue_node< tbb::flow::continue_msg > c_n(my_graph, function_body<tbb::flow::continu… in operator ()()
286 tbb::task_arena arena(1); in test_graph_arena()
289 tbb::flow::graph g; in test_graph_arena()
[all …]
H A Dtest_limiter_node.cpp157 tbb::flow::graph g; in test_parallel()
172 tbb::flow::graph g; in test_parallel()
193 tbb::flow::graph g; in test_serial()
206 tbb::flow::graph g; in test_serial()
278 tbb::flow::graph g; in test_multifunction_to_limiter()
314 tbb::flow::graph g; in test_continue_msg_reception()
377 tbb::flow::graph g; in test_decrementer()
438 tbb::flow::graph g; in test_try_put_without_successors()
450 tbb::flow::function_node<int, int> fn(g, tbb::flow::unlimited, in test_try_put_without_successors()
616 tbb::flow::function_node<TestLargeStruct> func( graph, tbb::flow::serial,
[all …]
H A Dtest_task_arena.cpp77 tbb::task_arena arena( tbb::task_arena::automatic ); in InitializeAndTerminate()
185 tbb::task_arena a1; in TestConcurrentArenasFunc()
625 tbb::task_arena arena{tbb::task_arena::attach()}; in operator ()()
634 tbb::task_arena arena2{tbb::task_arena::attach()}; in operator ()()
649 tbb::task_arena arena2{tbb::task_arena::attach()}; in operator ()()
656 tbb::task_arena arena2{tbb::task_arena::attach()}; in operator ()()
978 tbb::task_arena arena{tbb::task_arena::attach()}; in TestEnqueue()
1166 tbb::global_control gc(tbb::global_control::thread_stack_size, in TestSmallStackSize()
1340 tbb::enumerable_thread_specific<tbb::task_arena*>& my_tls;
1347 tbb::enumerable_thread_specific<tbb::task_arena*>& tls, in MyObserver()
[all …]
H A Dtest_task.cpp128 tbb::task_group test_gr;
210 tbb::parallel_for(tbb::blocked_range<std::size_t>(0, pfor_iter_count), in __anon509d20bd0502()
355 tbb::parallel_for(tbb::blocked_range<std::size_t>(0, 100000), in execute()
388 tbb::parallel_for(tbb::blocked_range<std::size_t>(0, 100000),
591 …tbb::parallel_for(tbb::blocked_range<std::size_t>(0, 1000), [] (tbb::blocked_range<std::size_t>&) { in __anon509d20bd1702()
634 tbb::concurrent_vector<tbb::task::suspend_point> suspend_points;
642 tbb::task::suspend([&] (tbb::task::suspend_point sp) { in __anon509d20bd1a02()
692 tbb::global_control gc(tbb::global_control::max_allowed_parallelism, 1);
696 tbb::task_arena test_arena2(tbb::task_arena::attach{});
702 tbb::global_control gc(tbb::global_control::max_allowed_parallelism, 1);
[all …]
H A Dtest_continue_node.cpp37 struct fake_continue_sender : public tbb::flow::sender<tbb::flow::continue_msg>
39 typedef tbb::flow::sender<tbb::flow::continue_msg>::successor_type successor_type;
101 tbb::flow::graph g; in continue_nodes()
133 tbb::flow::graph g; in continue_nodes_with_copy()
274 tbb::flow::graph g; in test_lightweight_policy()
277 tbb::flow::continue_node<tbb::flow::continue_msg, tbb::flow::lightweight> in test_lightweight_policy()
279 tbb::flow::continue_node<tbb::flow::continue_msg, tbb::flow::lightweight> in test_lightweight_policy()
401 tbb::flow::continue_node<Input>(tbb::flow::follows(f), body);
402 tbb::flow::continue_node<Input>(tbb::flow::follows(f), body, priority);
403 tbb::flow::continue_node<Input>(tbb::flow::follows(f), num, body);
[all …]
H A Dtest_join_node.cpp38 typedef typename tbb::flow::join_node<OutputTupleType, tbb::flow::tag_matching> join_node_type;
53 typedef tbb::flow::join_node<input_tuple_type, tbb::flow::reserving> input_join_type;
61 tbb::flow::graph g; in test()
65 tbb::flow::input_node<tbb::flow::continue_msg> snode(g, recirc_input_node_body()); in test()
72 tbb::flow::make_edge(tag_queue, tbb::flow::input_port<0>(*my_input_join)); in test()
109 tbb::flow::remove_edge(tag_queue, tbb::flow::input_port<0>(*my_input_join)); in test()
110 tbb::flow::remove_edge(snode, tbb::flow::input_port<1>(*my_input_join)); in test()
119 typedef tbb::flow::join_node<JType, tbb::flow::tag_matching> join_node_type;
134 test_main<tbb::flow::queueing>();
135 test_main<tbb::flow::reserving>();
[all …]
/oneTBB/test/conformance/
H A Dconformance_mutex.cpp39 GeneralTest<oneapi::tbb::spin_mutex>("Spin Mutex");
40 GeneralTest<oneapi::tbb::spin_rw_mutex>("Spin RW Mutex");
41 GeneralTest<oneapi::tbb::queuing_mutex>("Queuing Mutex");
43 GeneralTest<oneapi::tbb::mutex>("Adaptive Mutex");
44 GeneralTest<oneapi::tbb::rw_mutex>("Adaptive RW Mutex");
52 …GeneralTest<oneapi::tbb::null_mutex, utils::AtomicCounter<oneapi::tbb::null_mutex>>("Null Mutex", …
53 …GeneralTest<oneapi::tbb::null_rw_mutex, utils::AtomicCounter<oneapi::tbb::null_rw_mutex>>("Null RW…
54 TestNullMutex<oneapi::tbb::null_mutex>("Null Mutex");
61 TestTryAcquire<oneapi::tbb::spin_mutex>("Spin Mutex");
65 TestTryAcquire<oneapi::tbb::mutex>("Adaptive Mutex");
[all …]
H A Dconformance_global_control.cpp34 oneapi::tbb::global_control s0(oneapi::tbb::global_control::thread_stack_size, 1*MB); in TestStackSizeSimpleControl()
37 oneapi::tbb::global_control s1(oneapi::tbb::global_control::thread_stack_size, 8*MB); in TestStackSizeSimpleControl()
251 …oneapi::tbb::global_control* ctl1 = new oneapi::tbb::global_control(oneapi::tbb::global_control::m…
252 …oneapi::tbb::global_control* ctl2 = new oneapi::tbb::global_control(oneapi::tbb::global_control::m…
266 tbb::task_scheduler_handle hdl1{ tbb::attach{} };
271 hdl2 = tbb::task_scheduler_handle{ tbb::attach{} };
288 tbb::task_scheduler_handle hndl{ tbb::attach{} };
300 tbb::task_scheduler_handle handle1{ tbb::attach{} };
316 tbb::task_scheduler_handle handle{ tbb::attach{} };
330 handle = tbb::task_scheduler_handle{ tbb::attach{} }; in __anon3ebcafb90202()
[all …]
H A Dconformance_parallel_pipeline.cpp70 static const oneapi::tbb::filter_mode filter_table[] = { oneapi::tbb::filter_mode::parallel,
125 auto f_beg = oneapi::tbb::make_filter<void, I>(oneapi::tbb::filter_mode::serial_out_of_order, in RunPipeline()
134 auto f_end = oneapi::tbb::make_filter<O, void>(oneapi::tbb::filter_mode::serial_in_order, in RunPipeline()
298 oneapi::tbb::filter<short, short> filter2(oneapi::tbb::filter_mode::serial_in_order,
308 oneapi::tbb::filter<short,int> filter3(oneapi::tbb::filter_mode::parallel,
318 oneapi::tbb::filter<int,void> filter4(oneapi::tbb::filter_mode::serial_in_order,
336 oneapi::tbb::filter<void,int> filter1(oneapi::tbb::filter_mode::parallel,
350 oneapi::tbb::filter<int,int> filter2(oneapi::tbb::filter_mode::parallel,
360 oneapi::tbb::filter<int,void> filter3(oneapi::tbb::filter_mode::serial_out_of_order,
383 oneapi::tbb::filter fc1(oneapi::tbb::filter_mode::serial_in_order, i_filter);
[all …]
H A Dconformance_graph.cpp50 oneapi::tbb::flow::graph g; in test_input_node_rf_reset_protocol()
70 oneapi::tbb::flow::graph g; in test_functional_nodes_rf_reset_protocol()
88 oneapi::tbb::flow::graph g; in test_buffering_nodes_rf_reset_protocol()
107 oneapi::tbb::flow::graph g; in test_nodes_with_body_rf_reset_bodies()
124 oneapi::tbb::flow::graph g; in test_limiter_node_rf_reset_protocol()
148 oneapi::tbb::flow::graph g; in test_join_node_rf_reset_protocol()
186 oneapi::tbb::flow::graph g;
197 oneapi::tbb::flow::function_node<int, int> fxn(g, oneapi::tbb::flow::unlimited, body());
202 oneapi::tbb::flow::join_node< std::tuple< int >, oneapi::tbb::flow::queueing > j(g);
280 oneapi::tbb::flow::graph g;
[all …]
H A Dconformance_task_arena.cpp51 oneapi::tbb::task_arena attached_arena{oneapi::tbb::task_arena::attach()}; in __anon3e0b77410202()
53 oneapi::tbb::task_arena attached_arena2{oneapi::tbb::attach()}; in __anon3e0b77410202()
85 conformance_observer( oneapi::tbb::task_arena &a ) : oneapi::tbb::task_scheduler_observer(a) { in conformance_observer()
113 oneapi::tbb::parallel_for(0, 100, utils::DummyBody(10), oneapi::tbb::simple_partitioner()); in __anon3e0b77410502()
132 oneapi::tbb::task_arena arena;
133 oneapi::tbb::task_group tg;
150 oneapi::tbb::task_arena arena;
151 oneapi::tbb::task_group tg;
175 oneapi::tbb::task_group tg;
201 oneapi::tbb::task_group tg;
[all …]
H A Dconformance_indexer_node.cpp33 oneapi::tbb::flow::graph g;
73 oneapi::tbb::flow::graph g;
92 oneapi::tbb::flow::graph g;
93 oneapi::tbb::flow::function_node<int, int> f1( g, oneapi::tbb::flow::unlimited,
95 oneapi::tbb::flow::function_node<float, float> f2( g, oneapi::tbb::flow::unlimited,
103 f3( g, oneapi::tbb::flow::unlimited,
118 oneapi::tbb::flow::make_edge(f1, oneapi::tbb::flow::input_port<0>(testing_node));
119 oneapi::tbb::flow::make_edge(f2, oneapi::tbb::flow::input_port<1>(testing_node));
120 oneapi::tbb::flow::make_edge(c1, oneapi::tbb::flow::input_port<2>(testing_node));
133 oneapi::tbb::flow::graph g;
[all …]
H A Dconformance_continue_node.cpp34 using namespace tbb::flow; in test_deduction_guides_common()
97 using tbb::flow::continue_msg; in test_deduction_guides()
157 using namespace oneapi::tbb::flow;
178 using namespace oneapi::tbb::flow;
222 oneapi::tbb::flow::graph g;
226 oneapi::tbb::flow::continue_node<oneapi::tbb::flow::continue_msg> node1(g, fun);
227 oneapi::tbb::flow::continue_node<oneapi::tbb::flow::continue_msg> node2(g, 1, fun);
228 oneapi::tbb::flow::continue_node<oneapi::tbb::flow::continue_msg> node3(g, 1, fun);
248 …conformance::test_priority<oneapi::tbb::flow::continue_node<oneapi::tbb::flow::continue_msg, int>,…
261 oneapi::tbb::flow::graph g;
[all …]
H A Dconformance_join_node.cpp41 using namespace tbb::flow; in test_deduction_guides()
73 oneapi::tbb::flow::graph g;
81 oneapi::tbb::flow::make_edge(node0, oneapi::tbb::flow::input_port<0>(node1));
122 oneapi::tbb::flow::graph g;
130 oneapi::tbb::flow::join_node<my_input_tuple, oneapi::tbb::flow::queueing> testing_node(g);
145 oneapi::tbb::flow::make_edge(f1, oneapi::tbb::flow::input_port<0>(testing_node));
146 oneapi::tbb::flow::make_edge(f2, oneapi::tbb::flow::input_port<1>(testing_node));
147 oneapi::tbb::flow::make_edge(c1, oneapi::tbb::flow::input_port<2>(testing_node));
214 oneapi::tbb::flow::graph g;
218 oneapi::tbb::flow::join_node<std::tuple<oneapi::tbb::flow::continue_msg, float>,
[all …]
H A Dconformance_split_node.cpp33 oneapi::tbb::flow::graph g;
41 oneapi::tbb::flow::make_edge(oneapi::tbb::flow::output_port<0>(testing_node), rejecter1);
42 oneapi::tbb::flow::make_edge(oneapi::tbb::flow::output_port<1>(testing_node), rejecter2);
43 oneapi::tbb::flow::make_edge(oneapi::tbb::flow::output_port<2>(testing_node), rejecter3);
63 using namespace oneapi::tbb::flow;
64 oneapi::tbb::flow::graph g;
95 oneapi::tbb::flow::graph g;
103 oneapi::tbb::flow::make_edge(node0, node1);
104 oneapi::tbb::flow::make_edge(oneapi::tbb::flow::output_port<0>(node1), node2);
108 oneapi::tbb::flow::make_edge(oneapi::tbb::flow::output_port<0>(node_copy), node3);
[all …]
/oneTBB/src/tbb/def/
H A Dwin64-tbb.def20 ?assertion_failure@r1@detail@tbb@@YAXPEBDH00@Z
23 ?call_itt_notify@r1@detail@tbb@@YAXHPEAX@Z
24 ?create_itt_sync@r1@detail@tbb@@YAXPEAXPEB_W1@Z
38 ?cache_line_size@r1@detail@tbb@@YA_KXZ
39 ?allocate_memory@r1@detail@tbb@@YAPEAX_K@Z
40 ?deallocate_memory@r1@detail@tbb@@YAXPEAX@Z
41 ?is_tbbmalloc_used@r1@detail@tbb@@YA_NXZ
52 ?what@user_abort@r1@detail@tbb@@UEBAPEBDXZ
73 ?notify_waiters@r1@detail@tbb@@YAX_K@Z
104 ?numa_node_count@r1@detail@tbb@@YAIXZ
[all …]
H A Dwin32-tbb.def20 ?assertion_failure@r1@detail@tbb@@YAXPBDH00@Z
23 ?call_itt_notify@r1@detail@tbb@@YAXHPAX@Z
38 ?cache_line_size@r1@detail@tbb@@YAIXZ
39 ?allocate_memory@r1@detail@tbb@@YAPAXI@Z
40 ?deallocate_memory@r1@detail@tbb@@YAXPAX@Z
41 ?is_tbbmalloc_used@r1@detail@tbb@@YA_NXZ
52 ?what@user_abort@r1@detail@tbb@@UBEPBDXZ
53 ?what@missing_wait@r1@detail@tbb@@UBEPBDXZ
73 ?notify_waiters@r1@detail@tbb@@YAXI@Z
104 ?numa_node_count@r1@detail@tbb@@YAIXZ
[all …]
/oneTBB/test/
H A DCMakeLists.txt375 if (TARGET TBB::tbb)
377 tbb_add_test(SUBDIR tbb NAME test_tick_count DEPENDENCIES TBB::tbb)
378 tbb_add_test(SUBDIR tbb NAME test_allocators DEPENDENCIES TBB::tbb)
409 tbb_add_test(SUBDIR tbb NAME test_task_group DEPENDENCIES TBB::tbb)
411 tbb_add_test(SUBDIR tbb NAME test_task_arena DEPENDENCIES TBB::tbb)
415 tbb_add_test(SUBDIR tbb NAME test_mutex DEPENDENCIES TBB::tbb)
427 tbb_add_test(SUBDIR tbb NAME test_join_node DEPENDENCIES TBB::tbb)
443 tbb_add_test(SUBDIR tbb NAME test_profiling DEPENDENCIES TBB::tbb)
446 tbb_add_test(SUBDIR tbb NAME test_semaphore DEPENDENCIES TBB::tbb)
449 tbb_add_test(SUBDIR tbb NAME test_eh_thread DEPENDENCIES TBB::tbb)
[all …]
/oneTBB/test/tbbmalloc/
H A Dtest_scalable_allocator.cpp97 tbb::memory_pool<NullAllocator> pool; in TestZeroSpaceMemoryPool()
132 tbb::fixed_pool pool(buf, sz); in TestSmallFixedSizePool()
190 tbb::memory_pool<tbb::scalable_allocator<int>> pool;
221 typedef tbb::memory_pool<tbb::memory_pool_allocator<char, tbb::fixed_pool> > NestedPool;
226 tbb::memory_pool_allocator<char, tbb::fixed_pool> fixedPoolAllocator(fixedPool);
234 tbb::memory_pool<tbb::scalable_allocator<int>> mpool;
243 …TestAllocator<tbb::memory_pool_allocator<void>>(Comparison, tbb::memory_pool_allocator<void>(mpool…
280 tbb::memory_pool<tbb::scalable_allocator<int>> mpool;
281 … TestAllocator<tbb::memory_pool_allocator<void>>(Broken, tbb::memory_pool_allocator<void>(mpool));
290 tbb::memory_pool<tbb::scalable_allocator<int> > mpool;
[all …]

12345678910>>...20