c3p0 0.10.1 · com.mchange.v2.resourcepool.BasicResourcePool

Modifier and Type	Class and Description
pack-priv class	BasicResourcePool.AsyncTestIdleResourceTask
pack-priv class	BasicResourcePool.CheckIdleResourcesTask
pack-priv class	BasicResourcePool.CullTask
pack-priv static class	BasicResourcePool.PunchCard
pack-priv class	BasicResourcePool.RemoveTask
pack-priv class	BasicResourcePool.ScatteredAcquireTask

Field Summary

Modifier and Type	Field and Description
pack-priv final int	acq_attempt_delay
pack-priv HashSet<E>	acquireWaiters
pack-priv final RunnableQueue	asyncEventQueue
pack-priv static final int	AUTO_CULL_FREQUENCY_DIVISOR
pack-priv static final int	AUTO_MAX_CULL_FREQUENCY
pack-priv static final int	AUTO_MIN_CULL_FREQUENCY
pack-priv final boolean	break_on_acquisition_failure
pack-priv boolean	broken
pack-priv final long	check_idle_resources_delay
pack-priv Timer	cullAndIdleRefurbishTimer
pack-priv TimerTask	cullTask
pack-priv final boolean	debug_store_checkout_exceptions
private static final int	DECREMENT_ON_SUCCESS
private static final int	DECREMENT_WITH_CERTAINTY
pack-priv final long	destroy_unreturned_resc_time
pack-priv Object	exampleResource
pack-priv final long	excess_max_idle_time
pack-priv HashSet<E>	excluded
pack-priv final long	expiration_enforcement_delay
pack-priv final BasicResourcePoolFactory	factory
pack-priv long	failed_checkins
pack-priv long	failed_checkouts
pack-priv long	failed_idle_tests
pack-priv boolean	force_kill_acquires
pack-priv final boolean	force_synchronous_checkins
pack-priv Map<K, V>	formerResources
pack-priv Set<E>	idleCheckResources
pack-priv TimerTask	idleRefurbishTask
pack-priv final int	inc
pack-priv Throwable	lastAcquisitionFailiure
pack-priv Throwable	lastCheckinFailure
pack-priv Throwable	lastCheckoutFailure
pack-priv Throwable	lastIdleTestFailure
pack-priv Throwable	lastResourceTestFailure
private static final MLogger	logger
pack-priv HashMap<K, V>	managed
pack-priv final int	max
pack-priv final long	max_idle_time
pack-priv final long	max_resource_age
pack-priv final ResourcePool.Manager	mgr
pack-priv final int	min
private static final int	NO_DECREMENT
pack-priv final int	num_acq_attempts
pack-priv HashSet<E>	otherWaiters
pack-priv int	pending_acquires
pack-priv int	pending_removes
pack-priv final long	pool_start_time
pack-priv final ResourcePoolEventSupport	rpes
pack-priv final int	start
pack-priv int	target_pool_size
pack-priv final AsynchronousRunner	taskRunner
pack-priv LinkedList<E>	unused

Access	Constructor and Description
public	BasicResourcePool(ResourcePool.Manager mgr, int start, int min, int max, int inc, int num_acq_attempts, int acq_attempt_delay, long check_idle_resources_delay, long max_resource_age, long max_idle_time, long excess_max_idle_time, long destroy_unreturned_resc_time, long expiration_enforcement_delay, boolean break_on_acquisition_failure, boolean debug_store_checkout_exceptions, boolean force_synchronous_checkins, AsynchronousRunner taskRunner, RunnableQueue asyncEventQueue, Timer cullAndIdleRefurbishTimer, BasicResourcePoolFactory may be null factory)

Method Summary

