Package org.infinispan.interceptors.locking

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 java.lang.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 org.infinispan.container.impl.InternalDataContainer<java.lang.Object,java.lang.Object>	dataContainer
protected DistributionManager	distributionManager
protected org.infinispan.functional.impl.FunctionalNotifier<java.lang.Object,java.lang.Object>	functionalNotifier
protected KeyPartitioner	keyPartitioner
protected CacheNotifier<java.lang.Object,java.lang.Object>	notifier
protected PersistenceManager	persistenceManager
protected TimeService	timeService
protected boolean	totalOrder

Constructor Summary

Constructors

Constructor	Description
AbstractClusteringDependentLogic()

Method Summary

Modifier and Type	Method	Description
protected ClusteringDependentLogic.Commit	clusterCommitType(org.infinispan.commands.FlagAffectedCommand command, InvocationContext ctx, int segment, boolean removed)
void	commitEntry(CacheEntry entry, org.infinispan.commands.FlagAffectedCommand command, InvocationContext ctx, Flag trackFlag, boolean l1Invalidation)
protected abstract 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.
EntryVersionsMap	createNewVersionsAndCheckForWriteSkews(VersionGenerator versionGenerator, org.infinispan.context.impl.TxInvocationContext context, org.infinispan.commands.tx.VersionedPrepareCommand prepareCommand)
Address	getAddress()
LocalizedCacheTopology	getCacheTopology()
protected abstract org.infinispan.transaction.impl.WriteSkewHelper.KeySpecificLogic	initKeySpecificLogic(boolean totalOrder)
void	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

Field Detail

distributionManager

protected DistributionManager distributionManager

dataContainer

protected org.infinispan.container.impl.InternalDataContainer<java.lang.Object,java.lang.Object> dataContainer

notifier

protected CacheNotifier<java.lang.Object,java.lang.Object> notifier

commitManager

protected CommitManager commitManager

persistenceManager

protected PersistenceManager persistenceManager

timeService

protected TimeService timeService

functionalNotifier

protected org.infinispan.functional.impl.FunctionalNotifier<java.lang.Object,java.lang.Object> functionalNotifier

configuration

protected Configuration configuration

keyPartitioner

protected KeyPartitioner keyPartitioner

totalOrder

protected boolean totalOrder

Constructor Detail

AbstractClusteringDependentLogic

public AbstractClusteringDependentLogic()

Method Detail

start

public void start()

createNewVersionsAndCheckForWriteSkews

public EntryVersionsMap createNewVersionsAndCheckForWriteSkews(VersionGenerator versionGenerator,
                                                               org.infinispan.context.impl.TxInvocationContext context,
                                                               org.infinispan.commands.tx.VersionedPrepareCommand prepareCommand)

Specified by:

createNewVersionsAndCheckForWriteSkews in interface ClusteringDependentLogic

commitEntry

public final void commitEntry(CacheEntry entry,
                              org.infinispan.commands.FlagAffectedCommand command,
                              InvocationContext ctx,
                              Flag trackFlag,
                              boolean l1Invalidation)

Specified by:

commitEntry in interface ClusteringDependentLogic

commitSingleEntry

protected abstract void commitSingleEntry(CacheEntry entry,
                                          org.infinispan.commands.FlagAffectedCommand command,
                                          InvocationContext ctx,
                                          Flag trackFlag,
                                          boolean l1Invalidation)

clusterCommitType

protected ClusteringDependentLogic.Commit clusterCommitType(org.infinispan.commands.FlagAffectedCommand command,
                                                            InvocationContext ctx,
                                                            int segment,
                                                            boolean removed)

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

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

Returns:

initKeySpecificLogic

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

getCacheTopology

public LocalizedCacheTopology getCacheTopology()

Specified by:

getCacheTopology in interface ClusteringDependentLogic

Returns:

information about the location of keys.

getAddress

public Address getAddress()

Specified by:

getAddress in interface ClusteringDependentLogic