Searched defs:rendez (Results 1 – 11 of 11) sorted by relevance
149 RemoteRendezvous* rendez = rmgr_.Find(step_id); in TEST_F() local170 RemoteRendezvous* rendez = rmgr_.Find(step_id); in TEST_F() local184 RemoteRendezvous* rendez = rmgr_.Find(step_id); in TEST_F() local204 RemoteRendezvous* rendez = rmgr_.Find(step_id); in TEST_F() local228 RemoteRendezvous* rendez = rmgr_.Find(step_id); in TEST_F() local268 RemoteRendezvous* rendez = rmgr_.Find(step_id); in TEST_F() local300 RemoteRendezvous* rendez = rmgr_.Find(step_id); in TEST_F() local319 RemoteRendezvous* rendez = rmgr_.Find(step_id); in TEST_F() local
43 static void StartAbortRendevous(Rendezvous* rendez, const Status& s) { in StartAbortRendevous()53 auto rendez = p.second; in ~BaseRendezvousMgr() local76 auto rendez = FindOrCreate(step_id); in RecvLocalAsync() local107 Rendezvous* rendez = nullptr; in Cleanup() local
112 RemoteRendezvous* rendez = env_->rendezvous_mgr->Find(step_id); in AbortStep() local
95 Status Run(Rendezvous* rendez) { in Run()287 Rendezvous* rendez = NewLocalRendezvous(); in TEST_F() local402 Rendezvous* rendez = NewLocalRendezvous(); in TEST_F() local421 Rendezvous* rendez = NewLocalRendezvous(); in TEST_F() local
129 SimpleRendezvous rendez; in Run() local
50 Rendezvous* rendez, const char* executor_type, in Benchmark()
218 core::RefCountPtr<IntraProcessRendezvous> rendez = nullptr; member
112 Status Run(Rendezvous* rendez) { in Run()
1165 IntraProcessRendezvous* rendez) { in SendPRunInputs()
438 Rendezvous* rendez = NewLocalRendezvous(); in BM_SendRecv() local455 Rendezvous* rendez = NewLocalRendezvous(); in BM_RecvSend() local492 Rendezvous* rendez = NewLocalRendezvous(); in BM_PingPong() local
1425 PrivateIntraProcessRendezvous rendez(device_mgr_); in InitializeVarOnTPU() local1592 PrivateIntraProcessRendezvous rendez(device_mgr_); in InitializeShardedVarOnTPU() local2695 auto* rendez = new RefCountedIntraProcessRendezvous(device_mgr_); in ExecuteFunctions() local