public static final class ClusteringDependentLogic.DistributionLogic extends Object implements ClusteringDependentLogic
ClusteringDependentLogic.AllNodesLogic, ClusteringDependentLogic.DistributionLogic
log
Constructor and Description |
---|
ClusteringDependentLogic.DistributionLogic() |
Modifier and Type | Method and Description |
---|---|
void |
commitEntry(CacheEntry entry,
EntryVersion newVersion,
boolean skipOwnershipCheck) |
EntryVersionsMap |
createNewVersionsAndCheckForWriteSkews(VersionGenerator versionGenerator,
TxInvocationContext context,
VersionedPrepareCommand prepareCommand) |
Address |
getAddress() |
Collection<Address> |
getOwners(Collection<Object> keys) |
void |
init(DistributionManager dm,
DataContainer dataContainer,
Configuration configuration,
RpcManager rpcManager) |
boolean |
localNodeIsOwner(Object key) |
boolean |
localNodeIsPrimaryOwner(Object key) |
public ClusteringDependentLogic.DistributionLogic()
public void init(DistributionManager dm, DataContainer dataContainer, Configuration configuration, RpcManager rpcManager)
public boolean localNodeIsOwner(Object key)
localNodeIsOwner
in interface ClusteringDependentLogic
public Address getAddress()
getAddress
in interface ClusteringDependentLogic
public boolean localNodeIsPrimaryOwner(Object key)
localNodeIsPrimaryOwner
in interface ClusteringDependentLogic
public void commitEntry(CacheEntry entry, EntryVersion newVersion, boolean skipOwnershipCheck)
commitEntry
in interface ClusteringDependentLogic
public Collection<Address> getOwners(Collection<Object> keys)
getOwners
in interface ClusteringDependentLogic
public EntryVersionsMap createNewVersionsAndCheckForWriteSkews(VersionGenerator versionGenerator, TxInvocationContext context, VersionedPrepareCommand prepareCommand)
createNewVersionsAndCheckForWriteSkews
in interface ClusteringDependentLogic
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.