Package org.infinispan.interceptors.locking

Class ClusteringDependentLogic.InvalidationLogic

java.lang.Object

org.infinispan.interceptors.locking.ClusteringDependentLogic.AbstractClusteringDependentLogic

org.infinispan.interceptors.locking.ClusteringDependentLogic.InvalidationLogic

All Implemented Interfaces:

ClusteringDependentLogic

Direct Known Subclasses:

ClusteringDependentLogic.ReplicationLogic

Enclosing interface:

ClusteringDependentLogic

public static class ClusteringDependentLogic.InvalidationLogic
extends ClusteringDependentLogic.AbstractClusteringDependentLogic

This logic is used in invalidation 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, componentRegistry, configuration, dataContainer, distributionManager, evictionManager, functionalNotifier, keyPartitioner, notifier, persistenceManager, timeService, totalOrder

Constructor Summary

Constructors

Constructor	Description
InvalidationLogic()

Method Summary

Modifier and Type	Method	Description
protected java.util.concurrent.CompletionStage<java.lang.Void>	commitSingleEntry(CacheEntry entry, org.infinispan.commands.FlagAffectedCommand command, InvocationContext ctx, Flag trackFlag, boolean l1Invalidation)
ClusteringDependentLogic.Commit	commitType(org.infinispan.commands.FlagAffectedCommand command, InvocationContext ctx, int segment, boolean removed)	Determines what type of commit this is.
protected org.infinispan.transaction.impl.WriteSkewHelper.KeySpecificLogic	initKeySpecificLogic(boolean totalOrder)

Methods inherited from class org.infinispan.interceptors.locking.ClusteringDependentLogic.AbstractClusteringDependentLogic

clusterCommitType, commitEntry, createNewVersionsAndCheckForWriteSkews, getAddress, getCacheTopology, 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

Constructor Detail

InvalidationLogic

public InvalidationLogic()

Method Detail

commitType

public ClusteringDependentLogic.Commit commitType(org.infinispan.commands.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 interface ClusteringDependentLogic

Overrides:

commitType in class ClusteringDependentLogic.AbstractClusteringDependentLogic

segment - if 0 or greater assumes the underlying container is segmented.

Returns:

commitSingleEntry

protected java.util.concurrent.CompletionStage<java.lang.Void> commitSingleEntry(CacheEntry entry,
                                                                                 org.infinispan.commands.FlagAffectedCommand command,
                                                                                 InvocationContext ctx,
                                                                                 Flag trackFlag,
                                                                                 boolean l1Invalidation)

Specified by:

commitSingleEntry in class ClusteringDependentLogic.AbstractClusteringDependentLogic

initKeySpecificLogic

protected org.infinispan.transaction.impl.WriteSkewHelper.KeySpecificLogic initKeySpecificLogic(boolean totalOrder)

Specified by:

initKeySpecificLogic in class ClusteringDependentLogic.AbstractClusteringDependentLogic