Searched defs:rendez (Results 1 – 10 of 10) sorted by relevance
145 RemoteRendezvous* rendez = rmgr_.Find(step_id); in TEST_F() local166 RemoteRendezvous* rendez = rmgr_.Find(step_id); in TEST_F() local180 RemoteRendezvous* rendez = rmgr_.Find(step_id); in TEST_F() local200 RemoteRendezvous* rendez = rmgr_.Find(step_id); in TEST_F() local224 RemoteRendezvous* rendez = rmgr_.Find(step_id); in TEST_F() local264 RemoteRendezvous* rendez = rmgr_.Find(step_id); in TEST_F() local296 RemoteRendezvous* rendez = rmgr_.Find(step_id); in TEST_F() local315 RemoteRendezvous* rendez = rmgr_.Find(step_id); in TEST_F() local
41 static void StartAbortRendevous(Rendezvous* rendez, const Status& s) { in StartAbortRendevous()51 auto rendez = p.second; in ~BaseRendezvousMgr() local74 auto rendez = FindOrCreate(step_id); in RecvLocalAsync() local105 Rendezvous* rendez = nullptr; in Cleanup() local
109 Rendezvous* rendez = env_->rendezvous_mgr->Find(step_id); in AbortStep() local
89 Status Run(Rendezvous* rendez) { in Run()281 Rendezvous* rendez = NewLocalRendezvous(); in TEST_F() local397 Rendezvous* rendez = NewLocalRendezvous(); in TEST_F() local416 Rendezvous* rendez = NewLocalRendezvous(); in TEST_F() local
129 SimpleRendezvous rendez; in Run() local
51 Rendezvous* rendez, const char* executor_type, in Benchmark()
218 core::RefCountPtr<IntraProcessRendezvous> rendez = nullptr; member
1148 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
77 Status Run(Rendezvous* rendez) { in Run()