|
Infinispan Distribution 5.2.6.Final-redhat-2 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.infinispan.transaction.TransactionTable
public class TransactionTable
Repository for RemoteTransaction
and TransactionXaAdapter
s (locally
originated transactions).
Field Summary | |
---|---|
static int |
CACHE_STOPPED_TOPOLOGY_ID
|
protected boolean |
clustered
|
protected ClusteringDependentLogic |
clusteringLogic
|
protected CommandsFactory |
commandsFactory
|
protected Configuration |
configuration
|
protected InvocationContextContainer |
icc
|
protected RpcManager |
rpcManager
|
protected TransactionCoordinator |
txCoordinator
|
protected TransactionFactory |
txFactory
|
Constructor Summary | |
---|---|
TransactionTable()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final int CACHE_STOPPED_TOPOLOGY_ID
protected Configuration configuration
protected InvocationContextContainer icc
protected TransactionCoordinator txCoordinator
protected TransactionFactory txFactory
protected RpcManager rpcManager
protected CommandsFactory commandsFactory
protected ClusteringDependentLogic clusteringLogic
protected boolean clustered
Constructor Detail |
---|
public TransactionTable()
Method Detail |
---|
public void initialize(RpcManager rpcManager, Configuration configuration, InvocationContextContainer icc, InterceptorChain invoker, CacheNotifier notifier, TransactionFactory gtf, TransactionCoordinator txCoordinator, TransactionSynchronizationRegistry transactionSynchronizationRegistry, CommandsFactory commandsFactory, ClusteringDependentLogic clusteringDependentLogic, Cache cache)
public Set<Object> getLockedKeysForRemoteTransaction(GlobalTransaction gtx)
public void remoteTransactionPrepared(GlobalTransaction gtx)
public void localTransactionPrepared(LocalTransaction localTransaction)
public void enlist(Transaction transaction, LocalTransaction localTransaction)
public void failureCompletingTransaction(Transaction tx)
public boolean containsLocalTx(Transaction tx)
tx
- if null false is returnedpublic int getMinTopologyId()
public void cleanupStaleTransactions(CacheTopology cacheTopology)
public RemoteTransaction getRemoteTransaction(GlobalTransaction txId)
RemoteTransaction
associated with the supplied transaction id. Returns null if no such
association exists.
public void remoteTransactionRollback(GlobalTransaction gtx)
public RemoteTransaction getOrCreateRemoteTransaction(GlobalTransaction globalTx, WriteCommand[] modifications)
public LocalTransaction getOrCreateLocalTransaction(Transaction transaction, TxInvocationContext ctx)
TransactionXaAdapter
corresponding to the supplied transaction.
If none exists, will be created first.
public boolean removeLocalTransaction(LocalTransaction localTransaction)
TransactionXaAdapter
corresponding to the given tx. Returns true
if such an tx exists.
protected final LocalTransaction removeLocalTransactionInternal(Transaction tx)
public void remoteTransactionCommitted(GlobalTransaction gtx)
RemoteTransaction
corresponding to the given tx.
public final RemoteTransaction removeRemoteTransaction(GlobalTransaction txId)
public int getRemoteTxCount()
public int getLocalTxCount()
public LocalTransaction getLocalTransaction(GlobalTransaction txId)
txId
- the global transaction identifier
public LocalTransaction getLocalTransaction(Transaction tx)
public boolean containRemoteTx(GlobalTransaction globalTransaction)
public Collection<RemoteTransaction> getRemoteTransactions()
public Collection<LocalTransaction> getLocalTransactions()
protected final void recalculateMinTopologyIdIfNeeded(CacheTransaction removedTransaction)
public void onTopologyChange(TopologyChangedEvent<?,?> tce)
public void markTransactionCompleted(GlobalTransaction globalTx)
public boolean isTransactionCompleted(GlobalTransaction gtx)
markTransactionCompleted(org.infinispan.transaction.xa.GlobalTransaction)
public void cleanupCompletedTransactions()
|
Infinispan Distribution 5.2.6.Final-redhat-2 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |