org.eclipse.jetty.client

Class MultiplexConnectionPool

java.lang.Object

org.eclipse.jetty.client.AbstractConnectionPool

org.eclipse.jetty.client.MultiplexConnectionPool

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, ConnectionPool, Dumpable, Sweeper.Sweepable

public class MultiplexConnectionPool
extends AbstractConnectionPool
implements Sweeper.Sweepable

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	MultiplexConnectionPool.Holder

Nested classes/interfaces inherited from interface org.eclipse.jetty.client.ConnectionPool

ConnectionPool.Factory

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.Map<Connection,MultiplexConnectionPool.Holder>	busyConnections
private HttpDestination	destination
private java.util.Deque<MultiplexConnectionPool.Holder>	idleConnections
private java.util.concurrent.locks.ReentrantLock	lock
private static Logger	LOG
private int	maxMultiplex
private java.util.Map<Connection,MultiplexConnectionPool.Holder>	muxedConnections

Constructor Summary

Constructors

Constructor and Description
MultiplexConnectionPool(HttpDestination destination, int maxConnections, Callback requester, int maxMultiplex)

Method Summary

Modifier and Type	Method and Description
Connection	acquire() Returns an idle connection, if available, or schedules the opening of a new connection and returns null.
protected Connection	activate()
void	close() Closes this ConnectionPool.
void	dump(java.lang.Appendable out, java.lang.String indent)
int	getMaxMultiplex()
boolean	isActive(Connection connection)
protected void	lock()
protected void	onCreated(Connection connection)
boolean	release(Connection connection) Returns the given connection, previously obtained via ConnectionPool.acquire(), back to this ConnectionPool.
boolean	remove(Connection connection) Removes the given connection from this ConnectionPool.
protected boolean	remove(Connection connection, boolean force)
void	setMaxMultiplex(int maxMultiplex)
boolean	sweep()
java.lang.String	toString()
protected void	unlock()

Methods inherited from class org.eclipse.jetty.client.AbstractConnectionPool

acquired, active, close, dump, getConnectionCount, getMaxConnectionCount, getPendingCount, idle, isClosed, isEmpty, proceed, released, removed, tryCreate

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

LOG

private static final Logger LOG

lock

private final java.util.concurrent.locks.ReentrantLock lock

destination

private final HttpDestination destination

idleConnections

private final java.util.Deque<MultiplexConnectionPool.Holder> idleConnections

muxedConnections

private final java.util.Map<Connection,MultiplexConnectionPool.Holder> muxedConnections

busyConnections

private final java.util.Map<Connection,MultiplexConnectionPool.Holder> busyConnections

maxMultiplex

private int maxMultiplex

Constructor Detail

MultiplexConnectionPool

public MultiplexConnectionPool(HttpDestination destination,
                               int maxConnections,
                               Callback requester,
                               int maxMultiplex)

Method Detail

acquire

public Connection acquire()

Description copied from interface: ConnectionPool

Returns an idle connection, if available, or schedules the opening of a new connection and returns null.

Specified by:

acquire in interface ConnectionPool

Overrides:

acquire in class AbstractConnectionPool

Returns:

an available connection, or null

lock

protected void lock()

unlock

protected void unlock()

getMaxMultiplex

public int getMaxMultiplex()

setMaxMultiplex

public void setMaxMultiplex(int maxMultiplex)

isActive

public boolean isActive(Connection connection)

Specified by:

isActive in interface ConnectionPool

Parameters:

connection - the connection to test

Returns:

whether the given connection is currently in use

onCreated

protected void onCreated(Connection connection)

Specified by:

onCreated in class AbstractConnectionPool

activate

protected Connection activate()

Specified by:

activate in class AbstractConnectionPool

release

public boolean release(Connection connection)

Description copied from interface: ConnectionPool

Returns the given connection, previously obtained via ConnectionPool.acquire(), back to this ConnectionPool.

Specified by:

release in interface ConnectionPool

Parameters:

connection - the connection to release

Returns:

true if the connection has been released, false if the connection should be closed

remove

public boolean remove(Connection connection)

Description copied from interface: ConnectionPool

Removes the given connection from this ConnectionPool.

Specified by:

remove in interface ConnectionPool

Parameters:

connection - the connection to remove

Returns:

true if the connection was removed from this ConnectionPool

remove

protected boolean remove(Connection connection,
                         boolean force)

close

public void close()

Description copied from interface: ConnectionPool

Closes this ConnectionPool.

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface ConnectionPool

Overrides:

close in class AbstractConnectionPool

See Also:

ConnectionPool.isClosed()

dump

public void dump(java.lang.Appendable out,
                 java.lang.String indent)
          throws java.io.IOException

Specified by:

dump in interface Dumpable

Throws:

java.io.IOException

sweep

public boolean sweep()

Specified by:

sweep in interface Sweeper.Sweepable

Returns:

whether this resource should be swept

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object