Home
last modified time | relevance | path

Searched refs:DeviceMgr (Results 1 – 25 of 95) sorted by relevance

1234

/external/tensorflow/tensorflow/core/distributed_runtime/
Dworker_session.h40 const DeviceMgr* device_mgr() { in device_mgr()
61 std::unique_ptr<DeviceMgr> device_mgr,
68 const DeviceMgr* borrowed_device_mgr, std::unique_ptr<GraphMgr> graph_mgr,
93 const DeviceMgr* borrowed_device_mgr,
116 const std::unique_ptr<const DeviceMgr> device_mgr_;
117 const DeviceMgr* const borrowed_device_mgr_; // Not owned.
Dworker_env.h30 class DeviceMgr; variable
56 const DeviceMgr* device_mgr = nullptr;
Dcluster_function_library_runtime.h33 DeviceMgr* remote_device_mgr) in ClusterFunctionLibraryRuntime()
59 DeviceMgr* remote_device_mgr() const override { return remote_device_mgr_; } in remote_device_mgr()
73 DeviceMgr* remote_device_mgr_; // not owned.
Ddevice_resolver_distributed.h27 class DeviceMgr; variable
32 explicit DeviceResolverDistributed(const DeviceMgr* dev_mgr);
Dgraph_mgr.h45 class DeviceMgr; variable
72 explicit GraphMgr(const WorkerEnv* worker_env, const DeviceMgr* device_mgr);
148 const DeviceMgr* device_mgr_;
Dserver_lib.h27 class DeviceMgr; variable
70 const tensorflow::DeviceMgr* local_device_mgr;
Drpc_collective_executor_mgr.h24 class DeviceMgr; variable
38 const ConfigProto& config, const DeviceMgr* dev_mgr,
Dcollective_param_resolver_distributed.h27 class DeviceMgr; variable
32 const DeviceMgr* dev_mgr,
Dworker_session.cc110 std::unique_ptr<DeviceMgr> device_mgr, std::unique_ptr<GraphMgr> graph_mgr, in WorkerSession()
147 const DeviceMgr* borrowed_device_mgr, std::unique_ptr<GraphMgr> graph_mgr, in CreateWithBorrowedDeviceMgr()
157 const DeviceMgr* borrowed_device_mgr, std::unique_ptr<GraphMgr> graph_mgr, in WorkerSession()
Dcollective_rma_distributed_test.cc65 FakeWorker(const string& name, DeviceMgr* dev_mgr, in FakeWorker()
135 DeviceMgr* device_mgr_;
189 for (DeviceMgr* dm : device_mgrs_) { in ~CollRMADistTest()
248 DeviceMgr* dev_mgr = new StaticDeviceMgr(std::move(devices)); in DefineWorker()
285 std::vector<DeviceMgr*> device_mgrs_;
/external/tensorflow/tensorflow/core/common_runtime/
Drendezvous_mgr.h45 explicit RefCountedIntraProcessRendezvous(const DeviceMgr* device_mgr);
55 const DeviceMgr* device_mgr_;
73 explicit PrivateIntraProcessRendezvous(const DeviceMgr* device_mgr);
84 const DeviceMgr* device_mgr_;
Ddevice_mgr.h38 class DeviceMgr {
40 DeviceMgr() = default;
41 virtual ~DeviceMgr();
75 TF_DISALLOW_COPY_AND_ASSIGN(DeviceMgr);
79 class StaticDeviceMgr : public DeviceMgr {
118 class DynamicDeviceMgr : public DeviceMgr {
Ddevice_resolver_local.h26 class DeviceMgr; variable
31 explicit DeviceResolverLocal(const DeviceMgr* dev_mgr) : dev_mgr_(dev_mgr) {} in DeviceResolverLocal()
43 const DeviceMgr* dev_mgr_;
Dcollective_executor_mgr.h24 class DeviceMgr; variable
30 const ConfigProto& config, const DeviceMgr* dev_mgr,
70 const DeviceMgr* dev_mgr_;
Dbuf_rendezvous.h31 class DeviceMgr; variable
44 explicit BufRendezvous(uint64 step_id, const DeviceMgr* dev_mgr) in BufRendezvous()
124 const DeviceMgr* const dev_mgr_; // Not owned.
Dbase_collective_executor.h28 class DeviceMgr; variable
100 const DeviceMgr* dev_mgr, const string* gpu_ring_order, in BaseCollectiveExecutor()
140 const DeviceMgr* dev_mgr_; // Not owned.
Drendezvous_mgr.cc36 void SameWorkerRecvDone(const DeviceMgr* device_mgr, in SameWorkerRecvDone()
115 void IntraProcessRecvAsyncImpl(const DeviceMgr* device_mgr, in IntraProcessRecvAsyncImpl()
153 const DeviceMgr* device_mgr) in RefCountedIntraProcessRendezvous()
178 const DeviceMgr* device_mgr) in PrivateIntraProcessRendezvous()
Dcollective_param_resolver_local.h36 class DeviceMgr; variable
44 const DeviceMgr* dev_mgr,
189 const DeviceMgr* dev_mgr_;
Dcollective_rma_local.h28 CollectiveRemoteAccessLocal(const DeviceMgr* dev_mgr, in CollectiveRemoteAccessLocal()
75 const DeviceMgr* dev_mgr_; // not owned
/external/tensorflow/tensorflow/core/framework/
Drendezvous.h31 class DeviceMgr; variable
137 Factory(std::function<Status(const int64, const DeviceMgr*, Rendezvous**)> in Factory() argument
147 std::function<Status(const int64, const DeviceMgr*, Rendezvous**)> in Factory() argument
155 Status operator()(const int64 step_id, const DeviceMgr* device_mgr, in operator()
164 std::function<Status(const int64, const DeviceMgr*, Rendezvous**)>
/external/tensorflow/tensorflow/core/distributed_runtime/eager/
Dcluster_function_library_runtime.h39 DeviceMgr* remote_device_mgr) in EagerClusterFunctionLibraryRuntime()
79 DeviceMgr* remote_device_mgr() const override { return remote_device_mgr_; } in remote_device_mgr()
84 DeviceMgr* remote_device_mgr_; // not owned.
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_server_lib.h72 const DeviceMgr* local_device_mgr = nullptr;
78 GrpcServer(const ServerDef& server_def, DeviceMgr* local_device_mgr,
91 const DeviceMgr* local_device_mgr,
178 std::unique_ptr<const DeviceMgr> owned_device_manager_;
/external/tensorflow/tensorflow/core/common_runtime/eager/
Dcontext.h100 bool async, const DeviceMgr* device_mgr, bool device_mgr_owned,
302 const tensorflow::DeviceMgr* local_device_mgr() const { in local_device_mgr()
371 Rendezvous* r, const DeviceMgr* local_device_mgr, int keep_alive_secs,
408 std::unique_ptr<ServerInterface> new_server, const DeviceMgr* device_mgr,
526 void ResetPFLR(const DeviceMgr* device_mgr, Env* env,
580 OwnedOrUnownedHelper<const DeviceMgr> local_device_manager_;
582 std::vector<std::unique_ptr<const DeviceMgr>> old_local_device_managers_;
673 const DeviceMgr* local_device_mgr, int keep_alive_secs,
/external/tensorflow/tensorflow/core/data/
Dstandalone.h111 Dataset(DatasetBase* dataset, DeviceMgr* device_mgr,
116 std::unique_ptr<DeviceMgr> device_mgr_;
/external/tensorflow/tensorflow/core/kernels/data/
Diterator_ops.h37 std::unique_ptr<DeviceMgr> device_mgr,
133 const std::unique_ptr<DeviceMgr> device_mgr_ TF_GUARDED_BY(mu_);
160 OpKernelContext* ctx, std::unique_ptr<DeviceMgr>* device_mgr,

1234