Package org.infinispan.transaction.impl

Class TransactionTable

java.lang.Object

org.infinispan.transaction.impl.TransactionTable

All Implemented Interfaces:

TransactionTable

Direct Known Subclasses:

XaTransactionTable

public class TransactionTable
extends Object
implements TransactionTable

Repository for RemoteTransaction and TransactionXaAdapters (locally originated transactions).

Since:

4.0

Author:

Mircea.Markus@jboss.com, Galder Zamarreño

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TransactionTable.CompletedTransactionStatus

Field Summary

Fields

Modifier and Type	Field	Description
static int	CACHE_STOPPED_TOPOLOGY_ID
protected boolean	clustered
protected CommandsFactory	commandsFactory
protected Configuration	configuration
protected PartitionHandlingManager	partitionHandlingManager
protected RpcManager	rpcManager
protected boolean	running
protected TransactionCoordinator	txCoordinator

Constructor Summary

Constructors

Constructor	Description
TransactionTable()

Method Summary

Modifier and Type	Method	Description
void	afterCompletion(LocalTransaction localTransaction, int status)
int	beforeCompletion(LocalTransaction localTransaction)
void	cleanupLeaverTransactions(List<Address> members)
boolean	containRemoteTx(GlobalTransaction globalTransaction)
boolean	containsLocalTx(GlobalTransaction globalTransaction)
void	enlist(Transaction transaction, LocalTransaction localTransaction)
void	enlistClientTransaction(Transaction transaction, LocalTransaction localTransaction)
void	failureCompletingTransaction(Transaction tx)
TransactionTable.CompletedTransactionStatus	getCompletedTransactionStatus(GlobalTransaction gtx)
GlobalTransaction	getGlobalTransaction(Transaction transaction)
Collection<GlobalTransaction>	getLocalGlobalTransaction()
LocalTransaction	getLocalTransaction(Transaction tx)
LocalTransaction	getLocalTransaction(GlobalTransaction txId)	Looks up a LocalTransaction given a GlobalTransaction.
Collection<LocalTransaction>	getLocalTransactions()
int	getLocalTxCount()
int	getMinTopologyId()
LocalTransaction	getOrCreateLocalTransaction(Transaction transaction, boolean implicitTransaction)	Returns the TransactionXaAdapter corresponding to the supplied transaction.
LocalTransaction	getOrCreateLocalTransaction(Transaction transaction, boolean implicitTransaction, Supplier<GlobalTransaction> gtxFactory)	Similar to getOrCreateLocalTransaction(Transaction, boolean) but with a custom global transaction factory.
RemoteTransaction	getOrCreateRemoteTransaction(GlobalTransaction globalTx, org.infinispan.commands.write.WriteCommand[] modifications)	Returns an existing remote transaction or creates one if none exists.
Collection<GlobalTransaction>	getRemoteGlobalTransaction()
RemoteTransaction	getRemoteTransaction(GlobalTransaction txId)	Returns the RemoteTransaction associated with the supplied transaction id.
Collection<RemoteTransaction>	getRemoteTransactions()
int	getRemoteTxCount()
boolean	isTransactionCompleted(GlobalTransaction gtx)
void	localTransactionPrepared(LocalTransaction localTransaction)
void	markTransactionCompleted(GlobalTransaction gtx, boolean successful)	With the current state transfer implementation it is possible for a transaction to be prepared several times on a remote node.
void	onTopologyChange(TopologyChangedEvent<?,?> tce)
void	onViewChange(ViewChangedEvent e)
protected void	recalculateMinTopologyIdIfNeeded(CacheTransaction removedTransaction)
protected void	releaseLocksForCompletedTransaction(LocalTransaction localTransaction, boolean committedInOnePhase)
void	remoteTransactionCommitted(GlobalTransaction gtx, boolean onePc)	Removes the RemoteTransaction corresponding to the given tx.
void	remoteTransactionPrepared(GlobalTransaction gtx)
void	remoteTransactionRollback(GlobalTransaction gtx)
boolean	removeLocalTransaction(LocalTransaction localTransaction)	Removes the TransactionXaAdapter corresponding to the given tx.
RemoteTransaction	removeRemoteTransaction(GlobalTransaction txId)
void	start()

Methods inherited from class java.lang.Object

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

Field Detail

CACHE_STOPPED_TOPOLOGY_ID

public static final int CACHE_STOPPED_TOPOLOGY_ID

See Also:

Constant Field Values

configuration

protected Configuration configuration

txCoordinator

protected TransactionCoordinator txCoordinator

rpcManager

protected RpcManager rpcManager

commandsFactory

protected CommandsFactory commandsFactory

partitionHandlingManager

protected PartitionHandlingManager partitionHandlingManager

clustered

protected boolean clustered

running

protected volatile boolean running

Constructor Detail

TransactionTable

public TransactionTable()

Method Detail

start

public void start()

getGlobalTransaction

public GlobalTransaction getGlobalTransaction(Transaction transaction)

Specified by:

getGlobalTransaction in interface TransactionTable

Parameters:

transaction - the local transaction. Must be non-null.

Returns:

