ت‏؛¾4z=com/hazelcast/internal/partition/impl/PartitionReplicaManagerjava/lang/Object?com/hazelcast/internal/partition/PartitionReplicaVersionManagerPartitionReplicaManager.java?com/hazelcast/internal/partition/impl/PartitionReplicaManager$1]com/hazelcast/internal/partition/impl/PartitionReplicaManager$PartitionAntiEntropyTaskFactory PartitionAntiEntropyTaskFactoryMcom/hazelcast/internal/partition/impl/PartitionReplicaManager$AntiEntropyTask AntiEntropyTaskYcom/hazelcast/internal/partition/impl/PartitionReplicaManager$ReplicaSyncTimeoutProcessorReplicaSyncTimeoutProcessornodeLcom/hazelcast/instance/Node; nodeEngine'Lcom/hazelcast/spi/impl/NodeEngineImpl;loggerLcom/hazelcast/logging/ILogger;partitionServiceDLcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;partitionStateManager=Lcom/hazelcast/internal/partition/impl/PartitionStateManager;replicaVersionsA[Lcom/hazelcast/internal/partition/impl/PartitionReplicaVersions;replicaSyncRequestsLjava/util/Set;PLjava/util/Set;replicaSyncTimeoutScheduler1Lcom/hazelcast/util/scheduler/EntryTaskScheduler;‚Lcom/hazelcast/util/scheduler/EntryTaskScheduler;replicaSyncSemaphore Ljava/util/concurrent/Semaphore;&Lcom/hazelcast/internal/metrics/Probe;replicaSyncRequestsCounter0Lcom/hazelcast/internal/util/counters/MwCounter;partitionMigrationTimeoutJmaxParallelReplicationsI$assertionsDisabledZd(Lcom/hazelcast/instance/Node;Lcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;)V()V02 3.com/hazelcast/internal/util/counters/MwCounter5newMwCounter2()Lcom/hazelcast/internal/util/counters/MwCounter;78 69() ; =com/hazelcast/instance/Node? @A AgetClass()Ljava/lang/Class;DE F getLogger2(Ljava/lang/Class;)Lcom/hazelcast/logging/ILogger;HI @J L NBcom/hazelcast/internal/partition/impl/InternalPartitionServiceImplPgetPartitionCount()IRS QTgetPartitionStateManager?()Lcom/hazelcast/internal/partition/impl/PartitionStateManager;VW QX Z getProperties4()Lcom/hazelcast/spi/properties/HazelcastProperties;\] @^*com/hazelcast/spi/properties/GroupProperty`PARTITION_MIGRATION_TIMEOUT0Lcom/hazelcast/spi/properties/HazelcastProperty;bc ad0com/hazelcast/spi/properties/HazelcastPropertiesf getMillis3(Lcom/hazelcast/spi/properties/HazelcastProperty;)Jhi gj*+ l#PARTITION_MAX_PARALLEL_REPLICATIONSnc ao getInteger3(Lcom/hazelcast/spi/properties/HazelcastProperty;)Iqr gs,- ujava/util/concurrent/Semaphorew(I)V0y xz%& |>com/hazelcast/internal/partition/impl/PartitionReplicaVersions~ € z%com/hazelcast/spi/impl/NodeEngineImplƒgetExecutionServiceD()Lcom/hazelcast/spi/impl/executionservice/InternalExecutionService;…† „‡"com/hazelcast/spi/ExecutionService‰getGlobalTaskScheduler#()Lcom/hazelcast/spi/TaskScheduler;‹Œٹچƒ(Lcom/hazelcast/internal/partition/impl/PartitionReplicaManager;Lcom/hazelcast/internal/partition/impl/PartitionReplicaManager$1;)V0ڈ گ)com/hazelcast/util/scheduler/ScheduleType’POSTPONE+Lcom/hazelcast/util/scheduler/ScheduleType;”• “–6com/hazelcast/util/scheduler/EntryTaskSchedulerFactoryکnewSchedulerµ(Lcom/hazelcast/spi/TaskScheduler;Lcom/hazelcast/util/scheduler/ScheduledEntryProcessor;Lcom/hazelcast/util/scheduler/ScheduleType;)Lcom/hazelcast/util/scheduler/EntryTaskScheduler;ڑ› ™œ"# ‍&java/util/concurrent/ConcurrentHashMap ،zjava/util/Collections£ newSetFromMap (Ljava/util/Map;)Ljava/util/Set;¥¦ ¤§ ©ithis?Lcom/hazelcast/internal/partition/impl/PartitionReplicaManager;partitionCount properties2Lcom/hazelcast/spi/properties/HazelcastProperties;executionService$Lcom/hazelcast/spi/ExecutionService;globalScheduler!Lcom/hazelcast/spi/TaskScheduler;triggerPartitionReplicaSync(ILjava/util/Collection;I)VA(ILjava/util/Collection;I)V./ ¸java/lang/AssertionError؛java/lang/StringBuilder¼ ½3#Invalid replica index! partitionId=؟append-(Ljava/lang/String;)Ljava/lang/StringBuilder;ءآ ½أ(I)Ljava/lang/StringBuilder;ءإ ½ئ, replicaIndex=بtoString()Ljava/lang/String;تث ½ج(Ljava/lang/Object;)V0خ »دcheckAndGetPrimaryReplicaOwner7(II)Lcom/hazelcast/internal/partition/PartitionReplica;رز س1com/hazelcast/internal/partition/PartitionReplicaصareMigrationTasksAllowed()Z×ط Qظ1Cannot send sync replica request for partitionId=غ , namespaces=ف-(Ljava/lang/Object;)Ljava/lang/StringBuilder;ءك ½à. Sync is not allowed.âcom/hazelcast/logging/ILoggerنfinest(Ljava/lang/String;)Vوçهè;com/hazelcast/internal/partition/impl/PartitionStateManagerêgetPartitionImpl@(I)Lcom/hazelcast/internal/partition/impl/InternalPartitionImpl;ىي ëî;com/hazelcast/internal/partition/impl/InternalPartitionImplًisMigratingٍط ٌَ!. Partition is already migrating.ُsendSyncReplicaRequestN(ILjava/util/Collection;ILcom/hazelcast/internal/partition/PartitionReplica;)V÷ّ ùpartitionId namespaces;Ljava/util/Collection;replicaIndextarget3Lcom/hazelcast/internal/partition/PartitionReplica; partition=Lcom/hazelcast/internal/partition/impl/InternalPartitionImpl;getOwnerReplicaOrNull5()Lcom/hazelcast/internal/partition/PartitionReplica; ٌ partitionId=info çهgetLocalMember%()Lcom/hazelcast/instance/MemberImpl; „fromP(Lcom/hazelcast/core/Member;)Lcom/hazelcast/internal/partition/PartitionReplica; ضequals(Ljava/lang/Object;)Z ضisFinestEnabledطهHThis node is now owner of partition, cannot sync replica -> partitionId=, partition-info=isOwnerOrBackup6(Lcom/hazelcast/internal/partition/PartitionReplica;)Z ! ٌ"/This node is not backup replica of partitionId=$ anymore.&ownerlocalReplicat(ILjava/util/Collection;ILcom/hazelcast/internal/partition/PartitionReplica;)VclusterService8Lcom/hazelcast/internal/cluster/impl/ClusterServiceImpl;+, @-address()Lcom/hazelcast/nio/Address;/0 ض1uuid3ث ض46com/hazelcast/internal/cluster/impl/ClusterServiceImpl6isMissingMember0(Lcom/hazelcast/nio/Address;Ljava/lang/String;)Z89 7:java/util/Collection<size>S=?tryAcquireReplicaSyncPermits(I)IAB C. No permits available!EregisterSyncInfoForNamespaces^(ILjava/util/Collection;ILcom/hazelcast/internal/partition/PartitionReplica;I)Ljava/util/List;GH Ijava/util/ListKL?releaseReplicaSyncPermitsNy OisEmptyQطLR-Sending sync replica request for partitionId=Tinc()JVW 6XFcom/hazelcast/internal/partition/operation/PartitionReplicaSyncRequestZ(ILjava/util/List;I)V0\ []getOperationServiceD()Lcom/hazelcast/spi/impl/operationservice/InternalOperationService;_` „a@com/hazelcast/spi/impl/operationservice/InternalOperationServicecsend;(Lcom/hazelcast/spi/Operation;Lcom/hazelcast/nio/Address;)ZefdgrequestedNamespacespermits6Ljava/util/List;Ljava/util/List;syncRequestHLcom/hazelcast/internal/partition/operation/PartitionReplicaSyncRequest;ھ(ILjava/util/Collection;ILcom/hazelcast/internal/partition/PartitionReplica;I)Ljava/util/List;java/util/ArrayListp qziterator()Ljava/util/Iterator;st=ujava/util/IteratorwhasNextyطxznext()Ljava/lang/Object;|}x~"com/hazelcast/spi/ServiceNamespace€%Cannot send sync replica request for ‚, namespace=„registerSyncInfoFor\(ILcom/hazelcast/spi/ServiceNamespace;ILcom/hazelcast/internal/partition/PartitionReplica;)Z†‡ ˆaddٹL‹ namespace$Lcom/hazelcast/spi/ServiceNamespace;=com/hazelcast/internal/partition/impl/ReplicaFragmentSyncInfoڈ\(ILcom/hazelcast/spi/ServiceNamespace;ILcom/hazelcast/internal/partition/PartitionReplica;)V0‘ گ’ java/util/Set”•‹. Sync is already in progress!—/com/hazelcast/util/scheduler/EntryTaskScheduler™schedule((JLjava/lang/Object;Ljava/lang/Object;)Z›œڑ‌syncInfo?Lcom/hazelcast/internal/partition/impl/ReplicaFragmentSyncInfo;getServiceNamespaceC(Lcom/hazelcast/spi/Operation;)Lcom/hazelcast/spi/ServiceNamespace;'com/hazelcast/spi/ServiceNamespaceAware£&()Lcom/hazelcast/spi/ServiceNamespace;،¥¤¦>com/hazelcast/internal/partition/NonFragmentedServiceNamespace¨INSTANCE@Lcom/hazelcast/internal/partition/NonFragmentedServiceNamespace;ھ« ©¬ operationLcom/hazelcast/spi/Operation;!incrementPartitionReplicaVersions*(ILcom/hazelcast/spi/ServiceNamespace;I)[JincrementAndGet)(Lcom/hazelcast/spi/ServiceNamespace;I)[J²³ ´backupCountreplicaVersion@Lcom/hazelcast/internal/partition/impl/PartitionReplicaVersions;updatePartitionReplicaVersions+(ILcom/hazelcast/spi/ServiceNamespace;[JI)Vupdate*(Lcom/hazelcast/spi/ServiceNamespace;[JI)Z»¼ ½ singleton#(Ljava/lang/Object;)Ljava/util/Set;؟ہ ¤ءµ¶ أversions[JpartitionVersionisPartitionReplicaVersionStale+(ILcom/hazelcast/spi/ServiceNamespace;[JI)ZisStaleت¼ ثisPartitionReplicaVersionDirty((ILcom/hazelcast/spi/ServiceNamespace;)ZisDirty'(Lcom/hazelcast/spi/ServiceNamespace;)Zدذ رgetPartitionReplicaVersions)(ILcom/hazelcast/spi/ServiceNamespace;)[Jget((Lcom/hazelcast/spi/ServiceNamespace;)[Jصض ×setPartitionReplicaVersionsset*(Lcom/hazelcast/spi/ServiceNamespace;[JI)Vعغ ـ replicaOffsetclearPartitionReplicaVersions((ILcom/hazelcast/spi/ServiceNamespace;)Vclear'(Lcom/hazelcast/spi/ServiceNamespace;)Vلâ مfinalizeReplicaSync+(IILcom/hazelcast/spi/ServiceNamespace;[J)VclearReplicaSyncRequest)(ILcom/hazelcast/spi/ServiceNamespace;I)Vçè éremoveë•ى.Clearing sync replica request for partitionId=îcancelIfExists'(Ljava/lang/Object;Ljava/lang/Object;)IًٌڑٍcancelReplicaSyncRequestsTo(Lcom/hazelcast/core/Member;)V•u گ÷isIdentical(Lcom/hazelcast/core/Member;)Zùْ ضûë2x‎cancelA(Ljava/lang/Object;)Lcom/hazelcast/util/scheduler/ScheduledEntry;ےڑmemberLcom/hazelcast/core/Member;iterULjava/util/Iterator;Ljava/util/Iterator;cancelReplicaSyncû- گ Invalid permits: tryAcquire(I)Z x Acquired - replica sync permits, requested permits was . Remaining permits: availablePermitsS xrequestedPermitsreleasey x Released * replica sync permits. Available permits: availableReplicaSyncPermits"S #>Number of replica sync permits exceeded the configured number!%getOngoingReplicaSyncRequests()Ljava/util/List;S()Ljava/util/List;(Ljava/util/Collection;)V0* q+getScheduledReplicaSyncRequests’()Ljava/util/List;>; q3صڑ0entry~Lcom/hazelcast/util/scheduler/ScheduledEntry;-Lcom/hazelcast/util/scheduler/ScheduledEntry;entriesگLjava/util/List;>;resetل2•8 cancelAll:2ڑ;drainPermits=S x>scheduleReplicaVersionSync'(Lcom/hazelcast/spi/ExecutionService;)VPARTITION_BACKUP_SYNC_INTERVALBc aC getSecondsEr gF گjava/util/concurrent/TimeUnitISECONDSLjava/util/concurrent/TimeUnit;KL JMscheduleWithRepetition](Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;OPٹQdefinedBackupSyncCheckIntervalbackupSyncCheckInterval getNamespaces(I)Ljava/util/Collection;?(I)Ljava/util/Collection;()Ljava/util/Collection;UX YretainNamespaces(ILjava/util/Set;)V9(ILjava/util/Set;)V(Ljava/util/Set;)V[^ _5Ljava/util/Set; access$200P(Lcom/hazelcast/internal/partition/impl/PartitionReplicaManager;)Ljava/util/Set;x0 access$300^(Lcom/hazelcast/internal/partition/impl/PartitionReplicaManager;)Lcom/hazelcast/instance/Node; access$400…(Lcom/hazelcast/internal/partition/impl/PartitionReplicaManager;)Lcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl; access$600h(Lcom/hazelcast/internal/partition/impl/PartitionReplicaManager;)Lcom/hazelcast/spi/impl/NodeEngineImpl;java/lang/ClassldesiredAssertionStatusnط mo SignatureRuntimeVisibleAnnotationsCode StackMapTableLineNumberTableLocalVariableTableLocalVariableTypeTableInnerClasses SourceFile! q!"#q$%&r'()r'*+,-./ 01s©إ*·4*¸:µ<*+µ>*+´BµC*+*¶G¶KµM*,µO,¶U>*,¶Yµ[+¶_:*²e¶kµm*²p¶tµv*»xY*´v·{µ}*½µپ6*´پ¾¢*´پ»Y·‚S„§ےم*´C¶ˆ:¹ژ:*»Y*·‘²—¸‌µں*»،Y·¢¸¨µھ±tےn@QgْuZSMNTUV$W)Y.Z6\<]H^T_cakbxcˆbژf—g pµsؤtvRn «-إ¬إإ.—®-<‰¯°—.±² %³´µ¶s…ذ²¹ڑ1› ،'»»Y»½Y·¾ہ¶ؤ¶اة¶ؤ¶ا¶ح·ذ؟*¶ش:ا±*´O¶عڑ7*´M»½Y·¾ـ¶ؤ¶اة¶ؤ¶اق¶ؤ,¶لم¶ؤ¶ح¹é±*´[¶ï:¶ô™7*´M»½Y·¾ـ¶ؤ¶اة¶ؤ¶اق¶ؤ,¶لِ¶ؤ¶ح¹é±*,·ْ±t#ü ض=üEٌu6 ‡4ٹ<‹AŒBڈLگ’€•ٹ–’—إ™ئœد‌v>ذ¬ذû-ذü‏ذے-<”ٹFwذü‎q·رزs•ف*´[¶ïN-¶:ا+*´M»½Y·¾ ¶ؤ¶اة¶ؤ¶ا¶ح¹°*´C¶¸:¶™H*´M¹™:*´M»½Y·¾¶ؤ¶اة¶ؤ¶ا¶ؤ*´[¶ï¶ل¶ح¹é°-¶#ڑ=*´M¹™/*´M»½Y·¾%¶ؤ¶اة¶ؤ¶ا'¶ؤ¶ح¹é°°t‎<ٌضüXضû@uF، ¢£¤:¦<©HھR«^¬‡®گ¬•°—³ ´¬µط¸ع؛v>ف¬فû-فے- شخ(H•)÷ّsى*´>´.¶2¶5¶;™±*,¹@¶D6ڑD*´M¹™7*´M»½Y·¾ـ¶ؤ¶اة¶ؤ¶اق¶ؤ,¶لF¶ؤ¶ح¹é±*,·J:¹Mں*¹Md¶P¹S™±*´M¹™3*´M»½Y·¾U¶ؤ¶اة¶ؤ¶اق¶ؤ¶ل¶ح¹é*´<¶YX»[Y·^:*´C¶b¶2¹hW±tüPü&L ;uNؤإب$ة)ت5ثiدjسrشw×ƒط‘غ›ـœك¨àطمàهيوçvR¬û-i‏ے-$قj-w‹ülيmnwi‎w‹ükq*GHse ک»qY·r:,¹v:¹{™{¹ہپ:¹M I*´M¹™W*´M»½Y·¾ƒ¶ؤ¶اة¶ؤ¶ا…¶ؤ¶لF¶ؤ¶ح¹é§ے›*·‰™ ¹ŒW§ےپ°t‎Lxügپْْu* ىي)î5ïAًxٍ{ُˆِ’ّ•ùvR)iچژک¬کû-کi‏کے-ککj-چülwکi‎چükqo†‡sنa»گY,·“:*´ھ¹–ڑ5*´M¹™'*´M»½Y·¾ƒ¶ؤ¶لک¶ؤ¶ح¹é¬*´ں*´m¹‍W¬t üLگu‎‏ے(LN_v>a¬aû-aچژaے-aSں ،¢sZ+ء¤™ +ہ¤¹§°²°tu v¬®¯°±sf*´پ2:,¶µ°u v4¬û-چژ¶-·¸¹؛s– *´پ2:,-¶¾ڑ*,¸آ¶ؤ±tüuv> ¬ û- چژ إئ ے-ا¸بةs`*´پ2,-¶ج¬u$v4¬û-چژإئے-حخsI*´پ2,¶ز¬u)v ¬û-چژسشsI*´پ2,¶ط°u/v ¬û-چژظ؛sd*´پ2,-¶ف±u 5 6v4¬û-چژإئق-كàsM*´پ2,¶ن±u : ;v ¬û-چژهوs‹*´پ2:-¶ن-¶ف*-¶ê±uGHIJKv>¬û-ے-چژإئ·¸çèsèk»گY,·“:*´ھ¹يڑ±*´M¹™3*´M»½Y·¾ï¶ؤ¶اة¶ؤ¶ا…¶ؤ,¶ل¶ح¹é*¶P*´ں¹َW±t üگ;u"W XY\(]X`]ajbv4k¬kû-kچژkے- ^ں ôُsسI*´ھ¹ِM,¹{™8,¹ہگN-´ّئ$-´ّ+¶ü™,¹‏*´ں-¹W*¶P§ےإ±t ü x:u& e fgh/i5j@kEmHnv*(ں I¬I ?w ?ysة?*´ھ¹ِM,¹{™.,¹ہگN-´ ,¹‏*´ں-¹W*¶P§ےد±t ü x0u& q rst%u+v6w;y>zv*ں ?¬?û- 5w 5ABsُ†²¹ڑ#‌»»Y»½Y·¾¶ؤ¶ا¶ح·ذ؟=‍*´}¶ڑ „ے§ےî‍F*´M¹™:*´M»½Y·¾¶ؤ¶ا¶ؤ¶ا¶ؤ*´}¶¶ا¶ح¹é¬t&üûFu& …&‡(ˆ7‰=ŒMچvژچ„گv †¬†-(^j-Nysل„²¹ڑ#‌»»Y»½Y·¾¶ؤ¶ا¶ح·ذ؟*´}¶*´M¹™0*´M»½Y·¾¶ؤ¶ا!¶ؤ*´}¶¶ا¶ح¹é²¹ڑ*¶$*´v¤»»Y&·ذ؟±t&û@u"™&ڑ.›:œY‌bœgںƒ،v„¬„j-"Ss2*´}¶¬u§v¬'(s6»qY*´ھ·,°u®v¬q)-(sصD»qY·/L*´ھ¹ِM,¹{™*,¹ہگN*´ں-¹1:ئ+¹ŒW§ےس+°t‎Lx,ْu¶·%¸1¹6؛?¼B½v*124%ں D¬<5lw123<56q.72s`&*´ھ¹9*´ں¹<*´}¶?W*´}*´v¶±uء آإئ%اv&¬@As–4*´>¶_²D¶G…A ”‍ § 7+»Y*·H²N¹RW±tü@uتثح3دv*4¬4±²%S+T+UVs> *´پ2¶Z°uسv ¬ û-qW[\so *´پ2N-,¶`±u×طظv* ¬ û- ü إ¸w üaq]bcs/*´ھ°u?vdefs/*´>°u?vdghs/*´O°u?vdijs/*´C°u?vdk2s4¶pڑ§³¹±t@u?x" y