43com/hazelcast/flakeidgen/impl/FlakeIdGeneratorProxyLcom/hazelcast/spi/AbstractDistributedObject;Lcom/hazelcast/flakeidgen/FlakeIdGenerator;+com/hazelcast/spi/AbstractDistributedObject)com/hazelcast/flakeidgen/FlakeIdGeneratorFlakeIdGeneratorProxy.javaFcom/hazelcast/flakeidgen/impl/FlakeIdGeneratorProxy$IdBatchAndWaitTime IdBatchAndWaitTime5com/hazelcast/flakeidgen/impl/FlakeIdGeneratorProxy$1 9com/hazelcast/flakeidgen/impl/AutoBatcher$IdBatchSupplier)com/hazelcast/flakeidgen/impl/AutoBatcherIdBatchSupplierBITS_TIMESTAMPI) BITS_SEQUENCE BITS_NODE_ID INCREMENTJALLOWED_FUTURE_MILLIS: EPOCH_START`NODE_ID_UPDATE_INTERVAL_NSNODE_ID_NOT_YET_SETNODE_ID_OUT_OF_RANGEnameLjava/lang/String; epochStart nodeIdOffsetnodeIdnextNodeIdUpdateloggerLcom/hazelcast/logging/ILogger;generatedValue(Ljava/util/concurrent/atomic/AtomicLong; randomMemberLcom/hazelcast/core/Member;batcher+Lcom/hazelcast/flakeidgen/impl/AutoBatcher;outOfRangeMembersLjava/util/Set;#Ljava/util/Set;$assertionsDisabledZj(Ljava/lang/String;Lcom/hazelcast/spi/NodeEngine;Lcom/hazelcast/flakeidgen/impl/FlakeIdGeneratorService;)VB(Lcom/hazelcast/spi/NodeEngine;Lcom/hazelcast/spi/RemoteService;)V <> ? - A . E&java/util/concurrent/atomic/AtomicLongG(J)V <I HJ 12 L&java/util/concurrent/ConcurrentHashMapN()V <P OQjava/util/CollectionsS newSetFromMap (Ljava/util/Map;)Ljava/util/Set; UV TW 78 Y )* [java/lang/Object]getClass()Ljava/lang/Class; _` ^acom/hazelcast/spi/NodeEnginec getLogger2(Ljava/lang/Class;)Lcom/hazelcast/logging/ILogger; ef dg /0 i getConfig()Lcom/hazelcast/config/Config; kl dmgetName()Ljava/lang/String; op qcom/hazelcast/config/ConfigsfindFlakeIdGeneratorConfigA(Ljava/lang/String;)Lcom/hazelcast/config/FlakeIdGeneratorConfig; uv tw+com/hazelcast/config/FlakeIdGeneratorConfigy getIdOffset()J {| z} + getNodeIdOffset | z , getPrefetchCount()I zgetPrefetchValidityMillis | z8(Lcom/hazelcast/flakeidgen/impl/FlakeIdGeneratorProxy;)V < @(IJLcom/hazelcast/flakeidgen/impl/AutoBatcher$IdBatchSupplier;)V <  56 com/hazelcast/logging/ILoggerisFinestEnabled()Z java/lang/StringBuilder Q%Created FlakeIdGeneratorProxy, name='append-(Ljava/lang/String;)Ljava/lang/StringBuilder; 'toString p finest(Ljava/lang/String;)V java/lang/String5com/hazelcast/flakeidgen/impl/FlakeIdGeneratorServicethis5Lcom/hazelcast/flakeidgen/impl/FlakeIdGeneratorProxy; nodeEngineLcom/hazelcast/spi/NodeEngine;service7Lcom/hazelcast/flakeidgen/impl/FlakeIdGeneratorService;config-Lcom/hazelcast/config/FlakeIdGeneratorConfig;newId | init(J)Zjava/util/concurrent/TimeUnitHOURSLjava/util/concurrent/TimeUnit; toMillis(J)J idreserve newIdBatchK(I)Lcom/hazelcast/flakeidgen/impl/FlakeIdGeneratorProxy$IdBatchAndWaitTime;7com/hazelcast/flakeidgen/impl/NodeIdOutOfRangeException getNodeId com/hazelcast/util/ClockcurrentTimeMillis | newIdBaseLocalM(JII)Lcom/hazelcast/flakeidgen/impl/FlakeIdGeneratorProxy$IdBatchAndWaitTime; 1com/hazelcast/flakeidgen/impl/NewIdBatchOperation(Ljava/lang/String;I)V < getRandomMember()Lcom/hazelcast/core/Member;  getNodeEngine ()Lcom/hazelcast/spi/NodeEngine; getOperationService&()Lcom/hazelcast/spi/OperationService; dgetServiceName p com/hazelcast/core/Member getAddress()Lcom/hazelcast/nio/Address; "com/hazelcast/spi/OperationServiceinvokeOnTargety(Ljava/lang/String;Lcom/hazelcast/spi/Operation;Lcom/hazelcast/nio/Address;)Lcom/hazelcast/spi/InternalCompletableFuture; +com/hazelcast/spi/InternalCompletableFuturejoin()Ljava/lang/Object; java/lang/Long longValue | %com/hazelcast/flakeidgen/impl/IdBatch(JJI)V <  +(Lcom/hazelcast/flakeidgen/impl/IdBatch;J)V <  getUuid p  java/util/Setadd(Ljava/lang/Object;)Z   34 basee9Lcom/hazelcast/flakeidgen/impl/NodeIdOutOfRangeException;op3Lcom/hazelcast/flakeidgen/impl/NewIdBatchOperation;targetfuture?Lcom/hazelcast/spi/InternalCompletableFuture;-Lcom/hazelcast/spi/InternalCompletableFuture; batchSize" com/hazelcast/util/Preconditions$ checkPositive(ILjava/lang/String;)I &' %(0NodeID overflow, this member cannot generate IDs* < , :; .java/lang/AssertionError1nodeId out of range: 3(I)Ljava/lang/StringBuilder; 5 6(Ljava/lang/Object;)V <8 29%com/hazelcast/core/HazelcastException?!Current time out of allowed rangeA @,get D| HEjava/lang/MathGmax(JJ)J IJ HK compareAndSet(JJ)Z MN HO getService#()Lcom/hazelcast/spi/RemoteService; QR SupdateStatsForBatch U VnowoldGeneratedValuewaitTimejava/lang/System[nanoTime ]| \^(J)I ` agetClusterService1()Lcom/hazelcast/internal/cluster/ClusterService; cd de-com/hazelcast/internal/cluster/ClusterServiceggetMemberListJoinVersion i hj newNodeId=l $ ngetLocalMember p hqNode ID is out of range (sM), this member won't be able to generate IDs. Cluster restart is recommended.usevere w x isFineEnabled z {Node ID assigned to '}': fine   newNodeId getMembers()Ljava/util/Set;  hjava/util/ArrayListsize  (I)V < iterator()Ljava/util/Iterator;  java/util/Listjava/util/IteratorhasNext  next  contains   isEmpty  BAll members have node ID out of range. Cluster restart is required5com/hazelcast/internal/util/ThreadLocalRandomProvider()Ljava/util/Random; D  java/util/RandomnextInt(I)I  (I)Ljava/lang/Object; D mmembers,Ljava/util/Set;filteredMembers-Ljava/util/List;Ljava/util/List;memberhz:impl:flakeIdGeneratorServicejava/lang/ClassdesiredAssertionStatus  SECONDS  toNanos   ConstantValue SignatureCode StackMapTableLineNumberTableLocalVariableTableLocalVariableTypeTable InnerClasses SourceFile!!"$%&'()*+,B-B./012B3456789:; <=X *,-@*B*CF*HYCKM*OYRXZ*+\*,*bhj,n*rx:*"~{e**Y Y**j$*jY+dz:YF GM V.Z3[A]P^`_i`qrt4)*Pd|2*z l yB*!a@    ` *= *ڰY*\N*:**-:7 YY  :*ZW*BfgS6   &0BQgizRQi _&Y4B=!"}- B= A **ڰ " #)WY+-/'0~2YY47:*e@; =@YBCy@*MF7L7*MaP ae{eL7 y7*T*\W YY   ) > DK[fkt|HX-"taY|Y2Z 2*_b `*B>*F*fk6/% 2YYm7:*a6*oaF>0~F*Z*frW*jYt7vy>*B*j|-*jY~*\7 Lg:B$LW`fiq*$]-X*L+*fMY,N,:.:*Z -W-@YC--L*++ .16  &DW`clw 4D4z8&l4z&lop/*\ p. PDŚ/ɶͳo @ +>