3 ,org/elasticsearch/indices/store/IndicesStore4org/elasticsearch/common/component/AbstractComponent.org/elasticsearch/cluster/ClusterStateListenerIndicesStore.java.org/elasticsearch/indices/store/IndicesStore$1@org/elasticsearch/indices/store/IndicesStore$ShardActiveResponse ShardActiveResponse?org/elasticsearch/indices/store/IndicesStore$ShardActiveRequest ShardActiveRequestForg/elasticsearch/indices/store/IndicesStore$ShardActiveRequestHandlerShardActiveRequestHandlerGorg/elasticsearch/indices/store/IndicesStore$ShardActiveResponseHandlerShardActiveResponseHandler:org/elasticsearch/indices/store/IndicesStore$ApplySettings ApplySettings.org/apache/lucene/store/StoreRateLimiting$Type)org/apache/lucene/store/StoreRateLimitingType;nodeEnv'Lorg/elasticsearch/env/NodeEnvironment;nodeSettingsService5Lorg/elasticsearch/node/settings/NodeSettingsService;indicesService*Lorg/elasticsearch/indices/IndicesService;clusterService*Lorg/elasticsearch/cluster/ClusterService;transportService.Lorg/elasticsearch/transport/TransportService;rateLimitingTyperateLimitingThrottle-Lorg/elasticsearch/common/unit/ByteSizeValue; rateLimiting+Lorg/apache/lucene/store/StoreRateLimiting; applySettings (Lorg/elasticsearch/common/settings/Settings;Lorg/elasticsearch/env/NodeEnvironment;Lorg/elasticsearch/node/settings/NodeSettingsService;Lorg/elasticsearch/indices/IndicesService;Lorg/elasticsearch/cluster/ClusterService;Lorg/elasticsearch/transport/TransportService;)V(Lorg/elasticsearch/common/inject/Inject;/(Lorg/elasticsearch/common/settings/Settings;)V CF G()V CI J => L1(Lorg/elasticsearch/indices/store/IndicesStore;)V CN O ?@ Q 01 S 23 U 45 W 67 Y 89 [a(Lorg/elasticsearch/indices/store/IndicesStore;Lorg/elasticsearch/indices/store/IndicesStore$1;)V C] ^,org/elasticsearch/transport/TransportService`registerHandlerJ(Ljava/lang/String;Lorg/elasticsearch/transport/TransportRequestHandler;)V bc adcomponentSettings,Lorg/elasticsearch/common/settings/Settings; fg h throttle.typejMERGE0Lorg/apache/lucene/store/StoreRateLimiting$Type; lm nname()Ljava/lang/String; pq r*org/elasticsearch/common/settings/Settingstget8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String; vw ux :$ zsetType(Ljava/lang/String;)V |} ~throttle.max_bytes_per_sec+org/elasticsearch/common/unit/ByteSizeValue*org/elasticsearch/common/unit/ByteSizeUnitMB,Lorg/elasticsearch/common/unit/ByteSizeUnit; 0(JLorg/elasticsearch/common/unit/ByteSizeUnit;)V C getAsBytesSizen(Ljava/lang/String;Lorg/elasticsearch/common/unit/ByteSizeValue;)Lorg/elasticsearch/common/unit/ByteSizeValue; u ;<  setMaxRate0(Lorg/elasticsearch/common/unit/ByteSizeValue;)V logger+Lorg/elasticsearch/common/logging/ESLogger; Xusing indices.store.throttle.type [{}], with index.store.throttle.max_bytes_per_sec [{}]java/lang/Object)org/elasticsearch/common/logging/ESLoggerdebug((Ljava/lang/String;[Ljava/lang/Object;)V  addListenerA(Lorg/elasticsearch/node/settings/NodeSettingsService$Listener;)V !(org/elasticsearch/cluster/ClusterServiceaddLast3(Lorg/elasticsearch/cluster/ClusterStateListener;)V this.Lorg/elasticsearch/indices/store/IndicesStore;settings3org/elasticsearch/common/settings/ImmutableSettingsEMPTY g -()Lorg/apache/lucene/store/StoreRateLimiting;closeremoveListener !remove clusterChanged2(Lorg/elasticsearch/cluster/ClusterChangedEvent;)V-org/elasticsearch/cluster/ClusterChangedEventroutingTableChanged()Z state*()Lorg/elasticsearch/cluster/ClusterState; &org/elasticsearch/cluster/ClusterStateblocks1()Lorg/elasticsearch/cluster/block/ClusterBlocks; -org/elasticsearch/cluster/block/ClusterBlocksdisableStatePersistence  routingTable2()Lorg/elasticsearch/cluster/routing/RoutingTable; .org/elasticsearch/cluster/routing/RoutingTableiterator()Ljava/util/Iterator; java/util/IteratorhasNext next()Ljava/lang/Object; 3org/elasticsearch/cluster/routing/IndexRoutingTable 8org/elasticsearch/cluster/routing/IndexShardRoutingTableshardCanBeDeletede(Lorg/elasticsearch/cluster/ClusterState;Lorg/elasticsearch/cluster/routing/IndexShardRoutingTable;)Z shardId)()Lorg/elasticsearch/index/shard/ShardId; %org/elasticsearch/index/shard/ShardIdgetIndex q (org/elasticsearch/indices/IndicesService indexServiceB(Ljava/lang/String;)Lorg/elasticsearch/index/service/IndexService;  %org/elasticsearch/env/NodeEnvironment hasNodeFile  shardLocations8(Lorg/elasticsearch/index/shard/ShardId;)[Ljava/io/File;   +org/elasticsearch/common/io/FileSystemUtils exists([Ljava/io/File;)Z   deleteShardIfExistElseWheree(Lorg/elasticsearch/cluster/ClusterState;Lorg/elasticsearch/cluster/routing/IndexShardRoutingTable;)V  ,org/elasticsearch/index/service/IndexServiceid()I  hasShard(I)Z  store,()Lorg/elasticsearch/index/store/IndexStore;  ! "(org/elasticsearch/index/store/IndexStore$canDeleteUnallocated*(Lorg/elasticsearch/index/shard/ShardId;)Z &' %([Ljava/io/File;'Lorg/elasticsearch/index/shard/ShardId;.Lorg/elasticsearch/index/service/IndexService;indexShardRoutingTable:Lorg/elasticsearch/cluster/routing/IndexShardRoutingTable;i$Ljava/util/Iterator;indexRoutingTable5Lorg/elasticsearch/cluster/routing/IndexRoutingTable;event/Lorg/elasticsearch/cluster/ClusterChangedEvent;size 5 6 .org/elasticsearch/cluster/routing/ShardRouting9started ; :<nodes1()Lorg/elasticsearch/cluster/node/DiscoveryNodes; >? @ currentNodeId Bq :C-org/elasticsearch/cluster/node/DiscoveryNodesEB(Ljava/lang/String;)Lorg/elasticsearch/cluster/node/DiscoveryNode; vG FH,org/elasticsearch/cluster/node/DiscoveryNodeJ getVersion()Lorg/elasticsearch/Version; LM KNorg/elasticsearch/VersionPV_1_3_0Lorg/elasticsearch/Version; RS QTbefore(Lorg/elasticsearch/Version;)Z VW QXVSkip deleting deleting shard instance [{}], a node holding a shard instance is < 1.3.0ZrelocatingNodeId \q :]getNodes _? ` localNode0()Lorg/elasticsearch/cluster/node/DiscoveryNode; bc Fd q Kfjava/lang/Stringhequals(Ljava/lang/Object;)Z jk ilnode.Lorg/elasticsearch/cluster/node/DiscoveryNode; localNodeId shardRouting0Lorg/elasticsearch/cluster/routing/ShardRouting;(Lorg/elasticsearch/cluster/ClusterState;java/util/ArrayListt(I)V Cv uw getMetaData/()Lorg/elasticsearch/cluster/metadata/MetaData; yz {+org/elasticsearch/cluster/metadata/MetaData}indexF(Ljava/lang/String;)Lorg/elasticsearch/cluster/metadata/IndexMetaData;  ~0org/elasticsearch/cluster/metadata/IndexMetaDatagetUUID q getClusterName)()Lorg/elasticsearch/cluster/ClusterName;  java/util/List%org/elasticsearch/cluster/ClusterName AB java/lang/AssertionError J&org/elasticsearch/common/collect/Tuple :c(Lorg/elasticsearch/cluster/ClusterName;Ljava/lang/String;Lorg/elasticsearch/index/shard/ShardId;)V C '(Ljava/lang/Object;Ljava/lang/Object;)V C add k  6(Lorg/elasticsearch/indices/store/IndicesStore;Lorg/elasticsearch/index/shard/ShardId;Lorg/elasticsearch/cluster/ClusterState;I)V C  #{} sending shard active check to {}v2   access$600j(Lorg/elasticsearch/indices/store/IndicesStore$ShardActiveRequest;)Lorg/elasticsearch/index/shard/ShardId;  v1  trace  ,org/elasticsearch/transport/TransportRequest sendRequest(Lorg/elasticsearch/cluster/node/DiscoveryNode;Ljava/lang/String;Lorg/elasticsearch/transport/TransportRequest;Lorg/elasticsearch/transport/TransportResponseHandler;)V  arelocatingNode currentNoderequestLorg/elasticsearch/common/collect/Tuple;(Lorg/elasticsearch/common/collect/Tuple;requestsLjava/util/List;>;Ljava/util/List; indexUUID clusterName'Lorg/elasticsearch/cluster/ClusterName;responseHandlerILorg/elasticsearch/indices/store/IndicesStore$ShardActiveResponseHandler; access$000B(Lorg/elasticsearch/indices/store/IndicesStore;)Ljava/lang/String;x0 access$100[(Lorg/elasticsearch/indices/store/IndicesStore;)Lorg/elasticsearch/common/logging/ESLogger; access$002T(Lorg/elasticsearch/indices/store/IndicesStore;Ljava/lang/String;)Ljava/lang/String;x1 access$200[(Lorg/elasticsearch/indices/store/IndicesStore;)Lorg/apache/lucene/store/StoreRateLimiting; access$300](Lorg/elasticsearch/indices/store/IndicesStore;)Lorg/elasticsearch/common/unit/ByteSizeValue; access$400 access$302(Lorg/elasticsearch/indices/store/IndicesStore;Lorg/elasticsearch/common/unit/ByteSizeValue;)Lorg/elasticsearch/common/unit/ByteSizeValue; access$900 access$1000 access$1100 access$1200Z(Lorg/elasticsearch/indices/store/IndicesStore;)Lorg/elasticsearch/cluster/ClusterService; access$1300 access$1600 access$1700Z(Lorg/elasticsearch/indices/store/IndicesStore;)Lorg/elasticsearch/indices/IndicesService; access$1800W(Lorg/elasticsearch/indices/store/IndicesStore;)Lorg/elasticsearch/env/NodeEnvironment; access$1900 access$2000 access$2100 access$2200 access$2400 access$2600()Ljava/util/EnumSet; -. java/lang/ClassdesiredAssertionStatus  -org/elasticsearch/index/shard/IndexShardStateSTARTED/Lorg/elasticsearch/index/shard/IndexShardState;   RELOCATED  java/util/EnumSetof5(Ljava/lang/Enum;Ljava/lang/Enum;)Ljava/util/EnumSet;   ConstantValue SignatureCodeLocalVariableTableLineNumberTableRuntimeVisibleAnnotations StackMapTableLocalVariableTypeTable SourceFile InnerClasses!#$&'$)*$,-./0123456789B:$B;<=>?@ABCDc*+H*YKM*Y*PR*,T*-V*X*Z*\,Y*_e**ikosy{*M*{**iY*M**Y*{SY*S-*R*Hg0123456789Flegm!n&o,p2q8rHu]vhwxz|}~ECI8*H*YKM*Y*PR*T*V*X*Z*\ 8& eg#(-27=/*M IH*V*R*Z*   +Ț+̶Ҷי+̶۶M,,N-::*+s:*X:-*TM*T : *+-#) *+mQ\ *di+tY,P}-.:/0412!/034V4P]dty)  e),7,8N--::=+ADI:OUY*[YS^?+A^I:OUY*[YS+aeg:Dm^m2H>no p$"qr/0s-.^ ",.>CEShjt$ :K$ $)i PuY,7xN+|,:+:,8:::+ADI: Y-YYW^H+A^I:  Y-Y YWVY*,+-:-:S:*YSYS*\K, 5o QoAqr+/0 AZ/0PPsP-. D1$%+c A DJ %AQd 1LO?+i8:KNK!Y/*{ ;/* ;;*+Z{$;/*M ;/* ;/* ;;*+Z<;/* ;/* ;/* ;/*Z ;/* ;/* ;/*X ;/*T ;/* ;/* ;/* ;/* ;/* ;;ID ;B @ B    @!"