| /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()
|
| D | Threads.cpp | 110 for (size_t i = 0, threads = 0; threads < num_threads_; i++) { in WaitForAllToQuiesce() local
113 threads++; in WaitForAllToQuiesce()
|
| /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/sepolicy/prebuilts/api/26.0/public/ |
| D | performanced.te | 10 # Access /proc to validate we're only affecting threads in the same thread group.
11 # Performanced also shields unbound kernel threads. It scans every task in the
12 # root cpu set, but only affects the kernel threads.
|
| /system/sepolicy/prebuilts/api/27.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/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/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/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/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/tools/hidl/test/lazy_test/ |
| D | hidl_lazy_test.cpp | 141 std::vector<std::thread> threads(NUM_CONCURRENT_THREADS); in TEST_F() local
142 for (size_t i = 0; i < threads.size(); i++) { in TEST_F()
144 threads[i] = std::thread(testWithTimes, threadWaitTimes[i], instance); in TEST_F()
147 for (auto& thread : threads) { in TEST_F()
|
| /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()
|
| D | README.md | 61 4. *Collection process*: All threads in the original process are paused with `ptrace()`.
63 …6. *Original process*: Allocations are re-enabled using `malloc_enable()`, but all threads are sti…
65 8. Collection process releases all threads from `ptrace` and exits
66 …9. *Original process*: All threads continue, the thread that called `GetUnreachableMemory()` block…
79 - `ThreadCapture.cpp`: Pauses threads in the main process and collects register contents.
90 - `malloc enable()`: re-enable allocations in all threads.
|
| /system/extras/simpleperf/app_api/cpp/ |
| D | simpleperf.cpp | 46 std::vector<pid_t> threads; member in simpleperf::RecordOptionsImpl
79 RecordOptions& RecordOptions::SetSampleThreads(const std::vector<pid_t> &threads) { in SetSampleThreads() argument
80 impl_->threads = threads; in SetSampleThreads()
127 if (impl_->threads.empty()) { in ToRecordArgs()
131 os << *(impl_->threads.begin()); in ToRecordArgs()
132 for (auto it = std::next(impl_->threads.begin()); it != impl_->threads.end(); ++it) { in ToRecordArgs()
|
| /system/core/libunwindstack/tests/ |
| D | MapInfoGetLoadBiasTest.cpp | 96 std::vector<std::thread*> threads; in MultipleThreadTest() local
108 threads.push_back(thread); in MultipleThreadTest()
113 for (auto thread : threads) { in MultipleThreadTest()
|
| /system/extras/simpleperf/scripts/ |
| D | report_html.py | 91 def threads(self): member in EventScope
93 for thread in process.threads.values():
99 for thread in process.threads.values():
110 self.threads = {} # map from tid to ThreadScope
113 thread = self.threads.get(tid)
115 thread = self.threads[tid] = ThreadScope(tid)
125 threads = sorted(self.threads.values(), key=lambda a: a.event_count, reverse=True)
127 for thread in threads]
132 thread_list = list(self.threads.values()) + list(process.threads.values())
140 self.threads = {}
[all …]
|
| /system/extras/simpleperf/ |
| D | record_lib_interface.cpp | 84 bool MonitorThreadsInCurrentProcess(const std::vector<pid_t>& threads) override { in MonitorThreadsInCurrentProcess() argument
87 for (auto& tid : threads) { in MonitorThreadsInCurrentProcess()
93 threads_.insert(threads.begin(), threads.end()); in MonitorThreadsInCurrentProcess()
|
| /system/tools/aidl/tests/lazy_test/ |
| D | main.cpp | 141 std::vector<std::thread> threads(NUM_CONCURRENT_THREADS); in testConcurrentThreadsWithDelays() local
142 for (size_t i = 0; i < threads.size(); i++) { in testConcurrentThreadsWithDelays()
143 threads.at(i) = std::thread(testWithTimes, threadWaitTimes.at(i), delayBeforeGet); in testConcurrentThreadsWithDelays()
146 for (auto& thread : threads) { in testConcurrentThreadsWithDelays()
|
| /system/extras/simpleperf/scripts/inferno/ |
| D | data_types.py | 56 self.threads = {}
67 thread = self.threads.get(tid)
69 thread = self.threads[tid] = Thread(tid, pid)
|
| D | inferno.py | 139 main_threads = [thread for thread in process.threads.values() if thread.tid == thread.pid]
144 for thread in process.threads.values():
180 thread_entry = '' if args.one_flamegraph else ('Threads: %d<br/>' % len(process.threads))
219 for thread in sorted(process.threads.values(), key=lambda x: x.num_events, reverse=True):
234 for thread in process.threads.values():
|
| /system/core/debuggerd/client/ |
| D | debuggerd_client_test.cpp | 60 std::vector<std::thread> threads; in TEST() local
62 threads.emplace_back([]() { in TEST()
|
| /system/extras/simpleperf/app_api/java/com/android/simpleperf/ |
| D | RecordOptions.java | 91 public RecordOptions setSampleThreads(@NonNull List<Integer> threads) { in setSampleThreads() argument
92 mThreads.addAll(threads); in setSampleThreads()
|