org.infinispan.interceptors.impl

Class AbstractIracRemoteSiteInterceptor

java.lang.Object

org.infinispan.interceptors.BaseAsyncInterceptor

org.infinispan.interceptors.DDAsyncInterceptor

org.infinispan.interceptors.impl.AbstractIracLocalSiteInterceptor

org.infinispan.interceptors.impl.AbstractIracRemoteSiteInterceptor

All Implemented Interfaces:

Visitor, AsyncInterceptor

Direct Known Subclasses:

NonTxIracRemoteSiteInterceptor, OptimisticTxIracRemoteSiteInterceptor, PessimisticTxIracRemoteSiteInterceptor

public abstract class AbstractIracRemoteSiteInterceptor
extends AbstractIracLocalSiteInterceptor

An IRAC related interceptor that that handles the requests from the remote site.

This class contains only the common code and it is always present in the AsyncInterceptorChain because the cache has no knowledge if it is a backup from others site or not.

Since:

11.0

Author:

Pedro Ruivo

Field Summary

Fields inherited from class org.infinispan.interceptors.BaseAsyncInterceptor

cacheConfiguration

Constructor Summary

Constructors

Constructor and Description
AbstractIracRemoteSiteInterceptor()

Method Summary

Modifier and Type	Method and Description
protected void	setIracMetadataForOwner(InvocationContext ctx, DataWriteCommand command, Object rv) Invoked by backup owners, it make sure the entry has the same version as set by the primary owner.
protected void	validateOnPrimary(InvocationContext ctx, DataWriteCommand command, Object rv) Invoked on the primary owner, it validates if the remote site update is valid or not.

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

getCacheTopology, getDistributionInfo, getDistributionInfo, getOwnership, getOwnership, getSegment, isIracState, isNormalWriteCommand, isPrimaryOwner, isWriteOwner, setIracMetadata, setMetadataToCacheEntry, streamKeysFromCommand, streamKeysFromModifications, streamKeysFromModifications

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

AbstractIracRemoteSiteInterceptor

public AbstractIracRemoteSiteInterceptor()

Method Detail

validateOnPrimary

protected void validateOnPrimary(InvocationContext ctx,
                                 DataWriteCommand command,
                                 Object rv)

Invoked on the primary owner, it validates if the remote site update is valid or not.

It also performs a conflict resolution if a conflict is found.

setIracMetadataForOwner

protected void setIracMetadataForOwner(InvocationContext ctx,
                                       DataWriteCommand command,
                                       Object rv)

Invoked by backup owners, it make sure the entry has the same version as set by the primary owner.