Êþº¾1›8org/elasticsearch/common/netty/handler/ssl/SslBufferPooljava/lang/ObjectSslBufferPool.javaMAX_PACKET_SIZE_ALIGNEDII€DEFAULT_POOL_SIZE& preallocatedLjava/nio/ByteBuffer;pool$Ljava/util/concurrent/BlockingQueue;;Ljava/util/concurrent/BlockingQueue;maxBufferCountallocateDirectZnumAllocations+Ljava/util/concurrent/atomic/AtomicInteger;()V(I)V  this:Lorg/elasticsearch/common/netty/handler/ssl/SslBufferPool;(ZZ)V(IZZ)V   preallocate maxPoolSize  ""java/lang/IllegalArgumentException$java/lang/StringBuilder& '" maxPoolSize: )append-(Ljava/lang/String;)Ljava/lang/StringBuilder; +, '-(I)Ljava/lang/StringBuilder; +/ '0toString()Ljava/lang/String; 23 '4(Ljava/lang/String;)V 6 %7  9  ;'java/util/concurrent/ArrayBlockingQueue= >  @allocate(I)Ljava/nio/ByteBuffer; BC D F  Hjava/nio/ByteBufferJclear()Ljava/nio/Buffer; LM KNjava/nio/BufferPposition(I)Ljava/nio/Buffer; RS QTlimit VS QWslice()Ljava/nio/ByteBuffer; YZ K["java/util/concurrent/BlockingQueue]add(Ljava/lang/Object;)Z _` ^a)java/util/concurrent/atomic/AtomicIntegerc d"posigetMaxPoolSize()IgetUnacquiredPoolSizesize ki ^l acquireBufferjava/lang/InterruptedExceptionoget qi drtake()Ljava/lang/Object; tu ^vjava/lang/Threadx currentThread()Ljava/lang/Thread; z{ y| interrupt ~ ypoll u ^‚incrementAndGet „i d…ignore Ljava/lang/InterruptedException; interruptedbuf releaseBuffer(Ljava/nio/ByteBuffer;)Voffer ` ^Žbuffer C K‘ KDcapacity ConstantValue SignatureCodeLocalVariableTableLineNumberTable SourceFile!• •   – —5* ·±˜ ™ 89—K * ·±˜    ™ CD—@*·±˜!™ LM—i·*·#»%Y»'Y·(*¶.¶1¶5·8¿I€l6I€p™„*µ:*µ<*»>Y·?µA™X**I€h·EµG*µI6¢8I€h6*´G¶O¶UI€`¶XW*´A*´G¶\¹bW„§ÿǧ*µG*»dY·eµI±˜Hv'fg<g··!· ·*™RWXY#\*]2^5a;b@dMfQg_hdinjvkŒli¦o«p¶rhi—3 *´:I€h¬˜  ™yji—8*´A¹mI€h¬˜ ™„nZ—øb*´GÇ*´I¶s*´:¡(<*´A¹wÀKM§ N<§ÿí™ ¸}¶€§$*´A¹ƒÀKM,Ç*´I¶†W*I·EM,¶OW,°$'p˜4(‡ˆ ‰$Š bGŠ ™BŽ‘$’'“(”*•-—1˜7š:›GœKŸS [¤`¥‹Œ—D *´A+¹W±˜  ™ ¬ ­BC—M*´<™¸’°¸“°˜”™°± ³š