Searched defs:threads (Results 76 - 100 of 128) sorted by relevance

123456

/external/chromium_org/content/browser/
H A Dbrowser_thread_impl.cc28 // 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 Dhandle_watcher_unittest.cc375 // 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 Dtest_post_message.cc42 // 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 DWorkerThread.cpp78 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 Dcpumonitor_unittest.cc98 // 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 DdeThreadTest.c274 /* 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 Dcode-reading.c395 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 Devent.c318 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 Devlist.c31 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 Dpython.c442 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 DGeneralMatrixMatrix.h81 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 Dgettime.c534 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 Dcast_benchmarks.cc629 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 Ddirectory_unittest.cc1569 // 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 DThreadState.cpp116 // 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 Dtzfmttst.cpp410 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 Dtsmthred.cpp208 // 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 DEdgeWalker_TestUtility.cpp558 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 DJSR166TestCase.java43 * 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 Dtzfmttst.cpp410 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 DMachTask.cpp239 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 DEdgeWalker_TestUtility.cpp558 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 Dtrace_event_unittest.cc1432 // 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 Dimplement.h160 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 Dthreadtest3.c428 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...]

Completed in 1771 milliseconds

123456