Package org.infinispan.interceptors.locking

Class ClusteringDependentLogic.ReplicationLogic

java.lang.Object

org.infinispan.interceptors.locking.ClusteringDependentLogic.AbstractClusteringDependentLogic

org.infinispan.interceptors.locking.ClusteringDependentLogic.InvalidationLogic

org.infinispan.interceptors.locking.ClusteringDependentLogic.ReplicationLogic

All Implemented Interfaces:

ClusteringDependentLogic

Enclosing interface:

ClusteringDependentLogic

public static class ClusteringDependentLogic.ReplicationLogic
extends ClusteringDependentLogic.InvalidationLogic

This logic is used in replicated 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, configuration, dataContainer, distributionManager, functionalNotifier, keyPartitioner, notifier, persistenceManager, timeService, totalOrder

Constructor Summary

Constructors

Constructor	Description
ReplicationLogic()

Method Summary

Modifier and Type	Method	Description
protected void	commitSingleEntry(CacheEntry entry, FlagAffectedCommand command, InvocationContext ctx, Flag trackFlag, boolean l1Invalidation)
ClusteringDependentLogic.Commit	commitType(FlagAffectedCommand command, InvocationContext ctx, int segment, boolean removed)	Determines what type of commit this is.
Collection<Address>	getOwners(Object key)
Collection<Address>	getOwners(Collection<Object> keys)
protected WriteSkewHelper.KeySpecificLogic	initKeySpecificLogic(boolean totalOrder)

Methods inherited from class org.infinispan.interceptors.locking.ClusteringDependentLogic.AbstractClusteringDependentLogic

clusterCommitType, commitEntry, createNewVersionsAndCheckForWriteSkews, getAddress, getCacheTopology, 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

getPrimaryOwner, localNodeIsOwner, localNodeIsPrimaryOwner

Constructor Detail

ReplicationLogic

public ReplicationLogic()

Method Detail

getOwners

public Collection<Address> getOwners(Object key)

getOwners

public Collection<Address> getOwners(Collection<Object> keys)

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

Overrides:

commitType in class ClusteringDependentLogic.InvalidationLogic

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

Returns:

commitSingleEntry

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

Overrides:

commitSingleEntry in class ClusteringDependentLogic.InvalidationLogic

initKeySpecificLogic

protected WriteSkewHelper.KeySpecificLogic initKeySpecificLogic(boolean totalOrder)

Overrides:

initKeySpecificLogic in class ClusteringDependentLogic.InvalidationLogic