Top Description Inners Fields Constructors Methods

io.netty.resolver.dns

pack-priv abstract Class Cache<E>

Class Inheritance

extends Object

java.lang.Object
io.netty.resolver.dns.Cache

Imports

io.netty.channel.EventLoop, io.netty.util.internal.PlatformDependent, java.util.ArrayList, .Collections, .Iterator, .List, .Map, .Map.Entry, java.util.concurrent.ConcurrentMap, .Delayed, .ScheduledFuture, .TimeUnit, java.util.concurrent.atomic.AtomicReference, .AtomicReferenceFieldUpdater

Abstract cache that automatically removes entries for a hostname once the TTL for an entry is reached.

Nested and Inner Type Summary

Modifier and Type	Class and Description
private class	Cache.Entries

Field Summary

Modifier and Type	Field and Description
private static final ScheduledFuture<?>	CANCELLED
private static final AtomicReferenceFieldUpdater<Cache.Entries, ScheduledFuture<V>>	FUTURE_UPDATER
pack-priv static final int	MAX_SUPPORTED_TTL_SECS
private final ConcurrentMap<String, Cache<E>.Entries>	resolveCache

Constructor Summary

Access	Constructor and Description
pack-priv	Cache()

Method Summary

Modifier and Type	Method and Description
pack-priv final void	cache(String hostname, E value, int ttl, EventLoop loop) Cache a value for the given hostname that will automatically expire once the TTL is reached.
pack-priv final void	clear() Remove everything from the cache.
pack-priv final boolean	clear(String hostname) Clear all entries (if anything exists) for the given hostname and return `true` if anything was removed.
protected abstract boolean	equals(E entry, E otherEntry) Returns `true` if both entries are equal.
pack-priv final List<? extends E>	get(String hostname) Returns all caches entries for the given hostname.
protected abstract boolean	shouldReplaceAll(E entry) Returns `true` if this entry should replace all other entries that are already cached for the hostname.
pack-priv final int	size() Return the number of hostnames for which we have cached something.
protected void	sortEntries(String hostname, List<E> entries) Sort the `List` for a `hostname` before caching these.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

CANCELLED	back to summary
private static final ScheduledFuture<?> CANCELLED

FUTURE_UPDATER	back to summary
private static final AtomicReferenceFieldUpdater<Cache.Entries, ScheduledFuture<V>> FUTURE_UPDATER

MAX_SUPPORTED_TTL_SECS	back to summary
pack-priv static final int MAX_SUPPORTED_TTL_SECS

resolveCache	back to summary
private final ConcurrentMap<String, Cache<E>.Entries> resolveCache

Constructor Detail

Cache	back to summary
pack-priv Cache()

Method Detail

cache	back to summary
pack-priv final void cache(String hostname, E value, int ttl, EventLoop loop) Cache a value for the given hostname that will automatically expire once the TTL is reached.

clear	back to summary
pack-priv final void clear() Remove everything from the cache.

clear	back to summary
pack-priv final boolean clear(String hostname) Clear all entries (if anything exists) for the given hostname and return `true` if anything was removed.

equals	back to summary
protected abstract boolean equals(E entry, E otherEntry) Returns `true` if both entries are equal.

get	back to summary
pack-priv final List<? extends E> get(String hostname) Returns all caches entries for the given hostname.

shouldReplaceAll	back to summary
protected abstract boolean shouldReplaceAll(E entry) Returns `true` if this entry should replace all other entries that are already cached for the hostname.

size	back to summary
pack-priv final int size() Return the number of hostnames for which we have cached something.

sortEntries	back to summary
protected void sortEntries(String hostname, List<E> entries) Sort the `List` for a `hostname` before caching these.

io.netty.resolver.dns back to summary

private final Class Cache.Entries

Class Inheritance

extends AtomicReference<List<E>>
implements Runnable

java.lang.Object
java.util.concurrent.atomic.AtomicReference
io.netty.resolver.dns.Cache.Entries

All Implemented Interfaces

java.lang.Runnable

Field Summary

Modifier and Type	Field and Description
pack-priv volatile ScheduledFuture<?>	expirationFuture
private final String	hostname

Constructor Summary

Access	Constructor and Description
pack-priv	Entries(String hostname)

Method Summary

Modifier and Type	Method and Description
pack-priv void	add(E e, int ttl, EventLoop loop)
pack-priv boolean	clearAndCancel()
public void	run() Implements java.lang.Runnable.run. Runs this operation.
private void	scheduleCacheExpirationIfNeeded(int ttl, EventLoop loop)

Field Detail

expirationFuture	back to summary
pack-priv volatile ScheduledFuture<?> expirationFuture

hostname	back to summary
private final String hostname

Constructor Detail

Entries	back to summary
pack-priv Entries(String hostname)

Method Detail

add	back to summary
pack-priv void add(E e, int ttl, EventLoop loop)

clearAndCancel	back to summary
pack-priv boolean clearAndCancel()

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations

@Override

scheduleCacheExpirationIfNeeded	back to summary
private void scheduleCacheExpirationIfNeeded(int ttl, EventLoop loop)