| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | message_wrappers.cc | 674 return response_.recv_size(); in num_recvs()
678 return response_.recv(i).name(); in recv_key()
683 out_tensor->Swap(response_.mutable_recv(i)->mutable_tensor()); in RecvValue()
688 if (!ParseTensorProtoToTensor(response_.recv(i).tensor(), out_tensor)) { in RecvValue()
697 NamedTensorProto* recv = response_.add_recv(); in AddRecv()
704 return response_.mutable_step_stats(); in mutable_step_stats()
708 return response_.mutable_cost_graph(); in mutable_cost_graph()
712 return response_.status_code(); in status_code()
716 return response_.status_error_message(); in status_error_message()
720 response_.set_status_code(status.code()); in set_status()
[all …]
|
| /external/pigweed/pw_metric/ |
| D | metric_service_nanopb.cc | 31 : response_(pw_metric_MetricResponse_init_zero), in MetricWriter()
40 std::span<pw_metric_Metric> metrics(response_.metrics); in Write()
41 PW_CHECK_INT_LT(response_.metrics_count, metrics.size()); in Write()
44 pw_metric_Metric& proto_metric = response_.metrics[response_.metrics_count]; in Write()
62 response_.metrics_count++; in Write()
66 if (response_.metrics_count == metrics.size()) { in Write()
72 if (response_.metrics_count) { in Flush()
73 response_writer_.Write(response_); in Flush()
74 response_ = pw_metric_MetricResponse_init_zero; in Flush()
79 pw_metric_MetricResponse response_; member in pw::metric::__anon4653944a0111::MetricWriter
|
| /external/pigweed/pw_rpc/ |
| D | base_server_writer.cc | 42 response_ = std::move(other.response_); in operator =()
56 if (!response_.empty()) { in Finish()
75 if (response_.empty()) { in AcquirePayloadBuffer()
76 response_ = call_.channel().AcquireBuffer(); in AcquirePayloadBuffer()
79 return response_.payload(ResponsePacket()); in AcquirePayloadBuffer()
85 return call_.channel().Send(response_, ResponsePacket(payload)); in ReleasePayloadBuffer()
90 call_.channel().Release(response_); in ReleasePayloadBuffer()
|
| /external/webrtc/p2p/base/ |
| D | stun_request_unittest.cc | 28 response_(NULL), in StunRequestTest()
40 response_ = res; in OnResponse()
44 response_ = res; in OnErrorResponse()
67 StunMessage* response_; member in cricket::StunRequestTest
102 EXPECT_TRUE(response_ == res); in TEST_F()
117 EXPECT_TRUE(response_ == res); in TEST_F()
132 EXPECT_TRUE(response_ == NULL); in TEST_F()
157 EXPECT_TRUE(response_ == res); in TEST_F()
174 EXPECT_TRUE(response_ == NULL); in TEST_F()
194 EXPECT_TRUE(response_ == res); in TEST_F()
[all …]
|
| /external/libbrillo/brillo/http/ |
| D | http_connection_fake.cc | 51 response_.ReplyText(status_code::NotFound, in FinishRequest()
55 handler.Run(request_, &response_); in FinishRequest()
92 return response_.GetStatusCode(); in GetResponseStatusCode()
96 return response_.GetStatusText(); in GetResponseStatusText()
100 return response_.GetProtocolVersion(); in GetProtocolVersion()
105 return response_.GetHeader(header_name); in GetResponseHeader()
111 return MemoryStream::OpenRef(response_.GetData(), error); in ExtractDataStream()
|
| D | http_connection_fake.h | 55 ServerResponse response_; variable
|
| /external/libbrillo/brillo/dbus/ |
| D | dbus_object_test_helpers.h | 47 response_ = std::move(response); in ReceiveResponse()
50 std::unique_ptr<::dbus::Response> response_; member
73 response = std::move(response_holder.response_); in CallMethod()
109 CHECK(response_holder.response_.get()) in Call()
112 ExtractMethodCallResults(response_holder.response_.get(), error, &ret_val); in Call()
136 CHECK(response_holder.response_.get())
138 ExtractMethodCallResults(response_holder.response_.get(), error);
|
| /external/libtextclassifier/native/actions/ |
| D | lua-ranker.cc | 55 PushActions(&response_->actions, actions_entity_data_schema_, in Initialize()
80 if (action_id < 0 || action_id >= response_->actions.size()) { in ReadActionsRanking()
85 ranked_actions.push_back(response_->actions[action_id]); in ReadActionsRanking()
88 response_->actions = ranked_actions; in ReadActionsRanking()
93 if (response_->actions.empty()) { in RankActions()
|
| D | lua-ranker.h | 49 response_(response) {} in ActionsSuggestionsLuaRanker()
60 ActionsSuggestionsResponse* response_; variable
|
| /external/tensorflow/tensorflow/core/platform/cloud/ |
| D | http_request_fake.h | 73 response_(response), in FakeHttpRequest()
131 buffer_->insert(buffer_->begin(), response_.data(), in Send()
132 response_.data() + response_.size()); in Send()
135 std::min<size_t>(direct_result_buffer_size_, response_.size()); in Send()
136 memcpy(direct_result_buffer_, response_.data(), bytes_to_copy); in Send()
185 string response_; variable
|
| /external/grpc-grpc/test/cpp/qps/ |
| D | server_async.cc | 287 grpc::Status status = invoke_method_(&req_, &response_); in invoker()
291 response_writer_.Finish(response_, status, AsyncQpsServerTest::tag(this)); in invoker()
296 ResponseType response_; member in grpc::testing::AsyncQpsServerTest::ServerRpcContextUnaryImpl
347 grpc::Status status = invoke_method_(&req_, &response_); in read_done()
350 stream_.Write(response_, AsyncQpsServerTest::tag(this)); in read_done()
373 ResponseType response_; member in grpc::testing::AsyncQpsServerTest::ServerRpcContextStreamingImpl
431 grpc::Status status = invoke_method_(&req_, &response_); in read_done()
434 stream_.Finish(response_, Status::OK, AsyncQpsServerTest::tag(this)); in read_done()
442 ResponseType response_; member in grpc::testing::AsyncQpsServerTest::ServerRpcContextStreamingFromClientImpl
488 grpc::Status status = invoke_method_(&req_, &response_); in request_done()
[all …]
|
| D | client_async.cc | 79 response_(), in ClientRpcContextUnaryImpl()
96 response_reader_->Finish(&response_, &status_, in RunNextState()
103 callback_(status_, &response_, entry); in RunNextState()
124 ResponseType response_; member in grpc::testing::ClientRpcContextUnaryImpl
350 response_(), in ClientRpcContextStreamingPingPongImpl()
393 stream_->Read(&response_, ClientRpcContext::tag(this)); in RunNextState()
398 callback_(status_, &response_); in RunNextState()
439 ResponseType response_; member in grpc::testing::ClientRpcContextStreamingPingPongImpl
535 response_(), in ClientRpcContextStreamingFromClientImpl()
594 ResponseType response_; member in grpc::testing::ClientRpcContextStreamingFromClientImpl
[all …]
|
| /external/tensorflow/tensorflow/core/profiler/rpc/client/ |
| D | profiler_client.cc | 98 : response_(absl::make_unique<ProfileResponse>()), in RemoteProfilerSession()
103 response_->set_empty_trace(true); in RemoteProfilerSession()
119 rpc_->Finish(response_.get(), &grpc_status_, in ProfileAsync()
126 if (!response_) { in WaitForCompletion()
158 return std::move(response_); in WaitForCompletion()
|
| /external/libchrome/mojo/public/cpp/bindings/ |
| D | thread_safe_interface_ptr.h | 186 : response_(response) {} in SyncResponseSignaler()
191 if (response_) in ~SyncResponseSignaler()
192 response_->event.Signal(); in ~SyncResponseSignaler()
196 response_->message = std::move(*message); in Accept()
197 response_->received = true; in Accept()
198 response_->event.Signal(); in Accept()
199 response_ = nullptr; in Accept()
204 scoped_refptr<SyncResponseInfo> response_;
|
| /external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/codegen/ |
| D | message_allocator.h | 49 ResponseT* response() { return response_; } in response()
53 void set_response(ResponseT* response) { response_ = response; } in set_response()
58 ResponseT* response_; variable
|
| /external/rust/crates/grpcio-sys/grpc/include/grpcpp/impl/codegen/ |
| D | message_allocator.h | 49 ResponseT* response() { return response_; } in response()
53 void set_response(ResponseT* response) { response_ = response; } in set_response()
58 ResponseT* response_; variable
|
| /external/protobuf/src/google/protobuf/compiler/ |
| D | plugin.cc | 69 response_(response), in GeneratorResponseContext()
76 CodeGeneratorResponse::File* file = response_->add_file(); in Open()
83 CodeGeneratorResponse::File* file = response_->add_file(); in OpenForInsert()
99 CodeGeneratorResponse* response_; member in google::protobuf::compiler::GeneratorResponseContext
|
| /external/rust/crates/grpcio-sys/grpc/third_party/cares/cares/test/ |
| D | dns-proto-test.cc | 43 pkt.response_ = true; in TEST()
88 pkt.response_ = true; in TEST()
|
| D | dns-proto.h | 188 : qid_(0), response_(false), opcode_(ns_o_query), in DNSPacket()
210 DNSPacket& set_response(bool v = true) { response_ = v; return *this; }
224 bool response_; member
|
| /external/pigweed/pw_rpc/public/pw_rpc/internal/ |
| D | test_method.h | 38 void set_response(std::span<const std::byte> payload) { response_ = payload; } in set_response()
56 std::span<const std::byte> response_; variable
|
| D | base_server_writer.h | 71 constexpr const Channel::OutputBuffer& buffer() const { return response_; } in buffer()
92 Channel::OutputBuffer response_; variable
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_call.h | 459 stream_.Write(response_, &response_sent_tag_); in SendResponse()
463 response_.Clear(); in SendResponse()
490 ResponseMessage* mutable_response() { return &response_; } in mutable_response()
496 ResponseMessage response_; variable
|
| D | grpc_state.h | 107 response_ = response; in RPCState()
199 if (!GrpcMaybeParseProto(&response_buf_, response_)) { in ParseAndCallDone()
211 Response* response_; variable
289 response_(response), in Exchange()
322 protobuf::Message* response_; variable
|
| /external/google-breakpad/src/common/mac/ |
| D | HTTPMultipartUpload.m | 163 [response_ release];
246 [response_ release];
247 response_ = nil;
255 response_ = (NSHTTPURLResponse *)[response retain];
264 return response_;
|
| D | HTTPMultipartUpload.h | 43 NSHTTPURLResponse *response_; // The response from the send (STRONG) variable
|