| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | message_wrappers.cc | 655 return response_.recv_size(); in num_recvs()
659 return response_.recv(i).name(); in recv_key()
664 out_tensor->Swap(response_.mutable_recv(i)->mutable_tensor()); in RecvValue()
669 if (!ParseTensorProtoToTensor(response_.recv(i).tensor(), out_tensor)) { in RecvValue()
678 NamedTensorProto* recv = response_.add_recv(); in AddRecv()
685 return response_.mutable_step_stats(); in mutable_step_stats()
689 return response_.mutable_cost_graph(); in mutable_cost_graph()
693 return response_.status_code(); in status_code()
697 return response_.status_error_message(); in status_error_message()
701 response_.set_status_code(status.code()); in set_status()
[all …]
|
| D | message_wrappers.h | 560 RunGraphResponse response_;
587 RunGraphResponse* const response_;
700 RunStepResponse response_;
725 RunStepResponse* response_; // Not owned.
|
| /external/webrtc/webrtc/p2p/base/ |
| D | stunrequest_unittest.cc | 25 request_count_(0), response_(NULL), in StunRequestTest()
35 response_ = res; in OnResponse()
39 response_ = res; in OnErrorResponse()
69 StunMessage* response_; member in StunRequestTest
107 EXPECT_TRUE(response_ == res); in TEST_F()
122 EXPECT_TRUE(response_ == res); in TEST_F()
137 EXPECT_TRUE(response_ == NULL); in TEST_F()
162 EXPECT_TRUE(response_ == res); in TEST_F()
178 EXPECT_TRUE(response_ == NULL); in TEST_F()
198 EXPECT_TRUE(response_ == res); in TEST_F()
|
| /external/libbrillo/brillo/dbus/ |
| D | dbus_object_test_helpers.h | 44 response_ = std::move(response); in ReceiveResponse()
47 std::unique_ptr<dbus::Response> response_; member
70 response = std::move(response_holder.response_); in CallMethod()
106 CHECK(response_holder.response_.get()) in Call()
109 ExtractMethodCallResults(response_holder.response_.get(), error, &ret_val); in Call()
133 CHECK(response_holder.response_.get())
135 ExtractMethodCallResults(response_holder.response_.get(), error);
|
| /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 | 53 ServerResponse response_; variable
|
| /external/libtextclassifier/actions/ |
| D | lua-ranker.cc | 54 actions_iterator_.NewIterator("actions", &response_->actions, 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 | 48 response_(response), in ActionsSuggestionsLuaRanker()
60 ActionsSuggestionsResponse* response_; variable
|
| /external/tensorflow/tensorflow/core/platform/cloud/ |
| D | http_request_fake.h | 72 response_(response), in FakeHttpRequest()
130 buffer_->insert(buffer_->begin(), response_.data(), in Send()
131 response_.data() + response_.size()); in Send()
134 std::min<size_t>(direct_result_buffer_size_, response_.size()); in Send()
135 memcpy(direct_result_buffer_, response_.data(), bytes_to_copy); in Send()
184 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/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_;
|
| D | message.h | 356 Message response_; in COMPONENT_EXPORT() local
|
| /external/protobuf/src/google/protobuf/compiler/ |
| D | plugin.cc | 67 : response_(response), in GeneratorResponseContext()
74 CodeGeneratorResponse::File* file = response_->add_file(); in Open()
81 CodeGeneratorResponse::File* file = response_->add_file(); in OpenForInsert()
92 CodeGeneratorResponse* response_; member in google::protobuf::compiler::GeneratorResponseContext
|
| /external/google-breakpad/src/common/mac/ |
| D | HTTPMultipartUpload.m | 106 [response_ release];
191 [response_ release];
192 response_ = nil;
199 returningResponse:&response_
201 [response_ retain];
210 return response_;
|
| D | HTTPMultipartUpload.h | 43 NSHTTPURLResponse *response_; // The response from the send (STRONG) variable
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_state.h | 65 response_ = response; in RPCState()
143 if (!GrpcMaybeParseProto(&response_buf_, response_)) { in ParseAndCallDone()
155 Response* response_; variable
|
| /external/libchrome/mojo/public/cpp/bindings/lib/ |
| D | message.cc | 490 DCHECK(!response_.IsNull()); in GetBadMessageCallback()
491 return base::BindOnce(&DoNotifyBadMessage, std::move(response_)); in GetBadMessageCallback()
547 context->response_ = std::move(*message); in SetCurrentSyncResponseMessage()
|
| /external/protobuf/src/google/protobuf/compiler/cpp/ |
| D | cpp_unittest.cc | 1133 response_(NULL), in MockTestService()
1151 response_ = response; in Foo()
1164 response_ = response; in Bar()
1174 Message* response_; member in google::protobuf::compiler::cpp::cpp_unittest::GeneratedServiceTest::MockTestService
1185 response_(NULL), in MockRpcChannel()
1207 response_ = response; in CallMethod()
1217 Message* response_; member in google::protobuf::compiler::cpp::cpp_unittest::GeneratedServiceTest::MockRpcChannel
1316 EXPECT_EQ(&foo_response_ , mock_service_.response_ ); in TEST_F()
1370 EXPECT_EQ(&foo_response_ , mock_channel_.response_ ); in TEST_F()
|