Infinispan Distribution 5.2.6.Final-redhat-2

org.infinispan.interceptors.distribution
Class NonTxDistributionInterceptor

java.lang.Object
  extended by org.infinispan.commands.AbstractVisitor
      extended by org.infinispan.interceptors.base.CommandInterceptor
          extended by org.infinispan.interceptors.base.BaseRpcInterceptor
              extended by org.infinispan.interceptors.ClusteringInterceptor
                  extended by org.infinispan.interceptors.distribution.BaseDistributionInterceptor
                      extended by 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
NonTxDistributionInterceptor()
           
 
Method Summary
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, isSynchronous, shouldInvokeRemoteTxCommand
 
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

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)

Infinispan Distribution 5.2.6.Final-redhat-2

Copyright © 2013 JBoss, a division of Red Hat. All Rights Reserved.