| /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 | 23 response, content = http.request(
26 assert response["content-location"] == tests.DUMMY_URL
36 response, content = http.request(
53 response, content = http.request("http://no-such-hostname./")
54 assert response["content-type"] == "text/plain"
56 assert response.status == 400
83 response, content = http.request(tests.DUMMY_URL)
85 assert response["content-type"] == "text/plain"
91 assert response.status == 400
98 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/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/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/openssh/regress/misc/sk-dummy/ |
| D | sk-dummy.c | 81 pack_key_ecdsa(struct sk_enroll_response *response) in pack_key_ecdsa() argument
92 response->public_key = NULL; in pack_key_ecdsa()
93 response->public_key_len = 0; in pack_key_ecdsa()
94 response->key_handle = NULL; in pack_key_ecdsa()
95 response->key_handle_len = 0; in pack_key_ecdsa()
112 response->public_key_len = EC_POINT_point2oct(g, q, in pack_key_ecdsa()
114 if (response->public_key_len == 0 || response->public_key_len > 2048) { in pack_key_ecdsa()
116 response->public_key_len); in pack_key_ecdsa()
119 if ((response->public_key = malloc(response->public_key_len)) == NULL) { in pack_key_ecdsa()
124 response->public_key, response->public_key_len, NULL) == 0) { in pack_key_ecdsa()
[all …]
|
| /external/wpa_supplicant_8/src/common/ |
| D | gas_server.c | 55 static void gas_server_free_response(struct gas_server_response *response);
60 struct gas_server_response *response = eloop_ctx; in gas_server_response_timeout() local
64 response, MAC2STR(response->dst), response->dialog_token, in gas_server_response_timeout()
65 response->freq, response->frag_id, in gas_server_response_timeout()
66 (unsigned long) response->offset, in gas_server_response_timeout()
67 (unsigned long) (response->resp ? in gas_server_response_timeout()
68 wpabuf_len(response->resp) : 0)); in gas_server_response_timeout()
69 response->handler->status_cb(response->handler->ctx, in gas_server_response_timeout()
70 response->resp, 0); in gas_server_response_timeout()
71 response->resp = NULL; in gas_server_response_timeout()
[all …]
|
| /external/llvm-project/lldb/source/Plugins/Process/gdb-remote/ |
| D | GDBRemoteCommunicationServerCommon.cpp | 183 StreamString response; in Handle_qHostInfo() local
189 response.PutCString("triple:"); in Handle_qHostInfo()
190 response.PutStringAsRawHex8(host_triple.getTriple()); in Handle_qHostInfo()
191 response.Printf(";ptrsize:%u;", host_arch.GetAddressByteSize()); in Handle_qHostInfo()
195 response.PutCString("distribution_id:"); in Handle_qHostInfo()
196 response.PutStringAsRawHex8(distribution_id); in Handle_qHostInfo()
197 response.PutCString(";"); in Handle_qHostInfo()
202 response.PutCString("vendor:apple;"); in Handle_qHostInfo()
208 response.Printf("cputype:%u;", cpu); in Handle_qHostInfo()
210 response.Printf("cpusubtype:%u;", sub); in Handle_qHostInfo()
[all …]
|
| D | GDBRemoteCommunicationClient.cpp | 124 StringExtractorGDBRemote response; in HandshakeWithServer() local
127 packet_result = ReadPacket(response, milliseconds(10), false); in HandshakeWithServer()
220 StringExtractorGDBRemote response; in QueryNoAckModeSupported() local
221 if (SendPacketAndWaitForResponse("QStartNoAckMode", response, false) == in QueryNoAckModeSupported()
223 if (response.IsOKResponse()) { in QueryNoAckModeSupported()
237 StringExtractorGDBRemote response; in GetListThreadsInStopReplySupported() local
238 if (SendPacketAndWaitForResponse("QListThreadsInStopReply", response, in GetListThreadsInStopReplySupported()
240 if (response.IsOKResponse()) in GetListThreadsInStopReplySupported()
250 StringExtractorGDBRemote response; in GetVAttachOrWaitSupported() local
251 if (SendPacketAndWaitForResponse("qVAttachOrWaitSupported", response, in GetVAttachOrWaitSupported()
[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/llvm-project/lldb/unittests/Process/gdb-remote/ |
| D | GDBRemoteClientBaseTest.cpp | 63 StateType SendCPacket(StringExtractorGDBRemote &response) { in SendCPacket() argument
65 "c", response); in SendCPacket()
78 StringExtractorGDBRemote response; in TEST_F() local
82 ASSERT_EQ(eStateStopped, SendCPacket(response)); in TEST_F()
83 ASSERT_EQ("T01", response.GetStringRef()); in TEST_F()
84 ASSERT_EQ(PacketResult::Success, server.GetPacket(response)); in TEST_F()
85 ASSERT_EQ("c", response.GetStringRef()); in TEST_F()
89 ASSERT_EQ(eStateExited, SendCPacket(response)); in TEST_F()
90 ASSERT_EQ("W01", response.GetStringRef()); in TEST_F()
91 ASSERT_EQ(PacketResult::Success, server.GetPacket(response)); in TEST_F()
[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 | 41 GetStatusResponse* response, bool fail_fast,
46 CreateWorkerSessionResponse* response, StatusCallback done) = 0;
50 DeleteWorkerSessionResponse* response, StatusCallback done) = 0;
53 RegisterGraphResponse* response,
57 DeregisterGraphResponse* response,
61 MutableRunGraphResponseWrapper* response,
65 RunGraphResponse* response, StatusCallback done) { in RunGraphAsync() argument
68 new NonOwnedProtoRunGraphResponse(response); in RunGraphAsync()
97 CleanupGraphResponse* response,
101 CleanupAllResponse* response,
[all …]
|
| /external/gptfdisk/ |
| D | support.cc | 75 uint64_t response, num; in GetNumber() local
84 num = sscanf(line, "%" SCNu64, &response); in GetNumber()
86 if ((response < low) || (response > high)) in GetNumber()
89 response = def; in GetNumber()
91 } while ((response < low) || (response > high)); in GetNumber()
94 response = low; in GetNumber()
96 return (response); in GetNumber()
101 char response; in GetYN() local
110 response = toupper(line[0]); in GetYN()
111 } while ((response != 'Y') && (response != 'N')); in GetYN()
[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/libbrillo/brillo/http/ |
| D | http_utils_test.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/libtextclassifier/native/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/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_remote_worker.cc | 75 GetStatusResponse* response, bool fail_fast, in GetStatusAsync() argument
77 IssueRequest(request, response, getstatus_, std::move(done), call_opts, in GetStatusAsync()
82 CreateWorkerSessionResponse* response, in CreateWorkerSessionAsync() argument
84 IssueRequest(request, response, createworkersession_, std::move(done)); in CreateWorkerSessionAsync()
89 DeleteWorkerSessionResponse* response, in DeleteWorkerSessionAsync() argument
91 IssueRequest(request, response, deleteworkersession_, std::move(done), in DeleteWorkerSessionAsync()
96 RegisterGraphResponse* response, in RegisterGraphAsync() argument
98 IssueRequest(request, response, registergraph_, std::move(done)); in RegisterGraphAsync()
102 DeregisterGraphResponse* response, in DeregisterGraphAsync() argument
104 IssueRequest(request, response, deregistergraph_, std::move(done)); in DeregisterGraphAsync()
[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/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 …]
|
| /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/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 …]
|