Home
last modified time | relevance | path

Searched defs:worker_cache (Results 1 – 19 of 19) sorted by relevance

/external/tensorflow/tensorflow/core/distributed_runtime/
Dsession_mgr.cc70 WorkerCacheInterface* worker_cache = nullptr; in CreateSession() local
163 WorkerCacheInterface* worker_cache = nullptr; in UpdateSession() local
253 auto* worker_cache = legacy_session_->worker_cache(); in SetLogging() local
262 auto* worker_cache = session->worker_cache(); in SetLogging() local
275 auto* worker_cache = legacy_session_->worker_cache(); in RetrieveLogs() local
288 auto* worker_cache = session->worker_cache(); in RetrieveLogs() local
305 auto* worker_cache = legacy_session_->worker_cache(); in ClearLogs() local
314 auto* worker_cache = session->worker_cache(); in ClearLogs() local
Dworker_session.cc109 std::unique_ptr<WorkerCacheInterface> worker_cache, in WorkerSession()
147 std::unique_ptr<WorkerCacheInterface> worker_cache, in CreateWithBorrowedDeviceMgr()
157 std::unique_ptr<WorkerCacheInterface> worker_cache, in WorkerSession()
Dcollective_rma_distributed.h31 WorkerCacheInterface* worker_cache, int64 step_id) in CollectiveRemoteAccessDistributed()
Dworker_session.h49 WorkerCacheInterface* worker_cache() const { return worker_cache_.get(); } in worker_cache() function
Dmaster.cc137 WorkerCacheInterface* worker_cache, in GetRemoteDevices()
148 WorkerCacheInterface* worker_cache, std::vector<string>* workers) { in GetRemoteWorkers()
156 WorkerCacheInterface* worker_cache) in DeviceFinder()
368 WorkerCacheInterface* worker_cache = nullptr; in CreateSession() local
Dmaster_env.h66 WorkerCacheInterface* worker_cache = nullptr; member
Dremote_device.cc74 void NewRemoteDevices(Env* env, WorkerCacheInterface* worker_cache, in NewRemoteDevices()
Ddevice_resolver_distributed.cc22 const DeviceMgr* dev_mgr, WorkerCacheInterface* worker_cache, in DeviceResolverDistributed()
Drpc_collective_executor_mgr_test.cc42 WorkerCacheInterface* worker_cache = nullptr; in RpcCollectiveExecutorMgrTest() local
Drpc_collective_executor_mgr.cc32 WorkerCacheInterface* worker_cache, const string& task_name) in RpcCollectiveExecutorMgr()
Dcluster_function_library_runtime_test.cc39 std::unique_ptr<WorkerCacheInterface> worker_cache( in ClusterFunctionLibraryRuntimeTest() local
Dsession_mgr_test.cc58 [](const ServerDef& server_def, WorkerCacheInterface** worker_cache) { in __anon18ea8b490102()
Dmaster_session.cc73 bool is_partial, WorkerCacheInterface* worker_cache, in ReffedClientGraph()
1107 WorkerCacheInterface* worker_cache = worker_cache_; in DeregisterPartitions() local
1228 std::unique_ptr<WorkerCacheInterface> worker_cache, in MasterSession()
1290 WorkerCacheInterface* worker_cache = get_worker_cache(); in CreateWorkerSessions() local
1385 WorkerCacheInterface* worker_cache = get_worker_cache(); in DeleteWorkerSessions() local
1519 WorkerCacheInterface* worker_cache = get_worker_cache(); in StartStep() local
Dcollective_param_resolver_distributed.cc86 DeviceResolverDistributed* dev_resolver, WorkerCacheInterface* worker_cache, in CollectiveParamResolverDistributed()
Ddevice_resolver_distributed_test.cc36 WorkerCacheInterface* worker_cache, in TestableDeviceResolverDistributed()
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_server_lib.cc248 WorkerCacheInterface* worker_cache; in Init() local
278 [this](const ServerDef& server_def, WorkerCacheInterface** worker_cache) { in Init()
295 std::vector<string> filtered_worker_list) { in Init()
304 WorkerCacheInterface** worker_cache) { in Init()
339 WorkerCacheInterface** worker_cache) { in WorkerCacheFactory()
413 WorkerCacheInterface* worker_cache; in UpdateServerDef() local
Drpc_rendezvous_mgr.cc118 void ReleaseWorker(WorkerCacheInterface* worker_cache) { in ReleaseWorker()
/external/tensorflow/tensorflow/core/distributed_runtime/eager/
Deager_service_impl_test.cc137 WorkerCacheInterface** worker_cache) { in EagerServiceImplTest()
/external/tensorflow/tensorflow/c/eager/
Dc_api.cc117 tensorflow::WorkerCacheInterface* worker_cache, in AddRemoteDevicesToMgr()
151 tensorflow::WorkerCacheInterface* worker_cache, in GetAllRemoteDevices()