java.lang.Object
- org.infinispan.interceptors.BaseAsyncInterceptor
- - org.infinispan.interceptors.DDAsyncInterceptor
  - - org.infinispan.interceptors.impl.BaseRpcInterceptor
    - - org.infinispan.interceptors.impl.ClusteringInterceptor
      - org.infinispan.interceptors.distribution.ScatteredDistributionInterceptor

All Implemented Interfaces:

Visitor, AsyncInterceptor

Direct Known Subclasses:

BiasedScatteredDistributionInterceptor
```
public class ScatteredDistributionInterceptor
extends ClusteringInterceptor
```
This interceptor mixes several functions: A) replicates changes to other nodes B) commits the entry C) schedules invalidation On primary owner, the commit is executed before the change is replicated to other node. If the command reads previous value and the version of entry in DataContainer has changed during execution ConcurrentChangeException is thrown and the command has to be retried.

Author:

Radim Vansa <rvansa@redhat.com>

Nested Class Summary

Nested Classes
Modifier and Type	Class	Description
`protected static class`	`ScatteredDistributionInterceptor.PrimaryResponseGenerator`
`protected class`	`ScatteredDistributionInterceptor.PrimaryResponseHandler`

Nested classes/interfaces inherited from class org.infinispan.interceptors.impl.ClusteringInterceptor
ClusteringInterceptor.ClusteredGetAllFuture

Field Summary

Fields
Modifier and Type	Field	Description
`protected CacheNotifier`	`cacheNotifier`
`protected FunctionalNotifier`	`functionalNotifier`
`protected GroupManager`	`groupManager`
`protected KeyPartitioner`	`keyPartitioner`
`protected ScatteredVersionManager<Object>`	`svm`
`protected TimeService`	`timeService`

Fields inherited from class org.infinispan.interceptors.impl.ClusteringInterceptor
cf, dataContainer, distributionManager, entryFactory, lockManager

Fields inherited from class org.infinispan.interceptors.impl.BaseRpcInterceptor
componentRegistry, defaultSynchronous, rpcManager

Fields inherited from class org.infinispan.interceptors.BaseAsyncInterceptor
cacheConfiguration

Constructor Summary

Constructors
Constructor Description

