| /external/linux-kselftest/tools/testing/selftests/powerpc/math/ |
| vmx_signal.c | 32 * worker threads
99 int i, j, rc, threads; local
103 threads = sysconf(_SC_NPROCESSORS_ONLN) * THREAD_FACTOR;
104 tids = malloc(threads * sizeof(pthread_t));
108 threads_starting = threads;
109 for (i = 0; i < threads; i++) {
115 printf("\tWaiting for %d workers to start... %d", threads, threads_starting);
123 printf("\tSending signals to all threads %d times...", ITERATIONS);
125 for (j = 0; j < threads; j++) {
134 for (i = 0; i < threads; i++)
[all...] |
| vsx_preempt.c | 11 * uses many threads and a long wait. As such, a successful test
31 * worker threads
96 int i, rc, threads; local
99 threads = sysconf(_SC_NPROCESSORS_ONLN) * THREAD_FACTOR;
100 tids = malloc(threads * sizeof(pthread_t));
104 threads_starting = threads;
105 for (i = 0; i < threads; i++) {
127 for (i = 0; i < threads; i++) {
|
| /external/ltp/testcases/kernel/fs/fs_fill/ |
| fs_fill.c | 19 * Runs several threads that fills up the filesystem repeatedly.
78 pthread_t threads[nthreads]; local
83 SAFE_PTHREAD_CREATE(&threads[i], NULL, worker, &workers[i]);
97 SAFE_PTHREAD_JOIN(threads[i], NULL);
115 tst_res(TINFO, "Running %i writer threads", nthreads);
|
| /external/ltp/testcases/open_posix_testsuite/stress/threads/pthread_exit/ |
| stress.c | 20 * -> when the threads are joinable, pthread_join always retrieve the
22 * -> pthread_exit() frees all the resources used by the threads.
152 pthread_t threads[NSCENAR * SCALABILITY_FACTOR * FACTOR]; local
176 /* Create all the threads */
179 /* Skip the alternative stack threads */
184 pthread_create(&threads[i * NSCENAR + sc],
186 &threads[i * NSCENAR + sc]);
234 /* Join all the joinable threads and check the value */
241 pthread_join(threads
250 (void *)&threads[i * NSCENAR
[all...] |
| /external/testng/src/main/java/org/testng/internal/thread/ |
| ExecutorAdapter.java | 54 List<Thread> threads = m_threadFactory.getThreads(); local
55 int threadCount = threads.size();
58 result[i] = threads.get(i).getStackTrace();
|
| /external/valgrind/coregrind/ |
| pub_core_gdbserver.h | 202 // address of VG_(threads) and various sizes
204 Addr32 threads; member in struct:__anon42535
223 Addr64 threads; member in struct:__anon42536
|
| /external/valgrind/helgrind/tests/ |
| tls_threads.c | 18 /* ptr_to_badly_shared_local allows to have multiple threads seeing
59 pthread_t threads[NLEVEL2]; local
69 pthread_create(&threads[curthread++], NULL, level2, NULL);
73 pthread_join(threads[i], NULL);
81 pthread_t threads[NLEVEL1]; local
88 pthread_create(&threads[curthread++], NULL, level1, NULL);
94 pthread_join(threads[i], NULL);
|
| /libcore/luni/src/test/java/libcore/java/nio/charset/ |
| CharsetTest.java | 54 CheckerThread[] threads = new CheckerThread[10]; local
56 threads[i] = new CheckerThread((i % 2 == 0) ? "UTF-8" : "ISO-8859-1");
59 for (CheckerThread ct : threads) {
63 for (CheckerThread ct : threads) {
67 for (CheckerThread ct : threads) {
|
| /prebuilts/ndk/r16/sources/cxx-stl/llvm-libc++/utils/google-benchmark/src/ |
| benchmark_api_internal.h | 32 int threads; // Number of concurrent threads to us member in struct:benchmark::internal::Benchmark::Instance
|
| /system/core/debuggerd/client/ |
| debuggerd_client_test.cpp | 59 // Spawn a bunch of threads, to make crash_dump take longer.
60 std::vector<std::thread> threads; local
62 threads.emplace_back([]() {
80 // Wait for a bit to let the child spawn all of its threads.
|
| /system/core/libsync/ |
| sync_test.c | 79 pthread_t threads[4]; local
119 pthread_create(&threads[i], NULL, sync_thread, &sync_data[i]);
143 pthread_join(threads[i], &val);
|
| /system/core/libunwindstack/tests/ |
| MapInfoGetLoadBiasTest.cpp | 96 std::vector<std::thread*> threads; local
100 // Create all of the threads and have them do the GetLoadBias at the same time
108 threads.push_back(thread);
111 // Set them all going and wait for the threads to finish.
113 for (auto thread : threads) {
|
| /art/test/114-ParallelGC/src/ |
| Main.java | 38 Thread[] threads = new Thread[THREAD_COUNT]; local
40 // This barrier is used to synchronize the threads starting to allocate.
43 CyclicBarrier startBarrier = new CyclicBarrier(threads.length);
45 for (int i = 0; i < threads.length; i++) {
46 threads[i] = new Thread(new Main(startBarrier));
47 threads[i].start();
50 // Wait for the threads to finish.
51 for (Thread thread : threads) {
|
| /art/test/597-deopt-invoke-stub/src/ |
| Main.java | 35 final Thread[] threads = new Thread[numberOfThreads]; local
36 for (int t = 0; t < threads.length; t++) {
37 threads[t] = new Thread(new Main(t));
38 threads[t].start();
40 for (Thread t : threads) {
|
| /art/test/911-get-stack-trace/src/art/ |
| ThreadListTraces.java | 22 System.out.println("### Other select threads (suspended) ###");
30 Thread threads[] = new Thread[N]; local
41 threads[i] = t;
63 threads[i].join();
67 public static void printList(Thread[] threads, int max) {
68 PrintThread.printAll(getThreadListStackTraces(threads, max));
71 // Similar to getAllStackTraces, but restricted to the given threads.
72 public static native Object[][] getThreadListStackTraces(Thread threads[], int max);
|
| /art/test/931-agent-thread/ |
| agent_thread.cc | 75 jthread* threads; local
76 jvmtiError threads_result = jenv->GetAllThreads(&thread_count, &threads);
80 if (env->IsSameObject(threads[i], this_thread)) {
|
| /art/test/952-invoke-custom/src/ |
| TestInvokeCustomWithConcurrentThreads.java | 49 // Synchronization barrier all threads will wait on in the bootstrap method.
96 // Wait for all threads to be in this method.
112 // Run threads that each invoke-custom the call site
113 Thread[] threads = new Thread[NUMBER_OF_THREADS]; local
115 threads[i] = new Thread(new TestInvokeCustomWithConcurrentThreads());
116 threads[i].start();
119 // Wait for all threads to complete
121 threads[i].join();
140 System.out.println("Threads did not the same call-sites:");
|
| /bionic/tests/ |
| leak_test.cpp | 130 struct thread_data { pthread_barrier_t* barrier; pid_t* tid; } threads[kThreadCount] = {}; local
135 // Start child threads.
138 threads[i] = {&barrier, &tids[i]};
146 ASSERT_EQ(0, pthread_create(&thread, nullptr, thread_function, &threads[i]));
|
| /bionic/tools/versioner/src/ |
| Driver.cpp | 219 std::vector<std::thread> threads; local
221 threads.emplace_back([type, &vfs, &reqs]() {
231 for (auto& thread : threads) {
|
| /cts/tests/tests/content/src/android/content/cts/ |
| ContextMoreTest.java | 36 * Call it repeatedly from multiple threads, and:
49 // Run the threads until this becomes true.
86 // Create and start the threads...
87 final Thread[] threads = new Thread[NUM_THREADS]; local
89 threads[i] = new Thread(tester);
92 threads[i].start();
101 threads[i].join();
|
| /external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/ThreadReference/ |
| SuspendTest.java | 52 * <BR>At first the test starts SuspendDebuggee which starts and runs some tested threads.
53 * <BR>After the tested threads starts, the test for every tested thread does:
67 ("## FAILURE: Exception while getting number of started threads from debuggee = " + exception);
68 printErrorAndFail("Can NOT get number of started threads from debuggee! ");
71 logWriter.println("==> There are no started threads in debuggee to test!");
74 logWriter.println("==> Number of started threads in debuggee to test = " + testedThreadsNumber);
91 int threads = allThreadIDReply.getNextValueAsInt(); local
92 logWriter.println("==> Number of all threads in debuggee = " + threads);
98 for (int i = 0; i < threads; i++)
[all...] |
| /external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/VirtualMachine/ |
| AllThreadsTest.java | 73 int threads = reply.getNextValueAsInt(); local
74 logWriter.println("Number of threads = " + threads);
75 assertTrue("Number of threads must be > 0", threads > 0);
77 for (int i = 0; i < threads; i++) {
112 * all threads returned by command have only valid thread status:
132 int threads = reply.getNextValueAsInt(); local
133 logWriter.println("Number of threads = " + threads);
203 int threads = reply.getNextValueAsInt(); local
[all...] |
| /external/chromium-trace/catapult/systrace/atrace_helper/jni/ |
| atrace_process_dump.cc | 210 fprintf(out_, "\"threads\":{\n");
211 const auto threads = &process->threads; local
212 for (auto thread_it = threads->begin(); thread_it != threads->end();) {
217 if (++thread_it != threads->end())
|
| /external/compiler-rt/lib/sanitizer_common/tests/ |
| sanitizer_mutex_test.cc | 107 pthread_t threads[kThreads]; local
109 PTHREAD_CREATE(&threads[i], 0, lock_thread<SpinMutex>, &data);
111 PTHREAD_JOIN(threads[i], 0);
118 pthread_t threads[kThreads]; local
120 PTHREAD_CREATE(&threads[i], 0, try_thread<SpinMutex>, &data);
122 PTHREAD_JOIN(threads[i], 0);
129 pthread_t threads[kThreads]; local
131 PTHREAD_CREATE(&threads[i], 0, lock_thread<BlockingMutex>, &data);
133 PTHREAD_JOIN(threads[i], 0);
|
| /external/compiler-rt/lib/tsan/tests/unit/ |
| tsan_mutex_test.cc | 99 pthread_t threads[kThreads]; local
101 pthread_create(&threads[i], 0, write_mutex_thread<Mutex>, &data);
103 pthread_join(threads[i], 0);
109 pthread_t threads[kThreads]; local
111 pthread_create(&threads[i], 0, read_mutex_thread<Mutex>, &data);
113 pthread_join(threads[i], 0);
119 pthread_t threads[kThreads]; local
121 pthread_create(&threads[i], 0, write_mutex_thread<SpinMutex>, &data);
123 pthread_join(threads[i], 0);
|
