Edit D:\app\Administrator\product\11.2.0\dbhome_1\ucp\lib\oracle\ucp\common\UniversalConnectionPoolBase.class
?? 1] ?9 ?: ?; ?< ?=> ?? @ ?AB C ?D ?EF G ?H??? ?I ?J ?K ?L ?M ?N ?O ?P ?Q ?RS T ?U ?V ?W ?X ?Y ?Z ?[ ?\ ?] ?^ ?_`a )b )c ?d ?e ?f ?g ?h = ?i ?j ?k ?l = ?m ?n ?o ?p ?qr == ?s tu ?v wxy z{ ?|}~ ??? ?? ?? ??m ?? ??z ?? ?? ??? ??? ?? ?? ?? ?? ?? ?? ?? ?? ??? ?? ?? z? ???i ?? ?? ?? ?? ?? ?? ????? ? ??? z? ?? ?? ??? ?? ??? ?? z??? z? ?? ??????? ? ??}?? ???? ??? ?? ??? ??????????????? ???? ????????? ?? ?? ????? ?????????? ???? ????????? ????? ?? ?? ????? ? ? ?? ??? ???????? ? ?= ? ?c ?? ?? ? ? ? ? w logger Ljava/util/logging/Logger; DEFAULT_INITIAL_POOL_SIZE I ConstantValue DEFAULT_MIN_POOL_SIZE DEFAULT_MAX_POOL_SIZE #DEFAULT_INACTIVE_CONNECTION_TIMEOUT DEFAULT_TIMEOUT_CHECK_INTERVAL $DEFAULT_ABANDONED_CONNECTION_TIMEOUT DEFAULT_CONNECTION_WAIT_TIMEOUT 'DEFAULT_TIME_TO_LIVE_CONNECTION_TIMEOUT $DEFAULT_VALIDATE_BORROWED_CONNECTION Z (DEFAULT_CONNECTION_HARVEST_TRIGGER_COUNT $DEFAULT_CONNECTION_HARVEST_MAX_COUNT DEFAULT_POOLNAME_PREFIX Ljava/lang/String; m_lifeCycleState -Ljava/util/concurrent/atomic/AtomicReference; Signature aLjava/util/concurrent/atomic/AtomicReference<Loracle/ucp/UniversalConnectionPoolLifeCycleState;>; m_initialPoolSize +Ljava/util/concurrent/atomic/AtomicInteger; m_minPoolSize m_skipPoolGrowing +Ljava/util/concurrent/atomic/AtomicBoolean; m_maxPoolSize m_inactiveConnectionTimeout m_timeoutCheckInterval m_abandonedConnectionTimeout m_connectionWaitTimeout m_numConnectionsCreated m_numConnectionsClosed m_timeToLiveConnectionTimeout m_validateConnectionOnBorrow m_connectionHarvestTriggerCount m_maxConnectionReuseTime (Ljava/util/concurrent/atomic/AtomicLong; m_maxConnectionReuseCount m_connectionHarvestMaxCount m_connectionFactoryAdapter %Loracle/ucp/ConnectionFactoryAdapter; m_defaultConnectionRetrievalInfo $Loracle/ucp/ConnectionRetrievalInfo; m_connectionLabelingCallback 'Loracle/ucp/ConnectionLabelingCallback; m_connectionAffinityCallback 'Loracle/ucp/ConnectionAffinityCallback; m_abandonedConnectionTimer Loracle/ucp/util/TimerHandle; m_inactiveConnectionTimer m_timeToLiveConnectionTimer m_connectionHarvestTimer m_failoverEnabled m_poolName m_abandonedConnectionsCount #m_cumulativeReturnedConnectionCount #m_cumulativeConnectionBorrowedCount )m_cumulativeSuccessfulConnectionWaitCount %m_cumulativeFailedConnectionWaitCount m_peakConnectionsCount m_cumulativeConnectionsCreated (m_cumulativeSuccessfulConnectionWaitTime $m_cumulativeFailedConnectionWaitTime m_peakConnectionWaitTime m_pendingRequestsCount m_cumulativeConnectionUseTime !m_averageBorrowedConnectionsCount !m_averageBorrowedConnectionsTimer $m_replaceNonReusableConnectionsTimer THREAD_POOL_SIZE m_poolsRunning m_borrowRequestQueue &Loracle/ucp/common/BorrowRequestQueue; <init> ((Loracle/ucp/ConnectionFactoryAdapter;)V Code LineNumberTable LocalVariableTable ucpe -Loracle/ucp/UniversalConnectionPoolException; this /Loracle/ucp/common/UniversalConnectionPoolBase; connectionFactoryAdapter Exceptions submitWTPTask 4(Loracle/ucp/util/Task;)Loracle/ucp/util/TaskHandle; task Loracle/ucp/util/Task; getInUseConnectionsArray )()[Loracle/ucp/UniversalPooledConnection; borrowConnection L(Loracle/ucp/ConnectionRetrievalInfo;)Loracle/ucp/UniversalPooledConnection; createOnePooledConnection returnConnection )(Loracle/ucp/UniversalPooledConnection;)V closeConnection addOneAvailableConnection $removeAndCloseOneAvailableConnection purge ()V refresh recycle getInitialConnections initialPoolSize growPool (I)V (ILjava/util/List;)V :(ILjava/util/List<Loracle/ucp/ConnectionRetrievalInfo;>;)V reducePool addNewConnections ((Loracle/ucp/ConnectionRetrievalInfo;I)V reconfigure (Ljava/util/Properties;)V props Ljava/util/Properties; start e1 Ljava/lang/Exception; e stop wasRunning resetAllPoolStatistics resetNonCumulativePoolStatistics getName ()Ljava/lang/String; setName (Ljava/lang/String;)V name getInitialPoolSize ()I setInitialPoolSize getMinPoolSize setMinPoolSize minPoolSize getMaxPoolSize setMaxPoolSize maxPoolSize oldMaxPoolSize closePhysicalConnection (Ljava/lang/Object;)V connectionPoolException physicalConnection Ljava/lang/Object; getAvailableConnections getInactiveConnectionTimeout processInactiveConnections cutoffTime J thisLocker "initInactiveConnectionTimeoutTimer exc %disableInactiveConnectionTimeoutTimer setInactiveConnectionTimeout inactiveConnectionTimeout getInactiveConnectionTimer ()Loracle/ucp/util/TimerHandle; getConnectionWaitTimeout setConnectionWaitTimeout waitTimeout getTimeToLiveConnectionTimeout processTimeToLiveTimeout $initTimeToLiveConnectionTimeoutTimer 'disableTimeToLiveConnectionTimeoutTimer setTimeToLiveConnectionTimeout timeToLiveConnectionTimeout getTimeToLiveConnectionTimer getTimeoutCheckInterval setTimeoutCheckInterval timeoutCheckInterval getValidateConnectionOnBorrow ()Z setValidateConnectionOnBorrow (Z)V validateConnectionOnBorrow getConnectionHarvestTriggerCount setConnectionHarvestTriggerCount connectionHarvestTriggerCount getConnectionHarvestMaxCount setConnectionHarvestMaxCount connectionHarvestMaxCount getConnectionsCreatedCount incrementConnectionsCreatedCount getConnectionsClosedCount incrementConnectionsClosedCount getAvailableConnectionsCount getBorrowedConnectionsCount getTotalConnectionsCount getStatistics 0()Loracle/ucp/UniversalConnectionPoolStatistics; getLifeCycleState 4()Loracle/ucp/UniversalConnectionPoolLifeCycleState; getConnectionFactoryAdapter '()Loracle/ucp/ConnectionFactoryAdapter; getConnectionRetrievalInfo &()Loracle/ucp/ConnectionRetrievalInfo; setConnectionRetrievalInfo '(Loracle/ucp/ConnectionRetrievalInfo;)V defaultConnectionRetrievalInfo "registerConnectionLabelingCallback *(Loracle/ucp/ConnectionLabelingCallback;)V cbk removeConnectionLabelingCallback "registerConnectionAffinityCallback *(Loracle/ucp/ConnectionAffinityCallback;)V removeConnectionAffinityCallback getConnectionAffinityCallback )()Loracle/ucp/ConnectionAffinityCallback; getAbandonedConnectionTimeout processAbandonedConnections processTimedOutConnection pc &Loracle/ucp/UniversalPooledConnection; #initAbandonedConnectionTimeoutTimer validatePoolSizes &disableAbandonedConnectionTimeoutTimer setAbandonedConnectionTimeout abandonedConnectionTimeout getAbandonedConnectionTimer processConnectionHarvesting getAllBorrowedConnections initConnectionHarvestingTimer disableConnectionHarvestingTimer #initAverageBorrowedConnectionsTimer AVERAGER_SAMPLE_INTERVAL %cancelAverageBorrowedConnectionsTimer &initReplaceNonReusableConnectionsTimer reuseTime timerInterval (cancelReplaceNonReusableConnectionsTimer setConnectionHarvestable *(Loracle/ucp/UniversalPooledConnection;Z)V isFailoverEnabled startFailover failoverEventHandlerThread .Loracle/ucp/common/FailoverEventHandlerThread; stopFailover Ljava/lang/InterruptedException; getFailoverEventHandlerThread 0()Loracle/ucp/common/FailoverEventHandlerThread; setFailoverEnabled failoverEnabled getMaxConnectionReuseTime ()J setMaxConnectionReuseTime (J)V maxConnectionReuseTime getMaxConnectionReuseCount setMaxConnectionReuseCount maxConnectionReuseCount replaceNonReusableConnections $replaceNonReusableConnectionsWithWTP isRuntimeLoadBalancingEnabled setRuntimeLoadBalancingEnabled RLBEnabled discardUsedConnection getUsedConnection :(Ljava/lang/Object;)Loracle/ucp/UniversalPooledConnection; returnUsedPhysicalConnection (Ljava/lang/Object;)Z closeUsedPhysicalConnection setFailoverInfo info getFailoverInfo ()Ljava/lang/Object; handleFailoverEvent $(Loracle/ucp/common/FailoverEvent;)V event !Loracle/ucp/common/FailoverEvent; getAbandonedConnectionsCount getPendingRequestsCount $getCumulativeConnectionReturnedCount *getCumulativeSuccessfulConnectionWaitCount &getCumulativeFailedConnectionWaitCount )getCumulativeSuccessfulConnectionWaitTime %getCumulativeFailedConnectionWaitTime $getCumulativeConnectionBorrowedCount getPeakConnectionWaitTime getCumulativeConnectionUseTime getPeakConnectionsCount getCumulativeConnectionsCreated "getAverageBorrowedConnectionsCount getLabeledConnectionsCount isLifecycleRunning isLifecycleStarting isLifecycleStopping isLifecycleStopped isLifecycleFailed setLifecycleFailed setLifecycleStarting setLifecycleStopping setLifecycleRunning setLifecycleStopped getConnectionLabelingCallback )()Loracle/ucp/ConnectionLabelingCallback; $getCumulativeReturnedConnectionCount access$000 ()Ljava/util/logging/Logger; access$100 \(Loracle/ucp/common/UniversalConnectionPoolBase;)Ljava/util/concurrent/atomic/AtomicInteger; x0 access$400 access$500 2(Loracle/ucp/common/UniversalConnectionPoolBase;)V <clinit> SourceFile UniversalConnectionPoolBase.javajH< Pj +java/util/concurrent/atomic/AtomicReferenceP? )java/util/concurrent/atomic/AtomicIntegerPp )java/util/concurrent/atomic/AtomicBooleanP? !"#$%&'( &java/util/concurrent/atomic/AtomicLongP?)*+,/0123456768696: oracle/ucp/util/UniqueIdentifier UniversalConnectionPool-P??;=*>*?*@*ABC*D*E*FG*I6J6 $oracle/ucp/common/BorrowRequestQueueNO !"#$?? UniversalConnectionPoolBase%&'-.()*+,-./\?j??tu$?%?'jM0?zj123?j?j?j?j?j?j???jmj +oracle/ucp/UniversalConnectionPoolException&j45678ij java/lang/Exception?j?j?j?j?j?j9?~j:p)j !universal connection pool started;?!?(j?j calling stopFailover()?j*j !universal connection pool stopped:? +all pool statistics metrics have been reset<? 6non-cumulative pool statistics metrics have been reset PoolName: {0}7=>? InitialPoolSize: {0}?@A MinPoolSize: {0} MaxPoolSize: {0}BCspf? calling CFA closeConnection()?j closed physical connection processing inactive connectionsDE? /oracle/ucp/common/UniversalConnectionPoolBase$1 InnerClassesPF[\ -oracle/ucp/common/InactiveConnectionTimerTaskP5GH -inactive connection timeout timer initializedIJj *inactive connection timeout timer disabled InactiveConnectionTimeout: {0} ConnectionWaitTimeout: {0} &processing TimeToLiveConnectionTimeout /oracle/ucp/common/UniversalConnectionPoolBase$2 &TTL connection timeout timer processed /oracle/ucp/common/TimeToLiveConnectionTimerTask (TTL connection timeout timer initialized %TTL connection timeout timer disabled TimeToLiveConnectionTimeout: {0} TimeoutCheckInterval: {0}>? ValidateConnectionOnBorrow: {0}K@L:? "ConnectionHarvestTriggerCount: {0} ConnectionHarvestMaxCount: {0}> 0oracle/ucp/UniversalConnectionPoolLifeCycleState ConnectionRetrievalInfo: {0} ConnectionLabelingCallback: {0} $connection labeling callback removed ConnectionAffinityCallback: {0} $connection affinity callback removed processing abandoned connections /oracle/ucp/common/UniversalConnectionPoolBase$3 abandoned connections processed .oracle/ucp/common/AbandonedConnectionTimerTask .abandoned connection timeout timer initialized +abandoned connection timeout timer disabled AbandonedConnectionTimeout: {0} /oracle/ucp/common/ConnectionHarvestingTimerTask 'connection harvesting timer initialized $connection harvesting timer disabled /oracle/ucp/common/UniversalConnectionPoolBase$4MH -average borrowed connection timer initialized +average borrowed connection timer cancelled>? /oracle/ucp/common/UniversalConnectionPoolBase$5 2replace non-reusable connections timer initialized 0replace non-reusable connections timer cancelled??NO? failover startedPj java/lang/InterruptedException failover thread interrupted failover stopped FailoverEnabled: {0}kj java/lang/StringBuilder failover QR enabled disabled MaxConnectionReuseTime: {0}S@T MaxConnectionReuseCount: {0} /oracle/ucp/common/UniversalConnectionPoolBase$6UVWX:? -oracle/ucp/common/UniversalConnectionPoolBaseY?Z[\ java/lang/Object "oracle/ucp/UniversalConnectionPool oracle/ucp/common/Failoverable LIFE_CYCLE_STOPPED 2Loracle/ucp/UniversalConnectionPoolLifeCycleState; toString oracle/ucp/util/UCPErrorHandler #newUniversalConnectionPoolException 0(I)Loracle/ucp/UniversalConnectionPoolException; getClass ()Ljava/lang/Class; java/lang/Class java/util/logging/Logger throwing <(Ljava/lang/String;Ljava/lang/String;Ljava/lang/Throwable;)V #oracle/ucp/ConnectionFactoryAdapter setUniversalConnectionPool '(Loracle/ucp/UniversalConnectionPool;)V 3oracle/ucp/admin/UniversalConnectionPoolManagerBase getTaskManager ()Loracle/ucp/util/TaskManager; oracle/ucp/util/TaskManager submitTask incrementAndGet getTimerManager ()Loracle/ucp/util/TimerManager; oracle/ucp/util/TimerManager java/util/logging/Level FINEST Ljava/util/logging/Level; log C(Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Throwable;)V getAndDecrement set fine finest @(Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Object;)V get java/lang/Integer valueOf (I)Ljava/lang/Integer; getAndSet (I)I java/lang/System currentTimeMillis E(Loracle/ucp/common/UniversalConnectionPoolBase;Ljava/lang/Object;J)V schedule <(Loracle/ucp/util/TimerTask;JJ)Loracle/ucp/util/TimerHandle; oracle/ucp/util/TimerHandle cancel java/lang/Boolean (Z)Ljava/lang/Boolean; scheduleAtFixedRate ,oracle/ucp/common/FailoverEventHandlerThread setTerminate join append -(Ljava/lang/String;)Ljava/lang/StringBuilder; java/lang/Long (J)Ljava/lang/Long; LIFE_CYCLE_RUNNING LIFE_CYCLE_STARTING LIFE_CYCLE_STOPPING LIFE_CYCLE_FAILED getCanonicalName (oracle/ucp/util/logging/UCPLoggerFactory createLogger .(Ljava/lang/String;)Ljava/util/logging/Logger;! ? ? ? ? : * ! " # $ % & ' ( )* + , -. /0 12 34 56 76 86 96 : ; < =* >* ?* @* A B C* D* E* F G* H I6 J6 K L M NO ? PQ R ? ?*? *? Y? ? ? *? Y? ? *? Y? ? *? Y? ? *? Y? ? *? *? *? *? Y? ? *? Y? ? *? Y? ? *? *? Y? ? *? Y? ? *? Y ? ? *? Y? ? *? Y? ? *? !*? "*? #*? $*? %*? &*? '*? (*? )Y*? +? ,? -*? Y? ? *? Y ? ? .*? Y ? ? /*? Y ? ? 0*? Y ? ? 1*? Y? 2? 3*? Y? 2? 4*? Y ? ? 5*? Y ? ? 6*? Y? 7? 8*? Y? ? 9*? Y ? ? :*? Y? ? *? ;*? <*? =Y? >? ?+? h? @M? *? A? BC,? D,?*+? E*? E*? F ? S ? 2 v ? ? ? * ? 6 ? C ? H ? N ? S ? _ ? k ? w ? | ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?"