org.apache.ignite.internal.processors.cache.mvcc

Interface MvccProcessor

All Superinterfaces:

GridComponent, GridProcessor

All Known Implementing Classes:

MvccProcessorImpl

public interface MvccProcessor
extends GridProcessor

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.ignite.internal.GridComponent

GridComponent.DiscoveryDataExchangeType

Method Summary

Modifier and Type	Method and Description
void	ackQueryDone(MvccSnapshot snapshot, long qryId)
IgniteInternalFuture<Void>	ackTxCommit(MvccSnapshot updateVer)
void	ackTxRollback(MvccVersion updateVer)
void	addQueryTracker(MvccQueryTracker tracker)
Optional<? extends MvccVersion>	checkWaiting(MvccVersion mvccVer) Checks whether one tx is waiting for another tx.
@NotNull MvccCoordinator	currentCoordinator()
void	dumpDebugInfo(IgniteLogger log, @Nullable IgniteDiagnosticPrepareContext diagCtx)
void	ensureStarted() Starts MVCC processor (i.e. initialises data structures and vacuum) if it has not been started yet.
void	failWaiter(MvccVersion mvccVer, Exception e) Unfreezes waiter for specific version failing it with passed exception.
boolean	hasLocalTransaction(long crd, long cntr)
boolean	mvccEnabled()
void	onCacheStop(GridCacheContext cctx) Cache stop callback.
void	onExchangeDone(DiscoCache discoCache) Exchange done callback.
void	onLocalJoin(DiscoveryEvent evt, DiscoCache discoCache) Local join callback.
void	preProcessCacheConfiguration(CacheConfiguration ccfg) Pre-processes cache configuration before start.
void	registerLocalTransaction(long crd, long cntr)
void	releaseWaiters(MvccVersion locked)
void	removeQueryTracker(Long id)
IgniteInternalFuture<MvccSnapshot>	requestReadSnapshotAsync() Requests snapshot on Mvcc coordinator.
void	requestReadSnapshotAsync(MvccCoordinator crd, MvccSnapshotResponseListener lsnr) Requests snapshot on Mvcc coordinator.
MvccSnapshot	requestReadSnapshotLocal()
IgniteInternalFuture<MvccSnapshot>	requestWriteSnapshotAsync() Requests snapshot on Mvcc coordinator.
void	requestWriteSnapshotAsync(MvccCoordinator crd, MvccSnapshotResponseListener lsnr) Requests snapshot on Mvcc coordinator.
MvccSnapshot	requestWriteSnapshotLocal()
byte	state(long crdVer, long cntr)
byte	state(MvccVersion ver)
void	stopTxLog() Force txLog stop.
void	updateState(MvccVersion ver, byte state)
void	updateState(MvccVersion ver, byte state, boolean primary)
void	validateCacheConfiguration(CacheConfiguration ccfg) Validates cache configuration before start.
IgniteInternalFuture<Void>	waitForLock(GridCacheContext cctx, MvccVersion waiterVer, MvccVersion blockerVer) Stands in the lock wait queue for the current lock holder.

Methods inherited from interface org.apache.ignite.internal.GridComponent

collectGridNodeData, collectJoiningNodeData, discoveryDataType, onDisconnected, onGridDataReceived, onJoiningNodeDataReceived, onKernalStart, onKernalStop, onReconnected, printMemoryStats, start, stop, validateNode, validateNode

Method Detail

onLocalJoin

void onLocalJoin(DiscoveryEvent evt,
                 DiscoCache discoCache)

Local join callback.

Parameters:

evt - Discovery event.

discoCache - Disco cache.

onExchangeDone

void onExchangeDone(DiscoCache discoCache)

Exchange done callback.

Parameters:

discoCache - Disco cache.

currentCoordinator

@NotNull
@NotNull MvccCoordinator currentCoordinator()

Returns:

Coordinator.

state

byte state(long crdVer,
           long cntr)

Parameters:

crdVer - Mvcc coordinator version.

cntr - Mvcc counter.

Returns:

State for given mvcc version.

state

byte state(MvccVersion ver)

Parameters:

ver - Version to check.

Returns:

State for given mvcc version.

updateState

void updateState(MvccVersion ver,
                 byte state)

Parameters:

ver - Version.

state - State.

updateState

void updateState(MvccVersion ver,
                 byte state,
                 boolean primary)

Parameters:

ver - Version.

state - State.

primary - Flag if this is primary node.

registerLocalTransaction

void registerLocalTransaction(long crd,
                              long cntr)

Parameters:

crd - Mvcc coordinator version.

cntr - Mvcc counter.

hasLocalTransaction

