Home
last modified time | relevance | path

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

12345678910

/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/volley/src/main/java/com/android/volley/toolbox/
DHurlStack.java88 HttpURLConnection connection = openConnection(parsedUrl, request); in executeRequest() local
159 UrlConnectionInputStream(HttpURLConnection connection) { in UrlConnectionInputStream()
177 private static InputStream inputStreamFromConnection(HttpURLConnection connection) { in inputStreamFromConnection()
189 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); in createConnection() local
207 HttpURLConnection connection = createConnection(url); in openConnection() local
227 HttpURLConnection connection, Request<?> request) throws IOException, AuthFailureError { in setConnectionParametersForRequest()
273 private static void addBodyIfExists(HttpURLConnection connection, Request<?> request) in addBodyIfExists()
281 private static void addBody(HttpURLConnection connection, Request<?> request, byte[] body) in addBody()
/external/libbrillo/brillo/http/
Dhttp_transport_curl_unittest.cc69 auto connection = transport_->CreateConnection("http://foo.bar/get", in TEST_F() local
99 auto connection = proxy_transport->CreateConnection("http://foo.bar/get", in TEST_F() local
117 auto connection = transport_->CreateConnection( in TEST_F() local
131 auto connection = transport_->CreateConnection( in TEST_F() local
147 auto connection = transport_->CreateConnection( in TEST_F() local
167 auto connection = transport_->CreateConnection( in TEST_F() local
185 auto connection = transport_->CreateConnection( in TEST_F() local
232 auto connection = transport_->CreateConnection( in TEST_F() local
328 auto connection = transport_->CreateConnection( in TEST_F() local
Dhttp_transport_curl.cc96 std::shared_ptr<Connection> connection; member
124 std::shared_ptr<http::Connection> connection; in CreateConnection() local
215 RequestID Transport::StartAsyncTransfer(http::Connection* connection, in StartAsyncTransfer()
434 Connection* connection = nullptr; in ProcessAsyncCurlMessages() local
446 void Transport::OnTransferComplete(Connection* connection, CURLcode code) { in OnTransferComplete()
496 void Transport::CleanAsyncConnection(Connection* connection) { in CleanAsyncConnection()
/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/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/skqp/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/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/http/
DDisconnectTest.java81 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()
DThreadInterruptTest.java85 HttpURLConnection connection = new OkUrlFactory(client).open(server.getUrl("/")); in interruptWritingRequestBody() local
112 HttpURLConnection connection = new OkUrlFactory(client).open(server.getUrl("/")); in interruptReadingResponseBody() local
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/
DSpdy3ConnectionTest.java77 FramedConnection connection = connection(peer, SPDY3); in clientCreatesStreamAndServerReplies() local
106 FramedConnection connection = connection(peer, SPDY3); in headersOnlyStreamIsClosedAfterReplyHeaders() local
123 FramedConnection connection = connection(peer, SPDY3); in clientCreatesStreamAndServerRepliesWithFin() local
226 FramedConnection connection = connection(peer, SPDY3); in clientPingsServer() local
/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 …]
DCacheAdapterTest.java65 private HttpURLConnection connection; field in CacheAdapterTest
239 private void executeGet(HttpURLConnection connection) throws IOException { in executeGet()
245 private void executePost(HttpURLConnection connection) throws IOException { in executePost()
/external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/
DConnectionPool.java192 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/src/main/java/com/squareup/okhttp/
DConnectionPool.java186 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/libbrillo/brillo/glib/
Ddbus.cc132 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/mockwebserver/src/test/java/com/google/mockwebserver/
DMockWebServerTest.java111 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/oj-libjdwp/src/share/classes/com/sun/jdi/
DVirtualMachineManager.java405 VirtualMachine createVirtualMachine(Connection connection, Process process) throws IOException; in createVirtualMachine()
430 VirtualMachine createVirtualMachine(Connection connection) throws IOException; in createVirtualMachine()
/external/wayland/src/
Dconnection.c164 struct wl_connection *connection; in wl_connection_create() local
195 wl_connection_destroy(struct wl_connection *connection) in wl_connection_destroy()
207 wl_connection_copy(struct wl_connection *connection, void *data, size_t size) in wl_connection_copy()
213 wl_connection_consume(struct wl_connection *connection, size_t size) in wl_connection_consume()
274 wl_connection_flush(struct wl_connection *connection) in wl_connection_flush()
318 wl_connection_pending_input(struct wl_connection *connection) in wl_connection_pending_input()
324 wl_connection_read(struct wl_connection *connection) in wl_connection_read()
363 wl_connection_write(struct wl_connection *connection, in wl_connection_write()
382 wl_connection_queue(struct wl_connection *connection, in wl_connection_queue()
409 wl_connection_get_fd(struct wl_connection *connection) in wl_connection_get_fd()
[all …]
/external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/
Dpublish.cpp187 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
Dreplay.cpp49 rx::composite_subscription connection; variable
62 rx::composite_subscription connection; variable
75 rx::composite_subscription connection; variable
162 rx::composite_subscription connection; variable
175 rx::composite_subscription connection; variable
250 rx::composite_subscription connection; variable
380 rx::composite_subscription connection; variable
499 rx::composite_subscription connection; variable
618 rx::composite_subscription connection; variable
/external/cmockery/cmockery_0_1_2/src/example/
Dcustomer_database_test.c28 DatabaseConnection* const connection, const char * const query_string, in mock_query_database()
53 DatabaseConnection connection = { in test_get_customer_id_by_name() local
/external/webrtc/webrtc/base/
Dhttpserver.cc48 Connection* connection = new Connection(connection_id, this); in HandleConnection() local
57 if (Connection* connection = Find(connection_id)) { in Respond() local
68 if (Connection* connection = Find(connection_id)) { in Close() local
106 Connection* connection = it->second; in Remove() local
/external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/http/
DStreamAllocation.java83 private RealConnection connection; field in StreamAllocation
212 public synchronized RealConnection connection() { in connection() method in StreamAllocation
302 public void acquire(RealConnection connection) { in acquire()
307 private void release(RealConnection connection) { in release()
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/http/
DStreamAllocation.java81 private RealConnection connection; field in StreamAllocation
210 public synchronized RealConnection connection() { in connection() method in StreamAllocation
300 public void acquire(RealConnection connection) { in acquire()
305 private void release(RealConnection connection) { in release()

12345678910