public abstract static class ClusteringDependentLogic.AbstractClusteringDependentLogic extends Object implements ClusteringDependentLogic
ClusteringDependentLogic.AbstractClusteringDependentLogic, ClusteringDependentLogic.DistributionLogic, ClusteringDependentLogic.InvalidationLogic, ClusteringDependentLogic.LocalLogic, ClusteringDependentLogic.ReplicationLogic
Modifier and Type | Field and Description |
---|---|
protected CommitManager |
commitManager |
protected DataContainer<Object,Object> |
dataContainer |
protected FunctionalNotifier<Object,Object> |
functionalNotifier |
protected CacheNotifier<Object,Object> |
notifier |
protected PersistenceManager |
persistenceManager |
protected TimeService |
timeService |
protected boolean |
totalOrder |
LOCAL_MODE_ADDRESS
Constructor and Description |
---|
AbstractClusteringDependentLogic() |
Modifier and Type | Method and Description |
---|---|
void |
commitEntry(CacheEntry entry,
Metadata metadata,
FlagAffectedCommand command,
InvocationContext ctx,
Flag trackFlag,
boolean l1Invalidation) |
protected abstract void |
commitSingleEntry(CacheEntry entry,
Metadata metadata,
FlagAffectedCommand command,
InvocationContext ctx,
Flag trackFlag,
boolean l1Invalidation) |
EntryVersionsMap |
createNewVersionsAndCheckForWriteSkews(VersionGenerator versionGenerator,
TxInvocationContext context,
VersionedPrepareCommand prepareCommand) |
void |
init(DataContainer<Object,Object> dataContainer,
CacheNotifier<Object,Object> notifier,
Configuration configuration,
CommitManager commitManager,
PersistenceManager persistenceManager,
TimeService timeService,
FunctionalNotifier<Object,Object> functionalNotifier) |
protected abstract WriteSkewHelper.KeySpecificLogic |
initKeySpecificLogic(boolean totalOrder) |
protected void |
notifyCommitEntry(boolean created,
boolean removed,
boolean expired,
CacheEntry entry,
InvocationContext ctx,
FlagAffectedCommand command,
Object previousValue,
Metadata previousMetadata) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getAddress, getOwners, getOwners, getPrimaryOwner, localNodeIsOwner, localNodeIsPrimaryOwner
protected DataContainer<Object,Object> dataContainer
protected CacheNotifier<Object,Object> notifier
protected boolean totalOrder
protected CommitManager commitManager
protected PersistenceManager persistenceManager
protected TimeService timeService
protected FunctionalNotifier<Object,Object> functionalNotifier
public void init(DataContainer<Object,Object> dataContainer, CacheNotifier<Object,Object> notifier, Configuration configuration, CommitManager commitManager, PersistenceManager persistenceManager, TimeService timeService, FunctionalNotifier<Object,Object> functionalNotifier)
public EntryVersionsMap createNewVersionsAndCheckForWriteSkews(VersionGenerator versionGenerator, TxInvocationContext context, VersionedPrepareCommand prepareCommand)
createNewVersionsAndCheckForWriteSkews
in interface ClusteringDependentLogic
public final void commitEntry(CacheEntry entry, Metadata metadata, FlagAffectedCommand command, InvocationContext ctx, Flag trackFlag, boolean l1Invalidation)
commitEntry
in interface ClusteringDependentLogic
protected abstract void commitSingleEntry(CacheEntry entry, Metadata metadata, FlagAffectedCommand command, InvocationContext ctx, Flag trackFlag, boolean l1Invalidation)
protected abstract WriteSkewHelper.KeySpecificLogic initKeySpecificLogic(boolean totalOrder)
protected void notifyCommitEntry(boolean created, boolean removed, boolean expired, CacheEntry entry, InvocationContext ctx, FlagAffectedCommand command, Object previousValue, Metadata previousMetadata)
Copyright © 2021 JBoss, a division of Red Hat. All rights reserved.