| /libcore/luni/src/test/java/libcore/java/net/ |
| ConcurrentCloseTest.java | 122 // We want to test that we unblock *all* the threads blocked on a socket, not just one.
126 final ArrayList<Thread> threads = new ArrayList<Thread>(); local
144 threads.add(t);
146 for (Thread t : threads) {
150 for (Thread t : threads) {
|
| /system/core/debuggerd/ |
| crash_dump.cpp | 379 // Note: processes with many threads and minidebug-info can take a bit to
394 // the threads, fetch their registers and associated information, and then
396 std::set<pid_t> threads; local
397 if (!android::procinfo::GetProcessTids(g_target_thread, &threads)) {
398 PLOG(FATAL) << "failed to get process threads";
407 for (pid_t thread : threads) {
471 // Detach from all of our attached threads before resuming.
|
| /system/core/libsync/tests/ |
| sync_test.cpp | 492 // Use a single timeline to synchronize two threads
516 // make sure the threads did not trample on one another.
528 vector<thread> threads; local
531 // Producer threads run this lambda.
558 threads.push_back(thread{threadMain, i});
583 // Release the producer threads.
587 for_each(begin(threads), end(threads), [](thread& thread) { thread.join(); });
|
| /system/extras/simpleperf/ |
| thread_tree.cpp | 88 // Share maps among threads in the same thread group.
342 std::vector<const ThreadEntry*> threads; local
344 threads.push_back(pair.second.get());
346 return threads;
|
| cmd_report_sample.cpp | 492 // For the main thread, the call chain ends at __libc_init in libc.so. For other threads,
581 std::vector<const ThreadEntry*> threads = thread_tree_.GetAllThreads(); local
585 std::sort(threads.begin(), threads.end(), compare_thread_id);
586 for (auto& thread : threads) {
|
| /system/extras/tests/memtest/ |
| bandwidth.cpp | 202 // all of the threads are running at this point.
259 pthread_t threads[num_threads]; local
265 rc = pthread_create(&threads[i], NULL, runBandwidthThread,
273 // Kick start the threads.
276 // Let the threads run.
279 // Stop the threads.
282 // Wait for the threads to complete.
284 rc = pthread_join(threads[i], NULL);
359 printf("Running %d threads\n", num_threads);
|
| /external/emma/core/java12/com/vladium/emma/rt/ |
| AppRunner.java | 840 final List threads = new ArrayList (); local
843 threads.clear ();
[all...] |
| /external/icu/icu4j/main/tests/core/src/com/ibm/icu/dev/test/rbbi/ |
| RBBITest.java | 407 List<Thread> threads = new ArrayList<Thread>(); local
409 threads.add(new Thread(new WorkerThread()));
411 for (Thread thread: threads) {
414 for (Thread thread: threads) {
422 // JUnit wont see failures from within the worker threads, so
|
| /libcore/ojluni/src/main/java/sun/nio/ch/ |
| FileChannelImpl.java | 88 // Thread-safe set of IDs of native threads, for signalling
89 private final NativeThreadSet threads = new NativeThreadSet(2); field in class:FileChannelImpl
153 // signal any threads blocked on this channel
154 threads.signalAndWait();
190 ti = threads.add();
198 threads.remove(ti);
218 ti = threads.add();
226 threads.remove(ti);
242 ti = threads.add();
250 threads.remove(ti)
[all...] |
| /bionic/tools/versioner/src/ |
| versioner.cpp | 195 std::vector<std::thread> threads; local
240 // Spawn threads.
242 threads.emplace_back([&jobs, &job_index, &result, vfs]() {
256 for (auto& thread : threads) {
259 threads.clear();
484 fprintf(stderr, " -j THREADS\tmaximum number of threads to use\n");
|
| /external/ImageMagick/MagickCore/ |
| distribute-cache.c | 908 threads;
992 status=pthread_create(&threads,&attributes,DistributePixelCacheClient,
903 threads; local
[all...] |
| /external/deqp/framework/delibs/dethread/ |
| deThreadTest.c | 274 /* Mutex and threads. */
302 deThread threads[2]; local
314 for (ndx = 0; ndx < (int)DE_LENGTH_OF_ARRAY(threads); ndx++)
316 threads[ndx] = deThread_create(mutexTestThr2, &data, DE_NULL);
317 DE_TEST_ASSERT(threads[ndx]);
322 for (ndx = 0; ndx < (int)DE_LENGTH_OF_ARRAY(threads); ndx++)
324 deBool ret = deThread_join(threads[ndx]);
326 deThread_destroy(threads[ndx]);
630 deThreadArray* threads = tmpPool ? deThreadArray_create(tmpPool) : DE_NULL; local
639 DE_TEST_ASSERT(deThreadArray_pushBack(threads, thread))
[all...] |
| /external/eigen/Eigen/src/Core/products/ |
| GeneralMatrixMatrix.h | 87 int threads = omp_get_num_threads(); local
109 // Then, we set info[tid].users to the number of threads to mark that all other threads are going to use it.
111 info[tid].users += threads;
115 // Notify the other threads that the part A'_i is ready to go.
119 for(int shift=0; shift<threads; ++shift)
121 int i = (tid+shift)%threads;
148 for(Index i=0; i<threads; ++i)
|
| /external/google-breakpad/src/processor/ |
| minidump_processor.cc | 135 MinidumpThreadList *threads = dump->GetThreadList(); local
136 if (!threads) {
147 (threads != NULL ? "" : "no ") << "thread list, " <<
154 unsigned int thread_count = threads->thread_count();
167 MinidumpThread *thread = threads->GetThreadAtIndex(thread_index);
201 // might be greater than the thread index in the threads vector if
202 // any of the minidump's threads are skipped and not placed into the
203 // processed threads vector. The thread vector's current size will
262 // Threads with missing CPU contexts will hit this, but
[all...] |
| /external/guava/guava-tests/test/com/google/common/base/ |
| SuppliersTest.java | 269 final Thread[] threads = new Thread[numThreads]; local
286 for (Thread thread : threads) {
302 "timed out waiting for other threads to block" +
316 threads[i] = new Thread() {
322 for (Thread t : threads) {
325 for (Thread t : threads) {
352 Thread[] threads = new Thread[numThreads]; local
354 threads[i] = new Thread() {
362 for (Thread t : threads) {
365 for (Thread t : threads) {
[all...] |
| /external/libevent/test/ |
| regress_thread.c | 131 /* exit the loop only if all threads fired all timeouts */
169 THREAD_T threads[NUM_THREADS]; local
229 THREAD_START(threads[i], basic_thread, base);
239 THREAD_JOIN(threads[i]);
294 THREAD_T threads[NUM_THREADS]; local
318 /* Threads 5 and 6 will be allowed to time out */
327 /* Launch the threads... */
329 THREAD_START(threads[i], wait_for_condition, &alerted[i]);
339 /* And wait till the threads are done. */
341 THREAD_JOIN(threads[i])
[all...] |
| /external/ltp/testcases/realtime/func/rt-migrate/ |
| rt-migrate.c | 28 * - Creates N+1 threads with lower real time priorities.
185 "-a priority Priority of the threads"
186 "-r time Run time (ms) to busy loop the threads (20)\n"
397 pthread_t *threads; local
428 threads = malloc(sizeof(*threads) * nr_tasks);
429 if (!threads)
431 memset(threads, 0, sizeof(*threads) * nr_tasks);
450 threads[i] = create_fifo_thread(start_task, (void *)i
[all...] |
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| ExecutorsTest.java | 158 * A new newFixedThreadPool with 0 threads throws IAE
289 List<Thread> threads = new ArrayList<Thread>(); local
291 threads.add(newStartedThread(new CheckedRunnable() {
297 for (Thread thread : threads)
|
| /libcore/ojluni/src/main/java/java/lang/ |
| ThreadGroup.java | 34 * A thread group represents a set of threads. In addition, a thread
73 Thread threads[]; field in class:ThreadGroup
178 * Returns the maximum priority of this thread group. Threads that are
238 * Sets the maximum priority of the group. Threads in the thread
331 * Returns an estimate of the number of active threads in this thread
336 * threads may change dynamically while this method traverses internal
338 * system threads. This method is intended primarily for debugging
341 * @return an estimate of the number of active threads in this thread
383 * an array into which to put the list of threads
385 * @return the number of threads put into the arra
[all...] |
| /system/core/debuggerd/libdebuggerd/ |
| tombstone.cpp | 606 std::map<pid_t, ThreadInfo> threads; local
607 threads[gettid()] = ThreadInfo{
624 threads, tid, abort_msg_address, nullptr, nullptr); local
628 const std::map<pid_t, ThreadInfo>& threads, pid_t target_thread,
643 auto it = threads.find(target_thread);
644 if (it == threads.end()) {
653 for (auto& [tid, thread_info] : threads) {
|
| /system/netd/tests/ |
| dns_tls_test.cpp | 631 std::vector<std::thread> threads; local
634 threads.emplace_back([key, i] (DnsTlsDispatcher* dispatcher) {
648 for (auto& thread : threads) {
|
| /art/openjdkjvmti/ |
| ti_stack.cc | 301 // Skip threads that are still starting.
361 threads.push_back(thread);
375 std::vector<art::Thread*> threads; member in struct:openjdkjvmti::AllStackTracesData
506 threads.push_back(thread);
524 std::vector<art::Thread*> threads; member in struct:openjdkjvmti::SelectStackTracesData
532 // Decode all threads to raw pointers. Put them into a handle scope to avoid any moving GC bugs.
561 art::Thread* self = data.threads[index];
[all...] |
| ti_thread.cc | 85 // Runtime isn't started. We only expect at most the signal handler or JIT threads to be
593 // Skip threads that are still starting.
613 jthread* threads = reinterpret_cast<jthread*>(data); local
615 threads[i] = soa.AddLocalReference<jthread>(peers[i]);
619 *threads_ptr = threads;
768 // The runtime is shutting down so we cannot create new threads.
770 // JVMTI_PHASE_DEAD so we cannot return ERR(WRONG_PHASE) but creating new threads is now
[all...] |
| /development/tools/bugreport/src/com/android/bugreport/html/ |
| Renderer.java | 200 * Makes a copy of the process and threads, removing ones that have accumulated in the
215 final int N = cloneProcess.threads.size();
217 final ThreadSnapshot cloneThread = cloneProcess.threads.get(i);
219 cloneProcess.threads.remove(i);
223 if (cloneProcess.threads.size() > 0) {
260 N = process.threads.size();
262 makeThreadSnapshotHdf(hdf.createChild("threads." + i), process, process.threads.get(i));
430 // And do the threads too.
435 * Sort threads so the more interesting ones are at the top
[all...] |
| /development/tools/bugreport/src/com/android/bugreport/inspector/ |
| Inspector.java | 124 for (ThreadSnapshot thread: process.threads) {
152 ThreadInfo ti = pi.threads.get(tid);
155 pi.threads.put(tid, ti);
197 * Pulls the locks out of the individual stack frames and tags the threads
202 for (ThreadSnapshot thread: process.threads) {
221 * Mark the threads that are doing binder transactions.
225 for (ThreadSnapshot thread: process.threads) {
382 * Sniff the threads that are blocked on other things.
386 for (ThreadSnapshot thread: process.threads) {
387 // These threads are technically blocked, but it's expected so don't report it
[all...] |
