| /external/python/httplib2/tests/ |
| D | test_cache.py | 16 response, content = http.request(
19 assert response.fromcache
20 assert response.status == 200
27 response, content = http.request(
30 assert not response.fromcache
31 assert response.status == 504
41 response, content = http.request(
44 assert not response.fromcache
45 assert response.status == 504
72 response = tests.http_response_bytes(
[all …]
|
| D | test_http.py | 25 response, content = http.request(
28 assert response["content-location"] == DUMMY_URL
38 response, content = http.request(
55 response, content = http.request("http://no-such-hostname./")
56 assert response["content-type"] == "text/plain"
58 assert response.status == 400
85 response, content = http.request(DUMMY_URL)
87 assert response["content-type"] == "text/plain"
93 assert response.status == 400
100 response, content = http.request(uri + query, "GET")
[all …]
|
| D | test_encoding.py | 8 response = tests.http_response_bytes(
11 with tests.server_const_bytes(response) as uri:
12 response, content = http.request(uri, "HEAD")
13 assert response.status == 200
14 assert int(response["content-length"]) != 0
21 response = tests.http_response_bytes(
25 with tests.server_const_bytes(response) as uri:
26 response, content = http.request(uri, "GET")
27 assert response.status == 200
28 assert "content-encoding" not in response
[all …]
|
| D | test_auth.py | 33 response, content = http.request(uri, "GET")
34 assert response.status == 401
36 response, content = http.request(uri, "GET")
37 assert response.status == 200
48 response, content = http.request(uri, "GET")
49 assert response.status == 401
51 response, content = http.request(uri, "GET")
52 assert response.status == 401
55 response, content = http.request(uri, "GET")
56 assert response.status == 200
[all …]
|
| /external/python/httplib2/python2/ |
| D | httplib2test.py | 288 response, content = self.http.request(
291 self.assertEqual(response["content-location"], "http://bitworking.org")
299 response, content = self.http.request(
319 (response, content) = self.http.request("http://fred.bitworking.org/")
320 self.assertEqual(response["content-type"], "text/plain")
322 self.assertEqual(response.status, 400)
335 (response, content) = self.http.request("http://localhost:7777/")
336 self.assertEqual(response["content-type"], "text/plain")
341 self.assertEqual(response.status, 400)
348 (response, content) = self.http.request(uri, "GET")
[all …]
|
| /external/python/httplib2/python3/ |
| D | httplib2test.py | 269 response, content = self.http.request(
272 self.assertEqual(response["content-location"], "http://bitworking.org")
280 response, content = self.http.request(
300 (response, content) = self.http.request("http://fred.bitworking.org/")
301 self.assertEqual(response["content-type"], "text/plain")
303 self.assertEqual(response.status, 400)
316 (response, content) = self.http.request("http://localhost:7777/")
317 self.assertEqual(response["content-type"], "text/plain")
319 self.assertEqual(response.status, 400)
326 (response, content) = self.http.request(uri, "GET")
[all …]
|
| /external/tensorflow/tensorflow/compiler/xla/rpc/ |
| D | grpc_stub.cc | 31 TransferToClientResponse* response) { in TransferToClient() argument
32 return MakeRPC([this, request, response](::grpc::ClientContext* context) { in TransferToClient()
33 return grpc_stub_->TransferToClient(context, *request, response); in TransferToClient()
38 TransferToServerResponse* response) { in TransferToServer() argument
39 return MakeRPC([this, request, response](::grpc::ClientContext* context) { in TransferToServer()
40 return grpc_stub_->TransferToServer(context, *request, response); in TransferToServer()
45 TransferToInfeedResponse* response) { in TransferToInfeed() argument
46 return MakeRPC([this, request, response](::grpc::ClientContext* context) { in TransferToInfeed()
47 return grpc_stub_->TransferToInfeed(context, *request, response); in TransferToInfeed()
52 TransferFromOutfeedResponse* response) { in TransferFromOutfeed() argument
[all …]
|
| /external/u-boot/drivers/fastboot/ |
| D | 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);
[all …]
|
| D | fb_command.c | 43 void (*dispatch)(char *cmd_parameter, char *response);
99 int fastboot_handle_command(char *cmd_string, char *response) in fastboot_handle_command() argument
111 response); in fastboot_handle_command()
120 fastboot_fail("unrecognized command", response); in fastboot_handle_command()
134 static void okay(char *cmd_parameter, char *response) in okay() argument
136 fastboot_okay(NULL, response); in okay()
145 static void getvar(char *cmd_parameter, char *response) in getvar() argument
147 fastboot_getvar(cmd_parameter, response); in getvar()
156 static void download(char *cmd_parameter, char *response) in download() argument
161 fastboot_fail("Expected command parameter", response); in download()
[all …]
|
| /external/vboot_reference/firmware/lib/tpm_lite/ |
| D | tlcl.c | 64 uint8_t* response, int max_length) { in TlclSendReceiveNoRetry() argument
77 response, &response_length); in TlclSendReceiveNoRetry()
85 result = TpmReturnCode(response); in TlclSendReceiveNoRetry()
93 response[0], response[1], in TlclSendReceiveNoRetry()
94 response[2], response[3], response[4], response[5], in TlclSendReceiveNoRetry()
95 response[6], response[7], response[8], response[9])); in TlclSendReceiveNoRetry()
108 uint32_t TlclSendReceive(const uint8_t* request, uint8_t* response, in TlclSendReceive() argument
110 uint32_t result = TlclSendReceiveNoRetry(request, response, max_length); in TlclSendReceive()
123 result = TlclSendReceiveNoRetry(request, response, max_length); in TlclSendReceive()
131 result = TlclSendReceiveNoRetry(request, response, max_length); in TlclSendReceive()
[all …]
|
| /external/wpa_supplicant_8/src/common/ |
| D | gas_server.c | 52 static void gas_server_free_response(struct gas_server_response *response);
57 struct gas_server_response *response = eloop_ctx; in gas_server_response_timeout() local
61 response, MAC2STR(response->dst), response->dialog_token, in gas_server_response_timeout()
62 response->freq, response->frag_id, in gas_server_response_timeout()
63 (unsigned long) response->offset, in gas_server_response_timeout()
64 (unsigned long) wpabuf_len(response->resp)); in gas_server_response_timeout()
65 response->handler->status_cb(response->handler->ctx, in gas_server_response_timeout()
66 response->resp, 0); in gas_server_response_timeout()
67 response->resp = NULL; in gas_server_response_timeout()
68 dl_list_del(&response->list); in gas_server_response_timeout()
[all …]
|
| /external/gptfdisk/ |
| D | support.cc | 54 int response, num; in GetNumber() local
63 num = sscanf(line, "%d", &response); in GetNumber()
65 if ((response < low) || (response > high)) in GetNumber()
68 response = def; in GetNumber()
70 } while ((response < low) || (response > high)); in GetNumber()
73 response = low; in GetNumber()
75 return (response); in GetNumber()
80 char response; in GetYN() local
89 response = toupper(line[0]); in GetYN()
90 } while ((response != 'Y') && (response != 'N')); in GetYN()
[all …]
|
| /external/libbrillo/brillo/http/ |
| D | http_utils_unittest.cc | 28 fake::ServerResponse* response) { in EchoDataHandler() argument
29 response->Reply(status_code::Ok, in EchoDataHandler()
36 fake::ServerResponse* response) { in EchoMethodHandler() argument
37 response->ReplyText( in EchoMethodHandler()
49 auto response = in TEST() local
58 EXPECT_TRUE(response->IsSuccessful()); in TEST()
60 response->GetContentType()); in TEST()
61 EXPECT_EQ(custom_data, response->ExtractData()); in TEST()
73 std::unique_ptr<http::Response> response) { in TEST() argument
74 EXPECT_TRUE(response->IsSuccessful()); in TEST()
[all …]
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | message_wrappers_test.cc | 114 void CheckRunGraphResponse(MutableRunGraphResponseWrapper* response) { in CheckRunGraphResponse() argument
115 ASSERT_EQ(2, response->num_recvs()); in CheckRunGraphResponse()
116 EXPECT_EQ("recv_2", response->recv_key(0)); in CheckRunGraphResponse()
117 EXPECT_EQ("recv_3", response->recv_key(1)); in CheckRunGraphResponse()
119 TF_EXPECT_OK(response->RecvValue(0, &val)); in CheckRunGraphResponse()
121 TF_EXPECT_OK(response->RecvValue(1, &val)); in CheckRunGraphResponse()
123 ASSERT_EQ(1, response->mutable_step_stats()->dev_stats_size()); in CheckRunGraphResponse()
124 EXPECT_EQ("/cpu:0", response->mutable_step_stats()->dev_stats(0).device()); in CheckRunGraphResponse()
125 ASSERT_EQ(1, response->mutable_cost_graph()->node_size()); in CheckRunGraphResponse()
126 EXPECT_EQ("cost_node", response->mutable_cost_graph()->node(0).name()); in CheckRunGraphResponse()
[all …]
|
| D | worker_interface.h | 40 GetStatusResponse* response,
45 CreateWorkerSessionResponse* response, StatusCallback done) = 0;
49 DeleteWorkerSessionResponse* response, StatusCallback done) = 0;
52 RegisterGraphResponse* response,
56 DeregisterGraphResponse* response,
64 RunGraphResponse* response, StatusCallback done) { in RunGraphAsync() argument
69 new NonOwnedProtoRunGraphResponse(response); in RunGraphAsync()
97 CleanupGraphResponse* response,
101 CleanupAllResponse* response,
106 TensorResponse* response,
[all …]
|
| /external/nanohttpd/nanolets/src/test/java/fi/iki/elonen/router/ |
| D | TestNanolets.java | 111 CloseableHttpResponse response = httpclient.execute(httpget); in doSomeBasicMethodTest() local
112 HttpEntity entity = response.getEntity(); in doSomeBasicMethodTest()
116 response.close(); in doSomeBasicMethodTest()
119 response = httpclient.execute(httppost); in doSomeBasicMethodTest()
120 entity = response.getEntity(); in doSomeBasicMethodTest()
124 response.close(); in doSomeBasicMethodTest()
127 response = httpclient.execute(httpgput); in doSomeBasicMethodTest()
128 entity = response.getEntity(); in doSomeBasicMethodTest()
132 response.close(); in doSomeBasicMethodTest()
135 response = httpclient.execute(httpdelete); in doSomeBasicMethodTest()
[all …]
|
| /external/u-boot/test/py/tests/ |
| D | test_avb.py | 33 response = u_boot_console.run_command('avb init %s' %str(mmc_dev))
34 assert response == ''
35 response = u_boot_console.run_command('avb verify')
36 assert response.find(success_str)
45 response = u_boot_console.run_command('avb init %s' % str(mmc_dev))
46 assert response == ''
48 response = u_boot_console.run_command('mmc rescan; mmc dev %s' %
50 assert response.find('is current device')
77 response = u_boot_console.run_command('avb init %s' % str(mmc_dev))
78 assert response == ''
[all …]
|
| /external/libtextclassifier/actions/ |
| D | ranker_test.cc | 39 ActionsSuggestionsResponse response; in TEST() local
40 response.actions = { in TEST()
53 ranker->RankActions(conversation, &response); in TEST()
55 response.actions, in TEST()
61 ActionsSuggestionsResponse response; in TEST() local
62 response.actions = { in TEST()
80 ranker->RankActions(conversation, &response); in TEST()
82 response.actions, in TEST()
91 ActionsSuggestionsResponse response; in TEST() local
97 response.actions.push_back({/*response_text=*/"", in TEST()
[all …]
|
| /external/apache-http/src/org/apache/http/protocol/ |
| D | HttpService.java | 136 HttpResponse response = null; in handleRequest() local
154 response = this.responseFactory.newHttpResponse(ver, in handleRequest()
156 response.setParams( in handleRequest()
157 new DefaultedHttpParams(response.getParams(), this.params)); in handleRequest()
161 this.expectationVerifier.verify(request, response, context); in handleRequest()
163 response = this.responseFactory.newHttpResponse(HttpVersion.HTTP_1_0, in handleRequest()
165 response.setParams( in handleRequest()
166 new DefaultedHttpParams(response.getParams(), this.params)); in handleRequest()
167 handleException(ex, response); in handleRequest()
170 if (response.getStatusLine().getStatusCode() < 200) { in handleRequest()
[all …]
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | channelz_service_test.cc | 66 EchoResponse* response) override { in Echo() argument
71 return stubs_[idx]->Echo(client_context.get(), *request, response); in Echo()
143 EchoResponse response; in SendSuccessfulEcho() local
147 Status s = echo_stub_->Echo(&context, request, &response); in SendSuccessfulEcho()
148 EXPECT_EQ(response.message(), request.message()); in SendSuccessfulEcho()
154 EchoResponse response; in SendFailedEcho() local
161 Status s = echo_stub_->Echo(&context, request, &response); in SendFailedEcho()
169 GetTopChannelsResponse response; in GetChannelId() local
172 Status s = channelz_stub_->GetTopChannels(&context, request, &response); in GetChannelId()
174 EXPECT_GT(response.channel_size(), channel_idx); in GetChannelId()
[all …]
|
| /external/tensorflow/tensorflow/compiler/xla/client/ |
| D | client.cc | 48 TransferToClientResponse response; in Transfer() local
52 Status s = stub_->TransferToClient(&request, &response); in Transfer()
58 VLOG(3) << "TransferToClientResponse: {" << response.DebugString() << "}"; in Transfer()
60 if (!response.has_literal()) { in Transfer()
65 return Literal::CreateFromProto(*response.mutable_literal()); in Transfer()
75 TransferToServerResponse response; in TransferToServer() local
79 Status s = stub_->TransferToServer(&request, &response); in TransferToServer()
85 VLOG(3) << "TransferToServerResponse: {" << response.DebugString() << "}"; in TransferToServer()
87 if (!response.has_data()) { in TransferToServer()
93 return absl::make_unique<GlobalData>(stub_, response.data()); in TransferToServer()
[all …]
|
| /external/grpc-grpc/test/cpp/util/ |
| D | proto_reflection_descriptor_database.cc | 71 ServerReflectionResponse response; in FindFileByName() local
73 if (!DoOneRequest(request, response)) { in FindFileByName()
77 if (response.message_response_case() == in FindFileByName()
79 AddFileFromResponse(response.file_descriptor_response()); in FindFileByName()
80 } else if (response.message_response_case() == in FindFileByName()
82 const ErrorResponse& error = response.error_response(); in FindFileByName()
100 response.message_response_case()); in FindFileByName()
118 ServerReflectionResponse response; in FindFileContainingSymbol() local
120 if (!DoOneRequest(request, response)) { in FindFileContainingSymbol()
124 if (response.message_response_case() == in FindFileContainingSymbol()
[all …]
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_master_service_impl.h | 45 CreateSessionResponse* response) = 0;
48 ExtendSessionResponse* response) = 0;
51 PartialRunSetupResponse* response) = 0;
54 RunStepResponse* response) = 0;
57 CloseSessionResponse* response) = 0;
60 ListDevicesResponse* response) = 0;
63 ResetResponse* response) = 0;
66 MakeCallableResponse* response) = 0;
69 RunCallableResponse* response) = 0;
72 ReleaseCallableResponse* response) = 0;
[all …]
|
| D | grpc_remote_worker.cc | 74 GetStatusResponse* response, in GetStatusAsync() argument
76 IssueRequest(request, response, getstatus_, std::move(done)); in GetStatusAsync()
80 CreateWorkerSessionResponse* response, in CreateWorkerSessionAsync() argument
82 IssueRequest(request, response, createworkersession_, std::move(done)); in CreateWorkerSessionAsync()
87 DeleteWorkerSessionResponse* response, in DeleteWorkerSessionAsync() argument
89 IssueRequest(request, response, deleteworkersession_, std::move(done), in DeleteWorkerSessionAsync()
94 RegisterGraphResponse* response, in RegisterGraphAsync() argument
96 IssueRequest(request, response, registergraph_, std::move(done)); in RegisterGraphAsync()
100 DeregisterGraphResponse* response, in DeregisterGraphAsync() argument
102 IssueRequest(request, response, deregistergraph_, std::move(done)); in DeregisterGraphAsync()
[all …]
|
| /external/nanohttpd/core/src/test/java/fi/iki/elonen/integration/ |
| D | GZipIntegrationTest.java | 60 public Response response; field in GZipIntegrationTest.TestServer
68 return response; in serve()
84 testServer.response = NanoHTTPD.newFixedLengthResponse("This is a test"); in contentEncodingShouldBeAddedToFixedLengthResponses()
87 HttpResponse response = httpclient.execute(request); in contentEncodingShouldBeAddedToFixedLengthResponses() local
88 Header contentEncoding = response.getFirstHeader("content-encoding"); in contentEncodingShouldBeAddedToFixedLengthResponses()
96 …testServer.response = NanoHTTPD.newChunkedResponse(NanoHTTPD.Response.Status.OK, "text/plain", dat… in contentEncodingShouldBeAddedToChunkedResponses()
99 HttpResponse response = httpclient.execute(request); in contentEncodingShouldBeAddedToChunkedResponses() local
100 Header contentEncoding = response.getFirstHeader("content-encoding"); in contentEncodingShouldBeAddedToChunkedResponses()
107 testServer.response = NanoHTTPD.newFixedLengthResponse("This is a test"); in shouldFindCorrectAcceptEncodingAmongMany()
110 HttpResponse response = httpclient.execute(request); in shouldFindCorrectAcceptEncodingAmongMany() local
[all …]
|