Êþº¾3 8org/elasticsearch/cluster/routing/IndexShardRoutingTableXLjava/lang/Object;Ljava/lang/Iterable;java/lang/Objectjava/lang/IterableIndexShardRoutingTable.java@org/elasticsearch/cluster/routing/IndexShardRoutingTable$Builder BuilderKorg/elasticsearch/cluster/routing/IndexShardRoutingTable$AttributesRoutings AttributesRoutingsForg/elasticsearch/cluster/routing/IndexShardRoutingTable$AttributesKey AttributesKey6org/elasticsearch/common/collect/ImmutableList$Builder.org/elasticsearch/common/collect/ImmutableListshuffler1Lorg/elasticsearch/cluster/routing/ShardShuffler;shardId'Lorg/elasticsearch/index/shard/ShardId;primary0Lorg/elasticsearch/cluster/routing/ShardRouting; primaryAsList0Lorg/elasticsearch/common/collect/ImmutableList;bLorg/elasticsearch/common/collect/ImmutableList;replicasshards activeShardsassignedShardsallInitializingShardsprimaryAllocatedPostApiZactiveShardsByAttributesLjava/util/Map;¦Ljava/util/Map;initializingShardsByAttributesshardsByAttributeMutexLjava/lang/Object;[(Lorg/elasticsearch/index/shard/ShardId;Lorg/elasticsearch/common/collect/ImmutableList;Z)V()V ,. /-org/elasticsearch/common/collect/ImmutableMap1of1()Lorg/elasticsearch/common/collect/ImmutableMap; 34 25 &' 7 )' 9 *+ ;  =7org/elasticsearch/cluster/routing/RotationShardShuffler?&java/util/concurrent/ThreadLocalRandomAcurrent*()Ljava/util/concurrent/ThreadLocalRandom; CD BEnextInt()I GH BI(I)V ,K @L  N  P $% Rbuilder:()Lorg/elasticsearch/common/collect/ImmutableList$Builder; TU Viterator()Ljava/util/Iterator; XY Z%org/elasticsearch/index/shard/ShardId\.org/elasticsearch/cluster/routing/ShardRouting^java/util/Iterator`hasNext()Z bc adnext()Ljava/lang/Object; fg ah c _jaddL(Ljava/lang/Object;)Lorg/elasticsearch/common/collect/ImmutableList$Builder; lm nactive pc _q initializing sc _t relocating vc _wtargetRoutingIfRelocating2()Lorg/elasticsearch/cluster/routing/ShardRouting; yz _{assignedToNode }c _~  €D(Ljava/lang/Object;)Lorg/elasticsearch/common/collect/ImmutableList; 3‚ ƒ  …2()Lorg/elasticsearch/common/collect/ImmutableList; 3‡ ˆbuild Š‡ ‹   !  " ‘ # “shardi$Ljava/util/Iterator;this:Lorg/elasticsearch/cluster/routing/IndexShardRoutingTable;jLorg/elasticsearch/common/collect/ImmutableList$Builder;8Lorg/elasticsearch/common/collect/ImmutableList$Builder;normalizeVersions<()Lorg/elasticsearch/cluster/routing/IndexShardRoutingTable;isEmpty žc Ÿsize ¡H ¢get(I)Ljava/lang/Object; ¤¥ ¦version()J ¨© _ªjava/util/ArrayList¬ ­Ljava/util/List¯(Ljava/lang/Object;)Z l± °²7org/elasticsearch/cluster/routing/ImmutableShardRouting´4(Lorg/elasticsearch/cluster/routing/ShardRouting;J)V ,¶ µ·copyOfH(Ljava/util/Collection;)Lorg/elasticsearch/common/collect/ImmutableList; ¹º » ,- ½iIhighestVersionJrequiresNormalization shardRoutingsBLjava/util/List;Ljava/util/List;)()Lorg/elasticsearch/index/shard/ShardId; getShardId Ç É9()Lorg/elasticsearch/common/collect/UnmodifiableIterator; XË ÌgetSize ¢ getShards ‡ ÑgetActiveShards !‡ ÔgetAssignedShardscountWithState8(Lorg/elasticsearch/cluster/routing/ShardRoutingState;)I Zstate7()Lorg/elasticsearch/cluster/routing/ShardRoutingState; ÚÛ _Ü5Lorg/elasticsearch/cluster/routing/ShardRoutingState;countshardsRandomIt3()Lorg/elasticsearch/cluster/routing/ShardIterator;4org/elasticsearch/cluster/routing/PlainShardIteratorâ/org/elasticsearch/cluster/routing/ShardShuffleräshuffle"(Ljava/util/List;)Ljava/util/List; æç åè:(Lorg/elasticsearch/index/shard/ShardId;Ljava/util/List;)V ,ê ãëshardsIt4(I)Lorg/elasticsearch/cluster/routing/ShardIterator;#(Ljava/util/List;I)Ljava/util/List; æï åðseedactiveShardsRandomItactiveShardsIt activeInitializingShardsRandomItnextSeed öH å÷activeInitializingShardsIt ùî úaddAll(Ljava/util/Collection;)Z üý ­þorderedGLjava/util/ArrayList;Ljava/util/ArrayList;assignedShardsRandomItassignedShardsItprimaryShardIt primaryActiveInitializingShardIt á  primaryList&primaryFirstActiveInitializingShardsIt °Z ­² ­¢ ­¦set'(ILjava/lang/Object;)Ljava/lang/Object;  ­ shardRouting"onlyNodeActiveInitializingShardsItE(Ljava/lang/String;)Lorg/elasticsearch/cluster/routing/ShardIterator; currentNodeId()Ljava/lang/String;  _java/lang/Stringequals ± nodeIdLjava/lang/String;$preferNodeActiveInitializingShardsItgetActiveAttributeÆ(Lorg/elasticsearch/cluster/routing/IndexShardRoutingTable$AttributesKey;Lorg/elasticsearch/cluster/node/DiscoveryNodes;)Lorg/elasticsearch/cluster/routing/IndexShardRoutingTable$AttributesRoutings; java/util/Map$&(Ljava/lang/Object;)Ljava/lang/Object; ¤& %'(Ljava/util/Collection;)V ,) ­*collectAttributeShards¾(Lorg/elasticsearch/cluster/routing/IndexShardRoutingTable$AttributesKey;Lorg/elasticsearch/cluster/node/DiscoveryNodes;Ljava/util/ArrayList;)Lorg/elasticsearch/common/collect/ImmutableList; ,- .c(Lorg/elasticsearch/common/collect/ImmutableList;Lorg/elasticsearch/common/collect/ImmutableList;)V ,0 1+org/elasticsearch/common/collect/MapBuilder3 newMapBuilder>(Ljava/util/Map;)Lorg/elasticsearch/common/collect/MapBuilder; 56 47putS(Ljava/lang/Object;Ljava/lang/Object;)Lorg/elasticsearch/common/collect/MapBuilder; 9: 4; immutableMap =4 4>-org/elasticsearch/cluster/node/DiscoveryNodes@java/lang/ThrowableBfromtokeyHLorg/elasticsearch/cluster/routing/IndexShardRoutingTable$AttributesKey;nodes/Lorg/elasticsearch/cluster/node/DiscoveryNodes;MLorg/elasticsearch/cluster/routing/IndexShardRoutingTable$AttributesRoutings;getInitializingAttribute ­/ attributes[Ljava/lang/String; MN ON localNode0()Lorg/elasticsearch/cluster/node/DiscoveryNode; RS AT,org/elasticsearch/cluster/node/DiscoveryNodeV M4 WX 2' ­ZB(Ljava/lang/String;)Lorg/elasticsearch/cluster/node/DiscoveryNode; ¤\ A]remove _. a` fromShard discoveryNode.Lorg/elasticsearch/cluster/node/DiscoveryNode;FLjava/util/Iterator;localAttributeValue attributearr$len$*preferAttributesActiveInitializingShardsItu([Ljava/lang/String;Lorg/elasticsearch/cluster/node/DiscoveryNodes;)Lorg/elasticsearch/cluster/routing/ShardIterator;v([Ljava/lang/String;Lorg/elasticsearch/cluster/node/DiscoveryNodes;I)Lorg/elasticsearch/cluster/routing/ShardIterator; jl m([Ljava/lang/String;)V ,o p "# r K# t totalSize vÀ wwithSameAttribute y zwithoutSameAttribute | }activeRoutingsinitializingRoutings primaryShard replicaShards()Ljava/util/List;replicaShardsWithStateH([Lorg/elasticsearch/cluster/routing/ShardRoutingState;)Ljava/util/List;&org/elasticsearch/common/collect/Lists† newArrayList()Ljava/util/ArrayList; ˆ‰ ‡Š6[Lorg/elasticsearch/cluster/routing/ShardRoutingState;Œ shardEntrystatesshardsWithState Ì SignatureCodeLocalVariableTableLocalVariableTypeTableLineNumberTable StackMapTable(Lorg/elasticsearch/index/shard/ShardId;Lorg/elasticsearch/common/collect/ImmutableList;Z)Vk()Lorg/elasticsearch/common/collect/UnmodifiableIterator;d()Lorg/elasticsearch/common/collect/ImmutableList;"(Lorg/elasticsearch/cluster/routing/IndexShardRoutingTable$AttributesKey;Lorg/elasticsearch/cluster/node/DiscoveryNodes;Ljava/util/ArrayList;)Lorg/elasticsearch/common/collect/ImmutableList;D()Ljava/util/List;z([Lorg/elasticsearch/cluster/routing/ShardRoutingState;)Ljava/util/List; SourceFile InnerClasses! ’’ ’!’"’#’$%B&'’(B)'’(*+),-“© *·0*¸6µ8*¸6µ:*»Y·0µ<*+µ>*»@Y¸F¶J·MµO*,µQ*µS:¸W:¸W:¸W:¸W:,¶[:  ¹e™x ¹iÀ_:  ¹k™  :§  ¶oW ¹r™  ¶oW ¹u™  ¶oW ¹x™ ¹|¶oW ¹™  ¶oW§ÿ„*µÆ*¸„µ†§ *¸‰µ†*¶ŒµŽ*¶Œµ*¶Œµ’*¶Œµ”±”p pf• Z–— ˜™ $%@ÜE×›JÒ!›OÍ"›TÈ#›•4 EךJÒ!šOÍ"šTÈ#š–Ž#A¡ ¢£B"C3D8E=G@HEIJJOKTMpNzOQ‰S“T›V¥W­Y·[Ä]Î^Ö`Ùbßcädðf÷hi jkl—7 ÿZ ]_aü&_úú’˜œ“ç*´Q¶ ™*°*´Q¶£ *°*´Q¶§À_¹«@>6*´Q¶£¢I*´Q¶§À_¹«”™>*´Q¶§À_¹«”ž*´Q¶§À_¹«@„§ÿ±š*°»­Y*´Q¶£·®:6*´Q¶£¢O*´Q¶§À_¹«”š*´Q¶§¹³W§»µY*´Q¶§À_·¸¹³W„§ÿ«»Y*´>¸¼*´S·¾°”>/R¿ÀšX¿À˜™*ÝÁÂ,ÛÃ%—pÄÆ• —pÄÅ–Vr s uvx*y,z;{Q|S~i{z‚…ƒ‡…—†¦‡¼ˆÐŠì†ò— þ#'úý°5ú$c“/*´S¬” ˜™–•Ç“/*´>°” ˜™–žÈÇ“/*¶Ê°” ˜™–§XË“2*´Q¶Í°” ˜™–¬’™¡H“2*´Q¶£¬” ˜™–³ÎH“/*¶Ï¬” ˜™–º ‡“/*´Q°” ˜™–Ã’šЇ“/*¶Ò°” ˜™–Ì’š!‡“/*´°” ˜™–Õ’šÓ‡“/*¶Õ°” ˜™–Þ’š"‡“/*´’°” ˜™–ç’šÖ‡“/*´’°” ˜™–ð’š×Ø“§.=*¶ÙN-¹e™-¹iÀ_:+¹Ý¦„§ÿÞ¬”4•%–—.˜™.ÚÞ,ßÀ–úûü&ý)ÿ,— ýa!úàá“A»ãY*´>*´O*´Q¶é·ì°” ˜™–íá“:»ãY*´>*´Q·ì°” ˜™–íî“L»ãY*´>*´O*´Q¶ñ·ì°”˜™òÀ– óá“A»ãY*´>*´O*´¶é·ì°” ˜™–ôá“:»ãY*´>*´·ì°” ˜™–ôî“L»ãY*´>*´O*´¶ñ·ì°”˜™òÀ–õá“6 **´O¶ø¶û°”  ˜™– ùî“Í`*´”¶ ™»ãY*´>*´O*´¶ñ·ì°»­Y*´¶£*´”¶£`·®M,*´O*´¶ñ¶ÿW,*´”¶ÿW»ãY*´>,·ì°” `˜™`òÀ9'• 9'–( )"+9,J-S.—"á“A»ãY*´>*´O*´’¶é·ì°” ˜™–2á“:»ãY*´>*´’·ì°” ˜™–6î“L»ãY*´>*´O*´’¶ñ·ì°”˜™òÀ–:á“:»ãY*´>*´†·ì°” ˜™–Aá“£F*´†¶ š:*´†¶§À_¹rš'*´†¶§À_¹uš¸‰L»ãY*´>+·ì°*¶°”4  ÆF˜™• 4  Å–E0F4GAI—ûA á“„»­Y*´¶£*´”¶£`·®L*´O*´¶é¹ M,¹e™6,¹iÀ_N+-¶ W-¹k™++¶ d+¶¶W+-¶W§ÿÇ*´”¶ š +*´”¶ÿW»ãY*´>+·ì°”*;&(<–—„˜™m• m–* MO;PAQJSZTaVdXnYw[—ý(­a8ú“MŽ»­Y*´¶£*´”¶£`·®M>*´¶£¢+*´¶§À_:+¹¶™ ,¶ W„§ÿÐ>*´”¶£¢+*´”¶§À_:+¹¶™ ,¶ W„§ÿлãY*´>,·ì°”H13¿ÀfN3¿ÀŽ˜™Ž w• w–2 _a$b1c?dFaLgYhfitj{gm—ý­,úü,ú!“,Œ»­Y*´¶£*´”¶£`·®M*´O*´¶é¹ N-¹e™>-¹iÀ_:,¶ W+¹¶™,,¶ d,¶¶W,¶W§ÿ¿*´”¶ š ,*´”¶ÿW»ãY*´>,·ì°”4<-(D–—Œ˜™Œ u• u–* qs<tCuQwaxizl{v|~—ý(­aû@ú"#“.b*´8+¹(À N-ÇQ*´'+D0"Eb˜™bFGbHITÄJ•'+D0"E–& ¦§¨©'ª0¬?­R®`°—ÿXA CúK#“.b*´:+¹(À N-ÇQ*´'+D0"Eb˜™bFGbHITÄJ•'+D0"E–& ´µ¶·'¸0¹?ºR»`½—ÿXA Cú ,-“Ô  »­Y·LN*´P:¾66¢2:+¶U¶Y¶ZÀ:Æ^,¶[:  ¹e™N ¹iÀ_: + ¹¶^:  Ç  ¹a§# ¶Y¶Z¶™ ¹a- ¶ W§ÿ®„§ÿ~-¸¼°”z V<b c/cd @UX— 5`f $qg hNˆiÀ…–À FG HI D˜E• @UXe  D˜E–>ÁÂ$Ã5Ä:ÅJÆVÇcÈhÉrÊ„Ë‹Ì’Ε›Ñ—8ÿA­­Qþ)aý1_Wùøø’›jk“L*+,*´O¶ø¶n°” ˜™MNHI–Õjl“,Š»Y+·q:*,·s:*,·u:»­Y´x´x`·®:*´O´{¶ñ¶ÿW*´O´~¶ñ¶ÿW*´O´{¶ñ¶ÿW*´O´~¶ñ¶ÿW»ãY*´>·ì°”RŠ˜™ŠMNŠHIŠòÀ €FGwJn€J0Z• 0Z–& Ù ÚÛß0àCáVâiã|äz“/*´°” ˜™–肃“/*´Ž°” ˜™–ì’œ„…“D Y¸‹M*´Ž¶[N-¹e™E-¹iÀ_:+:¾66¢%2:¹Ý¦ ,¹³W„§ÿÚ§ÿ¸,°”\ 9ÚÞ#1hŒ(,iÀ+)–À 4Ž K–—Y˜™YŒU Æ• U Å–"ðñ ò9óEôNòT÷Wø—=ý °aÿ°a_"ÿ°aú’…“A V¸‹M*¶ÙN-¹e™E-¹iÀ_:+:¾66¢%2:¹Ý¦ ,¹³W„§ÿÚ§ÿ¸,°”\ 6ÚÞ 1hŒ%,iÀ()–À4Ž K–—V˜™VŒR Æ• R Å–"üýþ6ÿBKþQT—=ý °aÿ°a_"ÿ°aú’AXY“/*¶‘°” ˜™–-’žŸ"