Infinispan Distribution 5.2.6.Final-redhat-2

org.infinispan.interceptors.locking
Class ClusteringDependentLogic.DistributionLogic

java.lang.Object
  extended by org.infinispan.interceptors.locking.ClusteringDependentLogic.AbstractClusteringDependentLogic
      extended by org.infinispan.interceptors.locking.ClusteringDependentLogic.DistributionLogic
All Implemented Interfaces:
ClusteringDependentLogic
Enclosing interface:
ClusteringDependentLogic

public static class ClusteringDependentLogic.DistributionLogic
extends ClusteringDependentLogic.AbstractClusteringDependentLogic

This logic is used in distributed 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.AbstractClusteringDependentLogic
dataContainer, notifier
 
Constructor Summary
ClusteringDependentLogic.DistributionLogic()
           
 
Method Summary
 void commitEntry(CacheEntry entry, EntryVersion newVersion, boolean skipOwnershipCheck, InvocationContext ctx)
           
 EntryVersionsMap createNewVersionsAndCheckForWriteSkews(VersionGenerator versionGenerator, TxInvocationContext context, VersionedPrepareCommand prepareCommand)
           
 Address getAddress()
           
 Collection<Address> getOwners(Collection<Object> keys)
           
 Address getPrimaryOwner(Object key)
           
 void init(DistributionManager dm, Configuration configuration, RpcManager rpcManager, StateTransferLock stateTransferLock)
           
 boolean localNodeIsOwner(Object key)
           
 boolean localNodeIsPrimaryOwner(Object key)
           
 
Methods inherited from class org.infinispan.interceptors.locking.ClusteringDependentLogic.AbstractClusteringDependentLogic
init, notifyCommitEntry
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ClusteringDependentLogic.DistributionLogic

public ClusteringDependentLogic.DistributionLogic()
Method Detail

init

public void init(DistributionManager dm,
                 Configuration configuration,
                 RpcManager rpcManager,
                 StateTransferLock stateTransferLock)

localNodeIsOwner

public boolean localNodeIsOwner(Object key)

getAddress

public Address getAddress()

localNodeIsPrimaryOwner

public boolean localNodeIsPrimaryOwner(Object key)

getPrimaryOwner

public Address getPrimaryOwner(Object key)

commitEntry

public void commitEntry(CacheEntry entry,
                        EntryVersion newVersion,
                        boolean skipOwnershipCheck,
                        InvocationContext ctx)

getOwners

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

createNewVersionsAndCheckForWriteSkews

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

Infinispan Distribution 5.2.6.Final-redhat-2

Copyright © 2013 JBoss, a division of Red Hat. All Rights Reserved.