public class OrderedClusteringDependentLogic extends Object implements ClusteringDependentLogic
DataOperationOrderer
component.ClusteringDependentLogic.AbstractClusteringDependentLogic, ClusteringDependentLogic.Commit, ClusteringDependentLogic.DistributionLogic, ClusteringDependentLogic.InvalidationLogic, ClusteringDependentLogic.LocalLogic, ClusteringDependentLogic.ReplicationLogic, ClusteringDependentLogic.ScatteredLogic
Constructor and Description |
---|
OrderedClusteringDependentLogic(ClusteringDependentLogic cdl,
boolean passivation) |
Modifier and Type | Method and Description |
---|---|
CompletionStage<Void> |
commitEntry(CacheEntry entry,
FlagAffectedCommand command,
InvocationContext ctx,
Flag trackFlag,
boolean l1Invalidation)
Commits the entry to the data container.
|
ClusteringDependentLogic.Commit |
commitType(FlagAffectedCommand command,
InvocationContext ctx,
int segment,
boolean removed)
Determines what type of commit this is.
|
CompletionStage<Map<Object,IncrementableEntryVersion>> |
createNewVersionsAndCheckForWriteSkews(VersionGenerator versionGenerator,
TxInvocationContext context,
VersionedPrepareCommand prepareCommand) |
Address |
getAddress() |
LocalizedCacheTopology |
getCacheTopology() |
<K,V> EntryLoader<K,V> |
getEntryLoader() |
void |
start()
Starts the object - must be first wired via component registry
|
public OrderedClusteringDependentLogic(ClusteringDependentLogic cdl, boolean passivation)
public void start()
ClusteringDependentLogic
start
in interface ClusteringDependentLogic
public LocalizedCacheTopology getCacheTopology()
getCacheTopology
in interface ClusteringDependentLogic
public CompletionStage<Void> commitEntry(CacheEntry entry, FlagAffectedCommand command, InvocationContext ctx, Flag trackFlag, boolean l1Invalidation)
ClusteringDependentLogic
commitEntry
in interface ClusteringDependentLogic
public ClusteringDependentLogic.Commit commitType(FlagAffectedCommand command, InvocationContext ctx, int segment, boolean removed)
ClusteringDependentLogic
commitType
in interface ClusteringDependentLogic
segment
- if 0 or greater assumes the underlying container is segmented.public CompletionStage<Map<Object,IncrementableEntryVersion>> createNewVersionsAndCheckForWriteSkews(VersionGenerator versionGenerator, TxInvocationContext context, VersionedPrepareCommand prepareCommand)
createNewVersionsAndCheckForWriteSkews
in interface ClusteringDependentLogic
public Address getAddress()
getAddress
in interface ClusteringDependentLogic
public <K,V> EntryLoader<K,V> getEntryLoader()
getEntryLoader
in interface ClusteringDependentLogic
Copyright © 2021 JBoss by Red Hat. All rights reserved.