40com/hazelcast/internal/util/concurrent/MPSCQueue]Ljava/util/AbstractQueue;Ljava/util/concurrent/BlockingQueue;java/util/AbstractQueue"java/util/concurrent/BlockingQueueMPSCQueue.java2com/hazelcast/internal/util/concurrent/MPSCQueue$1 5com/hazelcast/internal/util/concurrent/MPSCQueue$Node NodeINITIAL_ARRAY_SIZEIBLOCKED7Lcom/hazelcast/internal/util/concurrent/MPSCQueue$Node;putStack-Ljava/util/concurrent/atomic/AtomicReference;fLjava/util/concurrent/atomic/AtomicReference; takeStackSize+Ljava/util/concurrent/atomic/AtomicInteger; idleStrategy,Lcom/hazelcast/util/concurrent/IdleStrategy;consumerThreadLjava/lang/Thread; takeStack[Ljava/lang/Object;takeStackIndex$assertionsDisabledZA(Ljava/lang/Thread;Lcom/hazelcast/util/concurrent/IdleStrategy;)V()V !# $+java/util/concurrent/atomic/AtomicReference& '$  ))java/util/concurrent/atomic/AtomicInteger+ ,$  .java/lang/Object0  2  4consumerThread can't be null6 com/hazelcast/util/Preconditions8 checkNotNull8(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; :; 9<java/lang/Thread>  @  Bthis7Lcom/hazelcast/internal/util/concurrent/MPSCQueue;2Lcom/hazelcast/internal/util/concurrent/MPSCQueue;/(Lcom/hazelcast/util/concurrent/IdleStrategy;)VsetConsumerThread(Ljava/lang/Thread;)Vclear  Kset(Ljava/lang/Object;)V MN 'Ooffer(Ljava/lang/Object;)Z(TE;)Zitem can't be nullT7(Lcom/hazelcast/internal/util/concurrent/MPSCQueue$1;)V !V WitemLjava/lang/Object; YZ [get()Ljava/lang/Object; ]^ '_next a bsize d e compareAndSet'(Ljava/lang/Object;Ljava/lang/Object;)Z gh 'i&java/util/concurrent/locks/LockSupportkunpark mI lnoldHeadTE;newHeadpeek()TE;peekNext u^ v drainPutStack()Z xy ztakejava/lang/InterruptedException} a^ takeAll #   java/lang/AssertionError $polldequeue # ()I ] ,lazySet(I)V , isInterrupted y ? ~$*com/hazelcast/util/concurrent/IdleStrategyidle(J)Z park # lcopyIntoTakeStack:(Lcom/hazelcast/internal/util/concurrent/MPSCQueue$Node;)V currentPutStackHead iterationJheadcom/hazelcast/util/QuickMathnextPowerOfTwo(I)I i putStackHead putStackSizehisEmpty d put(TE;)V QR e5(Ljava/lang/Object;JLjava/util/concurrent/TimeUnit;)Z&(TE;JLjava/util/concurrent/TimeUnit;)Zadd R timeoutunitLjava/util/concurrent/TimeUnit;4(JLjava/util/concurrent/TimeUnit;)Ljava/lang/Object;%(JLjava/util/concurrent/TimeUnit;)TE;'java/lang/UnsupportedOperationException $remainingCapacitydrainTo(Ljava/util/Collection;)I(Ljava/util/Collection<-TE;>;)IcLjava/util/Collection<-TE;>;Ljava/util/Collection;(Ljava/util/Collection;I)I (Ljava/util/Collection<-TE;>;I)I maxElementsiterator()Ljava/util/Iterator;()Ljava/util/Iterator;java/lang/ClassdesiredAssertionStatus y  ConstantValue SignatureCodeLineNumberTableLocalVariableTableLocalVariableTypeTable StackMapTable Exceptions InnerClasses SourceFile1  !"<*%*'Y(**,Y-/*13*5*+7=?A*,C"A237$8)B6C;D <DF<< <DE!G/*%*'Y(**,Y-/*13*5*+CK237$8)L.M/DF/ /DEHIX*+7=?A [ \DF DEJ#K **LP e f  DF  DEQR7l+U=W**M YXN-+\,` : L-c-f-c-f`f,-jL *Ao'   >jl mnq#r0s5t=vCwNzX{[~cj4#IplDFlYZ `Wr lDElYq `Ss^*wL++*{*w  1 DFYZDEYqt|^C*L++**5 Y*3*52 Y*  1 $>CDF>YZCDE>Yq~t^*L++*{*  1 DFYZDEYqta^y*wL+*+ 1 DF YZDE Yqtu^4*5*5*3 *5*3*52L+ *5+  1*  '+024DF' YZ4DE' Yqt#m%*3*5S*Y5`5*/*/d $ %DF %DE#[ @**N*A-LjW~Y-` :,*C*CW-Lj'L -j*  a@ '"  Z"+07BEPSYagqtz}*+VDF~DE~~xy'**` L+**+j *+   "$ 'DF 'DE^+f=*/*3*+f13d>*3+\S+cL*5*32 Y$.    $ ,6; AF]*(^DF^Y ^DEd"**` L++f=*/`  C  "DF   "DEyT * @$  DF  DEN[*+W )*DFZDEq~Qp*+W ./*DFZDEq~XYǿ4 DF DE~?ɬ9 DF DEXYǿ>DFDEbYǿC DFDEDYǿH DF DE#Cۚ YXL @ .0