org.gridgain.grid.kernal.processors.cache.distributed

Class GridCachePerThreadTxCommitBuffer<K,V>

java.lang.Object

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

All Implemented Interfaces:

GridCacheTxCommitBuffer<K,V>

public class GridCachePerThreadTxCommitBuffer<K,V>
extends Object
implements GridCacheTxCommitBuffer<K,V>

Committed tx buffer which should be used in synchronous commit mode.

Constructor Summary

Constructors

Constructor and Description
GridCachePerThreadTxCommitBuffer(GridCacheContext<K,V> cctx)

Method Summary

Methods

Modifier and Type	Method and Description
void	addCommittedTx(GridCacheTxEx<K,V> tx) Adds committed transaction to commit buffer.
GridCacheCommittedTxInfo<K,V>	committedTx(GridCacheVersion originatingTxVer, UUID nodeId, long threadId) Gets transaction from commit buffer.
void	onNodeLeft(UUID nodeId) Callback called when lode left grid.
int	size()

Methods inherited from class java.lang.Object

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

Constructor Detail

GridCachePerThreadTxCommitBuffer

public GridCachePerThreadTxCommitBuffer(GridCacheContext<K,V> cctx)

Parameters:

cctx - Cache context.

Method Detail

addCommittedTx

public void addCommittedTx(GridCacheTxEx<K,V> tx)

Adds committed transaction to commit buffer.

Specified by:

addCommittedTx in interface GridCacheTxCommitBuffer<K,V>

Parameters:

tx - Committed transaction.

committedTx

@Nullable
public GridCacheCommittedTxInfo<K,V> committedTx(GridCacheVersion originatingTxVer,
                                                 UUID nodeId,
                                                 long threadId)

Gets transaction from commit buffer.

Specified by:

committedTx in interface GridCacheTxCommitBuffer<K,V>

Parameters:

originatingTxVer - Originating tx version.

nodeId - Originating node ID.

threadId - Originating thread ID.

Returns:

Committed info, if any.

onNodeLeft

public void onNodeLeft(UUID nodeId)

Description copied from interface: GridCacheTxCommitBuffer

Callback called when lode left grid. Used to eventually cleanup the queue from committed tx info from left node.

Specified by:

onNodeLeft in interface GridCacheTxCommitBuffer<K,V>

Parameters:

nodeId - Left node ID.

size

public int size()

Specified by:

size in interface GridCacheTxCommitBuffer<K,V>

Returns:

Buffer size.