3 6org/elasticsearch/indices/warmer/InternalIndicesWarmer4org/elasticsearch/common/component/AbstractComponent.org/elasticsearch/indices/warmer/IndicesWarmerInternalIndicesWarmer.java7org/elasticsearch/indices/warmer/IndicesWarmer$ListenerListener;(Lorg/elasticsearch/common/settings/Settings;Lorg/elasticsearch/threadpool/ThreadPool;Lorg/elasticsearch/cluster/ClusterService;Lorg/elasticsearch/indices/IndicesService;)V(Lorg/elasticsearch/common/inject/Inject;/(Lorg/elasticsearch/common/settings/Settings;)V ! ")java/util/concurrent/CopyOnWriteArrayList$()V & %'  )  +  -  /this8Lorg/elasticsearch/indices/warmer/InternalIndicesWarmer;settings,Lorg/elasticsearch/common/settings/Settings; addListener<(Lorg/elasticsearch/indices/warmer/IndicesWarmer$Listener;)Vadd(Ljava/lang/Object;)Z 78 %9listener9Lorg/elasticsearch/indices/warmer/IndicesWarmer$Listener;removeListenerremove >8 %?warmNewReadersA(Lorg/elasticsearch/indices/warmer/IndicesWarmer$WarmerContext;)V warmInternalB(Lorg/elasticsearch/indices/warmer/IndicesWarmer$WarmerContext;Z)V CD Econtext>Lorg/elasticsearch/indices/warmer/IndicesWarmer$WarmerContext; warmTopReaderjava/lang/InterruptedExceptionJ(org/elasticsearch/cluster/ClusterServiceLstate*()Lorg/elasticsearch/cluster/ClusterState; NO MP&org/elasticsearch/cluster/ClusterStateRmetaData/()Lorg/elasticsearch/cluster/metadata/MetaData; TU SVshardId)()Lorg/elasticsearch/index/shard/ShardId; XY Z%org/elasticsearch/index/shard/ShardId\index!()Lorg/elasticsearch/index/Index; ^_ ]`org/elasticsearch/index/Indexbname()Ljava/lang/String; de cf+org/elasticsearch/cluster/metadata/MetaDatahF(Ljava/lang/String;)Lorg/elasticsearch/cluster/metadata/IndexMetaData; ^j ik0org/elasticsearch/cluster/metadata/IndexMetaDatam.()Lorg/elasticsearch/common/settings/Settings; 3o np 34 rjava/lang/BooleantvalueOf(Z)Ljava/lang/Boolean; vw ux*org/elasticsearch/common/settings/Settingsz getAsBoolean:(Ljava/lang/String;Ljava/lang/Boolean;)Ljava/lang/Boolean; |} {~ booleanValue()Z u(org/elasticsearch/indices/IndicesService indexServiceB(Ljava/lang/String;)Lorg/elasticsearch/index/service/IndexService; ,org/elasticsearch/index/service/IndexServiceid()I ]shard5(I)Lorg/elasticsearch/index/shard/service/IndexShard; 0org/elasticsearch/index/shard/service/IndexShardlogger+Lorg/elasticsearch/common/logging/ESLogger; )org/elasticsearch/common/logging/ESLoggerisTraceEnabled [{}][{}] top warming [{}]java/lang/Objectjava/lang/Integer(I)Ljava/lang/Integer; v trace((Ljava/lang/String;[Ljava/lang/Object;)V [{}][{}] warming [{}] warmerService:()Lorg/elasticsearch/index/warmer/ShardIndexWarmerService; 6org/elasticsearch/index/warmer/ShardIndexWarmerService onPreWarm & java/lang/SystemnanoTime()J &org/elasticsearch/common/collect/Lists newArrayList()Ljava/util/ArrayList; iterator()Ljava/util/Iterator; %java/util/Listjava/util/IteratorhasNext next()Ljava/lang/Object; (Lorg/elasticsearch/index/shard/service/IndexShard;Lorg/elasticsearch/cluster/metadata/IndexMetaData;Lorg/elasticsearch/indices/warmer/IndicesWarmer$WarmerContext;Lorg/elasticsearch/threadpool/ThreadPool;)Lorg/elasticsearch/indices/warmer/IndicesWarmer$Listener$TerminationHandle; I 9 A awaitTermination & java/lang/Thread currentThread()Ljava/lang/Thread;  interrupt &  top warming has been interruptedwarn=(Ljava/lang/String;Ljava/lang/Throwable;[Ljava/lang/Object;)V warming has been interrupted onPostWarm(J)V -()Lorg/elasticsearch/common/logging/ESLogger; top warming took [{}]'org/elasticsearch/common/unit/TimeValuejava/util/concurrent/TimeUnit NANOSECONDSLjava/util/concurrent/TimeUnit; #(JLjava/util/concurrent/TimeUnit;)V  warming took [{}]i$Ljava/util/Iterator;e Ljava/lang/InterruptedException;terminationHandleKLorg/elasticsearch/indices/warmer/IndicesWarmer$Listener$TerminationHandle; topReaderZ indexMetaData2Lorg/elasticsearch/cluster/metadata/IndexMetaData;.Lorg/elasticsearch/index/service/IndexService; indexShard2Lorg/elasticsearch/index/shard/service/IndexShard;timeJterminationHandles]Ljava/util/List;Ljava/util/List;took ConstantValue SignatureCodeLocalVariableTableLineNumberTableRuntimeVisibleAnnotationsLocalVariableTypeTable StackMapTable SourceFile InnerClasses!!*+#*%Y(**,,*-.*04!12!34!!!62789 : 56B **+:W 12 ;< > ?=6B **+@W 12 ;< C DAB?*+F12GH GHIB?*+F12GH KLCD *.QW+[aglN--q*sy*0+[ag:+[:*d3*Y+[agSY+[SY+S0*Y+[agSY+[SY+S7:**:  C  :  -+*,ԹW -+*,׹W:  P :  7: * * e7  S*YY S(YY SdknK1;< J p2 d> NW 12GH    U k/*o  *(OPQS?T@VUWZX[Zk[p\q^}_`befgijk-mBoEqdsk|ntpuvvzwy{}~n ?,1   nKKP  n$