4Icom/hazelcast/internal/partition/impl/MigrationManager$RepartitioningTaskjava/lang/Object7com/hazelcast/internal/partition/impl/MigrationRunnableMigrationManager.java6com/hazelcast/internal/partition/impl/MigrationManagerRepartitioningTask\com/hazelcast/internal/partition/impl/MigrationManager$RepartitioningTask$MigrationCollector MigrationCollector8com/hazelcast/internal/partition/impl/MigrationManager$1Rcom/hazelcast/internal/partition/impl/MigrationManager$ProcessShutdownRequestsTaskProcessShutdownRequestsTaskUcom/hazelcast/internal/partition/impl/MigrationManager$PublishCompletedMigrationsTaskPublishCompletedMigrationsTaskPcom/hazelcast/internal/partition/impl/MigrationPlanner$MigrationDecisionCallback6com/hazelcast/internal/partition/impl/MigrationPlannerMigrationDecisionCallback1com/hazelcast/core/MigrationEvent$MigrationStatus!com/hazelcast/core/MigrationEventMigrationStatusthis$08Lcom/hazelcast/internal/partition/impl/MigrationManager;;(Lcom/hazelcast/internal/partition/impl/MigrationManager;)V ! $()V "& 'thisKLcom/hazelcast/internal/partition/impl/MigrationManager$RepartitioningTask;run access$200~(Lcom/hazelcast/internal/partition/impl/MigrationManager;)Lcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl; ,- .Bcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl0isLocalMemberMaster()Z 23 14 access$400[(Lcom/hazelcast/internal/partition/impl/MigrationManager;)Ljava/util/concurrent/locks/Lock; 67 8java/util/concurrent/locks/Lock:lock <& ;= access$600W(Lcom/hazelcast/internal/partition/impl/MigrationManager;)Lcom/hazelcast/instance/Node; ?@ Acom/hazelcast/instance/NodeCgetClusterService:()Lcom/hazelcast/internal/cluster/impl/ClusterServiceImpl; EF DG6com/hazelcast/internal/cluster/impl/ClusterServiceImplIgetClusterState&()Lcom/hazelcast/cluster/ClusterState; KL JM"com/hazelcast/cluster/ClusterStateOisMigrationAllowed Q3 PR access$502<(Lcom/hazelcast/internal/partition/impl/MigrationManager;Z)Z TU V access$500;(Lcom/hazelcast/internal/partition/impl/MigrationManager;)Z XY Z access$100Y(Lcom/hazelcast/internal/partition/impl/MigrationManager;)Lcom/hazelcast/logging/ILogger; \] ^com/hazelcast/logging/ILogger` isFineEnabled b3 acfMigrations are not allowed yet, repartitioning will be triggered when cluster state allows migrations.efine(Ljava/lang/String;)V gh aiassignCompletelyLostPartitions k& lunlock n& ;o repartition7()[[Lcom/hazelcast/internal/partition/PartitionReplica; qr s5[[Lcom/hazelcast/internal/partition/PartitionReplica;u access$700p(Lcom/hazelcast/internal/partition/impl/MigrationManager;)Lcom/hazelcast/internal/partition/impl/MigrationStats; wx y4com/hazelcast/internal/partition/impl/MigrationStats{markNewRepartition }& |~processNewPartitionState8([[Lcom/hazelcast/internal/partition/PartitionReplica;)V  access$900p(Lcom/hazelcast/internal/partition/impl/MigrationManager;)Lcom/hazelcast/internal/partition/impl/MigrationQueue; u(Lcom/hazelcast/internal/partition/impl/MigrationManager;Lcom/hazelcast/internal/partition/impl/MigrationManager$1;)V " 4com/hazelcast/internal/partition/impl/MigrationQueueadd<(Lcom/hazelcast/internal/partition/impl/MigrationRunnable;)V java/lang/ThrowablenewStatemigrationsTasksAllowed 3  access$1100w(Lcom/hazelcast/internal/partition/impl/MigrationManager;)Lcom/hazelcast/internal/partition/impl/PartitionStateManager;  access$1000I(Lcom/hazelcast/internal/partition/impl/MigrationManager;)Ljava/util/Set; ;com/hazelcast/internal/partition/impl/PartitionStateManager\(Ljava/util/Set;Ljava/util/Collection;)[[Lcom/hazelcast/internal/partition/PartitionReplica; q isPartitionPromotionAllowed 3 P`Cluster state doesn't allow repartitioning. RepartitioningTask will only assign lost partitions.java/util/ArrayList ' getPartitions7()[Lcom/hazelcast/internal/partition/InternalPartition; java/util/Collection5[Lcom/hazelcast/internal/partition/InternalPartition;2com/hazelcast/internal/partition/InternalPartition getReplica6(I)Lcom/hazelcast/internal/partition/PartitionReplica; getPartitionId()I java/lang/IntegervalueOf(I)Ljava/lang/Integer; (Ljava/lang/Object;)Z isEmpty 3 java/lang/StringBuilder 'Assigning new owners for append-(Ljava/lang/String;)Ljava/lang/StringBuilder; size (I)Ljava/lang/StringBuilder;  LOST partitions!toString()Ljava/lang/String; warning h aiterator()Ljava/util/Iterator; java/util/IteratorhasNext 3 next()Ljava/lang/Object; intValue getPartitionImpl@(I)Lcom/hazelcast/internal/partition/impl/InternalPartitionImpl; assignLostPartitionOwners(Lcom/hazelcast/internal/partition/impl/InternalPartitionImpl;Lcom/hazelcast/internal/partition/PartitionReplica;)V ;com/hazelcast/internal/partition/impl/InternalPartitionImpl setReplicas7([Lcom/hazelcast/internal/partition/PartitionReplica;)V  Unable to assign LOST partitionsindexIemptyZ partition4Lcom/hazelcast/internal/partition/InternalPartition;=Lcom/hazelcast/internal/partition/impl/InternalPartitionImpl;replicas4[Lcom/hazelcast/internal/partition/PartitionReplica; partitionIdstate partitions+Ljava/util/Collection;Ljava/util/Collection;!com/hazelcast/util/MutableInteger '(I)V " java/util/List getReplicas6()[Lcom/hazelcast/internal/partition/PartitionReplica;  (Lcom/hazelcast/internal/partition/impl/MigrationManager$RepartitioningTask;Lcom/hazelcast/internal/partition/impl/InternalPartitionImpl;Lcom/hazelcast/util/MutableInteger;Lcom/hazelcast/util/MutableInteger;)V " isFinestEnabled 3 a $Planning migrations for partitionId=". Current replicas: $java/util/Arrays&'([Ljava/lang/Object;)Ljava/lang/String; ( '), New replicas: +finest -h a.  access$1200r(Lcom/hazelcast/internal/partition/impl/MigrationManager;)Lcom/hazelcast/internal/partition/impl/MigrationPlanner; 12 3planMigrations(I[Lcom/hazelcast/internal/partition/PartitionReplica;[Lcom/hazelcast/internal/partition/PartitionReplica;Lcom/hazelcast/internal/partition/impl/MigrationPlanner$MigrationDecisionCallback;)V 56 7 access$1300v(Lcom/hazelcast/internal/partition/impl/MigrationManager$RepartitioningTask$MigrationCollector;)Ljava/util/LinkedList; 9: ;prioritizeCopiesAndShiftUps(Ljava/util/List;)V => ? publishPartitionRuntimeState B& 1Cvalue E FscheduleMigrations H> I logMigrationStatistics(II)V LM NcurrentPartitioncurrentReplicas newReplicasmigrationCollector^Lcom/hazelcast/internal/partition/impl/MigrationManager$RepartitioningTask$MigrationCollector; lostCount#Lcom/hazelcast/util/MutableInteger;migrationCount migrationsULjava/util/List;>;Ljava/util/List;X(Ljava/util/List;>;)V java/util/Queue]poll _ ^`.com/hazelcast/internal/partition/MigrationInfobscheduleMigration3(Lcom/hazelcast/internal/partition/MigrationInfo;)V de f migration0Lcom/hazelcast/internal/partition/MigrationInfo;queueCLjava/util/Queue;Ljava/util/Queue;migrationScheduled6Re-partitioning cluster data... Migration queue size: ninfo ph aqAPartition balance is ok, no need to re-partition cluster data... s n(ILcom/hazelcast/internal/partition/PartitionReplica;Lcom/hazelcast/internal/partition/PartitionReplica;IIII)V "v cwgetPartitionEventManager?()Lcom/hazelcast/internal/partition/impl/PartitionEventManager; yz 1{STARTED3Lcom/hazelcast/core/MigrationEvent$MigrationStatus; }~ ;com/hazelcast/internal/partition/impl/PartitionEventManagersendMigrationEventf(Lcom/hazelcast/internal/partition/MigrationInfo;Lcom/hazelcast/core/MigrationEvent$MigrationStatus;)V   setReplica7(ILcom/hazelcast/internal/partition/PartitionReplica;)V   COMPLETED ~ newOwner3Lcom/hazelcast/internal/partition/PartitionReplica; migrationInfopartitionEventManager=Lcom/hazelcast/internal/partition/impl/PartitionEventManager;areMigrationTasksAllowed 3 migrationTaskCount  triggerControlTask & migrationTasksAllowedhasMigrationTasks access$1500(Lcom/hazelcast/internal/partition/impl/MigrationManager$RepartitioningTask;Lcom/hazelcast/internal/partition/impl/InternalPartitionImpl;Lcom/hazelcast/internal/partition/PartitionReplica;)Vx0x1x2 "# :Lcom/hazelcast/internal/partition/impl/MigrationManager$1;CodeLineNumberTableLocalVariableTable StackMapTableLocalVariableTypeTable Signature InnerClasses SourceFile  ! "#4 *+%*(  )*+&*%/5*%9>*%*%BHNSWW*%[1*%_d*%_fj*m*%9p*tL+*%9p*%z*+*%Y*%*%9pM*%9p,er{+f  *v3b "6:DSaeqr w {  w6u)*qrL*v*%*%L+*%Y*%v*v+  1v &   !#"9#>&E'J)L)*-uk&m.*%BHN*%_jYL*%M,>6N,2:66~6+ùW+*%*%+M,u*%_Yζ+ڶҶ޹+N-9-6*%:,2:*2ħ*%_Q &XOv>b136"7*8G9J:T;j:p=u>8ABCDEFGIJKM-P\ M#J<G?  %  u.)**  * O YMYNY+:6+*%::+2: Y*-,: *%_!@*%_Y#%*,*Ҷ޹/*%4 8*%4 <@ <AWS*%/D-G*J*%Y*%K*-G,GOSv{ v00 3v,^TUVX%Y3Z:[@]N^]_~`a_cdeXgijlnof 3P:Q @R NzST  )*uUVWVXZ XYH>A=+\N---^:ac:=*%gñ/& uvw)x.y0z9|<}@~4)hijlA)*AXZ?mjkAXY[LM_'*%_YζڶҶ޹&*%_Yoض޹r*%_tr(&(,O^ _)*_W_U <+u>cY,x:*%/|:+,!+1;><)*<<7 'i!3/*%<*%= *% @ $&- /)*'E*+, *"D*+ )*!:     @