| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | message_wrappers.cc | 137 return request_.session_handle(); in session_handle()
140 request_.set_session_handle(handle); in set_session_handle()
144 return request_.partial_run_handle(); in partial_run_handle()
147 request_.set_partial_run_handle(handle); in set_partial_run_handle()
151 return request_.feed_size(); in num_feeds()
154 return request_.feed(i).name(); in feed_name()
158 if (!ParseTensorProtoToTensor(request_.feed(i).tensor(), out_tensor)) { in FeedValue()
167 *out_tensor = request_.feed(i).tensor(); in FeedValue()
173 NamedTensorProto* feed = request_.add_feed(); in add_feed()
180 return request_.fetch_size(); in num_fetches()
[all …]
|
| D | message_wrappers.h | 198 RunStepRequest request_;
230 const RunStepRequest* const request_; // Not owned.
429 RunGraphRequest request_;
454 const RunGraphRequest* const request_; // Not owned.
|
| D | master_interface.h | 71 ret->request_.set_request_id(GetUniqueRequestId()); in CreateRunStepRequest()
|
| /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()
|
| D | http_connection_fake.h | 52 ServerRequest request_; variable
|
| /external/tensorflow/tensorflow/core/distributed_runtime/eager/ |
| D | destroy_tensor_handle_node.h | 35 request_(std::move(request)), in DestroyTensorHandleNode()
51 request_.get(), response, in RunAsync()
72 strings::StrAppend(&out, " request: ", request_->DebugString()); in DebugString()
77 std::unique_ptr<EnqueueRequest> request_;
|
| D | remote_execute_node.cc | 37 ops.reserve(request_->queue_size()); in RunAsync()
38 for (const QueueItem& item : request_->queue()) { in RunAsync()
60 request_.get(), response, in RunAsync()
|
| D | remote_execute_node.h | 45 request_(std::move(request)), in RemoteExecuteNode()
91 strings::StrAppend(&out, " request: ", request_->DebugString()); in DebugString()
97 std::unique_ptr<EnqueueRequest> request_;
|
| /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/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()
|
| D | client.h | 439 ClientRequestCreator<RequestType> create_req(&request_, in ClientImpl()
446 RequestType request_; variable
|
| D | client_async.cc | 159 using ClientImpl<StubType, RequestType>::request_;
188 setup_ctx(channels_[ch].get_stub(), next_issuers_[t], request_); in AsyncClient()
|
| /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()
|
| D | load_reporter_async_service_impl.h | 144 ::grpc::lb::v1::LoadReportRequest request_;
|
| /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/protobuf/src/google/protobuf/compiler/cpp/ |
| D | cpp_unittest.inc | 1206 request_(NULL),
1224 request_ = request;
1237 request_ = request;
1247 const Message* request_;
1258 request_(NULL),
1280 request_ = request;
1290 const Message* request_;
1389 EXPECT_EQ(&foo_request_ , mock_service_.request_ );
1443 EXPECT_EQ(&foo_request_ , mock_channel_.request_ );
|