| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | worker_session.h | 30 class WorkerCacheInterface; variable
41 const std::unique_ptr<WorkerCacheInterface> worker_cache;
61 std::unique_ptr<WorkerCacheInterface> worker_cache,
67 std::unique_ptr<WorkerCacheInterface> worker_cache,
74 std::unique_ptr<WorkerCacheInterface> worker_cache,
|
| D | worker_session.cc | 23 class WorkerFreeListCache : public WorkerCacheInterface {
25 explicit WorkerFreeListCache(std::unique_ptr<WorkerCacheInterface> w) in WorkerFreeListCache()
80 std::unique_ptr<WorkerCacheInterface> wrapped_;
97 std::unique_ptr<WorkerCacheInterface> worker_cache, in WorkerSession()
112 std::unique_ptr<WorkerCacheInterface> worker_cache, in CreateWithBorrowedDeviceMgr()
121 std::unique_ptr<WorkerCacheInterface> worker_cache, in WorkerSession()
|
| D | session_mgr.h | 29 class WorkerCacheInterface; variable
39 typedef std::function<Status(const ServerDef&, WorkerCacheInterface**)>
44 std::unique_ptr<WorkerCacheInterface> default_worker_cache,
83 std::unique_ptr<WorkerCacheInterface> default_worker_cache_;
|
| D | collective_rma_distributed.h | 21 class WorkerCacheInterface; variable
28 WorkerCacheInterface* worker_cache, in CollectiveRemoteAccessDistributed()
46 WorkerCacheInterface* worker_cache_; // Not owned
|
| D | device_resolver_distributed.h | 27 class WorkerCacheInterface; variable
32 WorkerCacheInterface* worker_cache,
60 WorkerCacheInterface* worker_cache_; // Not owned
|
| D | master_env.h | 66 WorkerCacheInterface* worker_cache = nullptr;
86 std::unique_ptr<WorkerCacheInterface>,
92 WorkerCacheInterface**)>
|
| D | session_mgr.cc | 33 std::unique_ptr<WorkerCacheInterface> default_worker_cache, in SessionMgr()
39 std::unique_ptr<WorkerCacheInterface>( in SessionMgr()
60 WorkerCacheInterface* worker_cache = nullptr; in CreateSession()
91 std::unique_ptr<WorkerCacheInterface>(worker_cache), in CreateSession()
100 std::unique_ptr<WorkerCacheInterface>(worker_cache), in CreateSession()
|
| D | worker_cache_wrapper.h | 26 class WorkerCacheWrapper : public WorkerCacheInterface {
28 WorkerCacheWrapper(WorkerCacheInterface* wrapped) : wrapped_(wrapped) {} in WorkerCacheWrapper()
91 WorkerCacheInterface* wrapped_; // Not owned.
|
| D | rpc_collective_executor_mgr.h | 26 class WorkerCacheInterface; variable
41 WorkerCacheInterface* worker_cache, const string& task_name);
61 WorkerCacheInterface* const worker_cache_; // Not owned.
|
| D | collective_param_resolver_distributed.h | 22 class WorkerCacheInterface; variable
31 WorkerCacheInterface* worker_cache,
85 WorkerCacheInterface* worker_cache_; // Not owned
|
| D | remote_device.h | 27 class WorkerCacheInterface; variable
43 void NewRemoteDevices(Env* env, WorkerCacheInterface* worker_cache,
|
| D | worker_cache.h | 32 class WorkerCacheInterface {
34 virtual ~WorkerCacheInterface() {} in ~WorkerCacheInterface()
|
| D | cancellable_call.h | 31 WorkerCacheInterface* wc) in CancellableCall()
59 WorkerCacheInterface* const wc_; // Not owned
|
| D | master_session.h | 53 std::unique_ptr<WorkerCacheInterface> worker_cache,
127 const std::unique_ptr<WorkerCacheInterface> worker_cache_;
129 WorkerCacheInterface* get_worker_cache() const;
|
| D | master.cc | 137 WorkerCacheInterface* worker_cache, in GetRemoteDevices()
148 WorkerCacheInterface* worker_cache, std::vector<string>* workers) { in GetRemoteWorkers()
156 WorkerCacheInterface* worker_cache) in DeviceFinder()
297 WorkerCacheInterface* worker_cache_;
368 WorkerCacheInterface* worker_cache = nullptr; in CreateSession()
371 std::unique_ptr<WorkerCacheInterface> worker_cache_ptr; in CreateSession()
422 worker_cache_ptr = std::unique_ptr<WorkerCacheInterface>(worker_cache); in CreateSession()
|
| D | worker_cache_partial.h | 32 class WorkerCachePartial : public WorkerCacheInterface {
|
| D | session_mgr_test.cc | 48 std::unique_ptr<WorkerCacheInterface>(), factory_) { in SessionMgrTest()
58 [](const ServerDef& server_def, WorkerCacheInterface** worker_cache) { in __anon395f77470102()
|
| D | collective_param_resolver_distributed.cc | 29 const string& remote_worker, WorkerCacheInterface* wc) in CompleteGroupCall()
52 const string& remote_worker, WorkerCacheInterface* wc) in CompleteInstanceCall()
83 DeviceResolverDistributed* dev_resolver, WorkerCacheInterface* worker_cache, in CollectiveParamResolverDistributed()
|
| /external/tensorflow/tensorflow/contrib/gdr/ |
| D | gdr_collective_executor_mgr.cc | 30 class WorkerCacheInterface;
42 CancellationManager* cancel_mgr, WorkerCacheInterface* wc) in RecvBufCall()
69 WorkerCacheInterface* worker_cache, in CollectiveRemoteAccessDistributed()
143 WorkerCacheInterface* worker_cache_; // Not owned
|
| D | gdr_collective_executor_mgr.h | 27 class WorkerCacheInterface; variable
39 WorkerCacheInterface* worker_cache, const string& task_name, in GdrCollectiveExecutorMgr()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_worker_cache.h | 25 WorkerCacheInterface* NewGrpcWorkerCache(std::shared_ptr<GrpcChannelCache> cc);
27 WorkerCacheInterface* NewGrpcWorkerCacheWithLocalWorker(
|
| D | grpc_worker_cache.cc | 89 WorkerCacheInterface::ReleaseWorker(target, worker); in ReleaseWorker()
161 WorkerCacheInterface* NewGrpcWorkerCache(std::shared_ptr<GrpcChannelCache> cc) { in NewGrpcWorkerCache()
165 WorkerCacheInterface* NewGrpcWorkerCacheWithLocalWorker( in NewGrpcWorkerCacheWithLocalWorker()
|
| D | grpc_server_lib.cc | 215 WorkerCacheInterface* worker_cache; in Init()
244 std::unique_ptr<WorkerCacheInterface>(worker_cache), in Init()
245 [this](const ServerDef& server_def, WorkerCacheInterface** worker_cache) { in Init()
260 std::unique_ptr<WorkerCacheInterface> worker_cache, in Init()
271 WorkerCacheInterface** worker_cache) { in Init()
306 WorkerCacheInterface** worker_cache) { in WorkerCacheFactory()
|
| D | grpc_server_lib.h | 50 const ConfigProto&, const WorkerEnv*, WorkerCacheInterface*)>
113 WorkerCacheInterface** worker_cache);
|
| D | rpc_rendezvous_mgr_test.cc | 51 class DummyWorkerCache : public WorkerCacheInterface {
72 std::unique_ptr<WorkerCacheInterface>(cache_), in RpcRendezvousMgrTest()
|