Searched refs:writeQueue (Results 1 – 3 of 3) sorted by relevance
225 for (ReferenceEntry<?, ?> current : segment.writeQueue) { in checkExpiration()240 assertTrue(segment.writeQueue.isEmpty()); in checkExpiration()338 return segment.writeQueue.size();466 assertTrue(segment.writeQueue.isEmpty());
1467 assertFalse(segment.writeQueue.contains(entryOne)); in testReclaimKey()1597 assertSame(entry, segment.writeQueue.peek()); in testClear()1602 assertTrue(segment.writeQueue.isEmpty()); in testClear()1632 assertSame(entry, segment.writeQueue.peek()); in testClear_notification()1637 assertTrue(segment.writeQueue.isEmpty()); in testClear_notification()1671 assertFalse(segment.writeQueue.contains(entry)); in testRemoveEntry()1709 assertFalse(segment.writeQueue.contains(entry)); in testReclaimValue()1989 assertSameEntries(writeOrder, ImmutableList.copyOf(segment.writeQueue)); in checkEvictionQueues()2029 for (ReferenceEntry<K, V> e : segment.writeQueue) { in checkExpirationTimes()2051 segment.writeQueue.add(entry); in testExpireAfterWrite()[all …]
2125 final Queue<ReferenceEntry<K, V>> writeQueue; field in LocalCache.Segment2154 writeQueue = map.usesWriteQueue() in Segment()2283 writeQueue.remove(e); in lockedGetOrLoad()2607 writeQueue.add(entry); in recordWrite()2651 while ((e = writeQueue.peek()) != null && map.isExpired(e, now)) { in expireEntries()3252 writeQueue.clear(); in clear()3271 writeQueue.remove(entry); in removeValueFromChain()3303 writeQueue.remove(entry); in removeCollectedEntry()