Class Request<T>

java.lang.Object

java.util.concurrent.CompletableFuture<T>

org.jgroups.blocks.Request<T>

Type Parameters:

T - T

All Implemented Interfaces:

CompletionStage<T>, Future<T>

Direct Known Subclasses:

GroupRequest, UnicastRequest

public abstract class Request<T>
extends CompletableFuture<T>

Abstract class for a unicast or multicast request

Author:

Bela Ban

Nested Class Summary

Nested classes/interfaces inherited from class CompletableFuture

CompletableFuture.AsynchronousCompletionTask

Nested classes/interfaces inherited from interface Future

Future.State

Field Summary

Fields

Modifier and Type	Field	Description
protected final RequestCorrelator	corr
protected final RequestOptions	options
protected long	req_id
protected long	start_time

Constructor Summary

Constructors

Constructor	Description
Request(RequestCorrelator corr, RequestOptions options)

Method Summary

Modifier and Type	Method	Description
boolean	cancel(boolean mayInterruptIfRunning)
protected void	corrDone()
T	execute(Message msg, boolean block_for_results)
abstract void	memberUnreachable(Address mbr)
abstract void	receiveResponse(Object response_value, Address sender, boolean is_exception)
long	requestId()
Request<T>	requestId(long req_id)
abstract void	sendRequest(Message req)
Request<T>	setResponseFilter(RspFilter filter)
abstract void	siteUnreachable(String site)
String	toString()
abstract void	transportClosed()
abstract void	viewChange(View new_view, boolean handle_previous_subgroups)
abstract T	waitForCompletion()
abstract T	waitForCompletion(long timeout, TimeUnit unit)	Blocks until all responses have been received and returns result or throws exception

Methods inherited from class CompletableFuture

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

Methods inherited from class Object

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

Field Details

req_id

protected long req_id

corr

protected final RequestCorrelator corr

options

protected final RequestOptions options

start_time

protected long start_time

Constructor Details

Request

public Request(RequestCorrelator corr,
 RequestOptions options)

Method Details

requestId

public Request<T> requestId(long req_id)

requestId

public long requestId()

setResponseFilter

public Request<T> setResponseFilter(RspFilter filter)

execute

public T execute(Message msg,
 boolean block_for_results)
          throws Exception

Throws:

Exception

sendRequest

public abstract void sendRequest(Message req)
                          throws Exception

Throws:

Exception

receiveResponse

public abstract void receiveResponse(Object response_value,
 Address sender,
 boolean is_exception)

viewChange

public abstract void viewChange(View new_view,
 boolean handle_previous_subgroups)

siteUnreachable

public abstract void siteUnreachable(String site)

memberUnreachable

public abstract void memberUnreachable(Address mbr)

transportClosed

public abstract void transportClosed()

waitForCompletion

public abstract T waitForCompletion(long timeout,
 TimeUnit unit)
                             throws Exception

Blocks until all responses have been received and returns result or throws exception

Throws:

Exception

waitForCompletion

public abstract T waitForCompletion()
                             throws Exception

Throws:

Exception

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface Future<T>

Overrides:

cancel in class CompletableFuture<T>

toString

public String toString()

Overrides:

toString in class CompletableFuture<T>

corrDone

protected void corrDone()