org.infinispan.interceptors.distribution

Class NonTxDistributionInterceptor

java.lang.Object

org.infinispan.commands.AbstractVisitor

org.infinispan.interceptors.base.CommandInterceptor

org.infinispan.interceptors.base.BaseRpcInterceptor

org.infinispan.interceptors.ClusteringInterceptor

org.infinispan.interceptors.distribution.BaseDistributionInterceptor

org.infinispan.interceptors.distribution.NonTxDistributionInterceptor

All Implemented Interfaces:

Visitor

Direct Known Subclasses:

NonTxConcurrentDistributionInterceptor

public class NonTxDistributionInterceptor
extends BaseDistributionInterceptor

Handles the distribution of the non-transactional caches.

Since:

5.2

Author:

Mircea Markus

Field Summary

Fields inherited from class org.infinispan.interceptors.distribution.BaseDistributionInterceptor

cdl, dm

Fields inherited from class org.infinispan.interceptors.ClusteringInterceptor

cf, dataContainer, entryFactory, lockManager, needReliableReturnValues, stateTransferManager

Fields inherited from class org.infinispan.interceptors.base.BaseRpcInterceptor

defaultSynchronous, rpcManager

Fields inherited from class org.infinispan.interceptors.base.CommandInterceptor

cacheConfiguration

Constructor Summary

Constructors

Constructor and Description
NonTxDistributionInterceptor()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	checkForOutdatedTopology(WriteCommand command)
protected Object	getResponseFromPrimaryOwner(Address primaryOwner, Map<Address,Response> addressResponseMap)
protected Object	handleLocalWrite(InvocationContext ctx, WriteCommand command, org.infinispan.interceptors.distribution.BaseDistributionInterceptor.RecipientGenerator rg, boolean skipL1Invalidation, boolean sync)
protected void	handleRemoteWrite(InvocationContext ctx, WriteCommand command, org.infinispan.interceptors.distribution.BaseDistributionInterceptor.RecipientGenerator recipientGenerator, boolean skipL1Invalidation, boolean sync)
protected Object	handleWriteCommand(InvocationContext ctx, WriteCommand command, org.infinispan.interceptors.distribution.BaseDistributionInterceptor.RecipientGenerator recipientGenerator, boolean skipRemoteGet, boolean skipL1Invalidation)
void	start()
Object	visitClearCommand(InvocationContext ctx, ClearCommand command) Don't forward in the case of clear commands, just acquire local locks and broadcast.
Object	visitGetKeyValueCommand(InvocationContext ctx, GetKeyValueCommand command)
Object	visitPutKeyValueCommand(InvocationContext ctx, PutKeyValueCommand command)

Methods inherited from class org.infinispan.interceptors.distribution.BaseDistributionInterceptor

getLog, injectDependencies, isSingleOwnerAndLocal, retrieveFromRemoteSource, visitPutMapCommand, visitRemoveCommand, visitReplaceCommand

Methods inherited from class org.infinispan.interceptors.ClusteringInterceptor

configure, ignorePreviousValueOnBackup, injectDependencies, isNeedReliableReturnValues, needsRemoteGet

Methods inherited from class org.infinispan.interceptors.base.BaseRpcInterceptor

init, inject, isLocalModeForced, isSyncCommitPhase, isSynchronous, shouldInvokeRemoteTxCommand, transactionRemotelyPrepared

Methods inherited from class org.infinispan.interceptors.base.CommandInterceptor

getLockAcquisitionTimeout, getNext, handleDefault, hasNext, hasSkipLocking, injectConfiguration, invokeNextInterceptor, setNext

Methods inherited from class org.infinispan.commands.AbstractVisitor

visitApplyDeltaCommand, visitCollection, visitCommitCommand, visitDistributedExecuteCommand, visitEntrySetCommand, visitEvictCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitLockControlCommand, visitPrepareCommand, visitRollbackCommand, visitSizeCommand, visitUnknownCommand, visitValuesCommand

Methods inherited from class java.lang.Object

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

Constructor Detail

NonTxDistributionInterceptor

public NonTxDistributionInterceptor()

Method Detail

start

public void start()

visitGetKeyValueCommand

public Object visitGetKeyValueCommand(InvocationContext ctx,
                             GetKeyValueCommand command)
                               throws Throwable

Specified by:

visitGetKeyValueCommand in interface Visitor

Overrides:

visitGetKeyValueCommand in class AbstractVisitor

Throws:

Throwable

visitPutKeyValueCommand

public Object visitPutKeyValueCommand(InvocationContext ctx,
                             PutKeyValueCommand command)
                               throws Throwable

Specified by:

visitPutKeyValueCommand in interface Visitor

Overrides:

visitPutKeyValueCommand in class AbstractVisitor

Throws:

Throwable

visitClearCommand

public Object visitClearCommand(InvocationContext ctx,
                       ClearCommand command)
                         throws Throwable

Don't forward in the case of clear commands, just acquire local locks and broadcast.

Specified by:

visitClearCommand in interface Visitor

Overrides:

visitClearCommand in class AbstractVisitor

Throws:

Throwable

handleWriteCommand

protected Object handleWriteCommand(InvocationContext ctx,
                        WriteCommand command,
                        org.infinispan.interceptors.distribution.BaseDistributionInterceptor.RecipientGenerator recipientGenerator,
                        boolean skipRemoteGet,
                        boolean skipL1Invalidation)
                             throws Throwable

Specified by:

handleWriteCommand in class BaseDistributionInterceptor

Throws:

Throwable

checkForOutdatedTopology

protected void checkForOutdatedTopology(WriteCommand command)

handleLocalWrite

protected Object handleLocalWrite(InvocationContext ctx,
                      WriteCommand command,
                      org.infinispan.interceptors.distribution.BaseDistributionInterceptor.RecipientGenerator rg,
                      boolean skipL1Invalidation,
                      boolean sync)
                           throws Throwable

Throws:

Throwable

handleRemoteWrite

protected void handleRemoteWrite(InvocationContext ctx,
                     WriteCommand command,
                     org.infinispan.interceptors.distribution.BaseDistributionInterceptor.RecipientGenerator recipientGenerator,
                     boolean skipL1Invalidation,
                     boolean sync)
                          throws Throwable

Throws:

Throwable

getResponseFromPrimaryOwner

protected Object getResponseFromPrimaryOwner(Address primaryOwner,
                                 Map<Address,Response> addressResponseMap)