Home
last modified time | relevance | path

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

/external/tensorflow/tensorflow/core/distributed_runtime/
Dsession_mgr.cc105 WorkerCacheInterface* worker_cache = nullptr; in CreateSession() local
186 void SessionMgr::ResetDefaultWorkerCache(WorkerCacheInterface* worker_cache) { in ResetDefaultWorkerCache()
206 WorkerCacheInterface* worker_cache = nullptr; in UpdateSession() local
296 auto* worker_cache = legacy_session_->worker_cache(); in SetLogging() local
305 auto* worker_cache = session->worker_cache(); in SetLogging() local
318 auto* worker_cache = legacy_session_->worker_cache(); in RetrieveLogs() local
331 auto* worker_cache = session->worker_cache(); in RetrieveLogs() local
348 auto* worker_cache = legacy_session_->worker_cache(); in ClearLogs() local
357 auto* worker_cache = session->worker_cache(); in ClearLogs() local
Dworker_session.cc109 std::unique_ptr<WorkerCacheInterface> worker_cache, in WorkerSession()
146 std::unique_ptr<WorkerCacheInterface> worker_cache, in CreateWithBorrowedDeviceMgr()
156 std::unique_ptr<WorkerCacheInterface> worker_cache, in WorkerSession()
Dcollective_rma_distributed.h32 WorkerCacheInterface* worker_cache, int64 step_id, string task_name) in CollectiveRemoteAccessDistributed()
Dworker_session.h49 WorkerCacheInterface* worker_cache() const { in worker_cache() function
Dcluster_function_library_runtime.h80 const std::shared_ptr<WorkerCacheInterface> worker_cache; member
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.cc79 void NewRemoteDevices(Env* env, WorkerCacheInterface* worker_cache, in NewRemoteDevices()
Drpc_collective_executor_mgr_test.cc45 WorkerCacheInterface* worker_cache = nullptr; in RpcCollectiveExecutorMgrTest() local
Drpc_collective_executor_mgr.cc33 WorkerCacheInterface* worker_cache, const string& task_name) in RpcCollectiveExecutorMgr()
Dcluster_function_library_runtime_test.cc42 std::unique_ptr<WorkerCacheInterface> worker_cache( in ClusterFunctionLibraryRuntimeTest() local
Dmaster_session.cc75 bool is_partial, WorkerCacheInterface* worker_cache, in ReffedClientGraph()
1109 WorkerCacheInterface* worker_cache = worker_cache_; in DeregisterPartitions() local
1230 std::unique_ptr<WorkerCacheInterface> worker_cache, in MasterSession()
1292 WorkerCacheInterface* worker_cache = get_worker_cache(); in CreateWorkerSessions() local
1407 WorkerCacheInterface* worker_cache = get_worker_cache(); in DeleteWorkerSessions() local
1541 WorkerCacheInterface* worker_cache = get_worker_cache(); in StartStep() local
Dsession_mgr_test.cc58 [](const ServerDef& server_def, WorkerCacheInterface** worker_cache) { in __anond6a406250102()
Dcluster_function_library_runtime.cc189 std::shared_ptr<WorkerCacheInterface> worker_cache = in Instantiate() local
Dcollective_param_resolver_distributed.cc93 DeviceResolverDistributed* dev_resolver, WorkerCacheInterface* worker_cache, in CollectiveParamResolverDistributed()
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_worker_cache_test.cc40 std::unique_ptr<WorkerCacheInterface> worker_cache( in TEST() local
76 WorkerCacheInterface* worker_cache = in TEST() local
Dgrpc_server_lib.cc268 WorkerCacheInterface* worker_cache; in Init() local
298 [this](const ServerDef& server_def, WorkerCacheInterface** worker_cache) { in Init()
316 std::vector<string> filtered_worker_list) { in Init()
325 WorkerCacheInterface** worker_cache) { in Init()
360 WorkerCacheInterface** worker_cache) { in WorkerCacheFactory()
434 WorkerCacheInterface* worker_cache; in UpdateServerDef() local
Drpc_rendezvous_mgr.cc119 void ReleaseWorker(WorkerCacheInterface* worker_cache) { in ReleaseWorker()
249 std::shared_ptr<WorkerCacheInterface> worker_cache = in RecvFromRemoteAsync() local
/external/tensorflow/tensorflow/core/common_runtime/eager/
Dcontext_distributed_manager.cc64 tensorflow::WorkerCacheInterface* worker_cache, in AddRemoteDevicesToMgr()
98 tensorflow::WorkerCacheInterface* worker_cache, in GetAllRemoteDevices()
/external/tensorflow/tensorflow/core/distributed_runtime/eager/
Deager_service_impl_test.cc149 WorkerCacheInterface** worker_cache) { in EagerServiceImplTest()