Class ClusteringDependentLogic.AbstractClusteringDependentLogic
- java.lang.Object
-
- org.infinispan.interceptors.locking.ClusteringDependentLogic.AbstractClusteringDependentLogic
-
- All Implemented Interfaces:
ClusteringDependentLogic
- Direct Known Subclasses:
ClusteringDependentLogic.DistributionLogic
,ClusteringDependentLogic.InvalidationLogic
,ClusteringDependentLogic.LocalLogic
- Enclosing interface:
- ClusteringDependentLogic
public abstract static class ClusteringDependentLogic.AbstractClusteringDependentLogic extends Object implements ClusteringDependentLogic
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.infinispan.interceptors.locking.ClusteringDependentLogic
ClusteringDependentLogic.AbstractClusteringDependentLogic, ClusteringDependentLogic.Commit, ClusteringDependentLogic.DistributionLogic, ClusteringDependentLogic.InvalidationLogic, ClusteringDependentLogic.LocalLogic, ClusteringDependentLogic.ReplicationLogic, ClusteringDependentLogic.ScatteredLogic
-
-
Field Summary
Fields Modifier and Type Field Description protected CommitManager
commitManager
protected Configuration
configuration
protected InternalDataContainer<Object,Object>
dataContainer
protected DistributionManager
distributionManager
protected FunctionalNotifier<Object,Object>
functionalNotifier
protected KeyPartitioner
keyPartitioner
protected CacheNotifier<Object,Object>
notifier
protected PersistenceManager
persistenceManager
protected org.infinispan.commons.time.TimeService
timeService
protected boolean
totalOrder
-
Constructor Summary
Constructors Constructor Description AbstractClusteringDependentLogic()
-
Method Summary
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.infinispan.interceptors.locking.ClusteringDependentLogic
getOwners, getOwners, getPrimaryOwner, localNodeIsOwner, localNodeIsPrimaryOwner
-
-
-
-
Field Detail
-
distributionManager
protected DistributionManager distributionManager
-
dataContainer
protected InternalDataContainer<Object,Object> dataContainer
-
notifier
protected CacheNotifier<Object,Object> notifier
-
commitManager
protected CommitManager commitManager
-
persistenceManager
protected PersistenceManager persistenceManager
-
timeService
protected org.infinispan.commons.time.TimeService timeService
-
functionalNotifier
protected FunctionalNotifier<Object,Object> functionalNotifier
-
configuration
protected Configuration configuration
-
keyPartitioner
protected KeyPartitioner keyPartitioner
-
totalOrder
protected boolean totalOrder
-
-
Method Detail
-
start
public void start()
-
createNewVersionsAndCheckForWriteSkews
public EntryVersionsMap createNewVersionsAndCheckForWriteSkews(VersionGenerator versionGenerator, TxInvocationContext context, org.infinispan.commands.tx.VersionedPrepareCommand prepareCommand)
- Specified by:
createNewVersionsAndCheckForWriteSkews
in interfaceClusteringDependentLogic
-
commitEntry
public final void commitEntry(CacheEntry entry, FlagAffectedCommand command, InvocationContext ctx, Flag trackFlag, boolean l1Invalidation)
- Specified by:
commitEntry
in interfaceClusteringDependentLogic
-
commitSingleEntry
protected abstract void commitSingleEntry(CacheEntry entry, FlagAffectedCommand command, InvocationContext ctx, Flag trackFlag, boolean l1Invalidation)
-
clusterCommitType
protected ClusteringDependentLogic.Commit clusterCommitType(FlagAffectedCommand command, InvocationContext ctx, int segment, boolean removed)
-
commitType
public ClusteringDependentLogic.Commit commitType(FlagAffectedCommand command, InvocationContext ctx, int segment, boolean removed)
Description copied from interface:ClusteringDependentLogic
Determines what type of commit this is. Whether we shouldn't commit, or if this is a commit due to owning the key or not- Specified by:
commitType
in interfaceClusteringDependentLogic
segment
- if 0 or greater assumes the underlying container is segmented.- Returns:
-
initKeySpecificLogic
protected abstract WriteSkewHelper.KeySpecificLogic initKeySpecificLogic(boolean totalOrder)
-
getCacheTopology
public LocalizedCacheTopology getCacheTopology()
- Specified by:
getCacheTopology
in interfaceClusteringDependentLogic
- Returns:
- information about the location of keys.
-
getAddress
public Address getAddress()
- Specified by:
getAddress
in interfaceClusteringDependentLogic
-
-