33org/elasticsearch/cluster/routing/IndexRoutingTablebLjava/lang/Object;Ljava/lang/Iterable;java/lang/Objectjava/lang/IterableIndexRoutingTable.java;org/elasticsearch/cluster/routing/IndexRoutingTable$Builder Builder6org/elasticsearch/common/collect/ImmutableList$Builder .org/elasticsearch/common/collect/ImmutableListindexLjava/lang/String;shuffler1Lorg/elasticsearch/cluster/routing/ShardShuffler;shards6Lorg/elasticsearch/common/collect/ImmutableOpenIntMap;rLorg/elasticsearch/common/collect/ImmutableOpenIntMap; allShards0Lorg/elasticsearch/common/collect/ImmutableList;bLorg/elasticsearch/common/collect/ImmutableList;allActiveShardsK(Ljava/lang/String;Lorg/elasticsearch/common/collect/ImmutableOpenIntMap;)V()V     7org/elasticsearch/cluster/routing/RotationShardShuffler"&java/util/concurrent/ThreadLocalRandom$current*()Ljava/util/concurrent/ThreadLocalRandom; &' %(nextInt()I *+ %,(I)V . #/  1  3builder:()Lorg/elasticsearch/common/collect/ImmutableList$Builder; 56 74org/elasticsearch/common/collect/ImmutableOpenIntMap9iterator()Ljava/util/Iterator; ;< :=java/lang/String?java/util/IteratorAhasNext()Z CD BEnext()Ljava/lang/Object; GH BI5org/elasticsearch/common/hppc/cursors/IntObjectCursorKvalueLjava/lang/Object; MN LO8org/elasticsearch/cluster/routing/IndexShardRoutingTableQ R=.org/elasticsearch/cluster/routing/ShardRoutingTaddL(Ljava/lang/Object;)Lorg/elasticsearch/common/collect/ImmutableList$Builder; VW Xactive ZD U[build2()Lorg/elasticsearch/common/collect/ImmutableList; ]^ _  a  c shardRouting0Lorg/elasticsearch/cluster/routing/ShardRouting;i$Ljava/util/Iterator;cursorsLorg/elasticsearch/common/hppc/cursors/IntObjectCursor;7Lorg/elasticsearch/common/hppc/cursors/IntObjectCursor;this5Lorg/elasticsearch/cluster/routing/IndexRoutingTable;jLorg/elasticsearch/common/collect/ImmutableList$Builder;8Lorg/elasticsearch/common/collect/ImmutableList$Builder;()Ljava/lang/String;getIndex p rnormalizeVersions7()Lorg/elasticsearch/cluster/routing/IndexRoutingTable;(Ljava/lang/String;)V v w<()Lorg/elasticsearch/cluster/routing/IndexShardRoutingTable; ty Rz addIndexShardy(Lorg/elasticsearch/cluster/routing/IndexShardRoutingTable;)Lorg/elasticsearch/cluster/routing/IndexRoutingTable$Builder; |} ~ ]u =Lorg/elasticsearch/cluster/routing/IndexRoutingTable$Builder;validatej(Lorg/elasticsearch/cluster/routing/RoutingTableValidation;Lorg/elasticsearch/cluster/metadata/MetaData;)V+org/elasticsearch/cluster/metadata/MetaDatahasIndex(Ljava/lang/String;)Z -Exists in routing does not exists in metadata8org/elasticsearch/cluster/routing/RoutingTableValidationaddIndexFailure'(Ljava/lang/String;Ljava/lang/String;)V F(Ljava/lang/String;)Lorg/elasticsearch/cluster/metadata/IndexMetaData;  D(Lorg/elasticsearch/cluster/metadata/IndexMetaData;)Ljava/util/List; java/util/List =0org/elasticsearch/cluster/metadata/IndexMetaDatafailure validation:Lorg/elasticsearch/cluster/routing/RoutingTableValidation;metaData-Lorg/elasticsearch/cluster/metadata/MetaData; indexMetaData2Lorg/elasticsearch/cluster/metadata/IndexMetaData;java/util/ArrayList numberOfShards + 8()Lorg/elasticsearch/common/collect/ImmutableOpenIntMap;  size + :%org/elasticsearch/common/collect/Sets newHashSet()Ljava/util/HashSet;  java/util/Setjava/lang/IntegervalueOf(I)Ljava/lang/Integer; (Ljava/lang/Object;)Z V =shardId)()Lorg/elasticsearch/index/shard/ShardId; R%org/elasticsearch/index/shard/ShardIdid + remove java/lang/StringBuilder 2Wrong number of shards in routing table, missing: append-(Ljava/lang/String;)Ljava/lang/StringBuilder; -(Ljava/lang/Object;)Ljava/lang/StringBuilder; toString p RnumberOfReplicas + Shard [(I)Ljava/lang/StringBuilder; 8] routing table has wrong number of replicas, expected [], got [] Urequals @shard routing has an index [*] that is different than the routing tableiIindexShardRoutingTable:Lorg/elasticsearch/cluster/routing/IndexShardRoutingTable;expected$Ljava/util/Set;Ljava/util/Set;routingNumberOfReplicasfailures)Ljava/util/ArrayList;Ljava/util/ArrayList;9()Lorg/elasticsearch/common/collect/UnmodifiableIterator;valuesIt  :!numberOfNodesShardsAreAllocatedOn([Ljava/lang/String;)IassignedToNode D U currentNodeId  p U [Ljava/lang/String;  excludedNodearr$len$excludedZshardRoutingTable excludedNodesnodes#Ljava/util/Set; getShardsshard=(I)Lorg/elasticsearch/cluster/routing/IndexShardRoutingTable;get(I)Ljava/lang/Object;  :allPrimaryShardsActiveprimaryShardsActive !+ " primaryShard2()Lorg/elasticsearch/cluster/routing/ShardRouting; $% R&counterallPrimaryShardsUnassignedprimaryShardsUnassigned *+ + unassigned -D U.shardsWithStateH([Lorg/elasticsearch/cluster/routing/ShardRoutingState;)Ljava/util/List;&org/elasticsearch/common/collect/Lists2 newArrayList()Ljava/util/ArrayList; 45 36 01 R8addAll(Ljava/util/Collection;)Z :; <states6[Lorg/elasticsearch/cluster/routing/ShardRoutingState;BLjava/util/List;Ljava/util/List;randomAllShardsIt4()Lorg/elasticsearch/cluster/routing/ShardsIterator;5org/elasticsearch/cluster/routing/PlainShardsIteratorD/org/elasticsearch/cluster/routing/ShardShufflerFshuffle"(Ljava/util/List;)Ljava/util/List; HI GJ(Ljava/util/List;)V L EMrandomAllActiveShardsItgroupByShardsIt9()Lorg/elasticsearch/cluster/routing/GroupShardsIterator; /shardsIt3()Lorg/elasticsearch/cluster/routing/ShardIterator; ST RU5org/elasticsearch/cluster/routing/GroupShardsIteratorW XM indexShardsetHLjava/util/ArrayList; groupByAllIt UU;)VX(Lorg/elasticsearch/cluster/metadata/IndexMetaData;)Ljava/util/List;u()Lorg/elasticsearch/common/collect/UnmodifiableIterator;t()Lorg/elasticsearch/common/collect/ImmutableOpenIntMap;z([Lorg/elasticsearch/cluster/routing/ShardRoutingState;)Ljava/util/List; Exceptions SourceFile InnerClasses! **+!*#Y)-02*,48N8:,>:FQJL:PRS:F+JU:-YW\ YWѧ*-`b*`d\ gefQ2ghD?ik.Xghlm#uo(po*D?ij#un(pnBGH IJK#L(MDNgOnPxQSTUVW+.@:  B"LB.p/*! lm_qp/*s lmitu> Y*!xL*4>M,F,JLN+-PR{W+*'ik%gh>lm 25 'ijr s't6u9v B$O,*s+*s,*sN*-:FJ@:+*!>A +#ghOlmOO0"z {|~AKNB"|?YM+*nN6+-W*:F$JR:-ƶ˸W,YӶ-ڶݶW*N-F-JR:d6+=,Yƶ˶+׶ݶWS:FFJU:*s&,Y׶ݶWL,z T>+ghg4efMghgh?lm?7g7R&28Tfi7:=7 B*B_RBI;2*4 lm M*N-F-JR:S:FiJU: P :6+2+:  6 6     2:  6  ,Wu, m W, \' _$g MD PA:Wef$pghw ghlm  F:DMPTmwz}F BRB: BRBU@ /*4 lm/* lm@ *4R lm  DI*#* lm@!+.<*M,F,JRN-'\*%gh.lm,(&), B!)DI*,*4 lm@*+.<*M,F,JRN-'/*%gh.lm,(&), B!01/7M*N-F-JR:,+9=W,4  $gh/lm/>?+A +@   * - B#BC=EY*2*bKN lmOC=EY*2*dKN lmPQ<Y*4RL*M,F,JRN+-VWXY+Y*' Zgh<lm-[ -[\%&''0(3)B]QWYL*M,F;,JRN-S:FJU:+^Wާ»XY+Y>< ef&%gh +Z AghWlmO[ O[\56 7<8H9K:N; BRB$+ lm?` 5a3 Y*x  Bbp?YYd*!f׶ݷgL*M,Fr,JRN+i-ƶlqs-ƶ˶fW-S:F*JU:+uxzWҧ+ݰ>fn1gh=bZ*xghlm%{|" % = h  *BCRB0A;</*~ lm;/*4 m;