public static class ClusteringDependentLogic.DistributionLogic extends ClusteringDependentLogic.AbstractClusteringDependentLogic
ClusteringDependentLogic.AbstractClusteringDependentLogic, ClusteringDependentLogic.DistributionLogic, ClusteringDependentLogic.InvalidationLogic, ClusteringDependentLogic.LocalLogic, ClusteringDependentLogic.ReplicationLogic
dataContainer, notifier, totalOrder
LOCAL_MODE_ADDRESS
Constructor and Description |
---|
ClusteringDependentLogic.DistributionLogic() |
Modifier and Type | Method and Description |
---|---|
void |
commitEntry(CacheEntry entry,
Metadata metadata,
FlagAffectedCommand command,
InvocationContext ctx) |
Address |
getAddress() |
List<Address> |
getOwners(Collection<Object> affectedKeys) |
List<Address> |
getOwners(Object key) |
Address |
getPrimaryOwner(Object key) |
void |
init(DistributionManager dm,
Configuration configuration,
RpcManager rpcManager,
StateTransferLock stateTransferLock) |
protected WriteSkewHelper.KeySpecificLogic |
initKeySpecificLogic(boolean totalOrder) |
boolean |
localNodeIsOwner(Object key) |
boolean |
localNodeIsPrimaryOwner(Object key) |
commitCacheEntry, createNewVersionsAndCheckForWriteSkews, 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, Metadata metadata, FlagAffectedCommand command, InvocationContext ctx)
public List<Address> getOwners(Collection<Object> affectedKeys)
protected WriteSkewHelper.KeySpecificLogic initKeySpecificLogic(boolean totalOrder)
initKeySpecificLogic
in class ClusteringDependentLogic.AbstractClusteringDependentLogic
Copyright © 2014 JBoss, a division of Red Hat. All Rights Reserved.