weblogic.jdbc.common.internal

Class HAConnectionPool

java.lang.Object

weblogic.common.resourcepool.ResourcePoolImpl

weblogic.jdbc.common.internal.ConnectionPool

weblogic.jdbc.common.internal.HAConnectionPool

All Implemented Interfaces:

weblogic.common.resourcepool.ObjectLifeCycle, weblogic.common.resourcepool.ReserveReleaseInterceptor, weblogic.common.resourcepool.ResourcePool, weblogic.common.resourcepool.ResourcePoolMaintainer, HAJDBCConnectionPool, JDBCConnectionPool, OraclePool, weblogic.jdbc.common.rac.RACModulePool

public class HAConnectionPool
extends ConnectionPool
implements weblogic.jdbc.common.rac.RACModulePool, HAJDBCConnectionPool

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	HAConnectionPool.HAConnectionStoreDelegate

Nested classes/interfaces inherited from class weblogic.jdbc.common.internal.ConnectionPool

ConnectionPool.ConnectionStore, ConnectionPool.ConnectionStoreDelegate

Nested classes/interfaces inherited from class weblogic.common.resourcepool.ResourcePoolImpl

weblogic.common.resourcepool.ResourcePoolImpl.Group

Field Summary

Fields

Modifier and Type	Field and Description
private java.lang.String	affinityContextKey
private ConnectionAffinityCallback.AffinityPolicy	affinityPolicy
private boolean	autoOns
private java.lang.String	databaseName
(package private) static int	DRAININTERVAL
private DataSourceServiceImpl	dsService
private boolean	fanEnabled
private java.util.concurrent.atomic.AtomicInteger	gravitationShrinkTime
private java.util.Map<HAJDBCConnectionPool,HADataSourceRuntime>	haDataSourceRuntimes
private boolean	isxa
private java.lang.String	loggedServiceName
(package private) static int	MAXDRAIN
private weblogic.jdbc.common.rac.RACAffinityContextHelper	racAffinityContextHelper
private weblogic.jdbc.common.rac.RACModule	racModule
private int	rlbThreshold
private java.lang.String	serviceName
private AffinityCallback	sessionAffinityCallback
private TransactionManager	tm
private AffinityCallback	xaAffinityCallback

Fields inherited from class weblogic.jdbc.common.internal.ConnectionPool

classLoader, clearDBMSIdentityMethod, clientInfo, commitOutcomeRetryTotalCount, config, connectionHarvestMaxCount, connectionHarvestTriggerCount, connections, CP_PROP_CACHE_SIZE, CP_PROP_CACHE_TYPE, CP_PROP_DBG_LVL, CP_PROP_DRIVER, CP_PROP_FATAL_ERROR_CODES, CP_PROP_INIT_NAME, CP_PROP_REQUESTED_LABELS, CP_PROP_TEST_NAME, CP_PROP_URL, CP_PROP_USE_XA_INTERFACE, CURRENTINUSE, DEFAULT_WAIT, dsBean, failedRepurposeCount, harvestTime, initializationCallback, jtaDataSource, labelingCallback, localValidateOnly, oracleHelper, oracleVersion, ownerCIC, replayInitiationTimeout, replayStatisticsSnapshot, repurposeCount, resolvedAsCommittedTotalCount, resolvedAsNotCommittedTotalCount, resource, rootSwitchingContext, setDBMSIdentityMethod, sharedPool, sharedPoolReferenceCounter, SIZE, UNKNOWN, unresolvedTotalCount

Fields inherited from class weblogic.common.resourcepool.ResourcePoolImpl

allowShrinking, available, beingProcessed, capacityIncrement, countToDisablePool, countToFlushPool, dead, destroyed, disabledUponResetFailure, forSynchronizingSelfDisabling, inactiveSecs, initialCapacity, lastUsageCount, maintSecs, matchSupported, max_test_wait_millis, maxCapacity, minCapacity, name, reserved, reserveTimeoutSecs, resetFailCount, resFactory, resumeInternallyAllowed, retryIntervalSecs, returnNewlyCreatedResource, shrinkSecs, state, testOnCreate, testOnRelease, testOnReserve, testSecs, timeElapsedAfterShrinking

Fields inherited from interface weblogic.common.resourcepool.ResourcePool

INFINITE_WAIT, NO_WAIT, OVERLOADED_STR, RP_GROUP_DEFAULT_NAME, RP_PROP_CAPACITY_INCREMENT, RP_PROP_CREATE_DELAY, RP_PROP_IGNORE_IN_USE_RESOURCES, RP_PROP_INACTIVE_RES_TIMEOUT_SECS, RP_PROP_INITIAL_CAPACITY, RP_PROP_MAINT_FREQ_SECS, RP_PROP_MAX_CAPACITY, RP_PROP_MAX_RESV_RETRY, RP_PROP_MAX_UNAVL, RP_PROP_MAX_WAITERS, RP_PROP_MIN_CAPACITY, RP_PROP_NAME, RP_PROP_POOL_DISABLE_THRESHOLD_CNT, RP_PROP_POOL_PURGE_THRESHOLD_CNT, RP_PROP_PROFILE_HARVEST_FREQ_SECS, RP_PROP_QUIET_MESSAGES, RP_PROP_RES_CREATION_RETRY_SECS, RP_PROP_RESV_TIMEOUT_SECS, RP_PROP_SHRINK_ENABLED, RP_PROP_SHRINK_FREQUENCY_SECS, RP_PROP_TEST_FREQUENCY_SECS, RP_PROP_TEST_ON_CREATE, RP_PROP_TEST_ON_RELEASE, RP_PROP_TEST_ON_RESERVE, RUNNING, RUNNING_STR, SHUTDOWN, SHUTDOWN_STR, SUSPENDED, SUSPENDED_STR, UNHEALTHY, UNHEALTHY_STR, UNKNOWN, UNKNOWN_STR

Constructor Summary

Constructors

Constructor and Description
HAConnectionPool(JDBCDataSourceBean dsBean, java.lang.String appName, java.lang.String moduleName, java.lang.String compName, java.lang.ClassLoader classLoader)

Method Summary

