| /external/cronet/tot/net/third_party/quiche/src/quiche/quic/test_tools/ |
| D | quic_connection_peer.cc | 43 QuicConnection* connection, SendAlgorithmInterface* send_algorithm) { in SetSendAlgorithm()
49 QuicConnection* connection, LossDetectionInterface* loss_algorithm) { in SetLossAlgorithm()
55 QuicConnection* connection) { in GetPacketCreator()
61 QuicConnection* connection) { in GetSentPacketManager()
67 QuicConnection* connection) { in GetNetworkTimeout()
73 QuicConnection* connection) { in GetHandshakeTimeout()
78 void QuicConnectionPeer::SetPerspective(QuicConnection* connection, in SetPerspective()
86 void QuicConnectionPeer::SetSelfAddress(QuicConnection* connection, in SetSelfAddress()
92 void QuicConnectionPeer::SetPeerAddress(QuicConnection* connection, in SetPeerAddress()
99 QuicConnection* connection, const QuicSocketAddress& direct_peer_address) { in SetDirectPeerAddress()
[all …]
|
| /external/cronet/stable/net/third_party/quiche/src/quiche/quic/test_tools/ |
| D | quic_connection_peer.cc | 43 QuicConnection* connection, SendAlgorithmInterface* send_algorithm) { in SetSendAlgorithm()
49 QuicConnection* connection, LossDetectionInterface* loss_algorithm) { in SetLossAlgorithm()
55 QuicConnection* connection) { in GetPacketCreator()
61 QuicConnection* connection) { in GetSentPacketManager()
67 QuicConnection* connection) { in GetNetworkTimeout()
73 QuicConnection* connection) { in GetHandshakeTimeout()
78 void QuicConnectionPeer::SetPerspective(QuicConnection* connection, in SetPerspective()
86 void QuicConnectionPeer::SetSelfAddress(QuicConnection* connection, in SetSelfAddress()
92 void QuicConnectionPeer::SetPeerAddress(QuicConnection* connection, in SetPeerAddress()
99 QuicConnection* connection, const QuicSocketAddress& direct_peer_address) { in SetDirectPeerAddress()
[all …]
|
| /external/cronet/tot/base/android/junit/src/org/chromium/base/process_launcher/ |
| D | ChildProcessConnectionTest.java | 223 ChildProcessConnection connection = createDefaultTestConnection(); in testStrongBinding() local
243 ChildProcessConnection connection = in testServiceBundle() local
260 ChildProcessConnection connection = createDefaultTestConnection(); in testServiceStartsSuccessfully() local
279 ChildProcessConnection connection = createDefaultTestConnection(); in testServiceStartsAndFailsToBind() local
295 ChildProcessConnection connection = createDefaultTestConnection(); in testServiceStops() local
307 ChildProcessConnection connection = createDefaultTestConnection(); in testServiceDisconnects() local
319 ChildProcessConnection connection = in testNotBoundToCaller() local
337 ChildProcessConnection connection = in testBoundToCallerSuccess() local
356 ChildProcessConnection connection = in testBoundToCallerFailure() local
377 ChildProcessConnection connection = createDefaultTestConnection(); in testSetupConnectionBeforeServiceConnected() local
[all …]
|
| /external/cronet/stable/base/android/junit/src/org/chromium/base/process_launcher/ |
| D | ChildProcessConnectionTest.java | 223 ChildProcessConnection connection = createDefaultTestConnection(); in testStrongBinding() local
243 ChildProcessConnection connection = in testServiceBundle() local
260 ChildProcessConnection connection = createDefaultTestConnection(); in testServiceStartsSuccessfully() local
279 ChildProcessConnection connection = createDefaultTestConnection(); in testServiceStartsAndFailsToBind() local
295 ChildProcessConnection connection = createDefaultTestConnection(); in testServiceStops() local
307 ChildProcessConnection connection = createDefaultTestConnection(); in testServiceDisconnects() local
319 ChildProcessConnection connection = in testNotBoundToCaller() local
337 ChildProcessConnection connection = in testBoundToCallerSuccess() local
356 ChildProcessConnection connection = in testBoundToCallerFailure() local
377 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 | 157 async def async_read(connection): argument
400 async def read_value(connection): argument
419 async def read_value(connection): argument
473 def on_characteristic1_write(connection, value): argument
478 def on_characteristic2_read(connection): argument
481 def on_characteristic2_write(connection, value): argument
598 def on_characteristic1_subscription(connection, notify_enabled, indicate_enabled): argument
614 def on_characteristic2_subscription(connection, notify_enabled, indicate_enabled): argument
632 def on_characteristic3_subscription(connection, notify_enabled, indicate_enabled): argument
648 connection, characteristic, notify_enabled, indicate_enabled argument
[all …]
|
| /external/cronet/stable/net/server/ |
| D | http_server.cc | 79 HttpConnection* connection = FindConnection(connection_id); in HttpServer() local
90 HttpConnection* connection = FindConnection(connection_id); in HttpServer() local
101 HttpConnection* connection = FindConnection(connection_id); in HttpServer() local
172 HttpConnection* connection = FindConnection(connection_id); in HttpServer() local
178 HttpConnection* connection = FindConnection(connection_id); in HttpServer() local
208 HttpConnection* connection = connection_ptr.get(); in HttpServer() local
216 void HttpServer::DoReadLoop(HttpConnection* connection) { in HttpServer()
237 HttpConnection* connection = FindConnection(connection_id); in HttpServer() local
245 int HttpServer::HandleReadResult(HttpConnection* connection, int rv) { in HttpServer()
336 void HttpServer::DoWriteLoop(HttpConnection* connection, in HttpServer()
[all …]
|
| /external/cronet/tot/net/server/ |
| D | http_server.cc | 79 HttpConnection* connection = FindConnection(connection_id); in HttpServer() local
90 HttpConnection* connection = FindConnection(connection_id); in HttpServer() local
101 HttpConnection* connection = FindConnection(connection_id); in HttpServer() local
172 HttpConnection* connection = FindConnection(connection_id); in HttpServer() local
178 HttpConnection* connection = FindConnection(connection_id); in HttpServer() local
208 HttpConnection* connection = connection_ptr.get(); in HttpServer() local
216 void HttpServer::DoReadLoop(HttpConnection* connection) { in HttpServer()
237 HttpConnection* connection = FindConnection(connection_id); in HttpServer() local
245 int HttpServer::HandleReadResult(HttpConnection* connection, int rv) { in HttpServer()
336 void HttpServer::DoWriteLoop(HttpConnection* connection, 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/robolectric/robolectric/src/test/java/org/robolectric/shadows/ |
| D | ShadowConnectionTest.java | 22 Connection connection = new FakeConnection(); in testGetMostRecentEvent() local
34 Connection connection = new FakeConnection(); in isDestroyed_callDestroy_returnsTrue() local
44 Connection connection = new FakeConnection(); in isDestroyed_doNotCallDestroy_returnsFalse() local
|
| /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
|