| /device/google/cuttlefish_common/common/libs/net/ |
| netlink_request.cpp | 38 void* out = request_.end();
40 request_.Append(data, length);
43 request_.Resize(request_.size() + pad);
50 void* out = request_.end();
51 request_.Resize(request_.size() + RTA_ALIGN(length));
65 : request_(512),
78 request_.Swap(other.request_);
[all...] |
| netlink_request.h | 103 AutoFreeBuffer request_; member in class:cvd::NetlinkRequest
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| message_wrappers.cc | 135 return request_.session_handle();
138 request_.set_session_handle(handle);
142 return request_.partial_run_handle();
145 request_.set_partial_run_handle(handle);
149 return request_.feed_size();
152 return request_.feed(i).name();
156 if (!ParseTensorProtoToTensor(request_.feed(i).tensor(), out_tensor)) {
165 *out_tensor = request_.feed(i).tensor();
171 NamedTensorProto* feed = request_.add_feed();
178 return request_.fetch_size()
[all...] |
| master_interface.h | 71 ret->request_.set_request_id(GetUniqueRequestId());
|
| message_wrappers.h | 195 RunStepRequest request_; member in class:tensorflow::MutableProtoRunStepRequest
227 const RunStepRequest* const request_; // Not owned. member in class:tensorflow::ProtoRunStepRequest
418 RunGraphRequest request_; member in class:tensorflow::MutableProtoRunGraphRequest
442 const RunGraphRequest* const request_; // Not owned. member in class:tensorflow::ProtoRunGraphRequest
|
| /external/libbrillo/brillo/http/ |
| http_connection_fake.cc | 21 : http::Connection(transport), request_(url, method) {
31 request_.AddHeaders(headers);
37 request_.SetData(std::move(stream));
43 request_.AddHeaders(
44 {{request_header::kContentLength, ToString(request_.GetData().size())}});
47 auto handler = transport->GetHandler(request_.GetURL(), request_.GetMethod());
49 LOG(ERROR) << "Received unexpected " << request_.GetMethod()
50 << " request at " << request_.GetURL();
55 handler.Run(request_, &response_)
[all...] |
| http_connection_fake.h | 52 ServerRequest request_; member in class:brillo::http::fake::Connection
|
| /external/tensorflow/tensorflow/core/distributed_runtime/eager/ |
| remote_execute_node.h | 38 request_(std::move(request)),
51 request_(std::move(request)),
64 eager_client_->EnqueueAsync(request_.get(), &response,
79 std::unique_ptr<EnqueueRequest> request_; member in class:tensorflow::eager::RemoteExecuteNode
|
| /external/grpc-grpc/examples/cpp/helloworld/ |
| greeter_async_server.cc | 91 service_->RequestSayHello(&ctx_, &request_, &responder_, cq_, cq_,
101 reply_.set_message(prefix + request_.name());
127 HelloRequest request_; member in class:final::CallData
|
| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| server_interface.h | 211 request_(request) {
222 payload_.bbuf_ptr(), request_)
233 request_);
249 Message* const request_; member in class:grpc::ServerInterface::final
|
| /external/tensorflow/tensorflow/contrib/bigtable/kernels/test_kernels/ |
| bigtable_test_client.cc | 107 : client_(client), request_(request) {}
202 for (auto i = request_.rows().row_keys().begin();
203 i != request_.rows().row_keys().end(); ++i) {
206 for (auto i = request_.rows().row_ranges().begin();
207 i != request_.rows().row_ranges().end(); ++i) {
218 if (request_.filter().has_chain()) {
221 for (auto i = request_.filter().chain().filters().begin();
222 i != request_.filter().chain().filters().end(); ++i) {
261 << request_.filter().DebugString();
269 const google::bigtable::v2::ReadRowsRequest request_; member in class:tensorflow::ReadRowsResponse
[all...] |
| /external/grpc-grpc/test/cpp/qps/ |
| client_sync.cc | 132 stub->UnaryCall(&context, request_, &responses_[thread_idx]);
249 if (stream_[thread_idx]->Write(request_) &&
309 if (stream_[thread_idx]->Write(request_)) {
345 stub->StreamingFromServer(&context_[thread_idx], request_);
366 stub->StreamingFromServer(&context_[thread_idx], request_);
|
| client.h | 439 ClientRequestCreator<RequestType> create_req(&request_,
446 RequestType request_; member in class:grpc::testing::ClientImpl
|
| client_async.cc | 159 using ClientImpl<StubType, RequestType>::request_;
188 setup_ctx(channels_[ch].get_stub(), next_issuers_[t], request_);
[all...] |
| /external/grpc-grpc/src/cpp/server/load_reporter/ |
| load_reporter_async_service_impl.cc | 177 stream_.Read(&request_, &next_inbound_);
203 if (!request_.has_initial_request()) {
207 const auto& initial_request = request_.initial_request();
235 stream_.Read(&request_, &next_inbound_);
|
| load_reporter_async_service_impl.h | 144 ::grpc::lb::v1::LoadReportRequest request_; member in class:grpc::load_reporter::LoadReporterAsyncServiceImpl::ReportLoadHandler
|
| /external/grpc-grpc/src/cpp/server/ |
| server_cc.cc | 127 ~UnimplementedAsyncResponse() { delete request_; }
138 UnimplementedAsyncRequest* const request_; member in class:grpc::final
765 : request_(request) {
767 internal::UnknownMethodHandler::FillOps(request_->context(), this);
768 request_->stream()->call_.PerformOps(this);
|
| /external/protobuf/src/google/protobuf/compiler/cpp/ |
| cpp_unittest.cc | 1173 const Message* request_; member in class:google::protobuf::compiler::cpp::cpp_unittest::GeneratedServiceTest::MockTestService
1216 const Message* request_; member in class:google::protobuf::compiler::cpp::cpp_unittest::GeneratedServiceTest::MockRpcChannel
[all...] |
