4Bcom/hazelcast/internal/partition/impl/PartitionReplicaStateCheckerjava/lang/Object!PartitionReplicaStateChecker.java^com/hazelcast/internal/partition/impl/PartitionReplicaStateChecker$ReplicaSyncResponseCallbackReplicaSyncResponseCallbackDEFAULT_PAUSE_MILLISI"REPLICA_SYNC_CHECK_TIMEOUT_SECONDS INVOCATION_TRY_COUNTINVOCATION_TRY_PAUSE_MILLISdnodeLcom/hazelcast/instance/Node; nodeEngine'Lcom/hazelcast/spi/impl/NodeEngineImpl;partitionServiceDLcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;loggerLcom/hazelcast/logging/ILogger;partitionStateManager=Lcom/hazelcast/internal/partition/impl/PartitionStateManager;migrationManager8Lcom/hazelcast/internal/partition/impl/MigrationManager;d(Lcom/hazelcast/instance/Node;Lcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;)V()V    "com/hazelcast/instance/Node$ getNodeEngine)()Lcom/hazelcast/spi/impl/NodeEngineImpl; &' %(  *  ,getClass()Ljava/lang/Class; ./ 0 getLogger2(Ljava/lang/Class;)Lcom/hazelcast/logging/ILogger; 23 %4  6Bcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl8getPartitionStateManager?()Lcom/hazelcast/internal/partition/impl/PartitionStateManager; :; 9<  >getMigrationManager:()Lcom/hazelcast/internal/partition/impl/MigrationManager; @A 9B  DthisDLcom/hazelcast/internal/partition/impl/PartitionReplicaStateChecker;getPartitionServiceState?()Lcom/hazelcast/internal/partition/impl/PartitionServiceState;+isFetchMostRecentPartitionTableTaskRequired()Z JK 9L;com/hazelcast/internal/partition/impl/PartitionServiceStateNFETCHING_PARTITION_TABLE=Lcom/hazelcast/internal/partition/impl/PartitionServiceState; PQ ORhasMissingReplicaOwners TK UREPLICA_NOT_OWNED WQ OX6com/hazelcast/internal/partition/impl/MigrationManagerZhasOnGoingMigration \K []MIGRATION_LOCAL _Q O`isLocalMemberMaster bK 9cjava/util/logging/LeveleOFFLjava/util/logging/Level; gh fihasOnGoingMigrationMaster(Ljava/util/logging/Level;)Z kl mMIGRATION_ON_MASTER oQ OpcheckAndTriggerReplicaSync rK sREPLICA_NOT_SYNC uQ OvSAFE xQ OytriggerAndWaitForReplicaSync#(JLjava/util/concurrent/TimeUnit;)Z$(JLjava/util/concurrent/TimeUnit;J)Z { timeoutJunitLjava/util/concurrent/TimeUnit;java/util/concurrent/TimeUnittoMillis(J)J FINE h fwaitForMissingReplicaOwners(Ljava/util/logging/Level;JJ)J waitForOngoingMigrations com/hazelcast/util/ClockcurrentTimeMillis()J Replica sync state is OKcom/hazelcast/logging/ILoggerfinest(Ljava/lang/String;)V java/lang/StringBuilder ZSome backup replicas are inconsistent with primary, waiting for synchronization. Timeout: append-(Ljava/lang/String;)Ljava/lang/StringBuilder; (J)Ljava/lang/StringBuilder; mstoString()Ljava/lang/String; info sleepWithBusyWait(JJ)J start syncResultZ sleepMillistimeoutInMillis isLoggable l >Waiting for ownership assignments of missing replica owners...log.(Ljava/util/logging/Level;Ljava/lang/String;)V levelsleepneedsReplicaStateCheck K ;com/hazelcast/internal/partition/impl/PartitionStateManagergetMemberGroupsSize()I java/lang/Mathmin(II)I getClusterService:()Lcom/hazelcast/internal/cluster/impl/ClusterServiceImpl; %6com/hazelcast/internal/cluster/impl/ClusterServiceImplgetClusterState&()Lcom/hazelcast/cluster/ClusterState;  getPartitions7()[Lcom/hazelcast/internal/partition/InternalPartition; "com/hazelcast/cluster/ClusterState5[Lcom/hazelcast/internal/partition/InternalPartition;2com/hazelcast/internal/partition/InternalPartition getReplica6(I)Lcom/hazelcast/internal/partition/PartitionReplica; isFinestEnabled K Missing replica=(I)Ljava/lang/StringBuilder;  for partitionId=getPartitionId 1com/hazelcast/internal/partition/PartitionReplicaaddress()Lcom/hazelcast/nio/Address;  uuid   getMemberR(Lcom/hazelcast/nio/Address;Ljava/lang/String;)Lcom/hazelcast/instance/MemberImpl;     isJoinAllowed K isMissingMember0(Lcom/hazelcast/nio/Address;Ljava/lang/String;)Z  Unknown replica owner= -(Ljava/lang/Object;)Ljava/lang/StringBuilder;  , partitionId= , replica=replica3Lcom/hazelcast/internal/partition/PartitionReplica;index partition4Lcom/hazelcast/internal/partition/InternalPartition;memberGroupsSize replicaCountclusterService8Lcom/hazelcast/internal/cluster/impl/ClusterServiceImpl; clusterState$Lcom/hazelcast/cluster/ClusterState;?Waiting for the master node to complete remaining migrations...)java/lang/InterruptedException+java/lang/Thread-(J)V / .0 currentThread()Ljava/lang/Thread; 23 .4 interrupt 6 .7Busy wait interrupted9*(Ljava/lang/String;Ljava/lang/Throwable;)V ; <ie Ljava/lang/InterruptedException;java/util/concurrent/Semaphore@(I)V B AC)java/util/concurrent/atomic/AtomicBooleanE(Z)V G FHgetMaxAllowedBackupCount J 9KinvokeReplicaSyncOperationsO(ILjava/util/concurrent/Semaphore;Ljava/util/concurrent/atomic/AtomicBoolean;)I MN Oget QK FR SECONDS V W tryAcquire$(IJLjava/util/concurrent/TimeUnit;)Z YZ A[permitsreceivedAllResponsesignored semaphore Ljava/util/concurrent/Semaphore;ok+Ljava/util/concurrent/atomic/AtomicBoolean;maxBackupCountownedPartitionCountgetLocalMember%()Lcom/hazelcast/instance/MemberImpl; fg %hN(Ljava/util/concurrent/atomic/AtomicBoolean;Ljava/util/concurrent/Semaphore;)V j k!com/hazelcast/instance/MemberImplm$com/hazelcast/core/ExecutionCallbackogetOwnerReplicaOrNull5()Lcom/hazelcast/internal/partition/PartitionReplica; qr sset uG Fv isIdentical(Lcom/hazelcast/core/Member;)Z xy z isMigrating |K }release  AFcom/hazelcast/internal/partition/impl/CheckPartitionReplicaVersionTaskR(Lcom/hazelcast/spi/impl/NodeEngineImpl;IILcom/hazelcast/core/ExecutionCallback;)V  %com/hazelcast/spi/impl/NodeEngineImplgetOperationServiceD()Lcom/hazelcast/spi/impl/operationservice/InternalOperationService;  @com/hazelcast/spi/impl/operationservice/InternalOperationServiceexecute5(Lcom/hazelcast/spi/impl/PartitionSpecificRunnable;)V   replicaOwner partitionIdtask2Lcom/hazelcast/spi/impl/PartitionSpecificRunnable;ownerresult localMember#Lcom/hazelcast/instance/MemberImpl;callback:Lcom/hazelcast/core/ExecutionCallback;&Lcom/hazelcast/core/ExecutionCallback; ownedCount isInitialized K java/lang/Exception-com/hazelcast/internal/cluster/ClusterServicegetMasterAddress  isJoined K com/hazelcast/nio/Address>com/hazelcast/internal/partition/operation/HasOngoingMigration  hz:core:partitionService"com/hazelcast/spi/OperationServicecreateInvocationBuilderq(Ljava/lang/String;Lcom/hazelcast/spi/Operation;Lcom/hazelcast/nio/Address;)Lcom/hazelcast/spi/InvocationBuilder;  #com/hazelcast/spi/InvocationBuilder setTryCount((I)Lcom/hazelcast/spi/InvocationBuilder;  dsetTryPauseMillis((J)Lcom/hazelcast/spi/InvocationBuilder;  invoke/()Lcom/hazelcast/spi/InternalCompletableFuture;  +com/hazelcast/spi/InternalCompletableFuturejoin()Ljava/lang/Object;  java/lang/Boolean booleanValue K com/hazelcast/spi/Operation:Could not get a response from master about migrations! ->  eLjava/lang/Exception;/Lcom/hazelcast/internal/cluster/ClusterService; masterAddressLcom/hazelcast/nio/Address; operationLcom/hazelcast/spi/Operation;operationService$Lcom/hazelcast/spi/OperationService;futureBLcom/hazelcast/spi/InternalCompletableFuture;-Lcom/hazelcast/spi/InternalCompletableFuture; ConstantValueCodeLineNumberTableLocalVariableTable StackMapTableLocalVariableTypeTable InnerClasses SourceFile!         3*!*+#*+)+*,-*+*157*,=?*,CE"FG HIJ"L*M2N 3FG33HIN*-MS*VY*E^a*-d*jnq*twz  . Q RUVY#Z'];^?aFbJe NFG{|H *-}i  FG  {h -7 *7 {*7 d7*t6 ee7 *7 2*7Y*7m' .Rmnop"q%t2u9v<yAzG{R|W}b~dknHAYGS FG: 7 0*V)*7+*7+ƹ*7& *74:FG:h::7TK *Ϛ*?<=*#N-:*?:662:6   :  =*7/*7Y -    c-   J*7<*7Y   <%5 -M)Db  &ENY^j RY H E!"FG# $  %&&'(F 7 <*E^ *+n**7+*7+**7  )6C4FFGFhFFC!!1:58*7:=!e,G, * >?!FG!!rKPe*ϚAYDLFYIM*-L>*+,P6,Sh6+TX\6,S:58,4[,5Z[,1 +AF#@AF,: #,35;I[]cR; ] I^]_?eFGS`aJbc#Bd ,9e MN*#i:Y-,l:*#::6*?:  6 6     2:  t:  -w { ~-wy6p :-w,N  ,- 6Y*+:*+ =D 8 AFnp# ! ) $'FOTY\filpz    \! s O F!" FGd `ac %&$'('  KO*?*?՞@" FGklo}*#M,N- ,Y:*+:- Ķ:жӬ:*7+Y׶ضIVW*<f>&'(),#-,.4/;0A1D2I5W6Y7{9RY"}FG}hu%n#Z,QI4 I4