| /oneTBB/test/common/ |
| H A D | exception_handling.h | 34 std::atomic<intptr_t> g_CurExecuted, 44 std::atomic<intptr_t> g_ActualMaxThreads; 45 std::atomic<intptr_t> g_ActualCurrentThreads; 59 std::atomic<intptr_t> g_NumExceptionsCaught; 127 constexpr std::intptr_t Existed = INT_MAX; 149 intptr_t expected = 0; in ThrowTestException() 157 intptr_t expected = 0; in ThrowTestException() 176 intptr_t expected = 0;\ 269 intptr_t m_cancellationThreshold; 289 const intptr_t limit = 10000000; in WaitUntilReady() [all …]
|
| H A D | container_move_support.h | 33 static constexpr intptr_t initial_bar = 42; 123 intptr_t my_bar; 132 intptr_t& zero_bar() { in zero_bar() 137 intptr_t zero_bar() const { in zero_bar() 142 intptr_t& bar() { in bar() 147 intptr_t bar() const { in bar() 168 operator intptr_t() const { return bar(); } in intptr_t() function 170 Foo( intptr_t br ) : state_trackable_type(0) { in Foo() 253 FooWithAssign( intptr_t b ) : Foo(b) {} in FooWithAssign() 269 intptr_t x_bar; [all …]
|
| /oneTBB/src/tbbmalloc/ |
| H A D | backend.h | 30 std::atomic<intptr_t> inFlyBlocks; // to another 31 std::atomic<intptr_t> binsModifications; // incremented on every bin modification 42 intptr_t prev = inFlyBlocks.fetch_sub(1); in blockReleased() 48 inline bool waitTillBlockReleased(intptr_t startModifiedCnt); 57 std::atomic<intptr_t> inFlyBlocks; 67 std::atomic<intptr_t> active; 73 intptr_t prevCnt = active.load(std::memory_order_acquire); in wait() 253 std::atomic<intptr_t> bootsrapMemStatus; 268 std::atomic<intptr_t> backendCleanCnt; 283 intptr_t blocksInCoalescing() const { return coalescQ.blocksInFly(); } in blocksInCoalescing() [all …]
|
| H A D | Synchronize.h | 78 inline void SpinWaitWhileEq(const std::atomic<intptr_t>& location, const intptr_t value) { in SpinWaitWhileEq() 84 inline void SpinWaitUntilEq(const std::atomic<intptr_t>& location, const intptr_t value) { in SpinWaitUntilEq()
|
| H A D | tbbmalloc_internal.h | 92 extern intptr_t mallocCalls, cacheHits; 93 extern intptr_t memAllocKB, memHitKB; 283 void put(intptr_t binTag, Block *block); 346 intptr_t blockState[2]; 375 intptr_t val; 379 intptr_t get() const { 385 void set(intptr_t newVal) { 395 void initReadEnv(const char *envName, intptr_t defaultVal) { 434 std::atomic<intptr_t> needActualStatusPrint; 518 void setMode(intptr_t newVal) { [all …]
|
| H A D | large_objects.h | 160 std::atomic<intptr_t> ageThreshold; 167 std::atomic<intptr_t> meanHitRange; 194 intptr_t threshold = ageThreshold.load(std::memory_order_relaxed); in decreaseThreshold() 217 void updateMeanHitRange( intptr_t hitRange ) { in updateMeanHitRange() 219 intptr_t mean = meanHitRange.load(std::memory_order_relaxed); in updateMeanHitRange() 238 intptr_t hugeSizeThresholdIdx; 242 std::atomic<intptr_t> tooLargeLOC;
|
| H A D | Customize.h | 50 inline intptr_t BitScanRev(uintptr_t x) { in BitScanRev() 51 return x == 0 ? -1 : static_cast<intptr_t>(tbb::detail::log2(x)); in BitScanRev()
|
| H A D | frontend.cpp | 70 const intptr_t UNUSABLE = 0x1; 72 return (UNUSABLE|(intptr_t)ptr)!=UNUSABLE; in isSolidPtr() 75 return (intptr_t)ptr==UNUSABLE; in isNotForUse() 111 std::atomic<intptr_t> ThreadCount; 170 intptr_t ThreadId::ThreadCount; 295 static intptr_t defaultMemPool_space[sizeof(MemoryPool)/sizeof(intptr_t) + 376 void shareOrphaned(intptr_t binTag, unsigned index); 1455 const intptr_t endMarker = reset ? 0 : UNUSABLE; in privatizePublicFreeList() 1524 (intptr_t&)(publicFreeList) = UNUSABLE; in readyToShare() 1964 std::atomic<intptr_t> flag; [all …]
|
| H A D | large_objects.cpp | 220 std::atomic<intptr_t> mallocCalls, cacheHits; 222 std::atomic<intptr_t> memAllocKB, memHitKB; 226 inline bool lessThanWithOverflow(intptr_t a, intptr_t b) in lessThanWithOverflow() 228 return (a < b && (b - a < static_cast<intptr_t>(UINTPTR_MAX/2))) || in lessThanWithOverflow() 229 (a > b && (a - b > static_cast<intptr_t>(UINTPTR_MAX/2))); in lessThanWithOverflow() 489 …(intptr_t)(currTime - oldest.load(std::memory_order_relaxed)) > ageThreshold.load(std::memory_orde… in cleanToThreshold() 612 intptr_t threshold = ageThreshold.load(std::memory_order_relaxed); in forgetOutdatedState() 631 …(intptr_t)(currTime - last.load(std::memory_order_relaxed)->age) < ageThreshold.load(std::memory_o… in cleanToThreshold() 647 …(intptr_t)(currTime - last.load(std::memory_order_relaxed)->age) > ageThreshold.load(std::memory_o… in cleanToThreshold()
|
| /oneTBB/src/tbb/ |
| H A D | mailbox.h | 32 static const intptr_t pool_bit = 1<<0; 33 static const intptr_t mailbox_bit = 1<<1; 34 static const intptr_t location_mask = pool_bit | mailbox_bit; 39 std::atomic<intptr_t> task_and_tag; 53 static bool is_shared ( intptr_t tat ) { in is_shared() 58 static task* task_ptr ( intptr_t tat ) { in task_ptr() 63 template<intptr_t from_bit> 66 intptr_t tat = task_and_tag.load(std::memory_order_acquire); in extract_task() 71 const intptr_t cleaner_bit = location_mask & ~from_bit; in extract_task()
|
| H A D | arena_slot.cpp | 76 if ( (std::intptr_t)( head.load(std::memory_order_acquire) ) > (std::intptr_t)T ) { in get_task() 79 if ( (std::intptr_t)H0 > (std::intptr_t)T ) { in get_task() 143 __TBB_ASSERT( (std::intptr_t)tail.load(std::memory_order_relaxed) >= 0, nullptr ); in get_task() 162 if ((std::intptr_t)H > (std::intptr_t)(tail.load(std::memory_order_acquire))) { in steal_task()
|
| H A D | governor.cpp | 303 bool __TBB_EXPORTED_FUNC finalize(d1::task_scheduler_handle& handle, std::intptr_t mode) { in finalize() 539 unsigned __TBB_EXPORTED_FUNC core_type_count(intptr_t /*reserved*/) { in core_type_count() argument 544 void __TBB_EXPORTED_FUNC fill_core_type_indices(int* index_array, intptr_t /*reserved*/) { in fill_core_type_indices() argument 568 int __TBB_EXPORTED_FUNC constraints_default_concurrency(const d1::constraints& c, intptr_t /*reserv… in constraints_default_concurrency() argument 578 int __TBB_EXPORTED_FUNC constraints_threads_per_core(const d1::constraints&, intptr_t /*reserved*/)… in constraints_threads_per_core() argument
|
| /oneTBB/test/tbb/ |
| H A D | test_concurrent_unordered_map.cpp | 43 …checked_state_map_type = tbb::concurrent_unordered_map<intptr_t, FooWithAssign, std::hash<intptr_t… 44 … std::equal_to<intptr_t>, MyAllocator<intptr_t, FooWithAssign>>; 45 …ate_multimap_type = tbb::concurrent_unordered_multimap<intptr_t, FooWithAssign, std::hash<intptr_t… 46 … std::equal_to<intptr_t>, MyAllocator<intptr_t, FooWithAssign>>;
|
| H A D | test_concurrent_map.cpp | 39 using checked_state_map_type = tbb::concurrent_map<intptr_t, FooWithAssign, std::less<intptr_t>, 40 MyAllocator<intptr_t, FooWithAssign>>; 41 …checked_state_multimap_type = tbb::concurrent_multimap<intptr_t, FooWithAssign, std::less<intptr_t… 42 MyAllocator<intptr_t, FooWithAssign>>;
|
| H A D | test_eh_algorithms.cpp | 118 inline intptr_t CountSubranges(range_type r) { in CountSubranges() 119 if(!r.is_divisible()) return intptr_t(1); in CountSubranges() 124 inline intptr_t NumSubranges ( intptr_t length, intptr_t grain ) { in NumSubranges() 129 intptr_t TestNumSubrangesCalculation ( intptr_t length, intptr_t grain, intptr_t inner_length, intp… in TestNumSubrangesCalculation() 132 intptr_t outerCalls = NumSubranges(length, grain), in TestNumSubrangesCalculation() 921 intptr_t innerCalls = get_iter_range_size(), in Test3_parallel_for_each() 979 intptr_t innerCalls = get_iter_range_size(), in Test4_parallel_for_each() 1178 intptr_t threshold = get_iter_range_size() / 4; in TestCancelation1_parallel_for_each() 1537 intptr_t innerCalls = 2*get_iter_range_size(), in Test4_pipeline() 1544 intptr_t minExecuted = 0; in Test4_pipeline() [all …]
|
| /oneTBB/include/oneapi/tbb/ |
| H A D | info.h | 76 TBB_EXPORT unsigned __TBB_EXPORTED_FUNC core_type_count(intptr_t reserved = 0); 77 TBB_EXPORT void __TBB_EXPORTED_FUNC fill_core_type_indices(int* index_array, intptr_t reserved = 0); 79 …TBB_EXPORTED_FUNC constraints_default_concurrency(const d1::constraints& c, intptr_t reserved = 0); 80 TBB_EXPORT int __TBB_EXPORTED_FUNC constraints_threads_per_core(const d1::constraints& c, intptr_t …
|
| H A D | global_control.h | 48 TBB_EXPORT bool __TBB_EXPORTED_FUNC finalize(d1::task_scheduler_handle&, std::intptr_t mode); 97 …std::intptr_t my_reserved; // TODO: substitution of global_control* not to break backward compatib… 106 static constexpr std::intptr_t release_nothrowing = 0; 107 static constexpr std::intptr_t finalize_nothrowing = 1; 108 static constexpr std::intptr_t finalize_throwing = 2;
|
| H A D | memory_pool.h | 177 static void *allocate_request(intptr_t pool_id, size_t & bytes); 178 static int deallocate_request(intptr_t pool_id, void*, size_t raw_bytes); 191 inline static void *allocate_request(intptr_t pool_id, size_t & bytes); 206 rml::MemPoolError res = rml::pool_create_v1(intptr_t(this), &args, &my_pool); in memory_pool() 211 void *memory_pool<Alloc>::allocate_request(intptr_t pool_id, size_t & bytes) { in allocate_request() 234 int memory_pool<Alloc>::deallocate_request(intptr_t pool_id, void* raw_ptr, size_t raw_bytes) { in deallocate_request() 249 rml::MemPoolError res = rml::pool_create_v1(intptr_t(this), &args, &my_pool); in fixed_pool() 253 inline void *fixed_pool::allocate_request(intptr_t pool_id, size_t & bytes) { in allocate_request()
|
| H A D | scalable_allocator.h | 112 TBBMALLOC_EXPORT int __TBB_EXPORTED_FUNC scalable_allocation_mode(int param, intptr_t value); 138 typedef void *(*rawAllocType)(std::intptr_t pool_id, std::size_t &bytes); 140 typedef int (*rawFreeType)(std::intptr_t pool_id, void* raw_ptr, std::size_t raw_bytes); 182 TBBMALLOC_EXPORT MemPoolError pool_create_v1(std::intptr_t pool_id, const MemPoolPolicy *policy,
|
| H A D | task_scheduler_observer.h | 54 std::atomic<intptr_t> my_busy_count{ 0 };
|
| /oneTBB/test/tbbmalloc/ |
| H A D | test_malloc_pools.cpp | 67 static void *getMallocMem(intptr_t /*pool_id*/, size_t &bytes) in getMallocMem() argument 84 static int putMallocMem(intptr_t /*pool_id*/, void *ptr, size_t bytes) in putMallocMem() argument 203 void *CrossThreadGetMem(intptr_t pool_id, size_t &bytes) in CrossThreadGetMem() 332 static void *fixedBufGetMem(intptr_t pool_id, size_t &bytes) in fixedBufGetMem() 407 pool_create_v1((intptr_t)&head, &pol, &pool); in TestFixedBufferPool() 469 pool_create_v1((intptr_t)&head, &pol, &pool); in TestFixedBufferPool() 479 static void *getGranMem(intptr_t /*pool_id*/, size_t &bytes) in getGranMem() argument 485 static int putGranMem(intptr_t /*pool_id*/, void *ptr, size_t bytes) in putGranMem() argument 514 static void *getMemMalloc(intptr_t /*pool_id*/, size_t &bytes) in getMemMalloc() argument 523 static int putMemFree(intptr_t /*pool_id*/, void *ptr, size_t /*bytes*/) in putMemFree() argument [all …]
|
| H A D | test_malloc_compliance.cpp | 418 size_t words = size / sizeof(intptr_t); in NonZero() 419 size_t tailSz = size % sizeof(intptr_t); in NonZero() 420 intptr_t *buf =(intptr_t*)ptr; in NonZero() 425 for (unsigned b=0; b<sizeof(intptr_t); b++) in NonZero() 427 return sizeof(intptr_t)*i + b + 1; in NonZero() 431 return words*sizeof(intptr_t)+i+1; in NonZero() 450 size_t alignment = (sizeof(intptr_t)>4 && size>8) ? 16 : 8; in Tmalloc() 460 size_t alignment = (sizeof(intptr_t)>4 && num && size>8) ? 16 : 8; in Tcalloc() 470 size_t alignment = (sizeof(intptr_t)>4 && size>8) ? 16 : 8; in Trealloc()
|
| H A D | test_malloc_whitebox.cpp | 375 void *getMem(intptr_t /*pool_id*/, size_t &bytes) in getMem() argument 390 int putMem(intptr_t /*pool_id*/, void* /*raw_ptr*/, size_t /*raw_bytes*/) in putMem() argument 400 void *getMallocMem(intptr_t /*pool_id*/, size_t &bytes) in getMallocMem() argument 412 int putMallocMem(intptr_t /*pool_id*/, void *ptr, size_t bytes) in putMallocMem() argument 636 intptr_t data; 945 intptr_t threshold = cacheBinModel.ageThreshold.load(std::memory_order_relaxed); in doCleanup() 990 intptr_t hitRange = currTime - obj_age; in get() 991 intptr_t mean = cacheBinModel.meanHitRange.load(std::memory_order_relaxed); in get() 1041 static intptr_t tooLargeLOC; 1045 template<typename Props> intptr_t CacheBinModel<Props>::tooLargeLOC; [all …]
|
| H A D | test_scalable_allocator.cpp | 110 static void *fixedBufGetMem(intptr_t pool_id, size_t &bytes) in fixedBufGetMem() 153 rml::MemPoolError ret = pool_create_v1((intptr_t)&fixedPool, &pol, &pool); in TestSmallFixedSizePool()
|
| /oneTBB/include/oneapi/tbb/detail/ |
| H A D | _machine.h | 147 return 63 - static_cast<intptr_t>(x); in machine_log2() 150 return 31 - static_cast<intptr_t>(x); in machine_log2() 165 intptr_t result = 0; in machine_log2()
|