| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_worker_cache_test.cc | 45 worker_cache->ReleaseWorker("/job:worker/replica:0/task:0", wi); in TEST()
48 worker_cache->ReleaseWorker("/job:worker/replica:0/task:1", wi); in TEST()
51 worker_cache->ReleaseWorker("/job:worker/replica:0/task:2", wi); in TEST()
|
| D | rpc_rendezvous_mgr.cc | 119 void ReleaseWorker(WorkerCacheInterface* worker_cache) { in ReleaseWorker() function in tensorflow::__anona9090a8f0111::RpcRecvTensorCall
122 worker_cache->ReleaseWorker(src_worker_, wi_); in ReleaseWorker()
265 sess->worker_cache()->ReleaseWorker(call->src_worker_, rwi); in RecvFromRemoteAsync()
284 call->ReleaseWorker(sess->worker_cache()); in RecvFromRemoteAsync()
301 call->ReleaseWorker(session()->worker_cache()); in RecvFromRemoteAsync()
|
| D | grpc_worker_cache.cc | 68 void ReleaseWorker(const string& target, WorkerInterface* worker) override { in ReleaseWorker() function in tensorflow::__anon75b4e2090111::GrpcWorkerCache
73 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 | cancellable_call.h | 38 virtual ~CancellableCall() { wc_->ReleaseWorker(remote_worker_, wi_); } in ~CancellableCall()
|
| 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::__anonf821b21a0111::WorkerFreeListCache
|
| D | worker_cache.h | 54 virtual void ReleaseWorker(const string& target, WorkerInterface* worker) { in ReleaseWorker() function
|
| D | worker_cache_partial.cc | 66 ReleaseWorker(task, wi); in RefreshDeviceStatus()
|
| D | remote_device_test.cc | 63 worker_cache_->ReleaseWorker(remote_name_, wi_); in ~RemoteDeviceTest()
|
| D | remote_device.cc | 98 worker_cache->ReleaseWorker(worker_name, wi); in NewRemoteDevices()
|
| D | test_utils.h | 163 void ReleaseWorker(const string& target, WorkerInterface* worker) override {} in ReleaseWorker() function
|
| D | collective_rma_distributed.cc | 245 worker_cache_->ReleaseWorker(peer_task, wi); in CheckPeerHealth()
|
| D | master_session.cc | 107 worker_cache_->ReleaseWorker(part.name, part.worker); in ~ReffedClientGraph()
458 worker_cache_->ReleaseWorker(part.name, part.worker); in DoRegisterPartitions()
1120 worker_cache->ReleaseWorker(name, w); in DeregisterPartitions()
1313 worker_cache->ReleaseWorker(*worker_group.name, worker_group.worker); in CreateWorkerSessions()
1431 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()
|