| /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/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/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/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/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()
166 void ConnectionManager::AddConnection(Connection* connection) { in AddConnection()
173 void ConnectionManager::RemoveConnection(Connection* connection) { in RemoveConnection()
200 Connection* connection = GetConnection(message.connection_id); in OnStreamMessage() local
233 Connection* connection = GetConnection(request.connection_id); in OnStreamMessage() local
268 Connection* connection = GetConnection(event.connection_id); in OnStreamMessage() local
|
| /external/skqp/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/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/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 | 17 CastSocket::CastSocket(std::unique_ptr<TlsConnection> connection, in CastSocket()
68 void CastSocket::OnError(TlsConnection* connection, Error error) { in OnError()
73 void CastSocket::OnRead(TlsConnection* connection, std::vector<uint8_t> block) { in OnRead()
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/ |
| D | Spdy3ConnectionTest.java | 73 FramedConnection connection = connection(peer, SPDY3); in clientCreatesStreamAndServerReplies() local
104 FramedConnection connection = connection(peer, SPDY3); in headersOnlyStreamIsClosedAfterReplyHeaders() local
124 FramedConnection connection = connection(peer, SPDY3); in clientCreatesStreamAndServerRepliesWithFin() local
235 FramedConnection connection = connection(peer, SPDY3); in clientPingsServer() local
|
| /external/wayland/src/ |
| D | connection.c | 172 struct wl_connection *connection; in wl_connection_create() local
204 wl_connection_close_fds_in(struct wl_connection *connection, int max) in wl_connection_close_fds_in()
210 wl_connection_destroy(struct wl_connection *connection) in wl_connection_destroy()
222 wl_connection_copy(struct wl_connection *connection, void *data, size_t size) in wl_connection_copy()
228 wl_connection_consume(struct wl_connection *connection, size_t size) in wl_connection_consume()
289 wl_connection_flush(struct wl_connection *connection) in wl_connection_flush()
333 wl_connection_pending_input(struct wl_connection *connection) in wl_connection_pending_input()
339 wl_connection_read(struct wl_connection *connection) in wl_connection_read()
378 wl_connection_write(struct wl_connection *connection, in wl_connection_write()
397 wl_connection_queue(struct wl_connection *connection, in wl_connection_queue()
[all …]
|
| /external/mockwebserver/src/test/java/com/google/mockwebserver/ |
| D | MockWebServerTest.java | 111 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); in testRegularResponse() local
131 URLConnection connection = server.getUrl("/").openConnection(); in testRedirect() local
159 URLConnection connection = server.getUrl("/").openConnection(); in testDispatchBlocksWaitingForEnqueue() local
172 URLConnection connection = server.getUrl("/").openConnection(); in testNonHexadecimalChunkSize() local
|
| /external/openscreen/platform/impl/ |
| D | tls_connection_factory_posix.cc | 79 std::unique_ptr<TlsConnectionPosix> connection( in Connect() local
180 std::unique_ptr<TlsConnectionPosix> connection( in OnSocketAccepted() local
190 bool TlsConnectionFactoryPosix::ConfigureSsl(TlsConnectionPosix* connection) { in ConfigureSsl()
240 std::unique_ptr<TlsConnectionPosix> connection) { in Connect()
285 std::unique_ptr<TlsConnectionPosix> connection) { in Accept()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/ |
| D | publish.cpp | 187 rx::composite_subscription connection; variable
200 rx::composite_subscription connection; variable
213 rx::composite_subscription connection; variable
301 rx::composite_subscription connection; variable
314 rx::composite_subscription connection; variable
400 rx::composite_subscription connection; variable
413 rx::composite_subscription connection; variable
426 rx::composite_subscription connection; variable
|
| /external/setupcompat/main/java/com/google/android/setupcompat/portal/ |
| D | PortalHelper.java | 59 @NonNull Context context, @NonNull ServiceConnection connection) { in bindSetupNotificationService()
87 ServiceConnection connection = in registerProgressService() local
146 ServiceConnection connection = in isPortalAvailable() local
184 ServiceConnection connection = in isProgressServiceAlive() local
|