com.hazelcast.internal.nearcache.impl.invalidation

Class MetaDataFetcher

java.lang.Object

com.hazelcast.internal.nearcache.impl.invalidation.MetaDataFetcher

Direct Known Subclasses:

ClientCacheMetaDataFetcher, ClientMapMetaDataFetcher, MemberMapMetaDataFetcher

public abstract class MetaDataFetcher
extends Object

Runs on Near Cache side, an instance of this task is responsible for fetching of all Near Caches' remote metadata like last sequence numbers and partition UUIDs. To see usage of this metadata visit: MetaDataGenerator.

This class is abstract to provide different implementations on client and member sides.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	MetaDataFetcher.ResultHolder

Field Summary

Fields

Modifier and Type	Field and Description
protected static int	ASYNC_RESULT_WAIT_TIMEOUT_MINUTES
protected ILogger	logger

Constructor Summary

Constructors

Constructor and Description
MetaDataFetcher(ILogger logger)

Method Summary

Modifier and Type	Method and Description
protected abstract void	extractAndPopulateResult(InternalCompletableFuture future, MetaDataFetcher.ResultHolder resultHolder)
void	fetchMetadata(ConcurrentMap<String,RepairingHandler> handlers)
void	init(RepairingHandler handler)
protected void	initSequence(Collection<Map.Entry<String,List<Map.Entry<Integer,Long>>>> namePartitionSequenceList, RepairingHandler handler)
protected void	initUuid(Collection<Map.Entry<Integer,UUID>> uuids, RepairingHandler handler)
void	process(InternalCompletableFuture future, ConcurrentMap<String,RepairingHandler> handlers)
protected void	repairSequences(Collection<Map.Entry<String,List<Map.Entry<Integer,Long>>>> namePartitionSequenceList, ConcurrentMap<String,RepairingHandler> handlers)
protected void	repairUuids(Collection<Map.Entry<Integer,UUID>> uuids, ConcurrentMap<String,RepairingHandler> handlers)
protected abstract List<InternalCompletableFuture>	scanMembers(List<String> names)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

ASYNC_RESULT_WAIT_TIMEOUT_MINUTES

protected static final int ASYNC_RESULT_WAIT_TIMEOUT_MINUTES

See Also:

Constant Field Values

logger

protected final ILogger logger

Constructor Detail

MetaDataFetcher

public MetaDataFetcher(ILogger logger)

Method Detail

extractAndPopulateResult

protected abstract void extractAndPopulateResult(InternalCompletableFuture future,
                                                 MetaDataFetcher.ResultHolder resultHolder)
                                          throws Exception

Throws:

Exception

scanMembers

protected abstract List<InternalCompletableFuture> scanMembers(List<String> names)

init

public final void init(RepairingHandler handler)
                throws Exception

Throws:

Exception

process

public final void process(InternalCompletableFuture future,
                          ConcurrentMap<String,RepairingHandler> handlers)

fetchMetadata

public final void fetchMetadata(ConcurrentMap<String,RepairingHandler> handlers)

repairUuids

protected void repairUuids(Collection<Map.Entry<Integer,UUID>> uuids,
                           ConcurrentMap<String,RepairingHandler> handlers)

initUuid

protected void initUuid(Collection<Map.Entry<Integer,UUID>> uuids,
                        RepairingHandler handler)

repairSequences

protected void repairSequences(Collection<Map.Entry<String,List<Map.Entry<Integer,Long>>>> namePartitionSequenceList,
                               ConcurrentMap<String,RepairingHandler> handlers)

initSequence

protected void initSequence(Collection<Map.Entry<String,List<Map.Entry<Integer,Long>>>> namePartitionSequenceList,
                            RepairingHandler handler)