org.apache.ignite.internal.processors.cache.transactions

Class IgniteTxHandler

java.lang.Object

org.apache.ignite.internal.processors.cache.transactions.IgniteTxHandler

public class IgniteTxHandler
extends Object

Isolated logic to process cache messages.

Constructor Summary

Constructors

Constructor and Description
IgniteTxHandler(GridCacheSharedContext ctx)

Method Summary

Modifier and Type	Method and Description
void	applyPartitionsUpdatesCounters(Iterable<PartitionUpdateCountersMessage> counters) Applies partition counter updates for mvcc transactions.
List<PartitionUpdateCountersMessage>	filterUpdateCountersForBackupNode(IgniteInternalTx tx, ClusterNode node)
protected void	finish(GridDistributedTxRemoteAdapter tx, GridDhtTxPrepareRequest req)
IgniteInternalFuture<IgniteInternalTx>	finish(UUID nodeId, GridNearTxLocal locTx, GridNearTxFinishRequest req)
protected void	finish(UUID nodeId, IgniteTxRemoteEx tx, GridDhtTxFinishRequest req)
IgniteInternalFuture<IgniteInternalTx>	finishColocatedLocal(boolean commit, GridNearTxLocal tx)
void	mvccEnlistBatch(GridDhtTxRemote tx, GridCacheContext ctx, EnlistOperation op, List<KeyCacheObject> keys, List<Message> vals, MvccSnapshot snapshot, IgniteUuid futId, int batchNum) Writes updated values on the backup node.
IgniteInternalFuture<GridNearTxPrepareResponse>	prepareColocatedTx(GridNearTxLocal locTx, GridNearTxPrepareRequest req) Prepares local colocated tx.
IgniteInternalFuture<GridNearTxPrepareResponse>	prepareNearTxLocal(GridNearTxPrepareRequest req)
protected void	processCheckPreparedTxResponse(UUID nodeId, GridCacheTxRecoveryResponse res)

Methods inherited from class java.lang.Object

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

Constructor Detail

IgniteTxHandler

public IgniteTxHandler(GridCacheSharedContext ctx)

Parameters:

ctx - Shared cache context.

Method Detail

prepareColocatedTx

public IgniteInternalFuture<GridNearTxPrepareResponse> prepareColocatedTx(GridNearTxLocal locTx,
                                                                          GridNearTxPrepareRequest req)

Prepares local colocated tx.

Parameters:

locTx - Local transaction.

req - Near prepare request.

Returns:

Prepare future.

prepareNearTxLocal

public IgniteInternalFuture<GridNearTxPrepareResponse> prepareNearTxLocal(GridNearTxPrepareRequest req)

Parameters:

req - Request.

Returns:

Prepare future.

finish

@Nullable
public IgniteInternalFuture<IgniteInternalTx> finish(UUID nodeId,
                                                               @Nullable
                                                               GridNearTxLocal locTx,
                                                               GridNearTxFinishRequest req)

Parameters:

nodeId - Node ID.

locTx - Local transaction.

req - Request.

Returns:

Future.

finishColocatedLocal

public IgniteInternalFuture<IgniteInternalTx> finishColocatedLocal(boolean commit,
                                                                   GridNearTxLocal tx)

Parameters:

commit - Commit flag (rollback if false).

tx - Transaction to commit.

Returns:

Future.

finish

protected void finish(UUID nodeId,
                      IgniteTxRemoteEx tx,
                      GridDhtTxFinishRequest req)

Parameters:

nodeId - Node ID.

tx - Transaction.

req - Request.

finish

protected void finish(GridDistributedTxRemoteAdapter tx,
                      GridDhtTxPrepareRequest req)
               throws IgniteTxHeuristicCheckedException

Parameters:

tx - Transaction.

req - Request.

Throws:

IgniteTxHeuristicCheckedException

mvccEnlistBatch

public void mvccEnlistBatch(GridDhtTxRemote tx,
                            GridCacheContext ctx,
                            EnlistOperation op,
                            List<KeyCacheObject> keys,
                            List<Message> vals,
                            MvccSnapshot snapshot,
                            IgniteUuid futId,
                            int batchNum)
                     throws IgniteCheckedException

Writes updated values on the backup node.

Parameters:

tx - Transaction.

ctx - Cache context.

op - Operation.

keys - Keys.

vals - Values sent from the primary node.

snapshot - Mvcc snapshot.

batchNum - Batch number.

futId - Future id.

Throws:

IgniteCheckedException - If failed.

processCheckPreparedTxResponse

protected void processCheckPreparedTxResponse(UUID nodeId,
                                              GridCacheTxRecoveryResponse res)

Parameters:

nodeId - Node ID.

res - Response.

applyPartitionsUpdatesCounters

public void applyPartitionsUpdatesCounters(Iterable<PartitionUpdateCountersMessage> counters)

Applies partition counter updates for mvcc transactions.

Parameters:

counters - Counter values to be updated.

filterUpdateCountersForBackupNode

@Nullable
public List<PartitionUpdateCountersMessage> filterUpdateCountersForBackupNode(IgniteInternalTx tx,
                                                                                        ClusterNode node)

Parameters:

tx - Transaction.

node - Backup node.

Returns:

Partition counters for the given backup node.