com.hazelcast.internal.nearcache.impl.invalidation

Class RepairingHandler

java.lang.Object

com.hazelcast.internal.nearcache.impl.invalidation.RepairingHandler

public final class RepairingHandler
extends Object

Handler used on near-cache side. Observes local and remote invalidations and registers relevant data to MetaDataContainers Used to repair near-cache in the event of invalidation-event-miss or partition uuid changes. Here repairing is done by making relevant near-cache data unreachable. To make stale data unreachable StaleReadDetectorImpl is used. An instance of this class is created per near-cache and can concurrently be used by many threads.

See Also:

StaleReadDetectorImpl

Constructor Summary

Constructors

Constructor and Description
RepairingHandler(String name, NearCache nearCache, MinimalPartitionService partitionService, String localUuid, ILogger logger)

Method Summary

Modifier and Type	Method and Description
void	checkOrRepairSequence(int partition, long nextSequence, boolean viaAntiEntropy) Checks nextSequence against current one.
void	checkOrRepairUuid(int partition, UUID newUuid)
MetaDataContainer	getMetaDataContainer(int partition)
String	getName()
void	handle(Collection<Data> keys, Collection<String> sourceUuids, Collection<UUID> partitionUuids, Collection<Long> sequences) Handles batch invalidations
void	handle(Data key, String sourceUuid, UUID partitionUuid, long sequence) Handles a single invalidation
void	initUnknownUuids(AtomicReferenceArray<UUID> partitionUuids)
String	toString()
void	updateLastKnownStaleSequence(MetaDataContainer metaData, int partition)

Methods inherited from class java.lang.Object

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

Constructor Detail

RepairingHandler

public RepairingHandler(String name,
                        NearCache nearCache,
                        MinimalPartitionService partitionService,
                        String localUuid,
                        ILogger logger)

Method Detail

initUnknownUuids

public void initUnknownUuids(AtomicReferenceArray<UUID> partitionUuids)

getMetaDataContainer

public MetaDataContainer getMetaDataContainer(int partition)

handle

public void handle(Data key,
                   String sourceUuid,
                   UUID partitionUuid,
                   long sequence)

Handles a single invalidation

handle

public void handle(Collection<Data> keys,
                   Collection<String> sourceUuids,
                   Collection<UUID> partitionUuids,
                   Collection<Long> sequences)

Handles batch invalidations

getName

public String getName()

updateLastKnownStaleSequence

public void updateLastKnownStaleSequence(MetaDataContainer metaData,
                                         int partition)

checkOrRepairUuid

public void checkOrRepairUuid(int partition,
                              UUID newUuid)

checkOrRepairSequence

public void checkOrRepairSequence(int partition,
                                  long nextSequence,
                                  boolean viaAntiEntropy)

Checks nextSequence against current one. And updates current sequence if next one is bigger.

toString

public String toString()

Overrides:

toString in class Object