| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | message_wrappers.cc | 133 return request_.session_handle(); in session_handle()
136 request_.set_session_handle(handle); in set_session_handle()
140 return request_.partial_run_handle(); in partial_run_handle()
143 request_.set_partial_run_handle(handle); in set_partial_run_handle()
147 return request_.feed_size(); in num_feeds()
150 return request_.feed(i).name(); in feed_name()
154 if (!ParseTensorProtoToTensor(request_.feed(i).tensor(), out_tensor)) { in FeedValue()
163 *out_tensor = request_.feed(i).tensor(); in FeedValue()
169 NamedTensorProto* feed = request_.add_feed(); in add_feed()
176 return request_.fetch_size(); in num_fetches()
[all …]
|
| /external/libbrillo/brillo/http/ |
| D | http_connection_fake.cc | 21 : http::Connection(transport), request_(url, method) { in Connection()
31 request_.AddHeaders(headers); in SendHeaders()
37 request_.SetData(std::move(stream)); in SetRequestData()
43 request_.AddHeaders( in FinishRequest()
44 {{request_header::kContentLength, ToString(request_.GetData().size())}}); in FinishRequest()
47 auto handler = transport->GetHandler(request_.GetURL(), request_.GetMethod()); in FinishRequest()
49 LOG(ERROR) << "Received unexpected " << request_.GetMethod() in FinishRequest()
50 << " request at " << request_.GetURL(); in FinishRequest()
55 handler.Run(request_, &response_); in FinishRequest()
110 if (request_.GetMethod() != request_type::kHead) { in ExtractDataStream()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/eager/ |
| D | destroy_tensor_handle_node.h | 36 request_(std::move(request)), in DestroyTensorHandleNode()
50 /*call_opts=*/nullptr, request_.get(), response, in RunAsync()
74 strings::StrAppend(&out, " request: ", request_->DebugString()); in DebugString()
79 std::unique_ptr<EnqueueRequest> request_;
|
| D | remote_execute_node.h | 49 request_(std::move(request)), in RemoteExecuteNode()
119 strings::StrAppend(&out, " request: ", request_->DebugString()); in DebugString()
126 std::unique_ptr<EnqueueRequest> request_; variable
|
| D | remote_execute_node.cc | 37 ops.reserve(request_->queue_size()); in RunAsync()
38 for (const QueueItem& item : request_->queue()) { in RunAsync()
77 call_opts.get(), request_.get(), response.get(), in RunAsync()
|
| /external/pigweed/pw_rpc/ |
| D | base_client_call.cc | 32 request_ = channel_->AcquireBuffer(); in AcquirePayloadBuffer()
33 return request_.payload(NewPacket(PacketType::REQUEST)); in AcquirePayloadBuffer()
42 return channel_->Send(request_, NewPacket(PacketType::REQUEST, payload)); in ReleasePayloadBuffer()
|
| /external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/codegen/ |
| D | message_allocator.h | 48 RequestT* request() { return request_; } in request()
52 void set_request(RequestT* request) { request_ = request; } in set_request()
57 RequestT* request_;
|
| D | server_interface.h | 281 request_(request) { in PayloadAsyncRequest()
297 payload_.bbuf_ptr(), request_) in FinalizeResult()
308 request_); in FinalizeResult()
316 interceptor_methods_.SetRecvMessage(request_, nullptr); in FinalizeResult()
322 Message* const request_; variable
|
| /external/rust/crates/grpcio-sys/grpc/include/grpcpp/impl/codegen/ |
| D | message_allocator.h | 48 RequestT* request() { return request_; } in request()
52 void set_request(RequestT* request) { request_ = request; } in set_request()
57 RequestT* request_;
|
| D | server_interface.h | 281 request_(request) { in PayloadAsyncRequest()
297 payload_.bbuf_ptr(), request_) in FinalizeResult()
308 request_); in FinalizeResult()
316 interceptor_methods_.SetRecvMessage(request_, nullptr); in FinalizeResult()
322 Message* const request_; variable
|
| /external/protobuf/conformance/ |
| D | conformance_test.cc | 75 request_.set_protobuf_payload(input); in ConformanceRequestSetting()
80 request_.set_json_payload(input); in ConformanceRequestSetting()
85 request_.set_jspb_payload(input); in ConformanceRequestSetting()
90 request_.set_text_payload(input); in ConformanceRequestSetting()
98 request_.set_test_category(test_category); in ConformanceRequestSetting()
100 request_.set_message_type(prototype_message.GetDescriptor()->full_name()); in ConformanceRequestSetting()
101 request_.set_requested_output_format(output_format); in ConformanceRequestSetting()
|
| D | conformance_test.h | 218 return request_; in GetRequest()
228 request_.set_print_unknown_fields(true); in SetPrintUnknownFields()
238 conformance::ConformanceRequest request_; variable
|
| /external/grpc-grpc/examples/cpp/helloworld/ |
| D | greeter_async_server.cc | 91 service_->RequestSayHello(&ctx_, &request_, &responder_, cq_, cq_, in Proceed()
101 reply_.set_message(prefix + request_.name()); in Proceed()
127 HelloRequest request_; member in ServerImpl::CallData
|
| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| D | server_interface.h | 211 request_(request) { in PayloadAsyncRequest()
222 payload_.bbuf_ptr(), request_) in FinalizeResult()
233 request_); in FinalizeResult()
249 Message* const request_; variable
|
| /external/rust/crates/grpcio-sys/grpc/src/cpp/server/ |
| D | server_cc.cc | 319 ~UnimplementedAsyncResponse() override { delete request_; } in ~UnimplementedAsyncResponse()
334 UnimplementedAsyncRequest* const request_; member in grpc::Server::UnimplementedAsyncResponse
426 request_(nullptr), in CallData()
465 request_ = handler->Deserialize(call_.call(), request_payload_, in Run()
471 interceptor_methods_.SetRecvMessage(request_, nullptr); in Run()
490 &call_, &ctx_, request_, request_status_, nullptr, nullptr)); in ContinueRunAfterInterception()
491 request_ = nullptr; in ContinueRunAfterInterception()
511 void* request_; member in grpc::Server::SyncRequest::CallData
664 req_->request_ = req_->method_->handler()->Deserialize( in Run()
670 req_->interceptor_methods_.SetRecvMessage(req_->request_, nullptr); in Run()
[all …]
|
| /external/grpc-grpc/test/cpp/qps/ |
| D | client_sync.cc | 132 stub->UnaryCall(&context, request_, &responses_[thread_idx]); in ThreadFuncImpl()
249 if (stream_[thread_idx]->Write(request_) && in ThreadFuncImpl()
309 if (stream_[thread_idx]->Write(request_)) { in ThreadFuncImpl()
345 stub->StreamingFromServer(&context_[thread_idx], request_); in InitThreadFuncImpl()
366 stub->StreamingFromServer(&context_[thread_idx], request_); in ThreadFuncImpl()
|
| /external/tensorflow/tensorflow/core/profiler/rpc/client/ |
| D | remote_profiler_session_manager.cc | 53 : options_(options), request_(request) { in RemoteProfilerSessionManager()
85 ProfileRequest request = request_; in Init()
|
| D | remote_profiler_session_manager.h | 73 ProfileRequest request_ TF_GUARDED_BY(mutex_);
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_call.h | 447 request_.Clear(); in RequestRead()
448 stream_.Read(&request_, &request_received_tag_); in RequestRead()
489 const RequestMessage& request() const { return request_; } in request()
495 RequestMessage request_;
|
| /external/grpc-grpc/src/cpp/server/load_reporter/ |
| D | load_reporter_async_service_impl.cc | 177 stream_.Read(&request_, &next_inbound_); in OnRequestDelivered()
203 if (!request_.has_initial_request()) { in OnReadDone()
207 const auto& initial_request = request_.initial_request(); in OnReadDone()
235 stream_.Read(&request_, &next_inbound_); in OnReadDone()
|
| /external/rust/crates/grpcio-sys/grpc/src/cpp/server/load_reporter/ |
| D | load_reporter_async_service_impl.cc | 180 stream_.Read(&request_, &next_inbound_); in OnRequestDelivered()
206 if (!request_.has_initial_request()) { in OnReadDone()
210 const auto& initial_request = request_.initial_request(); in OnReadDone()
238 stream_.Read(&request_, &next_inbound_); in OnReadDone()
|
| /external/openscreen/osp/public/ |
| D | message_demuxer_unittest.cc | 36 msgs::EncodePresentationConnectionOpenRequest(request_, &buffer_)); in SetUp()
44 EXPECT_EQ(request_.request_id, received_request.request_id); in ExpectDecodedRequest()
45 EXPECT_EQ(request_.presentation_id, received_request.presentation_id); in ExpectDecodedRequest()
46 EXPECT_EQ(request_.url, received_request.url); in ExpectDecodedRequest()
53 msgs::PresentationConnectionOpenRequest request_{1, "fry-am-the-egg-man", member in openscreen::osp::__anon61b657190111::MessageDemuxerTest
|
| /external/grpc-grpc/src/cpp/server/ |
| D | server_cc.cc | 127 ~UnimplementedAsyncResponse() { delete request_; } in ~UnimplementedAsyncResponse()
138 UnimplementedAsyncRequest* const request_; member in grpc::Server::UnimplementedAsyncResponse
765 : request_(request) { in UnimplementedAsyncResponse()
767 internal::UnknownMethodHandler::FillOps(request_->context(), this); in UnimplementedAsyncResponse()
768 request_->stream()->call_.PerformOps(this); in UnimplementedAsyncResponse()
|
| /external/rust/crates/grpcio-sys/grpc/src/cpp/server/health/ |
| D | default_health_check_service.cc | 282 service->RequestAsyncUnary(0, &handler->ctx_, &handler->request_, in CreateAndStart()
308 if (!service_->DecodeRequest(request_, &service_name)) { in OnCallReceived()
369 service->RequestAsyncServerStreaming(1, &handler->ctx_, &handler->request_, in CreateAndStart()
397 if (!service_->DecodeRequest(request_, &service_name_)) { in OnCallReceived()
|
| D | default_health_check_service.h | 138 ByteBuffer request_; variable
196 ByteBuffer request_; variable
|