org.infinispan.remoting.transport.impl

Class MultiTargetRequest<T>

java.lang.Object

java.util.concurrent.CompletableFuture<T>

org.infinispan.remoting.transport.AbstractRequest<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 AbstractRequest<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 and Description
MultiTargetRequest(ResponseCollector<T> responseCollector, long requestId, RequestRepository repository, Collection<Address> targets, Address excluded)

Method Summary

Modifier and Type	Method and Description
protected Address	getTarget(int i)
protected int	getTargetsSize()
boolean	onNewView(Set<Address> members) Called when the node received a new cluster view.
void	onResponse(Address sender, Response response) Called when a response is received for this response.
protected void	onTimeout() Called when the timeout task scheduled with AbstractRequest.setTimeout(ScheduledExecutorService, long, TimeUnit) expires.

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

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

Methods inherited from class java.util.concurrent.CompletableFuture

acceptEither, acceptEitherAsync, acceptEitherAsync, allOf, anyOf, applyToEither, applyToEitherAsync, applyToEitherAsync, completedFuture, exceptionally, get, get, getNow, getNumberOfDependents, handle, handleAsync, handleAsync, isCancelled, isCompletedExceptionally, isDone, join, obtrudeException, obtrudeValue, 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, 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 Detail

MultiTargetRequest

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

Method Detail

getTargetsSize

protected int getTargetsSize()

getTarget

protected Address getTarget(int i)

Returns:

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

onResponse

public void onResponse(Address sender,
                       Response response)

Description copied from interface: Request

Called when a response is received for this response.

onNewView

public boolean onNewView(Set<Address> members)

Description copied from interface: Request

Called when the node received a new cluster view.

Returns:

true if any of the request targets is not in the view.

onTimeout

protected void onTimeout()

Description copied from class: AbstractRequest

Called when the timeout task scheduled with AbstractRequest.setTimeout(ScheduledExecutorService, long, TimeUnit) expires.

Specified by:

onTimeout in class AbstractRequest<T>