HomeSort by relevance Sort by last modified time
    Searched refs:WorkerSession (Results 1 - 17 of 17) sorted by null

  /external/tensorflow/tensorflow/core/distributed_runtime/
rendezvous_mgr_interface.h 28 struct WorkerSession;
42 virtual Status Initialize(WorkerSession* session) = 0;
session_mgr.h 53 std::shared_ptr<WorkerSession> WorkerSessionForSession(const string& session);
54 std::shared_ptr<WorkerSession> LegacySession();
79 // legacy_session_ is deleted. Further, we must ensure that WorkerSession's
80 // device_mgr is deleted after WorkerSession's graph_mgr.
83 std::shared_ptr<WorkerSession> legacy_session_;
89 std::shared_ptr<WorkerSession> WorkerSessionForSessionUnlocked(
94 std::map<string, std::shared_ptr<WorkerSession>> sessions_ GUARDED_BY(mu_);
worker_session.h 32 // WorkerSession encapsulates all of the state relating to a given session.
33 struct WorkerSession {
56 WorkerSession(const string& session_name, const string& worker_name,
cluster_function_library_runtime.h 24 struct WorkerSession;
30 ClusterFunctionLibraryRuntime(WorkerSession* worker_session)
53 WorkerSession* const worker_session_ = nullptr; // not owned.
base_rendezvous_mgr.h 124 Status Initialize(WorkerSession* session) override;
168 WorkerSession* session();
184 WorkerSession* session_ GUARDED_BY(mu_); // Not owned.
session_mgr.cc 36 legacy_session_(new WorkerSession(
84 std::shared_ptr<WorkerSession> worker_session(new WorkerSession(
101 std::shared_ptr<WorkerSession> SessionMgr::WorkerSessionForSessionUnlocked(
111 std::shared_ptr<WorkerSession> SessionMgr::WorkerSessionForSession(
117 std::shared_ptr<WorkerSession> SessionMgr::LegacySession() {
graph_mgr.h 45 struct WorkerSession;
89 WorkerSession* session, const ExecutorOpts& opts,
worker_session.cc 90 WorkerSession::WorkerSession(const string& session_name,
worker.h 31 struct WorkerSession;
base_rendezvous_mgr.cc 152 Status BaseRemoteRendezvous::Initialize(WorkerSession* session) {
177 WorkerSession* BaseRemoteRendezvous::session() {
209 WorkerSession* sess = nullptr;
254 WorkerSession* sess = session();
cluster_function_library_runtime_test.cc 41 worker_session_.reset(new WorkerSession(
99 std::unique_ptr<WorkerSession> worker_session_;
session_mgr_test.cc 62 std::shared_ptr<WorkerSession> legacy_session_;
graph_mgr.cc 382 WorkerSession* session, const ExecutorOpts& opts,
  /external/tensorflow/tensorflow/core/distributed_runtime/rpc/
grpc_worker_service.h 31 struct WorkerSession;
rpc_rendezvous_mgr.cc 222 WorkerSession* sess = session();
rpc_rendezvous_mgr_test.cc 80 WorkerSession worker_session_;
  /external/tensorflow/tensorflow/contrib/gdr/
gdr_rendezvous_mgr.cc 149 WorkerSession* sess = session();

Completed in 135 milliseconds