/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/base/metrics/ |
H A D | stats_table_unittest.cc | 45 slot_id = table.RegisterThread("too many threads"); 61 // CounterMixed will be incremented by odd numbered threads and 62 // decremented by even threads. 102 // Create a few threads and have them poke on their counters. 122 // Spin up a set of threads to go bang on the various counters. 123 // After we join the threads, we'll make sure the counters 125 StatsTableThread* threads[kMaxThreads]; local 127 // Spawn the threads. 129 threads[index] = new StatsTableThread("MultipleThreadsTest", index); 130 threads[inde [all...] |
/external/chromium_org/base/ |
H A D | observer_list_unittest.cc | 179 bool do_notifies_; // Whether these threads should do notifications. 365 // of observer threads, each of which constantly adds/removes itself 367 // to true, the observer threads will also trigger notifications to 387 base::PlatformThreadHandle threads[kMaxThreads]; local 391 threaded_observer[index], &threads[index])); 406 PlatformThread::Join(threads[index]); 411 // Use 7 observer threads. Notifications only come from 417 // Use 3 observer threads. Notifications will fire from 418 // the main thread and all 3 observer threads.
|
/external/chromium_org/base/threading/ |
H A D | thread_local_storage_unittest.cc | 99 // threads that set the TLS, while the destructor cleans it up. 100 // After the threads finish, verify that the value is cleaned up. 104 DelegateSimpleThread* threads[kNumThreads]; local 108 // Spawn the threads. 112 threads[index] = new DelegateSimpleThread(thread_delegates[index], 114 threads[index]->Start(); 117 // Wait for the threads to finish. 119 threads[index]->Join(); 120 delete threads[index]; 126 tls_slot.Free(); // Stop doing callbacks to cleanup threads [all...] |
/external/chromium_org/base/time/ |
H A D | time_win_unittest.cc | 69 // 2) Create N threads 70 // 3) Start the threads 84 HANDLE threads[kThreads]; local 89 threads[index] = reinterpret_cast<HANDLE>( 92 EXPECT_NE((HANDLE)NULL, threads[index]); 98 // Wait for threads to finish 100 DWORD rv = WaitForSingleObject(threads[index], INFINITE); 104 CloseHandle(threads[index]);
|
/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/content/common/ |
H A D | one_writer_seqlock_unittest.cc | 70 BasicSeqLockTestThread threads[kNumReaderThreads]; local 74 threads[i].Init(&seqlock, &data, &ready); 76 ASSERT_TRUE(PlatformThread::Create(0, &threads[i], &handles[i]));
|
/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/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/mojo/system/ |
H A D | dispatcher_unittest.cc | 280 ScopedVector<ThreadSafetyStressThread> threads; local 285 threads.push_back(new ThreadSafetyStressThread(&event, d, op)); 286 threads.back()->Start(); 288 // Kicks off real work on the threads: 290 } // Joins all the threads. 292 // One of the threads should already have closed the dispatcher. 307 ScopedVector<ThreadSafetyStressThread> threads; local 313 threads.push_back(new ThreadSafetyStressThread(&event, d, op)); 314 threads.back()->Start(); 316 // Kicks off real work on the threads [all...] |
H A D | simple_dispatcher_unittest.cc | 497 ScopedVector<test::WaiterThread> threads; local 499 threads.push_back(new test::WaiterThread(d, 507 threads.back()->Start(); 512 } // Joins the threads. 525 ScopedVector<test::WaiterThread> threads; local 527 threads.push_back(new test::WaiterThread(d, 535 threads.back()->Start(); 538 threads.push_back(new test::WaiterThread(d, 546 threads.back()->Start(); 552 } // Joins the threads 572 ScopedVector<test::WaiterThread> threads; local 620 ScopedVector<test::WaiterThread> 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/native_client_sdk/src/tests/nacl_io_test/ |
H A D | event_test.cc | 125 pthread_t threads[NUM_THREADS]; local 128 threads[a] = CreateThread(); 133 // Wait for all threads to wait 156 // Clean up remaining threads. 163 pthread_join(threads[a], NULL);
|
/external/chromium_org/net/base/ |
H A D | net_log_unittest.cc | 154 // Only triggered once all threads have been created, to make it less likely 210 // Creates |kThreads| threads of type |ThreadType| and then runs them all 214 ThreadType threads[kThreads]; local 217 for (size_t i = 0; i < arraysize(threads); ++i) { 218 threads[i].Init(net_log, &start_event); 219 threads[i].Start(); 224 for (size_t i = 0; i < arraysize(threads); ++i) 225 threads[i].Join(); 228 // Makes sure that events on multiple threads are dispatched to all observers. 238 // Run a bunch of threads t [all...] |
/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/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/testing/gtest/test/ |
H A D | gtest_stress_test.cc | 33 // used in a large number of threads concurrently. 61 // How many threads to create? 104 // RecordProperty() should interact safely with other threads as well. 125 // Tests using SCOPED_TRACE() and Google Test assertions in many threads 129 scoped_ptr<ThreadWithParam<int> > threads[kThreadCount]; local 132 threads[i].reset(new ThreadWithParam<int>(&ManyAsserts, 138 // Blocks until all the threads are done. 140 threads[i]->Join(); 205 // This statement should succeed, because failures in all threads are 224 // This statement should succeed, because failures in all threads ar [all...] |
/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/WebKit/Source/platform/heap/ |
H A D | Heap.cpp | 384 // FIXME: in an unlikely coincidence that two threads decide 401 // Only cleanup if we parked all threads in which case the GC happened 402 // and we need to resume the other threads. 413 bool m_parkedAllThreads; // False if we fail to park all threads 1059 // No locking needed as all threads are at safepoints at this point in time. 1060 ThreadState::AttachedThreadStateSet& threads = ThreadState::attachedThreads(); local 1061 for (ThreadState::AttachedThreadStateSet::iterator it = threads.begin(), end = threads.end(); it != end; ++it) 1182 // Since the FreePagePool is global other threads could use all the 2074 // FIXME: We should let the amount of threads scal 2120 ThreadState::AttachedThreadStateSet& threads = ThreadState::attachedThreads(); local 2335 ThreadState::AttachedThreadStateSet& threads = ThreadState::attachedThreads(); local 2648 ThreadState::AttachedThreadStateSet& threads = ThreadState::attachedThreads(); local 2660 ThreadState::AttachedThreadStateSet& threads = ThreadState::attachedThreads(); local 2673 ThreadState::AttachedThreadStateSet& threads = ThreadState::attachedThreads(); local 2685 ThreadState::AttachedThreadStateSet& threads = ThreadState::attachedThreads(); local [all...] |
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 | 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...] |
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/chromium_org/third_party/libaddressinput/src/java/ |
H A D | android.jar | META-INF/ META-INF/MANIFEST.MF AndroidManifest.xml android/ android/Manifest$permission.class ... |
/external/chromium_org/third_party/libjingle/source/talk/xmllite/ |
H A D | xmlelement_unittest.cc | 264 std::vector<rtc::Thread*> threads; local 266 threads.push_back( 268 threads[i]->Start(); 272 threads[i]->Stop(); 273 delete threads[i];
|
/external/chromium_org/third_party/libvpx/source/libvpx/test/ |
H A D | decode_perf_test.cc | 30 DecodePerfTest takes a tuple of filename + number of threads to decode with 72 const unsigned threads = GET_PARAM(THREADS); local 78 cfg.threads = threads; 98 printf("\t\"threadCount\" : %u,\n", threads);
|