| /system/extras/memory_replay/tests/ |
| D | ThreadsTest.cpp | 27 Threads threads(&pointers, 1); in TEST() local
28 Thread* thread = threads.CreateThread(900); in TEST()
30 ASSERT_EQ(1U, threads.num_threads()); in TEST()
32 Thread* found_thread = threads.FindThread(900); in TEST()
40 threads.Finish(thread); in TEST()
42 ASSERT_EQ(0U, threads.num_threads()); in TEST()
48 Threads threads(&pointers, 1); in TEST() local
49 Thread* thread1 = threads.CreateThread(900); in TEST()
51 ASSERT_EQ(1U, threads.num_threads()); in TEST()
53 Thread* thread2 = threads.CreateThread(901); in TEST()
[all …]
|
| /system/extras/libfec/ |
| D | fec_process.cpp | 54 int threads = sysconf(_SC_NPROCESSORS_ONLN); in process() local
56 if (threads < WORK_MIN_THREADS) { in process()
57 threads = WORK_MIN_THREADS; in process()
58 } else if (threads > WORK_MAX_THREADS) { in process()
59 threads = WORK_MAX_THREADS; in process()
65 size_t count_per_thread = fec_div_round_up(blocks, threads) * FEC_BLOCKSIZE; in process()
68 if ((size_t)threads > max_threads) { in process()
69 threads = (int)max_threads; in process()
76 debug("%d threads, %zu bytes per thread (total %zu)", threads, in process()
80 process_info info[threads]; in process()
[all …]
|
| /system/extras/memory_replay/ |
| D | main.cpp | 79 Threads threads(&pointers, max_threads); in ProcessDump() local
81 NativePrintf("Maximum threads available: %zu\n", threads.max_threads()); in ProcessDump()
93 Thread* thread = threads.FindThread(entry.tid); in ProcessDump()
95 thread = threads.CreateThread(entry.tid); in ProcessDump()
109 threads.WaitForAllToQuiesce(); in ProcessDump()
117 threads.Finish(thread); in ProcessDump()
128 threads.WaitForAllToQuiesce(); in ProcessDump()
135 threads.FinishAll(); in ProcessDump()
140 uint64_t total_nsecs = threads.total_time_nsecs(); in ProcessDump()
|
| /system/extras/simpleperf/scripts/test/ |
| D | inferno_test.py | 57 threads = set()
59 threads = set()
61 threads.add(int(m.group(1)))
62 return threads
80 threads = get_threads_for_filter('--filter-file ' + filter_file.name)
81 self.assertIn(31881, threads)
82 self.assertNotIn(31850, threads)
|
| D | gecko_profile_generator_test.py | 48 threads = set()
50 threads.add(int(m.group(1)))
51 return threads
71 threads = get_threads_for_filter('--filter-file ' + filter_file.name)
72 self.assertIn(31881, threads)
73 self.assertNotIn(31850, threads)
|
| D | stackcollapse_test.py | 74 threads = set()
76 threads.add(int(m.group(1)))
77 return threads
95 threads = get_threads_for_filter('--filter-file ' + filter_file.name)
96 self.assertIn(31881, threads)
97 self.assertNotIn(31850, threads)
|
| D | report_sample_test.py | 73 threads = set()
75 threads.add(int(m.group(1)))
76 return threads
96 threads = get_threads_for_filter('--filter-file ' + filter_file.name)
97 self.assertIn(31881, threads)
98 self.assertNotIn(31850, threads)
|
| D | report_html_test.py | 219 threads = set()
222 threads.add(thread['tid'])
225 return threads
245 threads = get_threads_for_filter('--filter-file ' + filter_file.name)
246 self.assertIn(31881, threads)
247 self.assertNotIn(31850, threads)
|
| D | pprof_proto_generator_test.py | 265 threads = set()
267 threads = set()
269 threads.add(int(m.group(1)))
270 return threads
290 threads = get_threads_for_filter('--filter-file ' + filter_file.name)
291 self.assertIn(31881, threads)
292 self.assertNotIn(31850, threads)
|
| /system/core/debuggerd/libdebuggerd/ |
| D | tombstone.cpp | 75 std::map<pid_t, ThreadInfo> threads; in engrave_tombstone_ucontext() local
76 threads[tid] = ThreadInfo{ in engrave_tombstone_ucontext()
87 const ThreadInfo& thread = threads[pid]; in engrave_tombstone_ucontext()
88 if (!iterate_tids(pid, [&threads, &thread](pid_t tid) { in engrave_tombstone_ucontext()
89 threads[tid] = ThreadInfo{ in engrave_tombstone_ucontext()
115 engrave_tombstone(unique_fd(dup(tombstone_fd)), unique_fd(dup(proto_fd)), &unwinder, threads, tid, in engrave_tombstone_ucontext()
120 const std::map<pid_t, ThreadInfo>& threads, pid_t target_thread, in engrave_tombstone() argument
125 engrave_tombstone_proto(&tombstone, unwinder, threads, target_thread, process_info, open_files); in engrave_tombstone()
|
| /system/memory/libmemunreachable/tests/ |
| D | ThreadCapture_test.cpp | 56 void StartThreads(unsigned int threads, Function&& func) { in StartThreads() argument
57 threads_.reserve(threads); in StartThreads()
58 tids_.reserve(threads); in StartThreads()
59 for (unsigned int i = 0; i < threads; i++) { in StartThreads()
60 threads_.emplace_back([&, threads, this]() { in StartThreads()
64 if (tids_.size() == threads) { in StartThreads()
80 cv_start_.wait(lk, [&] { return tids_.size() == threads; }); in StartThreads()
144 const unsigned int threads = GetParam() - 1; in TEST_P() local
146 StartThreads(threads, []() {}); in TEST_P()
210 const unsigned int threads = GetParam(); in TEST_P() local
[all …]
|
| /system/extras/verity/fec/ |
| D | image.cpp | 355 int threads = ctx->threads; in image_process() local
357 if (threads < IMAGE_MIN_THREADS) { in image_process()
358 threads = sysconf(_SC_NPROCESSORS_ONLN); in image_process()
360 if (threads < IMAGE_MIN_THREADS) { in image_process()
361 threads = IMAGE_MIN_THREADS; in image_process()
367 if ((uint64_t)threads > ctx->rounds) { in image_process()
368 threads = (int)ctx->rounds; in image_process()
370 if (threads > IMAGE_MAX_THREADS) { in image_process()
371 threads = IMAGE_MAX_THREADS; in image_process()
375 INFO("starting %d threads to compute RS(255, %d)\n", threads, in image_process()
[all …]
|
| /system/core/init/ |
| D | ueventd_test.cpp | 55 std::vector<std::thread> threads; in WriteFromMultipleThreads() local
57 threads.emplace_back(std::thread(make_thread_function(file, parameter))); in WriteFromMultipleThreads()
60 for (auto& thread : threads) { in WriteFromMultipleThreads()
186 std::vector<std::thread> threads; in TEST() local
187 std::generate_n(back_inserter(threads), num_threads, in TEST()
192 for (auto& thread : threads) { in TEST()
|
| /system/core/libutils/ |
| D | ProcessCallStack_fuzz.cpp | 36 std::vector<std::thread> threads = std::vector<std::thread>(); in spawnThreads() local
47 threads.push_back(move(th)); in spawnThreads()
68 for (auto& thread : threads) { in spawnThreads()
|
| /system/sepolicy/prebuilts/api/28.0/public/ |
| D | performanced.te | 15 # Access /proc to validate we're only affecting threads in the same thread group.
16 # Performanced also shields unbound kernel threads. It scans every task in the
17 # root cpu set, but only affects the kernel threads.
|
| /system/sepolicy/prebuilts/api/30.0/public/ |
| D | performanced.te | 15 # Access /proc to validate we're only affecting threads in the same thread group.
16 # Performanced also shields unbound kernel threads. It scans every task in the
17 # root cpu set, but only affects the kernel threads.
|
| /system/sepolicy/prebuilts/api/29.0/public/ |
| D | performanced.te | 15 # Access /proc to validate we're only affecting threads in the same thread group.
16 # Performanced also shields unbound kernel threads. It scans every task in the
17 # root cpu set, but only affects the kernel threads.
|
| /system/sepolicy/prebuilts/api/33.0/public/ |
| D | performanced.te | 15 # Access /proc to validate we're only affecting threads in the same thread group.
16 # Performanced also shields unbound kernel threads. It scans every task in the
17 # root cpu set, but only affects the kernel threads.
|
| /system/sepolicy/prebuilts/api/32.0/public/ |
| D | performanced.te | 15 # Access /proc to validate we're only affecting threads in the same thread group.
16 # Performanced also shields unbound kernel threads. It scans every task in the
17 # root cpu set, but only affects the kernel threads.
|
| /system/sepolicy/public/ |
| D | performanced.te | 15 # Access /proc to validate we're only affecting threads in the same thread group.
16 # Performanced also shields unbound kernel threads. It scans every task in the
17 # root cpu set, but only affects the kernel threads.
|
| /system/sepolicy/prebuilts/api/31.0/public/ |
| D | performanced.te | 15 # Access /proc to validate we're only affecting threads in the same thread group.
16 # Performanced also shields unbound kernel threads. It scans every task in the
17 # root cpu set, but only affects the kernel threads.
|
| /system/memory/libmemunreachable/ |
| D | ThreadCapture.cpp | 82 bool CapturedThreadInfo(ThreadInfoList& threads);
323 bool ThreadCaptureImpl::CapturedThreadInfo(ThreadInfoList& threads) { in CapturedThreadInfo() argument
324 threads.clear(); in CapturedThreadInfo()
331 threads.push_back(t); in CapturedThreadInfo()
359 bool ThreadCapture::CapturedThreadInfo(ThreadInfoList& threads) { in CapturedThreadInfo() argument
360 return impl_->CapturedThreadInfo(threads); in CapturedThreadInfo()
|
| /system/unwinding/libunwindstack/tests/ |
| D | UnwindTest.cpp | 442 std::vector<std::thread*> threads; in TEST_F() local
459 threads.push_back(thread); in TEST_F()
462 for (auto thread : threads) { in TEST_F()
612 std::vector<std::thread*> threads; in TEST_F() local
615 threads.push_back(CreateUnwindThread(tid, unwinder, start_unwinding, unwinders)); in TEST_F()
622 for (auto* thread : threads) { in TEST_F()
636 std::vector<std::thread*> threads; in TEST_F() local
642 threads.push_back(thread); in TEST_F()
669 for (auto* thread : threads) { in TEST_F()
686 std::vector<std::thread*> threads; in TEST_F() local
[all …]
|
| /system/memory/libdmabufheap/tests/ |
| D | dmabuf_heap_test.cpp | 89 std::vector<std::thread> threads(NUM_CONCURRENT_THREADS); in TEST_F() local
91 threads[i] = std::thread(&DmaBufHeapConcurrentAccessTest::DoConcurrentAlloc, this); in TEST_F()
94 for (auto& thread : threads) { in TEST_F()
100 std::vector<std::thread> threads(NUM_CONCURRENT_THREADS); in TEST_F() local
102 threads[i] = in TEST_F()
106 for (auto& thread : threads) { in TEST_F()
|
| /system/security/keystore2/selinux/src/ |
| D | concurrency_test.rs | 78 let mut threads: Vec<thread::JoinHandle<()>> = Vec::new(); in test_concurrent_check_access() localVariable
84 threads.push(thread::spawn(move || { in test_concurrent_check_access()
187 for t in threads { in test_concurrent_check_access()
|