public class InvalidateL1Command extends InvalidateCommand
Modifier and Type | Field and Description |
---|---|
static int |
COMMAND_ID |
keys
notifier, value, valueEquivalence, valueMatcher
commandInvocationId
key
flags
Constructor and Description |
---|
InvalidateL1Command() |
InvalidateL1Command(Address writeOrigin,
DataContainer dc,
DistributionManager dm,
CacheNotifier notifier,
Set<Flag> flags,
Collection<Object> keys,
CommandInvocationId commandInvocationId) |
InvalidateL1Command(DataContainer dc,
DistributionManager dm,
CacheNotifier notifier,
Set<Flag> flags,
Collection<Object> keys,
CommandInvocationId commandInvocationId) |
InvalidateL1Command(DataContainer dc,
DistributionManager dm,
CacheNotifier notifier,
Set<Flag> flags,
CommandInvocationId commandInvocationId,
Object... keys) |
Modifier and Type | Method and Description |
---|---|
Object |
acceptVisitor(InvocationContext ctx,
Visitor visitor)
Accept a visitor, and return the result of accepting this visitor.
|
byte |
getCommandId()
Used by marshallers to convert this command into an id for streaming.
|
Collection<Object> |
getKeysToLock()
It returns a
Collection with the keys to be lock. |
void |
init(Configuration config,
DistributionManager dm,
CacheNotifier n,
DataContainer dc) |
boolean |
isCausedByALocalWrite(Address address)
Returns true if the write that caused the invalidation was performed on this node.
|
Object |
perform(InvocationContext ctx)
Performs an invalidation on a specified entry
|
void |
readFrom(ObjectInput input)
Reads this instance from the stream written by
ReplicableCommand.writeTo(ObjectOutput) . |
void |
setKeys(Object[] keys) |
boolean |
shouldInvoke(InvocationContext ctx)
Used by the InboundInvocationHandler to determine whether the command should be invoked or not.
|
String |
toString() |
void |
writeTo(ObjectOutput output)
Writes this instance to the
ObjectOutput . |
equals, getAffectedKeys, getKey, getKeys, hashCode, ignoreCommandOnStatus, invalidate, notify, readsExistingValues
getValue, getValueMatcher, init, isConditional, isNonExistent, isReturnValueExpected, isSuccessful, performRemove, setValue, setValueMatcher, updateStatusFromRemoteResponse
canBlock, getKeyLockOwner, hasSkipLocking, hasZeroLockAcquisition
setKey
getMetadata, getTopologyId, setMetadata, setTopologyId
getFlags, setFlags
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
isWriteOnly
alwaysReadsExistingValues
getTopologyId, setTopologyId
getParameters, setParameters
getMetadata, setMetadata
public static final int COMMAND_ID
public InvalidateL1Command()
public InvalidateL1Command(DataContainer dc, DistributionManager dm, CacheNotifier notifier, Set<Flag> flags, CommandInvocationId commandInvocationId, Object... keys)
public InvalidateL1Command(DataContainer dc, DistributionManager dm, CacheNotifier notifier, Set<Flag> flags, Collection<Object> keys, CommandInvocationId commandInvocationId)
public InvalidateL1Command(Address writeOrigin, DataContainer dc, DistributionManager dm, CacheNotifier notifier, Set<Flag> flags, Collection<Object> keys, CommandInvocationId commandInvocationId)
public byte getCommandId()
ReplicableCommand
getCommandId
in interface ReplicableCommand
getCommandId
in class InvalidateCommand
public void init(Configuration config, DistributionManager dm, CacheNotifier n, DataContainer dc)
public Object perform(InvocationContext ctx) throws Throwable
InvalidateCommand
perform
in interface ReplicableCommand
perform
in class InvalidateCommand
ctx
- invocation contextThrowable
- in the event of problems.public void setKeys(Object[] keys)
public boolean shouldInvoke(InvocationContext ctx)
VisitableCommand
shouldInvoke
in interface VisitableCommand
shouldInvoke
in class AbstractDataCommand
public Collection<Object> getKeysToLock()
RemoteLockCommand
Collection
with the keys to be lock.
It may return an empty collection if no keys needs to be locked independently of the return value of RemoteLockCommand.hasSkipLocking()
. It may contains duplicated keys and null
is not a valid return value.
getKeysToLock
in interface RemoteLockCommand
getKeysToLock
in class InvalidateCommand
Collection
of keys to lock.public void writeTo(ObjectOutput output) throws IOException
ReplicableCommand
ObjectOutput
.writeTo
in interface ReplicableCommand
writeTo
in class InvalidateCommand
output
- the stream.IOException
- if an error occurred during the I/O.public void readFrom(ObjectInput input) throws IOException, ClassNotFoundException
ReplicableCommand
ReplicableCommand.writeTo(ObjectOutput)
.readFrom
in interface ReplicableCommand
readFrom
in class InvalidateCommand
input
- the stream to read.IOException
- if an error occurred during the I/O.ClassNotFoundException
- if it tries to load an undefined class.public Object acceptVisitor(InvocationContext ctx, Visitor visitor) throws Throwable
VisitableCommand
acceptVisitor
in interface VisitableCommand
acceptVisitor
in class InvalidateCommand
ctx
- invocation contextvisitor
- visitor to acceptThrowable
- in the event of problemspublic String toString()
toString
in class InvalidateCommand
public boolean isCausedByALocalWrite(Address address)
Copyright © 2022 JBoss, a division of Red Hat. All rights reserved.