/aosp12/system/extras/memory_replay/tests/ |
H A D | ThreadsTest.cpp | 27 Threads threads(&pointers, 1); in TEST() local 40 threads.Finish(thread); in TEST() 48 Threads threads(&pointers, 1); in TEST() local 76 threads.Finish(thread1); in TEST() 80 threads.Finish(thread3); in TEST() 84 threads.Finish(thread2); in TEST() 91 Threads threads(&pointers, 1); in TEST() local 107 threads.WaitForAllToQuiesce(); in TEST() 113 threads.WaitForAllToQuiesce(); in TEST() 119 threads.Finish(thread); in TEST() [all …]
|
/aosp12/art/test/626-const-class-linking/src/ |
H A D | Main.java | 123 final Thread[] threads = new Thread[4]; in testRacyLoader() local 145 threads[i] = t; in testRacyLoader() 147 for (Thread t : threads) { in testRacyLoader() 157 final Thread[] threads = new Thread[4]; in testRacyLoader2() local 182 threads[i] = t; in testRacyLoader2() 184 for (Thread t : threads) { in testRacyLoader2() 194 final Thread[] threads = new Thread[4]; in testRacyMisbehavingLoader() local 217 threads[i] = t; in testRacyMisbehavingLoader() 219 for (Thread t : threads) { in testRacyMisbehavingLoader() 252 threads[i] = t; in testRacyMisbehavingLoader2() [all …]
|
/aosp12/bionic/tests/ |
H A D | threads_test.cpp | 31 #if __has_include(<threads.h>) 67 TEST(threads, call_once) { in TEST() argument 193 TEST(threads, cnd_timedwait) { in TEST() argument 223 TEST(threads, mtx_init) { in TEST() argument 237 TEST(threads, mtx_destroy) { in TEST() argument 247 TEST(threads, mtx_lock_plain) { in TEST() argument 278 TEST(threads, mtx_timedlock) { in TEST() argument 299 TEST(threads, mtx_unlock) { in TEST() argument 442 TEST(threads, thrd_yield) { in TEST() argument 458 TEST(threads, tss_create) { in TEST() argument [all …]
|
/aosp12/system/extras/libfec/ |
H A D | fec_process.cpp | 54 int threads = sysconf(_SC_NPROCESSORS_ONLN); in process() local 56 if (threads < WORK_MIN_THREADS) { in process() 57 threads = WORK_MIN_THREADS; in process() 58 } else if (threads > WORK_MAX_THREADS) { in process() 59 threads = WORK_MAX_THREADS; in process() 65 size_t count_per_thread = fec_div_round_up(blocks, threads) * FEC_BLOCKSIZE; in process() 68 if ((size_t)threads > max_threads) { in process() 69 threads = (int)max_threads; in process() 76 debug("%d threads, %zu bytes per thread (total %zu)", threads, in process() 80 process_info info[threads]; in process() [all …]
|
/aosp12/art/test/924-threads/ |
H A D | Android.bp | 3 // Build rules for ART run-test `924-threads`. 16 name: "art-run-test-924-threads", 21 ":art-run-test-924-threads-expected-stdout", 22 ":art-run-test-924-threads-expected-stderr", 28 name: "art-run-test-924-threads-expected-stdout", 29 out: ["art-run-test-924-threads-expected-stdout.txt"], 36 name: "art-run-test-924-threads-expected-stderr", 37 out: ["art-run-test-924-threads-expected-stderr.txt"],
|
/aosp12/system/extras/memory_replay/ |
H A D | main.cpp | 79 Threads threads(&pointers, max_threads); in ProcessDump() local 81 NativePrintf("Maximum threads available: %zu\n", threads.max_threads()); in ProcessDump() 93 Thread* thread = threads.FindThread(entry.tid); in ProcessDump() 95 thread = threads.CreateThread(entry.tid); in ProcessDump() 109 threads.WaitForAllToQuiesce(); in ProcessDump() 117 threads.Finish(thread); in ProcessDump() 128 threads.WaitForAllToQuiesce(); in ProcessDump() 135 threads.FinishAll(); in ProcessDump() 140 uint64_t total_nsecs = threads.total_time_nsecs(); in ProcessDump()
|
/aosp12/art/test/ti-agent/ |
H A D | suspension_helper.cc | 50 std::vector<jthread> threads(CopyToVector(env, thr)); in Java_art_Suspension_resumeList() local 54 jintArray ret = env->NewIntArray(threads.size()); in Java_art_Suspension_resumeList() 60 jvmti_env->ResumeThreadList(threads.size(), in Java_art_Suspension_resumeList() 61 threads.data(), in Java_art_Suspension_resumeList() 71 std::vector<jthread> threads(CopyToVector(env, thrs)); in Java_art_Suspension_suspendList() local 75 jintArray ret = env->NewIntArray(threads.size()); in Java_art_Suspension_suspendList() 81 jvmti_env->SuspendThreadList(threads.size(), in Java_art_Suspension_suspendList() 82 threads.data(), in Java_art_Suspension_suspendList()
|
/aosp12/frameworks/base/apct-tests/perftests/core/src/android/text/ |
H A D | StaticLayoutMultithreadPerfTest.java | 57 Thread[] threads = new Thread[numOfThreads]; in startBackgroundThread() local 60 threads[i] = new Thread(new Runnable() { in startBackgroundThread() 78 threads[i].start(); in startBackgroundThread() 86 return threads; in startBackgroundThread() 89 private void finishThreads(Thread[] threads) { in finishThreads() argument 91 for (Thread thread : threads) { in finishThreads() 105 Thread[] threads = startBackgroundThread(numOfTotalThreads - 1); in runRandomTest() local 116 finishThreads(threads); in runRandomTest()
|
/aosp12/system/extras/verity/fec/ |
H A D | image.cpp | 355 int threads = ctx->threads; in image_process() local 357 if (threads < IMAGE_MIN_THREADS) { in image_process() 360 if (threads < IMAGE_MIN_THREADS) { in image_process() 361 threads = IMAGE_MIN_THREADS; in image_process() 368 threads = (int)ctx->rounds; in image_process() 370 if (threads > IMAGE_MAX_THREADS) { in image_process() 371 threads = IMAGE_MAX_THREADS; in image_process() 379 pthread_t pthreads[threads]; in image_process() 380 image_proc_ctx args[threads]; in image_process() 391 for (int i = 0; i < threads; ++i) { in image_process() [all …]
|
/aosp12/art/test/911-get-stack-trace/src/art/ |
H A D | ThreadListTraces.java | 30 Thread threads[] = new Thread[N]; in doTest() local 41 threads[i] = t; in doTest() 63 threads[i].join(); in doTest() 67 public static void printList(Thread[] threads, int max) { in printList() argument 68 PrintThread.printAll(getThreadListStackTraces(threads, max)); in printList() 72 public static native Object[][] getThreadListStackTraces(Thread threads[], int max); in getThreadListStackTraces() argument
|
/aosp12/system/memory/libmemunreachable/tests/ |
H A D | ThreadCapture_test.cpp | 57 threads_.reserve(threads); in StartThreads() 58 tids_.reserve(threads); in StartThreads() 59 for (unsigned int i = 0; i < threads; i++) { in StartThreads() 60 threads_.emplace_back([&, threads, this]() { in StartThreads() 64 if (tids_.size() == threads) { in StartThreads() 144 const unsigned int threads = GetParam() - 1; in TEST_P() local 146 StartThreads(threads, []() {}); in TEST_P() 210 const unsigned int threads = GetParam(); in TEST_P() local 215 StartThreads(threads - 1, []() {}); in TEST_P() 232 ASSERT_EQ(threads, list_tids.size()); in TEST_P() [all …]
|
/aosp12/art/test/149-suspend-all-stress/src/ |
H A D | Main.java | 24 final Thread[] threads = new Thread[numberOfThreads]; in main() local 25 for (int t = 0; t < threads.length; t++) { in main() 26 threads[t] = new Thread(new Main()); in main() 27 threads[t].start(); in main() 29 for (Thread t : threads) { in main()
|
/aosp12/art/test/597-deopt-busy-loop/src/ |
H A D | SimpleLoop.java | 28 final Thread[] threads = new Thread[numberOfThreads]; in main() local 29 for (int t = 0; t < threads.length; t++) { in main() 30 threads[t] = new Thread(new SimpleLoop(t)); in main() 31 threads[t].start(); in main() 33 for (Thread t : threads) { in main()
|
H A D | SimdLoop.java | 31 final Thread[] threads = new Thread[numberOfThreads]; in main() local 32 for (int t = 0; t < threads.length; t++) { in main() 33 threads[t] = new Thread(new SimdLoop(t)); in main() 34 threads[t].start(); in main() 36 for (Thread t : threads) { in main()
|
H A D | FloatLoop.java | 30 final Thread[] threads = new Thread[numberOfThreads]; in main() local 31 for (int t = 0; t < threads.length; t++) { in main() 32 threads[t] = new Thread(new FloatLoop(t)); in main() 33 threads[t].start(); in main() 35 for (Thread t : threads) { in main()
|
/aosp12/art/test/051-thread/src/ |
H A D | Main.java | 43 TestCapacityThread[] threads = new TestCapacityThread[128]; in testThreadCapacity() local 44 for (int i = 0; i < threads.length; i++) { in testThreadCapacity() 45 threads[i] = new TestCapacityThread(); in testThreadCapacity() 48 for (TestCapacityThread thread : threads) { in testThreadCapacity() 51 for (TestCapacityThread thread : threads) { in testThreadCapacity() 168 Thread threads[] = new Thread[10]; in testMainThreadGroup() local 170 current.getThreadGroup().enumerate(threads); in testMainThreadGroup() 172 for (Thread t : threads) { in testMainThreadGroup() 178 throw new RuntimeException("Did not find main thread: " + Arrays.toString(threads)); in testMainThreadGroup()
|
/aosp12/art/test/2005-pause-all-redefine-multithreaded/ |
H A D | pause-all.cc | 43 std::vector<jthread> threads; in Java_art_Test2005_UpdateFieldValuesAndResumeThreads() local 45 threads.push_back(env->GetObjectArrayElement(threads_arr, i)); in Java_art_Test2005_UpdateFieldValuesAndResumeThreads() 79 if (!threads.empty()) { in Java_art_Test2005_UpdateFieldValuesAndResumeThreads() 80 std::vector<jvmtiError> errs(threads.size(), JVMTI_ERROR_NONE); in Java_art_Test2005_UpdateFieldValuesAndResumeThreads() 81 CHECK_EQ(jvmti_env->ResumeThreadList(threads.size(), threads.data(), errs.data()), in Java_art_Test2005_UpdateFieldValuesAndResumeThreads()
|
/aosp12/art/test/114-ParallelGC/src/ |
H A D | Main.java | 38 Thread[] threads = new Thread[THREAD_COUNT]; in main() local 43 CyclicBarrier startBarrier = new CyclicBarrier(threads.length); in main() 45 for (int i = 0; i < threads.length; i++) { in main() 46 threads[i] = new Thread(new Main(startBarrier)); in main() 47 threads[i].start(); in main() 51 for (Thread thread : threads) { in main()
|
/aosp12/art/test/597-deopt-invoke-stub/src/ |
H A D | Main.java | 35 final Thread[] threads = new Thread[numberOfThreads]; in main() local 36 for (int t = 0; t < threads.length; t++) { in main() 37 threads[t] = new Thread(new Main(t)); in main() 38 threads[t].start(); in main() 40 for (Thread t : threads) { in main()
|
/aosp12/art/test/597-deopt-new-string/src/ |
H A D | Main.java | 34 final Thread[] threads = new Thread[numberOfThreads]; in main() local 35 for (int t = 0; t < threads.length; t++) { in main() 36 threads[t] = new Thread(new Main(t)); in main() 37 threads[t].start(); in main() 39 for (Thread t : threads) { in main()
|
/aosp12/art/test/145-alloc-tracking-stress/src-art/ |
H A D | Main.java | 47 final Thread[] threads = new Thread[numberOfThreads]; in main() local 48 for (int t = 0; t < threads.length; t++) { in main() 49 threads[t] = new Thread(new Main(t)); in main() 50 threads[t].start(); in main() 52 for (Thread t : threads) { in main()
|
/aosp12/frameworks/native/services/powermanager/tests/ |
H A D | PowerHalControllerTest.cpp | 224 std::vector<std::thread> threads; in TEST_F() local 226 threads.push_back(std::thread([&]() { in TEST_F() 231 std::for_each(threads.begin(), threads.end(), [](std::thread& t) { t.join(); }); in TEST_F() 252 std::vector<std::thread> threads; in TEST_F() local 254 threads.push_back(std::thread([&]() { in TEST_F() 258 threads.push_back(std::thread([&]() { in TEST_F() 262 threads.push_back(std::thread([&]() { in TEST_F() 266 threads.push_back(std::thread([&]() { in TEST_F() 271 std::for_each(threads.begin(), threads.end(), [](std::thread& t) { t.join(); }); in TEST_F()
|
/aosp12/art/test/304-method-tracing/src/ |
H A D | Main.java | 31 ArrayList<Thread> threads = new ArrayList<Thread>(); in main() local 33 threads.add(new Thread(new ThreadRunnable(), "TestThread-" + i)); in main() 36 for (Thread t : threads) { in main() 40 for (Thread t : threads) { in main()
|
/aosp12/art/test/165-lock-owner-proxy/src/ |
H A D | Main.java | 36 final Thread[] threads = new Thread[numberOfThreads]; in main() local 37 for (int t = 0; t < threads.length; t++) { in main() 38 threads[t] = new Thread((t % 2 == 0) ? new ProxyRunner() : new SyncRunner()); in main() 40 for (Thread t : threads) { in main() 45 for (Thread t : threads) { in main()
|
/aosp12/art/test/129-ThreadGetId/src/ |
H A D | Main.java | 25 final Thread[] threads = new Thread[NUMBER_OF_THREADS]; in main() local 26 for (int t = 0; t < threads.length; t++) { in main() 27 threads[t] = new Thread(new Main()); in main() 28 threads[t].start(); in main() 30 for (Thread t : threads) { in main()
|