// Copyright 2009-2021 Intel Corporation // SPDX-License-Identifier: Apache-2.0 #include "alloc.h" #include "../../common/sys/thread.h" namespace embree { __thread FastAllocator::ThreadLocal2* FastAllocator::thread_local_allocator2 = nullptr; SpinLock FastAllocator::s_thread_local_allocators_lock; std::vector> FastAllocator::s_thread_local_allocators; struct fast_allocator_regression_test : public RegressionTest { BarrierSys barrier; std::atomic numFailed; std::unique_ptr alloc; fast_allocator_regression_test() : RegressionTest("fast_allocator_regression_test"), numFailed(0) { registerRegressionTest(this); } static void thread_alloc(fast_allocator_regression_test* This) { FastAllocator::CachedAllocator threadalloc = This->alloc->getCachedAllocator(); size_t* ptrs[1000]; for (size_t j=0; j<1000; j++) { This->barrier.wait(); for (size_t i=0; i<1000; i++) { ptrs[i] = (size_t*) threadalloc.malloc0(sizeof(size_t)+(i%32)); *ptrs[i] = size_t(threadalloc.talloc0) + i; } for (size_t i=0; i<1000; i++) { if (*ptrs[i] != size_t(threadalloc.talloc0) + i) This->numFailed++; } This->barrier.wait(); } } bool run () { alloc = make_unique(new FastAllocator(nullptr,false)); numFailed.store(0); size_t numThreads = getNumberOfLogicalThreads(); barrier.init(numThreads+1); /* create threads */ std::vector threads; for (size_t i=0; ireset(); barrier.wait(); barrier.wait(); } /* destroy threads */ for (size_t i=0; i