org.apache.geronimo.connector.outbound

Class AbstractSinglePoolConnectionInterceptor

java.lang.Object

org.apache.geronimo.connector.outbound.AbstractSinglePoolConnectionInterceptor

All Implemented Interfaces:

ConnectionInterceptor, PoolingAttributes

Direct Known Subclasses:

SinglePoolConnectionInterceptor, SinglePoolMatchAllConnectionInterceptor

public abstract class AbstractSinglePoolConnectionInterceptor
extends Object
implements ConnectionInterceptor, PoolingAttributes

Version:

$Rev$ $Date$

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	AbstractSinglePoolConnectionInterceptor.FillTask

Field Summary

Fields

Modifier and Type	Field and Description
protected int	blockingTimeoutMilliseconds
protected int	connectionCount
protected boolean	destroyed
protected long	idleTimeoutMilliseconds
protected static org.slf4j.Logger	log
protected int	maxSize
protected int	minSize
protected ConnectionInterceptor	next
protected Semaphore	permits
protected int	shrinkLater
protected Timer	timer

Constructor Summary

Constructors

Constructor and Description
AbstractSinglePoolConnectionInterceptor(ConnectionInterceptor next, int maxSize, int minSize, int blockingTimeoutMilliseconds, int idleTimeoutMinutes)

Method Summary

Modifier and Type	Method and Description
protected boolean	addToPool(ManagedConnectionInfo mci)
void	destroy()
protected abstract void	doAdd(ManagedConnectionInfo mci)
protected abstract boolean	doRemove(ManagedConnectionInfo mci)
int	getBlockingTimeoutMilliseconds()
void	getConnection(ConnectionInfo connectionInfo)
int	getConnectionCount()
protected abstract void	getExpiredManagedConnectionInfos(long threshold, List<ManagedConnectionInfo> killList)
abstract int	getIdleConnectionCount()
int	getIdleTimeoutMinutes()
int	getPartitionCount()
int	getPartitionMaxSize()
int	getPartitionMinSize()
protected abstract Object	getPool()
protected abstract void	internalDestroy()
protected abstract void	internalGetConnection(ConnectionInfo connectionInfo)
protected boolean	internalReturn(ConnectionInfo connectionInfo, ConnectionReturnAction connectionReturnAction)
void	returnConnection(ConnectionInfo connectionInfo, ConnectionReturnAction connectionReturnAction)
void	setBlockingTimeoutMilliseconds(int blockingTimeoutMilliseconds)
void	setIdleTimeoutMinutes(int idleTimeoutMinutes)
void	setPartitionMaxSize(int newMaxSize)
void	setPartitionMinSize(int minSize)
protected abstract void	transferConnections(int maxSize, int shrinkNow)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.geronimo.connector.outbound.ConnectionInterceptor

info

Field Detail

log

protected static org.slf4j.Logger log

next

protected final ConnectionInterceptor next

permits

protected Semaphore permits

blockingTimeoutMilliseconds

protected int blockingTimeoutMilliseconds

connectionCount

protected int connectionCount

idleTimeoutMilliseconds

protected long idleTimeoutMilliseconds

timer

protected Timer timer

maxSize

protected int maxSize

minSize

protected int minSize

shrinkLater

protected int shrinkLater

destroyed

protected volatile boolean destroyed

Constructor Detail

AbstractSinglePoolConnectionInterceptor

public AbstractSinglePoolConnectionInterceptor(ConnectionInterceptor next,
                                               int maxSize,
                                               int minSize,
                                               int blockingTimeoutMilliseconds,
                                               int idleTimeoutMinutes)

Method Detail

getConnection

public void getConnection(ConnectionInfo connectionInfo)
                   throws javax.resource.ResourceException

Specified by:

getConnection in interface ConnectionInterceptor

Throws:

javax.resource.ResourceException

internalGetConnection

protected abstract void internalGetConnection(ConnectionInfo connectionInfo)
                                       throws javax.resource.ResourceException

Throws:

javax.resource.ResourceException

returnConnection

public void returnConnection(ConnectionInfo connectionInfo,
                             ConnectionReturnAction connectionReturnAction)

Specified by:

returnConnection in interface ConnectionInterceptor

internalReturn

protected boolean internalReturn(ConnectionInfo connectionInfo,
                                 ConnectionReturnAction connectionReturnAction)

Parameters:

connectionInfo - connection info to return to pool

connectionReturnAction - whether to return to pool or destroy

Returns:

true if a connection for which a permit was issued was returned (so the permit should be released), false if no permit was issued (for instance if the connection was already in the pool and we are destroying it).

internalDestroy

protected abstract void internalDestroy()

destroy

public void destroy()

Specified by:

destroy in interface ConnectionInterceptor

getPartitionCount

public int getPartitionCount()

Specified by:

getPartitionCount in interface PoolingAttributes

getPartitionMaxSize

public int getPartitionMaxSize()

Specified by:

getPartitionMaxSize in interface PoolingAttributes

setPartitionMaxSize

public void setPartitionMaxSize(int newMaxSize)
                         throws InterruptedException

Specified by:

setPartitionMaxSize in interface PoolingAttributes

Throws:

InterruptedException

doRemove

protected abstract boolean doRemove(ManagedConnectionInfo mci)

doAdd

protected abstract void doAdd(ManagedConnectionInfo mci)

getPool

protected abstract Object getPool()

transferConnections

protected abstract void transferConnections(int maxSize,
                                            int shrinkNow)

getIdleConnectionCount

public abstract int getIdleConnectionCount()

Specified by:

getIdleConnectionCount in interface PoolingAttributes

getConnectionCount

public int getConnectionCount()

Specified by:

getConnectionCount in interface PoolingAttributes

getPartitionMinSize

public int getPartitionMinSize()

Specified by:

getPartitionMinSize in interface PoolingAttributes

setPartitionMinSize

public void setPartitionMinSize(int minSize)

Specified by:

setPartitionMinSize in interface PoolingAttributes

getBlockingTimeoutMilliseconds

public int getBlockingTimeoutMilliseconds()

Specified by:

getBlockingTimeoutMilliseconds in interface PoolingAttributes

setBlockingTimeoutMilliseconds

public void setBlockingTimeoutMilliseconds(int blockingTimeoutMilliseconds)

Specified by:

setBlockingTimeoutMilliseconds in interface PoolingAttributes

getIdleTimeoutMinutes

public int getIdleTimeoutMinutes()

Specified by:

getIdleTimeoutMinutes in interface PoolingAttributes

setIdleTimeoutMinutes

public void setIdleTimeoutMinutes(int idleTimeoutMinutes)

Specified by:

setIdleTimeoutMinutes in interface PoolingAttributes

getExpiredManagedConnectionInfos

protected abstract void getExpiredManagedConnectionInfos(long threshold,
                                                         List<ManagedConnectionInfo> killList)

addToPool

protected boolean addToPool(ManagedConnectionInfo mci)