org.eclipse.jetty.client

Class RoundRobinConnectionPool

java.lang.Object

org.eclipse.jetty.client.AbstractConnectionPool

org.eclipse.jetty.client.RoundRobinConnectionPool

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, ConnectionPool, ConnectionPool.Multiplexable, Dumpable

@ManagedObject
public class RoundRobinConnectionPool
extends AbstractConnectionPool
implements ConnectionPool.Multiplexable

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	RoundRobinConnectionPool.Entry

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

ConnectionPool.Factory, ConnectionPool.Multiplexable

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.List<RoundRobinConnectionPool.Entry>	entries
private int	index
private int	maxMultiplex

Fields inherited from interface org.eclipse.jetty.util.component.Dumpable

KEY

Constructor Summary

Constructors

Constructor and Description
RoundRobinConnectionPool(Destination destination, int maxConnections, Callback requester)
RoundRobinConnectionPool(Destination destination, int maxConnections, Callback requester, int maxMultiplex)

Method Summary

Modifier and Type	Method and Description
protected Connection	acquire(boolean create) Returns an idle connection, if available, following a round robin algorithm; otherwise it always tries to create a new connection, up until the max connection count.
protected Connection	activate()
void	dump(java.lang.Appendable out, java.lang.String indent) Dump this object (and children) into an Appendable using the provided indent after any new lines.
int	getMaxMultiplex()
boolean	isActive(Connection connection)
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.
void	setMaxMultiplex(int maxMultiplex)
java.lang.String	toString()

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

acquire, acquired, active, close, close, dump, getConnectionCount, getHttpDestination, getMaxConnectionCount, getPendingConnectionCount, 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

Methods inherited from interface org.eclipse.jetty.util.component.Dumpable

dump, dumpContainer, dumpIterable, dumpMapEntries, dumpObject, dumpObjects, dumpSelf, named

Field Detail

entries

private final java.util.List<RoundRobinConnectionPool.Entry> entries

maxMultiplex

private int maxMultiplex

index

private int index

Constructor Detail

RoundRobinConnectionPool

public RoundRobinConnectionPool(Destination destination,
                                int maxConnections,
                                Callback requester)

RoundRobinConnectionPool

public RoundRobinConnectionPool(Destination destination,
                                int maxConnections,
                                Callback requester,
                                int maxMultiplex)

Method Detail

getMaxMultiplex

public int getMaxMultiplex()

Specified by:

getMaxMultiplex in interface ConnectionPool.Multiplexable

Returns:

the max number of requests multiplexable on a single connection

setMaxMultiplex

public void setMaxMultiplex(int maxMultiplex)

Specified by:

setMaxMultiplex in interface ConnectionPool.Multiplexable

Parameters:

maxMultiplex - the max number of requests multiplexable on a single connection

acquire

protected Connection acquire(boolean create)

Returns an idle connection, if available, following a round robin algorithm; otherwise it always tries to create a new connection, up until the max connection count.

Overrides:

acquire in class AbstractConnectionPool

Parameters:

create - this parameter is ignored and assumed to be always true

Returns:

an idle connection or null if no idle connections are available

See Also:

AbstractConnectionPool.tryCreate(int)

onCreated

protected void onCreated(Connection connection)

Specified by:

onCreated in class AbstractConnectionPool

activate

protected Connection activate()

Specified by:

activate in class AbstractConnectionPool

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

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

dump

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

Description copied from interface: Dumpable

Dump this object (and children) into an Appendable using the provided indent after any new lines. The indent should not be applied to the first object dumped.

Specified by:

dump in interface Dumpable

Parameters:

out - The appendable to dump to

indent - The indent to apply after any new lines.

Throws:

java.io.IOException - if unable to write to Appendable

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object