Searched defs:threads (Results 1 - 25 of 26) sorted by relevance

12

/system/core/debuggerd/client/
H A Ddebuggerd_client_test.cpp59 // 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 Dsync_test.c79 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 DMapInfoGetElfTest.cpp375 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 DMapInfoGetLoadBiasTest.cpp96 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 DUnwindTest.cpp314 // 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 Dfec_process.cpp42 /* 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 Dueventd_test.cpp56 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 DThreadCapture_test.cpp54 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 Dtaskstats.h44 int threads() const { return threads_; } function in class:TaskStatistics
/system/extras/verity/fec/
H A Dimage.h53 int threads; member in struct:image
H A Dimage.cpp354 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 DThreadCapture.cpp82 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 DMemUnreachable.cpp56 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 Devent_selection_set.h111 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 Dthread_tree.cpp88 // 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 Dcmd_report_sample.cpp492 // 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 Devent_selection_set.cpp452 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 Dcmd_record.cpp98 "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 Dbandwidth.cpp202 // 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 Dcrash_dump.cpp379 // 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 Dsync_test.cpp492 // 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 Ddns_tls_test.cpp631 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 Dtombstone.cpp606 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 Dadb.cpp796 // 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 Dbacktrace_test.cpp51 #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...]

Completed in 510 milliseconds

12