3.org/elasticsearch/cluster/routing/RoutingNodesWLjava/lang/Object;Ljava/lang/Iterable;java/lang/Objectjava/lang/IterableRoutingNodes.javaBorg/elasticsearch/cluster/routing/RoutingNodes$RoutingNodeIterator RoutingNodeIteratorCorg/elasticsearch/cluster/routing/RoutingNodes$RoutingNodesIterator RoutingNodesIterator?org/elasticsearch/cluster/routing/RoutingNodes$UnassignedShardsUnassignedShardsjava/util/Map$Entry java/util/MapEntry6org/elasticsearch/cluster/metadata/IndexMetaData$State0org/elasticsearch/cluster/metadata/IndexMetaDataStatemetaData-Lorg/elasticsearch/cluster/metadata/MetaData;blocks/Lorg/elasticsearch/cluster/block/ClusterBlocks; routingTable0Lorg/elasticsearch/cluster/routing/RoutingTable; nodesToShardsLjava/util/Map;RLjava/util/Map;unassignedShardsALorg/elasticsearch/cluster/routing/RoutingNodes$UnassignedShards;ignoredUnassignedShardsLjava/util/List;ILjava/util/List;assignedShardsLjava/util/Map;>;inactivePrimaryCountIinactiveShardCountrelocatingShardsclearPostAllocationFlagLjava/util/Set;8Ljava/util/Set;nodesPerAttributeNameskLjava/util/Map;>;EMPTY$assertionsDisabledZ+(Lorg/elasticsearch/cluster/ClusterState;)V()V 8: ;%org/elasticsearch/common/collect/Maps= newHashMap()Ljava/util/HashMap; ?@ >A "# C ; %& F&org/elasticsearch/common/collect/ListsH newArrayList()Ljava/util/ArrayList; JK IL '( N *# P ,- R .- T /- Vjava/util/HashMapX Y; 3# [&org/elasticsearch/cluster/ClusterState]/()Lorg/elasticsearch/cluster/metadata/MetaData; _ ^`  b1()Lorg/elasticsearch/cluster/block/ClusterBlocks; d ^e  g2()Lorg/elasticsearch/cluster/routing/RoutingTable; i ^j ! lnodes1()Lorg/elasticsearch/cluster/node/DiscoveryNodes; no ^p-org/elasticsearch/cluster/node/DiscoveryNodesr dataNodes5()Lorg/elasticsearch/common/collect/ImmutableOpenMap; tu sv1org/elasticsearch/common/collect/ImmutableOpenMapxvalues1()Lorg/elasticsearch/common/hppc/ObjectContainer; z{ y|-org/elasticsearch/common/hppc/ObjectContainer~iterator()Ljava/util/Iterator; java/util/IteratorhasNext()Z next()Ljava/lang/Object; 2org/elasticsearch/common/hppc/cursors/ObjectCursorvalueLjava/lang/Object; ,org/elasticsearch/cluster/node/DiscoveryNodeid()Ljava/lang/String; java/util/ArrayList ;put8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; .org/elasticsearch/cluster/routing/RoutingTableindicesRouting()Ljava/util/Map; ()Ljava/util/Collection; z java/util/Collection 3org/elasticsearch/cluster/routing/IndexRoutingTable 8org/elasticsearch/cluster/routing/IndexShardRoutingTable .org/elasticsearch/cluster/routing/ShardRoutingassignedToNode  currentNodeId get&(Ljava/lang/Object;)Ljava/lang/Object; java/util/List5org/elasticsearch/cluster/routing/MutableShardRouting3(Lorg/elasticsearch/cluster/routing/ShardRouting;)V 8 add(Ljava/lang/Object;)Z assignedShardsAdd:(Lorg/elasticsearch/cluster/routing/MutableShardRouting;)V  relocating relocatingNodeId index ()I primary 3org/elasticsearch/cluster/routing/ShardRoutingState INITIALIZING5Lorg/elasticsearch/cluster/routing/ShardRoutingState; version()J q(Ljava/lang/String;ILjava/lang/String;Ljava/lang/String;ZLorg/elasticsearch/cluster/routing/ShardRoutingState;J)V 8 active entrySet()Ljava/util/Set;  java/util/Set getKey java/lang/String-org/elasticsearch/cluster/routing/RoutingNodeB(Ljava/lang/String;)Lorg/elasticsearch/cluster/node/DiscoveryNode; sgetValue  S(Ljava/lang/String;Lorg/elasticsearch/cluster/node/DiscoveryNode;Ljava/util/List;)V 8 cursordLorg/elasticsearch/common/hppc/cursors/ObjectCursor;4Lorg/elasticsearch/common/hppc/cursors/ObjectCursor;i$Ljava/util/Iterator;entriessr7Lorg/elasticsearch/cluster/routing/MutableShardRouting;shard0Lorg/elasticsearch/cluster/routing/ShardRouting; indexShard:Lorg/elasticsearch/cluster/routing/IndexShardRoutingTable;indexRoutingTable5Lorg/elasticsearch/cluster/routing/IndexRoutingTable;nodeIdLjava/lang/String;entryrLjava/util/Map$Entry;>;Ljava/util/Map$Entry;this0Lorg/elasticsearch/cluster/routing/RoutingNodes; clusterState(Lorg/elasticsearch/cluster/ClusterState;lLjava/util/Map;>;*org/elasticsearch/common/collect/IteratorsunmodifiableIteratorM(Ljava/util/Iterator;)Lorg/elasticsearch/common/collect/UnmodifiableIterator;  ! "getRoutingTable j getMetaData ` getBlocks$requiredAverageNumberOfShardsPerNode+org/elasticsearch/cluster/metadata/MetaData*indices ,u +-state:()Lorg/elasticsearch/cluster/metadata/IndexMetaData$State; /0 1OPEN8Lorg/elasticsearch/cluster/metadata/IndexMetaData$State; 34 5totalNumberOfShards 7 8size : ; indexMetaData2Lorg/elasticsearch/cluster/metadata/IndexMetaData;hLorg/elasticsearch/common/hppc/cursors/ObjectCursor; hasUnassignedisEmpty A BignoredUnassigned()Ljava/util/List; unassignedC()Lorg/elasticsearch/cluster/routing/RoutingNodes$UnassignedShards;G()Lorg/elasticsearch/cluster/routing/RoutingNodes$RoutingNodesIterator;G(Lorg/elasticsearch/cluster/routing/RoutingNodes;Ljava/util/Iterator;)V 8I JaddClearPostAllocationFlag*(Lorg/elasticsearch/index/shard/ShardId;)V 01 N%org/elasticsearch/common/collect/SetsP newHashSet()Ljava/util/HashSet; RS QT shardId'Lorg/elasticsearch/index/shard/ShardId;"getShardsToClearPostAllocationFlag()Ljava/lang/Iterable;-org/elasticsearch/common/collect/ImmutableSet[of1()Lorg/elasticsearch/common/collect/ImmutableSet; ]^ \_nodeC(Ljava/lang/String;)Lorg/elasticsearch/cluster/routing/RoutingNode;nodesPerAttributesCountsH(Ljava/lang/String;)Lorg/elasticsearch/common/hppc/ObjectIntOpenHashMap;2org/elasticsearch/common/hppc/ObjectIntOpenHashMape f; 0()Lorg/elasticsearch/cluster/node/DiscoveryNode; ai j attributes1()Lorg/elasticsearch/common/collect/ImmutableMap; lm n-org/elasticsearch/common/collect/ImmutableMapp qaddTo(Ljava/lang/Object;I)I st fu attrValue routingNode/Lorg/elasticsearch/cluster/routing/RoutingNode; attributeNameHLorg/elasticsearch/common/hppc/ObjectIntOpenHashMap;4Lorg/elasticsearch/common/hppc/ObjectIntOpenHashMap;hasUnassignedPrimaries numPrimaries ~ hasUnassignedShardshasInactivePrimarieshasInactiveShardsgetRelocatingShardCount activePrimaryi(Lorg/elasticsearch/cluster/routing/ShardRouting;)Lorg/elasticsearch/cluster/routing/MutableShardRouting;)()Lorg/elasticsearch/index/shard/ShardId; W 9(Lorg/elasticsearch/index/shard/ShardId;)Ljava/util/List; *   shardRouting activeReplicaF(Lorg/elasticsearch/cluster/routing/ShardRouting;)Ljava/lang/Iterable;allReplicasActive3(Lorg/elasticsearch/cluster/routing/ShardRouting;)Z B ;I(Ljava/lang/String;)Lorg/elasticsearch/cluster/routing/IndexRoutingTable;  =(I)Lorg/elasticsearch/cluster/routing/IndexShardRoutingTable;   ;shards;(Lorg/elasticsearch/common/base/Predicate;)Ljava/util/List; 'org/elasticsearch/common/base/Predicateapply   predicatebLorg/elasticsearch/common/base/Predicate;)Lorg/elasticsearch/common/base/Predicate;shardsWithStateH([Lorg/elasticsearch/cluster/routing/ShardRoutingState;)Ljava/util/List;  addAll(Ljava/util/Collection;)Z  6[Lorg/elasticsearch/cluster/routing/ShardRoutingState; UNASSIGNED   FG *org/elasticsearch/common/collect/Iterables-(Ljava/util/Collection;Ljava/lang/Iterable;)Z  sarr$len$Z(Ljava/lang/String;[Lorg/elasticsearch/cluster/routing/ShardRoutingState;)Ljava/util/List;    equals  unassignedShard prettyPrintjava/lang/StringBuilderrouting_nodes: (Ljava/lang/String;)V 8   append-(Ljava/lang/String;)Ljava/lang/StringBuilder;  ---- unassigned -------- shortSummary  (C)Ljava/lang/StringBuilder;  toString   shardEntrysbLjava/lang/StringBuilder;assignL(Lorg/elasticsearch/cluster/routing/MutableShardRouting;Ljava/lang/String;)V7()Lorg/elasticsearch/cluster/routing/ShardRoutingState; /  assignToNode   ab   RELOCATING  oldStaterelocate  started 67   java/lang/AssertionError ; moveToStarted : cancelRelocation : swapPrimaryFlag;([Lorg/elasticsearch/cluster/routing/MutableShardRouting;)V8[Lorg/elasticsearch/cluster/routing/MutableShardRouting; moveFromPrimary  :  F  access$010D(Lorg/elasticsearch/cluster/routing/RoutingNodes$UnassignedShards;)I   moveToPrimary :  access$008   5( java/util/CollectionsunmodifiableList"(Ljava/util/List;)Ljava/util/List;  ! " replicaSetremove  &assignedShardsRemove ( ) assertInstanceNotInListJ(Lorg/elasticsearch/cluster/routing/MutableShardRouting;Ljava/util/List;)Z ,- . %: 0 Illegal state2(Ljava/lang/Object;)V 84 5MLjava/util/Iterator;isKnown1(Lorg/elasticsearch/cluster/node/DiscoveryNode;)ZgetId : ; containsKey = >.Lorg/elasticsearch/cluster/node/DiscoveryNode;addNode1(Lorg/elasticsearch/cluster/node/DiscoveryNode;)VC(Ljava/lang/String;Lorg/elasticsearch/cluster/node/DiscoveryNode;)V 8C D  FroutingNodeIterX(Ljava/lang/String;)Lorg/elasticsearch/cluster/routing/RoutingNodes$RoutingNodeIterator;b(Lorg/elasticsearch/cluster/routing/RoutingNodes;Lorg/elasticsearch/cluster/routing/RoutingNode;)V 8J KtoArray2()[Lorg/elasticsearch/cluster/routing/RoutingNode;(([Ljava/lang/Object;)[Ljava/lang/Object; MO P0[Lorg/elasticsearch/cluster/routing/RoutingNode;RassertShardStats3(Lorg/elasticsearch/cluster/routing/RoutingNodes;)Zjava/lang/IntegerV valueOf(I)Ljava/lang/Integer; YZ W[intValue ] W^java/lang/Math`max(II)I bc ad%org/elasticsearch/index/shard/ShardIdf(Ljava/lang/String;I)V 8h gicontains k l % n ;Unassigned primaries is [q(I)Ljava/lang/StringBuilder; s t2] but RoutingNodes returned unassigned primaries [v]xInactive Primary count [z0] but RoutingNodes returned inactive primaries [|Inactive Shard count [~-] but RoutingNodes returned inactive shards [  Relocating shards mismatch [] but expected [iLjava/lang/Integer;rmutableShardRoutingse; routingNodesrununassignedPrimaryCount seenShardsindicesAndShards6Ljava/util/Map;MLjava/util/Set;>; access$200j(Lorg/elasticsearch/cluster/routing/RoutingNodes;Lorg/elasticsearch/cluster/routing/MutableShardRouting;)V % x0x1java/lang/ClassdesiredAssertionStatus   emptyList E  SignatureCodeLocalVariableTableLocalVariableTypeTableLineNumberTable StackMapTableG()Ljava/util/Iterator;K()Ljava/util/List;?()Ljava/lang/Iterable;\(Ljava/lang/String;)Lorg/elasticsearch/common/hppc/ObjectIntOpenHashMap;(Lorg/elasticsearch/cluster/routing/ShardRouting;)Ljava/lang/Iterable;(Lorg/elasticsearch/common/base/Predicate;)Ljava/util/List;([Lorg/elasticsearch/cluster/routing/ShardRoutingState;)Ljava/util/List;(Ljava/lang/String;[Lorg/elasticsearch/cluster/routing/ShardRoutingState;)Ljava/util/List;r(Lorg/elasticsearch/index/shard/ShardId;)Ljava/util/List;(Lorg/elasticsearch/cluster/routing/MutableShardRouting;Ljava/util/List;)Z SourceFile InnerClasses! !"#$%&'()*#+,-.-/-0123#45()67/89 z*<*BD*YEG*MO*BQ*S*U*W*YYZ\*+ac*+fh*+kmBM+qw}N-*-:,YW*mN-p-::Q::1:,:  M: , WY:   W* ,: *YW`W M: , WY:   W* ͧ+! *YS`S*YU`UY: * *G ˧,N-E-::*DY+qW~j0   ( ;     8  ?X  _v  N(B4.K  zzZ "#*~ ) B4Z "4E3 579$;)=.?3C>FFGNHVJZL~MNRSTYZ[\ ]0_;`EaKbUcgdqevf{gkmnopqsuv wxz{|"}B~Nvy\j^/KZH  J<*D#  i/*m $i/*% _/*c &_/*' d/*h (d/*h )P<*c.}M,,,N-:26 9`<*D<l4.=>%2  PN7- %?%.9AD .@E*GC @DE/*O FG/*G nHA Y**DK LMc*O *UO*O+VWWXYZK*O`*O   abB*D+cd_*\+fM,,fYgM*hN-*-:ko+r:,vW*\+,W,>Fw5xy!0  __zQc| Qc{* 5FNQ]f /}E*G @E*GC @B *S   @B *U   @/*W 8*+M, ,N- --*# &  88#136 "8*+M, ,N- --*# &  88#1 3 6  "*? *+  b*+M,%,*m++,N--:4S  ?!  bb W(  W)" 68S [!]#`$6VMM*hN-E-::&:+ ,W֧,H: $-  4xy K  VVR(VR)"()*:+E,N.Q/T0 )/_MM*hN--:,+W+N-66#-2:,*W ,\  xy $  C/.3*-6' -__/[( [)* 567*8-9C:K;T<W9]? #  MN*h: :-+,¹W,:66R2:=*G:':  +Ǚ - Wէ -z xy '  q [.  JB4^9Y-<V -/( )6 DE F.G1HJIRJqK}LNOHR) & *nYͷL*hM,,N+-ҶW+ضW*GM,$,N+ڶ-ݶ W+># xy  R ?*  n c& V W#X,Y/Z7[R\f]i^)O+N+,*,+-*YU`U+ *YS`S+ *YW`W*+ͱ*OO OJ. tu vwx$y+z5~?IN 5V*YW`W+,   W+(+!*YUdU+!*YSdS+ *YWdW+ Y+WW & ,3=RV,K*YWdW+    P+M,>6D,2:#*GW *GW>5 M J-G -PP * !)49AIO +**Q+M, ,# WX$( $)  C%S+=+6*YUdU*U Y+*YSdS+*+'*+*SS & -4AHMR- P+*Q++M,MM*Q++,W*+,/ Y,+W PP 7( 7)& !0GO ',-4,N-%-:+ Y4 +  44 4( 4)/2 '(H*Q++M,5,N-+--1Y36*+ HH 7$(+77$)& %/56G89B*D+<?a@ABcY++EM*D,G,W a@ xy HIv*D+M, Y*,L xyMNH*D*D<QS  TUzm<Y< Y=>66U:YYZ:*h::  :   :  !     +VW ĹW:   X\:   _ Xe\WoO:M: :  ' :  : 6   W_*h:S::3: ǙX  Wɧ*gY  j:  Y:6: m Y oWƲ  Y *:  * :   +VWҲ@*G5YYpruw*uyֶ6:*S2YYp{u}*Suyֶ6<*U3YYpu*Uuyֶ6<*3YYp*uuyֶ6, m{ W  Pay :  u! _:  XAxyBZ  $ =  }(*- '   .  R <1  mk7O- M,-#J.-&G-+B149#v 1q( >}) +B249v q) 8 #&+4Pm}'<Xu*03RZ]jm,k ; ,W $6//  B<>>:*+ +:> + @*    @