org.infinispan.interceptors.locking

Class OrderedClusteringDependentLogic

java.lang.Object

org.infinispan.interceptors.locking.OrderedClusteringDependentLogic

All Implemented Interfaces:

ClusteringDependentLogic

public class OrderedClusteringDependentLogic
extends Object
implements ClusteringDependentLogic

ClusteringDependentLogic that orders write operations using the DataOperationOrderer component.

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

Constructor Summary

Constructors

Constructor and Description
OrderedClusteringDependentLogic(ClusteringDependentLogic cdl, boolean passivation)

Method Summary

Modifier and Type	Method and Description
CompletionStage<Void>	commitEntry(CacheEntry entry, FlagAffectedCommand command, InvocationContext ctx, Flag trackFlag, boolean l1Invalidation) Commits the entry to the data container.
ClusteringDependentLogic.Commit	commitType(FlagAffectedCommand command, InvocationContext ctx, int segment, boolean removed) Determines what type of commit this is.
CompletionStage<Map<Object,IncrementableEntryVersion>>	createNewVersionsAndCheckForWriteSkews(VersionGenerator versionGenerator, TxInvocationContext context, VersionedPrepareCommand prepareCommand)
Address	getAddress()
LocalizedCacheTopology	getCacheTopology()
<K,V> EntryLoader<K,V>	getEntryLoader()
void	start() Starts the object - must be first wired via component registry

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

OrderedClusteringDependentLogic

public OrderedClusteringDependentLogic(ClusteringDependentLogic cdl,
                                       boolean passivation)

Method Detail

start

public void start()

Description copied from interface: ClusteringDependentLogic

Starts the object - must be first wired via component registry

Specified by:

start in interface ClusteringDependentLogic

getCacheTopology

public LocalizedCacheTopology getCacheTopology()

Specified by:

getCacheTopology in interface ClusteringDependentLogic

Returns:

information about the location of keys.

commitEntry

public CompletionStage<Void> commitEntry(CacheEntry entry,
                                         FlagAffectedCommand command,
                                         InvocationContext ctx,
                                         Flag trackFlag,
                                         boolean l1Invalidation)

Description copied from interface: ClusteringDependentLogic

Commits the entry to the data container. The commit operation is always done synchronously in the current thread. However notifications for said operations can be performed asynchronously and the returned CompletionStage will complete when the notifications if any are completed.

Specified by:

commitEntry in interface ClusteringDependentLogic

Returns:

completion stage that is complete when all notifications for the commit are complete or null if already complete

commitType

public ClusteringDependentLogic.Commit commitType(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:

createNewVersionsAndCheckForWriteSkews

public CompletionStage<Map<Object,IncrementableEntryVersion>> createNewVersionsAndCheckForWriteSkews(VersionGenerator versionGenerator,
                                                                                                     TxInvocationContext context,
                                                                                                     VersionedPrepareCommand prepareCommand)

Specified by:

createNewVersionsAndCheckForWriteSkews in interface ClusteringDependentLogic

getAddress

public Address getAddress()

Specified by:

getAddress in interface ClusteringDependentLogic

getEntryLoader

public <K,V> EntryLoader<K,V> getEntryLoader()

Specified by:

getEntryLoader in interface ClusteringDependentLogic