org.infinispan.interceptors.locking
public static class ClusteringDependentLogic.DistributionLogic extends ClusteringDependentLogic.AbstractClusteringDependentLogic
ClusteringDependentLogic.AbstractClusteringDependentLogic, ClusteringDependentLogic.DistributionLogic, ClusteringDependentLogic.InvalidationLogic, ClusteringDependentLogic.LocalLogic, ClusteringDependentLogic.ReplicationLogic
dataContainer, notifier
Constructor and Description |
---|
ClusteringDependentLogic.DistributionLogic() |
Modifier and Type | Method and Description |
---|---|
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) |
commitCacheEntry, init, lock, notifyCommitEntry, unlock
public ClusteringDependentLogic.DistributionLogic()
public void init(DistributionManager dm, Configuration configuration, RpcManager rpcManager, StateTransferLock stateTransferLock)
public boolean localNodeIsOwner(Object key)
public Address getAddress()
public boolean localNodeIsPrimaryOwner(Object key)
public void commitEntry(CacheEntry entry, EntryVersion newVersion, boolean skipOwnershipCheck, InvocationContext ctx)
public Collection<Address> getOwners(Collection<Object> keys)
public EntryVersionsMap createNewVersionsAndCheckForWriteSkews(VersionGenerator versionGenerator, TxInvocationContext context, VersionedPrepareCommand prepareCommand)
Copyright © 2014 JBoss, a division of Red Hat. All Rights Reserved.