Home
last modified time | relevance | path

Searched refs:rmgr_ (Results 1 – 5 of 5) sorted by relevance

/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Drpc_rendezvous_mgr_test.cc128 rmgr_(&env) { in RpcRendezvousMgrTest()
136 RpcRendezvousMgr rmgr_; member in tensorflow::RpcRendezvousMgrTest
145 RemoteRendezvous* rendez = rmgr_.Find(step_id); in TEST_F()
154 TF_ASSERT_OK(rmgr_.RecvLocal(step_id, key, &val, &val_dead)); in TEST_F()
157 rmgr_.Cleanup(step_id); in TEST_F()
166 RemoteRendezvous* rendez = rmgr_.Find(step_id); in TEST_F()
180 RemoteRendezvous* rendez = rmgr_.Find(step_id); in TEST_F()
184 rmgr_.Cleanup(step_id); in TEST_F()
200 RemoteRendezvous* rendez = rmgr_.Find(step_id); in TEST_F()
224 RemoteRendezvous* rendez = rmgr_.Find(step_id); in TEST_F()
[all …]
/external/tensorflow/tensorflow/core/framework/
Ddevice.h159 virtual ResourceMgr* resource_manager() { return rmgr_; } in resource_manager()
177 void ClearResourceMgr() { rmgr_->Clear(); } in ClearResourceMgr()
186 delete rmgr_; in DeleteResourceMgr() local
187 rmgr_ = nullptr; in DeleteResourceMgr()
198 ResourceMgr* rmgr_ = nullptr; variable
Ddevice.cc30 rmgr_ = new ResourceMgr(parsed_name_.job); in Device()
34 if (rmgr_ != nullptr) { in ~Device()
Dresource_mgr.cc281 rmgr_ = rmgr; in Init()
297 container_ = rmgr_->default_container(); in Init()
Dresource_mgr.h423 ResourceMgr* resource_manager() const { return rmgr_; } in resource_manager()
434 ResourceMgr* rmgr_ = nullptr;