Searched refs:src_worker (Results 1 – 1 of 1) sorted by relevance
| /external/tensorflow/tensorflow/contrib/gdr/ |
| D | gdr_rendezvous_mgr.cc | 134 string src_worker; in RecvFromRemoteAsync() local
136 if (!DeviceNameUtils::SplitDeviceName(parsed.src_device, &src_worker, in RecvFromRemoteAsync()
145 WorkerInterface* rwi = sess->worker_cache->CreateWorker(src_worker); in RecvFromRemoteAsync()
147 Status s = errors::Internal("No worker known as ", src_worker); in RecvFromRemoteAsync()
155 sess->worker_cache->ReleaseWorker(src_worker, rwi); in RecvFromRemoteAsync()
173 session()->worker_cache->ReleaseWorker(src_worker, rwi); in RecvFromRemoteAsync()
181 call->Start([this, call, src_worker, rwi, done]() { in RecvFromRemoteAsync()
190 session()->worker_cache->ReleaseWorker(src_worker, rwi); in RecvFromRemoteAsync()
|