Modifier and Type	Method and Description
void	activate()
void	addHADataSourceRuntime(HAJDBCConnectionPool pool, HADataSourceRuntime runtime)
protected void	createCollections()
protected ConnectionPool.ConnectionStoreDelegate	createConnectionStoreDelegate()
HAConnectionEnv	createConnectionToInstance(weblogic.jdbc.common.rac.RACInstance instance) Create and return a new connection to the specified RAC instance.
void	createInstanceRuntime(HAJDBCConnectionPool pool, weblogic.common.resourcepool.ResourcePoolGroup instanceGroup, java.lang.String instanceName)
private void	debug(java.lang.String msg)
protected void	destroyResource(weblogic.common.resourcepool.PooledResource res)
protected boolean	disableGroupOnTestFailCount()
private boolean	doDraining()
boolean	doDraining(HAJDBCConnectionPool haPool)
private void	doGravitation()
private void	doHarvest(java.util.List<java.lang.String> instanceNames, boolean draining)
private java.lang.String	extractAttributeValueFromURL(java.lang.String key, java.lang.String url)
void	fcfDownEvent(HAJDBCConnectionPool haPool, weblogic.jdbc.common.rac.RACModule racModule, weblogic.jdbc.common.rac.RACModuleFailoverEvent event)
void	fcfDownEvent(weblogic.jdbc.common.rac.RACModuleFailoverEvent event) Process a down event.
int	fcfUpEvent(HAJDBCConnectionPool haPool, weblogic.jdbc.common.rac.RACModule racModule, weblogic.jdbc.common.rac.RACModuleFailoverEvent event)
int	fcfUpEvent(weblogic.jdbc.common.rac.RACModuleFailoverEvent event) Process an up event.
void	forceShutdownExternal()
void	forceSuspend(boolean shuttingDown)
void	forceSuspendExternal()
boolean	getAffForInstance(java.lang.String instanceName)
java.lang.String	getAffinityContextKey()
ConnectionAffinityCallback.AffinityPolicy	getAffinityPolicy() Returns the preferred affinity policy of the pool
void	getAvailableAndBorrowedConnections(java.util.List<weblogic.common.resourcepool.PooledResource> available, java.util.List<weblogic.common.resourcepool.PooledResource> borrowed)
void	getAvailableAndBorrowedConnections(java.util.List<weblogic.common.resourcepool.PooledResource> available, java.util.List<weblogic.common.resourcepool.PooledResource> borrowed, java.util.List<java.lang.String> instances, boolean removeAvailable)
java.util.List<weblogic.common.resourcepool.PooledResource>	getAvailableConnections(weblogic.jdbc.common.rac.RACInstance instance, boolean remove)
HAConnectionEnv	getConnectionToInstance(weblogic.jdbc.common.rac.RACInstance instance, int waitSeconds, java.util.Properties requestedLabels) Attempt to get an existing or new connection to instance.
int	getCurrentPoolCapacity() Returns the number of connections in the pool
DataAffinityCallback	getDataAffinityCallback() Returns the registered data affinity callback or null if not registered.
java.lang.String	getDatabaseName() Returns the database name for the pool
weblogic.jdbc.common.rac.RACConnectionEnv	getExistingConnection(int waitSeconds, java.util.Properties requestedLabels) Returns any existing connection.
HAConnectionEnv	getExistingConnectionToInstance(HAJDBCConnectionPool haPool, weblogic.jdbc.common.rac.RACInstance instance, int waitSeconds, java.util.Properties requestedLabels)
HAConnectionEnv	getExistingConnectionToInstance(weblogic.jdbc.common.rac.RACInstance instance, int waitSeconds, java.util.Properties requestedLabels) Returns a connection to the specified RAC instance if one already exists in the pool.
long	getFailedAffinityBasedBorrowCount()
long	getFailedRCLBBasedBorrowCount()
weblogic.common.resourcepool.ResourcePoolGroup	getGroupForInstance(java.lang.String instance)
private int	getInitialCapacity()
java.lang.String	getJDBCURL() Returns the JDBC URL that has been configured for this pool.
int	getMaxPoolSize() Returns the maximum capacity of the pool
int	getMinPoolSize() Returns the minimum capacity of the pool
(package private) weblogic.common.resourcepool.PooledResourceInfo	getPooledResourceInfo(weblogic.jdbc.common.rac.RACInstance instance)
weblogic.common.resourcepool.PooledResourceInfo	getPooledResourceInfo(weblogic.jdbc.common.rac.RACInstance instance, java.util.Properties labels)
weblogic.common.resourcepool.ResourcePoolGroup	getPoolGroup()
java.lang.String	getPoolName() The name that identifies the pool.
weblogic.jdbc.common.rac.RACModule	getRACModule()
private int	getRemainingCapacity()
int	getRemainingPoolCapacity() Returns the remaining, unallocated capacity of the pool.
java.util.List<weblogic.common.resourcepool.PooledResource>	getReservedConnections(weblogic.jdbc.common.rac.RACInstance instance)
private java.util.List<weblogic.common.resourcepool.PooledResource>	getReservedConnectionsForInstance(weblogic.jdbc.common.rac.RACInstance instance)
java.lang.String	getServiceName() Returns the service name for the pool
AffinityCallback	getSessionAffinityCallback() Returns the registered session affinity callback or null if not registered.
weblogic.jdbc.common.rac.RACModulePool	getSharedRACModulePool() Returns the shared pool if sharing enabled, or itself
long	getSuccessfulAffinityBasedBorrowCount()
long	getSuccessfulRCLBBasedBorrowCount()
int	getWeightForInstance(java.lang.String instanceName)
AffinityCallback	getXAAffinityCallback() Returns the registered transaction affinity callback or null if not registered.
private void	init()
void	initAffinityKeyIfNecessary() Initializes database state used for constructing RACInstance instances for use in affinity contexts, etc.
private void	initDatabaseServiceNames(weblogic.jdbc.common.rac.RACInstance racInstance)
void	initOns()
void	initOns(weblogic.jdbc.common.rac.RACModule racModule)
void	initOracleHelper()
protected boolean	isRootPartitionGroupEnabled(ConnectionEnv ce) For generic DS (non-RAC) return the state of the connection pool
boolean	isXA()
private boolean	locateConnectionsToDrain(HAJDBCConnectionPool haPool, weblogic.jdbc.common.rac.RACInstance instance, java.util.List<weblogic.jdbc.common.rac.RACConnectionEnv> toDestroy, int drainCnt)
private boolean	locateConnectionsToDrain(weblogic.jdbc.common.rac.RACInstance instance, java.util.List<weblogic.jdbc.common.rac.RACConnectionEnv> toDestroy, int drainCnt)
private weblogic.jdbc.common.rac.RACConnectionEnv	locateConnectionToDestroy(weblogic.jdbc.common.rac.RACInstance instance, java.util.List<weblogic.jdbc.common.rac.RACConnectionEnv> toDestroy, weblogic.common.resourcepool.ResourcePoolGroup g, int capacity)
void	markConnectionGood(ConnectionEnv pooledConnection)
weblogic.common.resourcepool.PooledResource	matchResource(weblogic.common.resourcepool.PooledResourceInfo pri)
private HAConnectionEnv	openConnectionToInstance(weblogic.jdbc.common.rac.RACInstance instance, boolean reserve, java.util.Properties additionalProperties)
void	performMaintenance()
protected void	processFailCountExceededDisableThreshold()
void	release(ConnectionEnv resource) Releases connection back to the pool.
protected void	releasePinnedToThread(ConnectionEnv resource)
boolean	removeFromAvailableForProcessing(java.util.List<weblogic.common.resourcepool.PooledResource> resources)
HADataSourceRuntime	removeHADataSourceRuntime(HAJDBCConnectionPool pool)
void	removePooledResource(weblogic.jdbc.common.rac.RACConnectionEnv conn) Removes the specified connection from the pool.
protected void	replayUpdateConnectionState(ConnectionEnv pooledConnection)
ConnectionEnv	reserve(weblogic.security.acl.internal.AuthenticatedSubject user, int waitSeconds, java.util.Properties requestedLabels, java.lang.String username, java.lang.String password)
ConnectionEnv	reserve(weblogic.jdbc.common.rac.RACModule racModule, weblogic.security.acl.internal.AuthenticatedSubject user, int waitSeconds, java.util.Properties requestedLabels, java.lang.String username, java.lang.String password)
HAConnectionEnv	reserveInternalResource() Returns a connection from the pool for internal use.
protected ConnectionEnv	reservePinnedToThread(int waitSeconds, boolean internalUse)
private ConnectionEnv	reserveWithTxAffinity(weblogic.security.acl.internal.AuthenticatedSubject user, int waitSeconds, java.util.Properties requestedLabels)
void	resume()
void	resumeExternal()
protected void	setAffinityContextKeyNameIfNecessary(weblogic.jdbc.common.rac.RACInstance racInstance)
void	setFanEnabled(boolean enabled)
private void	setTxAffinityContext(ConnectionEnv ce)
private void	setUCPTransactionAffinityContext(ConnectionEnv ce)
void	shutdown()
void	shutdownExternal(int operationSecs)
void	start(java.lang.Object unused)
void	startExternal()
private void	stopRACModule()
void	suspend(boolean shuttingDown)
void	suspendExternal(int operationSecs)
private void	switchToRootPartitionAndMakeAvailable(ConnectionEnv ce)
private void	turnOffDraining(HAJDBCConnectionPool haPool)

