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 CommitManager	commitManager
protected DataContainer<Object,Object>	dataContainer
protected FunctionalNotifier<Object,Object>	functionalNotifier
protected CacheNotifier<Object,Object>	notifier
protected PersistenceManager	persistenceManager
protected TimeService	timeService
protected boolean	totalOrder

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

LOCAL_MODE_ADDRESS

Constructor Summary

Constructors

Constructor and Description
AbstractClusteringDependentLogic()

Method Summary

Modifier and Type	Method and Description
void	commitEntry(CacheEntry entry, Metadata metadata, FlagAffectedCommand command, InvocationContext ctx, Flag trackFlag, boolean l1Invalidation)
protected abstract void	commitSingleEntry(CacheEntry entry, Metadata metadata, FlagAffectedCommand command, InvocationContext ctx, Flag trackFlag, boolean l1Invalidation)
EntryVersionsMap	createNewVersionsAndCheckForWriteSkews(VersionGenerator versionGenerator, TxInvocationContext context, VersionedPrepareCommand prepareCommand)
void	init(DataContainer<Object,Object> dataContainer, CacheNotifier<Object,Object> notifier, Configuration configuration, CommitManager commitManager, PersistenceManager persistenceManager, TimeService timeService, FunctionalNotifier<Object,Object> functionalNotifier)
protected abstract WriteSkewHelper.KeySpecificLogic	initKeySpecificLogic(boolean totalOrder)
protected void	notifyCommitEntry(boolean created, boolean removed, boolean expired, CacheEntry entry, InvocationContext ctx, FlagAffectedCommand command, Object previousValue, Metadata previousMetadata)

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

getAddress, getOwners, getOwners, getPrimaryOwner, localNodeIsOwner, localNodeIsPrimaryOwner

Field Detail

dataContainer

protected DataContainer<Object,Object> dataContainer

notifier

protected CacheNotifier<Object,Object> notifier

totalOrder

protected boolean totalOrder

commitManager

protected CommitManager commitManager

persistenceManager

protected PersistenceManager persistenceManager

timeService

protected TimeService timeService

functionalNotifier

protected FunctionalNotifier<Object,Object> functionalNotifier

Constructor Detail

AbstractClusteringDependentLogic

public AbstractClusteringDependentLogic()

Method Detail

init

public void init(DataContainer<Object,Object> dataContainer,
                 CacheNotifier<Object,Object> notifier,
                 Configuration configuration,
                 CommitManager commitManager,
                 PersistenceManager persistenceManager,
                 TimeService timeService,
                 FunctionalNotifier<Object,Object> functionalNotifier)

createNewVersionsAndCheckForWriteSkews

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

Specified by:

createNewVersionsAndCheckForWriteSkews in interface ClusteringDependentLogic

commitEntry

public final void commitEntry(CacheEntry entry,
                              Metadata metadata,
                              FlagAffectedCommand command,
                              InvocationContext ctx,
                              Flag trackFlag,
                              boolean l1Invalidation)

Specified by:

commitEntry in interface ClusteringDependentLogic

commitSingleEntry

protected abstract void commitSingleEntry(CacheEntry entry,
                                          Metadata metadata,
                                          FlagAffectedCommand command,
                                          InvocationContext ctx,
                                          Flag trackFlag,
                                          boolean l1Invalidation)

initKeySpecificLogic

protected abstract WriteSkewHelper.KeySpecificLogic initKeySpecificLogic(boolean totalOrder)

notifyCommitEntry

protected void notifyCommitEntry(boolean created,
                                 boolean removed,
                                 boolean expired,
                                 CacheEntry entry,
                                 InvocationContext ctx,
                                 FlagAffectedCommand command,
                                 Object previousValue,
                                 Metadata previousMetadata)