org.infinispan.interceptors.impl

Class AbstractIracLocalSiteInterceptor

java.lang.Object

org.infinispan.interceptors.BaseAsyncInterceptor

org.infinispan.interceptors.DDAsyncInterceptor

org.infinispan.interceptors.impl.AbstractIracLocalSiteInterceptor

All Implemented Interfaces:

Visitor, AsyncInterceptor

Direct Known Subclasses:

AbstractIracRemoteSiteInterceptor, NonTxIracLocalSiteInterceptor, OptimisticTxIracLocalSiteInterceptor, PessimisticTxIracLocalInterceptor

public abstract class AbstractIracLocalSiteInterceptor
extends DDAsyncInterceptor

A DDAsyncInterceptor with common code for all the IRAC related interceptors.

Since:

11.0

Author:

Pedro Ruivo

Field Summary

Fields inherited from class org.infinispan.interceptors.BaseAsyncInterceptor

cacheConfiguration

Constructor Summary

Constructors

Constructor and Description
AbstractIracLocalSiteInterceptor()

Method Summary

Modifier and Type	Method and Description
protected LocalizedCacheTopology	getCacheTopology()
protected DistributionInfo	getDistributionInfo(int segment)
protected DistributionInfo	getDistributionInfo(Object key)
protected Ownership	getOwnership(int segment)
protected Ownership	getOwnership(Object key)
protected int	getSegment(WriteCommand command, Object key)
protected static boolean	isIracState(FlagAffectedCommand command)
protected static boolean	isNormalWriteCommand(WriteCommand command)
protected boolean	isPrimaryOwner(org.infinispan.interceptors.impl.AbstractIracLocalSiteInterceptor.StreamData data)
protected boolean	isWriteOwner(org.infinispan.interceptors.impl.AbstractIracLocalSiteInterceptor.StreamData data)
protected void	setIracMetadata(CacheEntry<?,?> entry, IracMetadata metadata)
protected void	setMetadataToCacheEntry(CacheEntry<?,?> entry, IracMetadata metadata)
protected Stream<org.infinispan.interceptors.impl.AbstractIracLocalSiteInterceptor.StreamData>	streamKeysFromCommand(WriteCommand command)
protected Stream<org.infinispan.interceptors.impl.AbstractIracLocalSiteInterceptor.StreamData>	streamKeysFromModifications(Stream<WriteCommand> modsStream)
protected Stream<org.infinispan.interceptors.impl.AbstractIracLocalSiteInterceptor.StreamData>	streamKeysFromModifications(WriteCommand[] mods)

Methods inherited from class org.infinispan.interceptors.DDAsyncInterceptor

handleDefault, visitClearCommand, visitCommand, visitCommitCommand, visitComputeCommand, visitComputeIfAbsentCommand, visitEntrySetCommand, visitEvictCommand, visitGetAllCommand, visitGetCacheEntryCommand, visitGetKeysInGroupCommand, visitGetKeyValueCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitLockControlCommand, visitPrepareCommand, visitPutKeyValueCommand, visitPutMapCommand, visitReadOnlyKeyCommand, visitReadOnlyManyCommand, visitReadWriteKeyCommand, visitReadWriteKeyValueCommand, visitReadWriteManyCommand, visitReadWriteManyEntriesCommand, visitRemoveCommand, visitReplaceCommand, visitRollbackCommand, visitSizeCommand, visitUnknownCommand, visitWriteOnlyKeyCommand, visitWriteOnlyKeyValueCommand, visitWriteOnlyManyCommand, visitWriteOnlyManyEntriesCommand

Methods inherited from class org.infinispan.interceptors.BaseAsyncInterceptor

asyncInvokeNext, asyncInvokeNext, asyncInvokeNext, asyncValue, delayedNull, 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

visitRemoveExpiredCommand

Constructor Detail

AbstractIracLocalSiteInterceptor

public AbstractIracLocalSiteInterceptor()

Method Detail

isNormalWriteCommand

protected static boolean isNormalWriteCommand(WriteCommand command)

isIracState

protected static boolean isIracState(FlagAffectedCommand command)

getOwnership

protected Ownership getOwnership(int segment)

getOwnership

protected Ownership getOwnership(Object key)

getDistributionInfo

protected DistributionInfo getDistributionInfo(int segment)

getDistributionInfo

protected DistributionInfo getDistributionInfo(Object key)

isWriteOwner

protected boolean isWriteOwner(org.infinispan.interceptors.impl.AbstractIracLocalSiteInterceptor.StreamData data)

isPrimaryOwner

protected boolean isPrimaryOwner(org.infinispan.interceptors.impl.AbstractIracLocalSiteInterceptor.StreamData data)

getCacheTopology

protected LocalizedCacheTopology getCacheTopology()

getSegment

protected int getSegment(WriteCommand command,
                         Object key)

setMetadataToCacheEntry

protected void setMetadataToCacheEntry(CacheEntry<?,?> entry,
                                       IracMetadata metadata)

setIracMetadata

protected final void setIracMetadata(CacheEntry<?,?> entry,
                                     IracMetadata metadata)

streamKeysFromModifications

protected Stream<org.infinispan.interceptors.impl.AbstractIracLocalSiteInterceptor.StreamData> streamKeysFromModifications(WriteCommand[] mods)

streamKeysFromModifications

protected Stream<org.infinispan.interceptors.impl.AbstractIracLocalSiteInterceptor.StreamData> streamKeysFromModifications(Stream<WriteCommand> modsStream)

streamKeysFromCommand

protected Stream<org.infinispan.interceptors.impl.AbstractIracLocalSiteInterceptor.StreamData> streamKeysFromCommand(WriteCommand command)