4=com/hazelcast/internal/partition/operation/MigrationOperationAcom/hazelcast/internal/partition/operation/BaseMigrationOperation3com/hazelcast/spi/impl/operationservice/TargetAware.com/hazelcast/nio/serialization/impl/VersionedMigrationOperation.java?com/hazelcast/internal/partition/operation/MigrationOperation$1 java/util/Map$Entry  java/util/MapEntryTcom/hazelcast/internal/partition/impl/InternalMigrationListener$MigrationParticipant?com/hazelcast/internal/partition/impl/InternalMigrationListenerMigrationParticipantERROR_RESPONSE_HANDLER,Lcom/hazelcast/spi/OperationResponseHandler;fragmentMigrationState@Lcom/hazelcast/internal/partition/ReplicaFragmentMigrationState; firstFragmentZ lastFragment failureReasonLjava/lang/Throwable;()V  !this?Lcom/hazelcast/internal/partition/operation/MigrationOperation;(Lcom/hazelcast/internal/partition/MigrationInfo;Ljava/util/List;ILcom/hazelcast/internal/partition/ReplicaFragmentMigrationState;ZZ)V(Lcom/hazelcast/internal/partition/MigrationInfo;Ljava/util/List;ILcom/hazelcast/internal/partition/ReplicaFragmentMigrationState;ZZ)VD(Lcom/hazelcast/internal/partition/MigrationInfo;Ljava/util/List;I)V ' (  *  ,  ..com/hazelcast/internal/partition/MigrationInfo0getDestinationNewReplicaIndex()I 23 14setReplicaIndex (I)Lcom/hazelcast/spi/Operation; 67 8 migrationInfo0Lcom/hazelcast/internal/partition/MigrationInfo;completedMigrationsBLjava/util/List;Ljava/util/List;partitionStateVersionIrunjava/lang/ExceptionBjava/lang/ThrowableDsetActiveMigration F GcheckActiveMigration I JdoRun L MonMigrationComplete O Psuccess R S  UonExecutionFailure(Ljava/lang/Throwable;)V WX YlogMigrationFailure [X \t :; _startProcessing()Z ab 1cexecuteBeforeMigrations e f>com/hazelcast/internal/partition/ReplicaFragmentMigrationStatehgetMigrationOperations()Ljava/util/Collection; jk iljava/util/Collectionniterator()Ljava/util/Iterator; pq orjava/util/IteratorthasNext vb uwnext()Ljava/lang/Object; yz u{com/hazelcast/spi/Operation}runMigrationOperation (Lcom/hazelcast/spi/Operation;)V   afterMigrate  getLogger!()Lcom/hazelcast/logging/ILogger; java/lang/StringBuilder !-Error while executing replication operations append-(Ljava/lang/String;)Ljava/lang/StringBuilder; -(Ljava/lang/Object;)Ljava/lang/StringBuilder; toString()Ljava/lang/String; com/hazelcast/logging/ILoggersevere*(Ljava/lang/String;Ljava/lang/Throwable;)V logMigrationCancelled migrationOperationLcom/hazelcast/spi/Operation;e getService z Bcom/hazelcast/internal/partition/impl/InternalPartitionServiceImplgetMigrationManager:()Lcom/hazelcast/internal/partition/impl/MigrationManager; 6com/hazelcast/internal/partition/impl/MigrationManagergetActiveMigration2()Lcom/hazelcast/internal/partition/MigrationInfo; equals(Ljava/lang/Object;)Z 1java/lang/IllegalStateExceptionUnexpected active migration @! First migration fragment should have set active migration to: (Ljava/lang/String;)V  partitionServiceDLcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;activeMigrationprepareOperation  beforeRun ~ A ~afterRun ~op getNodeEngine ()Lcom/hazelcast/spi/NodeEngine;  setNodeEngine=(Lcom/hazelcast/spi/NodeEngine;)Lcom/hazelcast/spi/Operation; ~getPartitionId 3 setPartitionId 7 ~getReplicaIndex 3  ~8  setOperationResponseHandlerK(Lcom/hazelcast/spi/OperationResponseHandler;)Lcom/hazelcast/spi/Operation; ~getSourceAddress()Lcom/hazelcast/nio/Address; 1#com/hazelcast/spi/OperationAccessorsetCallerAddress;(Lcom/hazelcast/spi/Operation;Lcom/hazelcast/nio/Address;)V getReplicaManagerA()Lcom/hazelcast/internal/partition/impl/PartitionReplicaManager; java/lang/Mathmax(II)I getNamespaceVersionMap()Ljava/util/Map; ientrySet()Ljava/util/Set;   java/util/Set r=com/hazelcast/internal/partition/impl/PartitionReplicaManagergetKey  z  "com/hazelcast/spi/ServiceNamespace getValue z [J 1setPartitionReplicaVersions+(ILcom/hazelcast/spi/ServiceNamespace;[JI)V   isFinestEnabled b 5ReplicaVersions are set after migration. partitionId=(I)Ljava/lang/StringBuilder;   namespace: ! replicaVersions=#java/util/Arrays%([J)Ljava/lang/String; ' &(finest * +@ReplicaVersions are not set since migration failed. partitionId=-doneProcessing / 10 namespace$Lcom/hazelcast/spi/ServiceNamespace;replicaVersions=Ljava/util/Map$Entry;Ljava/util/Map$Entry;replicaManager?Lcom/hazelcast/internal/partition/impl/PartitionReplicaManager;destinationNewReplicaIndex replicaOffsetnamespaceVersions7Ljava/util/Map;Ljava/util/Map;loggerLcom/hazelcast/logging/ILogger;Migration is cancelled -> @warning B C getMessage E EF B HgetMigrationEvent-()Lcom/hazelcast/spi/PartitionMigrationEvent;)com/hazelcast/spi/PartitionMigrationEventL-com/hazelcast/spi/partition/MigrationEndpointN DESTINATION/Lcom/hazelcast/spi/partition/MigrationEndpoint; PQ OR!getDestinationCurrentReplicaIndex T3 1U5(Lcom/hazelcast/spi/partition/MigrationEndpoint;III)V W MXgetMigrationParticipantTypeX()Lcom/hazelcast/internal/partition/impl/InternalMigrationListener$MigrationParticipant;VLcom/hazelcast/internal/partition/impl/InternalMigrationListener$MigrationParticipant; P\ ]onOperationFailure5(Lcom/hazelcast/spi/Operation;Ljava/lang/Throwable;)V _` atasks5Ljava/util/Collection;Ljava/util/Collection; ~Y)While calling operation.onFailure(). op: ggetIdonMigrationStart j k P writeInternal'(Lcom/hazelcast/nio/ObjectDataOutput;)Vjava/io/IOExceptionp no r"com/hazelcast/nio/ObjectDataOutputt getVersion!()Lcom/hazelcast/version/Version; vw ux'com/hazelcast/internal/cluster/VersionszV3_12Lcom/hazelcast/version/Version; |} {~com/hazelcast/version/VersionisGreaterOrEqual"(Lcom/hazelcast/version/Version;)Z   writeObject(Ljava/lang/Object;)V  u writeData o i writeBoolean(Z)V  uout$Lcom/hazelcast/nio/ObjectDataOutput;version readInternal&(Lcom/hazelcast/nio/ObjectDataInput;)V  !com/hazelcast/nio/ObjectDataInput x readObject z  i!readData  i readBoolean b in#Lcom/hazelcast/nio/ObjectDataInput; setTarget(Lcom/hazelcast/nio/Address;)V  iaddressLcom/hazelcast/nio/Address;logError X onInvocationException:(Ljava/lang/Throwable;)Lcom/hazelcast/spi/ExceptionAction;   getResponse z getMigrationInfo   !CodeLineNumberTableLocalVariableTableLocalVariableTypeTable Signature StackMapTable Exceptions InnerClasses SourceFile! 3*" FG #$%#*+,)*+*-*/*+59WKL MNO"PH##$#:;#<>#?@### #<=&A  a*-*H*K*N*Q*TE**VZ:L*+]*+V*Q*T$**VZM*Q*T **VZ, )E J)4J ]E`EEJZ[ _`efg)a*b/c4e8f?gJeOfVg^i`j* ^a#$CL <*`dy*-*g*+msL+x+|~M*,*T*7L*+V*Y*`+* N*-* BIE BvIov uKElEJn pqt5u:v=xB}F~IyJzO{o}s~v}{~ 5J%#$I C*L+M*`,*YY,*` B1B C#$;3;V*++++ϱ #$Cs++*Զ*۶*W+W+*` *+#$+ & *L*T*M,N*`566*+::x}| : : : -*`  +<+Y*` " $ ),,+#+Y.*` ,*`1/A u(^ "*3Wcof c_23 oS4 Wk678"9@*:@3;=#$>?Wk53;< O!*YA*`D   !#$[X%*M+,+GD,+G+I   $ %#$% >?JKV MYS*`*`V*`5Y   #$Z[.^ #$WX@*+*+mM,.,sN-x-|~:**+b߱ou#& /5<?*/ @#$@0ce 0cd_`(+,f"N*Yh+-IEHE '* ^(#$((i3- #$j G *-*l    #$O G */*m    #$no@*+s+yM,+*+ *+++*-+*/ #" #+ 5 ?  @#$@ 4}qN*++M,*+i+*iY+*++*+-*+/ &&  &19CM N#$N B}qA *++   #$ AX0*+8 #$A0*+8 #$Az/*8 #$A/*8 #$ # Y:   @