Class ExclusiveTargetRequest<T>

java.lang.Object

java.util.concurrent.CompletableFuture<T>

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

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

All Implemented Interfaces:

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

Direct Known Subclasses:

MultiTargetRequest

public abstract class ExclusiveTargetRequest<T>
extends AbstractRequest<T>

Request implementation that waits for responses from multiple target nodes.

This Request handles concurrent calls to onResponse(Address, Response), onNewView(Set) and onTimeout() by using a very small synchronized block to guarantee only a single thread is performing any these actual operations at a time. This is done by updating the instance variable handling to true for the first caller to enter one of these methods. The thread that updates it to true will perform their operation immediately. However, if another concurrent call enters any of these methods and handling is already true this thread will instead initialize the queue if necessary and add its operation as a Runnable to it. The caller that updated handling to true will after performing its operation check under lock if the queue has been updated and if so run any of those operations, thus guaranteeing thread safety.

Note that onNewView(Set) return value is only valid if invoked before submitting this request. This is due to the update being possibly enqueued, and thus we cannot guarantee its correctness.

Author:

William Burns

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
ExclusiveTargetRequest(ResponseCollector<T> responseCollector, long requestId, RequestRepository repository)

Method Summary

Modifier and Type	Method	Description
protected abstract void	actualOnResponse(Address sender, Response response)
protected abstract void	actualOnTimeout()
protected abstract boolean	actualOnView(Set<Address> members)
final boolean	onNewView(Set<Address> members)	Called when the node received a new cluster view.
final void	onResponse(Address sender, Response response)	Called when a response is received for this response.
protected final 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, 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

ExclusiveTargetRequest

public ExclusiveTargetRequest(ResponseCollector<T> responseCollector,
 long requestId,
 RequestRepository repository)

Method Details

onResponse

public final void onResponse(Address sender,
 Response response)

Description copied from interface: Request

Called when a response is received for this response.

onNewView

public final 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. This value should only be used before the request was actually submitted.

onTimeout

protected final 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>

actualOnResponse

protected abstract void actualOnResponse(Address sender,
 Response response)

actualOnView

protected abstract boolean actualOnView(Set<Address> members)

actualOnTimeout

protected abstract void actualOnTimeout()