1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27 package org.apache.http.impl.conn;
28
29 import java.util.concurrent.TimeUnit;
30 import java.util.concurrent.atomic.AtomicLong;
31
32 import org.apache.commons.logging.Log;
33 import org.apache.commons.logging.LogFactory;
34 import org.apache.http.annotation.ThreadSafe;
35 import org.apache.http.conn.ManagedHttpClientConnection;
36 import org.apache.http.conn.routing.HttpRoute;
37 import org.apache.http.pool.AbstractConnPool;
38 import org.apache.http.pool.ConnFactory;
39
40
41
42
43 @ThreadSafe
44 class CPool extends AbstractConnPool<HttpRoute, ManagedHttpClientConnection, CPoolEntry> {
45
46 private static AtomicLong COUNTER = new AtomicLong();
47
48 private final Log log = LogFactory.getLog(CPool.class);
49 private final long timeToLive;
50 private final TimeUnit tunit;
51
52 public CPool(
53 final ConnFactory<HttpRoute, ManagedHttpClientConnection> connFactory,
54 final int defaultMaxPerRoute, final int maxTotal,
55 final long timeToLive, final TimeUnit tunit) {
56 super(connFactory, defaultMaxPerRoute, maxTotal);
57 this.timeToLive = timeToLive;
58 this.tunit = tunit;
59 }
60
61 @Override
62 protected CPoolEntry createEntry(final HttpRoute route, final ManagedHttpClientConnection conn) {
63 final String id = Long.toString(COUNTER.getAndIncrement());
64 return new CPoolEntry(this.log, id, route, conn, this.timeToLive, this.tunit);
65 }
66
67 }