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.DistributionLogic, ClusteringDependentLogic.InvalidationLogic, ClusteringDependentLogic.LocalLogic, ClusteringDependentLogic.ReplicationLogic

Field Summary

Fields inherited from class org.infinispan.interceptors.locking.ClusteringDependentLogic.InvalidationLogic

keySpecificLogic

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

dataContainer, notifier

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

LOCAL_MODE_ADDRESS

Constructor Summary

Constructors

Constructor and Description
ClusteringDependentLogic.ReplicationLogic()

Method Summary

Methods

Modifier and Type	Method and Description
void	commitEntry(CacheEntry entry, Metadata metadata, FlagAffectedCommand command, InvocationContext ctx)
EntryVersionsMap	createNewVersionsAndCheckForWriteSkews(VersionGenerator versionGenerator, TxInvocationContext context, VersionedPrepareCommand prepareCommand)
void	init(StateTransferLock stateTransferLock, Configuration configuration)

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

getAddress, getOwners, getOwners, getPrimaryOwner, init, localNodeIsOwner, localNodeIsPrimaryOwner

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

init, notifyCommitEntry, totalOrderCreateNewVersionsAndCheckForWriteSkews

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusteringDependentLogic.ReplicationLogic

public ClusteringDependentLogic.ReplicationLogic()

Method Detail

init

public void init(StateTransferLock stateTransferLock,
        Configuration configuration)

commitEntry

public void commitEntry(CacheEntry entry,
               Metadata metadata,
               FlagAffectedCommand command,
               InvocationContext ctx)

Specified by:

commitEntry in interface ClusteringDependentLogic

Overrides:

commitEntry in class ClusteringDependentLogic.InvalidationLogic

createNewVersionsAndCheckForWriteSkews

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

Specified by:

createNewVersionsAndCheckForWriteSkews in interface ClusteringDependentLogic

Overrides:

createNewVersionsAndCheckForWriteSkews in class ClusteringDependentLogic.InvalidationLogic