Methods inherited from class weblogic.jdbc.common.internal.ConnectionPool

areConnsBeingTested, clearDBMSIdentity, clearReplayStatistics, clearStatementCache, clearUserCache, connectionCallbacks, continueMakeResourceAttemptsAfterFailure, deactivate, decrementSharedPoolReferenceCounter, destroyMatchingAvailableAndReservedConnections, disableCountOfRefreshFailuresTillDisable, disableDroppingUsers, disableFreezingUsers, doAuthorizationCheck, doHarvest, enable, endRequest, getAppName, getAuthorizationCallable, getAvailableMatching, getCachedPooledResource, getClassLoader, getCommitOutcomeRetryTotalCount, getCompName, getComponentInvocationContextManager, getConfig, getConnectionHarvestMaxCount, getConnectionHarvestTriggerCount, getDBMSIdentity, getDriverClass, getDriverInterceptor, getDriverVersion, getFailedRepurposeCount, getGroup, getInactiveSeconds, getInfo, getInitializationCallback, getJDBCDataSource, getJTADataSource, getLabelingCallback, getMaintainer, getModuleName, getName, getOracleHelper, getOracleVersion, getOrCreateGroup, getPartitionName, getPrepStmtCacheAccessCount, getPrepStmtCacheAddCount, getPrepStmtCacheCurrentSize, getPrepStmtCacheDeleteCount, getPrepStmtCacheHitCount, getPrepStmtCacheMissCount, getProfiler, getProperties, getReplayInitiationTimeout, getReplayStatistics, getReplayStatisticsSnapshot, getRepurposeCount, getReservedMatching, getReserveReleaseInterceptor, getResolvedAsCommittedTotalCount, getResolvedAsNotCommittedTotalCount, getResourceFactory, getResourceName, getRootSwitchingContext, getSharedPoolReferenceCounter, getStateAsInt, getTestOnCreate, getTestOnRelease, getTestOnReserve, getTestSeconds, getUnresolvedTotalCount, getURL, getXARetryDurationSeconds, incrementCommitOutcomeRetryTotalCount, incrementLeakedConnectionCount, incrementResolvedAsCommittedTotalCount, incrementResolvedAsNotCommittedTotalCount, incrementSharedPoolReferenceCounter, incrementUnresolvedTotalCount, initOwnerCIC, initPooledResourceFactory, isCreateConnectionInline, isCredentialMappingEnabled, isEnabled, isIdentityBasedConnectionPoolingEnabled, isLocalValidateOnly, isMemberDS, isNativeXA, isOracleOptimizeUtf8Conversion, isOracleProxySession, isRemoveInfectedConnectionEnabled, isSharedPool, isSharingPool, isWrapJdbc, isWrapTypes, makeResource, onRelease, onReserve, poolExists, preventSelfResuming, processOracleProxySession, putCachedPooledResource, refresh, refreshOldestAvailResource, removeCachedPooledResource, removeConnection, removeResource, replayInitialize, replayInvokeInitializeCallbacks, repurposeMatchingAvailableAndReservedConnections, reserve, reserve, reserve, reserve, reserveInternal, reset, resetStatistics, returnNewlyCreatedResource, setConnectionHarvestMaxCount, setConnectionHarvestTriggerCount, setCountOfRefreshFailuresTillDisable, setCountOfTestFailuresTillFlush, setDataSource, setDBMSIdentity, setInitializationCallback, setJDBCDataSource, setLabelingCallback, setMaintenanceFrequencySeconds, setOracleOptimizeUtf8Conversion, setProfileConnectionLeakTimeoutSeconds, setProfileType, setReplayInitiationTimeout, setRootSwitchingContext, setSecondsToTrustAnIdlePoolConnection, setShrinkFrequencySeconds, setStatementCacheSize, setTestFrequencySeconds, setTestTableName, setupConnectionHarvesting, setupConnectionInitializationCallback, setupConnectionLabelingCallback, setupDriverInterceptor, setWrapJdbc, setWrapTypes, shrink, start, suspend, switchToRootPartition, updateCredential, updateGroups, waitForNoReservedMatching

Methods inherited from class weblogic.common.resourcepool.ResourcePoolImpl

