| /external/fio/t/ |
| dedupe.c | 334 static void show_progress(struct worker_thread *threads, unsigned long total)
350 nitems += threads[i].items;
351 some_done = threads[i].done;
379 struct worker_thread *threads; local
388 threads = malloc(num_threads * sizeof(struct worker_thread));
390 memset(&threads[i], 0, sizeof(struct worker_thread));
391 threads[i].fd = f->fd;
393 err = pthread_create(&threads[i].thread, NULL, thread_fn, &threads[i]);
400 show_progress(threads, total_items)
[all...] |
| /external/libchrome/base/trace_event/ |
| memory_dump_manager_unittest.cc | 503 // threads and registering a MemoryDumpProvider on each of them. At each
509 std::vector<std::unique_ptr<Thread>> threads; local
512 // Create the threads and setup the expectations. Given that at each iteration
516 threads.push_back(WrapUnique(new Thread("test thread")));
517 auto* thread = threads.back().get();
533 while (!threads.empty()) {
548 threads.back()->task_runner()->PostTaskAndReply(FROM_HERE, unregistration,
553 threads.back()->Stop();
554 threads.pop_back();
714 std::vector<std::unique_ptr<TestIOThread>> threads; local
836 std::vector<std::unique_ptr<TestIOThread>> threads; local
[all...] |
| /external/ltp/testcases/kernel/mem/lib/ |
| mem.c | 73 static void child_alloc(int testcase, int lite, int threads)
83 th = malloc(sizeof(pthread_t) * threads);
89 for (i = 0; i < threads; i++) {
103 /* wait for one of threads to exit whole process */
128 int status, threads; local
132 threads = MAX(1, tst_ncpus() - 1);
133 child_alloc(testcase, lite, threads);
|
| /external/mesa3d/src/gallium/drivers/nouveau/codegen/ |
| nv50_ir_target.h | 177 threads = info->prop.cp.numThreads;
178 if (threads == 0)
179 threads = info->target >= NVISA_GK104_CHIPSET ? 1024 : 512;
256 uint32_t threads; member in class:nv50_ir::Target
|
| /frameworks/ml/nn/common/ |
| CpuExecutor.cpp | 1546 int threads = nProcs; local
[all...] |
| /frameworks/native/libs/gui/tests/ |
| CpuConsumer_test.cpp | 712 // there are params.maxLockedBuffers+1 threads so one of the
713 // threads might get this error
726 // spawn threads
727 std::vector<std::thread> threads; local
729 threads.push_back(std::thread(lockAndUnlock));
732 // join threads
733 for (auto& thread : threads) {
737 // we produced N+1 buffers, but the threads might only consume N
|
| /hardware/libhardware/modules/sensors/ |
| multihal.cpp | 210 std::vector<pthread_t> threads; member in struct:sensors_poll_context_t
234 this->threads.push_back(writerThread);
|
| /libcore/luni/src/test/java/libcore/java/util/regex/ |
| OldMatcherTest.java | 579 ArrayList<Thread> threads = new ArrayList<Thread>(); local
599 threads.add(t);
602 for (Thread t : threads) {
605 for (Thread t : threads) {
|
| /packages/services/Car/tests/vehiclehal_test/src/com/android/car/vehiclehal/test/ |
| E2ePerformanceTest.java | 210 List<Thread> threads = new ArrayList<>(Lists.newArrayList( local
214 for (Thread t : threads) {
221 for (Thread t : threads) {
|
| /prebuilts/ndk/r16/sources/cxx-stl/llvm-libc++/utils/google-benchmark/include/benchmark/ |
| benchmark_api.h | 123 In a multithreaded test, it is guaranteed that none of the threads will start
139 BENCHMARK(BM_MultiThreaded)->Threads(4);
271 // presented divided by the number of threads.
347 // NOTE: The "real time" measurement is per-thread. If different threads
372 // calls to `KeepRunning()` will block until all threads have completed
373 // the `KeepRunning()` loop. If multiple threads report an error only the
478 // Index of the executing thread. Values from [0, threads).
480 // Number of threads concurrently executing the benchmark.
481 const int threads; member in class:benchmark::internal::State
571 // Threads, etc
[all...] |
| /system/core/adb/ |
| adb.cpp | 796 // Start threads to read from subprocess stdout/stderr and write to ours to make subprocess
797 // errors easier to diagnose. Note that the threads internally create inheritable handles, but
852 // Always try to wait a bit for threads reading stdout/stderr to finish.
853 // If the process started ok, it should close the pipes causing the threads
858 const HANDLE threads[] = { stdout_thread.get(), stderr_thread.get() }; local
859 const DWORD wait_result = WaitForMultipleObjects(arraysize(threads),
860 threads, TRUE, thread_timeout_ms);
862 // Threads did not finish after waiting a little while. Perhaps the
864 fprintf(stderr, "adb: timed out waiting for threads to finish reading from ADB server\n");
876 fprintf(stderr, "adb: unexpected result waiting for threads: %lu: %s\n", wait_result
[all...] |
| /test/suite_harness/common/host-side/tradefed/tests/src/com/android/compatibility/common/tradefed/presubmit/ |
| IntegrationTest.java | 577 List<ShardThread> threads = new ArrayList<>(); local
582 threads.add(st);
585 for (ShardThread thread : threads) {
588 // Allow some time for ResultReport to finalize the results coming from the threads.
626 List<ShardThread> threads = new ArrayList<>(); local
631 threads.add(st);
634 for (ShardThread thread : threads) {
637 // Allow some time for ResultReport to finalize the results coming from the threads.
[all...] |
| /external/icu/android_icu4j/src/main/tests/android/icu/dev/test/format/ |
| DateIntervalFormatTest.java | 1880 List<TestThread> threads = new ArrayList<TestThread>(); local
[all...] |
| /external/icu/icu4j/main/tests/core/src/com/ibm/icu/dev/test/format/ |
| DateIntervalFormatTest.java | 1877 List<TestThread> threads = new ArrayList<TestThread>(); local
[all...] |
| /art/test/924-threads/src/art/ |
| Test924.java | 213 Thread[] threads = getAllThreads(); local
214 List<Thread> threadList = new ArrayList<>(Arrays.asList(threads));
246 private static Thread findThreadByName(Set<Thread> threads, String name) {
247 for (Thread t : threads) {
252 throw new RuntimeException("Did not find thread " + name + ": " + threads);
|
| /external/deqp/external/vulkancts/modules/vulkan/synchronization/ |
| vktSynchronizationInternallySynchronizedObjectsTests.cpp | 691 ThreadGroup threads; local
696 threads.add(MovePtr<ThreadGroupThread>(new CreateComputeThread(
700 TestStatus thread_result = threads.run();
803 ThreadGroup threads; local
808 threads.add(MovePtr<ThreadGroupThread>(new CreateGraphicThread
[all...] |
| /external/deqp/modules/egl/ |
| teglGLES2SharedRenderingPerfTests.cpp | 886 void createThreads (vector<TestThread*>& threads, int threadCount, int perThreadContextCount, vector<TestContext*>& contexts, const Library& egl)
889 DE_ASSERT(threads.empty());
898 threads.push_back(new TestThread(threadContexts, egl));
904 void destroyThreads (vector<TestThread*>& threads)
906 for (int threadNdx = 0; threadNdx < (int)threads.size(); threadNdx++)
908 delete threads[threadNdx];
909 threads[threadNdx] = DE_NULL;
912 threads.clear();
915 void startThreads (vector<TestThread*>& threads)
917 for (int threadNdx = 0; threadNdx < (int)threads.size(); threadNdx++
1038 vector<TestThread*> threads; local
[all...] |
| /external/google-benchmark/include/benchmark/ |
| benchmark.h | 138 In a multithreaded test, it is guaranteed that none of the threads will start
154 BENCHMARK(BM_MultiThreaded)->Threads(4);
349 // presented divided by the number of threads.
451 // NOTE: The "real time" measurement is per-thread. If different threads
481 // calls to `KeepRunning()` will block until all threads have completed
482 // the `KeepRunning()` loop. If multiple threads report an error only the
587 // Index of the executing thread. Values from [0, threads).
589 // Number of threads concurrently executing the benchmark.
590 const int threads; member in class:benchmark::State
727 // Threads, etc
[all...] |
| /external/google-breakpad/src/tools/linux/md2core/ |
| minidump-2-core.cc | 222 std::vector<Thread> threads; member in struct:CrashedProcess
402 "Found %d threads\n"
421 crashinfo->threads.push_back(thread);
[all...] |
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| JSR166TestCase.java | 45 * helping to make sure that assertions failing in generated threads
52 * <li> All assertions in code running in generated threads must use
76 * <li> All threads generated must be joined inside each test case
103 * the smallest sensible numbers of threads, collection sizes, etc
540 * Checks that the threads do not terminate within the default
543 void assertThreadsStayAlive(Thread... threads) {
544 assertThreadsStayAlive(timeoutMillis(), threads); local
548 * Checks that the threads do not terminate within the given millisecond delay.
550 void assertThreadsStayAlive(long millis, Thread... threads) {
554 for (Thread thread : threads)
[all...] |
| /external/icu/android_icu4j/src/main/tests/android/icu/dev/test/charsetdet/ |
| TestCharsetDetector.java | 1240 Thread threads[] = new Thread[10]; local
[all...] |
| /external/icu/icu4j/main/tests/core/src/com/ibm/icu/dev/test/charsetdet/ |
| TestCharsetDetector.java | 1237 Thread threads[] = new Thread[10]; local
[all...] |
| /external/icu/icu4j/perf-tests/src/com/ibm/icu/dev/test/perf/ |
| PerfTest.java | 96 protected int threads; field in class:PerfTest
343 static final int THREADS = 14;
366 UOption.DEF("threads", 'r', UOption.REQUIRES_ARG),
461 threads = 1;
505 if (options[THREADS].doesOccur) {
507 threads = Integer.parseInt(options[THREADS].value);
509 throw new UsageException("'-r <threads>' requires an integer number of threads");
511 if (threads <= 0
[all...] |
| /external/libcxx/utils/google-benchmark/include/benchmark/ |
| benchmark.h | 138 In a multithreaded test, it is guaranteed that none of the threads will start
154 BENCHMARK(BM_MultiThreaded)->Threads(4);
349 // presented divided by the number of threads.
451 // NOTE: The "real time" measurement is per-thread. If different threads
481 // calls to `KeepRunning()` will block until all threads have completed
482 // the `KeepRunning()` loop. If multiple threads report an error only the
587 // Index of the executing thread. Values from [0, threads).
589 // Number of threads concurrently executing the benchmark.
590 const int threads; member in class:benchmark::State
727 // Threads, etc
[all...] |
| /frameworks/base/tests/CoreTests/android/core/ |
| TestWebServer.java | 41 /* Where worker threads stand idle */
42 Vector threads = new Vector(); field in class:TestWebServer
44 /* List of all active worker threads */
50 /* max # worker threads */
216 * The AcceptThread is responsible for initiating worker threads
264 synchronized (threads) {
265 if (threads.isEmpty()) {
271 w = (Worker) threads.elementAt(0);
272 threads.removeElementAt(0);
298 // Stop worker threads from continuin
[all...] |
