42com/hazelcast/internal/cluster/impl/AbstractJoinerjava/lang/Objectcom/hazelcast/cluster/JoinerAbstractJoiner.java4com/hazelcast/internal/cluster/impl/AbstractJoiner$1.com/hazelcast/util/FutureUtil$ExceptionHandler com/hazelcast/util/FutureUtil ExceptionHandlerTcom/hazelcast/internal/cluster/impl/SplitBrainJoinMessage$SplitBrainMergeCheckResult9com/hazelcast/internal/cluster/impl/SplitBrainJoinMessageSplitBrainMergeCheckResultJOIN_TRY_COUNTI!SPLIT_BRAIN_MERGE_TIMEOUT_SECONDS&SPLIT_BRAIN_JOIN_CHECK_TIMEOUT_SECONDS MIN_WAIT_BEFORE_JOIN_SECONDSJ SPLIT_BRAIN_SLEEP_TIME_MILLISSPLIT_BRAIN_CONN_TIMEOUT_MILLISconfigLcom/hazelcast/config/Config;nodeLcom/hazelcast/instance/Node;clusterService8Lcom/hazelcast/internal/cluster/impl/ClusterServiceImpl;loggerLcom/hazelcast/logging/ILogger;blacklistedAddresses$Ljava/util/concurrent/ConcurrentMap;TLjava/util/concurrent/ConcurrentMap;clusterJoinManager8Lcom/hazelcast/internal/cluster/impl/ClusterJoinManager; joinStartTime(Ljava/util/concurrent/atomic/AtomicLong;tryCount+Ljava/util/concurrent/atomic/AtomicInteger;mergeNextRunDelayMs targetAddressLcom/hazelcast/nio/Address;splitBrainMergeExceptionHandler0Lcom/hazelcast/util/FutureUtil$ExceptionHandler; (Lcom/hazelcast/instance/Node;)V()V 9; <&java/util/concurrent/ConcurrentHashMap> ?< +, A&java/util/concurrent/atomic/AtomicLongCcom/hazelcast/util/ClockEcurrentTimeMillis()J GH FI(J)V 9K DL 01 N)java/util/concurrent/atomic/AtomicIntegerP(I)V 9R QS 23 U7(Lcom/hazelcast/internal/cluster/impl/AbstractJoiner;)V 9W X 78 Z %& \com/hazelcast/instance/Node^loggingService*Lcom/hazelcast/logging/LoggingServiceImpl; `a _bgetClass()Ljava/lang/Class; de f(com/hazelcast/logging/LoggingServiceImplh getLogger2(Ljava/lang/Class;)Lcom/hazelcast/logging/ILogger; jk il )* nFLcom/hazelcast/internal/dynamicconfig/DynamicConfigurationAwareConfig; #p _q #$ sgetClusterService:()Lcom/hazelcast/internal/cluster/impl/ClusterServiceImpl; uv _w '( y6com/hazelcast/internal/cluster/impl/ClusterServiceImpl{getClusterJoinManager:()Lcom/hazelcast/internal/cluster/impl/ClusterJoinManager; }~ | ./  getProperties4()Lcom/hazelcast/spi/properties/HazelcastProperties; _*com/hazelcast/spi/properties/GroupPropertyMERGE_NEXT_RUN_DELAY_SECONDS0Lcom/hazelcast/spi/properties/HazelcastProperty; 0com/hazelcast/spi/properties/HazelcastProperties getMillis3(Lcom/hazelcast/spi/properties/HazelcastProperty;)J 4 this4Lcom/hazelcast/internal/cluster/impl/AbstractJoiner; getStartTimeget H DsetTargetAddress(Lcom/hazelcast/nio/Address;)V 56  blacklist(Lcom/hazelcast/nio/Address;Z)Vjava/lang/StringBuilder <append-(Ljava/lang/Object;)Ljava/lang/StringBuilder;  is added to the blacklist.-(Ljava/lang/String;)Ljava/lang/StringBuilder; toString()Ljava/lang/String; com/hazelcast/logging/ILoggerinfo(Ljava/lang/String;)V java/lang/BooleanvalueOf(Z)Ljava/lang/Boolean; "java/util/concurrent/ConcurrentMap putIfAbsent8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; address permanentZ unblacklist(Lcom/hazelcast/nio/Address;)ZFALSELjava/lang/Boolean; remove'(Ljava/lang/Object;Ljava/lang/Object;)Z  is removed from the blacklist. isBlacklisted containsKey(Ljava/lang/Object;)Z doJoinjoinclear ; ; isJoined()Z |isMemberExcludedFromHotRestart ECould not join to the cluster because hot restart data must be reset.warning getNodeExtension(()Lcom/hazelcast/instance/NodeExtension; _$com/hazelcast/instance/NodeExtensiongetInternalHotRestartService6()Lcom/hazelcast/hotrestart/InternalHotRestartService; 2com/hazelcast/hotrestart/InternalHotRestartServiceforceStartBeforeJoin ; reset ; postJoin ;  shouldRetry isRunning  _isStartCompleted  getThisAddress()Lcom/hazelcast/nio/Address;  _ getThisUuid  _ isMemberExcluded0(Lcom/hazelcast/nio/Address;Ljava/lang/String;)Z    nodeExtension&Lcom/hazelcast/instance/NodeExtension; isFineEnabled  PostJoin master: getMasterAddress  | , isMaster: isMaster  |(Z)Ljava/lang/StringBuilder;  !fine # $incrementAndGet()I &' Q(9Join try count exceed limit, setting this node as master!*6com/hazelcast/internal/cluster/impl/ClusterJoinManager,setThisMemberAsMaster . -/ensureConnectionToAllMembers 1; 2getSize 4' |5printMemberList 7; |8java/lang/InterruptedException:Waiting for all connections<CONNECT_ALL_WAIT_SECONDS > ? getSeconds3(Lcom/hazelcast/spi/properties/HazelcastProperty;)I AB C getMembers()Ljava/util/Set; EF |Gjava/util/CollectionIiterator()Ljava/util/Iterator; KL JMjava/util/IteratorOhasNext Q PRnext()Ljava/lang/Object; TU PVcom/hazelcast/core/MemberX localMember Z Y[(com/hazelcast/instance/EndpointQualifier]MEMBER*Lcom/hazelcast/instance/EndpointQualifier; _` ^agetEndpointManagerO(Lcom/hazelcast/instance/EndpointQualifier;)Lcom/hazelcast/nio/EndpointManager; cd _e getAddress g Yh!com/hazelcast/nio/EndpointManagerj getOrConnect;(Lcom/hazelcast/nio/Address;)Lcom/hazelcast/nio/Connection; lm knNot-connected to pjava/util/concurrent/TimeUnitrSECONDSLjava/util/concurrent/TimeUnit; tu svsleep xK syjava/lang/Thread{ currentThread()Ljava/lang/Thread; }~ | interrupt ; |memberLcom/hazelcast/core/Member;ignored Ljava/lang/InterruptedException; allConnectedmembers3Ljava/util/Collection;Ljava/util/Collection;connectAllWaitSeconds checkCountgetMaxJoinMillisMAX_JOIN_SECONDS  getMaxJoinTimeToMasterNodetoMillis(J)J  sMAX_WAIT_SECONDS_BEFORE_JOIN  )sendSplitBrainJoinMessageAndCheckResponse(Lcom/hazelcast/nio/Address;Lcom/hazelcast/internal/cluster/impl/SplitBrainJoinMessage;)Lcom/hazelcast/internal/cluster/impl/SplitBrainJoinMessage$SplitBrainMergeCheckResult;sendSplitBrainJoinMessage(Lcom/hazelcast/nio/Address;Lcom/hazelcast/internal/cluster/impl/SplitBrainJoinMessage;)Lcom/hazelcast/internal/cluster/impl/SplitBrainJoinMessage;   shouldMerge(Lcom/hazelcast/internal/cluster/impl/SplitBrainJoinMessage;)Lcom/hazelcast/internal/cluster/impl/SplitBrainJoinMessage$SplitBrainMergeCheckResult;  -targetrequest;Lcom/hazelcast/internal/cluster/impl/SplitBrainJoinMessage;response%java/util/concurrent/TimeoutExceptionjava/lang/Exception!Sending SplitBrainJoinMessage to <(Lcom/hazelcast/nio/Address;Z)Lcom/hazelcast/nio/Connection; l kcom/hazelcast/nio/ConnectionReturning null timeout<0, (J)Ljava/lang/StringBuilder;   |y getConnection m k nodeEngine'Lcom/hazelcast/spi/impl/NodeEngineImpl;  _com/hazelcast/spi/NodeEnginegetOperationService&()Lcom/hazelcast/spi/OperationService;  hz:core:clusterServiceJcom/hazelcast/internal/cluster/impl/operations/SplitBrainMergeValidationOp>(Lcom/hazelcast/internal/cluster/impl/SplitBrainJoinMessage;)V 9 "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;  invoke/()Lcom/hazelcast/spi/InternalCompletableFuture;  java/util/concurrent/Future4(JLjava/util/concurrent/TimeUnit;)Ljava/lang/Object;  com/hazelcast/nio/AddressTimeout during join check!*(Ljava/lang/String;Ljava/lang/Throwable;)V # Error during join check!  e'Ljava/util/concurrent/TimeoutException;Ljava/lang/Exception;connLcom/hazelcast/nio/Connection;timeoutLcom/hazelcast/spi/NodeEngine;futureLjava/util/concurrent/Future;set K D R QstartClusterMerge(Lcom/hazelcast/nio/Address;I)V _yprepareClusterState<(Lcom/hazelcast/internal/cluster/impl/ClusterServiceImpl;I)Z  %com/hazelcast/spi/impl/NodeEngineImplD()Lcom/hazelcast/spi/impl/operationservice/InternalOperationService;  java/util/ArrayListsize  ' J S>com/hazelcast/internal/cluster/impl/operations/MergeClustersOp 9 invokeOnTargety(Ljava/lang/String;Lcom/hazelcast/spi/Operation;Lcom/hazelcast/nio/Address;)Lcom/hazelcast/spi/InternalCompletableFuture;  add  JwaitWithDeadlinei(Ljava/util/Collection;JLjava/util/concurrent/TimeUnit;Lcom/hazelcast/util/FutureUtil$ExceptionHandler;)V  com/hazelcast/spi/Operation setNodeEngine=(Lcom/hazelcast/spi/NodeEngine;)Lcom/hazelcast/spi/Operation;  ! " setService1(Ljava/lang/Object;)Lcom/hazelcast/spi/Operation; $% &6com/hazelcast/spi/impl/OperationResponseHandlerFactory(createEmptyResponseHandler.()Lcom/hazelcast/spi/OperationResponseHandler; *+ ),setOperationResponseHandlerK(Lcom/hazelcast/spi/OperationResponseHandler;)Lcom/hazelcast/spi/Operation; ./ 0run (Lcom/hazelcast/spi/Operation;)V 23 4opLcom/hazelcast/spi/Operation;1Ljava/util/concurrent/Future;expectedMemberListVersionoperationService$Lcom/hazelcast/spi/OperationService; memberListfutures5Ljava/util/Collection;preCheckClusterState2(Lcom/hazelcast/internal/cluster/ClusterService;)Z ?@ AgetClusterState&()Lcom/hazelcast/cluster/ClusterState; CD |E"com/hazelcast/cluster/ClusterStateGisMigrationAllowed I HJ isJoinAllowed L HM IN_TRANSITION$Lcom/hazelcast/cluster/ClusterState; OP HQgetMemberListVersion S' |TLCould not change cluster state to FROZEN because local member list version: V(I)Ljava/lang/StringBuilder; X Y1 is different than expected member list version: [FROZEN ]P H^changeClusterState'(Lcom/hazelcast/cluster/ClusterState;)V `a |b'verifyMemberListVersionAfterStateChange`(Lcom/hazelcast/internal/cluster/impl/ClusterServiceImpl;Lcom/hazelcast/cluster/ClusterState;I)Z de fjava/lang/ClasshgetName j ik: m getMessage o p(While changing cluster state to FROZEN! r.Interrupted while preparing cluster for merge!t^Could not change cluster state to FROZEN in time. Postponing merge process until next attempt.verrorLjava/lang/String; clusterStateuntil Reverting cluster state back to | because member list version: ~!While reverting cluster state to ! -com/hazelcast/internal/cluster/ClusterService E=Could not prepare cluster state since it has been changed to /Lcom/hazelcast/internal/cluster/ClusterService; initialStategetTargetAddress ConstantValue SignatureCodeLineNumberTableLocalVariableTable StackMapTableLocalVariableTypeTable InnerClasses SourceFile! !#$%&'()*+,-./01234B56789:s*=*?Y@B*DYJMO*QYTV* Y*Y[*+]*+c*gmo*+rt*+xz**z*+2 ]ILM)R5^:_I`QaYbdcrdss%&H2*Oh >*+ mn56r,*oY+*B+Wrs+t ,,6,y0*B+˹!*oY+Ѷ.xy,z.|006? *B+ 6;;G*B**z.*'*o*]***B& ):>BF GV!*]*z*@ !3*]L+#+*] *]  1@23+; *B*o6*oY*z*z"%*]*V)*o+*0W*z#*z*3*z6 *z9 H : HRS^jr| 1;*z*o=%*]@D<=>*zH:N:SfWY:\M*]bfio4>*o&*oYqi%w z :^;"&JPiI;V $&.09X{}HXT09$& 9H8*] HJw*]a  _*+,N*z- *6 / *o *oY+%*]bf+N!7-Ye7 #*oY% :*]bf+N*]:ǻY,+ض:w:*o:*osy|;3 )2H; :Rf );@DLSqsy|~     f ~6;@W6;E*OJ*V   *]N*-*]:-H:Y  :N:SEWY:\,Y+:  i:  Ww*[Y+:*]#-'-1W5+|*|JJPHJ$ 4!S"]#g$p%|&(*,-./p g67 |  S3569'(:;$<4=!67 | 8 $<4=> *+BJ*aBJ!+F:K!NR+U+U/*oYW+UZ\ZRX+_c*+g:Yglnq:*oYsw z:*ou*ow; 1H@3WDI;n;< ?@A!B9CGFOGaHtGyJ{OQSTUV[a\]_`bdeRxyC!zP  '( 9{de5+U*oY},+UZ\Z+,cR:Yglnq:*oY,AD DN. jl$m7l<oAsDpFqkrux>k(xyFM'(zP9?@/+M,N"*oY,-H+- //'(PH *L*+  6  @