128 lines
16 KiB
Plaintext
128 lines
16 KiB
Plaintext
|
Êþº¾ 4
|
|||
|
|
org/mariadb/jdbc/pool/Pool addConnectionRequest ()V
|
|||
|
|
logger "Lorg/mariadb/jdbc/util/log/Logger;
|
|||
|
|
pendingRequestNumber +Ljava/util/concurrent/atomic/AtomicInteger; poolTag Ljava/lang/String;
|
|||
|
|
silentCloseConnection (Lorg/mariadb/jdbc/Connection;)V totalConnection idleConnections *Ljava/util/concurrent/LinkedBlockingDeque; poolState
|
|||
|
|
" # $ % java/lang/Object <init> ' )java/util/concurrent/atomic/AtomicInteger
|
|||
|
|
& # * + , conf Lorg/mariadb/jdbc/Configuration;
|
|||
|
|
. / 0 generatePoolTag (I)Ljava/lang/String; 2 'java/util/concurrent/ArrayBlockingQueue
|
|||
|
|
4 5 6 7 8 org/mariadb/jdbc/Configuration maxPoolSize ()I
|
|||
|
|
1 : % ; (I)V = > ? connectionAppenderQueue $Ljava/util/concurrent/BlockingQueue; A 'java/util/concurrent/ThreadPoolExecutor
|
|||
|
|
E F G H I java/util/concurrent/TimeUnit SECONDS Ljava/util/concurrent/TimeUnit; K 'org/mariadb/jdbc/pool/PoolThreadFactory M java/lang/StringBuilder
|
|||
|
|
L #
|
|||
|
|
L P Q R append -(Ljava/lang/String;)Ljava/lang/StringBuilder; T -appender
|
|||
|
|
L V W X toString ()Ljava/lang/String;
|
|||
|
|
J Z % [ (Ljava/lang/String;)V
|
|||
|
|
@ ] % ^ m(IIJLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/BlockingQueue;Ljava/util/concurrent/ThreadFactory;)V ` a b connectionAppender )Ljava/util/concurrent/ThreadPoolExecutor;
|
|||
|
|
@ d e f allowCoreThreadTimeOut (Z)V
|
|||
|
|
@ h i j prestartCoreThread ()Z l (java/util/concurrent/LinkedBlockingDeque
|
|||
|
|
k #
|
|||
|
|
4 o p q nonMappedOptions ()Ljava/util/Properties; s testMinRemovalDelay u 30
|
|||
|
|
w x y z { java/util/Properties getProperty 8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
|
|||
|
|
} ~ € � java/lang/Integer parseInt (Ljava/lang/String;)I
|
|||
|
|
4 ƒ „ 8 maxIdleTime
|
|||
|
|
† ‡ ˆ ‰ Š java/lang/Math min (II)I Œ � Ž poolExecutor 2Ljava/util/concurrent/ScheduledThreadPoolExecutor; � ‘ ’ run 2(Lorg/mariadb/jdbc/pool/Pool;)Ljava/lang/Runnable;
|
|||
|
|
” • – — ˜ 0java/util/concurrent/ScheduledThreadPoolExecutor scheduleAtFixedRate ](Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture; š › œ scheduledFuture &Ljava/util/concurrent/ScheduledFuture;
|
|||
|
|
4 ž Ÿ j registerJmxPool
|
|||
|
|
¡ ¢ registerJmx ¤ java/lang/Exception ¦ pool ¨ # not registered due to exception :
|
|||
|
|
£ ª « X
|
|||
|
|
getMessage ® ¯ ° [ org/mariadb/jdbc/util/log/Logger error
|
|||
|
|
4 ² ³ 8 minPoolSize
|
|||
|
|
† µ ¶ Š max
|
|||
|
|
¸ ¹
|
|||
|
|
addConnection » ¼ ½ waitTimeout I
|
|||
|
|
k ¿ À j isEmpty
|
|||
|
|
k Â Ã Ä getFirst ()Ljava/lang/Object; Æ 0org/mariadb/jdbc/pool/MariaDbInnerPoolConnection
|
|||
|
|
Å È É Ê
|
|||
|
|
getConnection ()Lorg/mariadb/jdbc/Connection;
|
|||
|
|
Ì Í Î Ï Ð org/mariadb/jdbc/Connection createStatement ()Lorg/mariadb/jdbc/Statement; Ò SELECT @@wait_timeout
|
|||
|
|
Ô Õ Ö × Ø org/mariadb/jdbc/Statement executeQuery ((Ljava/lang/String;)Ljava/sql/ResultSet; Ú Û Ü Ý j java/sql/ResultSet next Ú ß à á getInt (I)I
|
|||
|
|
Ô ã ä close æ java/lang/Throwable
|
|||
|
|
å è é ê
|
|||
|
|
addSuppressed (Ljava/lang/Throwable;)V ì java/sql/SQLException î "error initializing pool connection ð ° ñ *(Ljava/lang/String;Ljava/lang/Throwable;)V
|
|||
|
|
& ó ô 8 get � ÷ ø ù ú û "java/util/concurrent/BlockingQueue offer (Ljava/lang/Object;)Z
|
|||
|
|
k ý þ ÿ descendingIterator ()Ljava/util/Iterator; j java/util/Iterator hasNext Ý Ä
|
|||
|
|
|
|||
|
|
java/lang/System nanoTime ()J
|
|||
|
|
Å getLastUsed *()Ljava/util/concurrent/atomic/AtomicLong;
|
|||
|
|
ô &java/util/concurrent/atomic/AtomicLong
|
|||
|
|
E toNanos (J)J
|
|||
|
|
k û remove
|
|||
|
|
& 8 decrementAndGet ! j isDebugEnabled# Qpool {} connection {} removed due to inactivity (total:{}, active:{}, pending:{})
|
|||
|
|
Ì% & getThreadId
|
|||
|
|
()* +, java/lang/Long valueOf (J)Ljava/lang/Long;
|
|||
|
|
}. +/ (I)Ljava/lang/Integer;
|
|||
|
|
1 2 getActiveConnections 4 56 debug ((Ljava/lang/String;[Ljava/lang/Object;)V
|
|||
|
|
89: ;< org/mariadb/jdbc/Driver connect ?(Lorg/mariadb/jdbc/Configuration;)Lorg/mariadb/jdbc/Connection;
|
|||
|
|
Å> % @ org/mariadb/jdbc/pool/Pool$1
|
|||
|
|
?B %C (Lorg/mariadb/jdbc/pool/Pool;)V
|
|||
|
|
ÅE FG addConnectionEventListener &(Ljavax/sql/ConnectionEventListener;)V
|
|||
|
|
&I J 8 incrementAndGet
|
|||
|
|
kL MN addFirst (Ljava/lang/Object;)VP Lpool {} new physical connection {} created (total:{}, active:{}, pending:{})
|
|||
|
|
kR S Ä pollFirst
|
|||
|
|
kU SV 4(JLjava/util/concurrent/TimeUnit;)Ljava/lang/Object; EX Y I NANOSECONDS
|
|||
|
|
E[ \ toMillis
|
|||
|
|
4^ _ 8 poolValidMinDelay
|
|||
|
|
Ìa bc isValid (I)Z
|
|||
|
|
Åe f
|
|||
|
|
lastUsedToNow
|
|||
|
|
h i silentAbortConnectionk bpool {} connection {} removed from pool due to failed validation (total:{}, active:{}, pending:{})
|
|||
|
|
Ìm no setPoolConnection +(Lorg/mariadb/jdbc/MariaDbPoolConnection;)V
|
|||
|
|
Ì ã
|
|||
|
|
Ìr st abort "(Ljava/util/concurrent/Executor;)V 2 Ex y I MICROSECONDS
|
|||
|
|
{ |} getIdleConnection T(JLjava/util/concurrent/TimeUnit;)Lorg/mariadb/jdbc/pool/MariaDbInnerPoolConnection; E € I MILLISECONDS
|
|||
|
|
4‚ ƒ 8 connectTimeout… RNo connection available within the specified time (option 'connectTimeout': %s ms)
|
|||
|
|
‡ˆ‰ Š‹ java/text/NumberFormat getInstance ()Ljava/text/NumberFormat;
|
|||
|
|
‡� Ž� format (J)Ljava/lang/String;
|
|||
|
|
‘’“ Ž” java/lang/String 9(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
|
|||
|
|
ë Z— java/lang/InterruptedException™ Thread was interrupted› 70100
|
|||
|
|
ë� %ž <(Ljava/lang/String;Ljava/lang/String;Ljava/lang/Throwable;)V
|
|||
|
|
4 ¡ X user
|
|||
|
|
‘£ ¤ û equals
|
|||
|
|
‘ ¿
|
|||
|
|
4§ ¨ X password
|
|||
|
|
ª «¬ getPoolConnection 4()Lorg/mariadb/jdbc/pool/MariaDbInnerPoolConnection;
|
|||
|
|
4® ¯° clone F(Ljava/lang/String;Ljava/lang/String;)Lorg/mariadb/jdbc/Configuration;
|
|||
|
|
4² ³ X poolNameµ MariaDB-pool· -
|
|||
|
|
L¹ Qº (I)Ljava/lang/StringBuilder;
|
|||
|
|
¼½¾ C org/mariadb/jdbc/pool/Pools
|
|||
|
|
&À Á ; set ÃÄÅ ÆÇ $java/util/concurrent/ScheduledFuture cancel (Z)Z
|
|||
|
|
@É Ê shutdown
|
|||
|
|
@Ì ÍÎ awaitTermination #(JLjava/util/concurrent/TimeUnit;)Z Ð Ñ j
|
|||
|
|
isInfoEnabledÓ 1closing pool {} (total:{}, active:{}, pending:{})Õ (java/util/concurrent/LinkedBlockingQueue
|
|||
|
|
Ô :Ø
|
|||
|
|
-destroyer
|
|||
|
|
Ú ÛÜ closeAll (Ljava/util/Collection;)V
|
|||
|
|
Þßà áâ java/lang/Thread sleep (JI)V
|
|||
|
|
Eä å toSeconds çÉè $java/util/concurrent/ExecutorService
|
|||
|
|
ê ë
|
|||
|
|
unRegisterJmx çÌ îïð ñ ÿ java/util/Collection iterator î
|
|||
|
|
kô õ 8 size
|
|||
|
|
÷øù úû &java/lang/management/ManagementFactory getPlatformMBeanServer ()Ljavax/management/MBeanServer;ý :ÿ _
|
|||
|
|
‘ replace D(Ljava/lang/CharSequence;Ljava/lang/CharSequence;)Ljava/lang/String; javax/management/ObjectName org.mariadb.jdbc.pool:type=
|
|||
|
|
Z
|
|||
|
|
|
|||
|
|
javax/management/MBeanServer isRegistered (Ljavax/management/ObjectName;)Z
|
|||
|
|
|
|||
|
|
registerMBean R(Ljava/lang/Object;Ljavax/management/ObjectName;)Ljavax/management/ObjectInstance;
|
|||
|
|
unregisterMBean (Ljavax/management/ObjectName;)V java/util/ArrayList
|
|||
|
|
#
|
|||
|
|
kï û java/util/List add! error adding connection to pool
|
|||
|
|
#$% &' !org/mariadb/jdbc/util/log/Loggers getLogger 5(Ljava/lang/Class;)Lorg/mariadb/jdbc/util/log/Logger;) java/lang/AutoCloseable+ org/mariadb/jdbc/pool/PoolMBean
|
|||
|
|
POOL_STATE_OK
|
|||
|
|
ConstantValue POOL_STATE_CLOSING Signature ^Ljava/util/concurrent/LinkedBlockingDeque<Lorg/mariadb/jdbc/pool/MariaDbInnerPoolConnection;>; :Ljava/util/concurrent/BlockingQueue<Ljava/lang/Runnable;>; )Ljava/util/concurrent/ScheduledFuture<*>; V(Lorg/mariadb/jdbc/Configuration;ILjava/util/concurrent/ScheduledThreadPoolExecutor;)V Code LineNumberTable LocalVariableTable ex Ljava/lang/Exception; i rs Ljava/sql/ResultSet; stmt Lorg/mariadb/jdbc/Statement; sqle Ljava/sql/SQLException; this Lorg/mariadb/jdbc/pool/Pool; poolIndex minDelay
|
|||
|
|
scheduleDelay
|
|||
|
|
StackMapTable removeIdleTimeoutConnection idleTime J timedOut Z shouldBeReleased con Lorg/mariadb/jdbc/Connection; item 2Lorg/mariadb/jdbc/pool/MariaDbInnerPoolConnection; Ljava/util/Iterator; LocalVariableTypeTable HLjava/util/Iterator<Lorg/mariadb/jdbc/pool/MariaDbInnerPoolConnection;>;
|
|||
|
|
connection
|
|||
|
|
Exceptions timeout timeUnit poolConnection interrupted Ljava/lang/InterruptedException; X(Ljava/lang/String;Ljava/lang/String;)Lorg/mariadb/jdbc/pool/MariaDbInnerPoolConnection; username tmpConf getConf "()Lorg/mariadb/jdbc/Configuration; connectionRemover &Ljava/util/concurrent/ExecutorService; start
|
|||
|
|
collection Ljava/util/Collection; JLjava/util/Collection<Lorg/mariadb/jdbc/pool/MariaDbInnerPoolConnection;>; M(Ljava/util/Collection<Lorg/mariadb/jdbc/pool/MariaDbInnerPoolConnection;>;)V
|
|||
|
|
getPoolTag getTotalConnections getIdleConnections getConnectionRequests mbs Ljavax/management/MBeanServer; jmxName name Ljavax/management/ObjectName; testGetConnectionIdleThreadIds ()Ljava/util/List; pooledConnection threadIds Ljava/util/List; "Ljava/util/List<Ljava/lang/Long;>; $()Ljava/util/List<Ljava/lang/Long;>; lambda$addConnectionRequest$0
|
|||
|
|
access$000 I(Lorg/mariadb/jdbc/pool/Pool;)Ljava/util/concurrent/atomic/AtomicInteger; x0
|
|||
|
|
access$100 H(Lorg/mariadb/jdbc/pool/Pool;)Ljava/util/concurrent/LinkedBlockingDeque;
|
|||
|
|
access$200
|
|||
|
|
access$300 <(Lorg/mariadb/jdbc/pool/Pool;Lorg/mariadb/jdbc/Connection;)V x1
|
|||
|
|
access$400 0(Lorg/mariadb/jdbc/pool/Pool;)Ljava/lang/String;
|
|||
|
|
access$500
|
|||
|
|
access$600 $()Lorg/mariadb/jdbc/util/log/Logger;
|
|||
|
|
access$700 <clinit>
|
|||
|
|
SourceFile Pool.java BootstrapMethods Ž
|