Home
last modified time | relevance | path

Searched refs:r1 (Results 1 – 25 of 123) sorted by relevance

12345

/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/examples/parallel_for/tachyon/src/
H A Dcoordsys.cpp55 flt r1; in xytopolar() local
56 r1 = x * x + y * y; in xytopolar()
57 *v = sqrt(r1 / (rad * rad)); in xytopolar()
59 *u = 1.0 - acos(x / sqrt(r1)) / TWOPI; in xytopolar()
61 *u = acos(x / sqrt(r1)) / TWOPI; in xytopolar()
65 flt r1; in xyztocyl() local
67 r1 = pnt.x * pnt.x + pnt.y * pnt.y; in xyztocyl()
71 *u = 1.0 - acos(pnt.x / sqrt(r1)) / TWOPI; in xyztocyl()
73 *u = acos(pnt.x / sqrt(r1)) / TWOPI; in xyztocyl()
77 flt r1, phi, theta; in xyztospr() local
[all …]
/oneTBB/include/oneapi/tbb/detail/
H A D_task.h48 namespace r1 {
93 r1::resume(tag); in resume()
124 friend class r1::thread_data;
125 friend class r1::task_dispatcher;
169 return r1::execution_slot(&ed); in execution_slot()
182 r1::spawn(t, ctx); in spawn()
187 r1::spawn(t, ctx, id); in spawn()
197 r1::wait(wait_ctx, ctx); in wait()
202 using r1::current_context;
206 friend struct r1::task_accessor;
[all …]
H A D_rtm_rw_mutex.h29 namespace r1 {
45 friend struct r1::rtm_rw_mutex_impl; in alignas()
65 friend struct r1::rtm_rw_mutex_impl; in alignas()
124 namespace r1 {
148 r1::acquire_writer(m, *this); in acquire()
150 r1::acquire_reader(m, *this); in acquire()
158 return r1::try_acquire_writer(m, *this); in try_acquire()
160 return r1::try_acquire_reader(m, *this); in try_acquire()
168 return r1::release(*this); in release()
178 return r1::upgrade(*this); in upgrade_to_writer()
[all …]
H A D_rtm_mutex.h28 namespace r1 {
96 friend r1::rtm_mutex_impl; in alignas()
104 friend r1::rtm_mutex_impl; in alignas()
108 namespace r1 {
122 r1::acquire(m, *this); in acquire()
128 return r1::try_acquire(m, *this); in try_acquire()
135 return r1::release(*this); in release()
H A D_small_object_pool.h39 namespace r1 {
53 void* allocated_object = r1::allocate(m_pool, sizeof(Type), ed); in new_object()
61 void* allocated_object = r1::allocate(m_pool, sizeof(Type)); in new_object()
90 r1::deallocate(*m_pool, ptr, sizeof(Type), ed); in deallocate()
98 r1::deallocate(*m_pool, ptr, sizeof(Type)); in deallocate()
H A D_waitable_atomic.h25 namespace r1 {
38 r1::wait_on_address(address, pred, context); in adaptive_wait_on_address()
67 r1::wait_on_address(this, pred, context); in wait()
73 r1::notify_by_address_one(this); in notify_one_relaxed()
H A D_pipeline_filters.h35 namespace r1 {
74 r1::set_end_of_input(*this); in set_end_of_input()
111 r1::input_buffer* my_input_buffer;
113 friend class r1::stage_task;
114 friend class r1::pipeline;
115 friend void r1::set_end_of_input(d1::base_filter&);
121 r1::pipeline* my_pipeline;
177 return new (r1::allocate_memory(sizeof(T))) T(std::move(source));
184 r1::deallocate_memory(token);
363 r1::deallocate_memory(this);
[all …]
/oneTBB/include/oneapi/tbb/
H A Dglobal_control.h39 namespace r1 {
77 r1::create(*this); in global_control()
87 r1::destroy(*this); in ~global_control()
92 return r1::global_control_active_value((int)p); in active_value()
100 friend struct r1::global_control_impl;
101 friend struct r1::control_storage_comparator;
118 r1::get(*this); in task_scheduler_handle()
147 r1::finalize(*this, release_nothrowing); in release()
153 friend void r1::release_impl(task_scheduler_handle& handle);
181 finalized = r1::finalize(handle, finalize_nothrowing); in finalize()
[all …]
H A Dprofiling.h72 namespace r1 {
114 r1::create_itt_sync(ptr, type, name); in create_itt_sync()
125 r1::call_itt_notify(static_cast<int>(t), ptr); in call_itt_task_notify()
132 r1::call_itt_notify(static_cast<int>(t), ptr); in call_itt_notify()
137 r1::itt_set_sync_name(obj, name); in itt_set_sync_name()
143 r1::itt_set_sync_name(obj, obj_name); in itt_set_sync_name()
148 r1::itt_set_sync_name(obj, name); in itt_set_sync_name()
159 r1::itt_metadata_str_add( domain, addr, addr_extra, key, value ); in itt_metadata_str_add()
164 r1::itt_metadata_ptr_add(domain, addr, addr_extra, key, value); in register_node_addr()
178 r1::itt_task_end( domain ); in itt_task_end()
[all …]
H A Dtask_arena.h82 namespace r1 {
117 friend struct r1::task_arena_impl;
135 std::atomic<r1::arena*> my_arena;
136 static_assert(sizeof(std::atomic<r1::arena*>) == sizeof(r1::arena*),
251 r1::execute(*this, func); in execute_impl()
297 if (r1::attach(*this)) { in task_arena()
321 r1::initialize(*this);
338 r1::initialize(*this);
365 r1::terminate(*this); in terminate()
425 r1::wait(*this); in debug_wait_until_empty()
[all …]
H A Dqueuing_rw_mutex.h32 namespace r1 {
42 friend r1::queuing_rw_mutex_impl;
62 friend r1::queuing_rw_mutex_impl;
160 namespace r1 {
173 r1::acquire(m, *this, write); in acquire()
177 return r1::try_acquire(m, *this, write); in try_acquire()
181 r1::release(*this); in release()
185 return r1::upgrade_to_writer(*this); in upgrade_to_writer()
189 return r1::downgrade_to_reader(*this); in downgrade_to_reader()
193 return r1::is_writer(*this); in is_writer()
H A Dtask_scheduler_observer.h31 namespace r1 {
44 friend class r1::observer_proxy;
45 friend class r1::observer_list;
46 friend void r1::observe(d1::task_scheduler_observer&, bool);
50 std::atomic<r1::observer_proxy*> my_proxy{ nullptr };
103 r1::observe(*this, state);
H A Dinfo.h69 namespace r1 {
86 std::vector<numa_node_id> node_indices(r1::numa_node_count()); in numa_nodes()
87 r1::fill_numa_indices(node_indices.data()); in numa_nodes()
92 return r1::numa_default_concurrency(id);
96 std::vector<int> core_type_indexes(r1::core_type_count()); in core_types()
97 r1::fill_core_type_indices(core_type_indexes.data()); in core_types()
103 return r1::constraints_default_concurrency(c); in default_concurrency()
H A Dtask_group.h51 namespace r1 {
229 r1::context_list* my_context_list;
240 static_assert(sizeof(std::atomic<r1::tbb_exception_ptr*>) == sizeof(r1::tbb_exception_ptr*),
268 r1::initialize(*this);
353 r1::destroy(*this); in ~task_group_context()
366 r1::reset(actual_context()); in reset()
411 friend class r1::thread_data;
412 friend class r1::task_dispatcher;
414 friend class r1::context_guard_helper;
415 friend struct r1::task_arena_impl;
[all …]
H A Drw_mutex.h91 r1::notify_by_address(this, WRITER_CONTEXT); in unlock()
95 r1::notify_by_address_all(this); in unlock()
119 r1::notify_by_address(this, WRITER_CONTEXT); in try_lock_shared()
136 r1::notify_by_address(this, WRITER_CONTEXT); in unlock_shared()
140 r1::notify_by_address_all(this); in unlock_shared()
183 r1::notify_by_address(this, READER_CONTEXT); in downgrade()
H A Dtbb_allocator.h32 namespace r1 {
60 return static_cast<T*>(r1::allocate_memory(n * sizeof(value_type))); in allocate()
65 r1::deallocate_memory(p); in deallocate()
70 return r1::is_tbbmalloc_used() ? standard : scalable; in allocator_type()
H A Dconcurrent_queue.h136 r1::cache_aligned_deallocate(my_queue_representation); in ~concurrent_queue()
303 namespace r1 {
331 r1::wait_bounded_queue_monitor(monitors, monitor_tag, target, func); in internal_wait()
353 r1::allocate_bounded_queue_rep(sizeof(queue_representation_type))); in concurrent_bounded_queue()
580 r1::notify_bounded_queue_monitor(my_monitors, cbq_items_avail_tag, ticket); in internal_push()
596 r1::notify_bounded_queue_monitor(my_monitors, cbq_items_avail_tag, ticket); in internal_push_if_not_full()
625 r1::notify_bounded_queue_monitor(my_monitors, cbq_slots_avail_tag, target); in internal_pop()
641 r1::abort_bounded_queue_monitors(my_monitors); in internal_abort()
662 r1::concurrent_monitor* my_monitors;
694 using detail::r1::user_abort;
[all …]
H A Dparallel_pipeline.h32 namespace r1 {
72 my_root( new(r1::allocate_memory(sizeof(filter_node_leaf<InputType, OutputType, Body>))) in filter()
91 …return filter_node_ptr( new(r1::allocate_memory(sizeof(filter_node_leaf<InputType, OutputType, Bod… in make_filter()
108 …return filter_node_ptr( new (r1::allocate_memory(sizeof(filter_node))) filter_node(left.my_root,ri…
120 r1::parallel_pipeline(context, max_number_of_live_tokens, *filter_chain.my_root); in parallel_pipeline()
/oneTBB/test/tbb/
H A Dtest_blocked_range.cpp60 blocked_range<std::size_t> r1(0, std::size_t(-1) / 2); variable
61 std::size_t size = r1.size();
62 std::size_t begin = r1.begin();
63 std::size_t end = r1.end();
66 blocked_range<std::size_t> r2(r1, p);
79 bool test_passed = (r1.begin() == begin && r1.end() == r2.begin() && is_split_correct &&
83 …"must be r1[%lu, %lu) and r2[%lu, %lu)\n", begin, end, r1.begin(), r1.end(), r2.begin(), r2.end(),…
H A Dtest_dynamic_link.cpp57 static const tbb::detail::r1::dynamic_link_descriptor LinkTable[] = {
58 { "foo1", (tbb::detail::r1::pointer_to_handler*)(void*)(&foo1_handler) },
59 { "foo2", (tbb::detail::r1::pointer_to_handler*)(void*)(&foo2_handler) }
80 …if (tbb::detail::r1::dynamic_link(lib_name, LinkTable, sizeof(LinkTable) / sizeof(LinkTable[0]))) { in test_dynamic_link()
H A Dtest_intrusive_list.cpp24 using tbb::detail::r1::intrusive_list_node;
43 friend class tbb::detail::r1::intrusive_list<DataItemWithInheritedNode>;
65 using intrusive_list1 = tbb::detail::r1::intrusive_list<DataItemWithInheritedNode>;
66 using intrusive_list2 = tbb::detail::r1::memptr_intrusive_list<DataItemWithMemberNodes,
70 using intrusive_list3 = tbb::detail::r1::memptr_intrusive_list<DataItemWithMemberNodes,
/oneTBB/src/tbb/
H A Ditt_notify.h51 namespace r1 {
89 #define ITT_TASK_GROUP(obj,name,parent) r1::itt_make_task_group(d1::ITT_DOMAIN_MAIN,(void*)(obj…
90 #define ITT_TASK_BEGIN(obj,name,id) r1::itt_task_begin(d1::ITT_DOMAIN_MAIN,(void*)(id),ALGO…
91 #define ITT_TASK_END r1::itt_task_end(d1::ITT_DOMAIN_MAIN)
/oneTBB/test/conformance/
H A Dconformance_blocked_range.cpp155 oneapi::tbb::blocked_range r1(v.begin(), v.end()); variable
156 …static_assert(std::is_same<decltype(r1), oneapi::tbb::blocked_range<decltype(v)::iterator>>::value…
159 oneapi::tbb::blocked_range r2(r1);
160 static_assert(std::is_same<decltype(r2), decltype(r1)>::value);
163 oneapi::tbb::blocked_range r3(std::move(r1));
164 static_assert(std::is_same<decltype(r3), decltype(r1)>::value);

12345