| /external/libchrome/mojo/core/ |
| broker_host.cc | 128 BufferResponseData* response; local
130 BrokerMessageType::BUFFER_RESPONSE, handles.size(), 0, &response);
133 response->guid_high = guid.GetHighForSerialization();
134 response->guid_low = guid.GetLowForSerialization();
|
| broker_win.cc | 142 Channel::MessagePtr response = WaitForBrokerMessage( local
144 if (response && TakeHandlesFromBrokerMessage(response.get(), 1, &handle)) {
146 if (!GetBrokerMessageData(response.get(), &data))
|
| /external/nanohttpd/core/src/test/java/fi/iki/elonen/ |
| HttpSSLServerTest.java | 57 HttpResponse response = httpclient.execute(httphead); local
58 HttpEntity entity = response.getEntity();
59 Assert.assertEquals(200, response.getStatusLine().getStatusCode());
|
| SSLServerSocketFactoryTest.java | 58 HttpResponse response = httpclient.execute(httphead); local
59 HttpEntity entity = response.getEntity();
60 Assert.assertEquals(200, response.getStatusLine().getStatusCode());
|
| /external/nanohttpd/core/src/test/java/fi/iki/elonen/integration/ |
| GZipIntegrationTest.java | 60 public Response response; field in class:GZipIntegrationTest.TestServer
67 public Response serve(IHTTPSession session) {
68 return response;
72 protected boolean useGzipWhenAccepted(Response r) {
84 testServer.response = NanoHTTPD.newFixedLengthResponse("This is a test");
87 HttpResponse response = httpclient.execute(request); local
88 Header contentEncoding = response.getFirstHeader("content-encoding");
96 testServer.response = NanoHTTPD.newChunkedResponse(NanoHTTPD.Response.Status.OK, "text/plain", data)
99 HttpResponse response = httpclient.execute(request); local
110 HttpResponse response = httpclient.execute(request); local
121 HttpResponse response = httpclient.execute(request); local
131 HttpResponse response = new DecompressingHttpClient(httpclient).execute(request); local
141 HttpResponse response = new DecompressingHttpClient(httpclient).execute(request); local
149 HttpResponse response = httpclient.execute(request); local
161 HttpResponse response = httpclient.execute(request); local
[all...] |
| PutStreamIntegrationTest.java | 59 public Response serve(IHTTPSession session) {
70 return newFixedLengthResponse(Response.Status.INTERNAL_ERROR, NanoHTTPD.MIME_PLAINTEXT, e.getMessage());
73 String response = String.valueOf(method) + ':' + new String(body); local
74 return newFixedLengthResponse(response);
78 public Response serve(String uri, Method method, Map<String, String> headers, Map<String, String> parms, Map<String, String> files) {
|
| /external/nos/host/android/hals/keymaster/test/ |
| import_wrapped_key_test.cpp | 315 ImportKeyResponse response; local
345 // response
347 response.mutable_blob()->set_blob(response_key_blob);
349 response.mutable_characteristics()->
354 noskp = response.mutable_characteristics()->
371 .WillOnce(DoAll(SetArgPointee<1>(response), Return(APP_SUCCESS)));
|
| /external/nos/test/system-test-harness/src/ |
| keymaster-import-key-tests.cc | 111 ImportKeyResponse response; local
124 ASSERT_NO_ERROR(service->ImportKey(request, &response), "");
125 EXPECT_EQ((ErrorCode)response.error_code(), ErrorCode::INVALID_ARGUMENT);
132 ImportKeyResponse response; local
136 ASSERT_NO_ERROR(service->ImportKey(request, &response), "");
137 EXPECT_EQ((ErrorCode)response.error_code(), ErrorCode::UNSUPPORTED_KEY_SIZE);
142 ImportKeyResponse response; local
148 ASSERT_NO_ERROR(service->ImportKey(request, &response), "");
149 EXPECT_EQ((ErrorCode)response.error_code(),
155 ImportKeyResponse response; local
167 ImportKeyResponse response; local
179 ImportKeyResponse response; local
191 ImportKeyResponse response; local
204 ImportKeyResponse response; local
217 ImportKeyResponse response; local
230 ImportKeyResponse response; local
255 ImportKeyResponse response; local
345 ImportKeyResponse response; local
361 ImportKeyResponse response; local
374 ImportKeyResponse response; local
393 ImportKeyResponse response; local
416 ImportKeyResponse response; local
439 ImportKeyResponse response; local
483 ImportKeyResponse response; local
[all...] |
| keymaster-import-wrapped-key-tests.cc | 242 ImportKeyResponse response; local
261 ASSERT_NO_ERROR(service->ImportWrappedKey(request, &response), "");
262 EXPECT_EQ((ErrorCode)response.error_code(), ErrorCode::OK);
|
| /external/nos/test/system-test-harness/tools/ |
| avb_tools.cc | 52 GetStateResponse response; local
55 ASSERT_NO_ERROR(service.GetState(request, &response), "");
56 EXPECT_EQ(response.number_of_locks(), 4U);
59 *bootloader = response.bootloader();
61 *production = response.production();
63 auto response_locks = response.locks();
92 GetResetChallengeResponse response; local
95 uint32_t ret = service.GetResetChallenge(request, &response);
99 *selector = response.selector();
100 *nonce = response.nonce()
[all...] |
| /external/okhttp/benchmarks/src/main/java/com/squareup/okhttp/benchmarks/ |
| ApacheHttpClient.java | 66 HttpResponse response = client.execute(new HttpGet(url.toString())); local
67 InputStream in = response.getEntity().getContent();
68 Header contentEncoding = response.getFirstHeader("Content-Encoding");
|
| /external/okhttp/samples/guide/src/main/java/com/squareup/okhttp/recipes/ |
| Progress.java | 21 import com.squareup.okhttp.Response;
50 @Override public Response intercept(Chain chain) throws IOException {
51 Response originalResponse = chain.proceed(chain.request());
58 Response response = client.newCall(request).execute(); local
59 if (!response.isSuccessful()) throw new IOException("Unexpected code " + response);
61 System.out.println(response.body().string());
|
| RequestBodyCompression.java | 24 import com.squareup.okhttp.Response;
57 Response response = client.newCall(request).execute(); local
58 if (!response.isSuccessful()) throw new IOException("Unexpected code " + response);
60 System.out.println(response.body().string());
69 @Override public Response intercept(Chain chain) throws IOException {
|
| /external/okhttp/samples/simple-client/src/main/java/com/squareup/okhttp/sample/ |
| OkHttpContributors.java | 7 import com.squareup.okhttp.Response;
34 // Execute the request and retrieve the response.
35 Response response = client.newCall(request).execute(); local
37 // Deserialize HTTP response to concrete type.
38 ResponseBody body = response.body();
|
| /external/protobuf/conformance/ |
| conformance_cpp.cc | 88 void DoTest(const ConformanceRequest& request, ConformanceResponse* response) {
96 response->set_parse_error("Parse error (no more details available).");
106 response->set_parse_error(string("Parse error: ") +
112 response->set_runtime_error(
131 test_message.SerializeToString(response->mutable_protobuf_payload()));
138 response->mutable_json_payload());
140 response->set_serialize_error(
158 ConformanceResponse response; local
177 DoTest(request, &response);
179 response.SerializeToString(&serialized_output)
[all...] |
| /external/protobuf/src/google/protobuf/compiler/ |
| plugin.cc | 65 GeneratorResponseContext(CodeGeneratorResponse* response,
67 : response_(response),
97 const CodeGenerator& generator, CodeGeneratorResponse* response,
119 GeneratorResponseContext context(response, parsed_files);
131 response->set_error(error);
146 response->set_error(file->name() + ": " + error);
175 CodeGeneratorResponse response; local
177 if (GenerateCode(request, *generator, &response, &error_msg)) {
178 if (!response.SerializeToFileDescriptor(STDOUT_FILENO)) {
|
| /external/python/google-api-python-client/googleapiclient/ |
| model.py | 72 def response(self, resp, content): member in class:Model
73 """Convert the response wire format into a Python object.
76 resp: httplib2.Response, the HTTP response headers and status
77 content: string, the body of the HTTP response
83 googleapiclient.errors.HttpError if a non 2xx response is received.
98 Content" response.
179 """Logs debugging information about the response if requested."""
181 LOGGER.info('--response-start--')
186 LOGGER.info('--response-end--'
188 def response(self, resp, content): member in class:BaseModel
[all...] |
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| message_wrappers_test.cc | 114 void CheckRunGraphResponse(MutableRunGraphResponseWrapper* response) {
115 ASSERT_EQ(2, response->num_recvs());
116 EXPECT_EQ("recv_2", response->recv_key(0));
117 EXPECT_EQ("recv_3", response->recv_key(1));
119 TF_EXPECT_OK(response->RecvValue(0, &val));
121 TF_EXPECT_OK(response->RecvValue(1, &val));
123 ASSERT_EQ(1, response->mutable_step_stats()->dev_stats_size());
124 EXPECT_EQ("/cpu:0", response->mutable_step_stats()->dev_stats(0).device());
125 ASSERT_EQ(1, response->mutable_cost_graph()->node_size());
126 EXPECT_EQ("cost_node", response->mutable_cost_graph()->node(0).name())
259 InMemoryRunStepResponse response; local
268 OwnedProtoRunStepResponse response; local
287 InMemoryRunStepResponse response; local
296 OwnedProtoRunStepResponse response; local
316 InMemoryRunStepResponse response; local
326 OwnedProtoRunStepResponse response; local
[all...] |
| rpc_collective_executor_mgr_test.cc | 131 GetStepSequenceResponse response; local
137 cme_->GetStepSequenceAsync(&request, &response,
145 ASSERT_EQ(2, response.step_sequence_size());
147 for (const auto& ss : response.step_sequence()) {
153 response.Clear();
157 cme_->GetStepSequenceAsync(&request, &response,
165 ASSERT_EQ(2, response.step_sequence_size());
166 for (const auto& ss : response.step_sequence()) {
|
| tensor_coding_test.cc | 91 TensorResponse response; local
93 response.InitAlloc(&cpu_device, AllocatorAttributes());
94 for (int i = 0; i < 2; i++) { // Twice so we exercise reuse of "response"
95 Status s = response.ParseFrom(&source);
98 const RecvTensorResponse& meta = response.metadata();
102 const Tensor& result = response.tensor();
182 TensorResponse response; local
183 response.InitAlloc(&cpu_device, AllocatorAttributes());
185 Status s = response.ParseFrom(&source);
188 strings::StrCat("Bytes: ", response.tensor().TotalBytes()))
[all...] |
| /external/tensorflow/tensorflow/lite/models/smartreply/ |
| predictor_test.cc | 45 MATCHER_P(IncludeAnyResponesIn, expected_response, "contains the response") {
48 const string &response = item.GetText(); local
49 if (expected_response.find(response) != expected_response.end()) {
140 // Validate response and generate stats.
|
| /external/u-boot/drivers/fastboot/ |
| fb_getvar.c | 14 static void getvar_version(char *var_parameter, char *response);
15 static void getvar_bootloader_version(char *var_parameter, char *response);
16 static void getvar_downloadsize(char *var_parameter, char *response);
17 static void getvar_serialno(char *var_parameter, char *response);
18 static void getvar_version_baseband(char *var_parameter, char *response);
19 static void getvar_product(char *var_parameter, char *response);
20 static void getvar_current_slot(char *var_parameter, char *response);
21 static void getvar_slot_suffixes(char *var_parameter, char *response);
22 static void getvar_has_slot(char *var_parameter, char *response);
24 static void getvar_partition_type(char *part_name, char *response);
154 fastboot_okay(fs_get_type_name(), response); local
[all...] |
| /external/u-boot/lib/ |
| tpm-v2.c | 135 u8 response[COMMAND_BUFFER_SIZE]; local
145 ret = tpm_sendrecv_command(command_v2, response, &response_len);
149 if (unpack_byte_string(response, response_len, "ds",
173 u8 response[COMMAND_BUFFER_SIZE]; local
178 ret = tpm_sendrecv_command(command_v2, response, &response_len);
183 * In the response buffer, the properties are located after the:
184 * tag (u16), response size (u32), response code (u32),
189 memcpy(buf, &response[properties_off], response_len - properties_off);
|
| /external/webrtc/webrtc/libjingle/xmpp/ |
| xmpplogintask.cc | 231 XmlElement * response = sasl_mech_->HandleSaslChallenge(element); local
232 if (response == NULL) {
235 pctx_->InternalSendStanza(response);
236 delete response;
|
| /frameworks/av/media/libmediaplayer2/nuplayer2/ |
| NuPlayer2DecoderBase.cpp | 53 const sp<AMessage> &msg, sp<AMessage> *response) {
54 status_t err = msg->postAndAwaitResponse(response);
60 if (!(*response)->findInt32("err", &err)) {
97 sp<AMessage> response; local
98 PostAndAwaitResponse(msg, &response);
|
