Searched refs:task_name_ (Results 1 – 8 of 8) sorted by relevance
36 task_name_(std::move(task_name)) {} in CollectiveRemoteAccessDistributed()60 string task_name_; variable
38 task_name_(task_name) { in RpcCollectiveExecutorMgr()54 task_name_); in Create()
44 const string task_name_;
63 const string task_name_; variable
192 if (peer_task == task_name_) { in CheckPeerHealth()
45 task_name_ = "/job:localhost/replica:0/task:0"; in CollectiveParamResolverLocalTest()49 TF_CHECK_OK(DeviceFactory::AddDevices(options, task_name_, &devices)); in CollectiveParamResolverLocalTest()58 drl_.get(), task_name_)); in ResetParamResolver()85 string task_name_; member in tensorflow::CollectiveParamResolverLocalTest
191 string task_name_; variable
47 task_name_(task_name) {} in CollectiveParamResolverLocal()563 CompleteTaskIsLocal(task_name_, ir->shared); in InitInstanceSharedParams()750 CompleteTaskIsLocal(task_name_, cp); in CompleteInstanceFromInitializedIRec()