/external/google-breakpad/src/client/linux/minidump_writer/ |
D | linux_ptrace_dumper.cc | 157 if (index >= threads_.size()) in GetThreadInfoByIndex() 160 pid_t tid = threads_[index]; in GetThreadInfoByIndex() 281 for (size_t i = 0; i < threads_.size(); ++i) { in ThreadsSuspend() 282 if (!SuspendThread(threads_[i])) { in ThreadsSuspend() 286 if (i < threads_.size() - 1) { in ThreadsSuspend() 287 my_memmove(&threads_[i], &threads_[i + 1], in ThreadsSuspend() 288 (threads_.size() - i - 1) * sizeof(threads_[i])); in ThreadsSuspend() 290 threads_.resize(threads_.size() - 1); in ThreadsSuspend() 295 return threads_.size() > 0; in ThreadsSuspend() 302 for (size_t i = 0; i < threads_.size(); ++i) in ThreadsResume() [all …]
|
D | linux_dumper.h | 91 const wasteful_vector<pid_t> &threads() { return threads_; } in threads() 178 wasteful_vector<pid_t> threads_; variable
|
D | linux_core_dumper.cc | 211 threads_.push_back(pid); in EnumerateThreads()
|
/external/compiler-rt/lib/sanitizer_common/ |
D | sanitizer_thread_registry.cc | 102 threads_ = (ThreadContextBase **)MmapOrDie(max_threads_ * sizeof(threads_[0]), in ThreadRegistry() 132 threads_[tid] = tctx; in CreateThread() 161 ThreadContextBase *tctx = threads_[tid]; in RunCallbackForEachThreadLocked() 171 ThreadContextBase *tctx = threads_[tid]; in FindThread() 182 ThreadContextBase *tctx = threads_[tid]; in FindThreadContextLocked() 203 ThreadContextBase *tctx = threads_[tid]; in SetThreadName() 212 ThreadContextBase *tctx = threads_[tid]; in SetThreadNameByUserId() 224 ThreadContextBase *tctx = threads_[tid]; in DetachThread() 242 ThreadContextBase *tctx = threads_[tid]; in JoinThread() 259 ThreadContextBase *tctx = threads_[tid]; in FinishThread() [all …]
|
D | sanitizer_thread_registry.h | 93 return threads_[tid]; in GetThreadLocked() 136 ThreadContextBase **threads_; // Array of thread contexts is leaked. variable
|
/external/libchrome/base/threading/ |
D | simple_thread.cc | 117 DCHECK(threads_.empty()); in ~DelegateSimpleThreadPool() 123 DCHECK(threads_.empty()) << "Start() called with outstanding threads."; in Start() 127 threads_.push_back(thread); in Start() 132 DCHECK(!threads_.empty()) << "JoinAll() called with no outstanding threads."; in JoinAll() 139 threads_[i]->Join(); in JoinAll() 140 delete threads_[i]; in JoinAll() 142 threads_.clear(); in JoinAll()
|
D | simple_thread.h | 222 std::vector<DelegateSimpleThread*> threads_; variable
|
/external/eigen/unsupported/Eigen/CXX11/src/ThreadPool/ |
D | NonBlockingThreadPool.h | 24 threads_(num_threads), in env_() 58 threads_.push_back(env_.CreateThread([this, i]() { WorkerLoop(i); })); in env_() 70 for (size_t i = 0; i < threads_.size(); i++) delete threads_[i]; in ~NonBlockingThreadPoolTempl() local 71 for (size_t i = 0; i < threads_.size(); i++) delete queues_[i]; in ~NonBlockingThreadPoolTempl() 101 return static_cast<int>(threads_.size()); in NumThreads() 125 MaxSizeVector<Thread*> threads_; variable 211 if (done_ && blocked_ == threads_.size()) { in WaitForWork()
|
D | SimpleThreadPool.h | 25 : env_(env), threads_(num_threads), waiters_(num_threads) { in env_() 27 threads_.push_back(env.CreateThread([this, i]() { WorkerLoop(i); })); in env_() 51 for (auto t : threads_) { in ~SimpleThreadPoolTempl() 73 return static_cast<int>(threads_.size()); in NumThreads() 138 MaxSizeVector<Thread*> threads_; // All threads variable
|
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/ |
D | grpc_eager_client.cc | 65 : next_round_robin_assignment_(0), cache_(cache), threads_(4) {} in GrpcEagerClientCache() 67 ~GrpcEagerClientCache() override { threads_.clear(); } in ~GrpcEagerClientCache() 75 shared, threads_[AssignClientToThread(target)].completion_queue())); in GetClient() 97 target, (next_round_robin_assignment_++) % threads_.size())) in AssignClientToThread() 132 std::vector<GrpcEagerClientThread> threads_; member in tensorflow::eager::__anon22cba6b30111::GrpcEagerClientCache
|
/external/grpc-grpc/test/cpp/qps/ |
D | client.h | 161 std::vector<Histogram> to_merge(threads_.size()); in Mark() 162 std::vector<StatusHistogram> to_merge_status(threads_.size()); in Mark() 164 for (size_t i = 0; i < threads_.size(); i++) { in Mark() 165 threads_[i]->BeginSwap(&to_merge[i], &to_merge_status[i]); in Mark() 169 for (size_t i = 0; i < threads_.size(); i++) { in Mark() 177 for (size_t i = 0; i < threads_.size(); i++) { in Mark() 178 threads_[i]->MergeStatsInto(&latencies, &statuses); in Mark() 188 threads_[0]->GetMedianPerIntervalList(); in Mark() 189 gpr_log(GPR_INFO, "Num threads: %ld", threads_.size()); in Mark() 246 threads_.emplace_back(new Thread(this, i)); in StartThreads() [all …]
|
D | server_async.cc | 158 threads_.emplace_back(&AsyncQpsServerTest::ThreadFunc, this, i); in AsyncQpsServerTest() 170 for (auto thr = threads_.begin(); thr != threads_.end(); thr++) { in ~AsyncQpsServerTest() 519 std::vector<std::thread> threads_; member in grpc::testing::AsyncQpsServerTest
|
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
D | grpc_worker_cache.cc | 45 threads_(kGrpcWorkerCacheThreadCount), in GrpcWorkerCache() 60 threads_.clear(); // Blocks until threads exit. in ~GrpcWorkerCache() 79 channel, threads_[AssignWorkerToThread(target)].completion_queue(), in CreateWorker() 139 target, (next_round_robin_assignment_++) % threads_.size())) in AssignWorkerToThread() 149 std::vector<GrpcWorkerCacheThread> threads_; member in tensorflow::__anonab8e586b0111::GrpcWorkerCache
|
D | grpc_worker_service.cc | 387 threads_.emplace_back( in GrpcWorkerService() 404 for (auto& worker_thread : threads_) { in Shutdown() 412 for (auto& worker_thread : threads_) { in HandleRPCsLoop() 415 for (auto& worker_thread : threads_) { in HandleRPCsLoop() 422 std::vector<std::unique_ptr<GrpcWorkerServiceThread>> threads_; member in tensorflow::__anonf5bfbaa80111::GrpcWorkerService
|
/external/perfetto/src/trace_processor/ |
D | slice_tracker.cc | 54 MaybeCloseStack(timestamp, &threads_[utid]); in Begin() 64 MaybeCloseStack(timestamp, &threads_[utid]); in Scoped() 73 auto* stack = &threads_[utid]; in StartSlice() 116 MaybeCloseStack(timestamp, &threads_[utid]); in End() 118 const auto& stack = threads_[utid]; in End() 140 threads_[utid].pop_back(); in CompleteSlice()
|
D | slice_tracker.h | 75 std::unordered_map<UniqueTid, SlicesStack> threads_; variable
|
/external/google-breakpad/src/processor/ |
D | process_state.cc | 54 for (vector<CallStack *>::const_iterator iterator = threads_.begin(); in Clear() 55 iterator != threads_.end(); in Clear() 59 threads_.clear(); in Clear()
|
D | microdump_processor.cc | 91 process_state->threads_.push_back(stack.release()); in Process()
|
D | minidump.cc | 1542 threads_(NULL), in MinidumpThreadList() 1548 delete threads_; in ~MinidumpThreadList() 1555 delete threads_; in Read() 1556 threads_ = NULL; in Read() 1640 threads_ = threads.release(); in Read() 1663 return &(*threads_)[index]; in GetThreadAtIndex() 1689 (*threads_)[thread_index].Print(); in Print()
|
D | minidump_processor.cc | 206 process_state->requesting_thread_ = process_state->threads_.size(); in Process() 267 process_state->threads_.push_back(stack.release()); in Process()
|
/external/libvpx/libvpx/test/ |
D | encode_perf_test.cc | 62 encoding_mode_(GET_PARAM(1)), speed_(0), threads_(1) {} in VP9EncodePerfTest() 82 cfg_.g_threads = threads_; in SetUp() 114 void set_threads(unsigned int threads) { threads_ = threads; } in set_threads() 121 unsigned int threads_; member in __anon5ab2061e0111::VP9EncodePerfTest
|
D | vp9_ethread_test.cc | 227 tiles_(GET_PARAM(3)), threads_(GET_PARAM(4)), in VPxEncoderThreadTest() 309 int threads_; member in __anon34e9fbbf0111::VPxEncoderThreadTest 334 cfg_.g_threads = threads_; in TEST_P() 368 cfg_.g_threads = threads_; in TEST_P() 386 cfg_.g_threads = threads_; in TEST_P()
|
/external/libaom/libaom/test/ |
D | encode_perf_test.cc | 64 encoding_mode_(GET_PARAM(1)), speed_(0), threads_(1) {} in AV1EncodePerfTest() 83 cfg_.g_threads = threads_; in SetUp() 115 void set_threads(unsigned int threads) { threads_ = threads; } in set_threads() 122 unsigned int threads_; member in __anon79b12bfc0111::AV1EncodePerfTest
|
/external/google-breakpad/src/google_breakpad/processor/ |
D | process_state.h | 106 const vector<CallStack*>* threads() const { return &threads_; } in threads() 165 vector<CallStack*> threads_; variable
|
/external/tensorflow/tensorflow/core/framework/ |
D | rendezvous_test.cc | 68 LocalRendezvousTest() : threads_(Env::Default(), "test", 16) { in LocalRendezvousTest() 75 threads_.Schedule(std::move(fn)); in SchedClosure() 81 thread::ThreadPool threads_; member in tensorflow::__anon2f0f779b0111::LocalRendezvousTest
|