org.infinispan.interceptors.locking
Class ClusteringDependentLogic.DistributionLogic
java.lang.Object
org.infinispan.interceptors.locking.ClusteringDependentLogic.AbstractClusteringDependentLogic
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.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ClusteringDependentLogic.DistributionLogic
public ClusteringDependentLogic.DistributionLogic()
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)
Copyright © 2013 JBoss, a division of Red Hat. All Rights Reserved.