| /external/python/bumble/bumble/ |
| D | gatt_server.py | 141 def read_cccd(self, connection, characteristic): argument
152 def write_cccd(self, connection, characteristic, value): argument
168 def send_response(self, connection, response): argument
172 async def notify_subscriber(self, connection, attribute, force=False): argument
221 async def indicate_subscriber(self, connection, attribute, force=False): argument
285 def on_disconnection(self, connection): argument
295 def on_gatt_pdu(self, connection, att_pdu): argument
328 def get_mtu(self, connection): argument
334 def on_att_request(self, connection, pdu): argument
346 def on_att_exchange_mtu_request(self, connection, request): argument
[all …]
|
| D | device.py | 90 def __init__(self, connection): argument
362 def on_connection(self, connection): argument
368 …def on_characteristic_subscription(self, connection, characteristic, notify_enabled, indicate_enab… argument
507 def create_l2cap_connector(self, connection, psm): argument
850 async def disconnect(self, connection, reason): argument
871 async def update_connection_parameters( argument
957 async def pair(self, connection): argument
960 def request_pairing(self, connection): argument
993 async def authenticate(self, connection): argument
1021 async def encrypt(self, connection): argument
[all …]
|
| D | l2cap.py | 589 def __init__(self, manager, connection, signaling_cid, psm, source_cid, mtu): argument
839 def next_identifier(self, connection): argument
847 def send_pdu(self, connection, cid, pdu): argument
852 def on_pdu(self, connection, cid, pdu): argument
865 def send_control_frame(self, connection, cid, control_frame): argument
869 def on_control_frame(self, connection, cid, control_frame): argument
902 def on_l2cap_command_reject(self, connection, cid, packet): argument
906 def on_l2cap_connection_request(self, connection, cid, request): argument
949 def on_l2cap_connection_response(self, connection, cid, response): argument
956 def on_l2cap_configure_request(self, connection, cid, request): argument
[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/python/bumble/tests/ |
| D | gatt_test.py | 233 def on_characteristic1_write(connection, value): argument
238 def on_characteristic2_read(connection): argument
241 def on_characteristic2_write(connection, value): argument
361 def on_characteristic1_subscription(connection, notify_enabled, indicate_enabled): argument
373 def on_characteristic2_subscription(connection, notify_enabled, indicate_enabled): argument
385 def on_characteristic3_subscription(connection, notify_enabled, indicate_enabled): argument
400 … def on_characteristic_subscription(connection, characteristic, notify_enabled, indicate_enabled): argument
424 def on_c1_update(connection, value): argument
460 def on_c3_update(connection, value): argument
|
| /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/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/examples/ |
| D | run_gatt_server.py | 45 def on_connection(self, connection): argument
53 def my_custom_read(connection): argument
58 def my_custom_write(connection, value): argument
62 def my_custom_read_with_error(connection): argument
70 def my_custom_write_with_error(connection, value): argument
|
| /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/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/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
|
| D | quic_client_unittest.cc | 39 explicit ConnectionCallback(std::unique_ptr<ProtocolConnection>* connection) in ConnectionCallback()
45 std::unique_ptr<ProtocolConnection> connection) override { in OnConnectionOpened()
80 void SendTestMessage(ProtocolConnection* connection) { in SendTestMessage()
133 std::unique_ptr<ProtocolConnection> connection; in TEST_F() local
245 .WillOnce(Invoke([](std::unique_ptr<ProtocolConnection>& connection) { in TEST_F()
248 std::unique_ptr<ProtocolConnection> connection; in TEST_F() local
|
| /external/python/bumble/apps/link_relay/ |
| D | link_relay.py | 118 async def add_connection(self, connection): argument
123 async def remove_connection(self, connection): argument
131 async def bridge_connection(self, connection): argument
156 async def on_rpc_request(self, connection, message): argument
168 async def on_targetted_message(self, connection, message): argument
188 async def on_set_address_command(self, connection, params): argument
215 async def serve_as_controller(connection): argument
|
| /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/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/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
| D | ConnectionPool.java | 186 void put(RealConnection connection) { in put()
198 boolean connectionBecameIdle(RealConnection connection) { in connectionBecameIdle()
214 RealConnection connection = i.next(); in evictAll() local
244 RealConnection connection = i.next(); in cleanup() local
294 private int pruneAndGetAllocationCount(RealConnection connection, long now) { in pruneAndGetAllocationCount()
|
| /external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/ |
| D | ConnectionPool.java | 192 void put(RealConnection connection) { in put()
204 boolean connectionBecameIdle(RealConnection connection) { in connectionBecameIdle()
220 RealConnection connection = i.next(); in evictAll() local
250 RealConnection connection = i.next(); in cleanup() local
300 private int pruneAndGetAllocationCount(RealConnection connection, long now) { in pruneAndGetAllocationCount()
|
| /external/pandora/bt-test-interfaces/pandora/ |
| D | host.proto | 73 Connection connection = 1; field
88 Connection connection = 1; field
103 Connection connection = 1; field
110 Connection connection = 1; field
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/http/ |
| D | DisconnectTest.java | 81 HttpURLConnection connection = new OkUrlFactory(client).open(server.getUrl("/")); in interruptWritingRequestBody() local
108 HttpURLConnection connection = new OkUrlFactory(client).open(server.getUrl("/")); in interruptReadingResponseBody() local
123 private void disconnectLater(final HttpURLConnection connection, final int delayMillis) { in disconnectLater()
|
| /external/libbrillo/brillo/glib/ |
| D | dbus.cc | 132 Proxy::Proxy(const BusConnection& connection, in Proxy()
142 Proxy::Proxy(const BusConnection& connection, in Proxy()
150 Proxy::Proxy(const BusConnection& connection, in Proxy()
168 Proxy::value_type Proxy::GetGProxy(const BusConnection& connection, in GetGProxy()
199 Proxy::value_type Proxy::GetGPeerProxy(const BusConnection& connection, in GetGPeerProxy()
211 bool RegisterExclusiveService(const BusConnection& connection, in RegisterExclusiveService()
|
| /external/openscreen/cast/common/channel/ |
| D | cast_socket.cc | 19 CastSocket::CastSocket(std::unique_ptr<TlsConnection> connection, in CastSocket()
70 void CastSocket::OnError(TlsConnection* connection, Error error) { in OnError()
75 void CastSocket::OnRead(TlsConnection* connection, std::vector<uint8_t> block) { in OnRead()
|