Home | History | Annotate | Download | only in rpc

Lines Matching refs:step_id

85   const int64 step_id = 123;
90 RemoteRendezvous* rendez = rmgr_.Find(step_id);
99 TF_ASSERT_OK(rmgr_.RecvLocal(step_id, key, &val, &val_dead));
102 rmgr_.Cleanup(step_id);
110 const int64 step_id = 123;
111 RemoteRendezvous* rendez = rmgr_.Find(step_id);
124 const int64 step_id = 321;
125 RemoteRendezvous* rendez = rmgr_.Find(step_id);
127 SchedClosure([this, step_id]() {
129 rmgr_.Cleanup(step_id);
144 const int64 step_id = 123;
145 RemoteRendezvous* rendez = rmgr_.Find(step_id);
170 const int64 step_id = 123;
175 RemoteRendezvous* rendez = rmgr_.Find(step_id);
185 step_id, key,
197 rmgr_.Cleanup(step_id);