org.gridgain.grid.kernal.processors.cache

Class GridCacheEventManager<K,V>

java.lang.Object

org.gridgain.grid.kernal.processors.cache.GridCacheManagerAdapter<K,V>

org.gridgain.grid.kernal.processors.cache.GridCacheEventManager<K,V>

All Implemented Interfaces:

GridCacheManager<K,V>

public class GridCacheEventManager<K,V>
extends GridCacheManagerAdapter<K,V>

Cache event manager.

Field Summary

Fields inherited from class org.gridgain.grid.kernal.processors.cache.GridCacheManagerAdapter

cctx, log

Constructor Summary

Constructors

Constructor and Description
GridCacheEventManager()

Method Summary

Methods

Modifier and Type	Method and Description
void	addEvent(int part, K key, GridCacheTx tx, GridCacheMvccCandidate<K> owner, int type, V newVal, boolean hasNewVal, V oldVal, boolean hasOldVal, UUID subjId)
void	addEvent(int part, K key, UUID evtNodeId, GridCacheMvccCandidate<K> owner, int type, V newVal, boolean hasNewVal, V oldVal, boolean hasOldVal, UUID subjId)
void	addEvent(int part, K key, UUID nodeId, GridCacheTx tx, GridCacheMvccCandidate<K> owner, int type, V newVal, boolean hasNewVal, V oldVal, boolean hasOldVal, UUID subjId)
void	addEvent(int part, K key, UUID evtNodeId, GridUuid xid, Object lockId, int type, V newVal, boolean hasNewVal, V oldVal, boolean hasOldVal, UUID subjId)
void	addListener(GridLocalEventListener lsnr, int... evts) Adds local event listener.
void	addPreloadEvent(int part, int type, GridNode discoNode, int discoType, long discoTs) Adds preloading event.
void	addUnloadEvent(int part) Adds partition unload event.
boolean	isRecordable(int type)
void	printMemoryStats() Prints memory statistics (sizes of internal data structures, etc.).
void	removeListener(GridLocalEventListener lsnr) Removes local event listener.
void	start0()

Methods inherited from class org.gridgain.grid.kernal.processors.cache.GridCacheManagerAdapter

context, kernalStartInfo, kernalStopInfo, log, onKernalStart, onKernalStart0, onKernalStop, onKernalStop0, start, startInfo, stop, stop0, stopInfo, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

GridCacheEventManager

public GridCacheEventManager()

Method Detail

start0

public void start0()

Overrides:

start0 in class GridCacheManagerAdapter<K,V>

addListener

public void addListener(GridLocalEventListener lsnr,
               int... evts)

Adds local event listener.

Parameters:

lsnr - Listener.

evts - Types of events.

removeListener

public void removeListener(GridLocalEventListener lsnr)

Removes local event listener.

Parameters:

lsnr - Local event listener.

addEvent

public void addEvent(int part,
            K key,
            GridCacheTx tx,
            @Nullable
            GridCacheMvccCandidate<K> owner,
            int type,
            @Nullable
            V newVal,
            boolean hasNewVal,
            @Nullable
            V oldVal,
            boolean hasOldVal,
            UUID subjId)

Parameters:

part - Partition.

key - Key for the event.

tx - Possible surrounding transaction.

owner - Possible surrounding lock.

type - Event type.

newVal - New value.

hasNewVal - Whether new value is present or not.

oldVal - Old value.

hasOldVal - Whether old value is present or not.

addEvent

public void addEvent(int part,
            K key,
            UUID nodeId,
            GridCacheTx tx,
            GridCacheMvccCandidate<K> owner,
            int type,
            V newVal,
            boolean hasNewVal,
            V oldVal,
            boolean hasOldVal,
            UUID subjId)

Parameters:

part - Partition.

key - Key for the event.

nodeId - Node ID.

tx - Possible surrounding transaction.

owner - Possible surrounding lock.

type - Event type.

newVal - New value.

hasNewVal - Whether new value is present or not.

oldVal - Old value.

hasOldVal - Whether old value is present or not.

addEvent

public void addEvent(int part,
            K key,
            UUID evtNodeId,
            @Nullable
            GridCacheMvccCandidate<K> owner,
            int type,
            @Nullable
            V newVal,
            boolean hasNewVal,
            V oldVal,
            boolean hasOldVal,
            UUID subjId)

Parameters:

part - Partition.

key - Key for the event.

evtNodeId - Node ID.

owner - Possible surrounding lock.

type - Event type.

newVal - New value.

hasNewVal - Whether new value is present or not.

oldVal - Old value.

hasOldVal - Whether old value is present or not.

addEvent

public void addEvent(int part,
            K key,
            UUID evtNodeId,
            @Nullable
            GridUuid xid,
            @Nullable
            Object lockId,
            int type,
            @Nullable
            V newVal,
            boolean hasNewVal,
            @Nullable
            V oldVal,
            boolean hasOldVal,
            UUID subjId)

Parameters:

part - Partition.

key - Key for the event.

evtNodeId - Event node ID.

xid - Transaction ID.

lockId - Lock ID.

type - Event type.

newVal - New value.

hasNewVal - Whether new value is present or not.

oldVal - Old value.

hasOldVal - Whether old value is present or not.

addPreloadEvent

public void addPreloadEvent(int part,
                   int type,
                   GridNode discoNode,
                   int discoType,
                   long discoTs)

Adds preloading event.

Parameters:

part - Partition.

type - Event type.

discoNode - Discovery node.

discoType - Discovery event type.

discoTs - Discovery event timestamp.

addUnloadEvent

public void addUnloadEvent(int part)

Adds partition unload event.

Parameters:

part - Partition.

isRecordable

public boolean isRecordable(int type)

Parameters:

type - Event type.

Returns:

True if event is recordable.

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>

Overrides:

printMemoryStats in class GridCacheManagerAdapter<K,V>