Searched refs:group_leader_ (Results 1 – 4 of 4) sorted by relevance
37 group_leader_ = (task_name == config.experimental().collective_group_leader()) in RpcCollectiveExecutorMgr()70 if (group_leader_.empty()) { in RefreshStepIdSequenceAsync()83 WorkerInterface* wi = worker_cache_->CreateWorker(group_leader_); in RefreshStepIdSequenceAsync()92 << group_leader_; in RefreshStepIdSequenceAsync()106 if (!group_leader_.empty()) { in GetStepSequenceAsync()
87 group_leader_(task_name == config.experimental().collective_group_leader() in CollectiveParamResolverDistributed()257 << " dev: " << device << " is_leader=" << (group_leader_.empty()); in CompleteGroupDistributed()258 if (group_leader_.empty()) { in CompleteGroupDistributed()264 cp->group, device, cancel_mgr, group_leader_, worker_cache_); in CompleteGroupDistributed()365 if (group_leader_.empty()) { in CompleteInstanceDistributed()373 group_leader_, worker_cache_); in CompleteInstanceDistributed()
63 string group_leader_; variable
86 const string group_leader_; variable