Edit D:\app\Administrator\product\11.2.0\dbhome_1\ucp\lib\oracle\ucp\common\UniversalConnectionPoolImpl$UniversalConnectionPoolInternal.class
?? 1? ?T ?U ?V ?W ?X ?Y ?Z ?[ ?\ ?] ?^ ?_ ?` ?a ?b ?c ?d ?e ?f ?g ?h ?i ?j ?k ?l ?m ?n ?o ?p ?q ?r st ?u ?v wxy z{| &} ~ ~? ~? ? ?? ~?? .r??????? ? ??? ?? z? ??? :r ?? ?? ? ?????????? ?? ?? ?? ??? ?? 2? ?? 2? ???? ?? 2? ?? ~? 2??? ??????? ?? ?? ?? ??? \r?????? ?? ?? 2? 2? ?????? ?????? ?? ?? ? ?? ?? 2? ?? 2???? z? ??? ??? z? ?? ???? ?? ?? ?? ?? ??? ?? ????? ?r? ???? ?? 2??? ~??? ~? ???? ????? w??? m_cp /Loracle/ucp/common/UniversalConnectionPoolImpl; m_connectionsContainer (Loracle/ucp/common/ConnectionsContainer; m_connectionsHarvestable Ljava/util/Map; Signature ILjava/util/Map<Ljava/lang/Object;Loracle/ucp/UniversalPooledConnection;>; m_connectionsNonHarvestable m_availableConnections (Loracle/ucp/common/AvailableConnections; REPLACE_CONNECTION_NOW I ConstantValue REPLACE_INVALID_CONNECTION $assertionsDisabled Z <init> 2(Loracle/ucp/common/UniversalConnectionPoolImpl;)V Code LineNumberTable LocalVariableTable ucpe -Loracle/ucp/UniversalConnectionPoolException; this UniversalConnectionPoolInternal InnerClasses OLoracle/ucp/common/UniversalConnectionPoolImpl$UniversalConnectionPoolInternal; cp Exceptions )getCollectionAvailableConnectionsInternal *()Loracle/ucp/common/AvailableConnections; )setCollectionAvailableConnectionsInternal +(Loracle/ucp/common/AvailableConnections;)V availableConnections createCollectionInternal ()Ljava/util/Collection; 'getAvailablePhysicalConnectionsInternal <(Loracle/ucp/ConnectionRetrievalInfo;)Ljava/util/Collection; connectionRetrievalInfo $Loracle/ucp/ConnectionRetrievalInfo; getInUseConnectionsArrayInternal )()[Loracle/ucp/UniversalPooledConnection; conns '[Loracle/ucp/UniversalPooledConnection; !createOnePooledConnectionInternal L(Loracle/ucp/ConnectionRetrievalInfo;)Loracle/ucp/UniversalPooledConnection; storedCRI numAvailableConnections e pooledConnection &Loracle/ucp/UniversalPooledConnection; cfa %Loracle/ucp/ConnectionFactoryAdapter; connection Ljava/lang/Object; ,removeAndCloseOneAvailableConnectionInternal )(Loracle/ucp/UniversalPooledConnection;)V cpc physicalConnection wasInitiallyClosed $removeOneAvailableConnectionInternal cri !getValidAvailableConnectionHelper M(Loracle/ucp/ConnectionRetrievalInfo;Z)Loracle/ucp/UniversalPooledConnection; currentLabels Ljava/util/Properties; currentLabelingCost needValidateOnBorrow validateResult status ,Loracle/ucp/UniversalPooledConnectionStatus; conn i$ Ljava/util/Iterator; connsToClose Ljava/util/List; isRetryForLabeledRequest Ljava/util/Collection; num requestedLabels isLabeledRequest lowestLabelingCost pc LocalVariableTypeTable 8Ljava/util/List<Loracle/ucp/UniversalPooledConnection;>; >Ljava/util/Collection<Loracle/ucp/UniversalPooledConnection;>; #getValidAvailableConnectionInternal criNoLabels closeConnectionInternal removedConnection closePhysically purgeInternal ()V arr$ len$ borrowedConnsToClose refreshInternal i recycleInternal doForEveryAvailableConnection (I)V task #processConnectionHarvestingInternal thisLocker harvestNumRequested connectionHarvestTriggerCount setConnectionHarvestableInternal *(Loracle/ucp/UniversalPooledConnection;Z)V isConnectionHarvestable wasHarvestable !addOneAvailableConnectionInternal $getAvailableConnectionsCountInternal ()I #getBorrowedConnectionsCountInternal getAvailableConnectionsInternal !getAllBorrowedConnectionsInternal discardUsedConnectionInternal (Ljava/lang/Object;)V getUsedConnectionInternal :(Ljava/lang/Object;)Loracle/ucp/UniversalPooledConnection; $returnUsedPhysicalConnectionInternal (Ljava/lang/Object;)Z #closeUsedPhysicalConnectionInternal "getLabeledConnectionsCountInternal? c(Loracle/ucp/common/UniversalConnectionPoolImpl;Loracle/ucp/common/UniversalConnectionPoolImpl$1;)V x0 x1 1Loracle/ucp/common/UniversalConnectionPoolImpl$1; access$100 x(Loracle/ucp/common/UniversalConnectionPoolImpl$UniversalConnectionPoolInternal;)[Loracle/ucp/UniversalPooledConnection; access$200 y(Loracle/ucp/common/UniversalConnectionPoolImpl$UniversalConnectionPoolInternal;)Loracle/ucp/common/ConnectionsContainer; access$300 y(Loracle/ucp/common/UniversalConnectionPoolImpl$UniversalConnectionPoolInternal;)Loracle/ucp/common/AvailableConnections; access$400 `(Loracle/ucp/common/UniversalConnectionPoolImpl$UniversalConnectionPoolInternal;)Ljava/util/Map; access$500 access$600 ?(Loracle/ucp/common/UniversalConnectionPoolImpl$UniversalConnectionPoolInternal;Loracle/ucp/ConnectionRetrievalInfo;)Loracle/ucp/UniversalPooledConnection; access$700 x(Loracle/ucp/common/UniversalConnectionPoolImpl$UniversalConnectionPoolInternal;Loracle/ucp/UniversalPooledConnection;)V access$800 access$1000 R(Loracle/ucp/common/UniversalConnectionPoolImpl$UniversalConnectionPoolInternal;)V access$1100 access$1200 access$1300 access$1400 y(Loracle/ucp/common/UniversalConnectionPoolImpl$UniversalConnectionPoolInternal;Loracle/ucp/UniversalPooledConnection;Z)V x2 access$1500 access$1600 R(Loracle/ucp/common/UniversalConnectionPoolImpl$UniversalConnectionPoolInternal;)I access$1700 access$1800 access$1900 access$2000 d(Loracle/ucp/common/UniversalConnectionPoolImpl$UniversalConnectionPoolInternal;Ljava/lang/Object;)V access$2100 ?(Loracle/ucp/common/UniversalConnectionPoolImpl$UniversalConnectionPoolInternal;Ljava/lang/Object;)Loracle/ucp/UniversalPooledConnection; access$2200 d(Loracle/ucp/common/UniversalConnectionPoolImpl$UniversalConnectionPoolInternal;Ljava/lang/Object;)Z access$2300 access$2400 access$2500 z(Loracle/ucp/common/UniversalConnectionPoolImpl$UniversalConnectionPoolInternal;Loracle/ucp/common/AvailableConnections;)V access$2600 access$2700 access$2800 ?(Loracle/ucp/common/UniversalConnectionPoolImpl$UniversalConnectionPoolInternal;Loracle/ucp/ConnectionRetrievalInfo;)Ljava/util/Collection; access$2900 g(Loracle/ucp/common/UniversalConnectionPoolImpl$UniversalConnectionPoolInternal;)Ljava/util/Collection; access$3000 ?(Loracle/ucp/common/UniversalConnectionPoolImpl$UniversalConnectionPoolInternal;)Loracle/ucp/common/UniversalConnectionPoolImpl; <clinit> SourceFile UniversalConnectionPoolImpl.java ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ???????? constructor: Ooracle/ucp/common/UniversalConnectionPoolImpl$UniversalConnectionPoolInternal$1 ? ? ? java/util/HashSet ? ? $oracle/ucp/UniversalPooledConnection in use connections: {0} ? ? java/lang/AssertionError !"#$%&'()*+ ?,-./0 +oracle/ucp/UniversalConnectionPoolException12345 ?6789:;<=(>?@A ?BC9 ?D ?EF GHIJKJ java/util/ArrayListLMNO P3Q ?R S T&UVWXYZ[\]^_` ? ? ?a bcdefgfhij kl connection closedmno ?p ? purgedqnr ? refreshed recycled ?s ?tuvw Ooracle/ucp/common/UniversalConnectionPoolImpl$UniversalConnectionPoolInternal$2 ?xyz{|} java/lang/StringBuilder connection is now ~ harvestable non-harvestable?? ???? ???l? ?? -oracle/ucp/common/UniversalConnectionPoolImpl? Moracle/ucp/common/UniversalConnectionPoolImpl$UniversalConnectionPoolInternal java/lang/Object /oracle/ucp/common/UniversalConnectionPoolImpl$1 oracle/ucp/util/UCPErrorHandler #newUniversalConnectionPoolException 0(I)Loracle/ucp/UniversalConnectionPoolException; access$900 ()Ljava/util/logging/Logger; getClass ()Ljava/lang/Class; java/lang/Class getName ()Ljava/lang/String; java/util/logging/Logger throwing <(Ljava/lang/String;Ljava/lang/String;Ljava/lang/Throwable;)V ?(Loracle/ucp/common/UniversalConnectionPoolImpl$UniversalConnectionPoolInternal;Loracle/ucp/common/UniversalConnectionPoolImpl;)V &oracle/ucp/common/ConnectionsContainer getHarvestableConnections ()Ljava/util/Map; getNonHarvestableConnections getAvailableConnections isLifecycleStopped ()Z setAvailableConnections &oracle/ucp/common/AvailableConnections java/util/Map values java/util/Collection toArray (([Ljava/lang/Object;)[Ljava/lang/Object; java/util/logging/Level FINEST Ljava/util/logging/Level; java/lang/Integer valueOf (I)Ljava/lang/Integer; log @(Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Object;)V isLifecycleStarting isLifecycleRunning getConnectionFactoryAdapter '()Loracle/ucp/ConnectionFactoryAdapter; #oracle/ucp/ConnectionFactoryAdapter createConnection 8(Loracle/ucp/ConnectionRetrievalInfo;)Ljava/lang/Object; "oracle/ucp/ConnectionRetrievalInfo getLabels ()Ljava/util/Properties; getCopyWithNoLabels &()Loracle/ucp/ConnectionRetrievalInfo; createPooledConnection ^(Ljava/lang/Object;Loracle/ucp/ConnectionRetrievalInfo;)Loracle/ucp/UniversalPooledConnection; incrementConnectionsCreatedCount getAvailableConnectionsCount m_cumulativeConnectionsCreated +Ljava/util/concurrent/atomic/AtomicInteger; )java/util/concurrent/atomic/AtomicInteger incrementAndGet closePhysicalConnection getPhysicalConnection ()Ljava/lang/Object; *oracle/ucp/UniversalPooledConnectionStatus STATUS_CLOSED getStatus .()Loracle/ucp/UniversalPooledConnectionStatus; equals removeAvailableConnection )(Loracle/ucp/UniversalPooledConnection;)Z m_borrowRequestQueue &Loracle/ucp/common/BorrowRequestQueue; getConnectionRetrievalInfo $oracle/ucp/common/BorrowRequestQueue notifyAvailable '(Loracle/ucp/ConnectionRetrievalInfo;)V m_allConnections setStatus /(Loracle/ucp/UniversalPooledConnectionStatus;)V getAvailablePhysicalConnections size isRuntimeLoadBalancingEnabled getConnectionAffinityCallback )()Loracle/ucp/ConnectionAffinityCallback; 2selectConnectionPerRuntimeLoadBalancingAndAffinity >(Ljava/util/Collection;)Loracle/ucp/UniversalPooledConnection; 'selectConnectionPerRuntimeLoadBalancing iterator ()Ljava/util/Iterator; java/util/Iterator hasNext next STATUS_NORMAL getValidateConnectionOnBorrow isValid getConnectionLabels getConnectionLabelingCallback )()Loracle/ucp/ConnectionLabelingCallback; %oracle/ucp/ConnectionLabelingCallback cost /(Ljava/util/Properties;Ljava/util/Properties;)I java/util/List add 'closeAvailableConnectionsAsynchronously (Ljava/util/List;)V configure +(Ljava/util/Properties;Ljava/lang/Object;)Z addAvailableConnection isLifecycleFailed m_cumulativeConnectionUseTime (Ljava/util/concurrent/atomic/AtomicLong; java/lang/System currentTimeMillis ()J getBorrowedStartTime &java/util/concurrent/atomic/AtomicLong getAndAdd (J)J remove &(Ljava/lang/Object;)Ljava/lang/Object; finest (Ljava/lang/String;)V closeAllConnections getAllBorrowedConnections fine STATUS_REPLACE_ON_RETURN $removeAndCloseOneAvailableConnection addNewConnections ((Loracle/ucp/ConnectionRetrievalInfo;I)V getConnectionHarvestTriggerCount getConnectionHarvestMaxCount e(Loracle/ucp/common/UniversalConnectionPoolImpl$UniversalConnectionPoolInternal;Ljava/lang/Object;I)V -oracle/ucp/common/UniversalConnectionPoolBase submitWTPTask 4(Loracle/ucp/util/Task;)Loracle/ucp/util/TaskHandle; put 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; append -(Ljava/lang/String;)Ljava/lang/StringBuilder; toString setAvailableStartTime getNumAvailableConnections getBorrowedConnectionsCount getAllAvailableConnections getUsedConnection get returnConnection !getNumAvailableLabeledConnections desiredAssertionStatus 0 ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ; ? ? ? ? T*? +? 6? M? !*? "? #$,? %,?*+? *? &Y*+? '? **? ? (? **? ? )? **? ? *? ? ? . ? ? ? ? ? ? %? 2? =? H? S? ? ? ? T ? ? T ? ? ? H ? ? ? / *? ? ? ? ? ? ? ? ? ? ? L+? 9? M? !*? "? #+,? %,?*? ? ,? >? M? !*? "? #+,? %,?*? +? -*+? ? ? . ? ? ? ? ? &? ,? <? >? F? K? ? * ? ? , ? ? L ? ? L ? ? ? H ? ? ? 2 ? .Y? /? ? ? ? ? ? ? ? ? ? *? +? 0 ? ? ? ? ? ? ? ? ? ? d (*? ? 1 ? 2? 3 ? 4L? !? 56+? 7? 8+? ? & ? ( ? ? ? ? ? ? ? ? ? 9? +? ? :Y? ;?M*? ? <? %*? ? =? =? N? !*? "? #>-? %-?*? ? ?N-+? @ :? d? :? !*? "? #>? %?*? Y:?+? A ? +:? +? B :-? C M*? ? D*? ? E6*? ? F? GW? :?? ":*? ? I? !*? "? #>? %?,? y ? ? ? ? ? q ? ? H ? n 9 ; = (? .A >C @I HM QO VQ ]S nU qZ y^ ?` ?e ?h ?k ?m ?n ?o ?w ?q ?s ?t ?v ?y ? p . ? ? ] ? ? ? ? ? ? &