4Ocom/hazelcast/cp/internal/MetadataRaftGroupManager$DiscoverInitialCPMembersTaskjava/lang/Objectjava/lang/RunnableMetadataRaftGroupManager.javaEcom/hazelcast/cp/internal/MetadataRaftGroupManager$DiscoveryTaskState2com/hazelcast/cp/internal/MetadataRaftGroupManager DiscoveryTaskStateDiscoverInitialCPMembersTaskEcom/hazelcast/cp/internal/MetadataRaftGroupManager$CPMemberComparatorCPMemberComparator4com/hazelcast/cp/internal/MetadataRaftGroupManager$1.com/hazelcast/util/FutureUtil$ExceptionHandlercom/hazelcast/util/FutureUtilExceptionHandler latestMembersLjava/util/Collection;3Ljava/util/Collection;terminateOnDiscoveryFailureZlastLoggingTimeJ cancelledstateGLcom/hazelcast/cp/internal/MetadataRaftGroupManager$DiscoveryTaskState;$assertionsDisabledthis$04Lcom/hazelcast/cp/internal/MetadataRaftGroupManager;8(Lcom/hazelcast/cp/internal/MetadataRaftGroupManager;Z)V #$ '()V %) *java/util/Collections,emptySet()Ljava/util/Set; ./ -0  2  4 SCHEDULED 6! 7 ! 9thisQLcom/hazelcast/cp/internal/MetadataRaftGroupManager$DiscoverInitialCPMembersTask;runRUNNING >! ?doRun A) B COMPLETED D! Ejava/lang/ThrowableGshouldRescheduleOrSkip()Z IJ K access$200T(Lcom/hazelcast/cp/internal/MetadataRaftGroupManager;)Lcom/hazelcast/spi/NodeEngine; MN Ocom/hazelcast/spi/NodeEngineQgetClusterService1()Lcom/hazelcast/internal/cluster/ClusterService; ST RU4com/hazelcast/cluster/memberselector/MemberSelectorsWDATA_MEMBER_SELECTOR#Lcom/hazelcast/core/MemberSelector; YZ X[-com/hazelcast/internal/cluster/ClusterService] getMembers;(Lcom/hazelcast/core/MemberSelector;)Ljava/util/Collection; _` ^ajava/util/Collectionciterator()Ljava/util/Iterator; ef dgjava/util/IteratorihasNext kJ jlnext()Ljava/lang/Object; no jpcom/hazelcast/core/Memberrcontains(Ljava/lang/Object;)Z tu dv access$300U(Lcom/hazelcast/cp/internal/MetadataRaftGroupManager;)Lcom/hazelcast/logging/ILogger; xy zjava/lang/StringBuilder| }*append-(Ljava/lang/Object;)Ljava/lang/StringBuilder;  }; left the cluster while CP subsystem discovery in progress!-(Ljava/lang/String;)Ljava/lang/StringBuilder;  }toString()Ljava/lang/String; }com/hazelcast/logging/ILoggersevere(Ljava/lang/String;)V handleDiscoveryFailure ) %rescheduleIfCPMemberCountNotSatisfied(Ljava/util/Collection;)Z &com/hazelcast/cp/internal/CPMemberInfogetLocalMember()Lcom/hazelcast/core/Member; R(Lcom/hazelcast/core/Member;)V % getDiscoveredCPMembers((Ljava/util/Collection;)Ljava/util/List; completeDiscoveryIfNotCPMember;(Ljava/util/List;Lcom/hazelcast/cp/internal/CPMemberInfo;)Z java/util/ListgetMetadataGroupId)()Lcom/hazelcast/cp/internal/RaftGroupId; %com/hazelcast/cp/internal/RaftGroupIdseed()J  access$400O(Lcom/hazelcast/cp/internal/MetadataRaftGroupManager;JJLjava/util/Collection;)V commitMetadataRaftGroupInit;(Lcom/hazelcast/cp/internal/CPMemberInfo;Ljava/util/List;)Z "CP subsystem is initialized with: info  access$500a(Lcom/hazelcast/cp/internal/MetadataRaftGroupManager;)Ljava/util/concurrent/atomic/AtomicBoolean; )java/util/concurrent/atomic/AtomicBooleanset(Z)V broadcastActiveCPMembers )  access$6007(Lcom/hazelcast/cp/internal/MetadataRaftGroupManager;)V memberLcom/hazelcast/core/Member;memberslocalMemberCandidate(Lcom/hazelcast/cp/internal/CPMemberInfo;discoveredCPMembers:Ljava/util/List;Ljava/util/List;  isJoined J ^ scheduleSelf ) getClusterVersion!()Lcom/hazelcast/version/Version; ^'com/hazelcast/internal/cluster/VersionsV3_12Lcom/hazelcast/version/Version; com/hazelcast/version/Version isLessThan"(Lcom/hazelcast/version/Version;)Z RCannot start initial CP members discovery since cluster version is less than 3.12.fine isDiscoveryCompleted J 6(Ljava/util/Collection;)Zsize()I d access$700a(Lcom/hazelcast/cp/internal/MetadataRaftGroupManager;)Lcom/hazelcast/config/cp/CPSubsystemConfig;  )com/hazelcast/config/cp/CPSubsystemConfiggetCPMemberCount  com/hazelcast/util/Clock currentTimeMillis     CP Subsystem is waiting for (I)Ljava/lang/StringBuilder;  }4 members to join the cluster. Current member count: nowgetExecutionService&()Lcom/hazelcast/spi/ExecutionService;  Rjava/util/concurrent/TimeUnit! MILLISECONDSLjava/util/concurrent/TimeUnit; #$ "%"com/hazelcast/spi/ExecutionService'schedule\(Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture; )* (+o(Ljava/util/Collection;)Ljava/util/List; " .java/lang/AssertionError0 1*java/util/ArrayList3(Ljava/util/Collection;)V %5 46subList(II)Ljava/util/List; 89 4:(I)V %< 4= gadd @u A9(Lcom/hazelcast/cp/internal/MetadataRaftGroupManager$1;)V %C Dsort)(Ljava/util/List;Ljava/util/Comparator;)V FG -H memberList-Ljava/util/List; cpMemberse(Ljava/util/List;Lcom/hazelcast/cp/internal/CPMemberInfo;)Z v1I am not a CP member! I'll serve as an AP member.OlocalCPMemberCandidatee(Lcom/hazelcast/cp/internal/CPMemberInfo;Ljava/util/List;)Zjava/lang/ExceptionS getGroupSize U V : access$900](Lcom/hazelcast/cp/internal/MetadataRaftGroupManager;)Lcom/hazelcast/cp/internal/RaftService; YZ [%com/hazelcast/cp/internal/RaftService]createRaftNodeP(Lcom/hazelcast/cp/CPGroupId;Ljava/util/Collection;Lcom/hazelcast/cp/CPMember;)V _` ^aAcom/hazelcast/cp/internal/raftop/metadata/InitMetadataRaftGroupOpc<(Lcom/hazelcast/cp/internal/CPMemberInfo;Ljava/util/List;J)V %e dfgetInvocationManager3()Lcom/hazelcast/cp/internal/RaftInvocationManager; hi ^j/com/hazelcast/cp/internal/RaftInvocationManagerlinvokem(Lcom/hazelcast/cp/CPGroupId;Lcom/hazelcast/cp/internal/RaftOp;)Lcom/hazelcast/spi/InternalCompletableFuture; no mp+com/hazelcast/spi/InternalCompletableFuturerget to su access$1000c(Lcom/hazelcast/cp/internal/MetadataRaftGroupManager;)Ljava/util/concurrent/atomic/AtomicReference; wx y+java/util/concurrent/atomic/AtomicReference{(Ljava/lang/Object;)V } |~8Could not initialize METADATA CP group with CP members: *(Ljava/lang/String;Ljava/lang/Throwable;)V  destroyRaftNode(Lcom/hazelcast/cp/CPGroupId;)V  ^ 4*com/hazelcast/util/RandomPickergetInt(II)I  ;com/hazelcast/cp/internal/raftop/metadata/GetRaftGroupIdsOp *<SECONDS $ "IGNORE_ALL_EXCEPTIONS0Lcom/hazelcast/util/FutureUtil$ExceptionHandler;  waitWithDeadlinei(Ljava/util/Collection;JLjava/util/concurrent/TimeUnit;Lcom/hazelcast/util/FutureUtil$ExceptionHandler;)V  op"Lcom/hazelcast/cp/internal/RaftOp;eLjava/lang/Exception;iIjmetadataMembersmetadataGroupId'Lcom/hazelcast/cp/internal/RaftGroupId;futures?Ljava/util/List;.Terminating because of CP discovery failure...warning   terminateNode ) $Cancelling CP subsystem discovery...%com/hazelcast/spi/impl/NodeEngineImplgetNode()Lcom/hazelcast/instance/Node;  com/hazelcast/instance/Nodeshutdown  cancelAndAwaitCompletionjava/lang/InterruptedExceptiondjava/lang/Threadsleep(J)V   currentThread()Ljava/lang/Thread;   interrupt )  Ljava/lang/InterruptedException;java/lang/ClassdesiredAssertionStatus J  SignatureCodeLineNumberTableLocalVariableTable StackMapTableLocalVariableTypeTable InnerClasses SourceFile BB !"#$ %&a*+(*+*13*5*8: ;<=)4*@:*C*:@!*F:L*:@ *F:+ _HH" *13 4;<A)*L*(PV\bL*3hM,m>,qsN+-w'*({}Y~-**+3*+Y*(PM*+N*-,*(*( -*,-**({}Y~-*(*(*(ӱdj@ # f  :Dcghkpxy!"&()*-./014:.;<jddIJY*ݙ*(PV **(PV*({**( -* 89 ?@!A#E=FKGOHQK Y;<i+*( WA *e@* *({}Y~*( +* a* OPQ$R)SQT\SaWeXgZ Pi;<i i)W!*8:*(P*&,W^_` a !;<5/+*( 1Y24Y+7*( ;M4Y*( >N,?:m"qs:-YBW-YEI-!0j("d!e8fJghjxk{mn4h;<8QJJ?L 8QJKJ?L-(+,N*({P*(&r st$u&x (;<(L(Q (LM,*(WXN*(:-+N*(\-+bdY+,g:*(\kqvW*(z+5:*({}Y~-*(\4Y:66'*(\kYqBWehT3tT1*J|}%3CZehjf C"j03+;<QF FR)8*5*({**({*(̱,7 8;<)@*(P  ;<)#**:Fĸ˧L϶ҧR "" #;<)4 ٚ/ @* @