4;com/hazelcast/internal/partition/impl/PartitionStateManagerjava/lang/ObjectPartitionStateManager.java=com/hazelcast/internal/partition/impl/PartitionStateManager$1nodeLcom/hazelcast/instance/Node;loggerLcom/hazelcast/logging/ILogger;partitionServiceDLcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;partitionCountI partitions>[Lcom/hazelcast/internal/partition/impl/InternalPartitionImpl; stateVersion+Ljava/util/concurrent/atomic/AtomicInteger;&Lcom/hazelcast/internal/metrics/Probe;partitionStateGenerator:Lcom/hazelcast/internal/partition/PartitionStateGenerator;memberGroupFactory8Lcom/hazelcast/partition/membergroup/MemberGroupFactory; initializedZmemberGroupsSize$assertionsDisabled(Lcom/hazelcast/instance/Node;Lcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;Lcom/hazelcast/internal/partition/PartitionListener;)V()V   )java/util/concurrent/atomic/AtomicInteger" #  %  'getClass()Ljava/lang/Class; )* +com/hazelcast/instance/Node- getLogger2(Ljava/lang/Class;)Lcom/hazelcast/logging/ILogger; /0 .1 3 5Bcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl7getPartitionCount()I 9: 8;  =;com/hazelcast/internal/partition/impl/InternalPartitionImpl?  AgetLocalMember%()Lcom/hazelcast/instance/MemberImpl; CD .E1com/hazelcast/internal/partition/PartitionReplicaGfromP(Lcom/hazelcast/core/Member;)Lcom/hazelcast/internal/partition/PartitionReplica; IJ HK2com/hazelcast/internal/partition/PartitionListenerMk(ILcom/hazelcast/internal/partition/PartitionListener;Lcom/hazelcast/internal/partition/PartitionReplica;)V O @P getConfig()Lcom/hazelcast/config/Config; RS .Tcom/hazelcast/config/ConfigVgetPartitionGroupConfig-()Lcom/hazelcast/config/PartitionGroupConfig; XY WZgetDiscoveryService<()Lcom/hazelcast/spi/discovery/integration/DiscoveryService; \] .^=com/hazelcast/partition/membergroup/MemberGroupFactoryFactory`newMemberGroupFactory(Lcom/hazelcast/config/PartitionGroupConfig;Lcom/hazelcast/spi/discovery/integration/DiscoveryService;)Lcom/hazelcast/partition/membergroup/MemberGroupFactory; bc ad  fAcom/hazelcast/internal/partition/impl/PartitionStateGeneratorImplh i  kithis=Lcom/hazelcast/internal/partition/impl/PartitionStateManager;listener4Lcom/hazelcast/internal/partition/PartitionListener; localReplica3Lcom/hazelcast/internal/partition/PartitionReplica;localPartitionCount2com/hazelcast/internal/partition/InternalPartitionvisLocal()Z xy wz partition4Lcom/hazelcast/internal/partition/InternalPartition;countcreateMemberGroups'(Ljava/util/Set;)Ljava/util/Collection;w(Ljava/util/Set;)Ljava/util/Collection;O(Lcom/hazelcast/internal/partition/impl/PartitionStateManager;Ljava/util/Set;)V  !com/hazelcast/core/MemberSelector4com/hazelcast/cluster/memberselector/MemberSelectorsDATA_MEMBER_SELECTOR#Lcom/hazelcast/core/MemberSelector; andI([Lcom/hazelcast/core/MemberSelector;)Lcom/hazelcast/core/MemberSelector; getClusterService:()Lcom/hazelcast/internal/cluster/impl/ClusterServiceImpl; .6com/hazelcast/internal/cluster/impl/ClusterServiceImpl getMembers;(Lcom/hazelcast/core/MemberSelector;)Ljava/util/Collection; 6com/hazelcast/partition/membergroup/MemberGroupFactory.(Ljava/util/Collection;)Ljava/util/Collection;  excludedMembers,Ljava/util/Set;Ljava/util/Set;excludeselectormembers3Ljava/util/Collection;Ljava/util/Collection;()Ljava/util/Collection;K()Ljava/util/Collection;initializePartitionAssignments(Ljava/util/Set;)Z/(Ljava/util/Set;)ZisPartitionAssignmentAllowed y   java/util/CollectionisEmpty y =No member group is available to assign partition ownership...com/hazelcast/logging/ILoggerwarning(Ljava/lang/String;)V 3Initializing cluster partition table arrangement...info 8com/hazelcast/internal/partition/PartitionStateGeneratorarrange(Ljava/util/Collection;[Lcom/hazelcast/internal/partition/InternalPartition;)[[Lcom/hazelcast/internal/partition/PartitionReplica; %com/hazelcast/core/HazelcastExceptionjava/lang/StringBuilder #Invalid partition count! Expected: append-(Ljava/lang/String;)Ljava/lang/StringBuilder; (I)Ljava/lang/StringBuilder;  , Actual: toString()Ljava/lang/String;  5[[Lcom/hazelcast/internal/partition/PartitionReplica;incrementAndGet : #getClusterState&()Lcom/hazelcast/cluster/ClusterState; "com/hazelcast/cluster/ClusterStateisMigrationAllowed y decrementAndGet : #2Partitions can't be assigned since cluster-state= -(Ljava/lang/Object;)Ljava/lang/StringBuilder;  setReplicas7([Lcom/hazelcast/internal/partition/PartitionReplica;)V @setInitialized y =Lcom/hazelcast/internal/partition/impl/InternalPartitionImpl;replicas4[Lcom/hazelcast/internal/partition/PartitionReplica; partitionId memberGroupsILjava/util/Collection;newState clusterState$Lcom/hazelcast/cluster/ClusterState;getNodeExtension(()Lcom/hazelcast/instance/NodeExtension;  .$com/hazelcast/instance/NodeExtension isStartCompleted  y   @Partitions can't be assigned since startup is not completed yet.+isFetchMostRecentPartitionTableTaskRequired y 8RPartitions can't be assigned since most recent partition table is not decided yet.setInitialState8(Lcom/hazelcast/internal/partition/PartitionTableView;)V  java/lang/IllegalStateException'Partition table is already initialized! "Setting cluster partition table...3com/hazelcast/internal/partition/PartitionTableView! getReplicas7(I)[Lcom/hazelcast/internal/partition/PartitionReplica; #$ "%reset6(Lcom/hazelcast/internal/partition/PartitionReplica;)V () @*setInitialReplicas , @- getVersion /: "0set(I)V 23 #4partitionTable5Lcom/hazelcast/internal/partition/PartitionTableView; foundReplicaupdateMemberGroupsSize  :iterator()Ljava/util/Iterator; <= >java/util/Iterator@hasNext By ACnext()Ljava/lang/Object; EF AG/com/hazelcast/partition/membergroup/MemberGroupIsize K: JL  Ngroup1Lcom/hazelcast/partition/membergroup/MemberGroup;groupsgetMemberGroupsSize isLiteMember Ty .UremoveUnknownMembers getReplica6(I)Lcom/hazelcast/internal/partition/PartitionReplica; XY @Zaddress()Lcom/hazelcast/nio/Address; \] H^uuid ` Ha getMemberR(Lcom/hazelcast/nio/Address;Ljava/lang/String;)Lcom/hazelcast/instance/MemberImpl; cd e setReplica7(ILcom/hazelcast/internal/partition/PartitionReplica;)V gh @iisFinestEnabled ky l PartitionId=ngetPartitionId p: @q s is removed from replica index: u , partition: wfinest y zreplicaclusterService8Lcom/hazelcast/internal/cluster/impl/ClusterServiceImpl;isAbsentInPartitionTable(Lcom/hazelcast/core/Member;)Zcom/hazelcast/core/MemberisOwnerOrBackup6(Lcom/hazelcast/internal/partition/PartitionReplica;)Z  @memberLcom/hazelcast/core/Member; getPartitions7()[Lcom/hazelcast/internal/partition/InternalPartition;getPartitionsCopy:com/hazelcast/internal/partition/impl/NopPartitionListener  5[Lcom/hazelcast/internal/partition/InternalPartition;copys(Lcom/hazelcast/internal/partition/PartitionListener;)Lcom/hazelcast/internal/partition/impl/InternalPartitionImpl;  @;Ljava/util/Collection;)[[Lcom/hazelcast/internal/partition/PartitionReplica;(Ljava/util/Collection;[Lcom/hazelcast/internal/partition/InternalPartition;Ljava/util/Collection;)[[Lcom/hazelcast/internal/partition/PartitionReplica;  9Partition rearrangement failed. Number of member groups:  LpartitionInclusionSet+Ljava/util/Collection;trySetMigratingFlag(I)Z.Setting partition-migrating flag. partitionId= setMigrating y @clearMigratingFlag/Clearing partition-migrating flag. partitionId=resetMigrating  @ isMigrating y @updateReplicas8(I[Lcom/hazelcast/internal/partition/PartitionReplica;)V setVersionversionget : #incrementVersion  java/lang/AssertionErrorDelta: (Ljava/lang/Object;)V   addAndGet(I)I  #deltaonPartitionStateChange    isInitialized replaceMember9(Lcom/hazelcast/core/Member;Lcom/hazelcast/core/Member;)IreplaceReplicai(Lcom/hazelcast/internal/partition/PartitionReplica;Lcom/hazelcast/internal/partition/PartitionReplica;)I  @ Replaced  with  in partition table in  partitions. oldMember newMember oldReplica newReplicagetPartitionTable7()Lcom/hazelcast/internal/partition/PartitionTableView;9([[Lcom/hazelcast/internal/partition/PartitionReplica;I)V  "9([Lcom/hazelcast/internal/partition/InternalPartition;I)V  "java/lang/ClassdesiredAssertionStatus y RuntimeVisibleAnnotationsCode StackMapTableLineNumberTableLocalVariableTableLocalVariableTypeTable Signature InnerClasses SourceFile!    BB>*!*#Y$&*+(*+*,24*,6*,<>**>@B+FL:6*>*B@Y-QS*+U[+_eg*iYjlD.8NH!BG9HI K%L-M8OAPMQ`PfToUrTxVW>D"mno  pqACrst:.<*BM,>6,2:{ u[\]#^&\,a  |}.no,~5Y*+MYSY,SN*(-:*ge kl)m45no5 +) 5) c*(L*g+ qrno   **+M,*4*4*l,*BN-*>+YYж*>ٶ-׶ݷ߿*&W*(:**&W*4Yݹ6*>*B2:-2:*W JB$^ #%0?HpxR |%no?^yg*( *4*(L+!*4Y+ݹ*6*4 /. (/KMWcegno(?*Y*4 =*(FLN6*>P*B2:+&:(#62=-+.*&+15*W9H%@'S"H@'N +7@HQ[kqw~RTm@>|H6.Vno67 y8+nrs98*;L=+?N-D-HJ:M*OA "",/27*" PQ8no3R1K 3RS:j*O<*(V   @ noKW`*(L*BM,>6,2:6[:j+_bfYj*4mE*4Yortvxݹ{~i*u@Hf6 )27:KS_42o|s"m|no}~1+LM*BN-66-2:,Hu')/* |1no1,|s/*B no0YL*BwM>*>,*B2+S, !"#(".%*m0no(p;*B2)noY**+N*l-*B,:1*4m%*4Y-׶ݹ{  I"-. 01#3(445V94YnoYYG#6 YYGx3*4m *4Y׶ݹ{*B2)= >)@3no33|3*4m *4Y׶ݹ{*B2)D E)G2H3no3> *B2K no ] *B2N-,PQ R* no  |3A *&5 VW no /:2*&Z no3u0#YY׶ݷĿ*&W&^&_/`0no07 *&W cd  noy_***( gh ijl noy/*p no(<**&5*(FLL*BM,>6,2:++#Hutu wx/y5x;{ /|<no$rsV *+LN,L:6*B:662:  -G*( *4Yն+׶,ٶ۶Զݹ&  HHuH6 ~ 3?BHMYH3| noss}~i.*"Y*B䰻"Y*B*& .no4 @0