addGroup, checkHangForAllGroups, createResources, createResources, decrementGroupCapacities, dumpPool, forceDestroyResource, getAverageReserved, getCreationDelayTime, getCurrCapacity, getDerivedState, getGroups, getGroups, getHighestCurrCapacity, getHighestNumAvailable, getHighestNumReserved, getHighestNumUnavailable, getHighestNumWaiters, getHighestWaitSeconds, getLastShrinkTime, getMaxCapacity, getMinCapacity, getNumAvailable, getNumFailedReserveRequests, getNumFailuresToRefresh, getNumIdleDetected, getNumLeaked, getNumReserved, getNumReserveRequests, getNumUnavailable, getNumWaiters, getResources, getResourcesDestroyedByShrinkingCount, getState, getTimeToNextShrinkOperation, getTotalNumAllocated, getTotalNumDestroyed, getTotalWaitingForConnection, getTotalWaitingForConnectionFailure, getTotalWaitingForConnectionSuccess, incrementGroupCapacities, incrementGroupCreatedCounts, incrementNumLeaked, incrementResourcesDestroyedByShrinkingCount, initParameters, makeResources, makeResources, makeResources, makeResources, refresh, releaseResource, reserveResource, reserveResource, reserveResource, reserveResource, setCapacityIncrement, setHighestNumUnavailable, setHighestNumWaiters, setIgnoreInUseResources, setInactiveResourceTimeoutSeconds, setInitialCapacity, setMaximumCapacity, setMinimumCapacity, setProfileHarvestFrequencySeconds, setResourceCreationRetrySeconds, setResourceReserveTimeoutSeconds, setShrinkEnabled, setShrinkFactor, setTestOnCreate, setTestOnRelease, setTestOnReserve, zeroResetFailCount

Methods inherited from class java.lang.Object

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

Methods inherited from interface weblogic.jdbc.common.rac.RACModulePool

isSharedPool, isSharingPool, switchToRootPartition

Methods inherited from interface weblogic.jdbc.common.internal.OraclePool

getDriverClass, replayInitialize

Methods inherited from interface weblogic.jdbc.common.internal.JDBCConnectionPool

areConnsBeingTested, clearDBMSIdentity, clearReplayStatistics, clearStatementCache, connectionCallbacks, decrementSharedPoolReferenceCounter, destroyMatchingAvailableAndReservedConnections, dumpPool, getAppName, getAvailableMatching, getCachedPooledResource, getClassLoader, getCommitOutcomeRetryTotalCount, getCompName, getConnectionHarvestTriggerCount, getDBMSIdentity, getDerivedState, getDriverInterceptor, getDriverVersion, getFailedRepurposeCount, getGroup, getGroups, getInactiveSeconds, getInitializationCallback, getJDBCDataSource, getJTADataSource, getLabelingCallback, getModuleName, getName, getOracleHelper, getOracleVersion, getOrCreateGroup, getPartitionName, getPrepStmtCacheAccessCount, getPrepStmtCacheAddCount, getPrepStmtCacheCurrentSize, getPrepStmtCacheDeleteCount, getPrepStmtCacheHitCount, getPrepStmtCacheMissCount, getProfiler, getProperties, getReplayInitiationTimeout, getReplayStatistics, getReplayStatisticsSnapshot, getRepurposeCount, getReservedMatching, getResolvedAsCommittedTotalCount, getResolvedAsNotCommittedTotalCount, getResourceFactory, getRootSwitchingContext, getStateAsInt, getTestOnReserve, getTestSeconds, getUnresolvedTotalCount, getURL, getXARetryDurationSeconds, incrementCommitOutcomeRetryTotalCount, incrementLeakedConnectionCount, incrementResolvedAsCommittedTotalCount, incrementResolvedAsNotCommittedTotalCount, incrementSharedPoolReferenceCounter, incrementUnresolvedTotalCount, isCreateConnectionInline, isCredentialMappingEnabled, isEnabled, isIdentityBasedConnectionPoolingEnabled, isLocalValidateOnly, isMemberDS, isNativeXA, isOracleOptimizeUtf8Conversion, isRemoveInfectedConnectionEnabled, isSharedPool, isSharingPool, isWrapJdbc, isWrapTypes, poolExists, putCachedPooledResource, removeCachedPooledResource, removeConnection, removeResource, repurposeMatchingAvailableAndReservedConnections, reserve, reserveInternal, reset, setConnectionHarvestMaxCount, setConnectionHarvestTriggerCount, setDataSource, setDBMSIdentity, setInitializationCallback, setJDBCDataSource, setLabelingCallback, setOracleOptimizeUtf8Conversion, setProfileConnectionLeakTimeoutSeconds, setProfileType, setReplayInitiationTimeout, setRootSwitchingContext, setSecondsToTrustAnIdlePoolConnection, setStatementCacheSize, setTestTableName, start, updateCredential, waitForNoReservedMatching, zeroResetFailCount

Methods inherited from interface weblogic.common.resourcepool.ResourcePool

createResources, createResources, getAverageReserved, getCreationDelayTime, getCurrCapacity, getHighestCurrCapacity, getHighestNumAvailable, getHighestNumReserved, getHighestNumUnavailable, getHighestNumWaiters, getHighestWaitSeconds, getMaintainer, getMaxCapacity, getMinCapacity, getNumAvailable, getNumFailedReserveRequests, getNumFailuresToRefresh, getNumLeaked, getNumReserved, getNumReserveRequests, getNumUnavailable, getNumWaiters, getReserveReleaseInterceptor, getResources, getState, getTotalNumAllocated, getTotalNumDestroyed, getTotalWaitingForConnection, getTotalWaitingForConnectionFailure, getTotalWaitingForConnectionSuccess, incrementNumLeaked, initPooledResourceFactory, refresh, releaseResource, reserveResource, reserveResource, resetStatistics, setCapacityIncrement, setCountOfRefreshFailuresTillDisable, setCountOfTestFailuresTillFlush, setHighestNumUnavailable, setHighestNumWaiters, setIgnoreInUseResources, setInactiveResourceTimeoutSeconds, setInitialCapacity, setMaintenanceFrequencySeconds, setMaximumCapacity, setMinimumCapacity, setProfileHarvestFrequencySeconds, setResourceCreationRetrySeconds, setResourceReserveTimeoutSeconds, setShrinkEnabled, setShrinkFrequencySeconds, setTestFrequencySeconds, setTestOnCreate, setTestOnRelease, setTestOnReserve, shrink

Field Detail

racModule

private weblogic.jdbc.common.rac.RACModule racModule

serviceName

private java.lang.String serviceName

loggedServiceName

