Package | Description |
---|---|
org.infinispan.commands |
Commands that operate on the cache, either locally or remotely.
|
org.infinispan.container.entries |
Entries which are stored in data containers.
|
org.infinispan.context.impl |
This package contains different context implementations, selected dynamically based on the type of invocation.
|
org.infinispan.interceptors |
Infinispan is designed around a set of interceptors around a data container.
|
org.infinispan.interceptors.base |
Base interceptors containing common, reusable behavior.
|
org.infinispan.interceptors.distribution | |
org.infinispan.interceptors.locking | |
org.infinispan.interceptors.totalorder | |
org.infinispan.interceptors.xsite | |
org.infinispan.query.backend | |
org.infinispan.statetransfer |
Transfer of state to new caches in a cluster.
|
org.infinispan.transaction |
JTA transaction support.
|
org.infinispan.xsite |
Modifier and Type | Method and Description |
---|---|
Object |
AbstractVisitor.visitCommitCommand(TxInvocationContext ctx,
CommitCommand command) |
Object |
Visitor.visitCommitCommand(TxInvocationContext ctx,
CommitCommand command) |
Object |
AbstractVisitor.visitLockControlCommand(TxInvocationContext ctx,
LockControlCommand command) |
Object |
Visitor.visitLockControlCommand(TxInvocationContext ctx,
LockControlCommand command) |
Object |
AbstractVisitor.visitPrepareCommand(TxInvocationContext ctx,
PrepareCommand command) |
Object |
Visitor.visitPrepareCommand(TxInvocationContext ctx,
PrepareCommand command) |
Object |
AbstractVisitor.visitRollbackCommand(TxInvocationContext ctx,
RollbackCommand command) |
Object |
Visitor.visitRollbackCommand(TxInvocationContext ctx,
RollbackCommand command) |
Modifier and Type | Method and Description |
---|---|
boolean |
ClusteredRepeatableReadEntry.performWriteSkewCheck(DataContainer container,
TxInvocationContext ctx,
EntryVersion versionSeen,
VersionGenerator versionGenerator) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractTxInvocationContext
Support class for
TxInvocationContext . |
class |
LocalTxInvocationContext
Invocation context to be used for locally originated transactions.
|
class |
RemoteTxInvocationContext
Context to be used for transaction that originated remotely.
|
Modifier and Type | Method and Description |
---|---|
TxInvocationContext |
AbstractTxInvocationContext.setTransaction(Transaction transaction) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
BaseRpcInterceptor.shouldInvokeRemoteTxCommand(TxInvocationContext ctx) |
protected static boolean |
BaseRpcInterceptor.shouldTotalOrderRollbackBeInvokedRemotely(TxInvocationContext ctx) |
protected static void |
BaseRpcInterceptor.totalOrderTxCommit(TxInvocationContext ctx) |
protected static void |
BaseRpcInterceptor.totalOrderTxRollback(TxInvocationContext ctx) |
protected static void |
BaseRpcInterceptor.transactionRemotelyPrepared(TxInvocationContext ctx) |
Object |
PrePostProcessingCommandInterceptor.visitCommitCommand(TxInvocationContext ctx,
CommitCommand command) |
Object |
PrePostProcessingCommandInterceptor.visitPrepareCommand(TxInvocationContext ctx,
PrepareCommand command) |
Object |
PrePostProcessingCommandInterceptor.visitRollbackCommand(TxInvocationContext ctx,
RollbackCommand command) |
Modifier and Type | Method and Description |
---|---|
EntryVersionsMap |
ClusteringDependentLogic.createNewVersionsAndCheckForWriteSkews(VersionGenerator versionGenerator,
TxInvocationContext context,
VersionedPrepareCommand prepareCommand) |
EntryVersionsMap |
ClusteringDependentLogic.AbstractClusteringDependentLogic.createNewVersionsAndCheckForWriteSkews(VersionGenerator versionGenerator,
TxInvocationContext context,
VersionedPrepareCommand prepareCommand) |
EntryVersionsMap |
ClusteringDependentLogic.LocalLogic.createNewVersionsAndCheckForWriteSkews(VersionGenerator versionGenerator,
TxInvocationContext context,
VersionedPrepareCommand prepareCommand) |
protected Object |
AbstractTxLockingInterceptor.invokeNextAndCommitIf1Pc(TxInvocationContext ctx,
PrepareCommand command) |
protected void |
AbstractTxLockingInterceptor.lockAndRegisterBackupLock(TxInvocationContext ctx,
Object key,
long lockTimeout,
boolean skipLocking)
The backup (non-primary) owners keep a "backup lock" for each key they received in a lock/prepare command.
|
Object |
AbstractTxLockingInterceptor.visitCommitCommand(TxInvocationContext ctx,
CommitCommand command) |
Object |
PessimisticLockingInterceptor.visitLockControlCommand(TxInvocationContext ctx,
LockControlCommand command) |
Object |
OptimisticLockingInterceptor.visitLockControlCommand(TxInvocationContext ctx,
LockControlCommand command) |
Object |
PessimisticLockingInterceptor.visitPrepareCommand(TxInvocationContext ctx,
PrepareCommand command) |
Object |
OptimisticLockingInterceptor.visitPrepareCommand(TxInvocationContext ctx,
PrepareCommand command) |
Object |
AbstractTxLockingInterceptor.visitRollbackCommand(TxInvocationContext ctx,
RollbackCommand command) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
BaseBackupInterceptor.shouldInvokeRemoteTxCommand(TxInvocationContext ctx) |
Object |
OptimisticBackupInterceptor.visitCommitCommand(TxInvocationContext ctx,
CommitCommand command) |
Object |
PessimisticBackupInterceptor.visitCommitCommand(TxInvocationContext ctx,
CommitCommand command) |
Object |
OptimisticBackupInterceptor.visitPrepareCommand(TxInvocationContext ctx,
PrepareCommand command) |
Object |
PessimisticBackupInterceptor.visitPrepareCommand(TxInvocationContext ctx,
PrepareCommand command) |
Object |
OptimisticBackupInterceptor.visitRollbackCommand(TxInvocationContext ctx,
RollbackCommand command) |
Modifier and Type | Method and Description |
---|---|
Object |
QueryInterceptor.visitPrepareCommand(TxInvocationContext ctx,
PrepareCommand command)
In case of a remotely originating transactions we don't have a chance to visit the single
commands but receive this "batch".
|
Modifier and Type | Method and Description |
---|---|
Object |
StateTransferInterceptor.visitCommitCommand(TxInvocationContext ctx,
CommitCommand command) |
Object |
TransactionSynchronizerInterceptor.visitCommitCommand(TxInvocationContext ctx,
CommitCommand command) |
Object |
StateTransferInterceptor.visitLockControlCommand(TxInvocationContext ctx,
LockControlCommand command) |
Object |
TransactionSynchronizerInterceptor.visitLockControlCommand(TxInvocationContext ctx,
LockControlCommand command) |
Object |
StateTransferInterceptor.visitPrepareCommand(TxInvocationContext ctx,
PrepareCommand command) |
Object |
TransactionSynchronizerInterceptor.visitPrepareCommand(TxInvocationContext ctx,
PrepareCommand command) |
Object |
StateTransferInterceptor.visitRollbackCommand(TxInvocationContext ctx,
RollbackCommand command) |
Object |
TransactionSynchronizerInterceptor.visitRollbackCommand(TxInvocationContext ctx,
RollbackCommand command) |
Modifier and Type | Method and Description |
---|---|
LocalTransaction |
TransactionTable.getOrCreateLocalTransaction(Transaction transaction,
TxInvocationContext ctx)
Returns the
TransactionXaAdapter corresponding to the supplied transaction. |
static EntryVersionsMap |
WriteSkewHelper.performTotalOrderWriteSkewCheckAndReturnNewVersions(VersionedPrepareCommand prepareCommand,
DataContainer dataContainer,
VersionGenerator versionGenerator,
TxInvocationContext context,
WriteSkewHelper.KeySpecificLogic ksl) |
static EntryVersionsMap |
WriteSkewHelper.performWriteSkewCheckAndReturnNewVersions(VersionedPrepareCommand prepareCommand,
DataContainer dataContainer,
VersionGenerator versionGenerator,
TxInvocationContext context,
WriteSkewHelper.KeySpecificLogic ksl) |
Modifier and Type | Method and Description |
---|---|
Object |
BackupReceiverImpl.BackupCacheUpdater.visitCommitCommand(TxInvocationContext ctx,
CommitCommand command) |
Object |
BackupSenderImpl.CustomBackupPolicyInvoker.visitCommitCommand(TxInvocationContext ctx,
CommitCommand command) |
Object |
BackupReceiverImpl.BackupCacheUpdater.visitPrepareCommand(TxInvocationContext ctx,
PrepareCommand command) |
Object |
BackupSenderImpl.CustomBackupPolicyInvoker.visitPrepareCommand(TxInvocationContext ctx,
PrepareCommand command) |
Object |
BackupReceiverImpl.BackupCacheUpdater.visitRollbackCommand(TxInvocationContext ctx,
RollbackCommand command) |
Object |
BackupSenderImpl.CustomBackupPolicyInvoker.visitRollbackCommand(TxInvocationContext ctx,
RollbackCommand command) |
Copyright © 2016 JBoss, a division of Red Hat. All rights reserved.