org.infinispan.transaction.xa.recovery

Class RecoveryManagerImpl

java.lang.Object

org.infinispan.transaction.xa.recovery.RecoveryManagerImpl

All Implemented Interfaces:

RecoveryManager

public class RecoveryManagerImpl
extends Object
implements RecoveryManager

Default implementation for RecoveryManager

Since:

5.0

Author:

Mircea.Markus@jboss.com

Nested Class Summary

Nested classes/interfaces inherited from interface org.infinispan.transaction.xa.recovery.RecoveryManager

RecoveryManager.RecoveryIterator

Constructor Summary

Constructors

Constructor and Description
RecoveryManagerImpl(ConcurrentMap<RecoveryInfoKey,RecoveryAwareRemoteTransaction> recoveryHolder, String cacheName)

Method Summary

Modifier and Type	Method and Description
CompletionStage<String>	forceTransactionCompletion(XidImpl xid, boolean commit) Replays the given transaction by re-running the prepare and commit.
String	forceTransactionCompletionFromCluster(XidImpl xid, Address where, boolean commit) This method invokes RecoveryManager.forceTransactionCompletion(XidImpl, boolean) on the specified node.
Set<InDoubtTxInfo>	getInDoubtTransactionInfo() Same as RecoveryManager.getInDoubtTransactionInfoFromCluster(), but only returns transactions from the local node.
Set<InDoubtTxInfo>	getInDoubtTransactionInfoFromCluster() Returns a Set containing all the in-doubt transactions from the cluster, including the local node.
List<XidImpl>	getInDoubtTransactions() Local call that returns a list containing:
ConcurrentMap<RecoveryInfoKey,RecoveryAwareRemoteTransaction>	getInDoubtTransactionsMap()
RecoveryAwareRemoteTransaction	getPreparedTransaction(XidImpl xid) Local call returning the remote transaction identified by the supplied xid or null.
RecoveryManager.RecoveryIterator	getPreparedTransactionsFromCluster() Returns the list of transactions in prepared state from both local and remote cluster nodes.
void	init(RpcManager rpcManager, CommandsFactory commandsFactory, ComponentRef<TransactionTable> txTable, TransactionCoordinator txCoordinator, TransactionFactory txFactory)
boolean	isTransactionPrepared(GlobalTransaction globalTx) Checks both internal state and transaction table's state for the given tx.
void	registerInDoubtTransaction(RecoveryAwareRemoteTransaction remoteTransaction)
CompletionStage<Void>	removeRecoveryInformation(Collection<Address> lockOwners, XidImpl xid, GlobalTransaction gtx, boolean fromCluster) Removes from the specified nodes (or all nodes if the value of 'where' is null) the recovery information associated with these Xids.
RecoveryAwareTransaction	removeRecoveryInformation(Long internalId) Same as RecoveryManager.removeRecoveryInformation(XidImpl) but identifies the tx by its internal id.
RecoveryAwareTransaction	removeRecoveryInformation(XidImpl xid) Remove recovery information stored on this node (doesn't involve rpc).
CompletionStage<Void>	removeRecoveryInformationFromCluster(Collection<Address> where, long internalId) Same as RecoveryManager.removeRecoveryInformation(Collection, XidImpl, GlobalTransaction, boolean) but the transaction is identified by its internal id, and not by its xid.

Methods inherited from class java.lang.Object

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

Constructor Detail

RecoveryManagerImpl

public RecoveryManagerImpl(ConcurrentMap<RecoveryInfoKey,RecoveryAwareRemoteTransaction> recoveryHolder,
                           String cacheName)

Method Detail

init

public void init(RpcManager rpcManager,
                 CommandsFactory commandsFactory,
                 ComponentRef<TransactionTable> txTable,
                 TransactionCoordinator txCoordinator,
                 TransactionFactory txFactory)

getPreparedTransactionsFromCluster

public RecoveryManager.RecoveryIterator getPreparedTransactionsFromCluster()

Description copied from interface: RecoveryManager

Returns the list of transactions in prepared state from both local and remote cluster nodes. Implementation can take advantage of several optimisations:

• in order to get all tx from the cluster a broadcast is performed. This can be performed only once (assuming the call is successful), the first time this method is called. After that a local, cached list of tx prepared on this node is returned.
• during the broadcast just return the list of prepared transactions that are not originated on other active nodes of the cluster.

Specified by:

getPreparedTransactionsFromCluster in interface RecoveryManager

removeRecoveryInformation

public CompletionStage<Void> removeRecoveryInformation(Collection<Address> lockOwners,
                                                       XidImpl xid,
                                                       GlobalTransaction gtx,
                                                       boolean fromCluster)

Description copied from interface: RecoveryManager

Removes from the specified nodes (or all nodes if the value of 'where' is null) the recovery information associated with these Xids.

Specified by:

removeRecoveryInformation in interface RecoveryManager

Parameters:

lockOwners - on which nodes should this be executed.

xid - the list of xids to be removed.

gtx - the global transaction

fromCluster - true to remove the recovery information from all cluster.

removeRecoveryInformationFromCluster

public CompletionStage<Void> removeRecoveryInformationFromCluster(Collection<Address> where,
                                                                  long internalId)

Description copied from interface: RecoveryManager

Same as RecoveryManager.removeRecoveryInformation(Collection, XidImpl, GlobalTransaction, boolean) but the transaction is identified by its internal id, and not by its xid.

Specified by:

removeRecoveryInformationFromCluster in interface RecoveryManager

removeRecoveryInformation

public RecoveryAwareTransaction removeRecoveryInformation(XidImpl xid)

Description copied from interface: RecoveryManager

Remove recovery information stored on this node (doesn't involve rpc).

Specified by:

removeRecoveryInformation in interface RecoveryManager

See Also:

RecoveryManager.removeRecoveryInformation(Collection, XidImpl, GlobalTransaction, boolean)

removeRecoveryInformation

public RecoveryAwareTransaction removeRecoveryInformation(Long internalId)

Description copied from interface: RecoveryManager

Same as RecoveryManager.removeRecoveryInformation(XidImpl) but identifies the tx by its internal id.

Specified by:

removeRecoveryInformation in interface RecoveryManager

getInDoubtTransactions

public List<XidImpl> getInDoubtTransactions()

Description copied from interface: RecoveryManager

Local call that returns a list containing:

 - all the remote transactions prepared on this node for which the originator(i.e. the node where the tx
 stared) is no longer part of the cluster.
 AND
 - all the locally originated transactions which are prepared and for which the commit failed
 

Specified by:

getInDoubtTransactions in interface RecoveryManager

See Also:

RecoveryAwareRemoteTransaction.isInDoubt()

getInDoubtTransactionInfo

public Set<InDoubtTxInfo> getInDoubtTransactionInfo()

Description copied from interface: RecoveryManager

Same as RecoveryManager.getInDoubtTransactionInfoFromCluster(), but only returns transactions from the local node.

Specified by:

getInDoubtTransactionInfo in interface RecoveryManager

getInDoubtTransactionInfoFromCluster

public Set<InDoubtTxInfo> getInDoubtTransactionInfoFromCluster()

Description copied from interface: RecoveryManager

Returns a Set containing all the in-doubt transactions from the cluster, including the local node. This does not include transactions that are prepared successfully and for which the originator is still in the cluster.

Specified by:

getInDoubtTransactionInfoFromCluster in interface RecoveryManager

See Also:

InDoubtTxInfo

registerInDoubtTransaction

public void registerInDoubtTransaction(RecoveryAwareRemoteTransaction remoteTransaction)

Specified by:

registerInDoubtTransaction in interface RecoveryManager

getPreparedTransaction

public RecoveryAwareRemoteTransaction getPreparedTransaction(XidImpl xid)

Description copied from interface: RecoveryManager

Local call returning the remote transaction identified by the supplied xid or null.

Specified by:

getPreparedTransaction in interface RecoveryManager

forceTransactionCompletion

public CompletionStage<String> forceTransactionCompletion(XidImpl xid,
                                                          boolean commit)

Description copied from interface: RecoveryManager

Replays the given transaction by re-running the prepare and commit. This call expects the transaction to exist on this node either as a local or remote transaction.

Specified by:

forceTransactionCompletion in interface RecoveryManager

Parameters:

xid - tx to commit or rollback

commit - if true tx is committed, if false it is rolled back

forceTransactionCompletionFromCluster

public String forceTransactionCompletionFromCluster(XidImpl xid,
                                                    Address where,
                                                    boolean commit)

Description copied from interface: RecoveryManager

This method invokes RecoveryManager.forceTransactionCompletion(XidImpl, boolean) on the specified node.

Specified by:

forceTransactionCompletionFromCluster in interface RecoveryManager

isTransactionPrepared

public boolean isTransactionPrepared(GlobalTransaction globalTx)

Description copied from interface: RecoveryManager

Checks both internal state and transaction table's state for the given tx. If it finds it, returns true if tx is prepared.

Specified by:

isTransactionPrepared in interface RecoveryManager

getInDoubtTransactionsMap

public ConcurrentMap<RecoveryInfoKey,RecoveryAwareRemoteTransaction> getInDoubtTransactionsMap()