Home
last modified time | relevance | path

Searched refs:kThreadCount (Results 1 – 25 of 30) sorted by relevance

12

/external/angle/src/libANGLE/
DContextMutex_unittest.cpp19 constexpr size_t kThreadCount = 16; in runBasicContextMutexTest() local
22 std::array<std::thread, kThreadCount> threads; in runBasicContextMutexTest()
23 std::array<egl::ContextMutex *, kThreadCount> contextMutexes = {}; in runBasicContextMutexTest()
31 for (size_t i = 0; i < kThreadCount; ++i) in runBasicContextMutexTest()
39 if (readyCount < kThreadCount) in runBasicContextMutexTest()
41 condVar.wait(lock, [&]() { return readyCount == kThreadCount; }); in runBasicContextMutexTest()
58 for (size_t i = 0; i < kThreadCount; ++i) in runBasicContextMutexTest()
66 EXPECT_EQ(testVar.load(), kThreadCount * kIterationCount); in runBasicContextMutexTest()
70 EXPECT_LE(testVar.load(), kThreadCount * kIterationCount); in runBasicContextMutexTest()
107 constexpr size_t kThreadCount = 2; in TEST() local
[all …]
DGlobalMutex_unittest.cpp19 constexpr size_t kThreadCount = 16; in runBasicGlobalMutexTest() local
22 std::array<std::thread, kThreadCount> threads; in runBasicGlobalMutexTest()
30 for (size_t i = 0; i < kThreadCount; ++i) in runBasicGlobalMutexTest()
36 if (readyCount < kThreadCount) in runBasicGlobalMutexTest()
38 condVar.wait(lock, [&]() { return readyCount == kThreadCount; }); in runBasicGlobalMutexTest()
55 for (size_t i = 0; i < kThreadCount; ++i) in runBasicGlobalMutexTest()
62 EXPECT_EQ(testVar.load(), kThreadCount * kIterationCount); in runBasicGlobalMutexTest()
66 EXPECT_LE(testVar.load(), kThreadCount * kIterationCount); in runBasicGlobalMutexTest()
DResourceMap_unittest.cpp210 constexpr size_t kThreadCount = 13; in ConcurrentAccess() local
214 std::array<std::thread, kThreadCount> threads; in ConcurrentAccess()
215 std::array<std::map<LockedType, size_t>, kThreadCount> insertedIds; in ConcurrentAccess()
217 for (size_t i = 0; i < kThreadCount; ++i) in ConcurrentAccess()
224 const LockedType id = (j % (idCycleSize / kThreadCount)) * kThreadCount + i; in ConcurrentAccess()
268 for (size_t i = 0; i < kThreadCount; ++i) in ConcurrentAccess()
277 for (size_t i = 0; i < kThreadCount; ++i) in ConcurrentAccess()
/external/angle/src/common/
DSimpleMutex_unittest.cpp21 constexpr size_t kThreadCount = 16; in runBasicMutexTest() local
24 std::array<std::thread, kThreadCount> threads; in runBasicMutexTest()
33 for (size_t i = 0; i < kThreadCount; ++i) in runBasicMutexTest()
41 if (readyCount < kThreadCount) in runBasicMutexTest()
43 condVar.wait(lock, [&]() { return readyCount == kThreadCount; }); in runBasicMutexTest()
60 for (size_t i = 0; i < kThreadCount; ++i) in runBasicMutexTest()
65 const bool passed = testVar.load() == kThreadCount * kIterationCount; in runBasicMutexTest()
Dsystem_utils_unittest.cpp452 constexpr size_t kThreadCount = 64; in TEST() local
461 for (size_t i = 0; i < kThreadCount; ++i) in TEST()
475 if (readyCount < kThreadCount) in TEST()
477 condVar.wait(lock, [&]() { return readyCount == kThreadCount; }); in TEST()
489 for (size_t i = 0; i < kThreadCount; ++i) in TEST()
495 EXPECT_EQ(threadIds.size(), kThreadCount); in TEST()
/external/compiler-rt/lib/sanitizer_common/tests/
Dsanitizer_stoptheworld_test.cc92 static const uptr kThreadCount = 50; variable
99 volatile int counters[kThreadCount];
100 pthread_t thread_ids[kThreadCount];
118 if (this_thread_index + 1 < kThreadCount) { in AdvancedIncrementerThread()
127 kThreadCount - callback_argument->thread_index); in AdvancedIncrementerThread()
148 int counters_at_init[kThreadCount]; in AdvancedCallback()
149 for (uptr j = 0; j < kThreadCount; j++) in AdvancedCallback()
154 for (uptr j = 0; j < kThreadCount; j++) in AdvancedCallback()
182 while (__sync_fetch_and_add(&argument.thread_index, 0) < kThreadCount) in TEST()
187 for (uptr i = 0; i < kThreadCount; i++) in TEST()
Dsanitizer_linux_test.cc67 for (uptr i = 0; i < kThreadCount; i++) { in SetUp()
85 static const uptr kThreadCount = 20; member in __sanitizer::ThreadListerTest
/external/cronet/tot/third_party/googletest/src/googletest/test/
Dgtest_stress_test.cc55 const int kThreadCount = 50; variable
86 for (int i = 0; i < kThreadCount; i++) { in ManyAsserts()
121 std::unique_ptr<ThreadWithParam<int> > threads[kThreadCount]; in TEST()
123 for (int i = 0; i != kThreadCount; i++) in TEST()
130 for (int i = 0; i != kThreadCount; i++) threads[i]->Join(); in TEST()
143 EXPECT_EQ(kThreadCount * 2 + 1, result->test_property_count()) in TEST()
146 for (int i = 0; i < kThreadCount; ++i) { in TEST()
150 CheckTestFailureCount(kThreadCount * kThreadCount); in TEST()
/external/rust/android-crates-io/crates/quiche/deps/boringssl/src/third_party/googletest/test/
Dgtest_stress_test.cc54 const int kThreadCount = 50; variable
86 for (int i = 0; i < kThreadCount; i++) { in ManyAsserts()
121 std::unique_ptr<ThreadWithParam<int> > threads[kThreadCount]; in TEST()
123 for (int i = 0; i != kThreadCount; i++) in TEST()
131 for (int i = 0; i != kThreadCount; i++) in TEST()
145 EXPECT_EQ(kThreadCount * 2 + 1, result->test_property_count()) in TEST()
148 for (int i = 0; i < kThreadCount; ++i) { in TEST()
152 CheckTestFailureCount(kThreadCount*kThreadCount); in TEST()
/external/cronet/stable/third_party/boringssl/src/third_party/googletest/googletest/test/
Dgtest_stress_test.cc55 const int kThreadCount = 50; variable
86 for (int i = 0; i < kThreadCount; i++) { in ManyAsserts()
121 std::unique_ptr<ThreadWithParam<int> > threads[kThreadCount]; in TEST()
123 for (int i = 0; i != kThreadCount; i++) in TEST()
130 for (int i = 0; i != kThreadCount; i++) threads[i]->Join(); in TEST()
143 EXPECT_EQ(kThreadCount * 2 + 1, result->test_property_count()) in TEST()
146 for (int i = 0; i < kThreadCount; ++i) { in TEST()
150 CheckTestFailureCount(kThreadCount * kThreadCount); in TEST()
Dgoogletest-port-test.cc1101 const int kThreadCount = 7; in TEST() local
1102 std::unique_ptr<ThreadType> counting_threads[kThreadCount]; in TEST()
1106 for (int i = 0; i < kThreadCount; ++i) { in TEST()
1112 for (int i = 0; i < kThreadCount; ++i) counting_threads[i]->Join(); in TEST()
1118 EXPECT_EQ(kCycleCount * kThreadCount, locked_counter.value()); in TEST()
/external/googletest/googletest/test/
Dgtest_stress_test.cc55 const int kThreadCount = 50; variable
86 for (int i = 0; i < kThreadCount; i++) { in ManyAsserts()
121 std::unique_ptr<ThreadWithParam<int> > threads[kThreadCount]; in TEST()
123 for (int i = 0; i != kThreadCount; i++) in TEST()
130 for (int i = 0; i != kThreadCount; i++) threads[i]->Join(); in TEST()
143 EXPECT_EQ(kThreadCount * 2 + 1, result->test_property_count()) in TEST()
146 for (int i = 0; i < kThreadCount; ++i) { in TEST()
150 CheckTestFailureCount(kThreadCount * kThreadCount); in TEST()
/external/cronet/tot/third_party/boringssl/src/third_party/googletest/googletest/test/
Dgtest_stress_test.cc55 const int kThreadCount = 50; variable
86 for (int i = 0; i < kThreadCount; i++) { in ManyAsserts()
121 std::unique_ptr<ThreadWithParam<int> > threads[kThreadCount]; in TEST()
123 for (int i = 0; i != kThreadCount; i++) in TEST()
130 for (int i = 0; i != kThreadCount; i++) threads[i]->Join(); in TEST()
143 EXPECT_EQ(kThreadCount * 2 + 1, result->test_property_count()) in TEST()
146 for (int i = 0; i < kThreadCount; ++i) { in TEST()
150 CheckTestFailureCount(kThreadCount * kThreadCount); in TEST()
Dgoogletest-port-test.cc1101 const int kThreadCount = 7; in TEST() local
1102 std::unique_ptr<ThreadType> counting_threads[kThreadCount]; in TEST()
1106 for (int i = 0; i < kThreadCount; ++i) { in TEST()
1112 for (int i = 0; i < kThreadCount; ++i) counting_threads[i]->Join(); in TEST()
1118 EXPECT_EQ(kCycleCount * kThreadCount, locked_counter.value()); in TEST()
/external/cronet/stable/third_party/googletest/src/googletest/test/
Dgtest_stress_test.cc55 const int kThreadCount = 50; variable
86 for (int i = 0; i < kThreadCount; i++) { in ManyAsserts()
121 std::unique_ptr<ThreadWithParam<int> > threads[kThreadCount]; in TEST()
123 for (int i = 0; i != kThreadCount; i++) in TEST()
130 for (int i = 0; i != kThreadCount; i++) threads[i]->Join(); in TEST()
143 EXPECT_EQ(kThreadCount * 2 + 1, result->test_property_count()) in TEST()
146 for (int i = 0; i < kThreadCount; ++i) { in TEST()
150 CheckTestFailureCount(kThreadCount * kThreadCount); in TEST()
/external/cronet/stable/base/synchronization/
Dcondition_variable_unittest.cc249 const int kThreadCount = 10; in TEST_F() local
250 WorkQueue queue(kThreadCount); // Start the threads. in TEST_F()
389 queue.ThreadSafeCheckShutdown(kThreadCount)); in TEST_F()
393 const int kThreadCount = 200; in TEST_F() local
394 WorkQueue queue(kThreadCount); // Start the threads. in TEST_F()
421 queue.SetTaskCount(20 * kThreadCount); in TEST_F()
440 EXPECT_EQ(kThreadCount, queue.GetNumThreadsTakingAssignments()); in TEST_F()
441 EXPECT_EQ(kThreadCount, queue.GetNumThreadsCompletingTasks()); in TEST_F()
444 EXPECT_EQ(20 * kThreadCount, queue.GetNumberOfCompletedTasks()); in TEST_F()
448 queue.SetTaskCount(kThreadCount * 4); in TEST_F()
[all …]
/external/cronet/tot/base/synchronization/
Dcondition_variable_unittest.cc249 const int kThreadCount = 10; in TEST_F() local
250 WorkQueue queue(kThreadCount); // Start the threads. in TEST_F()
389 queue.ThreadSafeCheckShutdown(kThreadCount)); in TEST_F()
393 const int kThreadCount = 200; in TEST_F() local
394 WorkQueue queue(kThreadCount); // Start the threads. in TEST_F()
421 queue.SetTaskCount(20 * kThreadCount); in TEST_F()
440 EXPECT_EQ(kThreadCount, queue.GetNumThreadsTakingAssignments()); in TEST_F()
441 EXPECT_EQ(kThreadCount, queue.GetNumThreadsCompletingTasks()); in TEST_F()
444 EXPECT_EQ(20 * kThreadCount, queue.GetNumberOfCompletedTasks()); in TEST_F()
448 queue.SetTaskCount(kThreadCount * 4); in TEST_F()
[all …]
/external/libchrome/base/synchronization/
Dcondition_variable_unittest.cc258 const int kThreadCount = 10; in TEST_F() local
259 WorkQueue queue(kThreadCount); // Start the threads. in TEST_F()
398 queue.ThreadSafeCheckShutdown(kThreadCount)); in TEST_F()
408 const int kThreadCount = 200; in TEST_F() local
409 WorkQueue queue(kThreadCount); // Start the threads. in TEST_F()
436 queue.SetTaskCount(20 * kThreadCount); in TEST_F()
455 EXPECT_EQ(kThreadCount, queue.GetNumThreadsTakingAssignments()); in TEST_F()
456 EXPECT_EQ(kThreadCount, queue.GetNumThreadsCompletingTasks()); in TEST_F()
459 EXPECT_EQ(20 * kThreadCount, queue.GetNumberOfCompletedTasks()); in TEST_F()
463 queue.SetTaskCount(kThreadCount * 4); in TEST_F()
[all …]
/external/federated-compute/fcp/tracing/test/
Dthread_local_tracing_recorder_test.cc90 const int kThreadCount = 2; in TEST() local
91 auto scheduler = CreateThreadPoolScheduler(kThreadCount); in TEST()
93 for (int i = 0; i < kThreadCount; i++) { in TEST()
109 for (int i = 0; i < kThreadCount; i++) { in TEST()
/external/compiler-rt/lib/tsan/tests/rtl/
Dtsan_mutex.cc179 const int kThreadCount = 8; in TEST() local
193 pthread_t threads[kThreadCount]; in TEST()
194 for (int t = 0; t < kThreadCount; t++) in TEST()
196 for (int t = 0; t < kThreadCount; t++) in TEST()
/external/skia/tests/
DSkStrikeTest.cpp112 static constexpr int kThreadCount = 4; in DEF_TEST() local
114 Barrier barrier{kThreadCount}; in DEF_TEST()
138 auto executor = SkExecutor::MakeFIFOThreadPool(kThreadCount); in DEF_TEST()
146 auto local = data.subspan(threadIndex * 2, data.size() - kThreadCount * 2); in DEF_TEST()
171 SkTaskGroup(*executor).batch(kThreadCount, perThread); in DEF_TEST()
/external/pytorch/aten/src/ATen/native/cuda/cutlass_extensions/gemm/warp/
Dmma_tensorop_compute_B_with_f16.h162 static int const kThreadCount = 32; variable
175 kThreadCount,
192 kThreadCount,
/external/angle/src/tests/gl_tests/
DMultithreadingTest.cpp205 constexpr size_t kThreadCount = 16; in TEST_P() local
206 std::array<std::thread, kThreadCount> threads; in TEST_P()
501 constexpr size_t kThreadCount = 16; in TEST_P() local
503 std::vector<std::thread> threads(kThreadCount); in TEST_P()
504 std::vector<EGLContext> contexts(kThreadCount); in TEST_P()
505 for (size_t threadIdx = 0; threadIdx < kThreadCount; threadIdx++) in TEST_P()
516 while (barrier < kThreadCount) in TEST_P()
2137 constexpr size_t kThreadCount = 2; in TEST_P() local
2138 EGLSurface surface[kThreadCount] = {EGL_NO_SURFACE, EGL_NO_SURFACE}; in TEST_P()
2139 EGLContext ctx[kThreadCount] = {EGL_NO_CONTEXT, EGL_NO_CONTEXT}; in TEST_P()
[all …]
/external/angle/src/tests/egl_tests/
DEGLContextSharingTest.cpp602 constexpr size_t kThreadCount = 2; in TEST_P() local
603 EGLSurface surface[kThreadCount] = {EGL_NO_SURFACE, EGL_NO_SURFACE}; in TEST_P()
604 EGLContext ctx[kThreadCount] = {EGL_NO_CONTEXT, EGL_NO_CONTEXT}; in TEST_P()
608 for (size_t t = 0; t < kThreadCount; ++t) in TEST_P()
633 GLRenderbuffer renderbuffer[kThreadCount]; in TEST_P()
634 GLFramebuffer fbo[kThreadCount]; in TEST_P()
635 GLProgram program[kThreadCount]; in TEST_P()
637 for (size_t t = 0; t < kThreadCount; ++t) in TEST_P()
765 for (size_t t = 0; t < kThreadCount; ++t) in TEST_P()
1435 constexpr size_t kThreadCount = 2; in TEST_P() local
[all …]
DEGLMultiContextTest.cpp198 constexpr size_t kThreadCount = 2; in TEST_P() local
199 EGLSurface surface[kThreadCount] = {EGL_NO_SURFACE, EGL_NO_SURFACE}; in TEST_P()
200 EGLContext ctx[kThreadCount] = {EGL_NO_CONTEXT, EGL_NO_CONTEXT}; in TEST_P()
204 for (size_t t = 0; t < kThreadCount; ++t) in TEST_P()
340 for (size_t t = 0; t < kThreadCount; ++t) in TEST_P()

12