| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
| D | ConnectionPoolTest.java | 48 ConnectionPool pool = new ConnectionPool(Integer.MAX_VALUE, 100L, TimeUnit.NANOSECONDS); in connectionsEvictedWhenIdleLongEnough()
80 ConnectionPool pool = new ConnectionPool(Integer.MAX_VALUE, 100L, TimeUnit.NANOSECONDS); in inUseConnectionsNotEvicted()
104 ConnectionPool pool = new ConnectionPool(Integer.MAX_VALUE, 100L, TimeUnit.NANOSECONDS); in cleanupPrioritizesEarliestEviction()
136 ConnectionPool pool = new ConnectionPool(2, 100L, TimeUnit.NANOSECONDS); in oldestConnectionsEvictedIfIdleLimitExceeded()
160 ConnectionPool pool = new ConnectionPool(2, 100L, TimeUnit.NANOSECONDS); in leakedAllocation()
174 private void allocateAndLeakAllocation(ConnectionPool pool, RealConnection connection) { in allocateAndLeakAllocation()
190 private RealConnection newConnection(ConnectionPool pool, Route route, long idleAtNanos) { in newConnection()
|
| D | ConnectionReuseTest.java | 104 client.setConnectionPool(new ConnectionPool(0, 5000)); in connectionsAreNotReusedIfPoolIsSizeZero()
115 client.setConnectionPool(new ConnectionPool(0, 5000)); in connectionsReusedWithRedirectEvenIfPoolIsSizeZero()
132 client.setConnectionPool(new ConnectionPool(0, 5000)); in connectionsNotReusedWithRedirectIfDiscardingResponseIsSlow()
209 client.setConnectionPool(new ConnectionPool(5, 250, TimeUnit.MILLISECONDS)); in connectionsAreEvicted()
|
| D | CacheTest.java | 1024 ConnectionPool pool = ConnectionPool.getDefault(); in conditionalCacheHitIsNotDoublePooled()
|
| D | URLConnectionTest.java | 1302 ConnectionPool pool = ConnectionPool.getDefault(); in endOfStreamResponseIsNotPooled()
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
| D | ConnectionPool.java | 58 public final class ConnectionPool { class
61 private static final ConnectionPool systemDefault;
71 systemDefault = new ConnectionPool(0, keepAliveDurationMs);
73 systemDefault = new ConnectionPool(Integer.parseInt(maxIdleConnections), keepAliveDurationMs);
75 systemDefault = new ConnectionPool(5, keepAliveDurationMs);
99 synchronized (ConnectionPool.this) {
101 ConnectionPool.this.wait(waitMillis, (int) waitNanos);
113 public ConnectionPool(int maxIdleConnections, long keepAliveDurationMs) { in ConnectionPool() method in ConnectionPool
117 public ConnectionPool(int maxIdleConnections, long keepAliveDuration, TimeUnit timeUnit) { in ConnectionPool() method in ConnectionPool
127 public static ConnectionPool getDefault() { in getDefault()
|
| D | OkHttpClient.java | 79 ConnectionPool pool, RealConnection connection) {
84 ConnectionPool pool, Address address, StreamAllocation streamAllocation) {
88 @Override public void put(ConnectionPool pool, RealConnection connection) {
92 @Override public RouteDatabase routeDatabase(ConnectionPool connectionPool) {
139 private ConnectionPool connectionPool;
405 public OkHttpClient setConnectionPool(ConnectionPool connectionPool) { in setConnectionPool()
410 public ConnectionPool getConnectionPool() { in getConnectionPool()
603 result.connectionPool = ConnectionPool.getDefault(); in copyWithDefaults()
|
| /external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/ |
| D | ConnectionPool.java | 60 public final class ConnectionPool { class
64 private static final ConnectionPool systemDefault;
74 systemDefault = new ConnectionPool(0, keepAliveDurationMs);
76 systemDefault = new ConnectionPool(Integer.parseInt(maxIdleConnections), keepAliveDurationMs);
78 systemDefault = new ConnectionPool(5, keepAliveDurationMs);
104 synchronized (ConnectionPool.this) {
106 ConnectionPool.this.wait(waitMillis, (int) waitNanos);
119 public ConnectionPool(int maxIdleConnections, long keepAliveDurationMs) { in ConnectionPool() method in ConnectionPool
123 public ConnectionPool(int maxIdleConnections, long keepAliveDuration, TimeUnit timeUnit) { in ConnectionPool() method in ConnectionPool
133 public static ConnectionPool getDefault() { in getDefault()
|
| D | OkHttpClient.java | 82 ConnectionPool pool, RealConnection connection) {
87 ConnectionPool pool, Address address, StreamAllocation streamAllocation) {
91 @Override public void put(ConnectionPool pool, RealConnection connection) {
95 @Override public RouteDatabase routeDatabase(ConnectionPool connectionPool) {
143 private ConnectionPool connectionPool;
416 public OkHttpClient setConnectionPool(ConnectionPool connectionPool) { in setConnectionPool()
422 public ConnectionPool getConnectionPool() { in getConnectionPool()
617 result.connectionPool = ConnectionPool.getDefault(); in copyWithDefaults()
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/ |
| D | Internal.java | 21 import com.squareup.okhttp.ConnectionPool;
57 ConnectionPool pool, Address address, StreamAllocation streamAllocation); in get()
59 public abstract void put(ConnectionPool pool, RealConnection connection); in put()
61 public abstract boolean connectionBecameIdle(ConnectionPool pool, RealConnection connection); in connectionBecameIdle()
63 public abstract RouteDatabase routeDatabase(ConnectionPool connectionPool); in routeDatabase()
|
| /external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/ |
| D | Internal.java | 22 import com.android.okhttp.ConnectionPool;
69 ConnectionPool pool, Address address, StreamAllocation streamAllocation); in get()
72 public abstract void put(ConnectionPool pool, RealConnection connection); in put()
75 public abstract boolean connectionBecameIdle(ConnectionPool pool, RealConnection connection); in connectionBecameIdle()
78 public abstract RouteDatabase routeDatabase(ConnectionPool connectionPool); in routeDatabase()
|
| /external/okhttp/repackaged/android/src/main/java/com/android/okhttp/ |
| D | ConfigAwareConnectionPool.java | 62 private ConnectionPool connectionPool;
80 public synchronized ConnectionPool get() { in get()
97 connectionPool = new ConnectionPool( in get()
|
| /external/okhttp/android/src/main/java/com/squareup/okhttp/ |
| D | ConfigAwareConnectionPool.java | 60 private ConnectionPool connectionPool;
78 public synchronized ConnectionPool get() { in get()
95 connectionPool = new ConnectionPool( in get()
|
| /external/okhttp/repackaged/android/src/main/java/com/android/okhttp/internalandroidapi/ |
| D | HttpURLConnectionFactory.java | 20 import com.android.okhttp.ConnectionPool;
58 private ConnectionPool connectionPool;
73 this.connectionPool = new ConnectionPool(maxIdleConnections, keepAliveDuration, timeUnit); in setNewConnectionPool()
|
| /external/okhttp/android/src/main/java/com/android/okhttp/internalandroidapi/ |
| D | HttpURLConnectionFactory.java | 19 import com.squareup.okhttp.ConnectionPool;
56 private ConnectionPool connectionPool;
71 this.connectionPool = new ConnectionPool(maxIdleConnections, keepAliveDuration, timeUnit); in setNewConnectionPool()
|
| /external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/http/ |
| D | StreamAllocation.java | 20 import com.android.okhttp.ConnectionPool;
79 private final ConnectionPool connectionPool;
88 public StreamAllocation(ConnectionPool connectionPool, Address address) { in StreamAllocation()
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/http/ |
| D | StreamAllocation.java | 19 import com.squareup.okhttp.ConnectionPool;
77 private final ConnectionPool connectionPool;
86 public StreamAllocation(ConnectionPool connectionPool, Address address) { in StreamAllocation()
|
| /external/autotest/server/hosts/ |
| D | ssh_multiplex_unittest.py | 17 p = ssh_multiplex.ConnectionPool()
|
| D | ssh_multiplex.py | 139 class ConnectionPool(object): class
|
| /external/okhttp/android/src/test/java/com/squareup/okhttp/ |
| D | ConfigAwareConnectionPoolTest.java | 43 ConnectionPool beforeEventInstance = instance.get(); in get()
|
| /external/okhttp/ |
| D | README.android | 13 ConnectionPool that listens for network configuration changes.
|
| /external/okhttp/okcurl/src/main/java/com/squareup/okhttp/curl/ |
| D | Main.java | 19 import com.squareup.okhttp.ConnectionPool;
186 client.setConnectionPool(ConnectionPool.getDefault()); in createClient()
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/ |
| D | HttpOverSpdyTest.java | 19 import com.squareup.okhttp.ConnectionPool;
398 ConnectionPool connectionPool = new ConnectionPool(5, 5000); in disconnectWithStreamNotEstablished()
|
| /external/okhttp/okhttp-urlconnection/src/test/java/com/squareup/okhttp/ |
| D | UrlConnectionCacheTest.java | 852 ConnectionPool pool = ConnectionPool.getDefault(); in conditionalCacheHitIsNotDoublePooled()
|
| /external/autotest/server/ |
| D | server_job.py | 376 self._connection_pool = ssh_multiplex.ConnectionPool()
|