ScatteredDistributionInterceptor()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`protected void`	`completeManyWriteOnPrimaryOriginator(org.infinispan.commands.write.WriteCommand command, Address backup, org.infinispan.interceptors.distribution.CountDownCompletableFuture future)`	This is a hook for bias-enabled mode where the primary performs additional RPCs but replication to another node.
`protected CompletionStage<?>`	`completeSingleWriteOnPrimaryOriginator(org.infinispan.commands.write.DataWriteCommand command, Address backup, CompletionStage<?> rpcFuture)`	This is a hook for bias-enabled mode where the primary performs additional RPCs but replication to another node.
`protected <C extends org.infinispan.commands.write.WriteCommand> CommandAckCollector.MultiTargetCollector`	`createMultiTargetCollector(C command, int primaries)`
`protected Log`	`getLog()`
`protected void`	`handleClear(InvocationContext ctx, VisitableCommand command, Object ignored)`
`protected CompletionStage<ValidResponse>`	`manyWriteOnRemotePrimary(Address target, org.infinispan.commands.write.WriteCommand command, CommandAckCollector.MultiTargetCollector multiTargetCollector)`
`protected Object`	`manyWriteResponse(InvocationContext ctx, org.infinispan.commands.write.WriteCommand cmd, Object returnValue)`
`protected void`	`scheduleKeyInvalidation(Object key, EntryVersion nextVersion, boolean removed)`
`protected CompletionStage<ValidResponse>`	`singleWriteOnRemotePrimary(Address target, org.infinispan.commands.write.DataWriteCommand command)`	This method is called by a non-owner sending write request to the primary owner
`protected Object`	`singleWriteResponse(InvocationContext ctx, org.infinispan.commands.write.DataWriteCommand cmd, Object returnValue)`	This method is called by primary owner responding to the originator after write has been completed
`Object`	`visitClearCommand(InvocationContext ctx, org.infinispan.commands.write.ClearCommand command)`
`Object`	`visitComputeCommand(InvocationContext ctx, org.infinispan.commands.write.ComputeCommand command)`
`Object`	`visitComputeIfAbsentCommand(InvocationContext ctx, org.infinispan.commands.write.ComputeIfAbsentCommand command)`
`Object`	`visitEvictCommand(InvocationContext ctx, org.infinispan.commands.write.EvictCommand command)`
`Object`	`visitGetAllCommand(InvocationContext ctx, org.infinispan.commands.read.GetAllCommand command)`
`Object`	`visitGetCacheEntryCommand(InvocationContext ctx, org.infinispan.commands.read.GetCacheEntryCommand command)`
`Object`	`visitGetKeysInGroupCommand(InvocationContext ctx, org.infinispan.commands.remote.GetKeysInGroupCommand command)`
`Object`	`visitGetKeyValueCommand(InvocationContext ctx, org.infinispan.commands.read.GetKeyValueCommand command)`
`Object`	`visitPutKeyValueCommand(InvocationContext ctx, org.infinispan.commands.write.PutKeyValueCommand command)`
`Object`	`visitPutMapCommand(InvocationContext ctx, org.infinispan.commands.write.PutMapCommand command)`
`Object`	`visitReadOnlyKeyCommand(InvocationContext ctx, org.infinispan.commands.functional.ReadOnlyKeyCommand command)`
`Object`	`visitReadOnlyManyCommand(InvocationContext ctx, org.infinispan.commands.functional.ReadOnlyManyCommand command)`
`Object`	`visitReadWriteKeyCommand(InvocationContext ctx, org.infinispan.commands.functional.ReadWriteKeyCommand command)`
`Object`	`visitReadWriteKeyValueCommand(InvocationContext ctx, org.infinispan.commands.functional.ReadWriteKeyValueCommand command)`
`Object`	`visitReadWriteManyCommand(InvocationContext ctx, org.infinispan.commands.functional.ReadWriteManyCommand command)`
`Object`	`visitReadWriteManyEntriesCommand(InvocationContext ctx, org.infinispan.commands.functional.ReadWriteManyEntriesCommand command)`
`Object`	`visitRemoveCommand(InvocationContext ctx, org.infinispan.commands.write.RemoveCommand command)`
`Object`	`visitReplaceCommand(InvocationContext ctx, org.infinispan.commands.write.ReplaceCommand command)`
`Object`	`visitWriteOnlyKeyCommand(InvocationContext ctx, org.infinispan.commands.functional.WriteOnlyKeyCommand command)`
`Object`	`visitWriteOnlyKeyValueCommand(InvocationContext ctx, org.infinispan.commands.functional.WriteOnlyKeyValueCommand command)`
`Object`	`visitWriteOnlyManyCommand(InvocationContext ctx, org.infinispan.commands.functional.WriteOnlyManyCommand command)`
`Object`	`visitWriteOnlyManyEntriesCommand(InvocationContext ctx, org.infinispan.commands.functional.WriteOnlyManyEntriesCommand command)`

Methods inherited from class org.infinispan.interceptors.impl.ClusteringInterceptor
getSuccessfulResponseOrFail, unexpected

Methods inherited from class org.infinispan.interceptors.impl.BaseRpcInterceptor
init, isLocalModeForced, isSynchronous, shouldInvokeRemoteTxCommand, shouldTotalOrderRollbackBeInvokedRemotely, totalOrderPrepare, totalOrderTxCommit, totalOrderTxRollback, transactionRemotelyPrepared

Methods inherited from class org.infinispan.interceptors.DDAsyncInterceptor
handleDefault, visitCommand, visitCommitCommand, visitDistributedExecuteCommand, visitEntrySetCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitLockControlCommand, visitPrepareCommand, visitRollbackCommand, visitSizeCommand, visitUnknownCommand

