/system/core/debuggerd/client/ |
H A D | debuggerd_client_test.cpp | 59 // Spawn a bunch of threads, to make crash_dump take longer. 60 std::vector<std::thread> threads; local 62 threads.emplace_back([]() { 80 // Wait for a bit to let the child spawn all of its threads.
|
/system/core/libsync/ |
H A D | sync_test.c | 79 pthread_t threads[4]; local 119 pthread_create(&threads[i], NULL, sync_thread, &sync_data[i]); 143 pthread_join(threads[i], &val);
|
/system/core/libunwindstack/tests/ |
H A D | MapInfoGetElfTest.cpp | 375 std::vector<std::thread*> threads; local 379 // Create all of the threads and have them do the GetElf at the same time 389 threads.push_back(thread); 393 // Set them all going and wait for the threads to finish. 395 for (auto thread : threads) {
|
H A D | MapInfoGetLoadBiasTest.cpp | 96 std::vector<std::thread*> threads; local 100 // Create all of the threads and have them do the GetLoadBias at the same time 108 threads.push_back(thread); 111 // Set them all going and wait for the threads to finish. 113 for (auto thread : threads) {
|
H A D | UnwindTest.cpp | 314 // Verify that using the same map while unwinding multiple threads at the 323 std::vector<std::thread*> threads; local 340 threads.push_back(thread); 343 for (auto thread : threads) {
|
/system/extras/libfec/ |
H A D | fec_process.cpp | 42 /* launches a maximum number of threads to process a read */ 54 int threads = sysconf(_SC_NPROCESSORS_ONLN); local 56 if (threads < WORK_MIN_THREADS) { 57 threads = WORK_MIN_THREADS; 58 } else if (threads > WORK_MAX_THREADS) { 59 threads = WORK_MAX_THREADS; 65 size_t count_per_thread = fec_div_round_up(blocks, threads) * FEC_BLOCKSIZE; 68 if ((size_t)threads > max_threads) { 69 threads = (int)max_threads; 76 debug("%d threads, [all...] |
/system/core/init/ |
H A D | ueventd_test.cpp | 56 std::vector<std::thread> threads; local 62 threads.emplace_back(std::thread(make_thread_function(file, parameter))); 65 for (auto& thread : threads) { 191 std::vector<std::thread> threads; local 192 std::generate_n(back_inserter(threads), num_threads, 197 for (auto& thread : threads) {
|
/system/core/libmemunreachable/tests/ |
H A D | ThreadCapture_test.cpp | 54 void StartThreads(unsigned int threads, Function&& func) { argument 55 threads_.reserve(threads); 56 tids_.reserve(threads); 57 for (unsigned int i = 0; i < threads; i++) { 58 threads_.emplace_back([&, threads, this]() { 62 if (tids_.size() == threads) { 78 cv_start_.wait(lk, [&] { return tids_.size() == threads; }); 142 const unsigned int threads = GetParam() - 1; local 144 StartThreads(threads, []() {}); 208 const unsigned int threads local [all...] |
/system/extras/iotop/ |
H A D | taskstats.h | 44 int threads() const { return threads_; } function in class:TaskStatistics
|
/system/extras/verity/fec/ |
H A D | image.h | 53 int threads; member in struct:image
|
H A D | image.cpp | 354 int threads = ctx->threads; local 356 if (threads < IMAGE_MIN_THREADS) { 357 threads = sysconf(_SC_NPROCESSORS_ONLN); 359 if (threads < IMAGE_MIN_THREADS) { 360 threads = IMAGE_MIN_THREADS; 366 if ((uint64_t)threads > ctx->rounds) { 367 threads = (int)ctx->rounds; 369 if (threads > IMAGE_MAX_THREADS) { 370 threads [all...] |
/system/core/libmemunreachable/ |
H A D | ThreadCapture.cpp | 82 bool CapturedThreadInfo(ThreadInfoList& threads); 323 bool ThreadCaptureImpl::CapturedThreadInfo(ThreadInfoList& threads) { argument 324 threads.clear(); 331 threads.push_back(t); 359 bool ThreadCapture::CapturedThreadInfo(ThreadInfoList& threads) { argument 360 return impl_->CapturedThreadInfo(threads);
|
H A D | MemUnreachable.cpp | 56 bool CollectAllocations(const allocator::vector<ThreadInfo>& threads, 86 bool MemUnreachable::CollectAllocations(const allocator::vector<ThreadInfo>& threads, argument 114 for (auto thread_it = threads.begin(); thread_it != threads.end(); thread_it++) { 292 // ptrace all the threads 316 // locks as ScopedDisableMalloc. All threads are paused in ptrace, so 365 // releasing all the captured threads.
|
/system/extras/simpleperf/ |
H A D | event_selection_set.h | 111 void AddMonitoredThreads(const std::set<pid_t>& threads) { argument 112 threads_.insert(threads.begin(), threads.end()); 138 // Stop profiling if all monitored processes/threads don't exist.
|
H A D | thread_tree.cpp | 88 // Share maps among threads in the same thread group. 342 std::vector<const ThreadEntry*> threads; local 344 threads.push_back(pair.second.get()); 346 return threads;
|
H A D | cmd_report_sample.cpp | 492 // For the main thread, the call chain ends at __libc_init in libc.so. For other threads, 581 std::vector<const ThreadEntry*> threads = thread_tree_.GetAllThreads(); local 585 std::sort(threads.begin(), threads.end(), compare_thread_id); 586 for (auto& thread : threads) {
|
H A D | event_selection_set.cpp | 452 const std::set<pid_t>& threads) { 459 for (auto& tid : threads) { 460 // tid = -1 means monitoring all threads. 501 // Because threads may exit between PrepareThreads() and OpenEventFilesOnGroup(), and 507 << (pair.first == -1 ? "all threads" 508 : "threads in process " + std::to_string(pair.first)); 852 << (tid == -1 ? "all threads" : "thread " + std::to_string(tid)) 451 PrepareThreads(const std::set<pid_t>& processes, const std::set<pid_t>& threads) argument
|
H A D | cmd_record.cpp | 98 "Select monitored threads:\n" 107 "-t tid1,tid2,... Record events on existing threads. Mutually exclusive with -a.\n" 121 "--trace-offcpu Generate samples when threads are scheduled off cpu.\n" 164 "--no-inherit Don't record created child threads/processes.\n" 401 << "No threads to monitor. Try `simpleperf help record` for help"; 787 LOG(ERROR) << "Record system wide and existing processes/threads can't be " 941 // Decide which processes and threads to dump. 942 // For system_wide profiling, dump all threads. 967 // Dump each process and its threads. 994 std::vector<pid_t> threads local [all...] |
/system/extras/tests/memtest/ |
H A D | bandwidth.cpp | 202 // all of the threads are running at this point. 259 pthread_t threads[num_threads]; local 265 rc = pthread_create(&threads[i], NULL, runBandwidthThread, 273 // Kick start the threads. 276 // Let the threads run. 279 // Stop the threads. 282 // Wait for the threads to complete. 284 rc = pthread_join(threads[i], NULL); 359 printf("Running %d threads\n", num_threads);
|
/system/core/debuggerd/ |
H A D | crash_dump.cpp | 379 // Note: processes with many threads and minidebug-info can take a bit to 394 // the threads, fetch their registers and associated information, and then 396 std::set<pid_t> threads; local 397 if (!android::procinfo::GetProcessTids(g_target_thread, &threads)) { 398 PLOG(FATAL) << "failed to get process threads"; 407 for (pid_t thread : threads) { 471 // Detach from all of our attached threads before resuming.
|
/system/core/libsync/tests/ |
H A D | sync_test.cpp | 492 // Use a single timeline to synchronize two threads 516 // make sure the threads did not trample on one another. 528 vector<thread> threads; local 531 // Producer threads run this lambda. 558 threads.push_back(thread{threadMain, i}); 583 // Release the producer threads. 587 for_each(begin(threads), end(threads), [](thread& thread) { thread.join(); });
|
/system/netd/tests/ |
H A D | dns_tls_test.cpp | 631 std::vector<std::thread> threads; local 634 threads.emplace_back([key, i] (DnsTlsDispatcher* dispatcher) { 648 for (auto& thread : threads) {
|
/system/core/debuggerd/libdebuggerd/ |
H A D | tombstone.cpp | 606 std::map<pid_t, ThreadInfo> threads; local 607 threads[gettid()] = ThreadInfo{ 624 threads, tid, abort_msg_address, nullptr, nullptr); local 628 const std::map<pid_t, ThreadInfo>& threads, pid_t target_thread, 643 auto it = threads.find(target_thread); 644 if (it == threads.end()) { 653 for (auto& [tid, thread_info] : threads) { 627 engrave_tombstone(unique_fd output_fd, BacktraceMap* map, Memory* process_memory, const std::map<pid_t, ThreadInfo>& threads, pid_t target_thread, uint64_t abort_msg_address, OpenFilesList* open_files, std::string* amfd_data) argument
|
/system/core/adb/ |
H A D | 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); 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,
|
/system/core/libbacktrace/ |
H A D | backtrace_test.cpp | 51 #include <cutils/threads.h> 69 // Number of simultaneous threads running in our forked process. 463 // Create a process with multiple threads and dump all of the threads. 469 static void GetThreads(pid_t pid, std::vector<pid_t>* threads) { argument 481 threads->push_back(tid); 501 // Check to see that all of the threads are running before unwinding. 502 std::vector<pid_t> threads; local 506 threads.clear(); 507 GetThreads(pid, &threads); [all...] |