| /external/libchrome/base/task_scheduler/ |
| D | scheduler_worker_pool_impl.cc | 212 DCHECK(workers_.empty()); in Start()
232 workers_.reserve(num_initial_workers); in Start()
257 DCHECK(workers_.empty()); in ~SchedulerWorkerPoolImpl()
300 WaitForWorkersIdleLockRequiredForTesting(workers_.size()); in WaitForAllWorkersIdleForTesting()
320 decltype(workers_) workers_copy; in JoinForTesting()
324 DCHECK_GT(workers_.size(), size_t(0)) << "Joined an unstarted worker pool."; in JoinForTesting()
333 workers_copy = workers_; in JoinForTesting()
339 DCHECK(workers_ == workers_copy); in JoinForTesting()
341 workers_.clear(); in JoinForTesting()
346 return workers_.size(); in NumberOfWorkersForTesting()
[all …]
|
| D | scheduler_single_thread_task_runner_manager.cc | 418 decltype(workers_) workers_to_start; in Start()
422 workers_to_start = workers_; in Start()
512 decltype(workers_) local_workers; in JoinForTesting()
515 local_workers = std::move(workers_); in JoinForTesting()
523 DCHECK(workers_.empty()) in JoinForTesting()
525 workers_ = std::move(local_workers); in JoinForTesting()
577 workers_.emplace_back(std::move(worker)); in CreateAndRegisterSchedulerWorker()
578 return workers_.back().get(); in CreateAndRegisterSchedulerWorker()
608 if (workers_.empty()) in UnregisterSchedulerWorker()
612 std::find_if(workers_.begin(), workers_.end(), in UnregisterSchedulerWorker()
[all …]
|
| D | scheduler_single_thread_task_runner_manager.h | 130 std::vector<scoped_refptr<SchedulerWorker>> workers_; variable
|
| D | scheduler_worker_pool_impl.h | 249 std::vector<scoped_refptr<SchedulerWorker>> workers_; variable
|
| /external/tensorflow/tensorflow/core/kernels/data/experimental/ |
| D | parallel_interleave_dataset_op.cc | 279 workers_(dataset()->num_threads()), in Iterator()
313 WorkerState* current_worker = &workers_[current_worker_index]; in GetNextInternal()
393 workers_[interleave_indices_[next_index_]].cond_var.wait(l); in GetNextInternal()
428 writer->WriteScalar(prefix(), kWorkersSize, workers_.size())); in SaveInternal()
429 for (int i = 0; i < workers_.size(); ++i) { in SaveInternal()
652 for (auto& worker : workers_) { in CancelThreads()
669 workers_[i].SetInputs(s, std::move(args)); in EnsureWorkerThreadsStarted()
712 workers_[thread_index].cond_var.notify_all(); in WorkerThread()
749 while (!cancelled_ && !workers_[thread_index].is_producing) { in WorkerThread()
751 workers_[thread_index].cond_var.wait(l); in WorkerThread()
[all …]
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | test_utils.h | 128 workers_[target] = wi; in AddWorker()
137 for (auto it : workers_) { in ListWorkers()
145 for (auto it : workers_) { in ListWorkersInJob()
156 auto it = workers_.find(target); in GetOrCreateWorker()
157 if (it != workers_.end()) { in GetOrCreateWorker()
192 std::unordered_map<string, WorkerInterface*> workers_;
|
| D | worker_session.cc | 36 for (auto& p : workers_) { in ~WorkerFreeListCache()
52 auto p = workers_.find(target); in GetOrCreateWorker()
53 if (p != workers_.end()) { in GetOrCreateWorker()
59 workers_.insert(std::make_pair(target, state)); in GetOrCreateWorker()
102 std::unordered_map<string, WorkerState> workers_ TF_GUARDED_BY(mu_);
|
| D | collective_rma_distributed_test.cc | 158 auto it = workers_.find(task_name); in GetDeviceLocalityAsync()
159 if (it == workers_.end()) { in GetDeviceLocalityAsync()
195 for (FakeWorker* w : workers_) { in ~CollRMADistTest()
258 workers_.push_back(fw); in DefineWorker()
289 std::vector<FakeWorker*> workers_; member in tensorflow::__anon9c39ea670111::CollRMADistTest
307 FakeWorker* wi = workers_[1]; in TEST_F()
345 FakeWorker* wi = workers_[1]; in TEST_F()
408 FakeWorker* wi = workers_[1]; in TEST_F()
|
| D | collective_param_resolver_distributed_test.cc | 105 auto it = workers_.find(task_name); in GetDeviceLocalityAsync()
106 if (it == workers_.end()) { in GetDeviceLocalityAsync()
172 workers_[worker_name] = absl::make_unique<FakeWorker>( in DefineWorker()
175 wc_.AddWorker(worker_name, workers_[worker_name].get()); in DefineWorker()
316 absl::flat_hash_map<string, std::unique_ptr<FakeWorker>> workers_; member in tensorflow::__anondb24ef490111::DeviceResDistTest
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/poller/ |
| D | eventmanager_libuv.cc | 37 workers_.emplace_back( in LibuvEventManager()
41 workers_.back().Start(); in LibuvEventManager()
47 for (auto& th : workers_) { in ~LibuvEventManager()
|
| D | eventmanager_libuv.h | 79 std::vector<grpc_core::Thread> workers_; variable
|
| /external/perfetto/test/stress_test/ |
| D | stress_producer.cc | 76 std::list<Worker> workers_; member in perfetto::__anon2202aaec0111::StressTestDataSource
82 workers_.emplace_back(i); in OnSetup()
87 for (auto& worker : workers_) in OnStart()
93 for (auto& worker : workers_) in OnStop()
95 workers_.clear(); in OnStop()
|
| /external/gemmlowp/internal/ |
| D | multi_thread_gemm.h | 370 for (auto w : workers_) { in ~WorkersPool()
383 assert(workers_count <= workers_.size()); in Execute()
386 workers_[i]->StartWork(&tasks[i]); in Execute()
403 assert(workers_count <= workers_.size()); in LegacyExecuteAndDestroyTasks()
406 workers_[i]->StartWork(tasks[i]); in LegacyExecuteAndDestroyTasks()
429 if (workers_.size() >= workers_count) { in CreateWorkers()
432 counter_to_decrement_when_ready_.Reset(workers_count - workers_.size()); in CreateWorkers()
433 while (workers_.size() < workers_count) { in CreateWorkers()
434 workers_.push_back(new Worker(&counter_to_decrement_when_ready_)); in CreateWorkers()
444 std::vector<Worker*> workers_; variable
|
| /external/tensorflow/tensorflow/core/data/service/ |
| D | dispatcher_state.cc | 82 DCHECK(!workers_.contains(address)); in RegisterWorker()
83 workers_[address] = in RegisterWorker()
242 auto it = workers_.find(address); in WorkerFromAddress()
243 if (it == workers_.end()) { in WorkerFromAddress()
253 workers.reserve(workers_.size()); in ListWorkers()
254 for (const auto& it : workers_) { in ListWorkers()
|
| D | test_cluster.cc | 55 workers_.reserve(num_workers_); in Initialize()
73 workers_.push_back(std::move(worker)); in AddWorker()
|
| D | test_cluster.h | 47 std::vector<std::unique_ptr<WorkerGrpcDataServer>> workers_; variable
|
| D | dispatcher_state.h | 232 absl::flat_hash_map<std::string, std::shared_ptr<Worker>> workers_; variable
|
| /external/tensorflow/tensorflow/core/kernels/ |
| D | quantization_utils.h | 913 : workers_(workers) {} in TensorflowGemmlowpWorkersPool()
924 assert(workers_ != nullptr); in Execute()
927 workers_->Schedule([this, task]() { in Execute()
943 thread::ThreadPool* const workers_;
|