You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hc.apache.org by ol...@apache.org on 2013/06/05 11:04:40 UTC
svn commit: r1489753 - in /httpcomponents/httpcore/trunk:
httpcore-nio/src/main/java/org/apache/http/nio/pool/AbstractNIOConnPool.java
httpcore/src/main/java/org/apache/http/pool/AbstractConnPool.java
Author: olegk
Date: Wed Jun 5 09:04:40 2013
New Revision: 1489753
URL: http://svn.apache.org/r1489753
Log:
HTTPCORE-341: Added methods to enumerate all available and leased connections in connection pool (fixed java 1.5 compatibility)
Modified:
httpcomponents/httpcore/trunk/httpcore-nio/src/main/java/org/apache/http/nio/pool/AbstractNIOConnPool.java
httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/pool/AbstractConnPool.java
Modified: httpcomponents/httpcore/trunk/httpcore-nio/src/main/java/org/apache/http/nio/pool/AbstractNIOConnPool.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpcore/trunk/httpcore-nio/src/main/java/org/apache/http/nio/pool/AbstractNIOConnPool.java?rev=1489753&r1=1489752&r2=1489753&view=diff
==============================================================================
--- httpcomponents/httpcore/trunk/httpcore-nio/src/main/java/org/apache/http/nio/pool/AbstractNIOConnPool.java (original)
+++ httpcomponents/httpcore/trunk/httpcore-nio/src/main/java/org/apache/http/nio/pool/AbstractNIOConnPool.java Wed Jun 5 09:04:40 2013
@@ -646,7 +646,6 @@ public abstract class AbstractNIOConnPoo
final long deadline = System.currentTimeMillis() - time;
enumAvailable(new PoolEntryCallback<T, C>() {
- @Override
public void process(final PoolEntry<T, C> entry) {
if (entry.getUpdated() <= deadline) {
entry.close();
@@ -660,7 +659,6 @@ public abstract class AbstractNIOConnPoo
final long now = System.currentTimeMillis();
enumAvailable(new PoolEntryCallback<T, C>() {
- @Override
public void process(final PoolEntry<T, C> entry) {
if (entry.isExpired(now)) {
entry.close();
Modified: httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/pool/AbstractConnPool.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/pool/AbstractConnPool.java?rev=1489753&r1=1489752&r2=1489753&view=diff
==============================================================================
--- httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/pool/AbstractConnPool.java (original)
+++ httpcomponents/httpcore/trunk/httpcore/src/main/java/org/apache/http/pool/AbstractConnPool.java Wed Jun 5 09:04:40 2013
@@ -468,7 +468,6 @@ public abstract class AbstractConnPool<T
final long deadline = System.currentTimeMillis() - time;
enumAvailable(new PoolEntryCallback<T, C>() {
- @Override
public void process(final PoolEntry<T, C> entry) {
if (entry.getUpdated() <= deadline) {
entry.close();
@@ -485,7 +484,6 @@ public abstract class AbstractConnPool<T
final long now = System.currentTimeMillis();
enumAvailable(new PoolEntryCallback<T, C>() {
- @Override
public void process(final PoolEntry<T, C> entry) {
if (entry.isExpired(now)) {
entry.close();