public static class ClusteringDependentLogic.InvalidationLogic extends ClusteringDependentLogic.AbstractClusteringDependentLogic
ClusteringDependentLogic.AbstractClusteringDependentLogic, ClusteringDependentLogic.DistributionLogic, ClusteringDependentLogic.InvalidationLogic, ClusteringDependentLogic.LocalLogic, ClusteringDependentLogic.ReplicationLogic
commitManager, dataContainer, functionalNotifier, notifier, persistenceManager, timeService, totalOrder
LOCAL_MODE_ADDRESS
Constructor and Description |
---|
InvalidationLogic() |
Modifier and Type | Method and Description |
---|---|
protected void |
commitSingleEntry(CacheEntry entry,
Metadata metadata,
FlagAffectedCommand command,
InvocationContext ctx,
Flag trackFlag,
boolean l1Invalidation) |
Address |
getAddress() |
List<Address> |
getOwners(Collection<Object> keys) |
List<Address> |
getOwners(Object key) |
Address |
getPrimaryOwner(Object key) |
void |
init(RpcManager rpcManager,
StateTransferManager stateTransferManager) |
protected WriteSkewHelper.KeySpecificLogic |
initKeySpecificLogic(boolean totalOrder) |
boolean |
localNodeIsOwner(Object key) |
boolean |
localNodeIsPrimaryOwner(Object key) |
commitEntry, createNewVersionsAndCheckForWriteSkews, init, notifyCommitEntry
public void init(RpcManager rpcManager, StateTransferManager stateTransferManager)
public boolean localNodeIsOwner(Object key)
public boolean localNodeIsPrimaryOwner(Object key)
protected void commitSingleEntry(CacheEntry entry, Metadata metadata, FlagAffectedCommand command, InvocationContext ctx, Flag trackFlag, boolean l1Invalidation)
commitSingleEntry
in class ClusteringDependentLogic.AbstractClusteringDependentLogic
public List<Address> getOwners(Collection<Object> keys)
public Address getAddress()
protected WriteSkewHelper.KeySpecificLogic initKeySpecificLogic(boolean totalOrder)
initKeySpecificLogic
in class ClusteringDependentLogic.AbstractClusteringDependentLogic
Copyright © 2023 JBoss, a division of Red Hat. All rights reserved.