Package org.apache.ignite.internal.processors.cache.dr

Class GridOsCacheDrManager

java.lang.Object

org.apache.ignite.internal.processors.cache.dr.GridOsCacheDrManager

All Implemented Interfaces:

GridCacheDrManager, GridCacheManager

public class GridOsCacheDrManager
extends Object
implements GridCacheDrManager

No-op implementation for GridCacheDrManager.

Constructor Summary

Constructors

Constructor	Description
GridOsCacheDrManager()

Method Summary

Modifier and Type	Method	Description
byte	dataCenterId()
boolean	enabled()
void	onDisconnected(IgniteFuture reconnectFut)
void	onExchange(AffinityTopologyVersion topVer, boolean left, boolean activate)	Process partitions exchange event.
void	onKernalStart()
void	onKernalStop(boolean cancel)
void	onReceiveCacheConflictResolved(boolean useNew, boolean useOld, boolean merge)	Callback for manual conflict resolution.
void	onReceiveCacheEntriesReceived(int entriesCnt)	Callback for received entries from receiver hub.
void	partitionEvicted(int part)	In case some partition is evicted, we remove entries of this partition from backup queue.
void	printMemoryStats()	Prints memory statistics (sizes of internal data structures, etc.).
boolean	receiveEnabled()
void	replicate(KeyCacheObject key, @Nullable CacheObject val, long ttl, long expireTime, GridCacheVersion ver, GridDrType drType, AffinityTopologyVersion topVer)	Performs replication.
void	resetMetrics()	Resets metrics for current cache.
void	start(GridCacheContext cctx)	Starts manager.
void	stop(boolean cancel, boolean destroy)	Stops manager.

Methods inherited from class java.lang.Object

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

Constructor Detail

GridOsCacheDrManager

public GridOsCacheDrManager()

Method Detail

enabled

public boolean enabled()

Specified by:

enabled in interface GridCacheDrManager

Returns:

True is DR is enabled.

start

public void start(GridCacheContext cctx)
           throws IgniteCheckedException

Starts manager.

Specified by:

start in interface GridCacheManager

Parameters:

cctx - Context.

Throws:

IgniteCheckedException - If failed.

stop

public void stop(boolean cancel,
                 boolean destroy)

Stops manager.

Specified by:

stop in interface GridCacheManager

Parameters:

cancel - Cancel flag.

destroy - Cache destroy flag.

onKernalStart

public void onKernalStart()
                   throws IgniteCheckedException

Specified by:

onKernalStart in interface GridCacheManager

Throws:

IgniteCheckedException - If failed.

onKernalStop

public void onKernalStop(boolean cancel)

Specified by:

onKernalStop in interface GridCacheManager

Parameters:

cancel - Cancel flag.

printMemoryStats

public void printMemoryStats()

Prints memory statistics (sizes of internal data structures, etc.). NOTE: this method is for testing and profiling purposes only.

Specified by:

printMemoryStats in interface GridCacheManager

dataCenterId

public byte dataCenterId()

Specified by:

dataCenterId in interface GridCacheDrManager

Returns:

Data center ID.

replicate

public void replicate(KeyCacheObject key,
                      @Nullable
                      @Nullable CacheObject val,
                      long ttl,
                      long expireTime,
                      GridCacheVersion ver,
                      GridDrType drType,
                      AffinityTopologyVersion topVer)

Performs replication.

Specified by:

replicate in interface GridCacheDrManager

Parameters:

key - Key.

val - Value.

ttl - TTL.

expireTime - Expire time.

ver - Version.

drType - Replication type.

topVer - Topology version.

onExchange

public void onExchange(AffinityTopologyVersion topVer,
                       boolean left,
                       boolean activate)
                throws IgniteCheckedException

Process partitions exchange event.

Specified by:

onExchange in interface GridCacheDrManager

Parameters:

topVer - Topology version.

left - True if exchange has been caused by node leave.

activate - True if exchange has been caused by cluster activation.

Throws:

IgniteCheckedException - If failed.

partitionEvicted

public void partitionEvicted(int part)

In case some partition is evicted, we remove entries of this partition from backup queue.

Specified by:

partitionEvicted in interface GridCacheDrManager

Parameters:

part - Partition.

onReceiveCacheEntriesReceived

public void onReceiveCacheEntriesReceived(int entriesCnt)

Callback for received entries from receiver hub.

Specified by:

onReceiveCacheEntriesReceived in interface GridCacheDrManager

Parameters:

entriesCnt - Number of received entries.

onReceiveCacheConflictResolved

public void onReceiveCacheConflictResolved(boolean useNew,
                                           boolean useOld,
                                           boolean merge)

Callback for manual conflict resolution.

Specified by:

onReceiveCacheConflictResolved in interface GridCacheDrManager

Parameters:

useNew - Use new.

useOld - Use old.

merge - Merge.

resetMetrics

public void resetMetrics()

Resets metrics for current cache.

Specified by:

resetMetrics in interface GridCacheDrManager

receiveEnabled

public boolean receiveEnabled()

Specified by:

receiveEnabled in interface GridCacheDrManager

Returns:

True if receives DR data.

onDisconnected

public void onDisconnected(IgniteFuture reconnectFut)

Specified by:

onDisconnected in interface GridCacheManager

Parameters:

reconnectFut - Reconnect future.