Searched defs:rendez (Results 1 – 12 of 12) sorted by relevance
92 RemoteRendezvous* rendez = rmgr_.Find(step_id); in TEST_F() local113 RemoteRendezvous* rendez = rmgr_.Find(step_id); in TEST_F() local127 RemoteRendezvous* rendez = rmgr_.Find(step_id); in TEST_F() local147 RemoteRendezvous* rendez = rmgr_.Find(step_id); in TEST_F() local177 RemoteRendezvous* rendez = rmgr_.Find(step_id); in TEST_F() local
38 static void StartAbortRendevous(Rendezvous* rendez, const Status& s) { in StartAbortRendevous()48 auto rendez = p.second; in ~BaseRendezvousMgr() local71 auto rendez = FindOrCreate(step_id); in RecvLocalAsync() local105 Rendezvous* rendez = nullptr; in Cleanup() local128 for (auto rendez : rendezs) { in CleanupAll() local
102 Rendezvous* rendez = env_->rendezvous_mgr->Find(step_id); in AbortStep() local
77 Status Run(Rendezvous* rendez) { in Run()269 Rendezvous* rendez = NewLocalRendezvous(); in TEST_F() local385 Rendezvous* rendez = NewLocalRendezvous(); in TEST_F() local404 Rendezvous* rendez = NewLocalRendezvous(); in TEST_F() local
47 Rendezvous* rendez, const char* executor_type) { in Benchmark()
127 SimpleRendezvous* rendez = new SimpleRendezvous; in Run() local
183 IntraProcessRendezvous* rendez = nullptr; member
1041 IntraProcessRendezvous* rendez) { in SendPRunInputs()1101 IntraProcessRendezvous* rendez = run_state->rendez; in RecvPRunOutputs() local
133 tensorflow::Rendezvous* rendez, bool log_memory, in KernelAndDeviceOp()
228 Rendezvous* rendez = new IntraProcessRendezvous(lib->device_mgr()); in RunFunction() local
316 Rendezvous* rendez = NewLocalRendezvous(); in BM_SendRecv() local339 Rendezvous* rendez = NewLocalRendezvous(); in BM_PingPong() local
75 Status Run(Rendezvous* rendez) { in Run()