4D-com/hazelcast/ringbuffer/impl/RingbufferProxyLcom/hazelcast/spi/AbstractDistributedObject;Lcom/hazelcast/ringbuffer/Ringbuffer;+com/hazelcast/spi/AbstractDistributedObject#com/hazelcast/ringbuffer/RingbufferRingbufferProxy.javaMAX_BATCH_SIZEInameLjava/lang/String; partitionIdconfig'Lcom/hazelcast/config/RingbufferConfig;(Lcom/hazelcast/spi/NodeEngine;Lcom/hazelcast/ringbuffer/impl/RingbufferService;Ljava/lang/String;Lcom/hazelcast/config/RingbufferConfig;)VB(Lcom/hazelcast/spi/NodeEngine;Lcom/hazelcast/spi/RemoteService;)V   /com/hazelcast/ringbuffer/impl/RingbufferServicegetRingbufferPartitionId(Ljava/lang/String;)I       this4Lcom/hazelcast/ringbuffer/impl/RingbufferProxy;/Lcom/hazelcast/ringbuffer/impl/RingbufferProxy; nodeEngineLcom/hazelcast/spi/NodeEngine;service1Lcom/hazelcast/ringbuffer/impl/RingbufferService;getPartitionId()IgetName()Ljava/lang/String;getServiceNamehz:impl:ringbufferService.capacity()J getService#()Lcom/hazelcast/spi/RemoteService; 23 4com/hazelcast/quorum/QuorumType6READ!Lcom/hazelcast/quorum/QuorumType; 89 7:ensureQuorumPresent6(Ljava/lang/String;Lcom/hazelcast/quorum/QuorumType;)V <= >%com/hazelcast/config/RingbufferConfig@ getCapacity B* ACsize9com/hazelcast/ringbuffer/impl/operations/GenericOperationF(Ljava/lang/String;B)V H GIsetPartitionId (I)Lcom/hazelcast/spi/Operation; KL GMinvokeOnPartitionL(Lcom/hazelcast/spi/Operation;)Lcom/hazelcast/spi/InternalCompletableFuture; OP Q+com/hazelcast/spi/InternalCompletableFutureSjoin()Ljava/lang/Object; UV TWjava/lang/LongY longValue [1 Z\opLcom/hazelcast/spi/Operation;f?Lcom/hazelcast/spi/InternalCompletableFuture;-Lcom/hazelcast/spi/InternalCompletableFuture; tailSequence headSequenceremainingCapacitygetTimeToLiveSeconds f* Agadd(Ljava/lang/Object;)J(TE;)Jitem can't be nulll com/hazelcast/util/Preconditionsn checkNotNull8(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; pq or5com/hazelcast/ringbuffer/impl/operations/AddOperationttoData:(Ljava/lang/Object;)Lcom/hazelcast/nio/serialization/Data; vw x'com/hazelcast/ringbuffer/OverflowPolicyz OVERWRITE)Lcom/hazelcast/ringbuffer/OverflowPolicy; |} {~d(Ljava/lang/String;Lcom/hazelcast/nio/serialization/Data;Lcom/hazelcast/ringbuffer/OverflowPolicy;)V  u uMitemTE;Ljava/lang/Object;addAsyncd(Ljava/lang/Object;Lcom/hazelcast/ringbuffer/OverflowPolicy;)Lcom/hazelcast/core/ICompletableFuture;g(TE;Lcom/hazelcast/ringbuffer/OverflowPolicy;)Lcom/hazelcast/core/ICompletableFuture;overflowPolicy can't be nulloverflowPolicyreadOne(J)Ljava/lang/Object;(J)TE;java/lang/InterruptedExceptionjava/lang/Throwable checkSequence(J)V 9com/hazelcast/ringbuffer/impl/operations/ReadOneOperation(Ljava/lang/String;J)V  Mget V Tcom/hazelcast/spi/Operation com/hazelcast/util/ExceptionUtilrethrowAllowInterrupted3(Ljava/lang/Throwable;)Ljava/lang/RuntimeException; tLjava/lang/Throwable;sequenceJ2Lcom/hazelcast/spi/InternalCompletableFuture; addAllAsynch(Ljava/util/Collection;Lcom/hazelcast/ringbuffer/OverflowPolicy;)Lcom/hazelcast/core/ICompletableFuture;(Ljava/util/Collection<+TE;>;Lcom/hazelcast/ringbuffer/OverflowPolicy;)Lcom/hazelcast/core/ICompletableFuture;collection can't be nulljava/util/CollectionisEmpty()Z collection can't be empty checkFalse(ZLjava/lang/String;)V o E* $collection can't be larger than 1000 checkTrue o8com/hazelcast/ringbuffer/impl/operations/AddAllOperation toDataArray?(Ljava/util/Collection;)[Lcom/hazelcast/nio/serialization/Data; e(Ljava/lang/String;[Lcom/hazelcast/nio/serialization/Data;Lcom/hazelcast/ringbuffer/OverflowPolicy;)V  MgetOperationService&()Lcom/hazelcast/spi/OperationService; "com/hazelcast/spi/OperationServicecreateInvocationBuilderW(Ljava/lang/String;Lcom/hazelcast/spi/Operation;I)Lcom/hazelcast/spi/InvocationBuilder; #com/hazelcast/spi/InvocationBuildersetCallTimeout((J)Lcom/hazelcast/spi/InvocationBuilder; invoke/()Lcom/hazelcast/spi/InternalCompletableFuture;  collectionLjava/util/Collection<+TE;>;Ljava/util/Collection;operationService$Lcom/hazelcast/spi/OperationService;E(Ljava/util/Collection<+TE;>;)[Lcom/hazelcast/nio/serialization/Data;$com/hazelcast/nio/serialization/Dataiterator()Ljava/util/Iterator; '[Lcom/hazelcast/nio/serialization/Data;java/util/IteratorhasNext next V $collection can't contains null itemsitemsk readManyAsyncJ(JIILcom/hazelcast/core/IFunction;)Lcom/hazelcast/core/ICompletableFuture;(JIILcom/hazelcast/core/IFunction;)Lcom/hazelcast/core/ICompletableFuture;>; minCount can't be smaller than 0checkNotNegative(ILjava/lang/String;)I  o0maxCount should be equal or larger than minCount ;Lcom/hazelcast/core/IFunction;"java/lang/IllegalArgumentExceptionjava/lang/StringBuilder()V   +sequence can't be smaller than 0, but was: "append-(Ljava/lang/String;)Ljava/lang/StringBuilder; $% &(J)Ljava/lang/StringBuilder; $( )toString +, ,(Ljava/lang/String;)V . /Ringbuffer{name='%s'}1java/lang/Object3java/lang/String5format9(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String; 78 69 ConstantValueCodeLineNumberTableLocalVariableTableLocalVariableTypeTable StackMapTable Signature Exceptions SourceFile! ;   <*+,*-*,-*!=GH IJK>4"$%&'( ? "#)*<A*=N> "$? "#+,<A*=S> "$? "#-,<?/=X> "$? "#01<Z*5*;?*!D= ]^> "$? "#E1<'GY*J*NL*+RM,XZ]=cdef> '"$^_ `b?'"# `ac1<'GY*J*NL*+RM,XZ]=klmn> '"$^_ `b?'"# `ad1<'GY*J*NL*+RM,XZ]=stuv> '"$^_ `b?'"# `ae1<K*!h*5*;?*!DGY*J*NL*+RM,XZ]@$=} ~$48>> K"$8^_> `b?K"#> `aij<5+msWuY**+y*M*,RN-XZ]="(>*5"$5"^_( `b? 5"#5( `aAk<-+msW,sWuY**+y,*N*-R=#'>*-"$--}'^_?-"#-A</Y**N*-R::&'@'T=')>4)/"$/^_`b?/"#`BA<e+sW,sW++¸ŻY**+,*N*:-*ڶ@)@=. /DHN^ad>4e"$ee}H^_N?e"#eA<@+M>+:#:sW,*yS,@)=" '/8;>>4'@"$@ 6 4 ? '@"#@A<>W *!D ŻY**:*:*ڶ@ @@@=2  4G\agx{~>H"$  a^_g?"#A <^# YY!#'*-0@"="> #+,<N24Y*S:=> "$? "#AC