Class UnicastRequest<T>

java.lang.Object

java.util.concurrent.CompletableFuture<T>

org.jgroups.blocks.Request<T>

org.jgroups.blocks.UnicastRequest<T>

Type Parameters:

T - T

All Implemented Interfaces:

CompletionStage<T>, Future<T>

public class UnicastRequest<T>
extends Request<T>

Sends a request to a single target destination

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 Address	target

Fields inherited from class Request

corr, options, req_id, start_time

Constructor Summary

Constructors

Constructor	Description
UnicastRequest(RequestCorrelator corr, Address target, RequestOptions options)

Method Summary

Modifier and Type	Method	Description
protected T	around(Supplier<T> supplier)
T	get()
T	get(long timeout, TimeUnit unit)
T	getNow(T valueIfAbsent)
protected T	getResult(Callable<T> supplier)
T	join()
void	memberUnreachable(Address mbr)
void	receiveResponse(Object response_value, Address sender, boolean is_exception)	Callback (called by RequestCorrelator or Transport).
boolean	responsesComplete()
void	sendRequest(Message msg)
void	siteUnreachable(String site)
String	toString()
void	transportClosed()
void	viewChange(View view, boolean handle_previous_subgroups)	If the target address is not a member of the new view, we'll mark the response as suspected and unblock the caller of execute()
T	waitForCompletion()
T	waitForCompletion(long timeout, TimeUnit unit)	Blocks until all responses have been received and returns result or throws exception

Methods inherited from class Request

cancel, corrDone, execute, requestId, requestId, setResponseFilter

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, getNumberOfDependents, handle, handleAsync, handleAsync, isCancelled, isCompletedExceptionally, isDone, 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

target

protected final Address target

Constructor Details

UnicastRequest

public UnicastRequest(RequestCorrelator corr,
 Address target,
 RequestOptions options)

Method Details

sendRequest

public void sendRequest(Message msg)
                 throws Exception

Specified by:

sendRequest in class Request<T>

Throws:

Exception

receiveResponse

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

Callback (called by RequestCorrelator or Transport). Adds a response to the response table. When all responses have been received, execute() returns.

Specified by:

receiveResponse in class Request<T>

siteUnreachable

public void siteUnreachable(String site)

Specified by:

siteUnreachable in class Request<T>

memberUnreachable

public void memberUnreachable(Address mbr)

Specified by:

memberUnreachable in class Request<T>

viewChange

public void viewChange(View view,
 boolean handle_previous_subgroups)

If the target address is not a member of the new view, we'll mark the response as suspected and unblock the caller of execute()

Specified by:

viewChange in class Request<T>

transportClosed

public void transportClosed()

Specified by:

transportClosed in class Request<T>

get

public T get()
      throws InterruptedException,
ExecutionException

Specified by:

get in interface Future<T>

Overrides:

get in class CompletableFuture<T>

Throws:

InterruptedException

ExecutionException

get

public T get(long timeout,
 TimeUnit unit)
      throws InterruptedException,
ExecutionException,
TimeoutException

Specified by:

get in interface Future<T>

Overrides:

get in class CompletableFuture<T>

Throws:

InterruptedException

ExecutionException

TimeoutException

join

public T join()

Overrides:

join in class CompletableFuture<T>

getNow

public T getNow(T valueIfAbsent)

Overrides:

getNow in class CompletableFuture<T>

waitForCompletion

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

Description copied from class: Request

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

Specified by:

waitForCompletion in class Request<T>

Throws:

Exception

waitForCompletion

public T waitForCompletion()
                    throws Exception

Specified by:

waitForCompletion in class Request<T>

Throws:

Exception

toString

public String toString()

Overrides:

toString in class Request<T>

responsesComplete

public boolean responsesComplete()

around

protected T around(Supplier<T> supplier)

getResult

protected T getResult(Callable<T> supplier)
               throws Exception

Throws:

Exception