Methods
Modifier and Type |
Method and Description |
void |
cleanupCompletedTransactions() |
void |
cleanupStaleTransactions(CacheTopology cacheTopology) |
boolean |
containRemoteTx(GlobalTransaction globalTransaction) |
boolean |
containsLocalTx(GlobalTransaction globalTransaction) |
boolean |
containsLocalTx(Transaction tx)
Returns true if the given transaction is already registered with the transaction table.
|
void |
enlist(Transaction transaction,
LocalTransaction localTransaction) |
void |
failureCompletingTransaction(Transaction tx) |
LocalTransaction |
getLocalTransaction(GlobalTransaction txId)
Looks up a LocalTransaction given a GlobalTransaction.
|
LocalTransaction |
getLocalTransaction(Transaction tx) |
Collection<LocalTransaction> |
getLocalTransactions() |
int |
getLocalTxCount() |
Set<Object> |
getLockedKeysForRemoteTransaction(GlobalTransaction gtx) |
int |
getMinTopologyId() |
LocalTransaction |
getOrCreateLocalTransaction(Transaction transaction,
TxInvocationContext ctx)
|
RemoteTransaction |
getOrCreateRemoteTransaction(GlobalTransaction globalTx,
WriteCommand[] modifications)
Returns an existing remote transaction or creates one if none exists.
|
RemoteTransaction |
getRemoteTransaction(GlobalTransaction txId)
|
Collection<RemoteTransaction> |
getRemoteTransactions() |
int |
getRemoteTxCount() |
void |
initialize(RpcManager rpcManager,
Configuration configuration,
InvocationContextFactory icf,
InterceptorChain invoker,
CacheNotifier notifier,
TransactionFactory gtf,
TransactionCoordinator txCoordinator,
TransactionSynchronizationRegistry transactionSynchronizationRegistry,
CommandsFactory commandsFactory,
ClusteringDependentLogic clusteringDependentLogic,
Cache cache,
TimeService timeService) |
boolean |
isTransactionCompleted(GlobalTransaction gtx) |
void |
localTransactionPrepared(LocalTransaction localTransaction) |
void |
markTransactionCompleted(GlobalTransaction globalTx)
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) |
protected void |
recalculateMinTopologyIdIfNeeded(CacheTransaction removedTransaction) |
void |
remoteTransactionCommitted(GlobalTransaction gtx,
boolean onePc)
|
void |
remoteTransactionPrepared(GlobalTransaction gtx) |
void |
remoteTransactionRollback(GlobalTransaction gtx) |
boolean |
removeLocalTransaction(LocalTransaction localTransaction)
|
protected LocalTransaction |
removeLocalTransactionInternal(Transaction tx) |
RemoteTransaction |
removeRemoteTransaction(GlobalTransaction txId) |