Methods inherited from class org.infinispan.interceptors.BaseAsyncInterceptor
asyncInvokeNext, asyncInvokeNext, asyncInvokeNext, asyncValue, 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
visitApplyDeltaCommand, visitRemoveExpiredCommand

Field Detail

svm

protected ScatteredVersionManager<Object> svm

groupManager
```
protected GroupManager groupManager
```

timeService
```
protected TimeService timeService
```

cacheNotifier
```
protected CacheNotifier cacheNotifier
```

functionalNotifier

protected FunctionalNotifier functionalNotifier

keyPartitioner

protected KeyPartitioner keyPartitioner

Constructor Detail
- ScatteredDistributionInterceptor
```
public ScatteredDistributionInterceptor()
```

Method Detail

visitEvictCommand

public Object visitEvictCommand(InvocationContext ctx,
                                org.infinispan.commands.write.EvictCommand command)

Specified by:: visitEvictCommand in interface Visitor
Overrides:: visitEvictCommand in class DDAsyncInterceptor

singleWriteOnRemotePrimary

protected CompletionStage<ValidResponse> singleWriteOnRemotePrimary(Address target,
                                                                    org.infinispan.commands.write.DataWriteCommand command)

This method is called by a non-owner sending write request to the primary owner

manyWriteOnRemotePrimary

protected CompletionStage<ValidResponse> manyWriteOnRemotePrimary(Address target,
                                                                  org.infinispan.commands.write.WriteCommand command,
                                                                  CommandAckCollector.MultiTargetCollector multiTargetCollector)

completeSingleWriteOnPrimaryOriginator

protected CompletionStage<?> completeSingleWriteOnPrimaryOriginator(org.infinispan.commands.write.DataWriteCommand command,
                                                                    Address backup,
                                                                    CompletionStage<?> rpcFuture)

This is a hook for bias-enabled mode where the primary performs additional RPCs but replication to another node. The returned CF will be complete when both the provided rpcFuture completes and all additional RPCs are complete, too. Failure in any of the RPCs will fail this future.

scheduleKeyInvalidation

protected void scheduleKeyInvalidation(Object key,
                                       EntryVersion nextVersion,
                                       boolean removed)

visitPutKeyValueCommand

public Object visitPutKeyValueCommand(InvocationContext ctx,
                                      org.infinispan.commands.write.PutKeyValueCommand command)
                               throws Throwable

Specified by:: visitPutKeyValueCommand in interface Visitor
Overrides:: visitPutKeyValueCommand in class DDAsyncInterceptor
Throws:: Throwable

visitRemoveCommand

public Object visitRemoveCommand(InvocationContext ctx,
                                 org.infinispan.commands.write.RemoveCommand command)
                          throws Throwable

Specified by:: visitRemoveCommand in interface Visitor
Overrides:: visitRemoveCommand in class DDAsyncInterceptor
Throws:: Throwable

visitReplaceCommand

public Object visitReplaceCommand(InvocationContext ctx,
                                  org.infinispan.commands.write.ReplaceCommand command)
                           throws Throwable

Specified by:: visitReplaceCommand in interface Visitor
Overrides:: visitReplaceCommand in class DDAsyncInterceptor
Throws:: Throwable

visitComputeIfAbsentCommand

public Object visitComputeIfAbsentCommand(InvocationContext ctx,
                                          org.infinispan.commands.write.ComputeIfAbsentCommand command)
                                   throws Throwable

Specified by:: visitComputeIfAbsentCommand in interface Visitor
Overrides:: visitComputeIfAbsentCommand in class DDAsyncInterceptor
Throws:: Throwable

visitComputeCommand

public Object visitComputeCommand(InvocationContext ctx,
                                  org.infinispan.commands.write.ComputeCommand command)
                           throws Throwable

