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-end 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	RECONCILIATION_INTERVAL_SECONDS

Constructor Summary

Constructors

Constructor and Description
RepairingTask(MetaDataFetcher metaDataFetcher, ExecutionService executionService, MinimalPartitionService partitionService, HazelcastProperties properties, String localUuid, ILogger logger)

Method Summary

Modifier and Type	Method and Description
protected int	checkMaxToleratedMissCount(HazelcastProperties properties)
void	deregisterHandler(String mapName)
<K,V> RepairingHandler	registerAndGetHandler(String name, 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

Constructor Detail

RepairingTask

public RepairingTask(MetaDataFetcher metaDataFetcher,
                     ExecutionService executionService,
                     MinimalPartitionService partitionService,
                     HazelcastProperties properties,
                     String localUuid,
                     ILogger logger)

Method Detail

checkMaxToleratedMissCount

protected int checkMaxToleratedMissCount(HazelcastProperties properties)

run

public void run()

Specified by:

run in interface Runnable

registerAndGetHandler

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

deregisterHandler

public void deregisterHandler(String mapName)

toString

public String toString()

Overrides:

toString in class Object