private java.lang.String loggedServiceName

databaseName

private java.lang.String databaseName

fanEnabled

private boolean fanEnabled

affinityContextKey

private java.lang.String affinityContextKey

tm

private TransactionManager tm

isxa

private boolean isxa

rlbThreshold

private int rlbThreshold

dsService

private DataSourceServiceImpl dsService

affinityPolicy

private ConnectionAffinityCallback.AffinityPolicy affinityPolicy

xaAffinityCallback

private AffinityCallback xaAffinityCallback

sessionAffinityCallback

private AffinityCallback sessionAffinityCallback

gravitationShrinkTime

private java.util.concurrent.atomic.AtomicInteger gravitationShrinkTime

racAffinityContextHelper

private weblogic.jdbc.common.rac.RACAffinityContextHelper racAffinityContextHelper

autoOns

private boolean autoOns

haDataSourceRuntimes

private java.util.Map<HAJDBCConnectionPool,HADataSourceRuntime> haDataSourceRuntimes

MAXDRAIN

static int MAXDRAIN

DRAININTERVAL

static int DRAININTERVAL

Constructor Detail

HAConnectionPool

public HAConnectionPool(JDBCDataSourceBean dsBean,
                        java.lang.String appName,
                        java.lang.String moduleName,
                        java.lang.String compName,
                        java.lang.ClassLoader classLoader)

Method Detail

setFanEnabled

public void setFanEnabled(boolean enabled)
                   throws ResourceException

Throws:

ResourceException

init

private void init()

isXA

public boolean isXA()

Specified by:

isXA in interface HAJDBCConnectionPool

extractAttributeValueFromURL

private java.lang.String extractAttributeValueFromURL(java.lang.String key,
                                                      java.lang.String url)

getServiceName

public java.lang.String getServiceName()

Description copied from interface: weblogic.jdbc.common.rac.RACModulePool

Returns the service name for the pool

Specified by:

getServiceName in interface HAJDBCConnectionPool

Specified by:

getServiceName in interface weblogic.jdbc.common.rac.RACModulePool

Returns:

The service name for the pool

getDatabaseName

public java.lang.String getDatabaseName()

Description copied from interface: weblogic.jdbc.common.rac.RACModulePool

Returns the database name for the pool

Specified by:

getDatabaseName in interface HAJDBCConnectionPool

Specified by:

getDatabaseName in interface weblogic.jdbc.common.rac.RACModulePool

Returns:

The database name for the pool

releasePinnedToThread

protected void releasePinnedToThread(ConnectionEnv resource)
                              throws ResourceException

Overrides:

releasePinnedToThread in class ConnectionPool

Throws:

ResourceException

reservePinnedToThread

protected ConnectionEnv reservePinnedToThread(int waitSeconds,
                                              boolean internalUse)
                                       throws ResourceException,
                                              weblogic.common.resourcepool.ResourceDisabledException

Overrides:

reservePinnedToThread in class ConnectionPool

Throws:

ResourceException

weblogic.common.resourcepool.ResourceDisabledException

reserve

public ConnectionEnv reserve(weblogic.security.acl.internal.AuthenticatedSubject user,
                             int waitSeconds,
                             java.util.Properties requestedLabels,
                             java.lang.String username,
                             java.lang.String password)
                      throws ResourceException

Specified by:

reserve in interface JDBCConnectionPool

Overrides:

reserve in class ConnectionPool

Throws:

ResourceException

reserve

public ConnectionEnv reserve(weblogic.jdbc.common.rac.RACModule racModule,
                             weblogic.security.acl.internal.AuthenticatedSubject user,
                             int waitSeconds,
                             java.util.Properties requestedLabels,
                             java.lang.String username,
                             java.lang.String password)
                      throws ResourceException

Specified by:

reserve in interface HAJDBCConnectionPool

Throws:

ResourceException

release

public void release(ConnectionEnv resource)
             throws ResourceException

Description copied from interface: weblogic.jdbc.common.rac.RACModulePool

Releases connection back to the pool.

Specified by:

release in interface JDBCConnectionPool

Specified by:

release in interface weblogic.jdbc.common.rac.RACModulePool

Overrides:

release in class ConnectionPool

Parameters:

resource - The pooled resource to release.

Throws:

ResourceException

destroyResource

protected void destroyResource(weblogic.common.resourcepool.PooledResource res)

Overrides:

destroyResource in class weblogic.common.resourcepool.ResourcePoolImpl

createCollections

protected void createCollections()

Overrides:

createCollections in class ConnectionPool

activate

public void activate()
              throws java.lang.IllegalStateException,
                     ResourceException

Overrides:

activate in class ConnectionPool

Throws:

java.lang.IllegalStateException

ResourceException

forceShutdownExternal

public void forceShutdownExternal()
                           throws ResourceException

Specified by:

forceShutdownExternal in interface JDBCConnectionPool

Overrides:

forceShutdownExternal in class ConnectionPool

Throws:

ResourceException

forceSuspend

public void forceSuspend(boolean shuttingDown)
                  throws ResourceException

Specified by:

forceSuspend in interface weblogic.common.resourcepool.ObjectLifeCycle

Overrides:

forceSuspend in class ConnectionPool

Throws:

ResourceException

forceSuspendExternal

public void forceSuspendExternal()
                          throws ResourceException

Specified by:

forceSuspendExternal in interface JDBCConnectionPool

Overrides:

forceSuspendExternal in class ConnectionPool

Throws:

ResourceException

resume

public void resume()
            throws ResourceException

Specified by:

resume in interface weblogic.common.resourcepool.ObjectLifeCycle

Overrides:

resume in class ConnectionPool

Throws:

ResourceException

resumeExternal

public void resumeExternal()
                    throws ResourceException

Specified by:

resumeExternal in interface JDBCConnectionPool

Overrides:

resumeExternal in class ConnectionPool

Throws:

ResourceException

shutdown

public void shutdown()
              throws ResourceException

Specified by:

shutdown in interface weblogic.common.resourcepool.ObjectLifeCycle

Overrides:

shutdown in class ConnectionPool

Throws:

ResourceException

shutdownExternal

public void shutdownExternal(int operationSecs)
                      throws ResourceException

Specified by:

shutdownExternal in interface JDBCConnectionPool

Overrides:

shutdownExternal in class ConnectionPool

Throws:

ResourceException

start

public void start(java.lang.Object unused)
           throws ResourceException

Specified by:

start in interface weblogic.common.resourcepool.ObjectLifeCycle

Overrides:

start in class ConnectionPool

Throws:

ResourceException

startExternal

public void startExternal()
                   throws ResourceException

Specified by:

