4Fcom/hazelcast/internal/partition/operation/PartitionReplicaSyncRequestEcom/hazelcast/internal/partition/operation/AbstractPartitionOperation)com/hazelcast/spi/PartitionAwareOperation8com/hazelcast/internal/partition/MigrationCycleOperation.com/hazelcast/nio/serialization/impl/Versioned  PartitionReplicaSyncRequest.java namespacesLjava/util/List;6Ljava/util/List;()V  java/util/Collections emptyList()Ljava/util/List;   thisHLcom/hazelcast/internal/partition/operation/PartitionReplicaSyncRequest;(ILjava/util/List;I)V;(ILjava/util/List;I)VsetPartitionId (I)Lcom/hazelcast/spi/Operation;  !setReplicaIndex # $ partitionIdI replicaIndex beforeRungetReplicaIndex()I *+ ,"java/lang/IllegalArgumentException.java/lang/StringBuilder0 1Replica index 3append-(Ljava/lang/String;)Ljava/lang/StringBuilder; 56 17(I)Ljava/lang/StringBuilder; 59 1: should be in the range [1-<]>toString()Ljava/lang/String; @A 1B(Ljava/lang/String;)V D /EsyncReplicaIndexrun getService()Ljava/lang/Object; IJ KBcom/hazelcast/internal/partition/impl/InternalPartitionServiceImplMareMigrationTasksAllowed()Z OP NQ getLogger!()Lcom/hazelcast/logging/ILogger; ST Ucom/hazelcast/logging/ILoggerWisFinestEnabled YP XZ9Migration is paused! Cannot process request. partitionId=\getPartitionId ^+ _, replicaIndex=a , namespaces=c-(Ljava/lang/Object;)Ljava/lang/StringBuilder; 5e 1ffinest hD XisendRetryResponse k lcheckPartitionOwner nP ogetReplicaManagerA()Lcom/hazelcast/internal/partition/impl/PartitionReplicaManager; qr Nsjava/util/Listusize w+ vx=com/hazelcast/internal/partition/impl/PartitionReplicaManagerztryAcquireReplicaSyncPermits(I)I |} {~logNotEnoughPermits  sendOperationsForNamespaces(I)V isEmpty P vloggerLcom/hazelcast/logging/ILogger;partitionServiceDLcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;permitsBNot enough permits available! Cannot process request. partitionId=+com/hazelcast/spi/PartitionReplicationEvent(II)V  iterator()Ljava/util/Iterator; vjava/util/Iteratornext J "com/hazelcast/spi/ServiceNamespace>com/hazelcast/internal/partition/NonFragmentedServiceNamespaceINSTANCE@Lcom/hazelcast/internal/partition/NonFragmentedServiceNamespace; equals(Ljava/lang/Object;)Z (createNonFragmentedReplicationOperationsE(Lcom/hazelcast/spi/PartitionReplicationEvent;)Ljava/util/Collection; #createFragmentReplicationOperationsi(Lcom/hazelcast/spi/PartitionReplicationEvent;Lcom/hazelcast/spi/ServiceNamespace;)Ljava/util/Collection; java/util/CollectionsendOperations=(Ljava/util/Collection;Lcom/hazelcast/spi/ServiceNamespace;)V remove  releaseReplicaSyncPermits {java/lang/Throwable operations5Ljava/util/Collection;Ljava/util/Collection; namespace$Lcom/hazelcast/spi/ServiceNamespace;ievent-Lcom/hazelcast/spi/PartitionReplicationEvent;:Ljava/util/Iterator;Ljava/util/Iterator;\(Ljava/util/Collection;Lcom/hazelcast/spi/ServiceNamespace;)V logNoReplicaDataFound)(ILcom/hazelcast/spi/ServiceNamespace;I)V  sendResponse nsgetPartitionStateManager?()Lcom/hazelcast/internal/partition/impl/PartitionStateManager; N;com/hazelcast/internal/partition/impl/PartitionStateManagergetPartitionImpl@(I)Lcom/hazelcast/internal/partition/impl/InternalPartitionImpl; ;com/hazelcast/internal/partition/impl/InternalPartitionImplgetOwnerReplicaOrNull5()Lcom/hazelcast/internal/partition/PartitionReplica;  getNodeEngine ()Lcom/hazelcast/spi/NodeEngine; com/hazelcast/spi/NodeEnginegetLocalMember()Lcom/hazelcast/core/Member; 1com/hazelcast/internal/partition/PartitionReplica isIdentical(Lcom/hazelcast/core/Member;)Z FThis node is not owner partition. Cannot process request. partitionId=partitionStateManager=Lcom/hazelcast/internal/partition/impl/PartitionStateManager; partition=Lcom/hazelcast/internal/partition/impl/InternalPartitionImpl;owner3Lcom/hazelcast/internal/partition/PartitionReplica; nodeEngineLcom/hazelcast/spi/NodeEngine;Lcom/hazelcast/internal/partition/operation/PartitionReplicaSyncRetryResponse(Ljava/util/Collection;)V   !com/hazelcast/spi/Operation $getCallerAddress()Lcom/hazelcast/nio/Address;   getOperationService&()Lcom/hazelcast/spi/OperationService;   "com/hazelcast/spi/OperationServicesend;(Lcom/hazelcast/spi/Operation;Lcom/hazelcast/nio/Address;)Z  responseNLcom/hazelcast/internal/partition/operation/PartitionReplicaSyncRetryResponse;targetLcom/hazelcast/nio/Address;operationService$Lcom/hazelcast/spi/OperationService;createResponse(Ljava/util/Collection;Lcom/hazelcast/spi/ServiceNamespace;)Lcom/hazelcast/internal/partition/operation/PartitionReplicaSyncResponse;  Sending sync response to ->   for partitionId="Gcom/hazelcast/internal/partition/operation/PartitionReplicaSyncResponse$com/hazelcast/nio/Address& setTarget(Lcom/hazelcast/nio/Address;)V () %* syncResponseILcom/hazelcast/internal/partition/operation/PartitionReplicaSyncResponse;(Ljava/util/Collection;Lcom/hazelcast/spi/ServiceNamespace;)Lcom/hazelcast/internal/partition/operation/PartitionReplicaSyncResponse;9com/hazelcast/internal/partition/InternalPartitionService/!getPartitionReplicaVersionManagerC()Lcom/hazelcast/internal/partition/PartitionReplicaVersionManager; 12 03?com/hazelcast/internal/partition/PartitionReplicaVersionManager5getPartitionReplicaVersions)(ILcom/hazelcast/spi/ServiceNamespace;)[J 78 69?(Ljava/util/Collection;Lcom/hazelcast/spi/ServiceNamespace;[J)V ; %< %!;Lcom/hazelcast/internal/partition/InternalPartitionService;versionManagerALcom/hazelcast/internal/partition/PartitionReplicaVersionManager;versions[J)No replica data is found for partitionId=D , namespace= FreturnsResponse getResponsejava/lang/BooleanJTRUELjava/lang/Boolean; LM KNvalidatesTargetlogError(Ljava/lang/Throwable;)V3com/hazelcast/internal/partition/ReplicaErrorLoggerSlog7(Ljava/lang/Throwable;Lcom/hazelcast/logging/ILogger;)V UV TWeLjava/lang/Throwable;getServiceNamehz:core:partitionService\ writeInternal'(Lcom/hazelcast/nio/ObjectDataOutput;)Vjava/io/IOException`"com/hazelcast/nio/ObjectDataOutputbwriteInt d cehasNext gP h writeObject(Ljava/lang/Object;)V jk clout$Lcom/hazelcast/nio/ObjectDataOutput; readInternal&(Lcom/hazelcast/nio/ObjectDataInput;)V!com/hazelcast/nio/ObjectDataInputrreadInt t+ sujava/util/ArrayListw  xy readObject {J s|add ~ vin#Lcom/hazelcast/nio/ObjectDataInput;lengetId SignatureCodeLineNumberTableLocalVariableTableLocalVariableTypeTable StackMapTable Exceptions SourceFile1  > **BC D  **,*"W*%WFG HIJ*&' ('  );*-< -/Y1Y248;=8;?8CF)NOP:S;6G'HP*LNL+RJ*VM,[7,1Y2]8*`;b8*-;d8*gCj*m*p*m+t*y= **m** **mQNX ZWXYZ[+\L[Q^U_Vb]cadbgshwi{jknqrsu*Bs''C*VL+[7+1Y28*`;b8*-;d8*gCjBXxyz{=zB}C> *LNMY*`*-N*:6B: *-: *-:*,t:,tkvvxv6&N&NJ B#,8CMV^eksv\ J8-V&E'S#H'| JV#H&+**`,*-*,ӧ *+,ӱ % &&& &nP?*LNL+M,*`N-:*:J*V:[81Y28*`;b8*-;d8*gCj$6NDX6  "6<FUv{}H<Aw ric"]kB*L*`=*->Y*:W* :+:W&  '-5AHB= 8&'3('&-5 O}*N*+,:* :*V:[A1Y2!8g#8*`;b8*-;d8,gCj+-:Wa%'X2  #>\ahp|R}}}x p,-jdp  } D*`>*-6*L0:4:,::%Y+,=:>W" (5A\ DDD?&' 9('0?'@A(BC5,- D.?*V:[11Y2E8;b8;G8,gCj>X>4??&'??('9HP, IJ.O PP, QRA +*VX   YZ[A.] ^_7+*yf*M,i,N+-m ,36 ,77noapq8+v=*xYz> +}:*W !    %1 74% "'881'a+-