Specified by:: visitComputeCommand in interface Visitor
Overrides:: visitComputeCommand in class DDAsyncInterceptor
Throws:: Throwable

visitPutMapCommand

public Object visitPutMapCommand(InvocationContext ctx,
                                 org.infinispan.commands.write.PutMapCommand command)
                          throws Throwable

Specified by:: visitPutMapCommand in interface Visitor
Overrides:: visitPutMapCommand in class DDAsyncInterceptor
Throws:: Throwable

visitGetKeyValueCommand

public Object visitGetKeyValueCommand(InvocationContext ctx,
                                      org.infinispan.commands.read.GetKeyValueCommand command)
                               throws Throwable

Specified by:: visitGetKeyValueCommand in interface Visitor
Overrides:: visitGetKeyValueCommand in class DDAsyncInterceptor
Throws:: Throwable

visitGetCacheEntryCommand

public Object visitGetCacheEntryCommand(InvocationContext ctx,
                                        org.infinispan.commands.read.GetCacheEntryCommand command)
                                 throws Throwable

Specified by:: visitGetCacheEntryCommand in interface Visitor
Overrides:: visitGetCacheEntryCommand in class DDAsyncInterceptor
Throws:: Throwable

visitGetAllCommand

public Object visitGetAllCommand(InvocationContext ctx,
                                 org.infinispan.commands.read.GetAllCommand command)
                          throws Throwable

Specified by:: visitGetAllCommand in interface Visitor
Overrides:: visitGetAllCommand in class DDAsyncInterceptor
Throws:: Throwable

visitClearCommand

public Object visitClearCommand(InvocationContext ctx,
                                org.infinispan.commands.write.ClearCommand command)
                         throws Throwable

Specified by:: visitClearCommand in interface Visitor
Overrides:: visitClearCommand in class DDAsyncInterceptor
Throws:: Throwable

handleClear

protected void handleClear(InvocationContext ctx,
                           VisitableCommand command,
                           Object ignored)

visitReadOnlyKeyCommand

public Object visitReadOnlyKeyCommand(InvocationContext ctx,
                                      org.infinispan.commands.functional.ReadOnlyKeyCommand command)
                               throws Throwable

Specified by:: visitReadOnlyKeyCommand in interface Visitor
Overrides:: visitReadOnlyKeyCommand in class DDAsyncInterceptor
Throws:: Throwable

visitReadOnlyManyCommand

public Object visitReadOnlyManyCommand(InvocationContext ctx,
                                       org.infinispan.commands.functional.ReadOnlyManyCommand command)
                                throws Throwable

Specified by:: visitReadOnlyManyCommand in interface Visitor
Overrides:: visitReadOnlyManyCommand in class DDAsyncInterceptor
Throws:: Throwable

visitWriteOnlyKeyCommand

public Object visitWriteOnlyKeyCommand(InvocationContext ctx,
                                       org.infinispan.commands.functional.WriteOnlyKeyCommand command)
                                throws Throwable

Specified by:: visitWriteOnlyKeyCommand in interface Visitor
Overrides:: visitWriteOnlyKeyCommand in class DDAsyncInterceptor
Throws:: Throwable

visitReadWriteKeyValueCommand

public Object visitReadWriteKeyValueCommand(InvocationContext ctx,
                                            org.infinispan.commands.functional.ReadWriteKeyValueCommand command)
                                     throws Throwable

Specified by:: visitReadWriteKeyValueCommand in interface Visitor
Overrides:: visitReadWriteKeyValueCommand in class DDAsyncInterceptor
Throws:: Throwable

visitReadWriteKeyCommand

public Object visitReadWriteKeyCommand(InvocationContext ctx,
                                       org.infinispan.commands.functional.ReadWriteKeyCommand command)
                                throws Throwable

Specified by:: visitReadWriteKeyCommand in interface Visitor
Overrides:: visitReadWriteKeyCommand in class DDAsyncInterceptor
Throws:: Throwable

createMultiTargetCollector