startExternal in interface JDBCConnectionPool

Overrides:

startExternal in class ConnectionPool

Throws:

ResourceException

suspend

public void suspend(boolean shuttingDown)
             throws ResourceException

Specified by:

suspend in interface weblogic.common.resourcepool.ObjectLifeCycle

Overrides:

suspend in class weblogic.common.resourcepool.ResourcePoolImpl

Throws:

ResourceException

suspendExternal

public void suspendExternal(int operationSecs)
                     throws ResourceException

Specified by:

suspendExternal in interface JDBCConnectionPool

Overrides:

suspendExternal in class ConnectionPool

Throws:

ResourceException

addHADataSourceRuntime

public void addHADataSourceRuntime(HAJDBCConnectionPool pool,
                                   HADataSourceRuntime runtime)

Specified by:

addHADataSourceRuntime in interface HAJDBCConnectionPool

removeHADataSourceRuntime

public HADataSourceRuntime removeHADataSourceRuntime(HAJDBCConnectionPool pool)

Specified by:

removeHADataSourceRuntime in interface HAJDBCConnectionPool

createInstanceRuntime

public void createInstanceRuntime(HAJDBCConnectionPool pool,
                                  weblogic.common.resourcepool.ResourcePoolGroup instanceGroup,
                                  java.lang.String instanceName)

Specified by:

createInstanceRuntime in interface HAJDBCConnectionPool

performMaintenance

public void performMaintenance()

Specified by:

performMaintenance in interface weblogic.common.resourcepool.ResourcePoolMaintainer

Overrides:

performMaintenance in class ConnectionPool

doGravitation

private void doGravitation()

doDraining

private boolean doDraining()

doDraining

public boolean doDraining(HAJDBCConnectionPool haPool)

Specified by:

doDraining in interface HAJDBCConnectionPool

locateConnectionsToDrain

private boolean locateConnectionsToDrain(weblogic.jdbc.common.rac.RACInstance instance,
                                         java.util.List<weblogic.jdbc.common.rac.RACConnectionEnv> toDestroy,
                                         int drainCnt)

locateConnectionsToDrain

private boolean locateConnectionsToDrain(HAJDBCConnectionPool haPool,
                                         weblogic.jdbc.common.rac.RACInstance instance,
                                         java.util.List<weblogic.jdbc.common.rac.RACConnectionEnv> toDestroy,
                                         int drainCnt)

locateConnectionToDestroy

private weblogic.jdbc.common.rac.RACConnectionEnv locateConnectionToDestroy(weblogic.jdbc.common.rac.RACInstance instance,
                                                                            java.util.List<weblogic.jdbc.common.rac.RACConnectionEnv> toDestroy,
                                                                            weblogic.common.resourcepool.ResourcePoolGroup g,
                                                                            int capacity)

getFailedRCLBBasedBorrowCount

public long getFailedRCLBBasedBorrowCount()

Specified by:

getFailedRCLBBasedBorrowCount in interface HAJDBCConnectionPool

getSuccessfulRCLBBasedBorrowCount

public long getSuccessfulRCLBBasedBorrowCount()

Specified by:

getSuccessfulRCLBBasedBorrowCount in interface HAJDBCConnectionPool

getFailedAffinityBasedBorrowCount

public long getFailedAffinityBasedBorrowCount()

Specified by:

getFailedAffinityBasedBorrowCount in interface HAJDBCConnectionPool

getSuccessfulAffinityBasedBorrowCount

public long getSuccessfulAffinityBasedBorrowCount()

Specified by:

getSuccessfulAffinityBasedBorrowCount in interface HAJDBCConnectionPool

processFailCountExceededDisableThreshold

protected void processFailCountExceededDisableThreshold()

Overrides:

processFailCountExceededDisableThreshold in class weblogic.common.resourcepool.ResourcePoolImpl

initOracleHelper

public void initOracleHelper()
                      throws ResourceException

Overrides:

initOracleHelper in class ConnectionPool

Throws:

ResourceException

initOns

public void initOns()
             throws ResourceException

Throws:

ResourceException

initOns

public void initOns(weblogic.jdbc.common.rac.RACModule racModule)
             throws ResourceException

Specified by:

initOns in interface HAJDBCConnectionPool

Throws:

ResourceException

stopRACModule

private void stopRACModule()
                    throws ResourceException

Throws:

ResourceException

getRACModule

public weblogic.jdbc.common.rac.RACModule getRACModule()

Specified by:

getRACModule in interface HAJDBCConnectionPool

getInitialCapacity

private int getInitialCapacity()

getRemainingCapacity

private int getRemainingCapacity()

openConnectionToInstance

private HAConnectionEnv openConnectionToInstance(weblogic.jdbc.common.rac.RACInstance instance,
                                                 boolean reserve,
                                                 java.util.Properties additionalProperties)
                                          throws ResourceException

Throws:

ResourceException

getPooledResourceInfo

weblogic.common.resourcepool.PooledResourceInfo getPooledResourceInfo(weblogic.jdbc.common.rac.RACInstance instance)

getPooledResourceInfo

public weblogic.common.resourcepool.PooledResourceInfo getPooledResourceInfo(weblogic.jdbc.common.rac.RACInstance instance,
                                                                             java.util.Properties labels)

Specified by:

getPooledResourceInfo in interface HAJDBCConnectionPool

getWeightForInstance

public int getWeightForInstance(java.lang.String instanceName)

Specified by:

getWeightForInstance in interface HAJDBCConnectionPool

getAffForInstance

public boolean getAffForInstance(java.lang.String instanceName)

Specified by:

getAffForInstance in interface HAJDBCConnectionPool

getAvailableAndBorrowedConnections

public void getAvailableAndBorrowedConnections(java.util.List<weblogic.common.resourcepool.PooledResource> available,
                                               java.util.List<weblogic.common.resourcepool.PooledResource> borrowed)

Specified by:

getAvailableAndBorrowedConnections in interface HAJDBCConnectionPool

getAvailableAndBorrowedConnections

public void getAvailableAndBorrowedConnections(java.util.List<weblogic.common.resourcepool.PooledResource> available,
                                               java.util.List<weblogic.common.resourcepool.PooledResource> borrowed,
                                               java.util.List<java.lang.String> instances,
                                               boolean removeAvailable)

Specified by:

getAvailableAndBorrowedConnections in interface HAJDBCConnectionPool

getAvailableConnections

public java.util.List<weblogic.common.resourcepool.PooledResource> getAvailableConnections(weblogic.jdbc.common.rac.RACInstance instance,
                                                                                           boolean remove)

Specified by:

