4Acom/hazelcast/internal/partition/operation/BaseMigrationOperationEcom/hazelcast/internal/partition/operation/AbstractPartitionOperation8com/hazelcast/internal/partition/MigrationCycleOperation)com/hazelcast/spi/PartitionAwareOperation.com/hazelcast/nio/serialization/impl/Versioned BaseMigrationOperation.javaTcom/hazelcast/internal/partition/impl/InternalMigrationListener$MigrationParticipant ?com/hazelcast/internal/partition/impl/InternalMigrationListenerMigrationParticipant migrationInfo0Lcom/hazelcast/internal/partition/MigrationInfo;successZcompletedMigrationsLjava/util/List;BLjava/util/List;partitionStateVersionInodeStartCompleted()V  thisCLcom/hazelcast/internal/partition/operation/BaseMigrationOperation;D(Lcom/hazelcast/internal/partition/MigrationInfo;Ljava/util/List;I)Vv(Lcom/hazelcast/internal/partition/MigrationInfo;Ljava/util/List;I)V  #  %  '.com/hazelcast/internal/partition/MigrationInfo)getPartitionId()I +, *-setPartitionId (I)Lcom/hazelcast/spi/Operation; /0 1 beforeRunjava/lang/Exception4onMigrationStart 6 7verifyNodeStarted 9 : verifyMaster < =verifyMigrationParticipant ? @verifyClusterState B CapplyCompletedMigrations E FverifyPartitionStateVersion H IonMigrationComplete K LeLjava/lang/Exception; getNodeEngine ()Lcom/hazelcast/spi/NodeEngine; PQ R%com/hazelcast/spi/impl/NodeEngineImplTgetNode()Lcom/hazelcast/instance/Node; VW UXcom/hazelcast/instance/NodeZgetNodeExtension(()Lcom/hazelcast/instance/NodeExtension; \] [^$com/hazelcast/instance/NodeExtension`isStartCompleted()Z bc ad  fjava/lang/IllegalStateExceptionhjava/lang/StringBuilderj kEMigration operation is received before startup is completed. Sender: mappend-(Ljava/lang/String;)Ljava/lang/StringBuilder; op kqgetCallerAddress()Lcom/hazelcast/nio/Address; st u-(Ljava/lang/Object;)Ljava/lang/StringBuilder; ow kxtoString()Ljava/lang/String; z{ k|(Ljava/lang/String;)V ~ i nodeEngine'Lcom/hazelcast/spi/impl/NodeEngineImpl;java/util/ListisEmpty c  getService()Ljava/lang/Object; Bcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl getMaster t *4(Ljava/util/Collection;Lcom/hazelcast/nio/Address;)Z E Gcom/hazelcast/internal/partition/PartitionStateVersionMismatchExceptiongetPartitionStateVersion , (II)V  getMigrationManager:()Lcom/hazelcast/internal/partition/impl/MigrationManager; 6com/hazelcast/internal/partition/impl/MigrationManagerisFinalizingMigrationRegistered(I)Z 7com/hazelcast/spi/exception/RetryableHazelcastExceptionJThere is a scheduled FinalizeMigrationOperation for the same partition =>  partitionServiceDLcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;9com/hazelcast/internal/partition/InternalPartitionService com/hazelcast/spi/NodeEnginegetThisAddress t com/hazelcast/nio/Addressequals(Ljava/lang/Object;)Z ;Lcom/hazelcast/internal/partition/InternalPartitionService;localPartitionStateVersiongetMasterAddress t +Migration initiator is not master node! =>  |isMemberMaster(Lcom/hazelcast/nio/Address;)Z EMigration initiator is not the master node known by migration system!getMigrationParticipantTypeX()Lcom/hazelcast/internal/partition/impl/InternalMigrationListener$MigrationParticipant; SOURCEVLcom/hazelcast/internal/partition/impl/InternalMigrationListener$MigrationParticipant; Caller is not master node! => Lcom/hazelcast/spi/NodeEngine;service masterAddressLcom/hazelcast/nio/Address;getLocalMember()Lcom/hazelcast/core/Member; getSourceCurrentReplicaIndex , * getSource5()Lcom/hazelcast/internal/partition/PartitionReplica; *1com/hazelcast/internal/partition/PartitionReplica isIdentical(Lcom/hazelcast/core/Member;)Z B is the migration source but has a different identity! Migration: com/hazelcast/core/MemberverifyPartitionOwner  verifyExistingDestination   DESTINATION getDestination *G is the migration destination but has a different identity! Migration:  localMemberLcom/hazelcast/core/Member; getPartition6()Lcom/hazelcast/internal/partition/InternalPartition; 2com/hazelcast/internal/partition/InternalPartitiongetOwnerReplicaOrNull  @Cannot migrate at the moment! Owner of the partition is null => (Owner of partition is not this node! =>  partition4Lcom/hazelcast/internal/partition/InternalPartition;owner3Lcom/hazelcast/internal/partition/PartitionReplica;getClusterService1()Lcom/hazelcast/internal/cluster/ClusterService;   address t uuid { -com/hazelcast/internal/cluster/ClusterService getMemberR(Lcom/hazelcast/nio/Address;Ljava/lang/String;)Lcom/hazelcast/instance/MemberImpl;  4com/hazelcast/spi/exception/TargetNotMemberException0Destination of migration could not be found! =>   destinationtarget UgetClusterState&()Lcom/hazelcast/cluster/ClusterState; %& '"com/hazelcast/cluster/ClusterState)isMigrationAllowed +c *,)Cluster state does not allow migrations! . clusterState$Lcom/hazelcast/cluster/ClusterState;setActiveMigrationb(Lcom/hazelcast/internal/partition/MigrationInfo;)Lcom/hazelcast/internal/partition/MigrationInfo; 23 4 *Cannot set active migration to 7. Current active migration is 9getPartitionStateManager?()Lcom/hazelcast/internal/partition/impl/PartitionStateManager; ;< =;com/hazelcast/internal/partition/impl/PartitionStateManager?trySetMigratingFlag A @B[Cannot set migrating flag, probably previous migration's finalization is not completed yet.DmigrationManager8Lcom/hazelcast/internal/partition/impl/MigrationManager;currentActiveMigrationpartitionStateManager=Lcom/hazelcast/internal/partition/impl/PartitionStateManager;getInternalMigrationListenerC()Lcom/hazelcast/internal/partition/impl/InternalMigrationListener; KL M(Lcom/hazelcast/internal/partition/impl/InternalMigrationListener$MigrationParticipant;Lcom/hazelcast/internal/partition/MigrationInfo;)V 6O PmigrationListenerALcom/hazelcast/internal/partition/impl/InternalMigrationListener;  T(Lcom/hazelcast/internal/partition/impl/InternalMigrationListener$MigrationParticipant;Lcom/hazelcast/internal/partition/MigrationInfo;Z)V KV WexecuteBeforeMigrationsjava/lang/ThrowableZgetMigrationEvent-()Lcom/hazelcast/spi/PartitionMigrationEvent; \] ^getMigrationAwareServices()Ljava/util/Collection; `a bjava/util/Collectionditerator()Ljava/util/Iterator; fg eh)com/hazelcast/spi/PartitionMigrationEventjjava/util/IteratorlhasNext nc monext q mr'com/hazelcast/spi/MigrationAwareServicetbeforeMigration.(Lcom/hazelcast/spi/PartitionMigrationEvent;)V vw ux getLogger!()Lcom/hazelcast/logging/ILogger; z{ |'Error while executing beforeMigration()~com/hazelcast/logging/ILoggerwarning*(Ljava/lang/String;Ljava/lang/Throwable;)V   com/hazelcast/util/ExceptionUtilrethrow3(Ljava/lang/Throwable;)Ljava/lang/RuntimeException;  Ljava/lang/Throwable;)Lcom/hazelcast/spi/MigrationAwareService;event+Lcom/hazelcast/spi/PartitionMigrationEvent;tgetPartitionImpl@(I)Lcom/hazelcast/internal/partition/impl/InternalPartitionImpl;  @getMigrationInfo2()Lcom/hazelcast/internal/partition/MigrationInfo; getResponsejava/lang/BooleanvalueOf(Z)Ljava/lang/Boolean;  validatesTargetonInvocationException:(Ljava/lang/Throwable;)Lcom/hazelcast/spi/ExceptionAction;&com/hazelcast/core/MemberLeftException!com/hazelcast/spi/ExceptionActionTHROW_EXCEPTION#Lcom/hazelcast/spi/ExceptionAction;  isValid c *   throwablelogError(Ljava/lang/Throwable;)V isFineEnabled c  getMessage { [fine  info ~  ~     loggerLcom/hazelcast/logging/ILogger; writeInternal'(Lcom/hazelcast/nio/ObjectDataOutput;)Vjava/io/IOException  "com/hazelcast/nio/ObjectDataOutput getVersion!()Lcom/hazelcast/version/Version;  'com/hazelcast/internal/cluster/VersionsV3_12Lcom/hazelcast/version/Version;  com/hazelcast/version/VersionisGreaterOrEqual"(Lcom/hazelcast/version/Version;)Z   writeObject(Ljava/lang/Object;)V   writeData  *writeInt(I)V  size ,  hlenout$Lcom/hazelcast/nio/ObjectDataOutput;version readInternal&(Lcom/hazelcast/nio/ObjectDataInput;)V  !com/hazelcast/nio/ObjectDataInput  readObject   *readData  *readInt , java/util/ArrayList  add  iin#Lcom/hazelcast/nio/ObjectDataInput;(Ljava/lang/StringBuilder;)V z   , migration=sbLjava/lang/StringBuilder; SignatureCodeLineNumberTableLocalVariableTableLocalVariableTypeTable StackMapTable Exceptions InnerClasses SourceFile  3* @A  !**+$*,&*(*+.2WCD EFGH*  "3'*8*;*>*A*D*G*J L*M+5_52 WXY Z[\]a^ _$`&b NO' 59>*SUL*+Y_eg*g!iYkYlnr*vy}=Ufghi0j=l> 6En*&*&*L+*&*$Y*(++*$.!YkYlr*$y} )."pqst.u>wO}mn RH<*L+=*('*S*$Y*( . -.; < 4-<*SL*M+N*$-!iYkYlr*¶r},*$ƚ Yȷ*̲Ц,,*vƚ!iYkYlҶr*¶r}@2*  "@NXm*  x?*SL*̲ЦH*$ݚ3*$+%iYkYl+yr*$y}**=*̲3*$+%iYkYl+yr*$y} N 9. ",NRYcq _*L+M,"YkYlr*$y},*S"YkYlr*¶r} /. /?^ _ Z   S  C*$L*S++M,"YkYl r*¶r}! B#B C ;" $#B6*SUL+$(M,-iYkYl/r,y} 5U*5 6 .$012u*L+M,*$5N-=*$-6 *-$YkYl8r*$y:r-y}+>:*$.CYE+*(@2  %*+TZit4u m hFG_HZIJ6d*L+NM,**$Q    RSKh*L+NM,**$*UX    RSY P*_LM*ciN-p/-su:+y:*}M,,%-0[.k[mk[mu[2 %-02@CF J O 42N%P KI5\]W*L+>*$. /*$  2*U  c,$  u&+ +*$*+ )*,- /& &]*}M+%,,++ ,+*g%+i,+, ,+*+± # '6 45 67#9-;.=<>F?O@VBWD\E ] ]NX}*++M,ֶܙ+*$ *$++*(,ֶܙ@*&>+*&:ps*:+#/m 6 IJ LM#O+R5U?VIWPXqYyZ|\4qI3} } q2*++M,ֶܙ*+*$**Y$*$+*+(,ֶܙ<+>*Y&6 +*:*&W&)">`a cd&f1g9jCmMnTo`piqtrpu>t c#T2    {z Q*+ +r*$yWy{|   @