| /external/cronet/net/third_party/quiche/src/quiche/quic/test_tools/ |
| D | quic_connection_peer.cc | 22 QuicConnection* connection, SendAlgorithmInterface* send_algorithm) { in SetSendAlgorithm()
28 QuicConnection* connection, LossDetectionInterface* loss_algorithm) { in SetLossAlgorithm()
34 QuicConnection* connection) { in GetPacketCreator()
40 QuicConnection* connection) { in GetSentPacketManager()
46 QuicConnection* connection) { in GetNetworkTimeout()
52 QuicConnection* connection) { in GetHandshakeTimeout()
57 void QuicConnectionPeer::SetPerspective(QuicConnection* connection, in SetPerspective()
65 void QuicConnectionPeer::SetSelfAddress(QuicConnection* connection, in SetSelfAddress()
71 void QuicConnectionPeer::SetPeerAddress(QuicConnection* connection, in SetPeerAddress()
78 QuicConnection* connection, const QuicSocketAddress& direct_peer_address) { in SetDirectPeerAddress()
[all …]
|
| /external/cronet/base/android/junit/src/org/chromium/base/process_launcher/ |
| D | ChildProcessConnectionTest.java | 220 ChildProcessConnection connection = createDefaultTestConnection(); in testStrongBinding() local
240 ChildProcessConnection connection = in testServiceBundle() local
257 ChildProcessConnection connection = createDefaultTestConnection(); in testServiceStartsSuccessfully() local
276 ChildProcessConnection connection = createDefaultTestConnection(); in testServiceStartsAndFailsToBind() local
292 ChildProcessConnection connection = createDefaultTestConnection(); in testServiceStops() local
304 ChildProcessConnection connection = createDefaultTestConnection(); in testServiceDisconnects() local
316 ChildProcessConnection connection = in testNotBoundToCaller() local
334 ChildProcessConnection connection = in testBoundToCallerSuccess() local
353 ChildProcessConnection connection = in testBoundToCallerFailure() local
374 ChildProcessConnection connection = createDefaultTestConnection(); in testSetupConnectionBeforeServiceConnected() local
[all …]
|
| /external/libchrome/base/android/junit/src/org/chromium/base/process_launcher/ |
| D | ChildProcessConnectionTest.java | 162 ChildProcessConnection connection = createDefaultTestConnection(); in testStrongBinding() local
182 ChildProcessConnection connection = createTestConnection( in testServiceBundle() local
195 ChildProcessConnection connection = createDefaultTestConnection(); in testServiceStartsSuccessfully() local
214 ChildProcessConnection connection = createDefaultTestConnection(); in testServiceStartsAndFailsToBind() local
230 ChildProcessConnection connection = createDefaultTestConnection(); in testServiceStops() local
242 ChildProcessConnection connection = createDefaultTestConnection(); in testServiceDisconnects() local
254 ChildProcessConnection connection = createTestConnection(false /* bindToCaller */, in testNotBoundToCaller() local
268 ChildProcessConnection connection = createTestConnection(true /* bindToCaller */, in testBoundToCallerSuccess() local
283 ChildProcessConnection connection = createTestConnection(true /* bindToCaller */, in testBoundToCallerFailure() local
300 ChildProcessConnection connection = createDefaultTestConnection(); in testSetupConnectionBeforeServiceConnected() local
[all …]
|
| D | ChildConnectionAllocatorTest.java | 95 final ChildProcessConnection connection = mock(ChildProcessConnection.class); in invokeCallbackOnConnectionStart() local
147 ChildProcessConnection connection = in testPlainAllocate() local
164 ChildProcessConnection connection = mAllocator.allocate( in testAllocateMaxNumber() local
185 ChildProcessConnection connection = in testQueueAllocation() local
226 ChildProcessConnection connection = allocator.allocate( in testStrongBindingParam() local
242 ChildProcessConnection connection = in runTestWithConnectionCallbacks() local
282 ChildProcessConnection connection = in testFreeConnection() local
|
| /external/volley/core/src/main/java/com/android/volley/toolbox/ |
| D | HurlStack.java | 83 HttpURLConnection connection = openConnection(parsedUrl, request); in executeRequest() local
154 UrlConnectionInputStream(HttpURLConnection connection) { in UrlConnectionInputStream()
175 protected InputStream createInputStream(Request<?> request, HttpURLConnection connection) { in createInputStream()
185 private static InputStream inputStreamFromConnection(HttpURLConnection connection) { in inputStreamFromConnection()
197 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); in createConnection() local
215 HttpURLConnection connection = createConnection(url); in openConnection() local
235 HttpURLConnection connection, Request<?> request) throws IOException, AuthFailureError { in setConnectionParametersForRequest()
281 private void addBodyIfExists(HttpURLConnection connection, Request<?> request) in addBodyIfExists()
289 private void addBody(HttpURLConnection connection, Request<?> request, byte[] body) in addBody()
318 Request<?> request, HttpURLConnection connection, int length) throws IOException { in createOutputStream()
|
| /external/okhttp/okhttp-urlconnection/src/test/java/com/squareup/okhttp/ |
| D | OkUrlFactoryTest.java | 68 HttpURLConnection connection = factory.open(server.getUrl("/")); in networkResponseSourceHeader() local
76 HttpURLConnection connection = factory.open(server.getUrl("/")); in networkFailureResponseSourceHeader() local
148 HttpURLConnection connection = factory.open(server.getUrl("/a")); in setInstanceFollowRedirectsFalse() local
168 HttpURLConnection connection = factory.open(server.url("/a").url()); in testURLFilter() local
174 HttpURLConnection connection = factory.open(server.url("/b").url()); in testURLFilter() local
178 private void assertResponseBody(HttpURLConnection connection, String expected) throws Exception { in assertResponseBody()
185 private void assertResponseHeader(HttpURLConnection connection, String expected) { in assertResponseHeader()
189 private void assertResponseCode(HttpURLConnection connection, int expected) throws IOException { in assertResponseCode()
|
| D | UrlConnectionCacheTest.java | 292 HttpURLConnection connection = client.open(server.getUrl("/")); in responseCachingAndRedirects() local
421 URLConnection connection = client.open(server.getUrl("/")); in testServerPrematureDisconnect() local
446 URLConnection connection = client.open(server.getUrl("/")); in testClientPrematureDisconnect() local
476 URLConnection connection = client.open(url); in defaultExpirationDateFullyCachedForLessThan24Hours() local
503 URLConnection connection = client.open(server.getUrl("/")); in defaultExpirationDateFullyCachedForMoreThan24Hours() local
876 URLConnection connection = client.open(server.getUrl("/")); in requestMaxAge() local
889 URLConnection connection = client.open(server.getUrl("/")); in requestMinFresh() local
902 URLConnection connection = client.open(server.getUrl("/")); in requestMaxStale() local
917 URLConnection connection = client.open(server.getUrl("/")); in requestMaxStaleNotHonoredWithMustRevalidate() local
925 HttpURLConnection connection = client.open(server.getUrl("/")); in requestOnlyIfCachedWithNoResponseCached() local
[all …]
|
| /external/aws-crt-java/src/native/ |
| D | mqtt_connection.c | 40 struct mqtt_jni_connection *connection; member
66 struct mqtt_jni_connection *connection; member
74 static void s_mqtt_jni_connection_acquire(struct mqtt_jni_connection *connection) { in s_mqtt_jni_connection_acquire()
82 static void s_mqtt_jni_connection_release(struct mqtt_jni_connection *connection) { in s_mqtt_jni_connection_release()
89 static void s_mqtt_jni_connection_destroy(struct mqtt_jni_connection *connection) { in s_mqtt_jni_connection_destroy()
105 struct mqtt_jni_connection *connection, in s_mqtt_jni_async_callback_new()
172 struct mqtt_jni_connection *connection = connect_callback->connection; in s_on_connection_complete() local
205 struct mqtt_jni_connection *connection, in s_on_connection_interrupted_internal()
229 struct mqtt_jni_connection *connection = user_data; in s_on_connection_interrupted() local
252 struct mqtt_jni_connection *connection = user_data; in s_on_connection_success() local
[all …]
|
| /external/python/bumble/examples/ |
| D | run_gatt_server.py | 42 def on_connection(self, connection): argument
50 def my_custom_read(connection): argument
55 def my_custom_write(connection, value): argument
59 def my_custom_read_with_error(connection): argument
67 def my_custom_write_with_error(connection, value): argument
|
| /external/libbrillo/brillo/http/ |
| D | http_transport_curl_test.cc | 72 auto connection = transport_->CreateConnection("http://foo.bar/get", in TEST_F() local
102 auto connection = proxy_transport->CreateConnection("http://foo.bar/get", in TEST_F() local
120 auto connection = transport_->CreateConnection( in TEST_F() local
134 auto connection = transport_->CreateConnection( in TEST_F() local
150 auto connection = transport_->CreateConnection( in TEST_F() local
170 auto connection = transport_->CreateConnection( in TEST_F() local
188 auto connection = transport_->CreateConnection( in TEST_F() local
237 auto connection = transport_->CreateConnection( in TEST_F() local
333 auto connection = transport_->CreateConnection( in TEST_F() local
350 auto connection = transport_->CreateConnection( in TEST_F() local
|
| /external/python/bumble/tests/ |
| D | gatt_test.py | 155 async def async_read(connection): argument
398 async def read_value(connection): argument
417 async def read_value(connection): argument
471 def on_characteristic1_write(connection, value): argument
476 def on_characteristic2_read(connection): argument
479 def on_characteristic2_write(connection, value): argument
596 def on_characteristic1_subscription(connection, notify_enabled, indicate_enabled): argument
612 def on_characteristic2_subscription(connection, notify_enabled, indicate_enabled): argument
630 def on_characteristic3_subscription(connection, notify_enabled, indicate_enabled): argument
646 connection, characteristic, notify_enabled, indicate_enabled argument
[all …]
|
| /external/cronet/net/server/ |
| D | http_server.cc | 71 HttpConnection* connection = FindConnection(connection_id); in HttpServer() local
82 HttpConnection* connection = FindConnection(connection_id); in HttpServer() local
93 HttpConnection* connection = FindConnection(connection_id); in HttpServer() local
144 std::unique_ptr<HttpConnection> connection = std::move(it->second); in HttpServer() local
161 HttpConnection* connection = FindConnection(connection_id); in HttpServer() local
167 HttpConnection* connection = FindConnection(connection_id); in HttpServer() local
197 HttpConnection* connection = connection_ptr.get(); in HttpServer() local
205 void HttpServer::DoReadLoop(HttpConnection* connection) { in HttpServer()
226 HttpConnection* connection = FindConnection(connection_id); in HttpServer() local
234 int HttpServer::HandleReadResult(HttpConnection* connection, int rv) { in HttpServer()
[all …]
|
| /external/webrtc/p2p/base/ |
| D | wrapping_active_ice_controller.cc | 68 const Connection* connection, in GetUseCandidateAttribute()
76 const Connection* connection) { in OnConnectionAdded()
82 const Connection* connection) { in OnConnectionPinged()
88 const Connection* connection) { in OnConnectionUpdated()
95 const Connection* connection) { in OnConnectionSwitched()
102 const Connection* connection) { in OnConnectionDestroyed()
|
| /external/aws-crt-java/src/main/java/software/amazon/awssdk/crt/mqtt/ |
| D | MqttClientConnection.java | 479 private static native void mqttClientConnectionDestroy(long connection); in mqttClientConnectionDestroy()
481 … private static native void mqttClientConnectionConnect(long connection, String endpoint, int port, in mqttClientConnectionConnect()
485 private static native void mqttClientConnectionDisconnect(long connection, AsyncCallback ack); in mqttClientConnectionDisconnect()
487 … private static native short mqttClientConnectionSubscribe(long connection, String topic, int qos, in mqttClientConnectionSubscribe()
490 … private static native void mqttClientConnectionOnMessage(long connection, MessageHandler handler) in mqttClientConnectionOnMessage()
493 …private static native short mqttClientConnectionUnsubscribe(long connection, String topic, AsyncCa… in mqttClientConnectionUnsubscribe()
495 …private static native short mqttClientConnectionPublish(long connection, String topic, int qos, bo… in mqttClientConnectionPublish()
498 …private static native boolean mqttClientConnectionSetWill(long connection, String topic, int qos, … in mqttClientConnectionSetWill()
501 …private static native void mqttClientConnectionSetLogin(long connection, String username, String p… in mqttClientConnectionSetLogin()
504 …private static native void mqttClientConnectionSetReconnectTimeout(long connection, long minTimeou… in mqttClientConnectionSetReconnectTimeout()
[all …]
|
| /external/okhttp/mockwebserver/src/test/java/com/squareup/okhttp/mockwebserver/ |
| D | MockWebServerTest.java | 87 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); in regularResponse() local
106 URLConnection connection = server.getUrl("/").openConnection(); in redirect() local
132 URLConnection connection = server.getUrl("/").openConnection(); in dispatchBlocksWaitingForEnqueue() local
144 URLConnection connection = server.getUrl("/").openConnection(); in nonHexadecimalChunkSize() local
203 URLConnection connection = server.getUrl("/").openConnection(); in throttleRequest() local
264 HttpURLConnection connection = (HttpURLConnection) server.getUrl("/").openConnection(); in disconnectRequestHalfway() local
291 URLConnection connection = server.getUrl("/").openConnection(); in disconnectResponseHalfway() local
|
| /external/okhttp/okhttp-android-support/src/test/java/com/squareup/okhttp/internal/huc/ |
| D | ResponseCacheTest.java | 199 HttpURLConnection connection = openConnection(url); in assertCached() local
302 HttpURLConnection connection = openConnection(server.getUrl("/")); in responseCachingAndRedirects() local
488 URLConnection connection = openConnection(server.getUrl("/")); in testServerPrematureDisconnect() local
513 URLConnection connection = openConnection(server.getUrl("/")); in testClientPrematureDisconnect() local
539 URLConnection connection = openConnection(url); in defaultExpirationDateFullyCachedForLessThan24Hours() local
567 URLConnection connection = openConnection(server.getUrl("/")); in defaultExpirationDateFullyCachedForMoreThan24Hours() local
722 private void addRequestBodyIfNecessary(String requestMethod, HttpURLConnection connection) in addRequestBodyIfNecessary()
987 URLConnection connection = openConnection(server.getUrl("/")); in requestMaxAge() local
1002 URLConnection connection = openConnection(server.getUrl("/")); in requestMinFresh() local
1017 URLConnection connection = openConnection(server.getUrl("/")); in requestMaxStale() local
[all …]
|
| /external/openscreen/osp/impl/quic/ |
| D | quic_server_unittest.cc | 35 std::unique_ptr<ProtocolConnection> connection) override { in OnConnectionOpened()
68 Invoke([&stream](std::unique_ptr<ProtocolConnection>& connection) { in ExpectIncomingConnection()
84 void SendTestMessage(ProtocolConnection* connection) { in SendTestMessage()
134 std::unique_ptr<ProtocolConnection> connection = ExpectIncomingConnection(); in TEST_F() local
162 std::unique_ptr<ProtocolConnection> connection = ExpectIncomingConnection(); in TEST_F() local
193 std::unique_ptr<ProtocolConnection> connection = ExpectIncomingConnection(); in TEST_F() local
|
| /external/aws-sdk-java-v2/core/regions/src/test/java/software/amazon/awssdk/regions/internal/util/ |
| D | ConnectionUtilsComponentTest.java | 56 …HttpURLConnection connection = sut.connectToEndpoint(URI.create("http://" + Inet4Address.getLocalH… in proxiesAreNotUsedEvenIfPropertyIsSet() local
63 …HttpURLConnection connection = sut.connectToEndpoint(URI.create("http://localhost:" + mockServer.p… in headersArePassedAsPartOfRequest() local
71 …HttpURLConnection connection = sut.connectToEndpoint(URI.create("http://localhost:" + mockServer.p… in shouldNotFollowRedirects() local
|
| /external/openscreen/osp/impl/presentation/ |
| D | presentation_receiver.cc | 68 ProtocolConnection* connection) { in WritePresentationInitiationResponse()
75 ProtocolConnection* connection) { in WritePresentationConnectionOpenResponse()
82 ProtocolConnection* connection) { in WritePresentationTerminationEvent()
89 ProtocolConnection* connection) { in WritePresentationTerminationResponse()
96 ProtocolConnection* connection) { in WritePresentationUrlAvailabilityResponse()
375 Connection* connection, in OnPresentationStarted()
425 Connection* connection, in OnConnectionCreated()
458 Error Receiver::CloseConnection(Connection* connection, in CloseConnection()
489 for (auto* connection : presentation.connections) in OnPresentationTerminated() local
509 void Receiver::OnConnectionDestroyed(Connection* connection) { in OnConnectionDestroyed()
|
| D | presentation_connection.cc | 30 ProtocolConnection* connection) { in WriteConnectionMessage()
165 void ConnectionManager::AddConnection(Connection* connection) { in AddConnection()
172 void ConnectionManager::RemoveConnection(Connection* connection) { in RemoveConnection()
199 Connection* connection = GetConnection(message.connection_id); in OnStreamMessage() local
232 Connection* connection = GetConnection(request.connection_id); in OnStreamMessage() local
267 Connection* connection = GetConnection(event.connection_id); in OnStreamMessage() local
|
| /external/python/bumble/apps/link_relay/ |
| D | link_relay.py | 123 async def add_connection(self, connection): argument
128 async def remove_connection(self, connection): argument
136 async def bridge_connection(self, connection): argument
163 async def on_rpc_request(self, connection, message): argument
177 async def on_targeted_message(self, connection, message): argument
198 async def on_set_address_command(self, connection, params): argument
228 async def serve_as_controller(self, connection): argument
|
| /external/skia/tools/skiaserve/ |
| D | Response.cpp | 44 int SendOK(MHD_Connection* connection) { in SendOK()
55 int SendError(MHD_Connection* connection, const char* msg) { in SendError()
64 int SendData(MHD_Connection* connection, const SkData* data, const char* type, in SendData()
80 int SendTemplate(MHD_Connection* connection, bool redirect, const char* redirectUrl) { in SendTemplate()
|
| /external/lottie/lottie/src/main/java/com/airbnb/lottie/network/ |
| D | DefaultLottieFetchResult.java | 19 private final HttpURLConnection connection; field in DefaultLottieFetchResult
21 public DefaultLottieFetchResult(@NonNull HttpURLConnection connection) { in DefaultLottieFetchResult()
55 private String getErrorFromConnection(HttpURLConnection connection) throws IOException { in getErrorFromConnection()
|
| /external/conscrypt/repackaged/common/src/test/java/com/android/org/conscrypt/javax/net/ssl/ |
| D | HttpsURLConnectionTest.java | 80 HttpsURLConnection connection = in testDefaultHostnameVerifierUsedForNewConnectionsByDefault() local
123 HttpsURLConnection connection = server.tlsConnection("/file"); in failedUrlConnect() local
135 HttpsURLConnection connection = server.tlsConnection("/file"); in successfulUrlConnect() local
149 HttpsURLConnection connection = server.tlsConnection("/file"); in urlReadTimeout() local
173 HttpsURLConnection connection = (HttpsURLConnection) url.openConnection(); in urlConnectTimeout() local
196 HttpsURLConnection connection = in testDefaultSSLSocketFactoryUsedForNewConnectionsByDefault() local
|
| /external/conscrypt/common/src/test/java/org/conscrypt/javax/net/ssl/ |
| D | HttpsURLConnectionTest.java | 78 HttpsURLConnection connection = in testDefaultHostnameVerifierUsedForNewConnectionsByDefault() local
123 HttpsURLConnection connection = server.tlsConnection("/file"); in failedUrlConnect() local
138 HttpsURLConnection connection = server.tlsConnection("/file"); in successfulUrlConnect() local
156 HttpsURLConnection connection = server.tlsConnection("/file"); in urlReadTimeout() local
180 HttpsURLConnection connection = (HttpsURLConnection) url.openConnection(); in urlConnectTimeout() local
203 HttpsURLConnection connection = in testDefaultSSLSocketFactoryUsedForNewConnectionsByDefault() local
|