| /oneTBB/test/tbb/ |
| H A D | test_concurrent_queue.cpp | 28 static constexpr std::size_t MaxThread = 4; variable 61 TestPrimitiveTypes<tbb::concurrent_queue<char>, char>(MaxThread, (char)1); in TestQueueWorksWithPrimitiveTypes() 62 TestPrimitiveTypes<tbb::concurrent_queue<int>, int>(MaxThread, (int)-12); in TestQueueWorksWithPrimitiveTypes() 63 TestPrimitiveTypes<tbb::concurrent_queue<float>, float>(MaxThread, (float)-1.2f); in TestQueueWorksWithPrimitiveTypes() 64 TestPrimitiveTypes<tbb::concurrent_queue<double>, double>(MaxThread, (double)-4.3); in TestQueueWorksWithPrimitiveTypes() 65 TestPrimitiveTypes<tbb::concurrent_bounded_queue<char>, char>(MaxThread, (char)1); in TestQueueWorksWithPrimitiveTypes() 66 TestPrimitiveTypes<tbb::concurrent_bounded_queue<int>, int>(MaxThread, (int)-12); in TestQueueWorksWithPrimitiveTypes() 67 TestPrimitiveTypes<tbb::concurrent_bounded_queue<float>, float>(MaxThread, (float)-1.2f); in TestQueueWorksWithPrimitiveTypes() 68 TestPrimitiveTypes<tbb::concurrent_bounded_queue<double>, double>(MaxThread, (double)-4.3); in TestQueueWorksWithPrimitiveTypes()
|
| H A D | test_task_group.cpp | 35 unsigned MaxThread = 4; variable 767 for (unsigned p=MinThread; p <= MaxThread; ++p) { 781 for (unsigned p=MinThread; p <= MaxThread; ++p) { 791 for (unsigned p = MinThread; p <= MaxThread; ++p) { 804 for (unsigned p=MinThread; p <= MaxThread; ++p) { 814 for (unsigned p=MinThread; p <= MaxThread; ++p) { 835 for (unsigned p=MinThread; p <= MaxThread; ++p) { 849 for (unsigned p=MinThread; p <= MaxThread; ++p) { 859 for (unsigned p=MinThread; p <= MaxThread; ++p) { 869 for (unsigned p=MinThread; p <= MaxThread; ++p) { [all …]
|
| H A D | test_semaphore.cpp | 277 test_binary_semaphore(utils::MaxThread); 282 for (int sem_size = 1; sem_size <= int(utils::MaxThread); ++sem_size) { 283 for (int ex_threads = 0; ex_threads <= int(utils::MaxThread) - sem_size; ++ex_threads) {
|
| H A D | test_flow_graph.cpp | 301 for(unsigned int p=utils::MinThread; p<=utils::MaxThread; ++p ) { 314 for(unsigned int p=utils::MinThread; p<=utils::MaxThread; ++p ) { 327 for(unsigned int p=utils::MinThread; p<=utils::MaxThread; ++p ) {
|
| H A D | test_tbb_fork.cpp | 26 static const int MaxThread = 4; variable 267 for (int threads=MinThread; threads<=MaxThread; threads+=MinThread) { in main()
|
| H A D | test_concurrent_queue_whitebox.cpp | 81 …utils::NativeParallelFor(static_cast<typename Q::value_type>(utils::MaxThread), FloggerBody<Q>(q, … in test_flogger_help()
|
| H A D | test_enumerable_thread_specific.cpp | 47 static int MaxThread = 4; variable 132 for (int p = MinThread; p <= MaxThread; ++p) { in flog_key_creation_and_deletion()
|
| H A D | test_concurrent_priority_queue.cpp | 81 for (std::size_t n = utils::MinThread; n != utils::MaxThread; ++n) { in test_multithreading()
|
| H A D | test_openmp.cpp | 164 for (int p = static_cast<int>(utils::MinThread); p <= static_cast<int>(utils::MaxThread); ++p) {
|
| H A D | test_overwrite_node.cpp | 196 for( unsigned int p=utils::MinThread; p<=utils::MaxThread; ++p ) {
|
| H A D | test_write_once_node.cpp | 220 for( unsigned int p=utils::MinThread; p<=utils::MaxThread; ++p ) {
|
| H A D | test_broadcast_node.cpp | 255 for( unsigned int p=utils::MinThread; p<=utils::MaxThread; ++p ) {
|
| H A D | test_function_node.cpp | 372 for (unsigned p = 1; p < 2*utils::MaxThread; ++p) { in unlimited_concurrency() 476 for(unsigned int p = utils::MinThread; p <= utils::MaxThread; ++p ) {
|
| H A D | test_input_node.cpp | 295 for ( unsigned int p = utils::MinThread; p < utils::MaxThread; ++p ) {
|
| H A D | test_multifunction_node.cpp | 360 for (unsigned int p = 1; p < 2*utils::MaxThread; ++p) { in unlimited_concurrency() 532 for( unsigned int p=utils::MinThread; p<=utils::MaxThread; ++p ) {
|
| H A D | test_parallel_for.cpp | 400 for ( int p = MinThread; p <= MaxThread; ++p ) {
|
| H A D | test_continue_node.cpp | 360 for( unsigned p=utils::MinThread; p<=utils::MaxThread; ++p ) {
|
| /oneTBB/test/tbbmalloc/ |
| H A D | test_malloc_init_shutdown.cpp | 29 static constexpr std::size_t MaxThread = 4; variable 51 std::size_t NTasks = utils::min(MaxTasks, utils::max(std::size_t(2), MaxThread)); in Test1()
|
| H A D | test_malloc_pools.cpp | 179 void **crossThread = new void*[utils::MaxThread * SharedPoolRun::OBJ_CNT]; in TestSharedPool() 180 void **afterTerm = new void*[utils::MaxThread * SharedPoolRun::OBJ_CNT]; in TestSharedPool() 182 for (int p=utils::MinThread; p<=utils::MaxThread; p++) { in TestSharedPool() 282 for (int p=utils::MinThread; p<=utils::MaxThread; p++) { in TestCrossThreadPools() 422 for (int p=utils::MinThread; p<=utils::MaxThread; p++) { in TestFixedBufferPool() 816 for (int p=utils::MinThread; p<=utils::MaxThread; p++) { in TestNoLeakOnDestroy()
|
| H A D | test_malloc_whitebox.cpp | 77 static const int MaxThread = 4; variable 176 for( int p=MaxThread; p>=MinThread; --p ) { in TestLargeObjectCache() 343 for( int p=MaxThread; p>=MinThread; --p ) in TestBackRef() 367 TestInvalidBackrefs::initBarrier(MaxThread); in TestBackRef() 368 utils::NativeParallelFor( MaxThread, TestInvalidBackrefs() ); in TestBackRef() 372 utils::NativeParallelFor( MaxThread, BackRefWork<0>() ); in TestBackRef() 499 for( int p=MaxThread; p>=MinThread; --p ) in TestPools() 670 for( int p=MaxThread; p>=MinThread; --p ) { in TestBackend() 791 for( int p=MaxThread; p>=MinThread; --p ) { in TestHeapLimit() 1662 for( int p=MaxThread; p>=MinThread; --p ) {
|
| H A D | test_malloc_compliance.cpp | 113 static const int MaxThread = 4; variable 1083 for( int p=MaxThread; p>=MinThread; --p ) {
|
| /oneTBB/test/conformance/ |
| H A D | conformance_combinable.cpp | 43 const int MaxThread = 4; variable 181 for (int p = MinThread; p <= MaxThread; ++p) { in RunParallelScalarTests() 277 for (int p = MinThread; p <= MaxThread; ++p) { in RunParallelVectorTests() 468 for(int i = 1 <= MinThread ? MinThread : 1; i <= MaxThread; ++i) { in RunLocalAllocationsTests()
|
| H A D | conformance_enumerable_thread_specific.cpp | 62 static int MaxThread = 4; variable 341 for (int p = std::max(MinThread, 2); p <= MaxThread; ++p) { in run_parallel_scalar_tests_nocombine() 511 for (int p = std::max(MinThread, 2); p <= MaxThread; ++p) { in run_parallel_scalar_tests() 640 for (int p = std::max(MinThread, 2); p <= MaxThread; ++p) { in run_parallel_vector_tests() 725 for (int p = std::max(MinThread, 2); p <= MaxThread; ++p) { in run_cross_type_vector_tests()
|
| H A D | conformance_concurrent_queue.cpp | 36 static constexpr std::size_t MaxThread = 4; variable 753 for (std::size_t nthread = MinThread; nthread <= MaxThread; ++nthread) { in TestConcurrentPushPop() 987 for (std::size_t nthreads = MinThread; nthreads <= MaxThread; ++nthreads) { in TestAbort() 1000 if (nthreads < (MaxThread + MinThread) / 2) { in TestAbort()
|
| /oneTBB/test/common/ |
| H A D | rwm_upgrade_downgrade.h | 59 for (auto p = utils::MinThread; p <= utils::MaxThread; ++p) { in test_rwm_upgrade_downgrade()
|