Searched refs:buf_rendezvous_ (Results 1 – 3 of 3) sorted by relevance
32 buf_rendezvous_(step_id), in CollectiveRemoteAccessLocal()71 BufRendezvous* buf_rendezvous() override { return &buf_rendezvous_; } in buf_rendezvous()87 BufRendezvous buf_rendezvous_; variable
23 buf_rendezvous_.StartAbort(s); in StartAbort()40 buf_rendezvous_.ConsumeBuf( in RecvFromPeer()78 buf_rendezvous_.ProvideBuf(key, from_device, from_device_ctx, from_tensor, in PostToPeer()
68 buf_rendezvous_(kStepId) {} in FakeWorker()72 BufRendezvous* buf_rendezvous() { return &buf_rendezvous_; } in buf_rendezvous()95 buf_rendezvous_.StartAbort(errors::Internal("Cancelled")); in RecvBufAsync()98 buf_rendezvous_.ConsumeBuf( in RecvBufAsync()122 BufRendezvous buf_rendezvous_; member in tensorflow::__anond64f02c00111::FakeWorker