org.gridgain.grid.dr.store

Class DrAbstractSenderStore

java.lang.Object

org.gridgain.grid.dr.store.DrAbstractSenderStore

All Implemented Interfaces:

DrSenderStore

Direct Known Subclasses:

DrSenderFsStore, DrSenderInMemoryStore

public abstract class DrAbstractSenderStore
extends Object
implements DrSenderStore

Defines common methods to DrSenderStore implementations.

Field Summary

Fields

Modifier and Type	Field and Description
protected DrSenderStoreOverflowMode	overflowMode

Constructor Summary

Constructors

Constructor and Description
DrAbstractSenderStore()

Method Summary

Modifier and Type	Method and Description
void	clear() Removes all data from store and resets overflow flag to false.
protected abstract void	clear0() Remove all store data and reset store's state.
DrSenderStoreCursor	cursor(byte dataCenterId) Gets cursor for the given data center ID.
protected abstract DrSenderStoreCursor	cursor0(byte dataCenterId) Create new cursor for specified data center.
DrSenderStoreOverflowMode	getOverflowMode() Gets overflow mode defining how store will behave in case of overflow.
boolean	isOverflow() Get overflow state of the store.
protected void	onOverflow() Handle overflow.
void	setOverflowCallback(IgniteRunnable overflowCb) Sets overflow callback.
DrAbstractSenderStore	setOverflowMode(DrSenderStoreOverflowMode overflowMode) Sets overflow mode defining how store will behave in case of overflow.
void	store(byte[] dataCenterIds, byte[] data, int cnt, @Nullable IgniteUuid fstId) Store data.
protected abstract void	store0(byte[] dataCenterIds, byte[] data, int cnt, @Nullable IgniteUuid fstId) Add data to store.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.gridgain.grid.dr.store.DrSenderStore

sizeBytes, store

Field Detail

overflowMode

protected DrSenderStoreOverflowMode overflowMode

Constructor Detail

DrAbstractSenderStore

public DrAbstractSenderStore()

Method Detail

store

public void store(byte[] dataCenterIds,
                  byte[] data,
                  int cnt,
                  @Nullable
                  @Nullable IgniteUuid fstId)
           throws IgniteCheckedException

Store data.

Specified by:

store in interface DrSenderStore

Parameters:

dataCenterIds - Target data center ids.

data - Data center replication store entry.

cnt - How many entries are inside passed byte array.

fstId - Full state transfer id.

Throws:

DrSenderStoreOverflowException - If store is overflowed.

IgniteCheckedException - In case of failure.

cursor

public DrSenderStoreCursor cursor(byte dataCenterId)
                           throws IgniteCheckedException

Gets cursor for the given data center ID.

Specified by:

cursor in interface DrSenderStore

Parameters:

dataCenterId - Data center ID.

Returns:

Cursor over stored entries which belongs to that data center ID.

Throws:

IgniteCheckedException - If failed.

clear

public void clear()
           throws IgniteCheckedException

Removes all data from store and resets overflow flag to false.

Specified by:

clear in interface DrSenderStore

Throws:

IgniteCheckedException - If failed.

isOverflow

public boolean isOverflow()

Get overflow state of the store. Overflow means that some data lost.

Specified by:

isOverflow in interface DrSenderStore

Returns:

True if store is overflowed.

getOverflowMode

public DrSenderStoreOverflowMode getOverflowMode()

Gets overflow mode defining how store will behave in case of overflow. Default is DrSenderStoreOverflowMode.STOP

Returns:

Overflow mode.

setOverflowMode

public DrAbstractSenderStore setOverflowMode(DrSenderStoreOverflowMode overflowMode)

Sets overflow mode defining how store will behave in case of overflow. See getOverflowMode() for more information.

Parameters:

overflowMode - Overflow mode.

Returns:

this for chaining.

setOverflowCallback

public void setOverflowCallback(IgniteRunnable overflowCb)

Sets overflow callback. This callback is called on store overflow.

Parameters:

overflowCb - Overflow callback.

onOverflow

protected void onOverflow()
                   throws DrSenderStoreOverflowException

Handle overflow.

Throws:

DrSenderStoreOverflowException - If store is overflowed and mode is DrSenderStoreOverflowMode.STOP.

store0

protected abstract void store0(byte[] dataCenterIds,
                               byte[] data,
                               int cnt,
                               @Nullable
                               @Nullable IgniteUuid fstId)
                        throws IgniteCheckedException

Add data to store.

Parameters:

dataCenterIds - Data center id.

data - Data to store.

cnt - Entries count.

fstId - Full state transfer id.

Throws:

DrSenderStoreOverflowException - If store is overflowed and mode is DrSenderStoreOverflowMode.STOP.

IgniteCheckedException

cursor0

protected abstract DrSenderStoreCursor cursor0(byte dataCenterId)
                                        throws IgniteCheckedException

Create new cursor for specified data center.

Parameters:

dataCenterId - Data center id.

Returns:

New cursor.

Throws:

IgniteCheckedException - If fails.

clear0

protected abstract void clear0()
                        throws IgniteCheckedException

Remove all store data and reset store's state.

Throws:

IgniteCheckedException - If fails.