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 missed invalidation events 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(ILogger logger, String localUuid, String name, NearCache nearCache, SerializationService serializationService, MinimalPartitionService partitionService)

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	initSequence(int partitionID, long partitionSequence)
void	initUuid(int partitionID, UUID partitionUuid)
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(ILogger logger,
                        String localUuid,
                        String name,
                        NearCache nearCache,
                        SerializationService serializationService,
                        MinimalPartitionService partitionService)

Method Detail

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

initUuid

public void initUuid(int partitionID,
                     UUID partitionUuid)

initSequence

public void initSequence(int partitionID,
                         long partitionSequence)