4Ccom/hazelcast/internal/partition/operation/PromotionCommitOperationEcom/hazelcast/internal/partition/operation/AbstractPartitionOperation8com/hazelcast/internal/partition/MigrationCycleOperation.com/hazelcast/nio/serialization/impl/VersionedPromotionCommitOperation.javadcom/hazelcast/internal/partition/operation/PromotionCommitOperation$BeforePromotionOperationCallback  BeforePromotionOperationCallbackTcom/hazelcast/internal/partition/impl/InternalMigrationListener$MigrationParticipant ?com/hazelcast/internal/partition/impl/InternalMigrationListenerMigrationParticipantpartitionState8Lcom/hazelcast/internal/partition/PartitionRuntimeState; promotionsLjava/util/Collection;HLjava/util/Collection;expectedMemberUuidLjava/lang/String;successZbeforeStateCompleted()V  thisELcom/hazelcast/internal/partition/operation/PromotionCommitOperation;c(Lcom/hazelcast/internal/partition/PartitionRuntimeState;Ljava/util/Collection;Ljava/lang/String;)V(Lcom/hazelcast/internal/partition/PartitionRuntimeState;Ljava/util/Collection;Ljava/lang/String;)V com/hazelcast/util/Preconditions$ checkNotNull&(Ljava/lang/Object;)Ljava/lang/Object; &' %(  *  ,  . beforeRunjava/lang/Exception1  3 getNodeEngine ()Lcom/hazelcast/spi/NodeEngine; 56 7com/hazelcast/spi/NodeEngine9getLocalMember()Lcom/hazelcast/core/Member; ;< :=com/hazelcast/core/Member?getUuid()Ljava/lang/String; AB @Cjava/lang/StringEequals(Ljava/lang/Object;)Z GH FIjava/lang/IllegalStateExceptionKjava/lang/StringBuilderM NThis Pappend-(Ljava/lang/String;)Ljava/lang/StringBuilder; RS NT-(Ljava/lang/Object;)Ljava/lang/StringBuilder; RV NW^ is promotion commit destination but most probably it's restarted and not the expected target.YtoString [B N\(Ljava/lang/String;)V ^ L_getMasterAddress()Lcom/hazelcast/nio/Address; ab :cgetCallerAddress eb fcom/hazelcast/nio/Addressh iI#Caller is not master node! Caller: k , Master: m getService()Ljava/lang/Object; op qBcom/hazelcast/internal/partition/impl/InternalPartitionServiceImplsisMemberMaster(Lcom/hazelcast/nio/Address;)Z uv tw7com/hazelcast/spi/exception/RetryableHazelcastExceptiony=Caller is not master node known by migration system! Caller: { z_ nodeEngineLcom/hazelcast/spi/NodeEngine; localMemberLcom/hazelcast/core/Member; masterAddressLcom/hazelcast/nio/Address;callerpartitionServiceDLcom/hazelcast/internal/partition/impl/InternalPartitionServiceImpl;call ()Lcom/hazelcast/spi/CallStatus;beforePromotion finalizePromotion  com/hazelcast/spi/CallStatus DONE_RESPONSELcom/hazelcast/spi/CallStatus; %com/hazelcast/spi/impl/NodeEngineImplgetOperationServiceD()Lcom/hazelcast/spi/impl/operationservice/InternalOperationService; getMigrationManager:()Lcom/hazelcast/internal/partition/impl/MigrationManager; t6com/hazelcast/internal/partition/impl/MigrationManageracquirePromotionPermit()Z yAnother promotion is being run currently. This is only expected when promotion is retried to an unresponsive destination.@com/hazelcast/spi/impl/operationservice/InternalOperationService getLogger!()Lcom/hazelcast/logging/ILogger; getPartitionStateVersion()I t6com/hazelcast/internal/partition/PartitionRuntimeState getVersion LAlready applied promotions to the partition state. Promotion state version: (I)Ljava/lang/StringBuilder; R N, current version: com/hazelcast/logging/ILoggerwarning ^ releasePromotionPermit   getInternalMigrationListenerC()Lcom/hazelcast/internal/partition/impl/InternalMigrationListener; t DESTINATIONVLcom/hazelcast/internal/partition/impl/InternalMigrationListener$MigrationParticipant; onPromotionStarto(Lcom/hazelcast/internal/partition/impl/InternalMigrationListener$MigrationParticipant;Ljava/util/Collection;)V  isFineEnabled )Submitting BeforePromotionOperations for java/util/Collectionsize 0 promotions. Promotion partition state version: #, current partition state version: fine ^ )java/util/concurrent/atomic/AtomicInteger(I)V  s(Lcom/hazelcast/internal/partition/operation/PromotionCommitOperation;Ljava/util/concurrent/atomic/AtomicInteger;)V  iterator()Ljava/util/Iterator; java/lang/Runnablejava/util/IteratorhasNext next p .com/hazelcast/internal/partition/MigrationInfoisFinestEnabled 3Submitting BeforePromotionOperation for promotion: finest ^ Ccom/hazelcast/internal/partition/operation/BeforePromotionOperationG(Lcom/hazelcast/internal/partition/MigrationInfo;Ljava/lang/Runnable;)V  getPartitionId   setPartitionId (I)Lcom/hazelcast/spi/Operation;   com/hazelcast/spi/Operation setNodeEngine=(Lcom/hazelcast/spi/NodeEngine;)Lcom/hazelcast/spi/Operation;   setService1(Ljava/lang/Object;)Lcom/hazelcast/spi/Operation;  execute (Lcom/hazelcast/spi/Operation;)V   DONE_VOID  opELcom/hazelcast/internal/partition/operation/BeforePromotionOperation; promotion0Lcom/hazelcast/internal/partition/MigrationInfo;'Lcom/hazelcast/spi/impl/NodeEngineImpl;operationServiceBLcom/hazelcast/spi/impl/operationservice/InternalOperationService;loggerLcom/hazelcast/logging/ILogger;partitionStateVersionIbeforePromotionsCallbackLjava/lang/Runnable;&()Lcom/hazelcast/spi/OperationService; . :/ setMaster(Lcom/hazelcast/nio/Address;)V 12 3processPartitionRuntimeState;(Lcom/hazelcast/internal/partition/PartitionRuntimeState;)Z 56 t7 Promotion of 99 partitions failed. . Promotion partition state version: ;severe =^ >"com/hazelcast/spi/OperationService@+Submitting FinalizePromotionOperations for B promotions. Result: D(Z)Ljava/lang/StringBuilder; RF NG%. Promotion partition state version: I5Submitting FinalizePromotionOperation for promotion: K . Result: MEcom/hazelcast/internal/partition/operation/FinalizePromotionOperationO4(Lcom/hazelcast/internal/partition/MigrationInfo;Z)V Q PR P AonPromotionCompletep(Lcom/hazelcast/internal/partition/impl/InternalMigrationListener$MigrationParticipant;Ljava/util/Collection;Z)V VW XGLcom/hazelcast/internal/partition/operation/FinalizePromotionOperation;$Lcom/hazelcast/spi/OperationService;getIdonBeforePromotionsComplete getResponsejava/lang/Boolean_valueOf(Z)Ljava/lang/Boolean; ab `cgetServiceNamehz:core:partitionServicefonInvocationException:(Ljava/lang/Throwable;)Lcom/hazelcast/spi/ExceptionAction;&com/hazelcast/core/MemberLeftExceptionj4com/hazelcast/spi/exception/TargetNotMemberExceptionl!com/hazelcast/spi/ExceptionActionnTHROW_EXCEPTION#Lcom/hazelcast/spi/ExceptionAction; pq or hi t throwableLjava/lang/Throwable; readInternal&(Lcom/hazelcast/nio/ObjectDataInput;)Vjava/io/IOExceptionz xy |!com/hazelcast/nio/ObjectDataInput~readUTF B !()Lcom/hazelcast/version/Version;  'com/hazelcast/internal/cluster/VersionsV3_12Lcom/hazelcast/version/Version;  com/hazelcast/version/VersionisGreaterOrEqual"(Lcom/hazelcast/version/Version;)Z   readObject p  readData y readInt  java/util/ArrayList   add H  migrationInfoiin#Lcom/hazelcast/nio/ObjectDataInput;versionlen writeInternal'(Lcom/hazelcast/nio/ObjectDataOutput;)V  "com/hazelcast/nio/ObjectDataOutputwriteUTF ^   writeObject(Ljava/lang/Object;)V   writeData  writeInt   out$Lcom/hazelcast/nio/ObjectDataOutput; access$000f(Lcom/hazelcast/internal/partition/operation/PromotionCommitOperation;)Lcom/hazelcast/logging/ILogger;x0 access$100H(Lcom/hazelcast/internal/partition/operation/PromotionCommitOperation;)V ]  SignatureCodeLineNumberTableLocalVariableTableLocalVariableTypeTable StackMapTable Exceptions InnerClasses SourceFile!3* FG  !"*,)W*++*,-*-/JK LMNO* ! #0`*4*8L+>M,D*/J#LYNYOQU,XZU]`+dN*g:-j(LYNYOlUXnU-X]`*rt:xzYNYO|UX]};:@:ii.t:STW XY$ZD_K`QaZbefgi> ! ~KdQ^'2S*4** mn pq  !2t ^*8L+M*rtN- zY}*:-6*+=NYOU*+U]-*Ʋ-ʲ*->NYO׶U*-޶U*+U] Y*Y*-:*-:`:NYOUX]Y:   +-W,  *)tQR$;*rz{ |~)/5ASfkrw{ /<OWZ\ <!"  N#$^ !V~% Q&'I//()5)*+v,-fh*8L*rtM+0N*+*g4*,*+8*:*ƚBNYO:U*-<U*+U,]?ONYOCU*-EU*ƶHJU*+U,]*-:o:,NYOLUXNU*ƶH]PY*ƷS: T+,W-U,ʲ*-*ƶY,ı*w:tAU H,n +18]irw!0CKN]`gH0!Z]#$h !c~ [T&[17()\-   !]G*4*80*U  !^p2*Ƹd  !eB.g  !hi^+k +ms*+u !vwxye*+}*+/+M,*++*Y+*+++>Q*Y-6<,+:Y:+*-Wı0J 0; C J NZcm{Hx$$]?+ !JS+{.*++*/+M,+*+ *++*->+*-:-:,+ +ϱ-*: "$ %-'5*?+F,g.q/|1344g$ !p?G+{/*9 !/*DZ9 !  @