Searched refs:CreateWorker (Results 1 – 17 of 17) sorted by relevance
47 virtual WorkerInterface* CreateWorker(const string& target) { in CreateWorker() function48 return wrapped_->CreateWorker(target); in CreateWorker()
43 WorkerInterface* CreateWorker(const string& target) override { in CreateWorker() function in tensorflow::__anond5aa72bc0111::WorkerFreeListCache50 state.worker = wrapped_->CreateWorker(target); in CreateWorker()
49 virtual WorkerInterface* CreateWorker(const string& target) = 0;
35 wi_(wc_->CreateWorker(remote_worker_)) {} in CancellableCall()
68 std::unique_ptr<WorkerInterface, decltype(deleter)> rwi(CreateWorker(task), in RefreshDeviceStatus()
56 wi_ = worker_cache_->CreateWorker(remote_name_); in RemoteDeviceTest()
59 WorkerInterface* wi = worker_cache->CreateWorker(worker_name); in NewRemoteDevices()
100 WorkerInterface* worker = worker_cache_->CreateWorker(task); in RefreshRemoteAttributes()
83 WorkerInterface* wi = worker_cache_->CreateWorker(group_leader_); in RefreshStepIdSequenceAsync()
155 WorkerInterface* CreateWorker(const string& target) override { in CreateWorker() function
127 worker_session_->worker_cache->CreateWorker(options.target); in Instantiate()
446 part->worker = worker_cache_->CreateWorker(part->name); in DoRegisterPartitions()1266 workers[i].worker = worker_cache->CreateWorker(worker_names[i]); in CreateWorkerSessions()1348 workers[i].worker = worker_cache->CreateWorker(worker_names[i]); in DeleteWorkerSessions()
632 auto worker = env_->worker_cache->CreateWorker(worker_name); in CleanupWorkers()
72 WorkerInterface* CreateWorker(const string& target) override { in CreateWorker() function in tensorflow::__anonab8e586b0111::GrpcWorkerCache
55 WorkerInterface* CreateWorker(const string& target) override { in CreateWorker() function in tensorflow::__anonfe79bbb00111::DummyWorkerCache
235 WorkerInterface* rwi = sess->worker_cache->CreateWorker(call->src_worker_); in RecvFromRemoteAsync()
145 WorkerInterface* rwi = sess->worker_cache->CreateWorker(src_worker); in RecvFromRemoteAsync()