Package org.infinispan.interceptors.impl

Class BiasedEntryWrappingInterceptor

java.lang.Object

org.infinispan.interceptors.BaseAsyncInterceptor

org.infinispan.interceptors.DDAsyncInterceptor

org.infinispan.interceptors.impl.EntryWrappingInterceptor

org.infinispan.interceptors.impl.RetryingEntryWrappingInterceptor

org.infinispan.interceptors.impl.BiasedEntryWrappingInterceptor

All Implemented Interfaces:

Visitor, AsyncInterceptor

public class BiasedEntryWrappingInterceptor
extends RetryingEntryWrappingInterceptor

Field Summary

Fields inherited from class org.infinispan.interceptors.impl.EntryWrappingInterceptor

cdl, distributionManager

Fields inherited from class org.infinispan.interceptors.BaseAsyncInterceptor

cacheConfiguration

Constructor Summary

Constructors

Constructor	Description
BiasedEntryWrappingInterceptor()

Method Summary

Modifier and Type	Method	Description
protected boolean	canRead(DataCommand command)
protected boolean	canReadKey(Object key)
void	inject(BiasManager biasManager)
protected Object	setSkipRemoteGetsAndInvokeNextForDataCommand(InvocationContext ctx, org.infinispan.commands.write.DataWriteCommand command, CompletionStage<Void> delay)	Locks the value for the keys accessed by the command to avoid being override from a remote get.
protected Object	setSkipRemoteGetsAndInvokeNextForManyEntriesCommand(InvocationContext ctx, org.infinispan.commands.write.WriteCommand command, CompletionStage<Void> delay)	Locks the value for the keys accessed by the command to avoid being override from a remote get.

Methods inherited from class org.infinispan.interceptors.impl.EntryWrappingInterceptor

commitContextEntries, commitContextEntry, shouldCommitDuringPrepare, start, visitClearCommand, visitCommitCommand, visitComputeCommand, visitComputeIfAbsentCommand, visitEvictCommand, visitGetAllCommand, visitGetCacheEntryCommand, visitGetKeysInGroupCommand, visitGetKeyValueCommand, visitInvalidateCommand, visitInvalidateL1Command, visitPrepareCommand, visitPutKeyValueCommand, visitPutMapCommand, visitReadOnlyKeyCommand, visitReadOnlyManyCommand, visitReadWriteKeyCommand, visitReadWriteKeyValueCommand, visitReadWriteManyCommand, visitReadWriteManyEntriesCommand, visitRemoveCommand, visitRemoveExpiredCommand, visitReplaceCommand, visitWriteOnlyKeyCommand, visitWriteOnlyKeyValueCommand, visitWriteOnlyManyCommand, visitWriteOnlyManyEntriesCommand, wrapEntriesForPrepareAndApply

Methods inherited from class org.infinispan.interceptors.DDAsyncInterceptor

handleDefault, visitCommand, visitDistributedExecuteCommand, visitEntrySetCommand, visitKeySetCommand, visitLockControlCommand, visitRollbackCommand, visitSizeCommand, visitUnknownCommand

Methods inherited from class org.infinispan.interceptors.BaseAsyncInterceptor

asyncInvokeNext, asyncInvokeNext, asyncInvokeNext, asyncValue, delayedValue, delayedValue, invokeNext, invokeNextAndExceptionally, invokeNextAndFinally, invokeNextAndHandle, invokeNextThenAccept, invokeNextThenApply, isSuccessfullyDone, makeStage, setNextInterceptor, valueOrException

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.infinispan.commands.Visitor

visitApplyDeltaCommand

Constructor Detail

BiasedEntryWrappingInterceptor

public BiasedEntryWrappingInterceptor()

Method Detail

inject

public void inject(BiasManager biasManager)

canRead

protected boolean canRead(DataCommand command)

Overrides:

canRead in class EntryWrappingInterceptor

canReadKey

protected boolean canReadKey(Object key)

Overrides:

canReadKey in class EntryWrappingInterceptor

setSkipRemoteGetsAndInvokeNextForDataCommand

protected Object setSkipRemoteGetsAndInvokeNextForDataCommand(InvocationContext ctx,
                                                              org.infinispan.commands.write.DataWriteCommand command,
                                                              CompletionStage<Void> delay)

Description copied from class: EntryWrappingInterceptor

Locks the value for the keys accessed by the command to avoid being override from a remote get.

Overrides:

setSkipRemoteGetsAndInvokeNextForDataCommand in class RetryingEntryWrappingInterceptor

setSkipRemoteGetsAndInvokeNextForManyEntriesCommand

protected Object setSkipRemoteGetsAndInvokeNextForManyEntriesCommand(InvocationContext ctx,
                                                                     org.infinispan.commands.write.WriteCommand command,
                                                                     CompletionStage<Void> delay)

Description copied from class: EntryWrappingInterceptor

Locks the value for the keys accessed by the command to avoid being override from a remote get.

Overrides:

setSkipRemoteGetsAndInvokeNextForManyEntriesCommand in class RetryingEntryWrappingInterceptor