getAvailableConnections in interface HAJDBCConnectionPool

getReservedConnections

public java.util.List<weblogic.common.resourcepool.PooledResource> getReservedConnections(weblogic.jdbc.common.rac.RACInstance instance)

Specified by:

getReservedConnections in interface HAJDBCConnectionPool

getReservedConnectionsForInstance

private java.util.List<weblogic.common.resourcepool.PooledResource> getReservedConnectionsForInstance(weblogic.jdbc.common.rac.RACInstance instance)

getAffinityContextKey

public java.lang.String getAffinityContextKey()

Specified by:

getAffinityContextKey in interface HAJDBCConnectionPool

initAffinityKeyIfNecessary

public void initAffinityKeyIfNecessary()
                                throws ResourceException

Description copied from interface: weblogic.jdbc.common.rac.RACModulePool

Initializes database state used for constructing RACInstance instances for use in affinity contexts, etc. If no connections to the target database have been processed a new connection will be established to query attributes such as database name, service name, etc.

Specified by:

initAffinityKeyIfNecessary in interface HAJDBCConnectionPool

Specified by:

initAffinityKeyIfNecessary in interface weblogic.jdbc.common.rac.RACModulePool

Throws:

ResourceException - An error occured trying to establish connection to the database

initDatabaseServiceNames

private void initDatabaseServiceNames(weblogic.jdbc.common.rac.RACInstance racInstance)

setAffinityContextKeyNameIfNecessary

protected void setAffinityContextKeyNameIfNecessary(weblogic.jdbc.common.rac.RACInstance racInstance)

reserveWithTxAffinity

private ConnectionEnv reserveWithTxAffinity(weblogic.security.acl.internal.AuthenticatedSubject user,
                                            int waitSeconds,
                                            java.util.Properties requestedLabels)
                                     throws ResourceException

Throws:

ResourceException

setTxAffinityContext

private void setTxAffinityContext(ConnectionEnv ce)

setUCPTransactionAffinityContext

private void setUCPTransactionAffinityContext(ConnectionEnv ce)

getConnectionToInstance

public HAConnectionEnv getConnectionToInstance(weblogic.jdbc.common.rac.RACInstance instance,
                                               int waitSeconds,
                                               java.util.Properties requestedLabels)
                                        throws ResourceException

Attempt to get an existing or new connection to instance. returns null if unable

Throws:

ResourceException

getExistingConnectionToInstance

public HAConnectionEnv getExistingConnectionToInstance(weblogic.jdbc.common.rac.RACInstance instance,
                                                       int waitSeconds,
                                                       java.util.Properties requestedLabels)
                                                throws ResourceException

Description copied from interface: weblogic.jdbc.common.rac.RACModulePool

Returns a connection to the specified RAC instance if one already exists in the pool.

Specified by:

getExistingConnectionToInstance in interface weblogic.jdbc.common.rac.RACModulePool

Parameters:

instance - The desired RAC instance.

waitSeconds - The number of seconds to wait for a connection.

requestedLabels - The set of labels to use to match a connection.

Returns:

A connection to the instance, or null if none exist or wait time was exceeded.

Throws:

ResourceException - An error occurred.

getExistingConnectionToInstance

public HAConnectionEnv getExistingConnectionToInstance(HAJDBCConnectionPool haPool,
                                                       weblogic.jdbc.common.rac.RACInstance instance,
                                                       int waitSeconds,
                                                       java.util.Properties requestedLabels)
                                                throws ResourceException

Specified by:

getExistingConnectionToInstance in interface HAJDBCConnectionPool

Throws:

ResourceException

getExistingConnection

public weblogic.jdbc.common.rac.RACConnectionEnv getExistingConnection(int waitSeconds,
                                                                       java.util.Properties requestedLabels)
                                                                throws ResourceException

Description copied from interface: weblogic.jdbc.common.rac.RACModulePool

Returns any existing connection.

Specified by:

getExistingConnection in interface weblogic.jdbc.common.rac.RACModulePool

Parameters:

waitSeconds - The number of seconds to wait for a connetion.

requestedLabels - The set of labels to use to match a connection.

Returns:

Any available connection, or null if none eixsts or if the wait time was exceeded

Throws:

ResourceException - An error occurred.

removePooledResource

public void removePooledResource(weblogic.jdbc.common.rac.RACConnectionEnv conn)
                          throws ResourceException

Description copied from interface: weblogic.jdbc.common.rac.RACModulePool

Removes the specified connection from the pool.

Specified by:

removePooledResource in interface weblogic.jdbc.common.rac.RACModulePool

Parameters:

conn - The connection to remove

Throws:

ResourceException - An error occurred.

createConnectionToInstance

public HAConnectionEnv createConnectionToInstance(weblogic.jdbc.common.rac.RACInstance instance)
                                           throws ResourceException

Description copied from interface: weblogic.jdbc.common.rac.RACModulePool

Create and return a new connection to the specified RAC instance. The new connection is added to the pool

Specified by:

createConnectionToInstance in interface weblogic.jdbc.common.rac.RACModulePool

Parameters:

instance - The desired instance to which to create the connection.

Returns:

The newly created instance.

Throws:

ResourceException - An error occurred.

getMaxPoolSize

public int getMaxPoolSize()

Description copied from interface: weblogic.jdbc.common.rac.RACModulePool

Returns the maximum capacity of the pool

Specified by:

getMaxPoolSize in interface weblogic.jdbc.common.rac.RACModulePool

Returns:

The maximum capacity

getMinPoolSize

public int getMinPoolSize()

Description copied from interface: weblogic.jdbc.common.rac.RACModulePool

Returns the minimum capacity of the pool

Specified by:

getMinPoolSize in interface weblogic.jdbc.common.rac.RACModulePool

Returns:

The minimum capacity

getPoolName

public java.lang.String getPoolName()

Description copied from interface: weblogic.jdbc.common.rac.RACModulePool

The name that identifies the pool.

Specified by:

getPoolName in interface weblogic.jdbc.common.rac.RACModulePool

Returns:

The pool name

getRemainingPoolCapacity

public int getRemainingPoolCapacity()

Description copied from interface: weblogic.jdbc.common.rac.RACModulePool

Returns the remaining, unallocated capacity of the pool.

Specified by:

getRemainingPoolCapacity in interface weblogic.jdbc.common.rac.RACModulePool

Returns:

The number of connections that can be added.

getCurrentPoolCapacity

public int getCurrentPoolCapacity()

Description copied from interface: weblogic.jdbc.common.rac.RACModulePool

Returns the number of connections in the pool

Specified by:

getCurrentPoolCapacity in interface weblogic.jdbc.common.rac.RACModulePool