the GlobalTransaction associated with the transaction or null if doesn't exists.

getLocalGlobalTransaction

public Collection<GlobalTransaction> getLocalGlobalTransaction()

Specified by:

getLocalGlobalTransaction in interface TransactionTable

Returns:

an unmodified collection of GlobalTransaction associated with local running transactions.

getRemoteGlobalTransaction

public Collection<GlobalTransaction> getRemoteGlobalTransaction()

Specified by:

getRemoteGlobalTransaction in interface TransactionTable

Returns:

an unmodified collection of GlobalTransaction associated with remote transactions.

remoteTransactionPrepared

public void remoteTransactionPrepared(GlobalTransaction gtx)

localTransactionPrepared

public void localTransactionPrepared(LocalTransaction localTransaction)

enlist

public void enlist(Transaction transaction,
                   LocalTransaction localTransaction)

enlistClientTransaction

public void enlistClientTransaction(Transaction transaction,
                                    LocalTransaction localTransaction)

failureCompletingTransaction

public void failureCompletingTransaction(Transaction tx)

getMinTopologyId

public int getMinTopologyId()

cleanupLeaverTransactions

public void cleanupLeaverTransactions(List<Address> members)

getRemoteTransaction

public RemoteTransaction getRemoteTransaction(GlobalTransaction txId)

Returns the RemoteTransaction associated with the supplied transaction id. Returns null if no such association exists.

remoteTransactionRollback

public void remoteTransactionRollback(GlobalTransaction gtx)

getOrCreateRemoteTransaction

public RemoteTransaction getOrCreateRemoteTransaction(GlobalTransaction globalTx,
                                                      org.infinispan.commands.write.WriteCommand[] modifications)

Returns an existing remote transaction or creates one if none exists. Atomicity: this method supports concurrent invocations, guaranteeing that all threads will see the same transaction object.

getOrCreateLocalTransaction

public LocalTransaction getOrCreateLocalTransaction(Transaction transaction,
                                                    boolean implicitTransaction)

Returns the TransactionXaAdapter corresponding to the supplied transaction. If none exists, will be created first.

getOrCreateLocalTransaction

public LocalTransaction getOrCreateLocalTransaction(Transaction transaction,
                                                    boolean implicitTransaction,
                                                    Supplier<GlobalTransaction> gtxFactory)

Similar to getOrCreateLocalTransaction(Transaction, boolean) but with a custom global transaction factory.

removeLocalTransaction

public boolean removeLocalTransaction(LocalTransaction localTransaction)

Removes the TransactionXaAdapter corresponding to the given tx. Returns true if such an tx exists.

remoteTransactionCommitted

public void remoteTransactionCommitted(GlobalTransaction gtx,
                                       boolean onePc)

Removes the RemoteTransaction corresponding to the given tx.

removeRemoteTransaction

public final RemoteTransaction removeRemoteTransaction(GlobalTransaction txId)

getRemoteTxCount

public int getRemoteTxCount()

getLocalTxCount

public int getLocalTxCount()

getLocalTransaction

public LocalTransaction getLocalTransaction(GlobalTransaction txId)

Looks up a LocalTransaction given a GlobalTransaction.

Parameters:

txId - the global transaction identifier

Returns:

the LocalTransaction or null if not found

containsLocalTx

public boolean containsLocalTx(GlobalTransaction globalTransaction)

getLocalTransaction

public LocalTransaction getLocalTransaction(Transaction tx)

containRemoteTx

public boolean containRemoteTx(GlobalTransaction globalTransaction)

getRemoteTransactions

public Collection<RemoteTransaction> getRemoteTransactions()

getLocalTransactions

public Collection<LocalTransaction> getLocalTransactions()

recalculateMinTopologyIdIfNeeded

protected final void recalculateMinTopologyIdIfNeeded(CacheTransaction removedTransaction)

onTopologyChange

public void onTopologyChange(TopologyChangedEvent<?,?> tce)

onViewChange

public void onViewChange(ViewChangedEvent e)

markTransactionCompleted

public void markTransactionCompleted(GlobalTransaction gtx,
                                     boolean successful)

With the current state transfer implementation it is possible for a transaction to be prepared several times on a remote node. This might cause leaks, e.g. if the transaction is prepared, committed and prepared again. Once marked as completed (because of commit or rollback) any further prepare received on that transaction are discarded.

isTransactionCompleted

public boolean isTransactionCompleted(GlobalTransaction gtx)

See Also:

markTransactionCompleted(org.infinispan.transaction.xa.GlobalTransaction, boolean)

getCompletedTransactionStatus

public TransactionTable.CompletedTransactionStatus getCompletedTransactionStatus(GlobalTransaction gtx)

See Also:

markTransactionCompleted(org.infinispan.transaction.xa.GlobalTransaction, boolean)

beforeCompletion

public int beforeCompletion(LocalTransaction localTransaction)

afterCompletion

public void afterCompletion(LocalTransaction localTransaction,
                            int status)

releaseLocksForCompletedTransaction

protected final void releaseLocksForCompletedTransaction(LocalTransaction localTransaction,
                                                         boolean committedInOnePhase)