Class ClusteringDependentLogic.LocalLogic
- java.lang.Object
-
- org.infinispan.interceptors.locking.ClusteringDependentLogic.AbstractClusteringDependentLogic
-
- org.infinispan.interceptors.locking.ClusteringDependentLogic.LocalLogic
-
- All Implemented Interfaces:
ClusteringDependentLogic
- Enclosing interface:
- ClusteringDependentLogic
public static class ClusteringDependentLogic.LocalLogic extends ClusteringDependentLogic.AbstractClusteringDependentLogic
This logic is used in local mode caches.
-
-
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 inherited from class org.infinispan.interceptors.locking.ClusteringDependentLogic.AbstractClusteringDependentLogic
commitManager, configuration, dataContainer, distributionManager, functionalNotifier, keyPartitioner, notifier, persistenceManager, timeService, totalOrder
-
-
Constructor Summary
Constructors Constructor Description LocalLogic()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
commitSingleEntry(CacheEntry entry, FlagAffectedCommand command, InvocationContext ctx, Flag trackFlag, boolean l1Invalidation)
ClusteringDependentLogic.Commit
commitType(FlagAffectedCommand command, InvocationContext ctx, int segment, boolean removed)
Determines what type of commit this is.Address
getAddress()
LocalizedCacheTopology
getCacheTopology()
void
init(Transport transport, Configuration configuration, KeyPartitioner keyPartitioner)
protected WriteSkewHelper.KeySpecificLogic
initKeySpecificLogic(boolean totalOrder)
-
Methods inherited from class org.infinispan.interceptors.locking.ClusteringDependentLogic.AbstractClusteringDependentLogic
clusterCommitType, commitEntry, createNewVersionsAndCheckForWriteSkews, start
-
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
-
-
-
-
Method Detail
-
init
public void init(Transport transport, Configuration configuration, KeyPartitioner keyPartitioner)
-
getCacheTopology
public LocalizedCacheTopology getCacheTopology()
- Specified by:
getCacheTopology
in interfaceClusteringDependentLogic
- Overrides:
getCacheTopology
in classClusteringDependentLogic.AbstractClusteringDependentLogic
- Returns:
- information about the location of keys.
-
getAddress
public Address getAddress()
- Specified by:
getAddress
in interfaceClusteringDependentLogic
- Overrides:
getAddress
in classClusteringDependentLogic.AbstractClusteringDependentLogic
-
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
- Overrides:
commitType
in classClusteringDependentLogic.AbstractClusteringDependentLogic
segment
- if 0 or greater assumes the underlying container is segmented.- Returns:
-
commitSingleEntry
protected void commitSingleEntry(CacheEntry entry, FlagAffectedCommand command, InvocationContext ctx, Flag trackFlag, boolean l1Invalidation)
- Specified by:
commitSingleEntry
in classClusteringDependentLogic.AbstractClusteringDependentLogic
-
initKeySpecificLogic
protected WriteSkewHelper.KeySpecificLogic initKeySpecificLogic(boolean totalOrder)
- Specified by:
initKeySpecificLogic
in classClusteringDependentLogic.AbstractClusteringDependentLogic
-
-