org.infinispan.interceptors.distribution

Class L1NonTxInterceptor

java.lang.Object

org.infinispan.commands.AbstractVisitor

org.infinispan.interceptors.base.CommandInterceptor

org.infinispan.interceptors.base.BaseRpcInterceptor

org.infinispan.interceptors.distribution.L1NonTxInterceptor

All Implemented Interfaces:

Visitor

Direct Known Subclasses:

L1TxInterceptor

public class L1NonTxInterceptor
extends BaseRpcInterceptor

Interceptor that handles L1 logic for non-transactional caches.

Since:

5.2

Author:

Mircea Markus, William Burns

Field Summary

Fields

Modifier and Type	Field and Description
protected ClusteringDependentLogic	cdl
protected Configuration	config
protected DataContainer	dataContainer
protected EntryFactory	entryFactory
protected L1Manager	l1Manager
protected StateTransferLock	stateTransferLock

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
L1NonTxInterceptor()

Method Summary

Methods

Modifier and Type	Method and Description
void	init(L1Manager l1Manager, ClusteringDependentLogic cdl, EntryFactory entryFactory, DataContainer dataContainer, Configuration config, StateTransferLock stateTransferLock)
protected Object	performCommandWithL1WriteIfAble(InvocationContext ctx, DataCommand command, boolean shouldAlwaysRunNextInterceptor, boolean registerL1)
protected Object	performL1Lookup(InvocationContext ctx, boolean runInterceptorOnConflict, Object key, DataCommand command)
protected boolean	skipL1Lookup(LocalFlagAffectedCommand command, Object key)
void	start()
Object	visitGetKeyValueCommand(InvocationContext ctx, GetKeyValueCommand command)
Object	visitInvalidateL1Command(InvocationContext ctx, InvalidateL1Command invalidateL1Command)
Object	visitPutKeyValueCommand(InvocationContext ctx, PutKeyValueCommand command)
Object	visitPutMapCommand(InvocationContext ctx, PutMapCommand command)
Object	visitRemoveCommand(InvocationContext ctx, RemoveCommand command)
Object	visitReplaceCommand(InvocationContext ctx, ReplaceCommand command)

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

getIgnoreExtraResponseFilter, getSelfDeliverFilter, init, inject, isLocalModeForced, isSyncCommitPhase, isSynchronous, shouldInvokeRemoteTxCommand, shouldTotalOrderRollbackBeInvokedRemotely, totalOrderAnycastPrepare, totalOrderBroadcastPrepare, totalOrderTxCommit, totalOrderTxRollback, transactionRemotelyPrepared

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

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

Methods inherited from class org.infinispan.commands.AbstractVisitor

visitApplyDeltaCommand, visitClearCommand, visitCollection, visitCommitCommand, visitDistributedExecuteCommand, visitEntrySetCommand, visitEvictCommand, visitInvalidateCommand, 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

Field Detail

l1Manager

protected L1Manager l1Manager

cdl

protected ClusteringDependentLogic cdl

entryFactory

protected EntryFactory entryFactory

dataContainer

protected DataContainer dataContainer

config

protected Configuration config

stateTransferLock

protected StateTransferLock stateTransferLock

Constructor Detail

L1NonTxInterceptor

public L1NonTxInterceptor()

Method Detail

init

public void init(L1Manager l1Manager,
        ClusteringDependentLogic cdl,
        EntryFactory entryFactory,
        DataContainer dataContainer,
        Configuration config,
        StateTransferLock stateTransferLock)

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

performCommandWithL1WriteIfAble

protected Object performCommandWithL1WriteIfAble(InvocationContext ctx,
                                     DataCommand command,
                                     boolean shouldAlwaysRunNextInterceptor,
                                     boolean registerL1)
                                          throws Throwable

Throws:

Throwable

performL1Lookup

protected Object performL1Lookup(InvocationContext ctx,
                     boolean runInterceptorOnConflict,
                     Object key,
                     DataCommand command)
                          throws Throwable

Throws:

Throwable

skipL1Lookup

protected boolean skipL1Lookup(LocalFlagAffectedCommand command,
                   Object key)

visitPutKeyValueCommand

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

Specified by:

visitPutKeyValueCommand in interface Visitor

Overrides:

visitPutKeyValueCommand in class AbstractVisitor

Throws:

Throwable

visitRemoveCommand

public Object visitRemoveCommand(InvocationContext ctx,
                        RemoveCommand command)
                          throws Throwable

Specified by:

visitRemoveCommand in interface Visitor

Overrides:

visitRemoveCommand in class AbstractVisitor

Throws:

Throwable

visitReplaceCommand

public Object visitReplaceCommand(InvocationContext ctx,
                         ReplaceCommand command)
                           throws Throwable

Specified by:

visitReplaceCommand in interface Visitor

Overrides:

visitReplaceCommand in class AbstractVisitor

Throws:

Throwable

visitPutMapCommand

public Object visitPutMapCommand(InvocationContext ctx,
                        PutMapCommand command)
                          throws Throwable

Specified by:

visitPutMapCommand in interface Visitor

Overrides:

visitPutMapCommand in class AbstractVisitor

Throws:

Throwable

visitInvalidateL1Command

public Object visitInvalidateL1Command(InvocationContext ctx,
                              InvalidateL1Command invalidateL1Command)
                                throws Throwable

Specified by:

visitInvalidateL1Command in interface Visitor

Overrides:

visitInvalidateL1Command in class AbstractVisitor

Throws:

Throwable