org.infinispan.interceptors.distribution

Class BiasedScatteredDistributionInterceptor

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

org.infinispan.interceptors.distribution.BiasedScatteredDistributionInterceptor

All Implemented Interfaces:

Visitor, AsyncInterceptor

public class BiasedScatteredDistributionInterceptor
extends ScatteredDistributionInterceptor

Nested Class Summary

Nested classes/interfaces inherited from class org.infinispan.interceptors.distribution.ScatteredDistributionInterceptor

ScatteredDistributionInterceptor.PrimaryResponseGenerator, ScatteredDistributionInterceptor.PrimaryResponseHandler

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

ClusteringInterceptor.ClusteredGetAllFuture

Field Summary

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

cacheNotifier, functionalNotifier, groupManager, keyPartitioner, svm, 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 and Description
BiasedScatteredDistributionInterceptor()

Method Summary

Modifier and Type	Method and Description
protected void	completeManyWriteOnPrimaryOriginator(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(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 WriteCommand> CommandAckCollector.MultiTargetCollector	createMultiTargetCollector(C command, int primaries)
protected Object	handleClear(InvocationContext ctx, ClearCommand command, Object ignored)
void	inject(CommandAckCollector collector, BiasManager biasManager)
protected CompletionStage<ValidResponse>	manyWriteOnRemotePrimary(Address target, WriteCommand command, CommandAckCollector.MultiTargetCollector multiTargetCollector)
protected Object	manyWriteResponse(InvocationContext ctx, WriteCommand cmd, Object returnValue)
protected CompletionStage<ValidResponse>	singleWriteOnRemotePrimary(Address target, DataWriteCommand command) This method is called by a non-owner sending write request to the primary owner
protected Object	singleWriteResponse(InvocationContext ctx, DataWriteCommand cmd, Object returnValue) This method is called by primary owner responding to the originator after write has been completed

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

getLog, scheduleKeyInvalidation, start, visitClearCommand, visitComputeCommand, visitComputeIfAbsentCommand, visitEvictCommand, visitGetAllCommand, visitGetCacheEntryCommand, visitGetKeysInGroupCommand, visitGetKeyValueCommand, visitPutKeyValueCommand, visitPutMapCommand, visitReadOnlyKeyCommand, visitReadOnlyManyCommand, visitReadWriteKeyCommand, visitReadWriteKeyValueCommand, visitReadWriteManyCommand, visitReadWriteManyEntriesCommand, visitRemoveCommand, visitReplaceCommand, visitWriteOnlyKeyCommand, visitWriteOnlyKeyValueCommand, visitWriteOnlyManyCommand, visitWriteOnlyManyEntriesCommand

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

getSuccessfulResponseOrFail, unexpected

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

init, isLocalModeForced, isSynchronous, shouldInvokeRemoteTxCommand, transactionRemotelyPrepared

Methods inherited from class org.infinispan.interceptors.DDAsyncInterceptor

handleDefault, visitCommand, visitCommitCommand, visitEntrySetCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitLockControlCommand, visitPrepareCommand, visitRollbackCommand, visitSizeCommand, visitUnknownCommand

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

BiasedScatteredDistributionInterceptor

public BiasedScatteredDistributionInterceptor()

Method Detail

inject

public void inject(CommandAckCollector collector,
                   BiasManager biasManager)

singleWriteOnRemotePrimary

protected CompletionStage<ValidResponse> singleWriteOnRemotePrimary(Address target,
                                                                    DataWriteCommand command)

Description copied from class: ScatteredDistributionInterceptor

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

Overrides:

singleWriteOnRemotePrimary in class ScatteredDistributionInterceptor

manyWriteOnRemotePrimary

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

Overrides:

manyWriteOnRemotePrimary in class ScatteredDistributionInterceptor

createMultiTargetCollector

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

Overrides:

createMultiTargetCollector in class ScatteredDistributionInterceptor

completeSingleWriteOnPrimaryOriginator

protected CompletionStage<?> completeSingleWriteOnPrimaryOriginator(DataWriteCommand command,
                                                                    Address backup,
                                                                    CompletionStage<?> rpcFuture)

Description copied from class: ScatteredDistributionInterceptor

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.

Overrides:

completeSingleWriteOnPrimaryOriginator in class ScatteredDistributionInterceptor

completeManyWriteOnPrimaryOriginator

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

Description copied from class: ScatteredDistributionInterceptor

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.

Overrides:

completeManyWriteOnPrimaryOriginator in class ScatteredDistributionInterceptor

singleWriteResponse

protected Object singleWriteResponse(InvocationContext ctx,
                                     DataWriteCommand cmd,
                                     Object returnValue)

Description copied from class: ScatteredDistributionInterceptor

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

Overrides:

singleWriteResponse in class ScatteredDistributionInterceptor

manyWriteResponse

protected Object manyWriteResponse(InvocationContext ctx,
                                   WriteCommand cmd,
                                   Object returnValue)

Overrides:

manyWriteResponse in class ScatteredDistributionInterceptor

handleClear

protected Object handleClear(InvocationContext ctx,
                             ClearCommand command,
                             Object ignored)

Overrides:

handleClear in class ScatteredDistributionInterceptor