Repository URL to install this package:
|
Version:
0.6.14 ▾
|
Êþº¾ 4>Ú
ÎÛÜ
Û ÍÝ ÍÞ Íß
àáã Íä
Íå
Íæ
çè
Û Íé
ê Íë
ìí
Û
î Íï
ðñ
Û Íóô
Û Íö÷
ø
ù Íú
û Íü ý
þÿ P P
þ P
à
Í Í
Í
Í
Í
Í
Í
Í
Í
B !
E"#$
H%
Í& '
Í(
Í)
Í*
+, P- .
/0 1 ¸2
Í3
4 ¸5
Í6
Í7
Í8 ÿ9 P:;
^Û
Í<
=
Í> ?@
dÛ
ABC
àD EF
HI
HùJ
møK
mLM
mN
jOP
tQ
tR
tS
TU
ÍVW
dX
ÍY ¸Z
Í[
^\]
^
_`Za
bc
^d e
Íf g
h Pi j
Ík
Íl
ÍmZno Íp
^Q
Íq
Ír
Ís
Ít
u
vw
x
Íy
Íz
{ P| ÿ}
Í~ Í
P ÿ ÿ
Í ÿ
¸
ÿ
¸
Í ÿ
Í
Í
Í
Í
Í ¸@
Í
Í
Í
^
^1
Í ÿ
Í¡
Í¢
^£
¤
Í¥
ͦ
ͧ
¨©ª Segment InnerClasses map $Lcom/google/common/cache/LocalCache; Signature ,Lcom/google/common/cache/LocalCache<TK;TV;>; RuntimeInvisibleAnnotations $Lcom/google/j2objc/annotations/Weak; count I totalWeight J 8Lcom/google/errorprone/annotations/concurrent/GuardedBy; value this modCount threshold table 2Ljava/util/concurrent/atomic/AtomicReferenceArray; dLjava/util/concurrent/atomic/AtomicReferenceArray<Lcom/google/common/cache/ReferenceEntry<TK;TV;>;>; RuntimeVisibleTypeAnnotations 5Lorg/checkerframework/checker/nullness/qual/Nullable; maxSegmentWeight keyReferenceQueue Ljava/lang/ref/ReferenceQueue; #Ljava/lang/ref/ReferenceQueue<TK;>; valueReferenceQueue #Ljava/lang/ref/ReferenceQueue<TV;>; recencyQueue Ljava/util/Queue; CLjava/util/Queue<Lcom/google/common/cache/ReferenceEntry<TK;TV;>;>; readCount +Ljava/util/concurrent/atomic/AtomicInteger;
writeQueue accessQueue statsCounter StatsCounter 4Lcom/google/common/cache/AbstractCache$StatsCounter; <init> ](Lcom/google/common/cache/LocalCache;IJLcom/google/common/cache/AbstractCache$StatsCounter;)V Code LineNumberTable LocalVariableTable ,Lcom/google/common/cache/LocalCache$Segment; initialCapacity LocalVariableTypeTable 4Lcom/google/common/cache/LocalCache$Segment<TK;TV;>;
StackMapTable« e(Lcom/google/common/cache/LocalCache<TK;TV;>;IJLcom/google/common/cache/AbstractCache$StatsCounter;)V
newEntryArray 5(I)Ljava/util/concurrent/atomic/AtomicReferenceArray; size g(I)Ljava/util/concurrent/atomic/AtomicReferenceArray<Lcom/google/common/cache/ReferenceEntry<TK;TV;>;>; initTable 5(Ljava/util/concurrent/atomic/AtomicReferenceArray;)V newTable g(Ljava/util/concurrent/atomic/AtomicReferenceArray<Lcom/google/common/cache/ReferenceEntry<TK;TV;>;>;)V newEntry e(Ljava/lang/Object;ILcom/google/common/cache/ReferenceEntry;)Lcom/google/common/cache/ReferenceEntry; key Ljava/lang/Object; hash next (Lcom/google/common/cache/ReferenceEntry; TK; 0Lcom/google/common/cache/ReferenceEntry<TK;TV;>; f(TK;ILcom/google/common/cache/ReferenceEntry<TK;TV;>;)Lcom/google/common/cache/ReferenceEntry<TK;TV;>; copyEntry z(Lcom/google/common/cache/ReferenceEntry;Lcom/google/common/cache/ReferenceEntry;)Lcom/google/common/cache/ReferenceEntry; original newNext valueReference ValueReference 3Lcom/google/common/cache/LocalCache$ValueReference; ;Lcom/google/common/cache/LocalCache$ValueReference<TK;TV;>; TV;¬ (Lcom/google/common/cache/ReferenceEntry<TK;TV;>;Lcom/google/common/cache/ReferenceEntry<TK;TV;>;)Lcom/google/common/cache/ReferenceEntry<TK;TV;>; setValue P(Lcom/google/common/cache/ReferenceEntry;Ljava/lang/Object;Ljava/lang/Object;J)V entry now previous weight :(Lcom/google/common/cache/ReferenceEntry<TK;TV;>;TK;TV;J)V get L(Ljava/lang/Object;ILcom/google/common/cache/CacheLoader;)Ljava/lang/Object; e cause Ljava/lang/Throwable; ee )Ljava/util/concurrent/ExecutionException; loader %Lcom/google/common/cache/CacheLoader; .Lcom/google/common/cache/CacheLoader<-TK;TV;>;
Exceptions 7(TK;ILcom/google/common/cache/CacheLoader<-TK;TV;>;)TV; '(Ljava/lang/Object;I)Ljava/lang/Object; (Ljava/lang/Object;I)TV; lockedGetOrLoad entryKey newCount index first loadingValueReference LoadingValueReference :Lcom/google/common/cache/LocalCache$LoadingValueReference; createNewEntry Z BLcom/google/common/cache/LocalCache$LoadingValueReference<TK;TV;>; waitForLoadingValue (Lcom/google/common/cache/ReferenceEntry;Ljava/lang/Object;Lcom/google/common/cache/LocalCache$ValueReference;)Ljava/lang/Object; s(Lcom/google/common/cache/ReferenceEntry<TK;TV;>;TK;Lcom/google/common/cache/LocalCache$ValueReference<TK;TV;>;)TV; compute F(Ljava/lang/Object;ILjava/util/function/BiFunction;)Ljava/lang/Object; exception newValue function Ljava/util/function/BiFunction; computingValueReference ComputingValueReference <Lcom/google/common/cache/LocalCache$ComputingValueReference; -Ljava/util/function/BiFunction<-TK;-TV;+TV;>; DLcom/google/common/cache/LocalCache$ComputingValueReference<TK;TV;>;® 6(TK;ILjava/util/function/BiFunction<-TK;-TV;+TV;>;)TV; loadSync (Ljava/lang/Object;ILcom/google/common/cache/LocalCache$LoadingValueReference;Lcom/google/common/cache/CacheLoader;)Ljava/lang/Object;
loadingFuture 4Lcom/google/common/util/concurrent/ListenableFuture; 9Lcom/google/common/util/concurrent/ListenableFuture<TV;>; y(TK;ILcom/google/common/cache/LocalCache$LoadingValueReference<TK;TV;>;Lcom/google/common/cache/CacheLoader<-TK;TV;>;)TV; loadAsync ¨(Ljava/lang/Object;ILcom/google/common/cache/LocalCache$LoadingValueReference;Lcom/google/common/cache/CacheLoader;)Lcom/google/common/util/concurrent/ListenableFuture; ¯(TK;ILcom/google/common/cache/LocalCache$LoadingValueReference<TK;TV;>;Lcom/google/common/cache/CacheLoader<-TK;TV;>;)Lcom/google/common/util/concurrent/ListenableFuture<TV;>; getAndRecordStats (Ljava/lang/Object;ILcom/google/common/cache/LocalCache$LoadingValueReference;Lcom/google/common/util/concurrent/ListenableFuture;)Ljava/lang/Object;¯ (TK;ILcom/google/common/cache/LocalCache$LoadingValueReference<TK;TV;>;Lcom/google/common/util/concurrent/ListenableFuture<TV;>;)TV; scheduleRefresh (Lcom/google/common/cache/ReferenceEntry;Ljava/lang/Object;ILjava/lang/Object;JLcom/google/common/cache/CacheLoader;)Ljava/lang/Object; oldValue k(Lcom/google/common/cache/ReferenceEntry<TK;TV;>;TK;ITV;JLcom/google/common/cache/CacheLoader<-TK;TV;>;)TV; refresh M(Ljava/lang/Object;ILcom/google/common/cache/CacheLoader;Z)Ljava/lang/Object; checkTime result 8(TK;ILcom/google/common/cache/CacheLoader<-TK;TV;>;Z)TV; insertLoadingValueReference P(Ljava/lang/Object;IZ)Lcom/google/common/cache/LocalCache$LoadingValueReference; I(TK;IZ)Lcom/google/common/cache/LocalCache$LoadingValueReference<TK;TV;>; tryDrainReferenceQueues ()V drainReferenceQueues drainKeyReferenceQueue ref Ljava/lang/ref/Reference; i Ljava/lang/ref/Reference<+TK;>;° drainValueReferenceQueue Ljava/lang/ref/Reference<+TV;>; clearReferenceQueues clearKeyReferenceQueue clearValueReferenceQueue
recordRead ,(Lcom/google/common/cache/ReferenceEntry;J)V 4(Lcom/google/common/cache/ReferenceEntry<TK;TV;>;J)V recordLockedRead recordWrite -(Lcom/google/common/cache/ReferenceEntry;IJ)V 5(Lcom/google/common/cache/ReferenceEntry<TK;TV;>;IJ)V drainRecencyQueue tryExpireEntries (J)V
expireEntries enqueueNotification O(Ljava/lang/Object;ILjava/lang/Object;ILcom/google/common/cache/RemovalCause;)V notification -Lcom/google/common/cache/RemovalNotification; &Lcom/google/common/cache/RemovalCause; 5Lcom/google/common/cache/RemovalNotification<TK;TV;>; 1(TK;ITV;ILcom/google/common/cache/RemovalCause;)V evictEntries +(Lcom/google/common/cache/ReferenceEntry;)V newest 3(Lcom/google/common/cache/ReferenceEntry<TK;TV;>;)V getNextEvictable *()Lcom/google/common/cache/ReferenceEntry;± 2()Lcom/google/common/cache/ReferenceEntry<TK;TV;>; getFirst +(I)Lcom/google/common/cache/ReferenceEntry; 3(I)Lcom/google/common/cache/ReferenceEntry<TK;TV;>; getEntry =(Ljava/lang/Object;I)Lcom/google/common/cache/ReferenceEntry; E(Ljava/lang/Object;I)Lcom/google/common/cache/ReferenceEntry<TK;TV;>; getLiveEntry >(Ljava/lang/Object;IJ)Lcom/google/common/cache/ReferenceEntry; F(Ljava/lang/Object;IJ)Lcom/google/common/cache/ReferenceEntry<TK;TV;>; getLiveValue =(Lcom/google/common/cache/ReferenceEntry;J)Ljava/lang/Object; 6(Lcom/google/common/cache/ReferenceEntry<TK;TV;>;J)TV; containsKey (Ljava/lang/Object;I)Z
containsValue (Ljava/lang/Object;)Z
entryValue length 1Lcom/google/common/annotations/VisibleForTesting; put :(Ljava/lang/Object;ILjava/lang/Object;Z)Ljava/lang/Object; onlyIfAbsent
(TK;ITV;Z)TV; expand newIndex newFirst tail tailIndex headIndex head oldIndex oldTable oldCapacity newMask replace :(Ljava/lang/Object;ILjava/lang/Object;Ljava/lang/Object;)Z
(TK;ITV;TV;)Z 9(Ljava/lang/Object;ILjava/lang/Object;)Ljava/lang/Object; (TK;ITV;)TV; remove² ((Ljava/lang/Object;ILjava/lang/Object;)Z storeLoadedValue b(Ljava/lang/Object;ILcom/google/common/cache/LocalCache$LoadingValueReference;Ljava/lang/Object;)Z oldValueReference L(TK;ILcom/google/common/cache/LocalCache$LoadingValueReference<TK;TV;>;TV;)Z clear removeValueFromChain ø(Lcom/google/common/cache/ReferenceEntry;Lcom/google/common/cache/ReferenceEntry;Ljava/lang/Object;ILjava/lang/Object;Lcom/google/common/cache/LocalCache$ValueReference;Lcom/google/common/cache/RemovalCause;)Lcom/google/common/cache/ReferenceEntry; ú(Lcom/google/common/cache/ReferenceEntry<TK;TV;>;Lcom/google/common/cache/ReferenceEntry<TK;TV;>;TK;ITV;Lcom/google/common/cache/LocalCache$ValueReference<TK;TV;>;Lcom/google/common/cache/RemovalCause;)Lcom/google/common/cache/ReferenceEntry<TK;TV;>; removeEntryFromChain removeCollectedEntry
reclaimKey ,(Lcom/google/common/cache/ReferenceEntry;I)Z 4(Lcom/google/common/cache/ReferenceEntry<TK;TV;>;I)Z reclaimValue I(Ljava/lang/Object;ILcom/google/common/cache/LocalCache$ValueReference;)Z v B(TK;ILcom/google/common/cache/LocalCache$ValueReference<TK;TV;>;)Z removeLoadingValue P(Ljava/lang/Object;ILcom/google/common/cache/LocalCache$LoadingValueReference;)Z I(TK;ILcom/google/common/cache/LocalCache$LoadingValueReference<TK;TV;>;)Z removeEntry R(Lcom/google/common/cache/ReferenceEntry;ILcom/google/common/cache/RemovalCause;)Z Z(Lcom/google/common/cache/ReferenceEntry<TK;TV;>;ILcom/google/common/cache/RemovalCause;)Z postReadCleanup preWriteCleanup postWriteCleanup cleanUp runLockedCleanup runUnlockedCleanup T<K:Ljava/lang/Object;V:Ljava/lang/Object;>Ljava/util/concurrent/locks/ReentrantLock;
SourceFile LocalCache.java "com/google/common/cache/LocalCache õi )java/util/concurrent/atomic/AtomicInteger î ï Ñ Ò å Ú³´µ¶ 2com/google/common/cache/AbstractCache$StatsCounter ò ô·¸ java/lang/ref/ReferenceQueue æ 繸 é 纸 *java/util/concurrent/ConcurrentLinkedQueue»¼ ë 콸 -com/google/common/cache/LocalCache$WriteQueue
WriteQueue ð ì .com/google/common/cache/LocalCache$AccessQueue AccessQueue ñ ì 0java/util/concurrent/atomic/AtomicReferenceArray õ¾¡¿ ß ØÀ¸ à áÁÃÄ ÅÆÇÈÉ%ÇʸËÌÍÎÏÐÑÒÓÔ Weights must be non-negativeÕÖ×ÙÚÛÜz{ÝÞ × Øßàáâãvwä¾\]Ñiå¸?@4& 'java/util/concurrent/ExecutionExceptionæç java/lang/Error 0com/google/common/util/concurrent/ExecutionError õè java/lang/RuntimeException =com/google/common/util/concurrent/UncheckedExecutionException õéê-hiëiÒ%ì &com/google/common/cache/ReferenceEntryí¿îïðñòó¿ô
õö÷
ywøiÓi·ù 8com/google/common/cache/LocalCache$LoadingValueReference
úûOPü¾ java/lang/AssertionErrorýþ Recursive load of: %sÕÿ Ç =com/google/common/cache/CacheLoader$InvalidCacheLoadException InvalidCacheLoadException java/lang/StringBuilder "CacheLoader returned null for key . õ :com/google/common/cache/LocalCache$ComputingValueReference õÏB ú
XY /impossible; Futures.immediateFuture can't throw õÞËÌ
ÎÏ ,com/google/common/cache/LocalCache$Segment$1 õ㺻¸ã Ú`aefUV¸ java/lang/Throwable Þ Ø ¸jikiqi!"Ä 1com/google/common/cache/LocalCache$ValueReferenceÇÏtiui#¸$%}i Ù Ú&¸'!Ç()Ç*¸+i, ì- ì./012¸3
456¸Ç~7ï§i8
ÿÀ9si¾iú¾Â:¸;É<¿ÔiÕÖi=i *com/google/common/cache/LocalCache$Segment (java/util/concurrent/locks/ReentrantLock java/util/Queue java/lang/Object #com/google/common/cache/CacheLoader java/util/function/BiFunction 2com/google/common/util/concurrent/ListenableFuture java/lang/ref/Reference java/util/Iterator $com/google/common/cache/RemovalCause $com/google/common/base/Preconditions checkNotNull &(Ljava/lang/Object;)Ljava/lang/Object; %com/google/common/cache/AbstractCache usesKeyReferences ()Z usesValueReferences usesAccessQueue discardingQueue ()Ljava/util/Queue; usesWriteQueue (I)V ()I
customWeigher entryFactory EntryFactory 1Lcom/google/common/cache/LocalCache$EntryFactory; /com/google/common/cache/LocalCache$EntryFactory (Lcom/google/common/cache/LocalCache$Segment;Ljava/lang/Object;ILcom/google/common/cache/ReferenceEntry;)Lcom/google/common/cache/ReferenceEntry; getKey ()Ljava/lang/Object; getValueReference 5()Lcom/google/common/cache/LocalCache$ValueReference; isActive ¦(Lcom/google/common/cache/LocalCache$Segment;Lcom/google/common/cache/ReferenceEntry;Lcom/google/common/cache/ReferenceEntry;)Lcom/google/common/cache/ReferenceEntry; copyFor (Ljava/lang/ref/ReferenceQueue;Ljava/lang/Object;Lcom/google/common/cache/ReferenceEntry;)Lcom/google/common/cache/LocalCache$ValueReference; setValueReference 6(Lcom/google/common/cache/LocalCache$ValueReference;)V weigher !Lcom/google/common/cache/Weigher; com/google/common/cache/Weigher weigh '(Ljava/lang/Object;Ljava/lang/Object;)I
checkState (ZLjava/lang/Object;)V
valueStrength Strength -Lcom/google/common/cache/LocalCache$Strength; +com/google/common/cache/LocalCache$Strength referenceValue (Lcom/google/common/cache/LocalCache$Segment;Lcom/google/common/cache/ReferenceEntry;Ljava/lang/Object;I)Lcom/google/common/cache/LocalCache$ValueReference; notifyNewValue (Ljava/lang/Object;)V ticker Lcom/google/common/base/Ticker; com/google/common/base/Ticker read ()J
recordHits isLoading getCause ()Ljava/lang/Throwable; (Ljava/lang/Error;)V (Ljava/lang/Throwable;)V
defaultLoader lock (I)Ljava/lang/Object; getHash keyEquivalence $Lcom/google/common/base/Equivalence; "com/google/common/base/Equivalence
equivalent '(Ljava/lang/Object;Ljava/lang/Object;)Z getWeight COLLECTED isExpired ,(Lcom/google/common/cache/ReferenceEntry;J)Z EXPIRED unlock getNext set (ILjava/lang/Object;)V recordMisses java/lang/Thread holdsLock ((ZLjava/lang/String;Ljava/lang/Object;)V waitForValue java/lang/String valueOf &(Ljava/lang/Object;)Ljava/lang/String; append -(Ljava/lang/String;)Ljava/lang/StringBuilder; toString ()Ljava/lang/String; (Ljava/lang/String;)V E(Ljava/lang/Object;Ljava/util/function/BiFunction;)Ljava/lang/Object; )com/google/common/util/concurrent/Futures immediateFuture H(Ljava/lang/Object;)Lcom/google/common/util/concurrent/ListenableFuture; EXPLICIT
loadFuture m(Ljava/lang/Object;Lcom/google/common/cache/CacheLoader;)Lcom/google/common/util/concurrent/ListenableFuture; °(Lcom/google/common/cache/LocalCache$Segment;Ljava/lang/Object;ILcom/google/common/cache/LocalCache$LoadingValueReference;Lcom/google/common/util/concurrent/ListenableFuture;)V /com/google/common/util/concurrent/MoreExecutors directExecutor !()Ljava/util/concurrent/Executor; addListener 6(Ljava/lang/Runnable;Ljava/util/concurrent/Executor;)V 2com/google/common/util/concurrent/Uninterruptibles getUninterruptibly 1(Ljava/util/concurrent/Future;)Ljava/lang/Object; elapsedNanos recordLoadSuccess recordLoadException refreshes getWriteTime refreshNanos isDone tryLock poll ()Ljava/lang/ref/Reference;
recordsAccess
setAccessTime add recordsWrite setWriteTime contains peek
wasEvicted recordEviction removalNotificationQueue DISCARDING_QUEUE +com/google/common/cache/RemovalNotification create y(Ljava/lang/Object;Ljava/lang/Object;Lcom/google/common/cache/RemovalCause;)Lcom/google/common/cache/RemovalNotification; offer evictsBySize SIZE iterator ()Ljava/util/Iterator; hasNext valueEquivalence REPLACED UNSET isHeldByCurrentThread getOldValue incrementAndGet processPendingNotifications Í Î Ñ Ò Ó Ô Õ Ö @ × Ø Ù Ú Õ Û Üs Ý Þ Ø ß Ø @ à á Ó â ã ä å Ú æ ç Ó è ã ä é ç Ó ê ã ä ë ì Ó í î ï ð ì Ó í Õ Û Üs Ý ñ ì Ó í Õ Û Üs Ý ò ô <