Searched refs:request_buf (Results 1 – 2 of 2) sorted by relevance
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_state.h | 285 Exchange(const ::grpc::ByteBuffer& request_buf, protobuf::Message* response, in Exchange() argument
288 request_buf_(request_buf), in Exchange()
293 const ::grpc::ByteBuffer& request_buf() { return request_buf_; } in request_buf() function
353 void Emplace(const ::grpc::ByteBuffer& request_buf,
434 ::grpc::ByteBuffer request_buf; in SendNextRequest()
435 ::grpc::Status s = GrpcMaybeUnparseProto(request, &request_buf); in SendNextRequest()
452 exchanges_.Emplace(request_buf, response, done, in SendNextRequest()
455 exchanges_.Emplace(request_buf, response, done, ""); in SendNextRequest()
586 call_->Write(exchange->request_buf(), &request_write_completed_tag_); in MaybeIssueRequestWriteLocked()
|
| D | grpc_state.cc | 89 void ExchangeQueue::Emplace(const ::grpc::ByteBuffer& request_buf, in Emplace() argument
92 exchanges_.emplace(exchanges_.end(), request_buf, response, std::move(cb), in Emplace()
|