| /oneTBB/include/oneapi/tbb/detail/ |
| H A D | _task.h | 45 struct execution_data;
54 TBB_EXPORT d1::slot_id __TBB_EXPORTED_FUNC execution_slot(const d1::execution_data*);
150 struct execution_data { struct
156 inline task_group_context* context(const execution_data& ed) { in context()
160 inline slot_id original_slot(const execution_data& ed) { in original_slot()
164 inline slot_id affinity_slot(const execution_data& ed) { in affinity_slot()
168 inline slot_id execution_slot(const execution_data& ed) { in execution_slot()
172 inline bool is_same_affinity(const execution_data& ed) { in is_same_affinity()
176 inline bool is_stolen(const execution_data& ed) { in is_stolen()
219 virtual task* execute(execution_data&) = 0; in alignas()
[all …]
|
| H A D | _small_object_pool.h | 36 struct execution_data;
41 const d1::execution_data& ed);
44 const d1::execution_data& ed);
52 Type* new_object(execution_data& ed, Args&&... args) { in new_object()
68 void delete_object(Type* object, const execution_data& ed) { in delete_object()
86 void deallocate(Type* ptr, const execution_data& ed) { in deallocate()
|
| H A D | _flow_graph_impl.h | 139 void destruct_and_deallocate(const execution_data& ed);
142 void finalize(const execution_data& ed);
164 task* execute(execution_data& ed) override { in execute()
171 task* cancel(execution_data& ed) override { in cancel()
364 inline void graph_task::destruct_and_deallocate(const execution_data& ed) { in destruct_and_deallocate()
372 inline void graph_task::finalize(const execution_data& ed) { in finalize()
|
| H A D | _flow_graph_body_impl.h | 257 task* execute(execution_data& ed) override {
267 task* cancel(execution_data& ed) override {
286 task* execute(execution_data& ed) override {
296 task* cancel(execution_data& ed) override {
310 task* execute(execution_data& ed) override {
320 task* cancel(execution_data& ed) override {
|
| H A D | _task_handle.h | 30 namespace d1 { class task_group_context; class wait_context; struct execution_data; }
41 void finalize(const d1::execution_data* ed = nullptr) {
|
| /oneTBB/include/oneapi/tbb/ |
| H A D | parallel_invoke.h | 45 task* execute(execution_data& ed) override { in execute()
52 task* cancel(execution_data& ed) override { in cancel()
91 void finalize(const execution_data& ed) { in finalize()
97 void release(const execution_data& ed) { in release()
106 task* execute(execution_data& ed) override { in execute()
116 task* cancel(execution_data& ed) override { in cancel()
129 void release(const execution_data&) { in release() argument
|
| H A D | parallel_scan.h | 139 task* execute(execution_data& ed) override { in execute()
146 task* cancel(execution_data& ed) override { in cancel()
162 void self_destroy(const execution_data& ed) { in self_destroy()
235 sum_node* finalize(const execution_data& ed) { in finalize()
247 task* execute(execution_data& ed) override { in execute()
265 task* cancel(execution_data& ed) override { in cancel()
268 void self_destroy(const execution_data& ed) { in self_destroy()
294 task* execute(execution_data& ed) override { in execute()
313 task* cancel(execution_data& ed) override { in cancel()
390 task* execute( execution_data& ) override;
[all …]
|
| H A D | parallel_for_each.h | 127 void finalize(const execution_data& ed) { in finalize()
149 task* execute(execution_data& ed) override { in execute()
155 task* cancel(execution_data& ed) override { in cancel()
221 task* execute(execution_data&) override { in execute()
227 task* cancel(execution_data&) override { in cancel()
277 void finalize(const execution_data& ed) {
297 task* cancel(execution_data& ed) override {
342 void finalize(const execution_data& ed) {
362 task* cancel(execution_data& ed) override {
485 task* cancel(execution_data&) override {
[all …]
|
| H A D | parallel_reduce.h | 98 task* execute(execution_data&) override;
99 task* cancel(execution_data&) override;
100 void finalize(const execution_data&);
162 void offer_work(const Range& r, depth_t d, execution_data& ed) { in offer_work()
168 void offer_work_impl(execution_data& ed, Args&&... args) { in offer_work_impl()
180 void spawn_self(execution_data& ed) { in spawn_self()
259 task* execute(execution_data&) override;
260 task* cancel(execution_data&) override;
261 void finalize(const execution_data&);
308 void offer_work_impl(execution_data& ed, Args&&... args) { in offer_work_impl()
[all …]
|
| H A D | partitioner.h | 161 void fold_tree(node* n, const execution_data& ed) { in fold_tree()
263 …bool check_being_stolen(Task&, const execution_data&) { return false; } // part of old should_exec… in check_being_stolen()
268 void work_balance(StartType &start, Range &range, const execution_data&) { in work_balance()
273 void execute(StartType &start, Range &range, execution_data& ed) { in execute()
381 static bool is_stolen_task(const execution_data& ed) { in is_stolen_task()
408 … bool check_being_stolen(Task &t, const execution_data& ed) { // part of old should_execute_range() in check_being_stolen()
433 void work_balance(StartType &start, Range &range, execution_data& ed) { in work_balance()
509 void execute(StartType &start, Range &range, execution_data& ed) { in execute()
584 bool should_execute_range(const execution_data& ) {return false;} in should_execute_range() argument
613 bool should_execute_range(const execution_data& ed) { in should_execute_range()
|
| H A D | parallel_for.h | 69 task* execute(execution_data&) override;
70 task* cancel(execution_data&) override;
71 void finalize(const execution_data&);
121 void offer_work(typename Partitioner::split_type& split_obj, execution_data& ed) { in offer_work()
126 void offer_work(const Range& r, depth_t d, execution_data& ed) { in offer_work()
132 void offer_work_impl(execution_data& ed, Args&&... constructor_args) { in offer_work_impl()
143 void spawn_self(execution_data& ed) { in spawn_self()
150 void start_for<Range, Body, Partitioner>::finalize(const execution_data& ed) { in finalize()
165 task* start_for<Range, Body, Partitioner>::execute(execution_data& ed) { in execute()
177 task* start_for<Range, Body, Partitioner>::cancel(execution_data& ed) { in cancel()
|
| H A D | task_group.h | 88 d1::task* execute(d1::execution_data& ed) override { in execute()
94 d1::task* cancel(d1::execution_data& ed) override { in cancel()
440 void finalize(const execution_data& ed) { in finalize()
451 task* execute(execution_data& ed) override { in execute()
456 task* cancel(execution_data& ed) override { in cancel()
480 task* execute(execution_data&) override { in execute() argument
485 task* cancel(execution_data&) override { in cancel() argument
|
| H A D | task_arena.h | 213 void finalize(const execution_data& ed) { in finalize()
216 task* execute(execution_data& ed) override { in execute()
221 task* cancel(execution_data&) override { in cancel() argument
|
| H A D | flow_graph.h | 3134 task* execute(execution_data& ed) override { in execute()
3145 task* cancel(execution_data& ed) override { in cancel()
|
| /oneTBB/src/tbb/ |
| H A D | parallel_pipeline.cpp | 216 void try_to_spawn_task_for_next_token(StageTask& spawner, d1::execution_data& ed) { in try_to_spawn_task_for_next_token()
278 bool execute_filter(d1::execution_data& ed);
281 void try_spawn_stage_task(d1::execution_data& ed) { in try_spawn_stage_task()
318 void finalize(d1::execution_data& ed) { in finalize()
322 task* execute(d1::execution_data& ed) override { in execute()
329 task* cancel(d1::execution_data& ed) override { in cancel()
342 void spawn_stage_task(const task_info& info, d1::execution_data& ed) { in spawn_stage_task()
349 bool stage_task::execute_filter(d1::execution_data& ed) { in execute_filter()
|
| H A D | small_object_pool.cpp | 33 …ate(d1::small_object_pool*& allocator, std::size_t number_of_bytes, const d1::execution_data& ed) { in allocate()
79 …all_object_pool& allocator, void* ptr, std::size_t number_of_bytes, const d1::execution_data& ed) { in deallocate()
|
| H A D | mailbox.h | 85 task* execute(d1::execution_data&) override { in execute()
89 task* cancel(d1::execution_data&) override { in cancel()
|
| H A D | scheduler_common.h | 93 struct execution_data_ext : d1::execution_data {
428 d1::task* execute(d1::execution_data& ed) override;
429 d1::task* cancel(d1::execution_data&) override { in cancel()
|
| H A D | task_dispatcher.cpp | 57 auto proxy = alloc.new_object<task_proxy>(static_cast<d1::execution_data&>(ed)); in spawn()
129 d1::slot_id __TBB_EXPORTED_FUNC execution_slot(const d1::execution_data* ed) { in execution_slot()
|
| H A D | arena.cpp | 699 d1::task* execute(d1::execution_data& ed) override { in execute()
718 d1::task* cancel(d1::execution_data&) override { in cancel() argument
|
| H A D | task_dispatcher.h | 65 inline d1::task* suspend_point_type::resume_task::execute(d1::execution_data& ed) { in execute()
|
| /oneTBB/test/tbb/ |
| H A D | test_task.cpp | 54 task* execute( tbb::detail::d1::execution_data& ) override { in execute() argument
61 task* cancel( tbb::detail::d1::execution_data& ) override { in cancel() argument
354 task* execute(tbb::detail::d1::execution_data&) override { in execute()
371 task* cancel(tbb::detail::d1::execution_data&) override { in cancel()
425 task* execute(tbb::detail::d1::execution_data&) override { in execute()
450 task* cancel(tbb::detail::d1::execution_data&) override { in cancel()
734 tbb::detail::d1::task* execute(tbb::detail::d1::execution_data& ) override { in execute()
741 tbb::detail::d1::task* cancel( tbb::detail::d1::execution_data& ) override { in cancel()
|
| H A D | test_task_arena.cpp | 943 tbb::detail::d1::task* execute(tbb::detail::d1::execution_data&) override { in execute() argument
954 tbb::detail::d1::task* cancel(tbb::detail::d1::execution_data&) override { return nullptr; } in cancel() argument
|