Searched refs:rendezvous_done (Results 1 – 1 of 1) sorted by relevance
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_worker_service.cc | 468 auto rendezvous_done = [this, request_id, do_response, cache_enabled]( in GrpcRecvTensorAsync() local
479 auto fail = [&rendezvous_done](const Status& status) { in GrpcRecvTensorAsync()
480 rendezvous_done(Tensor(), false, status); in GrpcRecvTensorAsync()
513 [opts, rendezvous_done, src_dev, request]( in GrpcRecvTensorAsync()
540 StatusCallback copy_ready = [rendezvous_done, copy, in GrpcRecvTensorAsync()
543 rendezvous_done(*copy, is_dead, s); in GrpcRecvTensorAsync()
554 rendezvous_done(val, is_dead, status); in GrpcRecvTensorAsync()
612 auto rendezvous_done = [this, request_id, do_response, cache_enabled]( in RecvBufAsync() local
622 auto fail = [&rendezvous_done](const Status& status) { in RecvBufAsync()
623 rendezvous_done(Tensor(), status); in RecvBufAsync()
[all …]
|