Home
last modified time | relevance | path

Searched defs:connection (Results 1 – 25 of 497) sorted by relevance

12345678910>>...20

/external/cronet/net/third_party/quiche/src/quiche/quic/test_tools/
Dquic_connection_peer.cc22 QuicConnection* connection, SendAlgorithmInterface* send_algorithm) { in SetSendAlgorithm()
28 QuicConnection* connection, LossDetectionInterface* loss_algorithm) { in SetLossAlgorithm()
34 QuicConnection* connection, QuicStopWaitingFrame* stop_waiting) { in PopulateStopWaitingFrame()
40 QuicConnection* connection) { in GetPacketCreator()
46 QuicConnection* connection) { in GetSentPacketManager()
52 QuicConnection* connection) { in GetNetworkTimeout()
58 QuicConnection* connection) { in GetHandshakeTimeout()
64 QuicConnection* connection) { in GetBandwidthUpdateTimeout()
69 void QuicConnectionPeer::DisableBandwidthUpdate(QuicConnection* connection) { in DisableBandwidthUpdate()
80 void QuicConnectionPeer::SetPerspective(QuicConnection* connection, in SetPerspective()
[all …]
/external/cronet/components/cronet/android/test/javatests/src/org/chromium/net/urlconnection/
DCronetBufferedOutputStreamTest.java57 HttpURLConnection connection = in testGetOutputStreamAfterConnectionMade() local
80 HttpURLConnection connection = in testWriteAfterConnect() local
103 HttpURLConnection connection = in testWriteAfterReadingResponse() local
124 HttpURLConnection connection = in testPostWithContentLength() local
156 HttpURLConnection connection = in testPostWithContentLengthOneMassiveWrite() local
176 HttpURLConnection connection = in testPostWithContentLengthWriteOneByte() local
198 HttpURLConnection connection = in testPostWithZeroContentLength() local
215 HttpURLConnection connection = in testPostZeroByteWithoutContentLength() local
241 HttpURLConnection connection = in testPostWithoutContentLengthSmall() local
258 HttpURLConnection connection = in testPostWithoutContentLength() local
[all …]
DCronetChunkedOutputStreamTest.java68 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); in testGetOutputStreamAfterConnectionMade() local
86 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); in testWriteAfterReadingResponse() local
105 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); in testWriteAfterRequestFailed() local
134 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); in testGetResponseAfterWriteFailed() local
179 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); in testPost() local
196 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); in testTransferEncodingHeaderSet() local
213 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); in testPostOneMassiveWrite() local
231 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); in testPostWriteOneByte() local
250 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); in testPostOneMassiveWriteWriteOneByte() local
270 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); in testPostWholeNumberOfChunks() local
[all …]
DCronetFixedModeOutputStreamTest.java74 HttpURLConnection connection = in testConnectBeforeWrite() local
94 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); in testZeroLengthWriteWithNoResponseBody() local
110 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); in testWriteAfterRequestFailed() local
141 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); in testGetResponseAfterWriteFailed() local
214 HttpURLConnection connection = in testWriteLessThanContentLength() local
236 HttpURLConnection connection = in testWriteMoreThanContentLength() local
262 HttpURLConnection connection = in testWriteMoreThanContentLengthWriteOneByte() local
294 HttpURLConnection connection = in testFixedLengthStreamingMode() local
312 HttpURLConnection connection = in testFixedLengthStreamingModeWriteOneByte() local
333 HttpURLConnection connection = in testFixedLengthStreamingModeLargeData() local
[all …]
DCronetHttpURLConnectionTest.java111 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); in testSetRequestMethod() local
127 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); in testConnectTimeout() local
144 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); in testReadTimeout() local
164 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); in testDefaultToPostWhenDoOutput() local
185 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); in testInitOutputStreamInConnect() local
210 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); in testInitChunkedOutputStreamInConnect() local
229 HttpURLConnection connection = in testSetFixedLengthStreamingModeLong() local
249 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); in testSetFixedLengthStreamingModeInt() local
444 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); in testAddRequestProperty() local
552 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); in testAddAndSetRequestPropertyWithSameKey() local
[all …]
/external/cronet/base/android/junit/src/org/chromium/base/process_launcher/
DChildProcessConnectionTest.java204 ChildProcessConnection connection = createDefaultTestConnection(); in testStrongBinding() local
224 ChildProcessConnection connection = createTestConnection(false /* bindToCaller */, in testServiceBundle() local
237 ChildProcessConnection connection = createDefaultTestConnection(); in testServiceStartsSuccessfully() local
256 ChildProcessConnection connection = createDefaultTestConnection(); in testServiceStartsAndFailsToBind() local
272 ChildProcessConnection connection = createDefaultTestConnection(); in testServiceStops() local
284 ChildProcessConnection connection = createDefaultTestConnection(); in testServiceDisconnects() local
296 ChildProcessConnection connection = in testNotBoundToCaller() local
311 ChildProcessConnection connection = in testBoundToCallerSuccess() local
327 ChildProcessConnection connection = in testBoundToCallerFailure() local
345 ChildProcessConnection connection = createDefaultTestConnection(); in testSetupConnectionBeforeServiceConnected() local
[all …]
/external/libchrome/base/android/junit/src/org/chromium/base/process_launcher/
DChildProcessConnectionTest.java162 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 …]
DChildConnectionAllocatorTest.java95 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/bumble/
Dgatt_server.py264 def read_cccd(self, connection, characteristic): argument
275 def write_cccd(self, connection, characteristic, value): argument
302 def send_response(self, connection, response): argument
308 async def notify_subscriber(self, connection, attribute, value=None, force=False): argument
345 async def indicate_subscriber(self, connection, attribute, value=None, force=False): argument
431 def on_disconnection(self, connection): argument
439 def on_gatt_pdu(self, connection, att_pdu): argument
481 def on_att_request(self, connection, pdu): argument
498 def on_att_exchange_mtu_request(self, connection, request): argument
515 def on_att_find_information_request(self, connection, request): argument
[all …]
/external/volley/core/src/main/java/com/android/volley/toolbox/
DHurlStack.java83 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/
DOkUrlFactoryTest.java68 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()
DUrlConnectionCacheTest.java292 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/
Dhttp_transport_curl_test.cc72 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/
Drun_gatt_server.py42 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/cronet/net/server/
Dhttp_server.cc71 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/python/bumble/tests/
Dgatt_test.py427 def on_characteristic1_write(connection, value): argument
432 def on_characteristic2_read(connection): argument
435 def on_characteristic2_write(connection, value): argument
552 def on_characteristic1_subscription(connection, notify_enabled, indicate_enabled): argument
568 def on_characteristic2_subscription(connection, notify_enabled, indicate_enabled): argument
584 def on_characteristic3_subscription(connection, notify_enabled, indicate_enabled): argument
600 connection, characteristic, notify_enabled, indicate_enabled argument
769 def on_d3_connection(connection): argument
/external/webrtc/p2p/base/
Dwrapping_active_ice_controller.cc68 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/okhttp/okhttp-android-support/src/test/java/com/squareup/okhttp/internal/huc/
DResponseCacheTest.java199 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/
DMockWebServerTest.java87 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/
Dquic_server_unittest.cc35 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/openscreen/osp/impl/presentation/
Dpresentation_receiver.cc68 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()
Dpresentation_connection.cc30 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/
Dlink_relay.py123 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/
DResponse.cpp44 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/conscrypt/common/src/test/java/org/conscrypt/javax/net/ssl/
DHttpsURLConnectionTest.java78 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

12345678910>>...20