org.gridgain.grid.kernal.processors.cache.dr.os

Class GridOsCacheDrManager<K,V>

java.lang.Object

org.gridgain.grid.kernal.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
int	backupQueueSize()
int	batchWaitingAcknowledgeCount()
int	batchWaitingSendCount()
void	beforeExchange(long topVer, boolean left) Process partitions "before exchange" event.
GridDrStatus	drPauseState() Get DR pause state.
Collection<GridDrStateTransferDescriptor>	listStateTransfers() List currently active state transfers.
void	onKernalStart()
void	onKernalStop(boolean cancel)
void	partitionEvicted(int part) In case some partition is evicted, we remove entries of this partition from backup queue.
void	pause() Pauses data center replication.
void	printMemoryStats() Prints memory statistics (sizes of internal data structures, etc.).
int	queuedKeysCount()
void	replicate(GridDrRawEntry<K,V> entry, GridDrType drType) Perform replication.
void	resume() Resumes data center replication.
int	senderHubsCount()
void	start(GridCacheContext<K,V> cctx) Starts manager.
GridFuture<?>	stateTransfer(Collection<Byte> dataCenterIds) Initiate state transfer.
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

start

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

Starts manager.

Specified by:

start in interface GridCacheManager<K,V>

Parameters:

cctx - Context.

Throws:

GridException - 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 GridException

Specified by:

onKernalStart in interface GridCacheManager<K,V>

Throws:

GridException - 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>

replicate

public void replicate(GridDrRawEntry<K,V> entry,
             GridDrType drType)

Perform replication.

Specified by:

replicate in interface GridCacheDrManager<K,V>

Parameters:

entry - Replication entry.

drType - Replication type.

beforeExchange

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

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:

GridException - 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.

stateTransfer

public GridFuture<?> stateTransfer(Collection<Byte> dataCenterIds)

Initiate state transfer.

Specified by:

stateTransfer in interface GridCacheDrManager<K,V>

Parameters:

dataCenterIds - Target data center IDs.

Returns:

Future that will be completed when all state transfer batches are sent.

listStateTransfers

public Collection<GridDrStateTransferDescriptor> listStateTransfers()
                                                             throws GridException

List currently active state transfers.

Specified by:

listStateTransfers in interface GridCacheDrManager<K,V>

Returns:

List of currently active state transfers.

Throws:

GridException - If failed.

pause

public void pause()
           throws GridException

Pauses data center replication.

Specified by:

pause in interface GridCacheDrManager<K,V>

Throws:

GridException - If failed.

resume

public void resume()
            throws GridException

Resumes data center replication.

Specified by:

resume in interface GridCacheDrManager<K,V>

Throws:

GridException - If failed.

drPauseState

public GridDrStatus drPauseState()

Get DR pause state.

Specified by:

drPauseState in interface GridCacheDrManager<K,V>

Returns:

DR pause state.

queuedKeysCount

public int queuedKeysCount()

Specified by:

queuedKeysCount in interface GridCacheDrManager<K,V>

Returns:

Count of keys enqueued for data center replication.

backupQueueSize

public int backupQueueSize()

Specified by:

backupQueueSize in interface GridCacheDrManager<K,V>

Returns:

Size of backup data center replication queue.

batchWaitingSendCount

public int batchWaitingSendCount()

Specified by:

batchWaitingSendCount in interface GridCacheDrManager<K,V>

Returns:

Count of data center replication batches awaiting to be send.

batchWaitingAcknowledgeCount

public int batchWaitingAcknowledgeCount()

Specified by:

batchWaitingAcknowledgeCount in interface GridCacheDrManager<K,V>

Returns:

Count of data center replication batches awaiting acknowledge from sender hub.

senderHubsCount

public int senderHubsCount()

Specified by:

senderHubsCount in interface GridCacheDrManager<K,V>

Returns:

Count of available sender hubs.