4 dcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl$FetchMostRecentPartitionTableTaskjava/lang/Object7com/hazelcast/internal/partition/impl/MigrationRunnable!InternalPartitionServiceImpl.javaBcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl!FetchMostRecentPartitionTableTaskcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl$FetchMostRecentPartitionTableTask$PartitionThreadBarrierTask PartitionThreadBarrierTaskjava/util/Map$Entry java/util/MapEntryDcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl$1>com/hazelcast/internal/partition/MigrationInfo$MigrationStatus.com/hazelcast/internal/partition/MigrationInfoMigrationStatus thisAddressLcom/hazelcast/nio/Address; maxVersionInewState8Lcom/hazelcast/internal/partition/PartitionRuntimeState;this$0DLcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;G(Lcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;)V ! $()V "& ' access$300c(Lcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;)Lcom/hazelcast/instance/Node; )* +com/hazelcast/instance/Node-getThisAddress()Lcom/hazelcast/nio/Address; /0 .1  3thisfLcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl$FetchMostRecentPartitionTableTask;rungetClusterService:()Lcom/hazelcast/internal/cluster/impl/ClusterServiceImpl; 89 .:6com/hazelcast/internal/cluster/impl/ClusterServiceImpl<getClusterState&()Lcom/hazelcast/cluster/ClusterState; >? =@"com/hazelcast/cluster/ClusterStateBisMigrationAllowed()Z DE CFisPartitionPromotionAllowed HE CI access$100e(Lcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;)Lcom/hazelcast/logging/ILogger; KL MdNo need to fetch the latest partition table. Cluster state does not allow to modify partition table.Ocom/hazelcast/logging/ILoggerQfine(Ljava/lang/String;)V ST RU access$402H(Lcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;Z)Z WX YsyncWithPartitionThreads [& \ access$500(Lcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;)Lcom/hazelcast/internal/partition/impl/PartitionStateManager; ^_ `;com/hazelcast/internal/partition/impl/PartitionStateManagerb getVersion()I de cf  hjava/lang/StringBuilderj k'2Fetching most recent partition table! my version: mappend-(Ljava/lang/String;)Ljava/lang/StringBuilder; op kq(I)Ljava/lang/StringBuilder; os kttoString()Ljava/lang/String; vw kxinfo zT R{java/util/HashSet} ~'collectAndProcessResults/(Ljava/util/Collection;Ljava/util/Collection;)V %Most recent partition table version: processNewState publishPartitionRuntimeState &  clusterState$Lcom/hazelcast/cluster/ClusterState;allCompletedMigrationsHLjava/util/Collection;Ljava/util/Collection;allActiveMigrationsfetchPartitionState:(Lcom/hazelcast/core/Member;)Ljava/util/concurrent/Future;t(Lcom/hazelcast/core/Member;)Ljava/util/concurrent/Future; access$600m(Lcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;)Lcom/hazelcast/spi/impl/NodeEngineImpl; %com/hazelcast/spi/impl/NodeEngineImplgetOperationServiceD()Lcom/hazelcast/spi/impl/operationservice/InternalOperationService; hz:core:partitionServiceGcom/hazelcast/internal/partition/operation/FetchPartitionStateOperation 'com/hazelcast/core/Member getAddress 0 @com/hazelcast/spi/impl/operationservice/InternalOperationServiceinvokeOnTargety(Ljava/lang/String;Lcom/hazelcast/spi/Operation;Lcom/hazelcast/nio/Address;)Lcom/hazelcast/spi/InternalCompletableFuture; mLcom/hazelcast/core/Member;(Ljava/util/Collection;Ljava/util/Collection;)VclusterService8Lcom/hazelcast/internal/cluster/impl/ClusterServiceImpl; .4com/hazelcast/cluster/memberselector/MemberSelectorsNON_LOCAL_MEMBER_SELECTOR#Lcom/hazelcast/core/MemberSelector;  getMembers;(Lcom/hazelcast/core/MemberSelector;)Ljava/util/Collection; =java/util/HashMap 'java/util/Collectioniterator()Ljava/util/Iterator; java/util/IteratorhasNext E next()Ljava/lang/Object; put8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; isEmpty E entrySet()Ljava/util/Set;  java/util/Set collectNextPartitionStateN(Ljava/util/Iterator;)Lcom/hazelcast/internal/partition/PartitionRuntimeState; 6com/hazelcast/internal/partition/PartitionRuntimeState f  getCompletedMigrations()Ljava/util/Collection; addAll(Ljava/util/Collection;)Z getActiveMigration2()Lcom/hazelcast/internal/partition/MigrationInfo; add(Ljava/lang/Object;)Z futureWLjava/util/concurrent/Future;Ljava/util/concurrent/Future;memberstateiterLjava/util/Iterator;>;>;Ljava/util/Iterator;members3Ljava/util/Collection;futuresLjava/util/Map;>;Ljava/util/Map;(Ljava/util/Iterator;>;>;)Lcom/hazelcast/internal/partition/PartitionRuntimeState;java/lang/InterruptedException %java/util/concurrent/TimeoutException java/lang/Exception getKey  getValue  java/util/concurrent/Futurejava/util/concurrent/TimeUnitSECONDSLjava/util/concurrent/TimeUnit;  get4(JLjava/util/concurrent/TimeUnit;)Ljava/lang/Object;  !#Received NULL partition state from #-(Ljava/lang/Object;)Ljava/lang/StringBuilder; o% k&"Received partition state version: ( from *remove ,& -1FetchMostRecentPartitionTableTask is interrupted./java/lang/Thread1 currentThread()Ljava/lang/Thread; 34 25 interrupt 7& 28setValue&(Ljava/lang/Object;)Ljava/lang/Object; :; <java/util/logging/Level>SEVERELjava/util/logging/Level; @A ?B&com/hazelcast/core/MemberLeftExceptionDgetCause()Ljava/lang/Throwable; FG H4com/hazelcast/spi/exception/TargetNotMemberExceptionJFINE LA ?M%Failed to fetch partition table from OlogC(Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Throwable;)V QR RSjava/lang/ThrowableUe Ljava/lang/InterruptedException;'Ljava/util/concurrent/TimeoutException;levelLjava/lang/Exception;Ljava/util/Map$Entry;>;Ljava/util/Map$Entry;collectedStateZ access$700g(Lcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;)Ljava/util/concurrent/locks/Lock; `a bjava/util/concurrent/locks/Lockdlock f& egprocessMigrations i jgetClusterVersion!()Lcom/hazelcast/version/Version; lm =n'com/hazelcast/internal/cluster/VersionspV3_12Lcom/hazelcast/version/Version; rs qtcom/hazelcast/version/VersionvisGreaterOrEqual"(Lcom/hazelcast/version/Version;)Z xy wzgetPartitionStateVersion |e }java/lang/Mathmax(II)I  getFinalPartitionVersion e >Applying the most recent of partition state with new version: getPartitionTable7()[[Lcom/hazelcast/internal/partition/PartitionReplica;   access$800(Lcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;[[Lcom/hazelcast/internal/partition/PartitionReplica;ILjava/util/Collection;Lcom/hazelcast/nio/Address;)Z   isInitialized E c access$900~(Lcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;)Lcom/hazelcast/internal/partition/impl/MigrationManager;  6com/hazelcast/internal/partition/impl/MigrationManageraddCompletedMigration3(Lcom/hazelcast/internal/partition/MigrationInfo;)Z  getPartitionVersionIncrement e incrementVersion(I)V  cisFinestEnabled E RMScheduling migration finalization after finding most recent partition table: finest T R#scheduleActiveMigrationFinalization3(Lcom/hazelcast/internal/partition/MigrationInfo;)V   & cgetNodeExtension(()Lcom/hazelcast/instance/NodeExtension;  .$com/hazelcast/instance/NodeExtensiononPartitionStateChange & unlock & e migration0Lcom/hazelcast/internal/partition/MigrationInfo; migrationInfoversionversion312plusgetCompletedMigrationsCopy()Ljava/util/List;   FAILED@Lcom/hazelcast/internal/partition/MigrationInfo$MigrationStatus;   setStatusr(Lcom/hazelcast/internal/partition/MigrationInfo$MigrationStatus;)Lcom/hazelcast/internal/partition/MigrationInfo;  setPartitionVersionIncrement3(I)Lcom/hazelcast/internal/partition/MigrationInfo;  Marked active migration  as activeMigrationAcom/hazelcast/spi/impl/operationservice/impl/OperationServiceImplgetOperationExecutor>()Lcom/hazelcast/spi/impl/operationexecutor/OperationExecutor;  #java/util/concurrent/CountDownLatch:com/hazelcast/spi/impl/operationexecutor/OperationExecutorgetPartitionThreadCount e  " (Lcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl$FetchMostRecentPartitionTableTask;Ljava/util/concurrent/CountDownLatch;Lcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl$1;)V " executeOnPartitionThreads(Ljava/lang/Runnable;)V  await & warning(Ljava/lang/Throwable;)V  RoperationServiceCLcom/hazelcast/spi/impl/operationservice/impl/OperationServiceImpl; opExecutor*348Fhpx~*56p>x6p>x6[*%Y+56 *%,NY:-:&:*:Wl:Q*:*i**i+W,W%",V8@LOYgqy~\ @ 8yCgX56>@ gX 1 C+M,N,:6":&*%NkYl$r-'yV1*%NkYl)ru+r-'yV: +.:*%N0V69+.:6,*-ӹ=Wm+.d:C:EIKN:*%NkYlPr-'yT+.: +." " ""111#1131t \- d ^?1V V! "49\   #( 18 > A p 4hWXWY<ZAAW[C56C 9]/$"!^_ C 9\$ *%ch*+,k*%,;oN-u{6***i*%~i4+:":**ii*Yi`i*%NkYlr*iuy|*%**i+*4W*%a+:q:*%S*%a*%N$*%NkYlr'y*%*%a*%,*%ZW*%c:*%c o~~~: Ow(G8/ Vz  )0 B"G#e&u'x*+,-./1356>9J;M=W>f@oB{C~BCDHe_ Os)F_56 i9+*%ȹW*%,*%ɹW,N-_-:ͶW`W+0*%NkYl׶r'ٶrͶ'y|/a* IJK/NJOSP`QkRTU*JN56 [&O*%L+MY,N, Y*--:*%N69158 8 * XYZ![1]5a8^:_H`Nb4:WXO56A<!."D*+ 56! *    @