/external/chromium_org/content/browser/ |
H A D | browser_thread_impl.cc | 28 // Friendly names for the well-known threads. 93 memset(threads, 0, BrowserThread::ID_COUNT * sizeof(threads[0])); 98 // This lock protects |threads|. Do not read or modify that array 102 // This array is protected by |lock|. The threads are not owned by this 103 // array. Typically, the threads are owned on the UI thread by 106 BrowserThreadImpl* threads[BrowserThread::ID_COUNT]; member in struct:content::__anon7031::BrowserThreadGlobals 281 DCHECK(globals.threads[identifier_] == NULL); 282 globals.threads[identifier_] = this; 293 globals.threads[identifier [all...] |
/external/chromium_org/mojo/common/ |
H A D | handle_watcher_unittest.cc | 375 // number of outstanding threads, |task_runner| the task runner for the main 377 // threads running. When done StressThreadDone() is invoked on the main thread. 423 // This test is meant to stress HandleWatcher. It uses from various threads 425 // threads. Each thread creates kWatchCount watches. Every so often each thread 439 ScopedVector<base::Thread> threads; local 441 // Starts the threads first and then post the task in hopes of having more 442 // threads running at once. 453 threads.push_back(thread.release()); 456 threads[i]->task_runner()->PostTask(
|
/external/chromium_org/ppapi/tests/ |
H A D | test_post_message.cc | 42 // back the number of threads & messages when running on Windows. 872 PP_Thread threads[kThreadsToRun]; local 876 PP_CreateThread(&threads[i], &InvokePostMessageThreadFunc, arg); 882 // Now join all threads. 884 PP_JoinThread(threads[i]);
|
/external/chromium_org/third_party/WebKit/Source/core/workers/ |
H A D | WorkerThread.cpp | 78 DEFINE_STATIC_LOCAL(HashSet<WorkerThread*>, threads, ()); 79 return threads; 405 HashSet<WorkerThread*> threads = workerThreads(); local 406 for (HashSet<WorkerThread*>::iterator itr = threads.begin(); itr != threads.end(); ++itr) 409 for (HashSet<WorkerThread*>::iterator itr = threads.begin(); itr != threads.end(); ++itr)
|
/external/chromium_org/third_party/webrtc/base/ |
H A D | cpumonitor_unittest.cc | 98 // 0 .. N means run on specific cpu. The tool will create N threads and call 127 std::vector<BusyThread*> threads; local 129 threads.push_back(new BusyThread(cpuload, duration, interval)); 131 if (!SetThreadPriority(threads[i], priority) || 132 !threads[i]->Start() || 133 !SetThreadAffinity(threads[i], i, affinity)) { 141 threads[i]->Stop(); 146 delete threads[i];
|
/external/deqp/framework/delibs/dethread/ |
H A D | 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]); 555 deThreadArray* threads = tmpPool ? deThreadArray_create(tmpPool) : DE_NULL; local 564 DE_TEST_ASSERT(deThreadArray_pushBack(threads, threa [all...] |
/external/linux-tools-perf/perf-3.12.0/tools/perf/tests/ |
H A D | code-reading.c | 395 struct thread_map *threads = NULL; local 437 threads = thread_map__new_by_tid(pid); 438 if (!threads) { 443 ret = perf_event__synthesize_thread_map(NULL, threads, 471 perf_evlist__set_maps(evlist, cpus, threads); 538 if (threads) 539 thread_map__delete(threads);
|
/external/linux-tools-perf/perf-3.12.0/tools/perf/util/ |
H A D | event.c | 318 struct thread_map *threads, 334 for (thread = 0; thread < threads->nr; ++thread) { 336 threads->map[thread], 0, 346 if ((int) comm_event->comm.pid != threads->map[thread]) { 350 for (j = 0; j < threads->nr; ++j) { 351 if ((int) comm_event->comm.pid == threads->map[j]) { 317 perf_event__synthesize_thread_map(struct perf_tool *tool, struct thread_map *threads, perf_event__handler_t process, struct machine *machine) argument
|
H A D | evlist.c | 31 struct thread_map *threads) 38 perf_evlist__set_maps(evlist, cpus, threads); 255 int nr_threads = thread_map__nr(evlist->threads); 273 int nr_threads = thread_map__nr(evlist->threads); 295 for (thread = 0; thread < evlist->threads->nr; thread++) { 314 for (thread = 0; thread < evlist->threads->nr; thread++) { 327 int nr_threads = thread_map__nr(evlist->threads); 584 evlist->nr_mmaps = thread_map__nr(evlist->threads); 610 int nr_threads = thread_map__nr(evlist->threads); 649 int nr_threads = thread_map__nr(evlist->threads); 30 perf_evlist__init(struct perf_evlist *evlist, struct cpu_map *cpus, struct thread_map *threads) argument 702 const struct thread_map *threads = evlist->threads; local [all...] |
H A D | python.c | 442 struct thread_map *threads; member in struct:pyrf_thread_map 455 pthreads->threads = thread_map__new(pid, tid, uid); 456 if (pthreads->threads == NULL) 463 thread_map__delete(pthreads->threads); 471 return pthreads->threads->nr; 478 if (i >= pthreads->threads->nr) 481 return Py_BuildValue("i", pthreads->threads->map[i]); 630 struct thread_map *threads = NULL; local 633 static char *kwlist[] = { "cpus", "threads", "group", "inherit", NULL }; 640 threads 699 struct thread_map *threads; local [all...] |
/external/eigen/Eigen/src/Core/products/ |
H A D | GeneralMatrixMatrix.h | 81 Index threads = omp_get_num_threads(); local 105 // Then, we set info[tid].users to the number of threads to mark that all other threads are going to use it. 107 info[tid].users += threads; 111 // Notify the other threads that the part B'_j is ready to go. 115 for(Index shift=0; shift<threads; ++shift) 117 Index j = (tid+shift)%threads; 142 for(Index j=0; j<threads; ++j)
|
/external/fio/ |
H A D | gettime.c | 534 struct clock_thread *threads; local 548 threads = malloc(nr_cpus * sizeof(struct clock_thread)); 555 struct clock_thread *t = &threads[i]; 571 struct clock_thread *t = &threads[i]; 577 struct clock_thread *t = &threads[i]; 583 struct clock_thread *t = &threads[i]; 590 free(threads); 593 log_err("Clocksource test: %lu threads failed\n", failed);
|
/external/chromium_org/media/cast/test/ |
H A D | cast_benchmarks.cc | 629 std::vector<linked_ptr<base::Thread> >* threads) { 638 (*threads)[thread_num % threads->size()]->message_loop()->PostTask( 646 SpanningSearch(max, x, y, skip, a, b, c, accuracy, threads); 647 SpanningSearch(max, x + skip, y + skip, skip, a, b, c, accuracy, threads); 648 SpanningSearch(max, x + skip, y, skip, a, b, c, accuracy, threads); 649 SpanningSearch(max, x, y + skip, skip, a, b, c, accuracy, threads); 656 std::vector<linked_ptr<base::Thread> > threads; local 658 threads.push_back(make_linked_ptr(new base::Thread( 660 threads[ 621 SpanningSearch(int max, int x, int y, int skip, SearchVector a, SearchVector b, SearchVector c, double accuracy, std::vector<linked_ptr<base::Thread> >* threads) argument [all...] |
/external/chromium_org/sync/syncable/ |
H A D | directory_unittest.cc | 1569 // Stress test Directory by accessing it from several threads concurrently. 1572 base::PlatformThreadHandle threads[kThreadCount]; local 1578 0, thread_delegates[i].get(), &threads[i])); 1582 base::PlatformThread::Join(threads[i]);
|
/external/chromium_org/third_party/WebKit/Source/platform/heap/ |
H A D | ThreadState.cpp | 116 // Wait time for parking all threads is at most 100 MS. 129 // Request other attached threads that are not at safe points to park themselves on safepoints. 134 // Lock threadAttachMutex() to prevent threads from attaching. 137 ThreadState::AttachedThreadStateSet& threads = ThreadState::attachedThreads(); local 140 atomicAdd(&m_unparkedThreadCount, threads.size()); 144 for (ThreadState::AttachedThreadStateSet::iterator it = threads.begin(), end = threads.end(); it != end; ++it) { 156 // One of the other threads did not return to a safepoint within the maximum 157 // time we allow for threads to be parked. Abandon the GC and resume the 158 // currently parked threads 168 ThreadState::AttachedThreadStateSet& threads = ThreadState::attachedThreads(); local 492 AttachedThreadStateSet& threads = attachedThreads(); local 500 AttachedThreadStateSet& threads = attachedThreads(); local 1257 ThreadState::AttachedThreadStateSet& threads = attachedThreads(); local [all...] |
/external/chromium_org/third_party/icu/source/test/intltest/ |
H A D | tzfmttst.cpp | 410 umtx_unlock(NULL); // Unlock for other threads to use 643 TestTimeRoundTripThread **threads = new TestTimeRoundTripThread*[threadCount]; local 646 threads[i] = new TestTimeRoundTripThread(*this, data, i); 647 if (threads[i]->start() != 0) { 665 delete threads[i]; 667 delete [] threads;
|
H A D | tsmthred.cpp | 208 // TestThreads -- see if threads really work at all. 210 // Set up N threads pointing at N chars. When they are started, they will 231 // TestArabicShapeThreads -- see if calls to u_shapeArabic in many threads works successfully 233 // Set up N threads pointing at N chars. When they are started, they will make calls to doTailTest which tests 235 // At the end we make sure all threads managed to run u_shapeArabic successfully. 302 SimpleThread *threads[THREADTEST_NRTHREADS]; local 309 threads[i] = new TestThreadsThread(&threadTestChars[i]); 313 logln("->" + UnicodeString(threadTestChars) + "<- Firing off threads.. "); 316 if (threads[i]->start() != 0) { 326 logln("Waiting for threads t 372 SimpleThread *threads[ARABICSHAPE_THREADTEST]; local 495 TestMutexThread *threads[TESTMUTEX_THREAD_COUNT]; local [all...] |
/external/chromium_org/third_party/skia/experimental/Intersection/ |
H A D | EdgeWalker_TestUtility.cpp | 558 int threads = -1; local 559 size_t size = sizeof(threads); 560 sysctlbyname("hw.logicalcpu_max", &threads, &size, NULL, 0); 561 if (threads > 0) { 562 maxThreads = threads;
|
/external/guava/guava-tests/test/com/google/common/util/concurrent/ |
H A D | JSR166TestCase.java | 43 * helping to make sure that assertions failing in generated threads 50 * <li> All assertions in code running in generated threads must use 74 * <li> All threads generated must be joined inside each test case 101 * the smallest sensible numbers of threads, collection sizes, etc 538 * Checks that the threads do not terminate within the default 541 void assertThreadsStayAlive(Thread... threads) { argument 542 assertThreadsStayAlive(timeoutMillis(), threads); 546 * Checks that the threads do not terminate within the given millisecond delay. 548 void assertThreadsStayAlive(long millis, Thread... threads) { argument 552 for (Thread thread : threads) [all...] |
/external/icu/icu4c/source/test/intltest/ |
H A D | tzfmttst.cpp | 410 umtx_unlock(NULL); // Unlock for other threads to use 643 TestTimeRoundTripThread **threads = new TestTimeRoundTripThread*[threadCount]; local 646 threads[i] = new TestTimeRoundTripThread(*this, data, i); 647 if (threads[i]->start() != 0) { 665 delete threads[i]; 667 delete [] threads;
|
/external/lldb/tools/debugserver/source/MacOSX/ |
H A D | MachTask.cpp | 239 thread_act_array_t threads; local 242 kr = task_threads(task, &threads, &tcnt); 250 kr = ::thread_info(threads[i], THREAD_IDENTIFIER_INFO, (thread_info_t)&identifier_info, &count); 255 kr = ::thread_info(threads[i], THREAD_BASIC_INFO, (thread_info_t)&basic_info, &count); 260 nub_thread_t tid = MachThread::GetGloballyUniqueThreadIDForMachPortID (threads[i]); 289 kr = mach_port_deallocate(mach_task_self(), threads[i]); 291 kr = mach_vm_deallocate(mach_task_self(), (mach_vm_address_t)(uintptr_t)threads, tcnt * sizeof(*threads)); 678 // then together. When we have multiple threads, we can get an exception
|
/external/skia/experimental/Intersection/ |
H A D | EdgeWalker_TestUtility.cpp | 558 int threads = -1; local 559 size_t size = sizeof(threads); 560 sysctlbyname("hw.logicalcpu_max", &threads, &size, NULL, 0); 561 if (threads > 0) { 562 maxThreads = threads;
|
/external/chromium_org/base/debug/ |
H A D | trace_event_unittest.cc | 1432 // Test that data sent from other threads is gathered 1449 // Test that data sent from multiple threads is gathered 1455 Thread* threads[num_threads]; local 1458 threads[i] = new Thread(StringPrintf("Thread %d", i)); 1460 threads[i]->Start(); 1461 threads[i]->message_loop()->PostTask( 1470 // Let half of the threads end before flush. 1472 threads[i]->Stop(); 1473 delete threads[i]; 1481 // Let the other half of the threads en 1495 Thread* threads[num_threads]; local [all...] |
/external/chromium_org/native_client_sdk/src/libraries/third_party/pthreads-win32/ |
H A D | implement.h | 160 ptw32_thread_t * prevReuse; /* Links threads on reuse stack */ 248 threads. */ 346 void *threads; member in struct:pthread_key_t_ 362 long nWaitersBlocked; /* Number of threads blocked */ 363 long nWaitersGone; /* Number of threads timed out */ 364 long nWaitersToUnblock; /* Number of threads to unblock */ 365 sem_t semBlockQueue; /* Queue up threads waiting for the */ 415 * (head of chain is key->threads) 481 * The pthread_key_t->threads attribute is the head of
|
/external/chromium_org/third_party/sqlite/src/test/ |
H A D | threadtest3.c | 428 Thread *pNext; /* Next in this list of threads */ 433 Thread *pThread; /* Linked list of threads */ 958 Threadset threads = {0}; /* Test threads */ local 972 launch_thread(&err, &threads, walthread1_thread, 0); 974 launch_thread(&err, &threads, walthread1_ckpt_thread, 0); 975 join_all_threads(&err, &threads); 1020 Threadset threads = {0}; local 1027 launch_thread(&err, &threads, walthread2_thread, 0); 1028 launch_thread(&err, &threads, walthread2_threa 1075 Threadset threads = {0}; local 1134 Threadset threads = {0}; local 1167 Threadset threads = {0}; local 1363 Threadset threads = {0}; local [all...] |