Searched refs:IntraProcessRendezvous (Results 1 – 11 of 11) sorted by relevance
34 IntraProcessRendezvous::IntraProcessRendezvous(const DeviceMgr* device_mgr) in IntraProcessRendezvous() function in tensorflow::IntraProcessRendezvous37 IntraProcessRendezvous::~IntraProcessRendezvous() { local_->Unref(); } in ~IntraProcessRendezvous()39 Status IntraProcessRendezvous::Send(const ParsedKey& parsed, in Send()52 Status IntraProcessRendezvous::ParseKey(const string& key, bool is_src, in ParseKey()62 void IntraProcessRendezvous::SameWorkerRecvDone( in SameWorkerRecvDone()116 void IntraProcessRendezvous::RecvAsync(const ParsedKey& parsed, in RecvAsync()156 void IntraProcessRendezvous::StartAbort(const Status& s) { in StartAbort()
40 class IntraProcessRendezvous : public Rendezvous {42 explicit IntraProcessRendezvous(const DeviceMgr* device_mgr);67 ~IntraProcessRendezvous() override;85 TF_DISALLOW_COPY_AND_ASSIGN(IntraProcessRendezvous);
183 IntraProcessRendezvous* rendez = nullptr;265 IntraProcessRendezvous* rendez);
95 rendezvous_ = new IntraProcessRendezvous(device_mgr_.get()); in Init()217 IntraProcessRendezvous* rendezvous_;
482 run_state.rendez = new IntraProcessRendezvous(device_mgr_.get()); in RunInternal()859 run_state->rendez = new IntraProcessRendezvous(device_mgr_.get()); in PRunSetup()1041 IntraProcessRendezvous* rendez) { in SendPRunInputs()1101 IntraProcessRendezvous* rendez = run_state->rendez; in RecvPRunOutputs()
1054 Rendezvous* rendezvous = new IntraProcessRendezvous(device_mgr_); in Run()1130 Rendezvous* rendezvous = new IntraProcessRendezvous(device_mgr_); in Run()
1591 opts.rendezvous = new IntraProcessRendezvous(device_mgr_.get()); in TEST_F()
42 new tensorflow::IntraProcessRendezvous(device_mgr.get()); in Prepare()
228 Rendezvous* rendez = new IntraProcessRendezvous(lib->device_mgr()); in RunFunction()
316 Rendezvous* rendezvous = new IntraProcessRendezvous(pflr_->device_mgr()); in Run()
346 new tensorflow::IntraProcessRendezvous(device_mgr.get()); in TFE_NewContext()359 new tensorflow::IntraProcessRendezvous(device_mgr); in TFE_NewContextFromSession()