Package org.eclipse.jetty.client
Class LeakTrackingConnectionPool
- java.lang.Object
-
- org.eclipse.jetty.client.AbstractConnectionPool
-
- org.eclipse.jetty.client.DuplexConnectionPool
-
- org.eclipse.jetty.client.LeakTrackingConnectionPool
-
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
,ConnectionPool
,Dumpable
,Sweeper.Sweepable
public class LeakTrackingConnectionPool extends DuplexConnectionPool
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.eclipse.jetty.client.ConnectionPool
ConnectionPool.Factory, ConnectionPool.Multiplexable
-
Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.Dumpable
Dumpable.DumpableContainer
-
-
Field Summary
Fields Modifier and Type Field Description private LeakDetector<Connection>
leakDetector
private static Logger
LOG
-
Constructor Summary
Constructors Constructor Description LeakTrackingConnectionPool(Destination destination, int maxConnections, Callback requester)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
acquired(Connection connection)
void
close()
Closes this ConnectionPool.protected void
leaked(LeakDetector.LeakInfo leakInfo)
protected void
released(Connection connection)
private void
start()
private void
stop()
-
Methods inherited from class org.eclipse.jetty.client.DuplexConnectionPool
activate, deactivate, dump, dump, getActiveConnectionCount, getActiveConnections, getIdleConnectionCount, getIdleConnections, isActive, lock, onCreated, release, remove, remove, sweep, toString, unlock
-
Methods inherited from class org.eclipse.jetty.client.AbstractConnectionPool
acquire, acquire, active, close, dump, getConnectionCount, getHttpDestination, getMaxConnectionCount, getPendingConnectionCount, getPendingCount, idle, isClosed, isEmpty, proceed, removed, tryCreate
-
-
-
-
Field Detail
-
LOG
private static final Logger LOG
-
leakDetector
private final LeakDetector<Connection> leakDetector
-
-
Constructor Detail
-
LeakTrackingConnectionPool
public LeakTrackingConnectionPool(Destination destination, int maxConnections, Callback requester)
-
-
Method Detail
-
start
private void start()
-
close
public void close()
Description copied from interface:ConnectionPool
Closes this ConnectionPool.- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfacejava.io.Closeable
- Specified by:
close
in interfaceConnectionPool
- Overrides:
close
in classDuplexConnectionPool
- See Also:
ConnectionPool.isClosed()
-
stop
private void stop()
-
acquired
protected void acquired(Connection connection)
- Overrides:
acquired
in classAbstractConnectionPool
-
released
protected void released(Connection connection)
- Overrides:
released
in classAbstractConnectionPool
-
leaked
protected void leaked(LeakDetector.LeakInfo leakInfo)
-
-