Package org.infinispan.interceptors.locking

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, componentRegistry, configuration, dataContainer, distributionManager, evictionManager, functionalNotifier, keyPartitioner, notifier, persistenceManager, timeService, totalOrder

Constructor Summary

Constructors

Constructor	Description
LocalLogic()

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.
Address	getAddress()
LocalizedCacheTopology	getCacheTopology()
void	init(Transport transport, Configuration configuration, KeyPartitioner keyPartitioner)
protected org.infinispan.transaction.impl.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

Constructor Detail

LocalLogic

public LocalLogic()

Method Detail

init

public void init(Transport transport,
                 Configuration configuration,
                 KeyPartitioner keyPartitioner)

getCacheTopology

public LocalizedCacheTopology getCacheTopology()

Specified by:

getCacheTopology in interface ClusteringDependentLogic

Overrides:

getCacheTopology in class ClusteringDependentLogic.AbstractClusteringDependentLogic

Returns:

information about the location of keys.

getAddress

public Address getAddress()

Specified by:

getAddress in interface ClusteringDependentLogic

Overrides:

getAddress in class ClusteringDependentLogic.AbstractClusteringDependentLogic

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