boolean hasLocalTransaction(long crd,
                            long cntr)

Parameters:

crd - Mvcc coordinator version.

cntr - Mvcc counter.

Returns:

True if there is an active local transaction with given version.

waitForLock

IgniteInternalFuture<Void> waitForLock(GridCacheContext cctx,
                                       MvccVersion waiterVer,
                                       MvccVersion blockerVer)

Stands in the lock wait queue for the current lock holder.

Parameters:

cctx - Cache context.

waiterVer - Version of the waiting tx.

blockerVer - Version the entry is locked by.

Returns:

Future, which is completed as soon as the lock is released.

releaseWaiters

void releaseWaiters(MvccVersion locked)

Parameters:

locked - Version the entry is locked by.

checkWaiting

Optional<? extends MvccVersion> checkWaiting(MvccVersion mvccVer)

Checks whether one tx is waiting for another tx. It is assumed that locks on data nodes are requested one by one, so tx can wait only for one another tx here.

Parameters:

mvccVer - Version of transaction which is checked for being waiting.

Returns:

Version of tx which blocks checked tx.

failWaiter

void failWaiter(MvccVersion mvccVer,
                Exception e)

Unfreezes waiter for specific version failing it with passed exception.

Parameters:

mvccVer - Version of a waiter to fail.

e - Exception reflecting failure reason.

addQueryTracker

void addQueryTracker(MvccQueryTracker tracker)

Parameters:

tracker - Query tracker.

removeQueryTracker

void removeQueryTracker(Long id)

Parameters:

id - Query tracker id.

requestReadSnapshotLocal

MvccSnapshot requestReadSnapshotLocal()

Returns:

MvccSnapshot if this is a coordinator node and coordinator is initialized. Null in other cases.

requestReadSnapshotAsync

IgniteInternalFuture<MvccSnapshot> requestReadSnapshotAsync()

Requests snapshot on Mvcc coordinator.

Returns:

Result future.

requestReadSnapshotAsync

void requestReadSnapshotAsync(MvccCoordinator crd,
                              MvccSnapshotResponseListener lsnr)

Requests snapshot on Mvcc coordinator.

Parameters:

crd - Expected coordinator.

lsnr - Request listener.

requestWriteSnapshotLocal

MvccSnapshot requestWriteSnapshotLocal()

Returns:

MvccSnapshot if this is a coordinator node and coordinator is initialized. Null in other cases.

requestWriteSnapshotAsync

IgniteInternalFuture<MvccSnapshot> requestWriteSnapshotAsync()

Requests snapshot on Mvcc coordinator.

Returns:

Result future.

requestWriteSnapshotAsync

void requestWriteSnapshotAsync(MvccCoordinator crd,
                               MvccSnapshotResponseListener lsnr)

Requests snapshot on Mvcc coordinator.

Parameters:

crd - Expected coordinator.

lsnr - Request listener.

ackQueryDone

void ackQueryDone(MvccSnapshot snapshot,
                  long qryId)

Parameters:

snapshot - Query version.

qryId - Query tracker ID.

ackTxCommit

IgniteInternalFuture<Void> ackTxCommit(MvccSnapshot updateVer)

Parameters:

updateVer - Transaction update version.

Returns:

Acknowledge future.

ackTxRollback

void ackTxRollback(MvccVersion updateVer)

Parameters:

updateVer - Transaction update version.

mvccEnabled

boolean mvccEnabled()

Returns:

True if at least one cache with CacheAtomicityMode.TRANSACTIONAL_SNAPSHOT mode is registered.

preProcessCacheConfiguration

void preProcessCacheConfiguration(CacheConfiguration ccfg)

Pre-processes cache configuration before start.

Parameters:

ccfg - Cache configuration to pre-process.

validateCacheConfiguration

void validateCacheConfiguration(CacheConfiguration ccfg)
                         throws IgniteCheckedException

Validates cache configuration before start.

Parameters:

ccfg - Cache configuration to validate.

Throws:

IgniteCheckedException - If validation failed.

ensureStarted

void ensureStarted()
            throws IgniteCheckedException

Starts MVCC processor (i.e. initialises data structures and vacuum) if it has not been started yet.

Throws:

IgniteCheckedException - If failed to initialize.

onCacheStop

void onCacheStop(GridCacheContext cctx)

Cache stop callback.

Parameters:

cctx - Cache context.

stopTxLog

void stopTxLog()

Force txLog stop.

dumpDebugInfo

void dumpDebugInfo(IgniteLogger log,
                   @Nullable
                   @Nullable IgniteDiagnosticPrepareContext diagCtx)

Parameters:

log - Logger.

diagCtx - Diagnostic request.