4Dcom/hazelcast/internal/util/concurrent/ManyToOneConcurrentArrayQueue`Lcom/hazelcast/internal/util/concurrent/AbstractConcurrentArrayQueue;Ccom/hazelcast/internal/util/concurrent/AbstractConcurrentArrayQueue"ManyToOneConcurrentArrayQueue.java$assertionsDisabledZ(I)V  thisKLcom/hazelcast/internal/util/concurrent/ManyToOneConcurrentArrayQueue;FLcom/hazelcast/internal/util/concurrent/ManyToOneConcurrentArrayQueue;requestedCapacityIoffer(Ljava/lang/Object;)Z(TE;)Z  java/lang/AssertionErrorattempt to offer a null element(Ljava/lang/Object;)V  capacity  sharedHeadCacheJ !" #tail %" &head (" )SHARED_HEAD_CACHE4Ljava/util/concurrent/atomic/AtomicLongFieldUpdater; +, -2java/util/concurrent/atomic/AtomicLongFieldUpdater/lazySet(Ljava/lang/Object;J)V 12 03TAIL 5, 6 compareAndSet(Ljava/lang/Object;JJ)Z 89 0:buffer2Ljava/util/concurrent/atomic/AtomicReferenceArray; <= >seqToArrayIndex(JJ)I @A B0java/util/concurrent/atomic/AtomicReferenceArrayD(ILjava/lang/Object;)V 1F EGeTE;Ljava/lang/Object; acquiredHead bufferLimit acquiredTailpoll()Ljava/lang/Object;()TE;get(I)Ljava/lang/Object; RS ETHEAD V, Wjava/lang/ObjectY7Ljava/util/concurrent/atomic/AtomicReferenceArray; arrayIndexitemdrain*(Lcom/hazelcast/util/function/Predicate;)I0(Lcom/hazelcast/util/function/Predicate<-TE;>;)I%com/hazelcast/util/function/Predicateatest c bd itemHandler-Lcom/hazelcast/util/function/Predicate<-TE;>;'Lcom/hazelcast/util/function/Predicate;masklimit nextSequencedrainTo(Ljava/util/Collection;I)I (Ljava/util/Collection<-TE;>;I)Ijava/util/Collectionoadd q prtargetLjava/util/Collection<-TE;>;Ljava/util/Collection;countsize()I xy zclear()V |} ~ retainAll(Ljava/util/Collection;)Z  removeAll addAll  containsAll remove  toArray(([Ljava/lang/Object;)[Ljava/lang/Object; ()[Ljava/lang/Object; iterator()Ljava/util/Iterator; contains  isEmpty()Z element P  P  rpeek P remainingCapacity y  y  removedCount()J  addedCount java/lang/ClassdesiredAssertionStatus CodeLineNumberTableLocalVariableTableLocalVariableTypeTable StackMapTable Signature SourceFile! P*  "#   2 r+ Y* =*$B!a7*'7 **B!a7.*!47* a;*?dC+H":')+,$/*02172=3E4G6O8_9p:>r rIKYTL"$NM"*HN"r rIJOP8**@*?N* dC6-U:-HX* a45EZ"@A BCD$E+F5H48 3(" .<=!\]K 8  .<[]JQ^_~ m*?M* dB**7!a a77  B !C6 , U:  *, H a7 X* 4+ e e!bEZ#FNO PQST'U/V7W<X?ZF[L\U]`^c`fa\ /4\ 7,]K m mfhh<= `i"ZL"Rj"Nk" *7,]J m mfgh<[`lmj ^*?N* d7**76AC6 - U:  (- H a7X*4+ sW pEZ$Bghjklm&n.o3p6r=sCtLuOvXw[x\ &2\ .*]K ^ ^tv^jY<=Pi"Jk"Gw*.*]J ^ ^tuY<[nAxyA*{    A|}A*    AB*+    AB*+    AB*+    AB*+    AB*+    AB*+    AA*    AA*    AB*+    AA*    APA*    APA*    AqB*+    APA*    AyA*    AyA*    AA*    AA*    }4 @