4$Ocom/hazelcast/internal/partition/impl/MigrationManager$RepairPartitionTableTaskjava/lang/Object7com/hazelcast/internal/partition/impl/MigrationRunnableMigrationManager.java6com/hazelcast/internal/partition/impl/MigrationManagerRepairPartitionTableTaskjava/util/Map$Entry  java/util/Map Entry8com/hazelcast/internal/partition/impl/MigrationManager$1Icom/hazelcast/internal/partition/impl/MigrationManager$RepartitioningTaskRepartitioningTaskTcom/hazelcast/internal/partition/impl/InternalMigrationListener$MigrationParticipant?com/hazelcast/internal/partition/impl/InternalMigrationListenerMigrationParticipant>com/hazelcast/internal/partition/MigrationInfo$MigrationStatus.com/hazelcast/internal/partition/MigrationInfoMigrationStatus$assertionsDisabledZthis$08Lcom/hazelcast/internal/partition/impl/MigrationManager;;(Lcom/hazelcast/internal/partition/impl/MigrationManager;)V !" %()V #' (thisQLcom/hazelcast/internal/partition/impl/MigrationManager$RepairPartitionTableTask;run access$1100w(Lcom/hazelcast/internal/partition/impl/MigrationManager;)Lcom/hazelcast/internal/partition/impl/PartitionStateManager; -. /;com/hazelcast/internal/partition/impl/PartitionStateManager1 isInitialized()Z 34 25 access$600W(Lcom/hazelcast/internal/partition/impl/MigrationManager;)Lcom/hazelcast/instance/Node; 78 9com/hazelcast/instance/Node;getClusterService:()Lcom/hazelcast/internal/cluster/impl/ClusterServiceImpl; => <?6com/hazelcast/internal/cluster/impl/ClusterServiceImplAgetClusterState&()Lcom/hazelcast/cluster/ClusterState; CD BE"com/hazelcast/cluster/ClusterStateGisMigrationAllowed I4 HJisPartitionPromotionAllowed L4 HM access$100Y(Lcom/hazelcast/internal/partition/impl/MigrationManager;)Lcom/hazelcast/logging/ILogger; OP QfWill not repair partition table at the moment. Cluster state does not allow to modify partition table.Scom/hazelcast/logging/ILoggerUfine(Ljava/lang/String;)V WX VY(removeUnknownMembersAndCollectPromotions()Ljava/util/Map; [\ ]promoteBackupsForMissingOwners(Ljava/util/Map;)Z _` a access$400[(Lcom/hazelcast/internal/partition/impl/MigrationManager;)Ljava/util/concurrent/locks/Lock; cd ejava/util/concurrent/locks/Lockglock i' hjisFinestEnabled l4 VmRepartitioningTask scheduledofinest qX Vr access$900p(Lcom/hazelcast/internal/partition/impl/MigrationManager;)Lcom/hazelcast/internal/partition/impl/MigrationQueue; tu vu(Lcom/hazelcast/internal/partition/impl/MigrationManager;Lcom/hazelcast/internal/partition/impl/MigrationManager$1;)V #x y4com/hazelcast/internal/partition/impl/MigrationQueue{add<(Lcom/hazelcast/internal/partition/impl/MigrationRunnable;)V }~ |triggerControlTask ' unlock ' hjava/lang/Throwable clusterState$Lcom/hazelcast/cluster/ClusterState; promotionsLjava/util/Map;>;Ljava/util/Map;success()Ljava/util/Map;>;removeUnknownMembers ' 2java/util/HashMap ( access$200~(Lcom/hazelcast/internal/partition/impl/MigrationManager;)Lcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl; Bcom/hazelcast/internal/partition/impl/InternalPartitionServiceImplgetPartitionCount()I %createPromotionMigrationIfOwnerIsNull3(I)Lcom/hazelcast/internal/partition/MigrationInfo; getDestination5()Lcom/hazelcast/internal/partition/PartitionReplica; get&(Ljava/lang/Object;)Ljava/lang/Object; java/util/Collectionjava/util/ArrayList (put8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; (Ljava/lang/Object;)Z }  migration0Lcom/hazelcast/internal/partition/MigrationInfo; migrationsHLjava/util/Collection;Ljava/util/Collection; partitionIdI(Ljava/util/Map;>;)ZentrySet()Ljava/util/Set;  java/util/Setiterator()Ljava/util/Iterator; java/util/IteratorhasNext 4 next()Ljava/lang/Object; getKey 1com/hazelcast/internal/partition/PartitionReplicagetValue commitPromotionMigrationsL(Lcom/hazelcast/internal/partition/PartitionReplica;Ljava/util/Collection;)Z  destination3Lcom/hazelcast/internal/partition/PartitionReplica;entryLjava/util/Map$Entry;>;Ljava/util/Map$Entry; allSucceeded~(Lcom/hazelcast/internal/partition/PartitionReplica;Ljava/util/Collection;)Z access$1600{(Lcom/hazelcast/internal/partition/impl/MigrationManager;)Lcom/hazelcast/internal/partition/impl/InternalMigrationListener; MASTERVLcom/hazelcast/internal/partition/impl/InternalMigrationListener$MigrationParticipant; onPromotionStarto(Lcom/hazelcast/internal/partition/impl/InternalMigrationListener$MigrationParticipant;Ljava/util/Collection;)V commitPromotionsToDestination getLocalMember%()Lcom/hazelcast/instance/MemberImpl; < isIdentical(Lcom/hazelcast/core/Member;)Z processPromotionCommitResultM(Lcom/hazelcast/internal/partition/PartitionReplica;Ljava/util/Collection;Z)V onPromotionCompletep(Lcom/hazelcast/internal/partition/impl/InternalMigrationListener$MigrationParticipant;Ljava/util/Collection;Z)V  publishPartitionRuntimeState ' local(Lcom/hazelcast/internal/partition/PartitionReplica;Ljava/util/Collection;Z)V getPartitionId   getPartitionImpl@(I)Lcom/hazelcast/internal/partition/impl/InternalPartitionImpl;  2  ;com/hazelcast/internal/partition/impl/InternalPartitionImplgetOwnerReplicaOrNull  java/lang/AssertionErrorjava/lang/StringBuilder (Owner should be null: append-(Ljava/lang/String;)Ljava/lang/StringBuilder;  ! "-(Ljava/lang/Object;)Ljava/lang/StringBuilder;  $ %toString()Ljava/lang/String; '( )(Ljava/lang/Object;)V #+ ,!getDestinationCurrentReplicaIndex . / getReplica6(I)Lcom/hazelcast/internal/partition/PartitionReplica; 12 3equals 5 6Invalid replica! Destination: 8 , index: :(I)Ljava/lang/StringBuilder;  < =, ? swapReplicas(II)V AB Csize E FgetPartitionStateManager?()Lcom/hazelcast/internal/partition/impl/PartitionStateManager; HI JincrementVersion(I)V LM 2N partition=Lcom/hazelcast/internal/partition/impl/InternalPartitionImpl;delta partitionId=S   owner is removed. replicaIndex=V will be shifted up to 0. X: owner is removed. there is no other replica to shift up. Zn(ILcom/hazelcast/internal/partition/PartitionReplica;Lcom/hazelcast/internal/partition/PartitionReplica;IIII)V #\ ]getThisAddress()Lcom/hazelcast/nio/Address; _` <a setMasterM(Lcom/hazelcast/nio/Address;)Lcom/hazelcast/internal/partition/MigrationInfo; cd eSUCCESS@Lcom/hazelcast/internal/partition/MigrationInfo$MigrationStatus; gh i setStatusr(Lcom/hazelcast/internal/partition/MigrationInfo$MigrationStatus;)Lcom/hazelcast/internal/partition/MigrationInfo; kl m is completely lost!owarning qX VrgetPartitionEventManager?()Lcom/hazelcast/internal/partition/impl/PartitionEventManager; tu v;com/hazelcast/internal/partition/impl/PartitionEventManagerxsendPartitionLostEvent zB y{iindexpartitionEventManager=Lcom/hazelcast/internal/partition/impl/PartitionEventManager;%No promotions to commit! destination=address ` uuid (  getMemberR(Lcom/hazelcast/nio/Address;Ljava/lang/String;)Lcom/hazelcast/instance/MemberImpl;  B&Cannot commit promotions. Destination  is not a member anymorecom/hazelcast/core/Member&Sending promotion commit operation to  for #createPromotionCommitPartitionStateP(Ljava/util/Collection;)Lcom/hazelcast/internal/partition/PartitionRuntimeState;  getUuid ( Ccom/hazelcast/internal/partition/operation/PromotionCommitOperationc(Lcom/hazelcast/internal/partition/PartitionRuntimeState;Ljava/util/Collection;Ljava/lang/String;)V #  access$1700a(Lcom/hazelcast/internal/partition/impl/MigrationManager;)Lcom/hazelcast/spi/impl/NodeEngineImpl;  %com/hazelcast/spi/impl/NodeEngineImplgetOperationServiceD()Lcom/hazelcast/spi/impl/operationservice/InternalOperationService;  hz:core:partitionService@com/hazelcast/spi/impl/operationservice/InternalOperationServicecreateInvocationBuilderq(Ljava/lang/String;Lcom/hazelcast/spi/Operation;Lcom/hazelcast/nio/Address;)Lcom/hazelcast/spi/InvocationBuilder;  #com/hazelcast/spi/InvocationBuilder setTryCount((I)Lcom/hazelcast/spi/InvocationBuilder;   access$2600;(Lcom/hazelcast/internal/partition/impl/MigrationManager;)J  setCallTimeout((J)Lcom/hazelcast/spi/InvocationBuilder;  invoke/()Lcom/hazelcast/spi/InternalCompletableFuture;  java/util/concurrent/Future java/lang/Boolean booleanValue 4 Promotion commit result (Z)Ljava/lang/StringBuilder;    from  for migrations 6com/hazelcast/internal/partition/PartitionRuntimeStatejava/lang/StringlogPromotionCommitFailurea(Lcom/hazelcast/internal/partition/PartitionReplica;Ljava/util/Collection;Ljava/lang/Throwable;)V  getCause()Ljava/lang/Throwable;  ,com/hazelcast/core/OperationTimeoutExceptionpartitionState8Lcom/hazelcast/internal/partition/PartitionRuntimeState;destinationUuidLjava/lang/String;opELcom/hazelcast/internal/partition/operation/PromotionCommitOperation;future2Ljava/util/concurrent/Future;Ljava/util/concurrent/Future;resulttLjava/lang/Throwable;memberLcom/hazelcast/core/Member;(Lcom/hazelcast/internal/partition/PartitionReplica;Ljava/util/Collection;Ljava/lang/Throwable;)V&com/hazelcast/core/MemberLeftException4com/hazelcast/spi/exception/TargetNotMemberException6com/hazelcast/core/HazelcastInstanceNotActiveExceptionPromotion commit failed for - migrations since this node is shutting down. since destination  left the cluster migrationsPromotion commit to  failed for  severe*(Ljava/lang/String;Ljava/lang/Throwable;)V   V  memberLeftmigrationsSize #$ x0x1:Lcom/hazelcast/internal/partition/impl/MigrationManager$1;java/lang/ClassdesiredAssertionStatus 4 CodeLineNumberTableLocalVariableTable StackMapTableLocalVariableTypeTable Signature InnerClasses SourceFile  !" #$4 *+&*)   *+,'*&06*&:@FL+K+N*&RTZ*^M*,b>*&fk9*&Rn*&Rps*&wY*&z *&*&f:*&fP*H7NN  *89>DPTcq!#&'&'(**+>tDn  >t[\*&fk*&0YL=*&I*N-6+-:Y:+-W-W+M*&f,:*&f v( )J2 468.94:8;;=J>O?X@eBn8tDvFDFG44:J$ Tf*+ J$f!_`J=+N-4- :::*~= 9RS"T.U:VEWHX>.: "#J*+JH  : "#J!L*&,*+,>+*&:6 *+,*&,*&1"cde%f*g1i@jJk4L*+LL7 %'  L!*&fk*&06*&f, ::*&0 :( YY#&*-I+0478YY9#+&;#0>@#&*-0DW,Gh`6*&KO*&f:*&f  &     & QK NNx z%|&~*HY HYPQHR*+  !  (*&0M,N66,4N- 6 *&Rno->*&RYT#,U>W#>Y#,&*s0*&RYT#,U>[#,&*s-0Y-^:*&:bfWjnW,;*&RYT#>p#*s*&wN-|!M,0>b #*.25;JN&R}~(*+( PQ j(,GYY#+&*-*&:@++N-+*&RY#+&#*s*&Rn-*&RY#+&#,&*s*&,:-:Y,:*&+*&ö:Ͷ6*&Rn8*&RYҶ#׶#+&ٶ#,&*s:*+, *+,mKLA+A8 ^+AEkm|ILNVahf VG Nj*+jjA) Vj!-- -6,G6+*&:+*&RY#>#*Z*&Rn6*&RY#,&#+&#*s[*&RY#, Y>#*&#+&#*s*&Rn1*&RY#+& #,&*-V*&RY#+& #, Y>#*&*- @GA'VV<1VV R"*/@ghw@e>*+"r *j !#xD*+  *+"'4  @ "2    @@#