/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
|