4Bcom/hazelcast/internal/partition/impl/InternalPartitionServiceImplLjava/lang/Object;Lcom/hazelcast/internal/partition/InternalPartitionService;Lcom/hazelcast/spi/EventPublishingService;>;Lcom/hazelcast/spi/PartitionAwareService;Lcom/hazelcast/internal/cluster/ClusterStateListener;Lcom/hazelcast/internal/cluster/ClusterVersionListener;java/lang/Object9com/hazelcast/internal/partition/InternalPartitionService(com/hazelcast/spi/EventPublishingService'com/hazelcast/spi/PartitionAwareService 3com/hazelcast/internal/cluster/ClusterStateListener 5com/hazelcast/internal/cluster/ClusterVersionListener!InternalPartitionServiceImpl.javadcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl$FetchMostRecentPartitionTableTask!FetchMostRecentPartitionTableTaskDcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl$3Dcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl$2Dcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl$1.com/hazelcast/util/FutureUtil$ExceptionHandlercom/hazelcast/util/FutureUtilExceptionHandler>com/hazelcast/internal/partition/MigrationInfo$MigrationStatus.com/hazelcast/internal/partition/MigrationInfo!MigrationStatusPARTITION_OWNERSHIP_WAIT_MILLISI *EXCEPTION_MSG_PARTITION_STATE_SYNC_TIMEOUTLjava/lang/String;)Partition state sync invocation timed out)PTABLE_SYNC_TIMEOUT_SECONDS#SAFE_SHUTDOWN_MAX_AWAIT_STEP_MILLISFETCH_PARTITION_STATE_SECONDSJTRIGGER_MASTER_DELAY_MILLISnodeLcom/hazelcast/instance/Node; nodeEngine'Lcom/hazelcast/spi/impl/NodeEngineImpl;loggerLcom/hazelcast/logging/ILogger;partitionCountpartitionMigrationTimeoutproxy8Lcom/hazelcast/internal/partition/PartitionServiceProxy;lock!Ljava/util/concurrent/locks/Lock;partitionListenerALcom/hazelcast/internal/partition/impl/InternalPartitionListener;partitionStateManager=Lcom/hazelcast/internal/partition/impl/PartitionStateManager;migrationManager8Lcom/hazelcast/internal/partition/impl/MigrationManager;replicaManager?Lcom/hazelcast/internal/partition/impl/PartitionReplicaManager;partitionReplicaStateCheckerDLcom/hazelcast/internal/partition/impl/PartitionReplicaStateChecker;partitionEventManager=Lcom/hazelcast/internal/partition/impl/PartitionEventManager; partitionStateSyncTimeoutHandler0Lcom/hazelcast/util/FutureUtil$ExceptionHandler;masterTriggered+Ljava/util/concurrent/atomic/AtomicBoolean; masterTrigger7Lcom/hazelcast/util/scheduler/CoalescingDelayedTrigger;shutdownLatchRef-Ljava/util/concurrent/atomic/AtomicReference;TLjava/util/concurrent/atomic/AtomicReference; latestMasterLcom/hazelcast/nio/Address;shouldFetchPartitionTablesZ$assertionsDisabled (Lcom/hazelcast/instance/Node;)V()V [] ^(java/util/concurrent/locks/ReentrantLock` a^ ?@ c)java/util/concurrent/atomic/AtomicBooleane(Z)V [g fh OP j+java/util/concurrent/atomic/AtomicReferencel m^ ST ocom/hazelcast/instance/Nodeq getProperties4()Lcom/hazelcast/spi/properties/HazelcastProperties; st ru*com/hazelcast/spi/properties/GroupPropertywPARTITION_COUNT0Lcom/hazelcast/spi/properties/HazelcastProperty; yz x{0com/hazelcast/spi/properties/HazelcastProperties} getInteger3(Lcom/hazelcast/spi/properties/HazelcastProperty;)I  ~ ;%  56  78 r  getLogger2(Ljava/lang/Class;)Lcom/hazelcast/logging/ILogger; r 9: ?com/hazelcast/internal/partition/impl/InternalPartitionListenerd(Lcom/hazelcast/instance/Node;Lcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;)V [ AB ;com/hazelcast/internal/partition/impl/PartitionStateManager(Lcom/hazelcast/instance/Node;Lcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;Lcom/hazelcast/internal/partition/PartitionListener;)V [ CD 6com/hazelcast/internal/partition/impl/MigrationManager(Lcom/hazelcast/instance/Node;Lcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;Ljava/util/concurrent/locks/Lock;)V [ EF =com/hazelcast/internal/partition/impl/PartitionReplicaManager GH Bcom/hazelcast/internal/partition/impl/PartitionReplicaStateChecker IJ ;com/hazelcast/internal/partition/impl/PartitionEventManager [\ KL 5com/hazelcast/util/scheduler/CoalescingDelayedTrigger%com/hazelcast/spi/impl/NodeEngineImplgetExecutionServiceD()Lcom/hazelcast/spi/impl/executionservice/InternalExecutionService; G(Lcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;)V [ =(Lcom/hazelcast/spi/ExecutionService;JJLjava/lang/Runnable;)V [ QR java/util/logging/LevelFINESTLjava/util/logging/Level; logAllExceptions|(Lcom/hazelcast/logging/ILogger;Ljava/lang/String;Ljava/util/logging/Level;)Lcom/hazelcast/util/FutureUtil$ExceptionHandler;  MN PARTITION_MIGRATION_TIMEOUT z x getMillis3(Lcom/hazelcast/spi/properties/HazelcastProperty;)J ~ </ 6com/hazelcast/internal/partition/PartitionServiceProxyn(Lcom/hazelcast/spi/impl/NodeEngineImpl;Lcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;)V [ => getMetricsRegistry2()Lcom/hazelcast/internal/metrics/MetricsRegistry;  partitions.com/hazelcast/internal/metrics/MetricsRegistryscanAndRegister'(Ljava/lang/Object;Ljava/lang/String;)V thisDLcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl; properties2Lcom/hazelcast/spi/properties/HazelcastProperties;metricsRegistry0Lcom/hazelcast/internal/metrics/MetricsRegistry;init7(Lcom/hazelcast/spi/NodeEngine;Ljava/util/Properties;)VPARTITION_TABLE_SEND_INTERVAL z x getSeconds ~com/hazelcast/spi/NodeEngine&()Lcom/hazelcast/spi/ExecutionService; Fcom/hazelcast/internal/partition/impl/PublishPartitionRuntimeStateTask java/util/concurrent/TimeUnitSECONDSLjava/util/concurrent/TimeUnit;   "com/hazelcast/spi/ExecutionService scheduleWithRepetition](Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;    start ] scheduleReplicaVersionSync'(Lcom/hazelcast/spi/ExecutionService;)V  Lcom/hazelcast/spi/NodeEngine;Ljava/util/Properties;partitionTableSendIntervalexecutionService$Lcom/hazelcast/spi/ExecutionService;getPartitionOwner(I)Lcom/hazelcast/nio/Address; isInitialized()Z  !firstArrangement:()Lcom/hazelcast/internal/partition/PartitionRuntimeState; #$ %getPartitionImpl@(I)Lcom/hazelcast/internal/partition/impl/InternalPartitionImpl; '( )2com/hazelcast/internal/partition/InternalPartition+getOwnerReplicaOrNull5()Lcom/hazelcast/internal/partition/PartitionReplica; -. ,/isMaster 1 r2 isClusterFormedByOnlyLiteMembers 4 5triggerMasterToAssignPartitions 7] 8getOwnerOrNull()Lcom/hazelcast/nio/Address; :; ,< partitionId partition4Lcom/hazelcast/internal/partition/InternalPartition;getPartitionOwnerOrWaitjava/lang/InterruptedExceptionB  D isRunning F G6com/hazelcast/core/HazelcastInstanceNotActiveExceptionI J^com/hazelcast/nio/AddressLgetClusterService:()Lcom/hazelcast/internal/cluster/impl/ClusterServiceImpl; NO rP6com/hazelcast/internal/cluster/impl/ClusterServiceImplRgetClusterState&()Lcom/hazelcast/cluster/ClusterState; TU SV"com/hazelcast/cluster/ClusterStateXisMigrationAllowed Z Y[java/lang/IllegalStateException]java/lang/StringBuilder_ `^2Partitions can't be assigned since cluster-state: bappend-(Ljava/lang/String;)Ljava/lang/StringBuilder; de `f-(Ljava/lang/Object;)Ljava/lang/StringBuilder; dh `itoString()Ljava/lang/String; kl `m(Ljava/lang/String;)V [o ^p6com/hazelcast/partition/NoDataMemberInClusterExceptionrLPartitions can't be assigned since all nodes in the cluster are lite memberst sp java/lang/Threadysleep(J)V {| z} currentThread()Ljava/lang/Thread;  z interrupt ] z com/hazelcast/util/ExceptionUtilrethrow3(Ljava/lang/Throwable;)Ljava/lang/RuntimeException;  e Ljava/lang/InterruptedException; clusterState$Lcom/hazelcast/cluster/ClusterState;ownerisLocalMemberMaster  java/util/concurrent/locks/Lock ?] getShutdownRequestedMembers()Ljava/util/Set;  initializePartitionAssignments(Ljava/util/Set;)Z  publishPartitionRuntimeState ] createPartitionStateInternal $ unlock ] java/lang/ThrowableexcludedMembers,Ljava/util/Set;Ljava/util/Set;%shouldTriggerMasterToAssignPartitions  1Partitions can't be assigned since cluster-state=com/hazelcast/logging/ILoggerwarning o  VW getThisAddress ; requals(Ljava/lang/Object;)Z  M compareAndSet(ZZ)Z  fgetOperationServiceD()Lcom/hazelcast/spi/impl/operationservice/InternalOperationService;  hz:core:partitionService;com/hazelcast/internal/partition/operation/AssignPartitions ^@com/hazelcast/spi/impl/operationservice/InternalOperationServiceinvokeOnTargety(Ljava/lang/String;Lcom/hazelcast/spi/Operation;Lcom/hazelcast/nio/Address;)Lcom/hazelcast/spi/InternalCompletableFuture;  b(Lcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;Lcom/hazelcast/nio/Address;)V [ %com/hazelcast/core/ICompletableFutureandThen)(Lcom/hazelcast/core/ExecutionCallback;)V  executeWithDelay ] operationServiceBLcom/hazelcast/spi/impl/operationservice/InternalOperationService;futureaLcom/hazelcast/core/ICompletableFuture;'Lcom/hazelcast/core/ICompletableFuture;clusterService8Lcom/hazelcast/internal/cluster/impl/ClusterServiceImpl; masterAddressisJoined  SgetNodeExtension(()Lcom/hazelcast/instance/NodeExtension;  r$com/hazelcast/instance/NodeExtensionisStartCompleted  resetMasterTriggeredFlagset g f4com/hazelcast/cluster/memberselector/MemberSelectorsDATA_MEMBER_SELECTOR#Lcom/hazelcast/core/MemberSelector;   getMembers;(Lcom/hazelcast/core/MemberSelector;)Ljava/util/Collection;  Sjava/util/CollectionisEmpty  setInitialState8(Lcom/hazelcast/internal/partition/PartitionTableView;)V   partitionTable5Lcom/hazelcast/internal/partition/PartitionTableView;getMemberGroupsSize()I   getMaxAllowedBackupCount&Lcom/hazelcast/internal/metrics/Probe;namemaxBackupCount java/lang/Mathmin(II)I  max  updateMemberGroupSizeupdateMemberGroupsSize  ] ! memberAdded(Lcom/hazelcast/core/Member;)VAdding %fine 'o (getMasterAddress *; S+com/hazelcast/core/Member- localMember / .0triggerControlTask 2] 3memberLcom/hazelcast/core/Member; memberRemoved Removing 8onMemberRemove :$ ;cancelReplicaSyncRequestsTo =$ >isPartitionPromotionAllowed @ YA ZY C XY Ejava/lang/AssertionErrorG H^isThisNodeNewMaster formerMasteronClusterStateChange'(Lcom/hazelcast/cluster/ClusterState;)V:shouldTriggerRepartitioningWhenClusterStateAllowsMigration N OnewStateonClusterVersionChange"(Lcom/hazelcast/version/Version;)V'com/hazelcast/internal/cluster/VersionsTV3_12Lcom/hazelcast/version/Version; VW UXcom/hazelcast/version/VersionZ isEqualTo"(Lcom/hazelcast/version/Version;)Z \] [^getPartitionCount ` a;com/hazelcast/internal/partition/impl/InternalPartitionImplc getReplicas6()[Lcom/hazelcast/internal/partition/PartitionReplica; ef dg4[Lcom/hazelcast/internal/partition/PartitionReplica;i1com/hazelcast/internal/partition/PartitionReplicakmuuid ol lpjava/lang/Stringr sUnknown uuid: u RS w3Lcom/hazelcast/internal/partition/PartitionReplica;=Lcom/hazelcast/internal/partition/impl/InternalPartitionImpl;replicaMemberspid newVersioncreatePartitionState+isFetchMostRecentPartitionTableTaskRequired  getCompletedMigrationsCopy()Ljava/util/List;   getPartitions7()[Lcom/hazelcast/internal/partition/InternalPartition;  6com/hazelcast/internal/partition/PartitionRuntimeStategetPartitionStateVersion  O([Lcom/hazelcast/internal/partition/InternalPartition;Ljava/util/Collection;I)V [ getActiveMigration2()Lcom/hazelcast/internal/partition/MigrationInfo;  setActiveMigration3(Lcom/hazelcast/internal/partition/MigrationInfo;)V  completedMigrationsBLjava/util/List;Ljava/util/List;5[Lcom/hazelcast/internal/partition/InternalPartition;state8Lcom/hazelcast/internal/partition/PartitionRuntimeState;#createMigrationCommitPartitionStatej(Lcom/hazelcast/internal/partition/MigrationInfo;)Lcom/hazelcast/internal/partition/PartitionRuntimeState;getPartitionsCopy  getPartitionId  "applyMigrationp(Lcom/hazelcast/internal/partition/impl/InternalPartitionImpl;Lcom/hazelcast/internal/partition/MigrationInfo;)V  SUCCESS@Lcom/hazelcast/internal/partition/MigrationInfo$MigrationStatus;   setStatusr(Lcom/hazelcast/internal/partition/MigrationInfo$MigrationStatus;)Lcom/hazelcast/internal/partition/MigrationInfo;  "java/util/Listadd  committedVersion migrationInfo0Lcom/hazelcast/internal/partition/MigrationInfo;#createPromotionCommitPartitionStateP(Ljava/util/Collection;)Lcom/hazelcast/internal/partition/PartitionRuntimeState;(Ljava/util/Collection;)Lcom/hazelcast/internal/partition/PartitionRuntimeState;iterator()Ljava/util/Iterator;  java/util/IteratorhasNext  next()Ljava/lang/Object;  size  migrationInfosHLjava/util/Collection;Ljava/util/Collection;java/lang/ExceptionareMigrationTasksAllowed   isFineEnabled  %Publishing partition state, version:  getVersion  (I)Ljava/lang/StringBuilder; d `Bcom/hazelcast/internal/partition/operation/PartitionStateOperation<(Lcom/hazelcast/internal/partition/PartitionRuntimeState;Z)V [   r  S"com/hazelcast/spi/OperationService getAddress ; .send;(Lcom/hazelcast/spi/Operation;Lcom/hazelcast/nio/Address;)Z  finest(Ljava/lang/Throwable;)V  Ljava/lang/Exception;partitionStateopDLcom/hazelcast/internal/partition/operation/PartitionStateOperation;$Lcom/hazelcast/spi/OperationService;members3Ljava/util/Collection;sendPartitionRuntimeState(Lcom/hazelcast/nio/Address;)V"Sending partition state, version: , to  target"checkClusterPartitionRuntimeStates#Checking partition state, version:  Ncom/hazelcast/internal/partition/operation/PartitionStateVersionCheckOperation (I)V [  b(Lcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;Lcom/hazelcast/core/Member;)V [ Lcom/hazelcast/spi/Operation;;partitionStateVersionsyncPartitionRuntimeStateisHeldByCurrentThread  a#Sync'ing partition state, version: java/util/ArrayList  returnWithDeadline~(Ljava/util/Collection;JLjava/util/concurrent/TimeUnit;Lcom/hazelcast/util/FutureUtil$ExceptionHandler;)Ljava/util/Collection;  ! "java/lang/Boolean$ booleanValue & %'BLcom/hazelcast/spi/InternalCompletableFuture;-Lcom/hazelcast/spi/InternalCompletableFuture;resultLjava/lang/Boolean;futuresJLjava/util/Collection;>;results+Ljava/util/Collection;processPartitionRuntimeState;(Lcom/hazelcast/internal/partition/PartitionRuntimeState;)Z getMaster 3; 4IIgnoring received partition table, startup is not completed yet. Sender: 6partition table update8validateSenderIsMaster0(Lcom/hazelcast/nio/Address;Ljava/lang/String;)Z :; <getPartitionTable7()[[Lcom/hazelcast/internal/partition/PartitionReplica; >? @getCompletedMigrations()Ljava/util/Collection; BC DapplyNewPartitionTablej([[Lcom/hazelcast/internal/partition/PartitionReplica;ILjava/util/Collection;Lcom/hazelcast/nio/Address;)Z FG Hsender%This is the master node and received K from M. Ignoring incoming state! OisMemberMaster(Lcom/hazelcast/nio/Address;)Z QR S getMember@(Lcom/hazelcast/nio/Address;)Lcom/hazelcast/instance/MemberImpl; UV SW Received Y$ from an unknown member! => Sender: [! ]severe _o `7, but its sender doesn't seem to be master! => Sender: b/! (Ignore if master node has changed recently.)d messageType thisAddress([[Lcom/hazelcast/internal/partition/PartitionReplica;ILjava/util/Collection;Lcom/hazelcast/nio/Address;)ZtryLock#(JLjava/util/concurrent/TimeUnit;)Z ij k 7Already applied partition state change. Local version: n, Master version: p Master: r1Already applied partition state change. Version: t , Master: v,updatePartitionTableReplicasForCompatibility8([[Lcom/hazelcast/internal/partition/PartitionReplica;)V xy z,requestMemberListUpdateIfUnknownMembersFoundS(Lcom/hazelcast/nio/Address;[[Lcom/hazelcast/internal/partition/PartitionReplica;)V |} ~%updatePartitionsAndFinalizeMigrationsO([[Lcom/hazelcast/internal/partition/PartitionReplica;ILjava/util/Collection;)V  5[[Lcom/hazelcast/internal/partition/PartitionReplica;currentVersiongetClusterVersion!()Lcom/hazelcast/version/Version;  S isLessThan ] [address ; lfromP(Lcom/hazelcast/core/Member;)Lcom/hazelcast/internal/partition/PartitionReplica;  lInvalid replica: (Ljava/lang/Object;)V [ HixreplicareplicasversioncompatibilityModejava/util/HashSet ^ java/util/SetR(Lcom/hazelcast/nio/Address;Ljava/lang/String;)Lcom/hazelcast/instance/MemberImpl; U S isJoinAllowed  YisMissingMember ; S  isWarningEnabled  8Following unknown addresses are found in partition table `p sent from master[].: (Probably they have recently joined or left the cluster.) {   }Icom/hazelcast/internal/cluster/impl/operations/TriggerMemberListPublishOp ^ indexsLjava/lang/StringBuilder;unknownReplicasDLjava/util/Set;([[Lcom/hazelcast/internal/partition/PartitionReplica;ILjava/util/Collection;)VupdateReplicas8(I[Lcom/hazelcast/internal/partition/PartitionReplica;)V   setVersion  addCompletedMigration3(Lcom/hazelcast/internal/partition/MigrationInfo;)Z  #scheduleActiveMigrationFinalization  -Applied partition state update with version: retainCompletedMigrations(Ljava/util/Collection;)V  setInitialized  onPartitionStateChange ] added migrationapplyCompletedMigrations4(Ljava/util/Collection;Lcom/hazelcast/nio/Address;)Zf(Ljava/util/Collection;Lcom/hazelcast/nio/Address;)Zcompleted migrations^Cannot apply completed migrations until partition table is initialized. Completed migrations: getFinalPartitionVersion  "isFinestEnabled  1Already applied migration commit. Local version: , Commit version:  o getInitialPartitionVersion  "1Cannot apply migration commit! Expected version: , current version: , final version:  Migration: getPartitionVersionIncrement  "incrementVersion     getStatusB()Lcom/hazelcast/internal/partition/MigrationInfo$MigrationStatus;   "Applying completed migration ;Applied completed migrations with partition state version: appliedAllMigrations migrations+()[Lcom/hazelcast/spi/partition/IPartition;&com/hazelcast/spi/partition/IPartitionjava/lang/System arraycopy*(Ljava/lang/Object;ILjava/lang/Object;II)V  )[Lcom/hazelcast/spi/partition/IPartition;getInternalPartitions getPartition7(I)Lcom/hazelcast/internal/partition/InternalPartition;8(IZ)Lcom/hazelcast/internal/partition/InternalPartition; !# $ d/triggerOwnerAssignmentp onShutdown isLiteMember * r+getShutdownLatch'()Ljava/util/concurrent/CountDownLatch; -. /toMillis(J)J 12 3(JJ)J 5 6#java/util/concurrent/CountDownLatch8 +1Safe shutdown failed, master member is not known!;getLocalMember%()Lcom/hazelcast/instance/MemberImpl; => r?onShutdownRequest A$ BCcom/hazelcast/internal/partition/operation/ShutdownRequestOperationD E^ MILLISECONDS G Hawait Jj 9KSafe shutdown is interrupted!Minfo Oo Ptimeoutunitlatch%Ljava/util/concurrent/CountDownLatch; timeoutMillis awaitStepget X mY 9'(Ljava/lang/Object;Ljava/lang/Object;)Z \ m] i _ BonShutdownResponse countDown c] 9disMemberStateSafegetPartitionServiceState?()Lcom/hazelcast/internal/partition/impl/PartitionServiceState; gh i;com/hazelcast/internal/partition/impl/PartitionServiceStatekSAFE=Lcom/hazelcast/internal/partition/impl/PartitionServiceState; mn lohasOnGoingMigrationhasOnGoingMigrationLocal r shasOnGoingMigrationMaster(Ljava/util/logging/Level;)Z uv w q y)(Lcom/hazelcast/nio/serialization/Data;)I$com/hazelcast/nio/serialization/Data|getPartitionHash ~ }com/hazelcast/util/HashUtil hashToIndex  key&Lcom/hazelcast/nio/serialization/Data;(Ljava/lang/Object;)ItoData:(Ljava/lang/Object;)Lcom/hazelcast/nio/serialization/Data;   { Ljava/lang/Object;getPartitionMigrationTimeout()J!getPartitionReplicaVersionManagerC()Lcom/hazelcast/internal/partition/PartitionReplicaVersionManager;getMemberPartitionsMap()Ljava/util/Map;S()Ljava/util/Map;>;ceil(D)D  com/hazelcast/util/MapUtil createHashMap(I)Ljava/util/Map;   java/util/Map A &(Ljava/lang/Object;)Ljava/lang/Object; X put8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;  java/lang/IntegervalueOf(I)Ljava/lang/Integer;  ownedPartitions%Ljava/util/List; dataMembersdataMembersSizepartitionsPerMembermemberPartitionsQLjava/util/Map;>;Ljava/util/Map;getMemberPartitions-(Lcom/hazelcast/nio/Address;)Ljava/util/List;B(Lcom/hazelcast/nio/Address;)Ljava/util/List;java/util/LinkedList ^igetMemberPartitionsIfAssignedjava/util/Collections emptyList    reset ]   pauseMigration ] resumeMigration ]  shutdown#Shutting down the partition servicestop ]   terminategetMigrationQueueSize  getPartitionServiceProxy:()Lcom/hazelcast/internal/partition/PartitionServiceProxy;addMigrationListener:(Lcom/hazelcast/core/MigrationListener;)Ljava/lang/String;  listener&Lcom/hazelcast/core/MigrationListener;removeMigrationListener(Ljava/lang/String;)Z  registrationIdaddPartitionLostListenerC(Lcom/hazelcast/partition/PartitionLostListener;)Ljava/lang/String;  /Lcom/hazelcast/partition/PartitionLostListener;addLocalPartitionLostListener  removePartitionLostListener   dispatchEvent[(Lcom/hazelcast/partition/PartitionEvent;Lcom/hazelcast/partition/PartitionEventListener;)V.com/hazelcast/partition/PartitionEventListeneronEvent+(Lcom/hazelcast/partition/PartitionEvent;)V  partitionEvent(Lcom/hazelcast/partition/PartitionEvent;partitionEventListener0Lcom/hazelcast/partition/PartitionEventListener;addPartitionListener7(Lcom/hazelcast/internal/partition/PartitionListener;)VaddChildListener  4Lcom/hazelcast/internal/partition/PartitionListener;isPartitionOwner(I)ZisLocal   , onPartitionLost4(Lcom/hazelcast/spi/partition/IPartitionLostEvent;)V  event1Lcom/hazelcast/spi/partition/IPartitionLostEvent;setInternalMigrationListenerD(Lcom/hazelcast/internal/partition/impl/InternalMigrationListener;)V  ALcom/hazelcast/internal/partition/impl/InternalMigrationListener;getInternalMigrationListenerC()Lcom/hazelcast/internal/partition/impl/InternalMigrationListener;  resetInternalMigrationListener ] getOngoingReplicaSyncRequestsS()Ljava/util/List; ! #getScheduledReplicaSyncRequests()Ljava/util/List;>; % 'getPartitionStateManager?()Lcom/hazelcast/internal/partition/impl/PartitionStateManager;getMigrationManager:()Lcom/hazelcast/internal/partition/impl/MigrationManager;getReplicaManagerA()Lcom/hazelcast/internal/partition/impl/PartitionReplicaManager;getPartitionReplicaStateCheckerF()Lcom/hazelcast/internal/partition/impl/PartitionReplicaStateChecker;getPartitionEventManager?()Lcom/hazelcast/internal/partition/impl/PartitionEventManager;3scheduleFetchMostRecentPartitionTableTaskIfRequired(Lcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;Lcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl$1;)V [4 5schedule<(Lcom/hazelcast/internal/partition/impl/MigrationRunnable;)V 78 9 replaceMember9(Lcom/hazelcast/core/Member;Lcom/hazelcast/core/Member;)V9(Lcom/hazelcast/core/Member;Lcom/hazelcast/core/Member;)I ;= > oldMember newMembercreatePartitionTableView7()Lcom/hazelcast/internal/partition/PartitionTableView; >C DgetSize F SGmastercommitMigrationOnDestinationN(Lcom/hazelcast/internal/partition/MigrationInfo;Lcom/hazelcast/nio/Address;)Zmigration commitL+Already applied migration commit. Version: N,Invalid migration commit! Expected version: P "Committed migration: S, Active migration: U2Could not add completed migration on destination: WfinalizeMigration Y Z Committed \. on destination with partition state version: ^initialVersion finalVersionactiveMigration#InternalPartitionService {version: c, migrationQ: e  g(J)Ljava/lang/StringBuilder; di `j}l,(IZ)Lcom/hazelcast/spi/partition/IPartition;+(I)Lcom/hazelcast/spi/partition/IPartition; !" p'(Ljava/lang/Object;Ljava/lang/Object;)V&com/hazelcast/partition/PartitionEvents  u access$000 ] xx0 access$100e(Lcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;)Lcom/hazelcast/logging/ILogger; access$300c(Lcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;)Lcom/hazelcast/instance/Node; access$402H(Lcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;Z)Zx1 access$500(Lcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;)Lcom/hazelcast/internal/partition/impl/PartitionStateManager; access$600m(Lcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;)Lcom/hazelcast/spi/impl/NodeEngineImpl; access$700g(Lcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;)Ljava/util/concurrent/locks/Lock; access$800(Lcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;[[Lcom/hazelcast/internal/partition/PartitionReplica;ILjava/util/Collection;Lcom/hazelcast/nio/Address;)Zx2x3x4 access$900~(Lcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;)Lcom/hazelcast/internal/partition/impl/MigrationManager;java/lang/ClassdesiredAssertionStatus   ConstantValue SignatureCodeLineNumberTableLocalVariableTable StackMapTableLocalVariableTypeTableRuntimeVisibleAnnotations InnerClasses SourceFile! $%&'(*+%&,%-./02/356789:;%</=>?@ABCDEFGHIJKLMNOPQRSTUBVWBXYZYc[\ #*_*aYbd*fYik*mYnp+vM*,|*+*+*+*Y+**Y+***Y+**d*Y+**Y+**Y+*Y*3Y*ĵ***̸е*,նٵ*Y***N-*-*-*-*j&+6;CMZk| "*##56+.H*v>>+:Y** W**"7>G4HH7H:%,=*"*&W**M,0*3*6*9,= &, +26 ==>%%?@A(x*EYMo*H JYK*QWN-\^Y`Yacg-jnq*6sYuvw~:,\beCM-YHC > '.JQ\begmsv4g 'Lxx>%qW#$S* *9*d*"*L*+**L*d+M*d,<G )O6    (37 <E GQ(S (7][**QL+WM,\!*`Yag,jn*N--**kę7*:ʻY-:Y*-ֹ*ƶ߱1SYM?F9: ?!Q"R%^&g't({):<>g+{~?TW { v.*QL*"+* ,S@ ?@.&]7 *k DE  4 M*QL+ HI **d*+ *dM*d, ] V XZ[Z'[)\**   2*` :*df  s]6*" jk #$u*`Ya&g+jn)*d**Q,+1 *"**" *4*dM*d,&\h DK 6 op&r4s=tDvKwUx\|e}h|r}t~uu567$*`Ya9g+jn)*d*+<*+?*M**Q,*QWN-\ -BX*"*36*,6D*F HYI*F *4*d:*d&(bMY&@ .K V&.6;ITbir>rE1Y+JY;|KWTc56LMX+\*"**d*"*P *4*dM*d,$?K  #K >$28?HKUWXXQRS +Y_*d*" *d=*bk**N-h::66C2:.nqt ^Y`Yavgjnq*+x*d: *d '? '"[djjl*[S V &'1:@Z_bp>Z35y:Y?z@S{i)p|%}W~$I**   $f*d*"L*d+*L*MY,+*N-*-:*d:*d X LXXZX w:  (0>ILUXc*(00(>f (0g *d*"M*d,*M*N+6-2d:++W,+W*`6Y-,:*d:*d v jvvxv  UJ   (06?EMU]j sv  H(N0F6@>%?7?z]% (N *d*"M*d,*M*N+:2":6-2d:W*+h`6Y-,:*d:*d  " 8'N + (0 N!U"^#e$n%q()+)+,RU>%^?zN (q0i%(q]*"**ך*L+*#*`Yaܶg+߶n)Y+M*N*::;.:1"-,W:*J  +&1. Z5 7 :;>@C D$E%H1IQL[McNoOPRUSTWXH )56 [`cXoL oL3*D*" HYID*ך HYI*MD, HYI*-*`Yag,߶g+jn)*NY,:-+W 52 [\^ _5a:bLdXehijk4W:i]*"**ך*<* *`Ya gn)*M*N-:K.:12 Y:,:Y* -NJn o rsvx{ |,}IQ\zH%z956 %Qf\[\[  VD*da HYID*" HYID*3 HYI*LD+ HYI*#*`Yag+߶n)*M*NY-:-:E.:1,Y+:,:Ww *Ҹ#::%:(; +)H#f3KPbn&(GOQTf  *356G +,VP-A/* )-.A/012R+5M*"*`Ya7g,jn*,9=*+A++E,I 3M & 13>@JN RRMJW:;@*N-*:-+2*`YaLg,gNg+jPgn*+Tp*+X3*`YaZg,g\g+j^gna0*`YaZg,gcg+jegn JME,* HJR`*JWf(gWFG,*dw l :*m6Q*6*`Yaogqgsgjn)6*dG*,*`Yaugwgjn)6*d*+{*+*+-6*d:*dC!r~&BC M:!Mn ! * 0<or!{~!!!"H*% }%JW hxy *QM,N-Y66*+2:W6I28n2qt'2:,X:    SY:66  F 2: D3 .n qt HY`Yag jn ?R S[j*M.  jCS[V'( )+",(--.8/@0C2T3^4f5k9n;x.?@?+Ep ^Wf56 0N%6y (i>%  WY|} K*N-W:Y:,:66i2: 6  R  2:  =*  q&-  q  W *r`Yg+jggg:: l:gjWgW*n*Q,:(**ȻYWG " MSYjl/ F`&5vHIJL0M:NAOFPIRbSkTyUMLZ[\]^_`abcdg i4kJnz ABy 3V% 0Yi yG *WKKJWK C=4 46*+2:*τ*-:+":*6 *٧* *`Ya۶gn)*-**.(B{ |}{#+ITYbeqR i >%TYI %  *,=*d*"9* *`Yag+jn)>*d>+:O":*m6H**`Yaggsg,jnL*`Yagggwg,jn)>*6D% HY`Yagjn* B*!*`Yagjn)**:*٧*&*`Yag*mn)*+*6*d: *d KV C ; m"R2@ M."M*   ,IKTVXv!,T`kwR?z4%,Yv=XYJW W*L*+*++ 2* !";*%>%!#~**N-& *EW-d *>%'Y (z)j *Q*,*0:*:-47377*::  *<* **@CEYF WILe7 : *NQ;VCWCC=  9M9Cb !*1;DIUWft    \ DWW  R/S!TU*1V/;W/-.1*pZ9L+#9Y[L*p+^*pZ9L+/9 $/1 &TUA$-*d`#*+a*dM*d,  `  "$% $*%,'--56b]p"*pZ9LD+ HYI+e9* +,!-" TUf H*jp@1 q _!*t**̶x@67 6 !r 2*z< {B+*AA **+F `/*K /*ۭO /*T o*QL+=*n>:6*G*::Y:WW)@ 9M6 YZ[+]1^=_EaSbXcbdnf{^hRE6WS(4M>%vo%+Y%1S S(v1S5YM>*$*E:+,W,  "mnop"q-n3t4W )%55W- -Y*"ư*+Ȱy z|W]<*d*F****dL*d+ #/o *  #,/9; <]6*б  ]6*ӱ   2*Ԭ gX*׹**۱ Y3 *߅  /* = *+ = *+ (= *+ = *+ = *+ (J,+  **d*+*dM*d, ]  ')**   R**M,   >% ?@2*m A *+  A *+  2* ]6*   !2*$ "%2*( &)*/* +,/* -./* /0/*  12/*  /*F 3 F*d*F *Y*6:<*d<*dM*d, ":-/:-L.   " +-/ 8: D! F;<,*d*+,?W*dN*d- _ % ')*))*++ ,,@6,A6BCz(*d*EL*d+M*d, \/ 1313&4 ( 6 **TB  QR=+*M*QN,-H-,M+,+-,MS@MNP QTU$Y*==W 2IW*JKd *d*,M=>*d*m>+6+6E***`YaOgwg,jn)6*dP*5*`Yagqgsg,jn)6*d4^Y`YaQggwg,jnq*:D3+R*HY`YaTg+jVgjn*+*:*+6D$HY`YaXg+jn+*+W*+[*+*`Ya]g+j_gn)6 *d : *d  !q}2 !LC6>"=dT"M&^ `aa!d)e/f5h;iGjnlqzl}nopssuvz{F~S]\ )%/`%5a%bS?z]YJWkl]+`Yadg*fg*hkmgnyz*y +A!n1*%t A!o0*qt Ar7 *+t,vt  w/*yu z{|/*u z}~/*u z;*ZFuzY/*u z/*u z/*du z\ *+-Iu4 z  %  W/*u z]4D @t2 "#@