| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | rpc_rendezvous_mgr.cc | 118 void ReleaseWorker(WorkerCacheInterface* worker_cache) { in ReleaseWorker() function in tensorflow::__anon9a114d310111::RpcRecvTensorCall
121 worker_cache->ReleaseWorker(src_worker_, wi_); in ReleaseWorker()
246 sess->worker_cache->ReleaseWorker(call->src_worker_, rwi); in RecvFromRemoteAsync()
264 call->ReleaseWorker(sess->worker_cache.get()); in RecvFromRemoteAsync()
281 call->ReleaseWorker(session()->worker_cache.get()); in RecvFromRemoteAsync()
|
| D | grpc_worker_cache.cc | 84 void ReleaseWorker(const string& target, WorkerInterface* worker) override { in ReleaseWorker() function in tensorflow::__anonab8e586b0111::GrpcWorkerCache
89 WorkerCacheInterface::ReleaseWorker(target, worker); in ReleaseWorker()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | worker_cache_wrapper.h | 56 virtual void ReleaseWorker(const string& target, WorkerInterface* worker) { in ReleaseWorker() function
57 return wrapped_->ReleaseWorker(target, worker); in ReleaseWorker()
|
| D | worker_session.cc | 30 wrapped_->ReleaseWorker(p.first, p.second.worker); in ~WorkerFreeListCache()
57 void ReleaseWorker(const string& target, WorkerInterface* worker) override { in ReleaseWorker() function in tensorflow::__anond5aa72bc0111::WorkerFreeListCache
|
| D | worker_cache.h | 56 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 | 76 worker_cache->ReleaseWorker(worker_name, wi); in NewRemoteDevices()
|
| D | device_resolver_distributed.cc | 113 worker_cache_->ReleaseWorker(task, worker); in RefreshRemoteAttributes()
|
| D | test_utils.h | 163 void ReleaseWorker(const string& target, WorkerInterface* worker) override {} in ReleaseWorker() function
|
| D | cluster_function_library_runtime.cc | 115 worker_session_->worker_cache->ReleaseWorker(function_data.target, in ~ClusterFunctionLibraryRuntime()
|
| D | master_session.cc | 103 worker_cache_->ReleaseWorker(part.name, part.worker); in ~ReffedClientGraph()
454 worker_cache_->ReleaseWorker(part.name, part.worker); in DoRegisterPartitions()
1063 worker_cache->ReleaseWorker(name, w); in DeregisterPartitions()
1257 worker_cache->ReleaseWorker(*worker_group.name, worker_group.worker); in CreateWorkerSessions()
1339 worker_cache->ReleaseWorker(*worker_group.name, worker_group.worker); in DeleteWorkerSessions()
|
| D | master.cc | 637 env_->worker_cache->ReleaseWorker(worker_name, worker); in CleanupWorkers()
|
| /external/tensorflow/tensorflow/contrib/gdr/ |
| D | gdr_rendezvous_mgr.cc | 155 sess->worker_cache->ReleaseWorker(src_worker, rwi); in RecvFromRemoteAsync()
173 session()->worker_cache->ReleaseWorker(src_worker, rwi); in RecvFromRemoteAsync()
190 session()->worker_cache->ReleaseWorker(src_worker, rwi); in RecvFromRemoteAsync()
|