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

Class GridOsCacheDrManager<K,V>

java.lang.Object

org.apache.ignite.internal.processors.cache.dr.os.GridOsCacheDrManager<K,V>

All Implemented Interfaces:

GridCacheDrManager<K,V>, GridCacheManager<K,V>

public class GridOsCacheDrManager<K,V>
extends Object
implements GridCacheDrManager<K,V>

No-op implementation for GridCacheDrManager.

Constructor Summary

Constructors

Constructor and Description
GridOsCacheDrManager()

Method Summary

Methods

Modifier and Type	Method and Description
void	beforeExchange(long topVer, boolean left) Process partitions "before exchange" event.
GridCacheVersionAbstractConflictResolver	conflictResolver()
byte	dataCenterId()
boolean	enabled()
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(K key, byte[] keyBytes, V val, byte[] valBytes, long ttl, long expireTime, GridCacheVersion ver, GridDrType drType) Performs replication.
void	resetMetrics() Resets metrics for current cache.
void	start(GridCacheContext<K,V> cctx) Starts manager.
void	stop(boolean cancel) 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<K,V>

Returns:

True is DR is enabled.

start

public void start(GridCacheContext<K,V> cctx)
           throws IgniteCheckedException

Starts manager.

Specified by:

start in interface GridCacheManager<K,V>

Parameters:

cctx - Context.

Throws:

IgniteCheckedException - If failed.

stop

public void stop(boolean cancel)

Stops manager.

Specified by:

stop in interface GridCacheManager<K,V>

Parameters:

cancel - Cancel flag.

onKernalStart

public void onKernalStart()
                   throws IgniteCheckedException

Specified by:

onKernalStart in interface GridCacheManager<K,V>

Throws:

IgniteCheckedException - If failed.

onKernalStop

public void onKernalStop(boolean cancel)

Specified by:

onKernalStop in interface GridCacheManager<K,V>

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<K,V>

dataCenterId

public byte dataCenterId()

Specified by:

dataCenterId in interface GridCacheDrManager<K,V>

Returns:

Data center ID.

conflictResolver

public GridCacheVersionAbstractConflictResolver conflictResolver()

Specified by:

conflictResolver in interface GridCacheDrManager<K,V>

Returns:

Cache version conflict resolver.

replicate

public void replicate(K key,
             @Nullable
             byte[] keyBytes,
             @Nullable
             V val,
             @Nullable
             byte[] valBytes,
             long ttl,
             long expireTime,
             GridCacheVersion ver,
             GridDrType drType)

Performs replication.

Specified by:

replicate in interface GridCacheDrManager<K,V>

Parameters:

key - Key.

keyBytes - Key bytes.

val - Value.

valBytes - Value bytes.

ttl - TTL.

expireTime - Expire time.

ver - Version.

drType - Replication type.

beforeExchange

public void beforeExchange(long topVer,
                  boolean left)
                    throws IgniteCheckedException

Process partitions "before exchange" event.

Specified by:

beforeExchange in interface GridCacheDrManager<K,V>

Parameters:

topVer - Topology version.

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

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<K,V>

Parameters:

part - Partition.

onReceiveCacheEntriesReceived

public void onReceiveCacheEntriesReceived(int entriesCnt)

Callback for received entries from receiver hub.

Specified by:

onReceiveCacheEntriesReceived in interface GridCacheDrManager<K,V>

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<K,V>

Parameters:

useNew - Use new.

useOld - Use old.

merge - Merge.

resetMetrics

public void resetMetrics()

Resets metrics for current cache.

Specified by:

resetMetrics in interface GridCacheDrManager<K,V>

receiveEnabled

public boolean receiveEnabled()

Specified by:

receiveEnabled in interface GridCacheDrManager<K,V>

Returns:

True if receives DR data.