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 Object
implements ClusteringDependentLogic

Nested Class Summary

Nested classes/interfaces inherited from interface org.infinispan.interceptors.locking.ClusteringDependentLogic

ClusteringDependentLogic.AbstractClusteringDependentLogic, ClusteringDependentLogic.DistributionLogic, ClusteringDependentLogic.InvalidationLogic, ClusteringDependentLogic.LocalLogic, ClusteringDependentLogic.ReplicationLogic

Field Summary

Fields

Modifier and Type	Field and Description
protected DataContainer	dataContainer
protected CacheNotifier	notifier
protected boolean	totalOrder

Fields inherited from interface org.infinispan.interceptors.locking.ClusteringDependentLogic

LOCAL_MODE_ADDRESS

Constructor Summary

Constructors

Constructor and Description
ClusteringDependentLogic.AbstractClusteringDependentLogic()

Method Summary

Methods

Modifier and Type	Method and Description
EntryVersionsMap	createNewVersionsAndCheckForWriteSkews(VersionGenerator versionGenerator, TxInvocationContext context, VersionedPrepareCommand prepareCommand)
void	init(DataContainer dataContainer, CacheNotifier notifier, Configuration configuration)
protected abstract WriteSkewHelper.KeySpecificLogic	initKeySpecificLogic(boolean totalOrder)
protected void	notifyCommitEntry(boolean created, boolean removed, boolean evicted, CacheEntry entry, InvocationContext ctx, FlagAffectedCommand command)

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

commitEntry, getAddress, getOwners, getOwners, getPrimaryOwner, localNodeIsOwner, localNodeIsPrimaryOwner

Field Detail

dataContainer

protected DataContainer dataContainer

notifier

protected CacheNotifier notifier

totalOrder

protected boolean totalOrder

Constructor Detail

ClusteringDependentLogic.AbstractClusteringDependentLogic

public ClusteringDependentLogic.AbstractClusteringDependentLogic()

Method Detail

init

public void init(DataContainer dataContainer,
        CacheNotifier notifier,
        Configuration configuration)

createNewVersionsAndCheckForWriteSkews

public EntryVersionsMap createNewVersionsAndCheckForWriteSkews(VersionGenerator versionGenerator,
                                                      TxInvocationContext context,
                                                      VersionedPrepareCommand prepareCommand)

Specified by:

createNewVersionsAndCheckForWriteSkews in interface ClusteringDependentLogic

initKeySpecificLogic

protected abstract WriteSkewHelper.KeySpecificLogic initKeySpecificLogic(boolean totalOrder)

notifyCommitEntry

protected void notifyCommitEntry(boolean created,
                     boolean removed,
                     boolean evicted,
                     CacheEntry entry,
                     InvocationContext ctx,
                     FlagAffectedCommand command)