Searched refs:RPCResponse (Results 1 – 3 of 3) sorted by relevance
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_response_cache.h | 35 class RPCResponse {
37 explicit RPCResponse() : buf_(nullptr), msg_(nullptr) {} in RPCResponse() function
38 explicit RPCResponse(::grpc::ByteBuffer* b) : buf_(b), msg_(nullptr) {} in RPCResponse() function
39 explicit RPCResponse(protobuf::Message* m) : buf_(nullptr), msg_(m) {} in RPCResponse() function
73 void LookupOrCompute(const string& key, RPCResponse response,
|
| D | grpc_response_cache.cc | 37 std::vector<std::pair<RPCResponse, StatusCallback>> callbacks;
40 void RPCResponse::Encode(::grpc::ByteBuffer* tgt) const { in Encode()
53 void RPCResponse::CopyFrom(const ::grpc::ByteBuffer& src) { in CopyFrom()
69 void GrpcResponseCache::LookupOrCompute(const string& key, RPCResponse response, in LookupOrCompute()
|
| D | grpc_worker_service.cc | 253 cache_->LookupOrCompute(request_key, RPCResponse(&call->response), in RunGraphHandler()
284 cache_->LookupOrCompute(request_key, RPCResponse(&call->response), in RecvTensorHandlerRaw()
|