protected <C extends org.infinispan.commands.write.WriteCommand> CommandAckCollector.MultiTargetCollector createMultiTargetCollector(C command,
                                                                                                                                     int primaries)

visitWriteOnlyManyEntriesCommand

public Object visitWriteOnlyManyEntriesCommand(InvocationContext ctx,
                                               org.infinispan.commands.functional.WriteOnlyManyEntriesCommand command)
                                        throws Throwable

Specified by:: visitWriteOnlyManyEntriesCommand in interface Visitor
Overrides:: visitWriteOnlyManyEntriesCommand in class DDAsyncInterceptor
Throws:: Throwable

visitWriteOnlyKeyValueCommand

public Object visitWriteOnlyKeyValueCommand(InvocationContext ctx,
                                            org.infinispan.commands.functional.WriteOnlyKeyValueCommand command)
                                     throws Throwable

Specified by:: visitWriteOnlyKeyValueCommand in interface Visitor
Overrides:: visitWriteOnlyKeyValueCommand in class DDAsyncInterceptor
Throws:: Throwable

visitWriteOnlyManyCommand

public Object visitWriteOnlyManyCommand(InvocationContext ctx,
                                        org.infinispan.commands.functional.WriteOnlyManyCommand command)
                                 throws Throwable

Specified by:: visitWriteOnlyManyCommand in interface Visitor
Overrides:: visitWriteOnlyManyCommand in class DDAsyncInterceptor
Throws:: Throwable

visitReadWriteManyCommand

public Object visitReadWriteManyCommand(InvocationContext ctx,
                                        org.infinispan.commands.functional.ReadWriteManyCommand command)
                                 throws Throwable

Specified by:: visitReadWriteManyCommand in interface Visitor
Overrides:: visitReadWriteManyCommand in class DDAsyncInterceptor
Throws:: Throwable

visitReadWriteManyEntriesCommand

public Object visitReadWriteManyEntriesCommand(InvocationContext ctx,
                                               org.infinispan.commands.functional.ReadWriteManyEntriesCommand command)
                                        throws Throwable

Specified by:: visitReadWriteManyEntriesCommand in interface Visitor
Overrides:: visitReadWriteManyEntriesCommand in class DDAsyncInterceptor
Throws:: Throwable

visitGetKeysInGroupCommand

public final Object visitGetKeysInGroupCommand(InvocationContext ctx,
                                               org.infinispan.commands.remote.GetKeysInGroupCommand command)
                                        throws Throwable

Specified by:: visitGetKeysInGroupCommand in interface Visitor
Overrides:: visitGetKeysInGroupCommand in class DDAsyncInterceptor
Throws:: Throwable

getLog
```
protected Log getLog()
```
Specified by:

getLog in class BaseRpcInterceptor

singleWriteResponse

protected Object singleWriteResponse(InvocationContext ctx,
                                     org.infinispan.commands.write.DataWriteCommand cmd,
                                     Object returnValue)

This method is called by primary owner responding to the originator after write has been completed

manyWriteResponse

protected Object manyWriteResponse(InvocationContext ctx,
                                   org.infinispan.commands.write.WriteCommand cmd,
                                   Object returnValue)

completeManyWriteOnPrimaryOriginator

protected void completeManyWriteOnPrimaryOriginator(org.infinispan.commands.write.WriteCommand command,
                                                    Address backup,
                                                    org.infinispan.interceptors.distribution.CountDownCompletableFuture future)

This is a hook for bias-enabled mode where the primary performs additional RPCs but replication to another node. Implementation is expected to increment future on each additional RPC and decrement it when the response arrives.

Class ScatteredDistributionInterceptor

Nested Class Summary

Nested classes/interfaces inherited from class org.infinispan.interceptors.impl.ClusteringInterceptor

Field Summary

Fields inherited from class org.infinispan.interceptors.impl.ClusteringInterceptor

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

Fields inherited from class org.infinispan.interceptors.BaseAsyncInterceptor

Constructor Summary