OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
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