| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | rpc_rendezvous_mgr.cc | 118 void ReleaseWorker(WorkerCacheInterface* worker_cache) { in ReleaseWorker() function in tensorflow::__anondc8fdab30111::RpcRecvTensorCall
121 worker_cache->ReleaseWorker(src_worker_, wi_); in ReleaseWorker()
242 sess->worker_cache()->ReleaseWorker(call->src_worker_, rwi); in RecvFromRemoteAsync()
260 call->ReleaseWorker(sess->worker_cache()); in RecvFromRemoteAsync()
277 call->ReleaseWorker(session()->worker_cache()); in RecvFromRemoteAsync()
|
| D | grpc_worker_cache.cc | 78 void ReleaseWorker(const string& target, WorkerInterface* worker) override { in ReleaseWorker() function in tensorflow::__anona5d03dad0111::GrpcWorkerCache
83 WorkerCacheInterface::ReleaseWorker(target, worker); in ReleaseWorker()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | worker_cache_wrapper.h | 53 void ReleaseWorker(const string& target, WorkerInterface* worker) override { in ReleaseWorker() function
54 return wrapped_->ReleaseWorker(target, worker); in ReleaseWorker()
|
| D | worker_session.cc | 37 wrapped_->ReleaseWorker(p.first, p.second.worker); in ~WorkerFreeListCache()
69 void ReleaseWorker(const string& target, WorkerInterface* worker) override { in ReleaseWorker() function in tensorflow::__anond7fc9e3e0111::WorkerFreeListCache
|
| D | worker_cache.h | 54 virtual void ReleaseWorker(const string& target, WorkerInterface* worker) { in ReleaseWorker() function
|
| D | cancellable_call.h | 37 virtual ~CancellableCall() { wc_->ReleaseWorker(remote_worker_, wi_); } in ~CancellableCall()
|
| D | worker_cache_partial.cc | 66 ReleaseWorker(task, wi); in RefreshDeviceStatus()
|
| D | remote_device_test.cc | 60 worker_cache_->ReleaseWorker(remote_name_, wi_); in ~RemoteDeviceTest()
|
| D | remote_device.cc | 93 worker_cache->ReleaseWorker(worker_name, wi); in NewRemoteDevices()
|
| D | device_resolver_distributed.cc | 112 worker_cache_->ReleaseWorker(task, worker); in RefreshRemoteAttributes()
|
| D | test_utils.h | 163 void ReleaseWorker(const string& target, WorkerInterface* worker) override {} in ReleaseWorker() function
|
| D | master_session.cc | 105 worker_cache_->ReleaseWorker(part.name, part.worker); in ~ReffedClientGraph()
456 worker_cache_->ReleaseWorker(part.name, part.worker); in DoRegisterPartitions()
1118 worker_cache->ReleaseWorker(name, w); in DeregisterPartitions()
1311 worker_cache->ReleaseWorker(*worker_group.name, worker_group.worker); in CreateWorkerSessions()
1409 worker_cache->ReleaseWorker(*worker_group.name, worker_group.worker); in DeleteWorkerSessions()
|
| D | cluster_function_library_runtime.cc | 176 worker_session_->worker_cache()->ReleaseWorker(function_data.target, in ~ClusterFunctionLibraryRuntime()
|
| D | master.cc | 637 env_->worker_cache->ReleaseWorker(worker_name, worker); in CleanupWorkers()
|