com.hazelcast.internal.nearcache.impl.invalidation

Class RepairingTask

java.lang.Object

com.hazelcast.internal.nearcache.impl.invalidation.RepairingTask

All Implemented Interfaces:

Runnable

public final class RepairingTask
extends Object
implements Runnable

This task runs on Near Cache side and only one instance is created per data-structure type like IMap and ICache.

Repairing responsibilities of this task are:

• To scan RepairingHandlers to see if any Near Cache needs to be invalidated according to missed invalidation counts (controlled via MAX_TOLERATED_MISS_COUNT).
• To send periodic generic-operations to cluster members in order to fetch latest partition sequences and UUIDs (controlled via MIN_RECONCILIATION_INTERVAL_SECONDS).

Field Summary

Fields

Modifier and Type	Field and Description
static HazelcastProperty	MAX_TOLERATED_MISS_COUNT
static HazelcastProperty	MIN_RECONCILIATION_INTERVAL_SECONDS
static HazelcastProperty	RECONCILIATION_INTERVAL_SECONDS

Constructor Summary

Constructors

Constructor and Description
RepairingTask(HazelcastProperties properties, InvalidationMetaDataFetcher invalidationMetaDataFetcher, TaskScheduler scheduler, SerializationService serializationService, MinimalPartitionService partitionService, String localUuid, ILogger logger)

Method Summary

Modifier and Type	Method and Description
void	deregisterHandler(String dataStructureName)
ConcurrentMap<String,RepairingHandler>	getHandlers()
InvalidationMetaDataFetcher	getInvalidationMetaDataFetcher()
<K,V> RepairingHandler	registerAndGetHandler(String dataStructureName, NearCache<K,V> nearCache)
void	run()
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

MAX_TOLERATED_MISS_COUNT

public static final HazelcastProperty MAX_TOLERATED_MISS_COUNT

RECONCILIATION_INTERVAL_SECONDS

public static final HazelcastProperty RECONCILIATION_INTERVAL_SECONDS

MIN_RECONCILIATION_INTERVAL_SECONDS

public static final HazelcastProperty MIN_RECONCILIATION_INTERVAL_SECONDS

Constructor Detail

RepairingTask

public RepairingTask(HazelcastProperties properties,
                     InvalidationMetaDataFetcher invalidationMetaDataFetcher,
                     TaskScheduler scheduler,
                     SerializationService serializationService,
                     MinimalPartitionService partitionService,
                     String localUuid,
                     ILogger logger)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

registerAndGetHandler

public <K,V> RepairingHandler registerAndGetHandler(String dataStructureName,
                                                    NearCache<K,V> nearCache)

deregisterHandler

public void deregisterHandler(String dataStructureName)

getInvalidationMetaDataFetcher

public InvalidationMetaDataFetcher getInvalidationMetaDataFetcher()

getHandlers

public ConcurrentMap<String,RepairingHandler> getHandlers()

toString

public String toString()

Overrides:

toString in class Object