| /oneTBB/src/tbb/ |
| H A D | task_dispatcher.cpp | 31 thread_data* tls = governor::get_thread_data(); in spawn() local
32 task_group_context_impl::bind_to(ctx, tls); in spawn()
33 arena* a = tls->my_arena; in spawn()
34 arena_slot* slot = tls->my_arena_slot; in spawn()
43 thread_data* tls = governor::get_thread_data(); in spawn() local
44 task_group_context_impl::bind_to(ctx, tls); in spawn()
45 arena* a = tls->my_arena; in spawn()
46 arena_slot* slot = tls->my_arena_slot; in spawn()
83 task_group_context_impl::bind_to(ctx, &tls); in submit()
90 if ( tls.is_attached_to(a) ) { in submit()
[all …]
|
| H A D | arena.cpp | 202 tls.attach_arena(*this, index); in process()
204 tls.my_inbox.set_is_idle(true); in process()
214 my_observers.notify_entry_observers(tls.my_last_observer, tls.my_is_worker); in process()
221 tls.my_inbox.set_is_idle(true); in process()
227 my_observers.notify_exit_observers(tls.my_last_observer, tls.my_is_worker); in process()
228 tls.my_last_observer = nullptr; in process()
230 tls.leave_task_dispatcher(); in process()
234 tls.my_arena_slot->release(); in process()
235 tls.my_arena_slot = nullptr; in process()
236 tls.my_inbox.detach(); in process()
[all …]
|
| H A D | small_object_pool.cpp | 34 auto& tls = static_cast<const execution_data_ext&>(ed).task_disp->get_thread_data(); in allocate() local
35 auto pool = tls.my_small_object_pool; in allocate()
41 auto tls = governor::get_thread_data(); in allocate() local
42 auto pool = tls->my_small_object_pool; in allocate()
75 auto tls = governor::get_thread_data(); in deallocate() local
76 pool->deallocate_impl(ptr, number_of_bytes, *tls); in deallocate()
80 auto& tls = static_cast<const execution_data_ext&>(ed).task_disp->get_thread_data(); in deallocate() local
82 pool->deallocate_impl(ptr, number_of_bytes, tls); in deallocate()
|
| H A D | task_dispatcher.h | 172 thread_data& tls, execution_data_ext& ed, Waiter& waiter, isolation_type isolation, in receive_or_steal_task() argument
175 __TBB_ASSERT(governor::is_thread_data_set(&tls), nullptr); in receive_or_steal_task()
179 arena& a = *tls.my_arena; in receive_or_steal_task()
180 arena_slot& slot = *tls.my_arena_slot; in receive_or_steal_task()
181 unsigned arena_index = tls.my_arena_index; in receive_or_steal_task()
182 mail_inbox& inbox = tls.my_inbox; in receive_or_steal_task()
218 … && (t = steal_or_get_critical(ed, a, arena_index, tls.my_random, isolation, critical_allowed))) { in receive_or_steal_task()
228 a.my_observers.notify_entry_observers(tls.my_last_observer, tls.my_is_worker); in receive_or_steal_task()
|
| H A D | governor.cpp | 216 void governor::auto_terminate(void* tls) { in auto_terminate() argument
218 get_thread_data_if_initialized() == tls, nullptr); in auto_terminate()
219 if (tls) { in auto_terminate()
220 thread_data* td = static_cast<thread_data*>(tls); in auto_terminate()
|
| H A D | governor.h | 94 static void auto_terminate(void* tls);
|
| H A D | arena.h | 372 std::size_t occupy_free_slot_in_range(thread_data& tls, std::size_t lower, std::size_t upper);
|
| H A D | scheduler_common.h | 493 d1::task* receive_or_steal_task(thread_data& tls, execution_data_ext& ed, Waiter& waiter, in alignas()
|
| /oneTBB/src/tbbmalloc/ |
| H A D | frontend.cpp | 619 if ( !tls ) in createTLS()
629 return tls; in createTLS()
669 head = tls; in registerThread()
680 tls->next->prev = tls->prev; in unregisterThread()
682 tls->prev->next = tls->next; in unregisterThread()
683 MALLOC_ASSERT(!tls->next || tls->next->next!=tls->next, ASSERT_TEXT); in unregisterThread()
995 return tls; in getTLS()
2291 if (tls) { in getFromLLOCache()
2347 if (tls) { in putToLLOCache()
2859 if (tls) { in doThreadShutdownNotification()
[all …]
|
| H A D | tbbmalloc_internal.h | 252 void registerThread(TLSRemote *tls);
253 void unregisterThread(TLSRemote *tls);
282 Block *get(TLSData *tls, unsigned int size);
|
| /oneTBB/test/tbb/ |
| H A D | test_numa_dist.cpp | 83 tbb::enumerable_thread_specific< std::pair<int, int> > tls; in TestNumaDistribution() local
96 tls.local() = std::pair<int, int>(proc.Group, proc.Number); in TestNumaDistribution()
100 for (const auto& it : tls) { in TestNumaDistribution()
|
| H A D | test_task_arena.cpp | 1347 tbb::enumerable_thread_specific<tbb::task_arena*>& tls, in MyObserver()
1351 : tbb::task_scheduler_observer(a), my_tls(tls), my_arena(a), in MyObserver()
1408 tbb::enumerable_thread_specific<tbb::task_arena*> tls; in TestArenaWorkersMigrationWithNumThreads() local
1412 observer[i] = new MyObserver(arenas[i], tls, failure_counter, counter, barrier); in TestArenaWorkersMigrationWithNumThreads()
1434 tls.clear(); in TestArenaWorkersMigrationWithNumThreads()
|
| /oneTBB/test/tbbmalloc/ |
| H A D | test_malloc_whitebox.cpp | 1357 TLSData *tls = defaultMemPool->getTLS(/*create=*/false); in TestReallocDecreasing() local
1358 tls->lloc.externalCleanup(&defaultMemPool->extMemPool); in TestReallocDecreasing()
|