Edit D:\rfid\ACS\sip2server\sip2server\lib\org\apache\http\pool\AbstractConnPool.class
?? 2 ?9 ?:; <=> ??@ <A ?BC ?DE : ?FG : ?HI : ?JK : ?L ?M ?N ?OPQ RSTSUV WXRYZ[R\ $]Y^X^ ^P_Y`a +bYcde fgh 1i ?jk lm no 4p ?q $r s ?t u ?v w x $yXz ?{ ?| $} ~ $? $?X? ? ? ? ? ? $? $? z \? $? 4??? T?Xx ? ?? $? ?? \?? ^?? ^?? b? $? $? $?Y? ? R??S? ??XRY?? o??? r? ??? u?? w:? w? w???? w? ?????? InnerClasses lock !Ljava/util/concurrent/locks/Lock; connFactory "Lorg/apache/http/pool/ConnFactory; Signature *Lorg/apache/http/pool/ConnFactory<TT;TC;>; routeToPool Ljava/util/Map; GLjava/util/Map<TT;Lorg/apache/http/pool/RouteSpecificPool<TT;TC;TE;>;>; leased Ljava/util/Set; Ljava/util/Set<TE;>; available Ljava/util/LinkedList; Ljava/util/LinkedList<TE;>; pending CLjava/util/LinkedList<Lorg/apache/http/pool/PoolEntryFuture<TE;>;>; maxPerRoute 'Ljava/util/Map<TT;Ljava/lang/Integer;>; isShutDown Z defaultMaxPerRoute I maxTotal validateAfterInactivity <init> '(Lorg/apache/http/pool/ConnFactory;II)V Code LineNumberTable LocalVariableTable this 'Lorg/apache/http/pool/AbstractConnPool; LocalVariableTypeTable 2Lorg/apache/http/pool/AbstractConnPool<TT;TC;TE;>; /(Lorg/apache/http/pool/ConnFactory<TT;TC;>;II)V createEntry F(Ljava/lang/Object;Ljava/lang/Object;)Lorg/apache/http/pool/PoolEntry; (TT;TC;)TE; onLease #(Lorg/apache/http/pool/PoolEntry;)V entry Lorg/apache/http/pool/PoolEntry; TE; (TE;)V onRelease onReuse validate #(Lorg/apache/http/pool/PoolEntry;)Z (TE;)Z isShutdown ()Z shutdown ()V i$ Ljava/util/Iterator; pool (Lorg/apache/http/pool/RouteSpecificPool; 3Lorg/apache/http/pool/RouteSpecificPool<TT;TC;TE;>; StackMapTable?? Exceptions? getPool <(Ljava/lang/Object;)Lorg/apache/http/pool/RouteSpecificPool; route Ljava/lang/Object; TT;\ 8(TT;)Lorg/apache/http/pool/RouteSpecificPool<TT;TC;TE;>; lease n(Ljava/lang/Object;Ljava/lang/Object;Lorg/apache/http/concurrent/FutureCallback;)Ljava/util/concurrent/Future; state callback +Lorg/apache/http/concurrent/FutureCallback; 0Lorg/apache/http/concurrent/FutureCallback<TE;>; i(TT;Ljava/lang/Object;Lorg/apache/http/concurrent/FutureCallback<TE;>;)Ljava/util/concurrent/Future<TE;>; C(Ljava/lang/Object;Ljava/lang/Object;)Ljava/util/concurrent/Future; 9(TT;Ljava/lang/Object;)Ljava/util/concurrent/Future<TE;>; getPoolEntryBlocking ?(Ljava/lang/Object;Ljava/lang/Object;JLjava/util/concurrent/TimeUnit;Lorg/apache/http/pool/PoolEntryFuture;)Lorg/apache/http/pool/PoolEntry; lastUsed i otherpool totalAvailable conn totalUsed freeCapacity excess success timeout J tunit Ljava/util/concurrent/TimeUnit; future &Lorg/apache/http/pool/PoolEntryFuture; deadline Ljava/util/Date; TC; +Lorg/apache/http/pool/PoolEntryFuture<TE;>;kV????? e(TT;Ljava/lang/Object;JLjava/util/concurrent/TimeUnit;Lorg/apache/http/pool/PoolEntryFuture<TE;>;)TE; release $(Lorg/apache/http/pool/PoolEntry;Z)V reusable (TE;Z)V getMax (Ljava/lang/Object;)I v Ljava/lang/Integer;? (TT;)I setMaxTotal (I)V max getMaxTotal ()I setDefaultMaxPerRoute getDefaultMaxPerRoute setMaxPerRoute (Ljava/lang/Object;I)V (TT;I)V getMaxPerRoute getTotalStats "()Lorg/apache/http/pool/PoolStats; getStats 4(Ljava/lang/Object;)Lorg/apache/http/pool/PoolStats; %(TT;)Lorg/apache/http/pool/PoolStats; getRoutes ()Ljava/util/Set; ()Ljava/util/Set<TT;>; enumAvailable +(Lorg/apache/http/pool/PoolEntryCallback;)V it (Lorg/apache/http/pool/PoolEntryCallback; Ljava/util/Iterator<TE;>; 0Lorg/apache/http/pool/PoolEntryCallback<TT;TC;>;? 3(Lorg/apache/http/pool/PoolEntryCallback<TT;TC;>;)V enumLeased purgePoolMap Entry Ljava/util/Map$Entry; MLjava/util/Map$Entry<TT;Lorg/apache/http/pool/RouteSpecificPool<TT;TC;TE;>;>; cLjava/util/Iterator<Ljava/util/Map$Entry<TT;Lorg/apache/http/pool/RouteSpecificPool<TT;TC;TE;>;>;>; closeIdle #(JLjava/util/concurrent/TimeUnit;)V idletime time closeExpired now getValidateAfterInactivity setValidateAfterInactivity ms toString ()Ljava/lang/String; buffer Ljava/lang/StringBuilder; (Ljava/lang/Object;Z)V x0 x1 access$000 ?(Lorg/apache/http/pool/AbstractConnPool;Ljava/lang/Object;Ljava/lang/Object;JLjava/util/concurrent/TimeUnit;Lorg/apache/http/pool/PoolEntryFuture;)Lorg/apache/http/pool/PoolEntry; x2 x3 x4 x5 ?<T:Ljava/lang/Object;C:Ljava/lang/Object;E:Lorg/apache/http/pool/PoolEntry<TT;TC;>;>Ljava/lang/Object;Lorg/apache/http/pool/ConnPool<TT;TE;>;Lorg/apache/http/pool/ConnPoolControl<TT;>; SourceFile AbstractConnPool.java RuntimeInvisibleAnnotations 'Lorg/apache/http/annotation/ThreadSafe; ? ? ? ? Connection factory??? org/apache/http/pool/ConnFactory ? ? Max per route value?? ? ? Max total value ? ? (java/util/concurrent/locks/ReentrantLock ? ? java/util/HashMap ? ? java/util/HashSet ? ? java/util/LinkedList ? ? ? ? ? ? ? ?? ? ????? ??? org/apache/http/pool/PoolEntry? ?????? &org/apache/http/pool/RouteSpecificPool ? ?? ?? ??? 'org/apache/http/pool/AbstractConnPool$1 ???? Route Connection pool shut down??? 'org/apache/http/pool/AbstractConnPool$2 ?? ? ? java/util/Date?????? ?? ? ????? ? ??? ? ?? ???? ??? ? ? ? ??? ????? ??? ????????????????? %java/util/concurrent/TimeoutException Timeout waiting for connection ???? ? ??? ? $org/apache/http/pool/PoolEntryFuture ? java/lang/Integer Max value org/apache/http/pool/PoolStats ? ? ? ?? ? ? java/util/Map$Entry ? Time unit 'org/apache/http/pool/AbstractConnPool$3 ? 'org/apache/http/pool/AbstractConnPool$4 java/lang/StringBuilder [leased: ][available: ][pending: ]'( ? ? %org/apache/http/pool/AbstractConnPool java/lang/Object org/apache/http/pool/ConnPool $org/apache/http/pool/ConnPoolControl java/util/Iterator java/lang/Throwable java/io/IOException java/util/concurrent/TimeUnit java/lang/InterruptedException &org/apache/http/pool/PoolEntryCallback org/apache/http/util/Args notNull 8(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; positive (ILjava/lang/String;)I java/util/concurrent/locks/Lock iterator ()Ljava/util/Iterator; hasNext next ()Ljava/lang/Object; close java/util/Set java/util/Map values ()Ljava/util/Collection; java/util/Collection clear unlock get &(Ljava/lang/Object;)Ljava/lang/Object; N(Lorg/apache/http/pool/AbstractConnPool;Ljava/lang/Object;Ljava/lang/Object;)V put 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; org/apache/http/util/Asserts check (ZLjava/lang/String;)V ?(Lorg/apache/http/pool/AbstractConnPool;Ljava/util/concurrent/locks/Lock;Lorg/apache/http/concurrent/FutureCallback;Ljava/lang/Object;Ljava/lang/Object;)V java/lang/System currentTimeMillis ()J toMillis (J)J (J)V getFree 4(Ljava/lang/Object;)Lorg/apache/http/pool/PoolEntry; isExpired (J)Z getUpdated isClosed remove (Ljava/lang/Object;)Z free add getAllocatedCount java/lang/Math (II)I getLastUsed "()Lorg/apache/http/pool/PoolEntry; size isEmpty removeLast getRoute create queue )(Lorg/apache/http/pool/PoolEntryFuture;)V await (Ljava/util/Date;)Z unqueue getTime (Ljava/lang/String;)V addFirst (Ljava/lang/Object;)V nextPending (()Lorg/apache/http/pool/PoolEntryFuture; poll wakeup intValue valueOf (I)Ljava/lang/Integer; (IIII)V getLeasedCount getPendingCount getAvailableCount keySet (Ljava/util/Collection;)V process entrySet getValue +(Lorg/apache/http/pool/AbstractConnPool;J)V append -(Ljava/lang/String;)Ljava/lang/StringBuilder; -(Ljava/lang/Object;)Ljava/lang/StringBuilder;! ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? B ? ? B ? ? B ? ? B ? ? ! ? ? ? ? h*? *+? ? ? *? ? * ? ? *? Y? ? *? Y? ? *? Y? ? *? Y? ? *? Y? ? *? Y? ? ? ? . T U V W % X 0 Y ; Z F [ Q \ \ ] g ^ ? * h ? ? h ? ? h ? ? h ? ? ? h ? ? h ? ? ? ? ? ? ? ? ? ? ? Q ? ? i ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? Q ? ? o ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? Q ? ? u ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? R ? ? { ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? A *? ? ? ? ? ? ? ? ? ? ? ? ? ?*? ? ?*? *? ? *? ? L+? ? +? ? M,? ??*? ? ! L+? ? +? ? M,? ??*? ? " ? # L+? ? +? ? $M,? %??*? ? & *? ? ' *? ? (*? ? ) ? N*? ? ) -? ? ? ? ? ? ? F ? ? ? ? ? 1 ? 8 ? U ? \ ? ~ ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? H 1 ? ? ? ? U ? ? B ? ? ~ ? ? k ? ? ? ? ? ? * 1 ? ? U ? ? ~ ? ? ? ? ? ? # ? ? ? ? ? ? d ? ? ? ? ? ? ? +*? +? * ? $M,? ? +Y*++? ,M*? +,? - W,? ? ? ? ? ? ) ? ? + ? ? + ? ? ? ? ? + ? ? + ? ? ? ? ? ? ) ? ? ? ? ? ? ? (+.? W*? ? ? /? 0? 1Y**? -+,? 2? ? ? ? ? ? * ( ? ? ( ? ? ( ? ? ( ? ? ? ( ? ? ( ? ? ( ? ? ? @ ? ? ? ? ? b *+,? 3? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? <