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.nio.conn;
28
29 import java.io.IOException;
30 import java.util.Date;
31 import java.util.concurrent.TimeUnit;
32
33 import org.apache.commons.logging.Log;
34 import org.apache.http.annotation.Contract;
35 import org.apache.http.annotation.ThreadingBehavior;
36 import org.apache.http.conn.routing.HttpRoute;
37 import org.apache.http.nio.conn.ManagedNHttpClientConnection;
38 import org.apache.http.pool.PoolEntry;
39
40 @Contract(threading = ThreadingBehavior.SAFE)
41 class CPoolEntry extends PoolEntry<HttpRoute, ManagedNHttpClientConnection> {
42
43 private final Log log;
44 private volatile int socketTimeout;
45 private volatile boolean routeComplete;
46
47 public CPoolEntry(
48 final Log log,
49 final String id,
50 final HttpRoute route,
51 final ManagedNHttpClientConnection conn,
52 final long timeToLive, final TimeUnit timeUnit) {
53 super(id, route, conn, timeToLive, timeUnit);
54 this.log = log;
55 }
56
57 public boolean isRouteComplete() {
58 return this.routeComplete;
59 }
60
61 public void markRouteComplete() {
62 this.routeComplete = true;
63 }
64
65 public int getSocketTimeout() {
66 return this.socketTimeout;
67 }
68
69 public void setSocketTimeout(final int socketTimeout) {
70 this.socketTimeout = socketTimeout;
71 }
72
73 public void closeConnection() throws IOException {
74 final ManagedNHttpClientConnection conn = getConnection();
75 conn.close();
76 }
77
78 public void shutdownConnection() throws IOException {
79 final ManagedNHttpClientConnection conn = getConnection();
80 conn.shutdown();
81 }
82
83 @Override
84 public boolean isExpired(final long now) {
85 final boolean expired = super.isExpired(now);
86 if (expired && this.log.isDebugEnabled()) {
87 this.log.debug("Connection " + this + " expired @ " + new Date(getExpiry()));
88 }
89 return expired;
90 }
91
92 @Override
93 public boolean isClosed() {
94 final ManagedNHttpClientConnection conn = getConnection();
95 return !conn.isOpen();
96 }
97
98 @Override
99 public void close() {
100 try {
101 closeConnection();
102 } catch (final IOException ex) {
103 this.log.debug("I/O error closing connection", ex);
104 }
105 }
106
107 }