Modifier and Type	Method and Description
private void	_decrementPendingAcquires()
private void	_markBroken(Object resc)
private void	_recheckResizePool()
public void	addResourcePoolListener(ResourcePoolListener rpl)
private void	addToFormerResources(Object resc)
private void	assimilateResource(Object resc)
private void	asyncFireResourceAcquired(final Object resc, final int pool_size, final int available_size, final int removed_but_unreturned_size)
private void	asyncFireResourceCheckedIn(final Object resc, final int pool_size, final int available_size, final int removed_but_unreturned_size)
private void	asyncFireResourceCheckedOut(final Object resc, final int pool_size, final int available_size, final int removed_but_unreturned_size)
private void	asyncFireResourceRemoved(final Object resc, final boolean checked_out_resource, final int pool_size, final int available_size, final int removed_but_unreturned_size)
private boolean	attemptRefurbishResourceOnCheckin(Object resc)
private boolean	attemptRefurbishResourceOnCheckout(Object resc)
private long	automaticExpirationEnforcementDelay()
private void	awaitAvailable(long timeout)
private boolean	canFireEvents()
private void	checkIdleResources()
public void	checkinAll() Implements com.mchange.v2.resourcepool.ResourcePool.checkinAll.
public void	checkinResource(Object resc) Implements com.mchange.v2.resourcepool.ResourcePool.checkinResource.
public Object	checkoutResource() Implements com.mchange.v2.resourcepool.ResourcePool.checkoutResource.
public Object	checkoutResource(long timeout) Implements com.mchange.v2.resourcepool.ResourcePool.checkoutResource.
private final HashSet<E>	cloneOfExcluded()
private final HashMap<K, V>	cloneOfManaged()
private final LinkedList<E>	cloneOfUnused()
public synchronized void	close() Implements com.mchange.v2.resourcepool.ResourcePool.close. forces the release of any resources that might be associated with this object.
public synchronized void	close(boolean close_checked_out_resources) Implements com.mchange.v2.resourcepool.ResourcePool.close.
private void	cullExpired()
private synchronized void	decrementPendingAcquires()
private synchronized void	decrementPendingRemoves()
private void	destroyResource(final Object resc)
private void	destroyResource(final Object resc, boolean synchronous)
private void	destroyResource(final Object resc, boolean synchronous, final boolean checked_out)
private void	doAcquire()
private void	doAcquire(int decrement_policy)
private void	doAcquireAndDecrementPendingAcquiresWithinLockAlways()
private void	doAcquireAndDecrementPendingAcquiresWithinLockOnSuccess()
private void	doCheckinExcluded(Object resc)
private void	doCheckinManaged(final Object resc)
private void	ensureMinResources()
private void	ensureNotBroken()
private void	ensureStartResources()
private void	excludeResource(Object resc)
private void	expandPool(int count)
public void	finalize() Overrides java.lang.Object.finalize. Called by the garbage collector on an object when garbage collection determines that there are no more references to the object.
private synchronized void	forceKillAcquires()
public synchronized int	getAvailableCount() Implements com.mchange.v2.resourcepool.ResourcePool.getAvailableCount.
public synchronized int	getAwaitingCheckinCount() Implements com.mchange.v2.resourcepool.ResourcePool.getAwaitingCheckinCount.
public synchronized int	getAwaitingCheckinNotExcludedCount() Implements com.mchange.v2.resourcepool.ResourcePool.getAwaitingCheckinNotExcludedCount.
public long	getEffectiveExpirationEnforcementDelay() Implements com.mchange.v2.resourcepool.ResourcePool.getEffectiveExpirationEnforcementDelay.
public synchronized int	getExcludedCount() Implements com.mchange.v2.resourcepool.ResourcePool.getExcludedCount.
public synchronized Throwable	getLastAcquisitionFailure() Implements com.mchange.v2.resourcepool.ResourcePool.getLastAcquisitionFailure.
public synchronized Throwable	getLastCheckinFailure() Implements com.mchange.v2.resourcepool.ResourcePool.getLastCheckinFailure.
public synchronized Throwable	getLastCheckoutFailure() Implements com.mchange.v2.resourcepool.ResourcePool.getLastCheckoutFailure.
public synchronized Throwable	getLastIdleCheckFailure() Implements com.mchange.v2.resourcepool.ResourcePool.getLastIdleCheckFailure.
public synchronized Throwable	getLastResourceTestFailure() Implements com.mchange.v2.resourcepool.ResourcePool.getLastResourceTestFailure.
public int	getMaxPoolSize() Implements com.mchange.v2.resourcepool.ResourcePool.getMaxPoolSize.
public int	getMinPoolSize() Implements com.mchange.v2.resourcepool.ResourcePool.getMinPoolSize.
public synchronized int	getNumCheckoutWaiters() Implements com.mchange.v2.resourcepool.ResourcePool.getNumCheckoutWaiters.
public synchronized long	getNumFailedCheckins() Implements com.mchange.v2.resourcepool.ResourcePool.getNumFailedCheckins.
public synchronized long	getNumFailedCheckouts() Implements com.mchange.v2.resourcepool.ResourcePool.getNumFailedCheckouts.
public synchronized long	getNumFailedIdleTests() Implements com.mchange.v2.resourcepool.ResourcePool.getNumFailedIdleTests.
public synchronized int	getNumPendingAcquireTasks()
public synchronized int	getNumPendingRemoveTasks()
public synchronized int	getNumThreadsWaitingForAdministrativeTasks()
public synchronized int	getNumThreadsWaitingForResources()
public synchronized int	getPoolSize() Implements com.mchange.v2.resourcepool.ResourcePool.getPoolSize.
public long	getStartTime() Implements com.mchange.v2.resourcepool.ResourcePool.getStartTime.
public synchronized String[]	getThreadNamesWaitingForAdministrativeTasks()
public synchronized String[]	getThreadNamesWaitingForResources()
public long	getUpTime() Implements com.mchange.v2.resourcepool.ResourcePool.getUpTime.
private synchronized void	incrementPendingAcquires()
private synchronized void	incrementPendingRemoves()
private synchronized boolean	isBroken()
private synchronized boolean	isForceKillAcquiresPending()
private boolean	isFormerResource(Object resc)
public synchronized void	markBroken(Object resc) Implements com.mchange.v2.resourcepool.ResourcePool.markBroken. Marks a resource as broken.
private void	markBrokenNoEnsureMinResources(Object resc)
private long	minExpirationTime()
private boolean	mustEnforceExpiration()
private boolean	mustTestIdleResources()
private synchronized Object	prelimCheckoutResource(long timeout)
private synchronized void	recheckResizePool()
private void	removeResource(Object resc)
private void	removeResource(Object resc, boolean synchronous)
public void	removeResourcePoolListener(ResourcePoolListener rpl)
private void	removeTowards(int new_sz)
public synchronized void	resetPool() Implements com.mchange.v2.resourcepool.ResourcePool.resetPool. Discards all resources managed by the pool and reacquires new resources to populate the pool.
private synchronized void	setLastAcquisitionFailure(Throwable t)
private void	setLastCheckinFailure(Throwable t)
private void	setLastCheckoutFailure(Throwable t)
private void	setLastIdleCheckFailure(Throwable t)
public synchronized void	setPoolSize(int sz) Implements com.mchange.v2.resourcepool.ResourcePool.setPoolSize.
public synchronized void	setTargetPoolSize(int sz)
private boolean	shouldExpire(Object resc)
private void	shrinkPool(int count)
public synchronized int	statusInPool(Object resc) Implements com.mchange.v2.resourcepool.ResourcePool.statusInPool.
private boolean	supportsEvents()
private void	synchronousRemoveArbitraryResource()
private synchronized void	syncTrace()
private void	trace()
private synchronized void	unexpectedBreak()

Inherited from java.lang.Object:: clone equals getClass hashCode notify notifyAll toString wait wait wait

pack-priv Class BasicResourcePool

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary