| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
| ConnectionPool.java | 38 * {@link Connection}. This class implements the policy of which connections to
49 * connection alive in the pool before closing it. Default is 5 minutes.
81 * thread running per connection pool. We use a thread pool executor because it can shrink to
134 for (RealConnection connection : connections) {
135 if (connection.allocations.isEmpty()) total++;
159 for (RealConnection connection : connections) {
160 if (connection.isMultiplexed()) total++;
170 /** Returns a recycled connection to {@code address}, or null if no such connection exists. */
173 for (RealConnection connection : connections)
214 RealConnection connection = i.next(); local
244 RealConnection connection = i.next(); local
[all...] |
| /external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/ |
| ConnectionPool.java | 39 * {@link Connection}. This class implements the policy of which connections to
50 * connection alive in the pool before closing it. Default is 5 minutes.
84 * thread running per connection pool. We use a thread pool executor because it can shrink to
140 for (RealConnection connection : connections) {
141 if (connection.allocations.isEmpty()) total++;
165 for (RealConnection connection : connections) {
166 if (connection.isMultiplexed()) total++;
176 /** Returns a recycled connection to {@code address}, or null if no such connection exists. */
179 for (RealConnection connection : connections)
220 RealConnection connection = i.next(); local
250 RealConnection connection = i.next(); local
[all...] |
| /external/conscrypt/openjdk-integ-tests/src/test/java/org/conscrypt/javax/net/ssl/ |
| HttpsURLConnectionTest.java | 50 HttpsURLConnection connection = local
53 assertSame(originalHostnameVerifier, connection.getHostnameVerifier());
55 connection.disconnect();
61 connection = (HttpsURLConnection) new URL(UNRESOLVABLE_HTTPS_URL).openConnection();
63 assertSame(anotherVerifier, connection.getHostnameVerifier());
65 connection.disconnect();
69 connection = (HttpsURLConnection) new URL(UNRESOLVABLE_HTTPS_URL).openConnection();
71 assertSame(originalHostnameVerifier, connection.getHostnameVerifier());
73 connection.disconnect();
88 HttpsURLConnection connection local
[all...] |
| /external/conscrypt/repackaged/openjdk-integ-tests/src/test/java/com/android/org/conscrypt/javax/net/ssl/ |
| HttpsURLConnectionTest.java | 54 HttpsURLConnection connection = local
57 assertSame(originalHostnameVerifier, connection.getHostnameVerifier());
59 connection.disconnect();
65 connection = (HttpsURLConnection) new URL(UNRESOLVABLE_HTTPS_URL).openConnection();
67 assertSame(anotherVerifier, connection.getHostnameVerifier());
69 connection.disconnect();
73 connection = (HttpsURLConnection) new URL(UNRESOLVABLE_HTTPS_URL).openConnection();
75 assertSame(originalHostnameVerifier, connection.getHostnameVerifier());
77 connection.disconnect();
92 HttpsURLConnection connection local
[all...] |
| /external/autotest/frontend/db/backends/afe/ |
| base.py | 22 self.connection = None
28 self.ops = DatabaseOperations(connection=kwargs.get('connection'))
32 if self.connection is not None:
33 if self.connection.open:
35 self.connection.ping()
38 self.connection.close()
39 self.connection = None
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/http/ |
| StreamAllocation.java | 43 * potentially slow to establish so it is necessary to be able to cancel a connection
46 * connections. Each connection has its own allocation limit, which defines how many
47 * concurrent streams that connection can carry. HTTP/1.x connections can carry 1 stream
51 * connection for better behavior and locality.
58 * <li>{@link #noNewStreams()} prevents the connection from being used for new streams in the
59 * future. Use this after a {@code Connection: close} header, or when the connection may be
65 * <li>{@link #release()} removes the call's hold on the connection. Note that this won't
66 * immediately free the connection if there is a stream still lingering. That happens when a
72 * stream but not the other streams sharing its connection. But if the TLS handshake is still i
81 private RealConnection connection; field in class:StreamAllocation
210 public synchronized RealConnection connection() { method in class:StreamAllocation
[all...] |
| /external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/http/ |
| StreamAllocation.java | 44 * potentially slow to establish so it is necessary to be able to cancel a connection
47 * connections. Each connection has its own allocation limit, which defines how many
48 * concurrent streams that connection can carry. HTTP/1.x connections can carry 1 stream
52 * connection for better behavior and locality.
59 * <li>{@link #noNewStreams()} prevents the connection from being used for new streams in the
60 * future. Use this after a {@code Connection: close} header, or when the connection may be
66 * <li>{@link #release()} removes the call's hold on the connection. Note that this won't
67 * immediately free the connection if there is a stream still lingering. That happens when a
73 * stream but not the other streams sharing its connection. But if the TLS handshake is still i
83 private RealConnection connection; field in class:StreamAllocation
212 public synchronized RealConnection connection() { method in class:StreamAllocation
[all...] |
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/http/ |
| DisconnectTest.java | 81 HttpURLConnection connection = new OkUrlFactory(client).open(server.getUrl("/")); local
82 disconnectLater(connection, 500);
84 connection.setDoOutput(true);
85 connection.setFixedLengthStreamingMode(requestBodySize);
86 OutputStream requestBody = connection.getOutputStream();
93 fail("Expected connection to be closed");
97 connection.disconnect();
108 HttpURLConnection connection = new OkUrlFactory(client).open(server.getUrl("/")); local
109 disconnectLater(connection, 500);
111 InputStream responseBody = connection.getInputStream()
[all...] |
| /external/skia/tools/skiaserve/urlhandlers/ |
| ColorModeHandler.cpp | 22 int ColorModeHandler::handle(Request* request, MHD_Connection* connection,
39 return SendError(connection, "Unable to create requested surface");
41 return SendOK(connection);
|
| EnableGPUHandler.cpp | 22 int EnableGPUHandler::handle(Request* request, MHD_Connection* connection,
37 return SendError(connection, "Unable to create GPU surface");
39 return SendOK(connection);
|
| OverdrawHandler.cpp | 22 int OverdrawHandler::handle(Request* request, MHD_Connection* connection,
37 return SendError(connection, "Unable to set overdraw");
39 return SendOK(connection);
|
| UrlHandler.h | 19 virtual int handle(Request* request, MHD_Connection* connection,
27 int handle(Request* request, MHD_Connection* connection,
35 int handle(Request* request, MHD_Connection* connection,
43 int handle(Request* request, MHD_Connection* connection,
55 int handle(Request* request, MHD_Connection* connection,
67 int handle(Request* request, MHD_Connection* connection,
79 int handle(Request* request, MHD_Connection* connection,
87 int handle(Request* request, MHD_Connection* connection,
95 int handle(Request* request, MHD_Connection* connection,
103 int handle(Request* request, MHD_Connection* connection,
[all...] |
| /external/skqp/tools/skiaserve/urlhandlers/ |
| ColorModeHandler.cpp | 22 int ColorModeHandler::handle(Request* request, MHD_Connection* connection,
39 return SendError(connection, "Unable to create requested surface");
41 return SendOK(connection);
|
| EnableGPUHandler.cpp | 22 int EnableGPUHandler::handle(Request* request, MHD_Connection* connection,
37 return SendError(connection, "Unable to create GPU surface");
39 return SendOK(connection);
|
| OverdrawHandler.cpp | 22 int OverdrawHandler::handle(Request* request, MHD_Connection* connection,
37 return SendError(connection, "Unable to set overdraw");
39 return SendOK(connection);
|
| UrlHandler.h | 19 virtual int handle(Request* request, MHD_Connection* connection,
27 int handle(Request* request, MHD_Connection* connection,
35 int handle(Request* request, MHD_Connection* connection,
43 int handle(Request* request, MHD_Connection* connection,
55 int handle(Request* request, MHD_Connection* connection,
67 int handle(Request* request, MHD_Connection* connection,
79 int handle(Request* request, MHD_Connection* connection,
87 int handle(Request* request, MHD_Connection* connection,
95 int handle(Request* request, MHD_Connection* connection,
103 int handle(Request* request, MHD_Connection* connection,
[all...] |
| /external/cmockery/cmockery_0_1_2/src/example/ |
| customer_database_test.c | 24 DatabaseConnection * const connection, const char * const customer_name);
28 DatabaseConnection* const connection, const char * const query_string,
53 DatabaseConnection connection = { local
60 assert_int_equal(get_customer_id_by_name(&connection, "john doe"), 543);
|
| database.h | 24 DatabaseConnection* const connection, const char * const query_string,
27 // Connection to a database.
|
| /external/pdfium/fxjs/xfa/ |
| cjx_binditems.h | 19 JS_PROP(connection);
|
| cjx_setproperty.h | 19 JS_PROP(connection);
|
| cjx_wsdlconnection.h | 17 explicit CJX_WsdlConnection(CXFA_WsdlConnection* connection);
|
| /external/python/cpython2/Modules/_sqlite/ |
| util.h | 29 #include "connection.h"
31 int pysqlite_step(sqlite3_stmt* statement, pysqlite_Connection* connection);
|
| /cts/apps/CtsVerifier/src/com/android/cts/verifier/telecom/ |
| CtsConnectionService.java | 21 import android.telecom.Connection;
41 void onDestroyed(CtsConnection connection) {
43 mConnections.remove(connection);
106 public Connection onCreateOutgoingConnection(PhoneAccountHandle connectionManagerAccount,
113 public Connection onCreateIncomingConnection(PhoneAccountHandle connectionManagerPhoneAccount,
129 private Connection createManagedConnection(ConnectionRequest request, boolean isIncoming) {
135 CtsConnection connection = new CtsConnection(getApplicationContext(), isIncoming, local
138 connection.setConnectionProperties(Connection.PROPERTY_SELF_MANAGED);
140 connection.setConnectionCapabilities(Connection.CAPABILITY_SUPPORT_HOLD
[all...] |
| /external/oauth/core/src/main/java/net/oauth/client/ |
| URLConnectionClient.java | 36 * they do things like connection pooling. They also support reading the body
50 final URLConnection connection = url.openConnection(); local
51 connection.setDoInput(true);
52 if (connection instanceof HttpURLConnection) {
53 HttpURLConnection http = (HttpURLConnection) connection;
65 for (Map.Entry<String, List<String>> header : connection
77 && connection instanceof HttpURLConnection) {
80 connection.setRequestProperty(key, header.getValue());
89 ((HttpURLConnection) connection)
92 connection.setDoOutput(true)
[all...] |
| /external/replicaisland/src/com/replica/replicaisland/ |
| EventReporter.java | 82 HttpURLConnection connection = null; local
95 connection = null;
97 //Set up the initial connection
98 connection = (HttpURLConnection)serverAddress.openConnection();
100 connection.setRequestMethod("GET");
101 connection.setDoOutput(true);
102 connection.setReadTimeout(0);
104 connection.connect();
105 final int response = connection.getResponseCode();
106 DebugLog.d("Report Event", event.eventType + " " + response + ":" + connection.getURL().toString())
[all...] |
