35org/elasticsearch/gateway/local/LocalGatewayAllocator4org/elasticsearch/common/component/AbstractComponentGorg/elasticsearch/cluster/routing/allocation/allocator/GatewayAllocatorLocalGatewayAllocator.java7org/elasticsearch/gateway/local/LocalGatewayAllocator$1Worg/elasticsearch/indices/store/TransportNodesListShardStoreMetaData$StoreFilesMetaData Dorg/elasticsearch/indices/store/TransportNodesListShardStoreMetaData StoreFilesMetaDatajava/util/Map$Entry java/util/MapEntryqorg/elasticsearch/gateway/local/state/shards/TransportNodesListGatewayStartedShards$NodeLocalGatewayStartedShardsSorg/elasticsearch/gateway/local/state/shards/TransportNodesListGatewayStartedShardsNodeLocalGatewayStartedShardsrorg/elasticsearch/gateway/local/state/shards/TransportNodesListGatewayStartedShards$NodesLocalGatewayStartedShardsNodesLocalGatewayStartedShards[org/elasticsearch/indices/store/TransportNodesListShardStoreMetaData$NodeStoreFilesMetaDataNodeStoreFilesMetaData\org/elasticsearch/indices/store/TransportNodesListShardStoreMetaData$NodesStoreFilesMetaDataNodesStoreFilesMetaData?org/elasticsearch/cluster/routing/RoutingNodes$UnassignedShards".org/elasticsearch/cluster/routing/RoutingNodes$UnassignedShardsBorg/elasticsearch/cluster/routing/allocation/decider/Decision$Type'=org/elasticsearch/cluster/routing/allocation/decider/Decision)TypeAorg/elasticsearch/common/hppc/ObjectLongOpenHashMap$KeysContainer,3org/elasticsearch/common/hppc/ObjectLongOpenHashMap. KeysContainerINDEX_RECOVERY_INITIAL_SHARDSLjava/lang/String;index.recovery.initial_shards3listGatewayStartedShardsULorg/elasticsearch/gateway/local/state/shards/TransportNodesListGatewayStartedShards;listShardStoreMetaDataFLorg/elasticsearch/indices/store/TransportNodesListShardStoreMetaData; cachedStores$Ljava/util/concurrent/ConcurrentMap;Ljava/util/concurrent/ConcurrentMap;>;cachedShardsStateLjava/util/concurrent/ConcurrentMap;>; listTimeout)Lorg/elasticsearch/common/unit/TimeValue; initialShards$assertionsDisabledZ(Lorg/elasticsearch/common/settings/Settings;Lorg/elasticsearch/gateway/local/state/shards/TransportNodesListGatewayStartedShards;Lorg/elasticsearch/indices/store/TransportNodesListShardStoreMetaData;)V(Lorg/elasticsearch/common/inject/Inject;/(Lorg/elasticsearch/common/settings/Settings;)V CF G>org/elasticsearch/common/util/concurrent/ConcurrentCollectionsInewConcurrentMap&()Ljava/util/concurrent/ConcurrentMap; KL JM 9: O <: Q 56 S 78 UcomponentSettings,Lorg/elasticsearch/common/settings/Settings; WX Y list_timeout['org/elasticsearch/common/unit/TimeValue_timeValueSeconds,(J)Lorg/elasticsearch/common/unit/TimeValue; ab `c*org/elasticsearch/common/settings/Settingse getAsTimef(Ljava/lang/String;Lorg/elasticsearch/common/unit/TimeValue;)Lorg/elasticsearch/common/unit/TimeValue; gh fi >? kinitial_shardsmquorumoget8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String; qr fs @2 ulogger+Lorg/elasticsearch/common/logging/ESLogger; wx y,using initial_shards [{}], list_timeout [{}]{java/lang/Object})org/elasticsearch/common/logging/ESLoggerdebug((Ljava/lang/String;[Ljava/lang/Object;)V this7Lorg/elasticsearch/gateway/local/LocalGatewayAllocator;settingsapplyStartedShardsJ(Lorg/elasticsearch/cluster/routing/allocation/StartedRerouteAllocation;)VEorg/elasticsearch/cluster/routing/allocation/StartedRerouteAllocation startedShards()Ljava/util/List; java/util/Listiterator()Ljava/util/Iterator; java/util/IteratorhasNext()Z next()Ljava/lang/Object; .org/elasticsearch/cluster/routing/ShardRoutingshardId)()Lorg/elasticsearch/index/shard/ShardId; "java/util/concurrent/ConcurrentMapremove&(Ljava/lang/Object;)Ljava/lang/Object;  shardRouting0Lorg/elasticsearch/cluster/routing/ShardRouting;i$Ljava/util/Iterator; allocationGLorg/elasticsearch/cluster/routing/allocation/StartedRerouteAllocation;applyFailedShardsI(Lorg/elasticsearch/cluster/routing/allocation/FailedRerouteAllocation;)VDorg/elasticsearch/cluster/routing/allocation/FailedRerouteAllocation failedShards  failedShardFLorg/elasticsearch/cluster/routing/allocation/FailedRerouteAllocation;allocateUnassignedC(Lorg/elasticsearch/cluster/routing/allocation/RoutingAllocation;)Zjava/lang/Exception>org/elasticsearch/cluster/routing/allocation/RoutingAllocationnodes1()Lorg/elasticsearch/cluster/node/DiscoveryNodes;  routingNodes2()Lorg/elasticsearch/cluster/routing/RoutingNodes;  unassignedC()Lorg/elasticsearch/cluster/routing/RoutingNodes$UnassignedShards; % #-org/elasticsearch/cluster/node/DiscoveryNodes5org/elasticsearch/cluster/routing/MutableShardRoutingprimary  routingTable2()Lorg/elasticsearch/cluster/routing/RoutingTable; %index()Ljava/lang/String; .org/elasticsearch/cluster/routing/RoutingTableI(Ljava/lang/String;)Lorg/elasticsearch/cluster/routing/IndexRoutingTable; id()I 3org/elasticsearch/cluster/routing/IndexRoutingTableshard=(I)Lorg/elasticsearch/cluster/routing/IndexShardRoutingTable; 8org/elasticsearch/cluster/routing/IndexShardRoutingTableprimaryAllocatedPostApi buildShardStates(Lorg/elasticsearch/cluster/node/DiscoveryNodes;Lorg/elasticsearch/cluster/routing/MutableShardRouting;)Lorg/elasticsearch/common/hppc/ObjectLongOpenHashMap; %org/elasticsearch/common/collect/Sets newHashSet()Ljava/util/HashSet;  allocated[Z /keys[Ljava/lang/Object;  /values[J  / java/util/Set ,org/elasticsearch/cluster/node/DiscoveryNode shouldIgnoreShardForNode<(Lorg/elasticsearch/index/shard/ShardId;Ljava/lang/String;)Z  add(Ljava/lang/Object;)Z   clear()V   metaData/()Lorg/elasticsearch/cluster/metadata/MetaData;  %!+org/elasticsearch/cluster/metadata/MetaData#F(Ljava/lang/String;)Lorg/elasticsearch/cluster/metadata/IndexMetaData; % $&0org/elasticsearch/cluster/metadata/IndexMetaData(.()Lorg/elasticsearch/common/settings/Settings; * )+ X -java/lang/String/equals 1 02numberOfReplicas 4 )5quorum-17half9one;full=all?full-1Aall-1Cjava/lang/IntegerEparseInt(Ljava/lang/String;)I GH FIQ[{}][{}] failed to derived initial_shards from value {}, ignore allocation for {}KvalueOf(I)Ljava/lang/Integer; MN FOwarn Q R  TignoredUnassigned V %W isDebugEnabled Z [U[{}][{}]: not allocating, number_of_allocated_shards_found [{}], required_number [{}]]  nodeC(Ljava/lang/String;)Lorg/elasticsearch/cluster/routing/RoutingNode; `a %b-org/elasticsearch/cluster/routing/RoutingNodeddecidersK()Lorg/elasticsearch/cluster/routing/allocation/decider/AllocationDeciders; fg hGorg/elasticsearch/cluster/routing/allocation/decider/AllocationDecidersj canAllocate(Lorg/elasticsearch/cluster/routing/ShardRouting;Lorg/elasticsearch/cluster/routing/RoutingNode;Lorg/elasticsearch/cluster/routing/allocation/RoutingAllocation;)Lorg/elasticsearch/cluster/routing/allocation/decider/Decision; lm kntypeF()Lorg/elasticsearch/cluster/routing/allocation/decider/Decision$Type; pq *rTHROTTLEDLorg/elasticsearch/cluster/routing/allocation/decider/Decision$Type; tu (vNO xu (y7[{}][{}]: allocating [{}] to [{}] on primary allocation{4(Lorg/elasticsearch/cluster/routing/ShardRouting;J)V C} ~nodeId  eassignL(Lorg/elasticsearch/cluster/routing/MutableShardRouting;Ljava/lang/String;)V  %isEmpty   ?[{}][{}]: forcing allocating [{}] to [{}] on primary allocationB[{}][{}]: throttling allocation [{}] to [{}] on primary allocation hasUnassigned  % dataNodes5()Lorg/elasticsearch/common/collect/ImmutableOpenMap;  1org/elasticsearch/common/collect/ImmutableOpenMap1()Lorg/elasticsearch/common/hppc/ObjectContainer;  -org/elasticsearch/common/hppc/ObjectContainer 2org/elasticsearch/common/hppc/cursors/ObjectCursorvalueLjava/lang/Object;  YES u (buildShardStoresw(Lorg/elasticsearch/cluster/node/DiscoveryNodes;Lorg/elasticsearch/cluster/routing/MutableShardRouting;)Ljava/util/Map;  entrySet()Ljava/util/Set;  getKey  getValue  {}: checking node [{}]trace    activePrimaryi(Lorg/elasticsearch/cluster/routing/ShardRouting;)Lorg/elasticsearch/cluster/routing/MutableShardRouting;  % AB active  java/lang/AssertionError C  currentNodeId  B(Ljava/lang/String;)Lorg/elasticsearch/cluster/node/DiscoveryNode; q  q  /org/elasticsearch/index/store/StoreFileMetaDataname   fileExists(Ljava/lang/String;)Z  fileE(Ljava/lang/String;)Lorg/elasticsearch/index/store/StoreFileMetaData;  isSame4(Lorg/elasticsearch/index/store/StoreFileMetaData;)Z  length()J  isTraceEnabled  t[{}][{}]: throttling allocation [{}] to [{}] in order to reuse its unallocated persistent store with total_size [{}]+org/elasticsearch/common/unit/ByteSizeValue(J)V C i[{}][{}]: allocating [{}] to [{}] in order to reuse its unallocated persistent store with total_size [{}].Lorg/elasticsearch/cluster/node/DiscoveryNode;versionJiI indexMetaData2Lorg/elasticsearch/cluster/metadata/IndexMetaData;eLjava/lang/Exception;/Lorg/elasticsearch/cluster/routing/RoutingNode;decision?Lorg/elasticsearch/cluster/routing/allocation/decider/Decision; discoNode7Lorg/elasticsearch/cluster/routing/MutableShardRouting; nodesStateeLorg/elasticsearch/common/hppc/ObjectLongOpenHashMap;5Lorg/elasticsearch/common/hppc/ObjectLongOpenHashMap;numberOfAllocationsFoundhighestVersionnodesWithHighestVersion?Ljava/util/Set;Ljava/util/Set;statesrequiredAllocationthrottledNodesnoNodescursordLorg/elasticsearch/common/hppc/cursors/ObjectCursor;4Lorg/elasticsearch/common/hppc/cursors/ObjectCursor;storeFileMetaData1Lorg/elasticsearch/index/store/StoreFileMetaData; sizeMatchedprimaryNodeStoreYLorg/elasticsearch/indices/store/TransportNodesListShardStoreMetaData$StoreFilesMetaData; primaryNode primaryShardstoreFilesMetaDatanodeStoreEntryLjava/util/Map$Entry;Ljava/util/Map$Entry;canBeAllocatedToAtLeastOneNode shardStoresLjava/util/Map;Ljava/util/Map;lastSizeMatchedlastDiscoNodeMatchedlastNodeMatched@Lorg/elasticsearch/cluster/routing/allocation/RoutingAllocation;changed/Lorg/elasticsearch/cluster/node/DiscoveryNodes;0Lorg/elasticsearch/cluster/routing/RoutingNodes;unassignedIteratorMLjava/util/Iterator;  /put8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; )* +7()Lorg/elasticsearch/common/hppc/ObjectLookupContainer; - ./org/elasticsearch/common/hppc/ObjectOpenHashSet0fromb(Lorg/elasticsearch/common/hppc/ObjectContainer;)Lorg/elasticsearch/common/hppc/ObjectOpenHashSet; 23 14E()Lorg/elasticsearch/common/hppc/ObjectLongOpenHashMap$KeysContainer; 6 /7i(Lorg/elasticsearch/gateway/local/LocalGatewayAllocator;Lorg/elasticsearch/cluster/node/DiscoveryNodes;)V C9 : removeAll=(Lorg/elasticsearch/common/hppc/predicates/ObjectPredicate;)I <= -> newInstance3()Lorg/elasticsearch/common/hppc/ObjectOpenHashSet; @A 1B containsKey D /E 1 1toArray&(Ljava/lang/Class;)[Ljava/lang/Object; IJ 1K[Ljava/lang/String;Mlist(Lorg/elasticsearch/index/shard/ShardId;[Ljava/lang/String;Lorg/elasticsearch/common/unit/TimeValue;)Lorg/elasticsearch/action/ActionFuture; OP Q%org/elasticsearch/action/ActionFutureS actionGet U TVfailures1()[Lorg/elasticsearch/action/FailedNodeException; XY Zjava/lang/StringBuilder\ ]append-(Ljava/lang/Object;)Ljava/lang/StringBuilder; _` ]a/: failures when trying to list shards on nodes:c-(Ljava/lang/String;)Ljava/lang/StringBuilder; _e ]ftoString h ]i(Ljava/lang/String;)V Ck ]l"org/elasticsearch/ExceptionsHelpern unwrapCause,(Ljava/lang/Throwable;)Ljava/lang/Throwable; pq or5org/elasticsearch/transport/ConnectTransportExceptiontjava/lang/Throwablev -> x,org/elasticsearch/action/FailedNodeExceptionzgetDetailedMessage | {} getNode0()Lorg/elasticsearch/cluster/node/DiscoveryNode;    (Ljava/lang/Object;J)J ) /nodeIdsELorg/elasticsearch/common/hppc/ObjectOpenHashSet;1Lorg/elasticsearch/common/hppc/ObjectOpenHashSet;causeLjava/lang/Throwable;sbLjava/lang/StringBuilder;nodeShardStatesLorg/elasticsearch/gateway/local/state/shards/TransportNodesListGatewayStartedShards$NodeLocalGatewayStartedShards; shardStates nodesIdsArrayresponsetLorg/elasticsearch/gateway/local/state/shards/TransportNodesListGatewayStartedShards$NodesLocalGatewayStartedShards;%org/elasticsearch/common/collect/Maps newHashMap()Ljava/util/HashMap;  keySet   nodeExists   E(Lorg/elasticsearch/index/shard/ShardId;Z[Ljava/lang/String;Lorg/elasticsearch/common/unit/TimeValue;)Lorg/elasticsearch/action/ActionFuture; O  Z/: failures when trying to list stores on nodes: [()Lorg/elasticsearch/indices/store/TransportNodesListShardStoreMetaData$StoreFilesMetaData;    +nodesIdsitDLjava/util/Iterator;nodeStoreFilesMetaData]Lorg/elasticsearch/indices/store/TransportNodesListShardStoreMetaData$NodeStoreFilesMetaData;nodesStoreFilesMetaData^Lorg/elasticsearch/indices/store/TransportNodesListShardStoreMetaData$NodesStoreFilesMetaData;java/lang/ClassdesiredAssertionStatus   ConstantValue SignatureCodeLocalVariableTableLineNumberTableRuntimeVisibleAnnotations StackMapTableLocalVariableTypeTable(Lorg/elasticsearch/cluster/node/DiscoveryNodes;Lorg/elasticsearch/cluster/routing/MutableShardRouting;)Lorg/elasticsearch/common/hppc/ObjectLongOpenHashMap;(Lorg/elasticsearch/cluster/node/DiscoveryNodes;Lorg/elasticsearch/cluster/routing/MutableShardRouting;)Ljava/util/Map; SourceFile InnerClasses!12456789:;<:=>?@2ABCDa*+H*NP*NR*,T*-V**Z\]djl**Znptv*z|~Y*vSY*lS*aaXa56a78& NC EOPR2SCU`VEA+M,0,N*P-W*R-Wͱ*  6AAZ[-\=]@^  5A+M,0,N*P-W*R-Wͱ*  6AAbc-d=e@f  5 '=+N+:̶:4:Ԛܶ*-:67 : : : :6  3 2:/7+[R  W7 5   W7   Wm6"ܶ':,4*.4*vtt:p366`l`683:36t6`l6f<3 6U>3@36`63B3D3666 J64:*zL~YSYPSY*vSYSSYUXYW*z\*z^~YSYPSYPSYPS:: _::c:+i+o:swWszWm*z\0*z|~YSYPSYSYS=+ȻY U._:c:*z\0*z~YSYPSYSYS=+ȻY UP*z\0*z~YSYPSYSYSUXYW̶::6-:K:c:+i+o:  s 6*-: 7 : : _:  > :: :*z~YSYSc:+i+o:szxԚ:Ú Yǿ-ʶ:~ :kc 7:;:նٙն a7 7 : :  +i +o:  sw_*z<*z~YSYPSYSY SYY SUXYW_*z\<*z~YSYPSYSY SYY S=+ UD 4s`l,I@2/`eY`-"_bg l s z 2   '` 9 R )B]m) 5c`y,E _ |B2/ , )  ''!%"B # $%R_l   9  ,2%&jkl op!q-s5t8xSyV|_~bglsz ,IS\l07>KWACZahoru;BORZ\fp|   )!5"O$T&W)c*h+k1y2378;<=>?@ABCE F(G2I5J=KALEMISLUQW_XjYvZ]^`a d ef"i%j9% -%/    $%Q%/    )0 %/    B0\%/      )e%*80ie"8% &/%e % %eO e* +4%e e* > %eb*D%8 *R,'/N-)/Y(N*R,-,W+/5:^-8 Y*+;?WC:+:0::-FGWH-0LN:*T,*lRW:*z\~[u]Y]Y^,bdgjm:6[8[2s:  uyg[2~gW*zj~:!:-X-8`u _7" @UlV(#oQ/M*8u  oQ/znpqr,s;vL|Q~u 7=Ol{~N ;/#13 \ /1N]"w' *P,'N-%N*P,-,W+/5:C:-_:%:+ U+:2::-GWH0LN:*V,*lW :*z~u]Y]Y^,bgjm:682s:  uyg2~gW*zj~:+:-W-4_`I,`  9:" "@U{2M#<s44I,   <s"(7<S_kru-:BE\btX71( 5e 1N ]"w.4; @R       ! #%&(*+@-/0