Home
last modified time | relevance | path

Searched refs:targets_ (Results 1 – 9 of 9) sorted by relevance

/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_testlib.cc40 ret->targets_.resize(n); in MakeTestCluster()
45 ret->targets_[i] = strings::StrCat("localhost:", port[i]); in MakeTestCluster()
49 absl::StrJoin(ret->targets_, ";")); in MakeTestCluster()
79 options_copy.target = strings::StrCat("grpc://", ret->targets_[0]); in MakeTestCluster()
Dgrpc_testlib.h61 const std::vector<string>& targets() const { return targets_; } in targets()
70 std::vector<string> targets_; variable
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/weighted_target/
Dweighted_target.cc204 std::map<std::string, OrphanablePtr<WeightedChild>> targets_; member in grpc_core::__anon33b6bffa0111::WeightedTargetLb
261 targets_.clear(); in ShutdownLocked()
265 for (auto& p : targets_) p.second->ResetBackoffLocked(); in ResetBackoffLocked()
276 for (const auto& p : targets_) { in UpdateLocked()
291 auto it = targets_.find(name); in UpdateLocked()
292 if (it == targets_.end()) { in UpdateLocked()
293 targets_.emplace(name, MakeOrphanable<WeightedChild>( in UpdateLocked()
303 targets_[name]->UpdateLocked(config, std::move(address_map[name]), in UpdateLocked()
327 for (const auto& p : targets_) { in UpdateStateLocked()
581 weighted_target_policy_->targets_.erase(name_); in OnDelayedRemovalTimerLocked()
/external/tensorflow/tensorflow/core/distributed_runtime/
Dmaster.cc150 *workers = finder.targets_; in GetRemoteWorkers()
177 std::swap(workers, targets_); in DeviceFinder()
224 targets_.push_back(name); in DeviceFinder()
228 seen_targets_.assign(targets_.size(), false); in DeviceFinder()
238 num_pending_ = targets_.size(); in Start()
246 for (size_t i = 0; i < targets_.size(); ++i) { in Start()
249 NewRemoteDevices(env_->env, worker_cache_, targets_[i], in Start()
266 for (size_t i = 0; i < targets_.size(); ++i) { in Wait()
270 << targets_[i]; in Wait()
307 std::vector<string> targets_; member in tensorflow::DeviceFinder
[all …]
Dmessage_wrappers.cc82 size_t InMemoryRunStepRequest::num_targets() const { return targets_.size(); } in num_targets()
84 return targets_[i]; in target_name()
87 targets_.push_back(name); in add_target()
Dmessage_wrappers.h151 gtl::InlinedVector<string, 4> targets_; variable
/external/tensorflow/tensorflow/c/
Dc_test_util.cc495 targets_.clear(); in SetTargets()
497 targets_.emplace_back(t); in SetTargets()
517 TF_Operation* const* targets_ptr = targets_.empty() ? nullptr : &targets_[0]; in Run()
521 targets_.size(), nullptr, s); in Run()
Dc_test_util.h162 std::vector<TF_Operation*> targets_; variable
/external/llvm-project/compiler-rt/lib/sanitizer_common/
Dsanitizer_syscalls_netbsd.inc2317 PRE_SYSCALL(_lwp_unpark_all)(void *targets_, long long ntargets_, void *hint_) {
2318 if (targets_) {
2319 PRE_READ(targets_, ntargets_ * sizeof(__sanitizer_lwpid_t));
2323 (long long res, void *targets_, long long ntargets_, void *hint_) {}