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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	deregisterHandler(String mapName)
ConcurrentMap<String,RepairingHandler>	getHandlers()
MetaDataFetcher	getMetaDataFetcher()
<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

Constructor Detail

RepairingTask

public RepairingTask(HazelcastProperties properties,
                     MetaDataFetcher metaDataFetcher,
                     TaskScheduler scheduler,
                     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 name,
                                                    NearCache<K,V> nearCache)

deregisterHandler

public void deregisterHandler(String mapName)

getMetaDataFetcher

public MetaDataFetcher getMetaDataFetcher()

getHandlers

public ConcurrentMap<String,RepairingHandler> getHandlers()

toString

public String toString()

Overrides:

toString in class Object