Returns:

The current number of pooled connections.

getJDBCURL

public java.lang.String getJDBCURL()

Description copied from interface: weblogic.jdbc.common.rac.RACModulePool

Returns the JDBC URL that has been configured for this pool.

Specified by:

getJDBCURL in interface weblogic.jdbc.common.rac.RACModulePool

Returns:

The JDBC URL used to create connections.

fcfDownEvent

public void fcfDownEvent(weblogic.jdbc.common.rac.RACModuleFailoverEvent event)
                  throws ResourceException

Description copied from interface: weblogic.jdbc.common.rac.RACModulePool

Process a down event.

Specified by:

fcfDownEvent in interface weblogic.jdbc.common.rac.RACModulePool

Parameters:

event - The incoming FAN event.

Throws:

ResourceException - An error occurred.

fcfDownEvent

public void fcfDownEvent(HAJDBCConnectionPool haPool,
                         weblogic.jdbc.common.rac.RACModule racModule,
                         weblogic.jdbc.common.rac.RACModuleFailoverEvent event)
                  throws ResourceException

Specified by:

fcfDownEvent in interface HAJDBCConnectionPool

Throws:

ResourceException

getPoolGroup

public weblogic.common.resourcepool.ResourcePoolGroup getPoolGroup()

Specified by:

getPoolGroup in interface HAJDBCConnectionPool

getGroupForInstance

public weblogic.common.resourcepool.ResourcePoolGroup getGroupForInstance(java.lang.String instance)

Specified by:

getGroupForInstance in interface HAJDBCConnectionPool

fcfUpEvent

public int fcfUpEvent(weblogic.jdbc.common.rac.RACModuleFailoverEvent event)
               throws ResourceException

Description copied from interface: weblogic.jdbc.common.rac.RACModulePool

Process an up event.

Specified by:

fcfUpEvent in interface weblogic.jdbc.common.rac.RACModulePool

Parameters:

event - The incoming FAN event.

Returns:

The number of connections opened?

Throws:

ResourceException - An error occurred.

fcfUpEvent

public int fcfUpEvent(HAJDBCConnectionPool haPool,
                      weblogic.jdbc.common.rac.RACModule racModule,
                      weblogic.jdbc.common.rac.RACModuleFailoverEvent event)
               throws ResourceException

Specified by:

fcfUpEvent in interface HAJDBCConnectionPool

Throws:

ResourceException

getAffinityPolicy

public ConnectionAffinityCallback.AffinityPolicy getAffinityPolicy()

Description copied from interface: weblogic.jdbc.common.rac.RACModulePool

Returns the preferred affinity policy of the pool

Specified by:

getAffinityPolicy in interface weblogic.jdbc.common.rac.RACModulePool

Returns:

The preferred affinity policy.

getDataAffinityCallback

public DataAffinityCallback getDataAffinityCallback()

Description copied from interface: weblogic.jdbc.common.rac.RACModulePool

Returns the registered data affinity callback or null if not registered.

Specified by:

getDataAffinityCallback in interface weblogic.jdbc.common.rac.RACModulePool

Returns:

The registered data affinity callback.

getSessionAffinityCallback

public AffinityCallback getSessionAffinityCallback()

Description copied from interface: weblogic.jdbc.common.rac.RACModulePool

Returns the registered session affinity callback or null if not registered.

Specified by:

getSessionAffinityCallback in interface weblogic.jdbc.common.rac.RACModulePool

Returns:

The registered session affinity callback.

getXAAffinityCallback

public AffinityCallback getXAAffinityCallback()

Description copied from interface: weblogic.jdbc.common.rac.RACModulePool

Returns the registered transaction affinity callback or null if not registered.

Specified by:

getXAAffinityCallback in interface weblogic.jdbc.common.rac.RACModulePool

Returns:

The registered transaction affinity callback.

getSharedRACModulePool

public weblogic.jdbc.common.rac.RACModulePool getSharedRACModulePool()

Description copied from interface: weblogic.jdbc.common.rac.RACModulePool

Returns the shared pool if sharing enabled, or itself

Specified by:

getSharedRACModulePool in interface weblogic.jdbc.common.rac.RACModulePool

Returns:

The shared pool if sharing enabled, or itself

markConnectionGood

public void markConnectionGood(ConnectionEnv pooledConnection)

Overrides:

markConnectionGood in class ConnectionPool

matchResource

public weblogic.common.resourcepool.PooledResource matchResource(weblogic.common.resourcepool.PooledResourceInfo pri)
                                                          throws ResourceException

Specified by:

matchResource in interface weblogic.common.resourcepool.ResourcePool

Overrides:

matchResource in class ConnectionPool

Throws:

ResourceException

disableGroupOnTestFailCount

protected boolean disableGroupOnTestFailCount()

Overrides:

disableGroupOnTestFailCount in class weblogic.common.resourcepool.ResourcePoolImpl

isRootPartitionGroupEnabled

protected boolean isRootPartitionGroupEnabled(ConnectionEnv ce)

Description copied from class: ConnectionPool

For generic DS (non-RAC) return the state of the connection pool

Overrides:

isRootPartitionGroupEnabled in class ConnectionPool

removeFromAvailableForProcessing

public boolean removeFromAvailableForProcessing(java.util.List<weblogic.common.resourcepool.PooledResource> resources)

Specified by:

removeFromAvailableForProcessing in interface HAJDBCConnectionPool

replayUpdateConnectionState

protected void replayUpdateConnectionState(ConnectionEnv pooledConnection)
                                    throws java.sql.SQLException

Overrides:

replayUpdateConnectionState in class ConnectionPool

Throws:

java.sql.SQLException

doHarvest

private void doHarvest(java.util.List<java.lang.String> instanceNames,
                       boolean draining)

turnOffDraining

private void turnOffDraining(HAJDBCConnectionPool haPool)

switchToRootPartitionAndMakeAvailable

private void switchToRootPartitionAndMakeAvailable(ConnectionEnv ce)

debug

private final void debug(java.lang.String msg)

createConnectionStoreDelegate

protected ConnectionPool.ConnectionStoreDelegate createConnectionStoreDelegate()

Overrides:

createConnectionStoreDelegate in class ConnectionPool

reserveInternalResource

public HAConnectionEnv reserveInternalResource()
                                        throws ResourceException

Description copied from interface: weblogic.jdbc.common.rac.RACModulePool

Returns a connection from the pool for internal use.

Specified by:

reserveInternalResource in interface weblogic.jdbc.common.rac.RACModulePool

Returns:

A connection from the pool for internal use.

Throws:

ResourceException