Class MultiTargetRequest<T>

java.lang.Object

java.util.concurrent.CompletableFuture<T>

org.infinispan.remoting.transport.AbstractRequest<T>

org.infinispan.remoting.transport.impl.ExclusiveTargetRequest<T>

org.infinispan.remoting.transport.impl.MultiTargetRequest<T>

All Implemented Interfaces:

Callable<Void>, CompletionStage<T>, Future<T>, Request<T>

Direct Known Subclasses:

StaggeredRequest

public class MultiTargetRequest<T>
extends ExclusiveTargetRequest<T>

Request implementation that waits for responses from multiple target nodes.

Since:

9.1

Author:

Dan Berindei

Nested Class Summary

Nested classes/interfaces inherited from class java.util.concurrent.CompletableFuture

CompletableFuture.AsynchronousCompletionTask

Field Summary

Fields inherited from class org.infinispan.remoting.transport.AbstractRequest

repository, requestId, responseCollector

Fields inherited from interface org.infinispan.remoting.transport.impl.Request

NO_REQUEST_ID

Constructor Summary

Constructors

Constructor	Description
MultiTargetRequest(ResponseCollector<T> responseCollector, long requestId, RequestRepository repository, Collection<Address> targets, Address excluded, JGroupsMetricsManager metricsCollector)

Method Summary

Modifier and Type	Method	Description
protected void	actualOnResponse(Address sender, Response response)
protected void	actualOnTimeout()
protected boolean	actualOnView(Set<Address> members)
protected RequestTracker	getTarget(int i)
protected int	getTargetsSize()

Methods inherited from class org.infinispan.remoting.transport.impl.ExclusiveTargetRequest

onNewView, onResponse, onTimeout

Methods inherited from class org.infinispan.remoting.transport.AbstractRequest

call, cancel, cancel, complete, completeExceptionally, getRequestId, getTimeoutMs, setTimeout

Methods inherited from class java.util.concurrent.CompletableFuture

acceptEither, acceptEitherAsync, acceptEitherAsync, allOf, anyOf, applyToEither, applyToEitherAsync, applyToEitherAsync, completeAsync, completeAsync, completedFuture, completedStage, completeOnTimeout, copy, defaultExecutor, delayedExecutor, delayedExecutor, exceptionally, exceptionallyAsync, exceptionallyAsync, exceptionallyCompose, exceptionallyComposeAsync, exceptionallyComposeAsync, failedFuture, failedStage, get, get, getNow, getNumberOfDependents, handle, handleAsync, handleAsync, isCancelled, isCompletedExceptionally, isDone, join, minimalCompletionStage, newIncompleteFuture, obtrudeException, obtrudeValue, orTimeout, runAfterBoth, runAfterBothAsync, runAfterBothAsync, runAfterEither, runAfterEitherAsync, runAfterEitherAsync, runAsync, runAsync, supplyAsync, supplyAsync, thenAccept, thenAcceptAsync, thenAcceptAsync, thenAcceptBoth, thenAcceptBothAsync, thenAcceptBothAsync, thenApply, thenApplyAsync, thenApplyAsync, thenCombine, thenCombineAsync, thenCombineAsync, thenCompose, thenComposeAsync, thenComposeAsync, thenRun, thenRunAsync, thenRunAsync, toCompletableFuture, toString, whenComplete, whenCompleteAsync, whenCompleteAsync

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.CompletionStage

acceptEither, acceptEitherAsync, acceptEitherAsync, applyToEither, applyToEitherAsync, applyToEitherAsync, exceptionally, exceptionallyAsync, exceptionallyAsync, exceptionallyCompose, exceptionallyComposeAsync, exceptionallyComposeAsync, handle, handleAsync, handleAsync, runAfterBoth, runAfterBothAsync, runAfterBothAsync, runAfterEither, runAfterEitherAsync, runAfterEitherAsync, thenAccept, thenAcceptAsync, thenAcceptAsync, thenAcceptBoth, thenAcceptBothAsync, thenAcceptBothAsync, thenApply, thenApplyAsync, thenApplyAsync, thenCombine, thenCombineAsync, thenCombineAsync, thenCompose, thenComposeAsync, thenComposeAsync, thenRun, thenRunAsync, thenRunAsync, toCompletableFuture, whenComplete, whenCompleteAsync, whenCompleteAsync

Constructor Details

MultiTargetRequest

public MultiTargetRequest(ResponseCollector<T> responseCollector,
 long requestId,
 RequestRepository repository,
 Collection<Address> targets,
 Address excluded,
 JGroupsMetricsManager metricsCollector)

Method Details

getTargetsSize

protected int getTargetsSize()

getTarget

protected RequestTracker getTarget(int i)

Returns:

target i, or null if a response was already added for target i.

actualOnResponse

protected void actualOnResponse(Address sender,
 Response response)

Specified by:

actualOnResponse in class ExclusiveTargetRequest<T>

actualOnView

protected boolean actualOnView(Set<Address> members)

Specified by:

actualOnView in class ExclusiveTargetRequest<T>

actualOnTimeout

protected void actualOnTimeout()

Specified by:

actualOnTimeout in class ExclusiveTargetRequest<T>