4VDcom/hazelcast/internal/partition/operation/MigrationRequestOperationAcom/hazelcast/internal/partition/operation/BaseMigrationOperationMigrationRequestOperation.javaFcom/hazelcast/internal/partition/operation/MigrationRequestOperation$1]com/hazelcast/internal/partition/operation/MigrationRequestOperation$ServiceNamespacesContextServiceNamespacesContextecom/hazelcast/internal/partition/operation/MigrationRequestOperation$SendNewMigrationFragmentRunnable  SendNewMigrationFragmentRunnableVcom/hazelcast/internal/partition/operation/MigrationRequestOperation$MigrationCallbackMigrationCallbackPcom/hazelcast/internal/partition/operation/MigrationRequestOperation$OffloadImpl OffloadImplTcom/hazelcast/internal/partition/impl/InternalMigrationListener$MigrationParticipant?com/hazelcast/internal/partition/impl/InternalMigrationListenerMigrationParticipantfragmentedMigrationEnabledZnamespacesContext_Lcom/hazelcast/internal/partition/operation/MigrationRequestOperation$ServiceNamespacesContext;$assertionsDisabled()V   thisFLcom/hazelcast/internal/partition/operation/MigrationRequestOperation;E(Lcom/hazelcast/internal/partition/MigrationInfo;Ljava/util/List;IZ)Vw(Lcom/hazelcast/internal/partition/MigrationInfo;Ljava/util/List;IZ)VD(Lcom/hazelcast/internal/partition/MigrationInfo;Ljava/util/List;I)V & '  ) migrationInfo0Lcom/hazelcast/internal/partition/MigrationInfo;completedMigrationsBLjava/util/List;Ljava/util/List;partitionStateVersionIcall ()Lcom/hazelcast/spi/CallStatus;java/lang/Exception4setActiveMigration 6 7 +, 9.com/hazelcast/internal/partition/MigrationInfo;startProcessing()Z => <? getLogger!()Lcom/hazelcast/logging/ILogger; AB Cjava/lang/StringBuilderE F Migration is cancelled -> Happend-(Ljava/lang/String;)Ljava/lang/StringBuilder; JK FL-(Ljava/lang/Object;)Ljava/lang/StringBuilder; JN FOtoString()Ljava/lang/String; QR FScom/hazelcast/logging/ILoggerUwarning(Ljava/lang/String;)V WX VYcompleteMigration(Z)V [\ ]com/hazelcast/spi/CallStatus_ DONE_VOIDLcom/hazelcast/spi/CallStatus; ab `c(Lcom/hazelcast/internal/partition/operation/MigrationRequestOperation;Lcom/hazelcast/internal/partition/operation/MigrationRequestOperation$1;)V e fexecuteBeforeMigrations getNodeEngine ()Lcom/hazelcast/spi/NodeEngine; ij k getSource5()Lcom/hazelcast/internal/partition/PartitionReplica; mn <ocom/hazelcast/spi/NodeEngineqgetLocalMember()Lcom/hazelcast/core/Member; st ru1com/hazelcast/internal/partition/PartitionReplicaw isIdentical(Lcom/hazelcast/core/Member;)Z yz x{ h } nodeEngineLcom/hazelcast/spi/NodeEngine;source3Lcom/hazelcast/internal/partition/PartitionReplica;ownerMigrationinvokeMigrationOperationD(Lcom/hazelcast/internal/partition/ReplicaFragmentMigrationState;Z)V  hasNext > =com/hazelcast/internal/partition/operation/MigrationOperation -/ >com/hazelcast/internal/partition/ReplicaFragmentMigrationStatejava/util/Collections emptyList()Ljava/util/List; java/util/List 01 (Lcom/hazelcast/internal/partition/MigrationInfo;Ljava/util/List;ILcom/hazelcast/internal/partition/ReplicaFragmentMigrationState;ZZ)V  isFinestEnabled > VgetNamespaceVersionMap()Ljava/util/Map;  java/util/MapkeySet()Ljava/util/Set; com/hazelcast/spi/OperationemptySet  java/util/Set+Invoking MigrationOperation for namespaces  and , lastFragment: (Z)Ljava/lang/StringBuilder; J Ffinest X V getService()Ljava/lang/Object; Bcom/hazelcast/internal/partition/impl/InternalPartitionServiceImplgetDestinationAddress()Lcom/hazelcast/nio/Address; <getOperationService&()Lcom/hazelcast/spi/OperationService; rhz:core:partitionService"com/hazelcast/spi/OperationServicecreateInvocationBuilderq(Ljava/lang/String;Lcom/hazelcast/spi/Operation;Lcom/hazelcast/nio/Address;)Lcom/hazelcast/spi/InvocationBuilder; f#com/hazelcast/spi/InvocationBuildersetExecutionCallbackM(Lcom/hazelcast/core/ExecutionCallback;)Lcom/hazelcast/spi/InvocationBuilder; setResultDeserialized((Z)Lcom/hazelcast/spi/InvocationBuilder; getPartitionMigrationTimeout()J setCallTimeout((J)Lcom/hazelcast/spi/InvocationBuilder;  setTryCount((I)Lcom/hazelcast/spi/InvocationBuilder; 'setTryPauseMillis invoke/()Lcom/hazelcast/spi/InternalCompletableFuture;  namespaces5Ljava/util/Set;Ljava/util/Set;migrationState@Lcom/hazelcast/internal/partition/ReplicaFragmentMigrationState; firstFragment lastFragment operationLcom/hazelcast/spi/Operation;loggerLcom/hazelcast/logging/ILogger;partitionServiceDLcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;targetLcom/hazelcast/nio/Address;trySendNewFragmentjava/lang/Throwable  java/lang/AssertionError'Fragmented migration should be enabled! (Ljava/lang/Object;)V     verifyMaster  verifyExistingDestination  getMigrationManager:()Lcom/hazelcast/internal/partition/impl/MigrationManager;  6com/hazelcast/internal/partition/impl/MigrationManagerb(Lcom/hazelcast/internal/partition/MigrationInfo;)Lcom/hazelcast/internal/partition/MigrationInfo; 6 equals(Ljava/lang/Object;)Z  < java/lang/IllegalStateException"Current active migration $ is different than expected: & X #('createNextReplicaFragmentMigrationStateB()Lcom/hazelcast/internal/partition/ReplicaFragmentMigrationState; *+ , .!All migration fragments done for 0 logThrowable(Ljava/lang/Throwable;)V 23 4migrationManager8Lcom/hazelcast/internal/partition/impl/MigrationManager;currentActiveMigrationeLjava/lang/Throwable;next&()Lcom/hazelcast/spi/ServiceNamespace; ;< =>com/hazelcast/internal/partition/NonFragmentedServiceNamespace?INSTANCE@Lcom/hazelcast/internal/partition/NonFragmentedServiceNamespace; AB @Cjava/lang/ObjectE F 0createNonFragmentedReplicaFragmentMigrationState H+ I"com/hazelcast/spi/ServiceNamespaceK&createReplicaFragmentMigrationStateForf(Lcom/hazelcast/spi/ServiceNamespace;)Lcom/hazelcast/internal/partition/ReplicaFragmentMigrationState; MN O namespace$Lcom/hazelcast/spi/ServiceNamespace;getPartitionReplicationEvent/()Lcom/hazelcast/spi/PartitionReplicationEvent; ST U(createNonFragmentedReplicationOperationsE(Lcom/hazelcast/spi/PartitionReplicationEvent;)Ljava/util/Collection; WX Y singleton#(Ljava/lang/Object;)Ljava/util/Set; [\ ]#createReplicaFragmentMigrationStaten(Ljava/util/Collection;Ljava/util/Collection;)Lcom/hazelcast/internal/partition/ReplicaFragmentMigrationState; _` aevent-Lcom/hazelcast/spi/PartitionReplicationEvent; operations5Ljava/util/Collection;Ljava/util/Collection;;getServiceNames<(Lcom/hazelcast/spi/ServiceNamespace;)Ljava/util/Collection; ij k#createFragmentReplicationOperations(Lcom/hazelcast/spi/PartitionReplicationEvent;Lcom/hazelcast/spi/ServiceNamespace;Ljava/util/Collection;)Ljava/util/Collection; mn ons serviceNames*Ljava/util/Collection;'createAllReplicaFragmentsMigrationStatecreateAllReplicationOperations uX v allNamespaces xg y(Ljava/util/Collection;Ljava/util/Collection;)Lcom/hazelcast/internal/partition/ReplicaFragmentMigrationState;9com/hazelcast/internal/partition/InternalPartitionService|!getPartitionReplicaVersionManagerC()Lcom/hazelcast/internal/partition/PartitionReplicaVersionManager; ~ }java/util/HashMapjava/util/Collectionsize()I  (I)V  iterator()Ljava/util/Iterator;  ?com/hazelcast/internal/partition/PartitionReplicaVersionManagerjava/util/Iterator  ; getPartitionId  getPartitionReplicaVersions)(ILcom/hazelcast/spi/ServiceNamespace;)[J  put8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;  ((Ljava/util/Map;Ljava/util/Collection;)V  v[J;Lcom/hazelcast/internal/partition/InternalPartitionService;versionManagerALcom/hazelcast/internal/partition/PartitionReplicaVersionManager;versions7Ljava/util/Map;Ljava/util/Map;getMigrationEvent-()Lcom/hazelcast/spi/PartitionMigrationEvent;)com/hazelcast/spi/PartitionMigrationEvent-com/hazelcast/spi/partition/MigrationEndpointSOURCE/Lcom/hazelcast/spi/partition/MigrationEndpoint;   <getSourceCurrentReplicaIndex  <getSourceNewReplicaIndex  <5(Lcom/hazelcast/spi/partition/MigrationEndpoint;III)V  getMigrationParticipantTypeX()Lcom/hazelcast/internal/partition/impl/InternalMigrationListener$MigrationParticipant;VLcom/hazelcast/internal/partition/impl/InternalMigrationListener$MigrationParticipant;  +com/hazelcast/spi/PartitionReplicationEventgetDestinationNewReplicaIndex  <(II)V  success  doneProcessing  <onMigrationComplete  java/lang/BooleanvalueOf(Z)Ljava/lang/Boolean;   sendResponse  result'java/util/concurrent/ExecutionExceptiongetCause()Ljava/lang/Throwable;   getLogLevel0(Ljava/lang/Throwable;)Ljava/util/logging/Level;   getMessage R logC(Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Throwable;)V  VtthrowableToLoglevelLjava/util/logging/Level;&com/hazelcast/core/MemberLeftExceptionjava/lang/InterruptedException isRunning > rjava/util/logging/LevelINFO  WARNING  getId writeInternal'(Lcom/hazelcast/nio/ObjectDataOutput;)Vjava/io/IOException   "com/hazelcast/nio/ObjectDataOutput  writeBoolean \ out$Lcom/hazelcast/nio/ObjectDataOutput; readInternal&(Lcom/hazelcast/nio/ObjectDataInput;)V  !com/hazelcast/nio/ObjectDataInput readBoolean > in#Lcom/hazelcast/nio/ObjectDataInput;logError 3  onInvocationException:(Ljava/lang/Throwable;)Lcom/hazelcast/spi/ExceptionAction; "# $ getResponse & 'getMigrationInfo2()Lcom/hazelcast/internal/partition/MigrationInfo; )* + access$102(Lcom/hazelcast/internal/partition/operation/MigrationRequestOperation;Lcom/hazelcast/internal/partition/operation/MigrationRequestOperation$ServiceNamespacesContext;)Lcom/hazelcast/internal/partition/operation/MigrationRequestOperation$ServiceNamespacesContext;x0x1 access$200u(Lcom/hazelcast/internal/partition/operation/MigrationRequestOperation;)Lcom/hazelcast/spi/PartitionReplicationEvent; access$300I(Lcom/hazelcast/internal/partition/operation/MigrationRequestOperation;)Z access$400(Lcom/hazelcast/internal/partition/operation/MigrationRequestOperation;)Lcom/hazelcast/internal/partition/ReplicaFragmentMigrationState; access$500 t+ 8 access$600(Lcom/hazelcast/internal/partition/operation/MigrationRequestOperation;Lcom/hazelcast/internal/partition/ReplicaFragmentMigrationState;Z)Vx2 access$700^(Lcom/hazelcast/internal/partition/operation/MigrationRequestOperation;Ljava/lang/Throwable;)V access$800J(Lcom/hazelcast/internal/partition/operation/MigrationRequestOperation;Z)V access$1100g(Lcom/hazelcast/internal/partition/operation/MigrationRequestOperation;)Lcom/hazelcast/logging/ILogger; access$1200I(Lcom/hazelcast/internal/partition/operation/MigrationRequestOperation;)V  Ejava/lang/ClassHdesiredAssertionStatus J> IKCodeLineNumberTableLocalVariableTableLocalVariableTypeTable Signature StackMapTable Exceptions InnerClasses SourceFile!#M3*!N LMO "#$Mz*+,(**NQR SO4"#+,-/01P -.Q%23M@*8*:@+*DFYGIM*:PTZ*^dY*gR6NWYZ-[2\6_O @"#S5hM.*lL*:pM,,+v|>*~R"rx@N|} ~$()-O*."#) !$ S5M ** *>Y*: **+:*D:H++:FYGMPM*:PMT*l:*:*::Y*Զ WRG@<<+VB1NR*9?IN^Of ^0"#9?LC:P ^0M** Y ***L+M,*:N*:-!,#YFYG%M-P'M*:PT)*-: */(*DFYG1M*:PT*^L*+5*^R$Q<$B NJ (-6AjpuO>(|-w676n8,p4 9:"#*+MA** Y **>L+DG*J*+PR  LN"$,6;OA"#,QRH+M*VL*+ZMD^N*-,bN O*"#cd eggP efhMNM"*VM*+lN*,+-p:*+^bNO4""#"qRcdrg egPrs eft+Mp*VL*+wM**z,bN O "#cd egP  ef_`M? f*}N-:Y+:+:-L:*:WϻY,R!'}3N"=LX[ORL =QRf"#fgfeg^VGP fhfefGQ{MV Y*:*:*:N O  "#M.ưNO "#STM@Y*:*:˷ΰNO "#[\M]**:**ݶN O"#23M/+M,, ,,M*,N*D-,,R @N   .O*/"#/:-:Mn$++*l RBN#O$"#$9:M-NO "#ML*+ +**N O"#S ML*+*+*N$%&O"#S A3M0*+!NGO "#A"#M0*+%NGO "#A&M/*(NGO "#A)*M/*,NGO "#-.M;*+ZNGO/#012M/*VNGO /#34M/**NGO /#56M/*-NGO /#76M/*9NGO /#:;ME*+/NGO /#0<=>M:*+5NGO/#0:?@M:*^NGO/#0ABM/*DNGO /#CDM/*FNGO /#GM4LR @NGT2   @U