All Methods Instance Methods Concrete Methods
Modifier and Type |
Method and Description |
void |
cleanupLeaverTransactions(List<Address> members) |
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) |
TransactionTable.CompletedTransactionStatus |
getCompletedTransactionStatus(GlobalTransaction gtx) |
GlobalTransaction |
getGlobalTransaction(Transaction transaction) |
Collection<GlobalTransaction> |
getLocalGlobalTransaction() |
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,
boolean implicitTransaction)
|
RemoteTransaction |
getOrCreateRemoteTransaction(GlobalTransaction globalTx,
WriteCommand[] modifications)
Returns an existing remote transaction or creates one if none exists.
|
Collection<GlobalTransaction> |
getRemoteGlobalTransaction() |
RemoteTransaction |
getRemoteTransaction(GlobalTransaction txId)
|
Collection<RemoteTransaction> |
getRemoteTransactions() |
int |
getRemoteTxCount() |
void |
initialize(RpcManager rpcManager,
Configuration configuration,
InvocationContextFactory icf,
CacheNotifier notifier,
TransactionFactory gtf,
TransactionCoordinator txCoordinator,
TransactionSynchronizationRegistry transactionSynchronizationRegistry,
CommandsFactory commandsFactory,
ClusteringDependentLogic clusteringDependentLogic,
Cache cache,
TimeService timeService,
CacheManagerNotifier cacheManagerNotifier,
PartitionHandlingManager partitionHandlingManager,
ScheduledExecutorService timeoutExecutor) |
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) |
void |
remoteTransactionCommitted(GlobalTransaction gtx,
boolean onePc)
|
void |
remoteTransactionPrepared(GlobalTransaction gtx) |
void |
remoteTransactionRollback(GlobalTransaction gtx) |
boolean |
removeLocalTransaction(LocalTransaction localTransaction)
|
RemoteTransaction |
removeRemoteTransaction(GlobalTransaction txId) |
void |
start() |