Modifier and Type | Method and Description |
---|---|
CheckTransactionRpcCommand |
CommandsFactory.buildCheckTransactionRpcCommand(Collection<GlobalTransaction> globalTransactions) |
CheckTransactionRpcCommand |
CommandsFactoryImpl.buildCheckTransactionRpcCommand(Collection<GlobalTransaction> globalTransactions) |
Modifier and Type | Method and Description |
---|---|
void |
LockControlCommand.setGlobalTransaction(GlobalTransaction gtx) |
Constructor and Description |
---|
LockControlCommand(Collection<?> keys,
ByteString cacheName,
long flags,
GlobalTransaction gtx) |
LockControlCommand(Object key,
ByteString cacheName,
long flags,
GlobalTransaction gtx) |
Modifier and Type | Method and Description |
---|---|
GlobalTransaction |
ClusteredGetCommand.getGlobalTransaction()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static ResponseCollector<Collection<GlobalTransaction>> |
CheckTransactionRpcCommand.responseCollector() |
Constructor and Description |
---|
ClusteredGetAllCommand(ByteString cacheName,
List<?> keys,
long flags,
GlobalTransaction gtx) |
Constructor and Description |
---|
CheckTransactionRpcCommand(ByteString cacheName,
Collection<GlobalTransaction> gtxToCheck) |
Modifier and Type | Method and Description |
---|---|
GlobalTransaction |
TxCompletionNotificationCommand.getGlobalTransaction() |
Constructor and Description |
---|
TxCompletionNotificationCommand(XidImpl xid,
GlobalTransaction gtx,
ByteString cacheName) |
Modifier and Type | Field and Description |
---|---|
protected GlobalTransaction |
AbstractTransactionBoundaryCommand.globalTx |
Modifier and Type | Method and Description |
---|---|
GlobalTransaction |
TransactionBoundaryCommand.getGlobalTransaction() |
GlobalTransaction |
AbstractTransactionBoundaryCommand.getGlobalTransaction() |
Constructor and Description |
---|
CommitCommand(ByteString cacheName,
GlobalTransaction gtx) |
PrepareCommand(ByteString cacheName,
GlobalTransaction gtx,
boolean onePhaseCommit,
WriteCommand... modifications) |
PrepareCommand(ByteString cacheName,
GlobalTransaction gtx,
List<WriteCommand> commands,
boolean onePhaseCommit) |
RollbackCommand(ByteString cacheName,
GlobalTransaction globalTransaction) |
VersionedCommitCommand(ByteString cacheName,
GlobalTransaction gtx) |
VersionedPrepareCommand(ByteString cacheName,
GlobalTransaction gtx,
List<WriteCommand> modifications,
boolean onePhase) |
Modifier and Type | Method and Description |
---|---|
GlobalTransaction |
AbstractTxInvocationContext.getGlobalTransaction() |
GlobalTransaction |
TxInvocationContext.getGlobalTransaction()
Returns the id of the transaction associated with the current call.
|
Modifier and Type | Method and Description |
---|---|
CompletionStage<Void> |
CacheNotifier.notifyTransactionCompleted(GlobalTransaction transaction,
boolean successful,
InvocationContext ctx)
Notifies all registered listeners of a transaction completion event.
|
CompletionStage<Void> |
CacheNotifierImpl.notifyTransactionCompleted(GlobalTransaction transaction,
boolean successful,
InvocationContext ctx) |
CompletionStage<Void> |
CacheNotifier.notifyTransactionRegistered(GlobalTransaction globalTransaction,
boolean isOriginLocal)
Notifies all registered listeners of a transaction registration event.
|
CompletionStage<Void> |
CacheNotifierImpl.notifyTransactionRegistered(GlobalTransaction globalTransaction,
boolean isOriginLocal) |
Modifier and Type | Method and Description |
---|---|
GlobalTransaction |
ClusterEvent.getGlobalTransaction() |
Modifier and Type | Method and Description |
---|---|
GlobalTransaction |
TransactionalEvent.getGlobalTransaction() |
Modifier and Type | Method and Description |
---|---|
GlobalTransaction |
EventImpl.getGlobalTransaction() |
Modifier and Type | Method and Description |
---|---|
void |
EventImpl.setTransactionId(GlobalTransaction transaction) |
Modifier and Type | Method and Description |
---|---|
Collection<GlobalTransaction> |
AvailablePartitionHandlingManager.getPartialTransactions() |
Collection<GlobalTransaction> |
PartitionHandlingManager.getPartialTransactions() |
Collection<GlobalTransaction> |
PartitionHandlingManagerImpl.getPartialTransactions() |
Modifier and Type | Method and Description |
---|---|
boolean |
AvailablePartitionHandlingManager.addPartialCommit1PCTransaction(GlobalTransaction globalTransaction,
Collection<Address> affectedNodes,
Collection<Object> lockedKeys,
List<WriteCommand> modifications) |
boolean |
PartitionHandlingManager.addPartialCommit1PCTransaction(GlobalTransaction globalTransaction,
Collection<Address> affectedNodes,
Collection<Object> lockedKeys,
List<WriteCommand> modifications)
Adds a partially committed transaction.
|
boolean |
PartitionHandlingManagerImpl.addPartialCommit1PCTransaction(GlobalTransaction globalTransaction,
Collection<Address> affectedNodes,
Collection<Object> lockedKeys,
List<WriteCommand> modifications) |
boolean |
AvailablePartitionHandlingManager.addPartialCommit2PCTransaction(GlobalTransaction globalTransaction,
Collection<Address> affectedNodes,
Collection<Object> lockedKeys,
Map<Object,IncrementableEntryVersion> newVersions) |
boolean |
PartitionHandlingManager.addPartialCommit2PCTransaction(GlobalTransaction globalTransaction,
Collection<Address> affectedNodes,
Collection<Object> lockedKeys,
Map<Object,IncrementableEntryVersion> newVersions)
Adds a partially committed transaction.
|
boolean |
PartitionHandlingManagerImpl.addPartialCommit2PCTransaction(GlobalTransaction globalTransaction,
Collection<Address> affectedNodes,
Collection<Object> lockedKeys,
Map<Object,IncrementableEntryVersion> newVersions) |
boolean |
AvailablePartitionHandlingManager.addPartialRollbackTransaction(GlobalTransaction globalTransaction,
Collection<Address> affectedNodes,
Collection<Object> lockedKeys) |
boolean |
PartitionHandlingManager.addPartialRollbackTransaction(GlobalTransaction globalTransaction,
Collection<Address> affectedNodes,
Collection<Object> lockedKeys)
Adds a partially aborted transaction.
|
boolean |
PartitionHandlingManagerImpl.addPartialRollbackTransaction(GlobalTransaction globalTransaction,
Collection<Address> affectedNodes,
Collection<Object> lockedKeys) |
boolean |
AvailablePartitionHandlingManager.canRollbackTransactionAfterOriginatorLeave(GlobalTransaction globalTransaction) |
boolean |
PartitionHandlingManager.canRollbackTransactionAfterOriginatorLeave(GlobalTransaction globalTransaction)
It checks if the transaction can be aborted when the originator leaves the cluster.
|
boolean |
PartitionHandlingManagerImpl.canRollbackTransactionAfterOriginatorLeave(GlobalTransaction globalTransaction) |
boolean |
AvailablePartitionHandlingManager.isTransactionPartiallyCommitted(GlobalTransaction globalTransaction) |
boolean |
PartitionHandlingManager.isTransactionPartiallyCommitted(GlobalTransaction globalTransaction)
It checks if the transaction resources (for example locks) can be released.
|
boolean |
PartitionHandlingManagerImpl.isTransactionPartiallyCommitted(GlobalTransaction globalTransaction) |
Modifier and Type | Method and Description |
---|---|
GlobalTransaction |
TransactionInfo.getGlobalTransaction() |
Constructor and Description |
---|
TransactionInfo(GlobalTransaction globalTransaction,
int topologyId,
WriteCommand[] modifications,
Set<Object> lockedKeys) |
Modifier and Type | Method and Description |
---|---|
GlobalTransaction |
TransactionTable.getGlobalTransaction(Transaction transaction) |
Modifier and Type | Method and Description |
---|---|
Collection<GlobalTransaction> |
TransactionTable.getLocalGlobalTransaction() |
Collection<GlobalTransaction> |
TransactionTable.getRemoteGlobalTransaction() |
Modifier and Type | Field and Description |
---|---|
protected GlobalTransaction |
AbstractCacheTransaction.tx |
Modifier and Type | Method and Description |
---|---|
GlobalTransaction |
AbstractCacheTransaction.getGlobalTransaction() |
GlobalTransaction |
TransactionTable.getGlobalTransaction(Transaction transaction) |
Modifier and Type | Method and Description |
---|---|
Collection<GlobalTransaction> |
TransactionTable.getLocalGlobalTransaction() |
Collection<GlobalTransaction> |
TransactionTable.getRemoteGlobalTransaction() |
Modifier and Type | Method and Description |
---|---|
boolean |
TransactionTable.containRemoteTx(GlobalTransaction globalTransaction) |
boolean |
TransactionTable.containsLocalTx(GlobalTransaction globalTransaction) |
TransactionTable.CompletedTransactionStatus |
TransactionTable.getCompletedTransactionStatus(GlobalTransaction gtx) |
LocalTransaction |
TransactionTable.getLocalTransaction(GlobalTransaction txId)
Looks up a LocalTransaction given a GlobalTransaction.
|
RemoteTransaction |
TransactionTable.getOrCreateRemoteTransaction(GlobalTransaction globalTx,
WriteCommand[] modifications)
Returns an existing remote transaction or creates one if none exists.
|
RemoteTransaction |
TransactionTable.getRemoteTransaction(GlobalTransaction txId)
Returns the
RemoteTransaction associated with the supplied transaction id. |
boolean |
TransactionOriginatorChecker.isOriginatorMissing(GlobalTransaction gtx) |
boolean |
ClusteredTransactionOriginatorChecker.isOriginatorMissing(GlobalTransaction gtx) |
boolean |
TransactionOriginatorChecker.isOriginatorMissing(GlobalTransaction gtx,
Collection<Address> liveMembers) |
boolean |
ClusteredTransactionOriginatorChecker.isOriginatorMissing(GlobalTransaction gtx,
Collection<Address> liveMembers) |
boolean |
TransactionTable.isTransactionCompleted(GlobalTransaction gtx) |
void |
TransactionTable.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 |
TransactionTable.remoteTransactionCommitted(GlobalTransaction gtx,
boolean onePc)
Removes the
RemoteTransaction corresponding to the given tx. |
void |
TransactionTable.remoteTransactionPrepared(GlobalTransaction gtx) |
void |
TransactionTable.remoteTransactionRollback(GlobalTransaction gtx) |
RemoteTransaction |
TransactionTable.removeRemoteTransaction(GlobalTransaction txId) |
Modifier and Type | Method and Description |
---|---|
LocalTransaction |
TransactionTable.getOrCreateLocalTransaction(Transaction transaction,
boolean implicitTransaction,
Supplier<GlobalTransaction> gtxFactory)
Similar to
TransactionTable.getOrCreateLocalTransaction(Transaction, boolean) but with a custom global transaction factory. |
Constructor and Description |
---|
AbstractCacheTransaction(GlobalTransaction tx,
int topologyId,
long txCreationTime) |
LocalTransaction(Transaction transaction,
GlobalTransaction tx,
boolean implicitTransaction,
int topologyId,
long txCreationTime) |
RemoteTransaction(GlobalTransaction tx,
int topologyId,
long txCreationTime) |
RemoteTransaction(WriteCommand[] modifications,
GlobalTransaction tx,
int topologyId,
long txCreationTime) |
Constructor and Description |
---|
SyncLocalTransaction(Transaction transaction,
GlobalTransaction tx,
boolean implicitTransaction,
int topologyId,
long txCreationTime) |
Modifier and Type | Method and Description |
---|---|
GlobalTransaction |
CacheTransaction.getGlobalTransaction()
Returns the transaction identifier.
|
GlobalTransaction |
TransactionFactory.newGlobalTransaction(Address addr,
boolean remote) |
abstract GlobalTransaction |
TransactionFactory.TxFactoryEnum.newGlobalTransaction(Address addr,
boolean remote,
VersionGenerator clusterIdGenerator,
boolean clustered) |
GlobalTransaction |
GlobalTransaction.Externalizer.readObject(ObjectInput input) |
Modifier and Type | Method and Description |
---|---|
Set<Class<? extends GlobalTransaction>> |
GlobalTransaction.Externalizer.getTypeClasses() |
Modifier and Type | Method and Description |
---|---|
LocalTransaction |
TransactionFactory.newLocalTransaction(Transaction tx,
GlobalTransaction gtx,
boolean implicitTransaction,
int topologyId) |
abstract LocalTransaction |
TransactionFactory.TxFactoryEnum.newLocalTransaction(Transaction tx,
GlobalTransaction gtx,
boolean implicitTransaction,
int topologyId,
long txCreationTime) |
RemoteTransaction |
TransactionFactory.newRemoteTransaction(GlobalTransaction tx,
int topologyId) |
abstract RemoteTransaction |
TransactionFactory.TxFactoryEnum.newRemoteTransaction(GlobalTransaction tx,
int topologyId,
long txCreationTime) |
RemoteTransaction |
TransactionFactory.newRemoteTransaction(WriteCommand[] modifications,
GlobalTransaction tx,
int topologyId) |
abstract RemoteTransaction |
TransactionFactory.TxFactoryEnum.newRemoteTransaction(WriteCommand[] modifications,
GlobalTransaction tx,
int topologyId,
long txCreationTime) |
void |
GlobalTransaction.Externalizer.writeObject(ObjectOutput output,
GlobalTransaction gtx) |
Constructor and Description |
---|
LocalXaTransaction(Transaction transaction,
GlobalTransaction tx,
boolean implicitTransaction,
int topologyId,
long txCreationTime) |
Modifier and Type | Method and Description |
---|---|
RemoteTransaction |
RecoveryAwareTransactionTable.getRemoteTransaction(GlobalTransaction txId) |
boolean |
RecoveryManager.isTransactionPrepared(GlobalTransaction globalTx)
Checks both internal state and transaction table's state for the given tx.
|
boolean |
RecoveryManagerImpl.isTransactionPrepared(GlobalTransaction globalTx) |
void |
RecoveryAwareTransactionTable.remoteTransactionCommitted(GlobalTransaction gtx,
boolean onePc) |
void |
RecoveryAwareTransactionTable.remoteTransactionPrepared(GlobalTransaction gtx)
Marks the transaction as prepared.
|
void |
RecoveryAwareTransactionTable.remoteTransactionRollback(GlobalTransaction gtx) |
CompletionStage<Void> |
RecoveryManager.removeRecoveryInformation(Collection<Address> where,
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.
|
CompletionStage<Void> |
RecoveryManagerImpl.removeRecoveryInformation(Collection<Address> lockOwners,
XidImpl xid,
GlobalTransaction gtx,
boolean fromCluster) |
Constructor and Description |
---|
RecoveryAwareLocalTransaction(Transaction transaction,
GlobalTransaction tx,
boolean implicitTransaction,
int topologyId,
long txCreationTime) |
RecoveryAwareRemoteTransaction(GlobalTransaction tx,
int topologyId,
long txCreationTime) |
RecoveryAwareRemoteTransaction(WriteCommand[] modifications,
GlobalTransaction tx,
int topologyId,
long txCreationTime) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultIracManager.trackKeysFromTransaction(Stream<WriteCommand> modifications,
GlobalTransaction lockOwner) |
void |
IracManager.trackKeysFromTransaction(Stream<WriteCommand> modifications,
GlobalTransaction lockOwner)
Sets all keys affected by the transaction as changed.
|
void |
NoOpIracManager.trackKeysFromTransaction(Stream<WriteCommand> modifications,
GlobalTransaction lockOwner) |
Copyright © 2021 JBoss by Red Hat. All rights reserved.