org.jgroups.blocks

Class UnicastRequest<T>

java.lang.Object

org.jgroups.blocks.Request

org.jgroups.blocks.UnicastRequest<T>

All Implemented Interfaces:

java.util.concurrent.Future, Condition, NotifyingFuture

public class UnicastRequest<T>
extends Request

Sends a request to a single target destination

Author:

Bela Ban

Field Summary

Fields

Modifier and Type	Field and Description
protected int	num_received
protected Rsp<T>	result
protected Address	target

Fields inherited from class org.jgroups.blocks.Request

cond, corr, done, listener, lock, log, options, req_id, start_time

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
T	get()
T	get(long timeout, java.util.concurrent.TimeUnit unit)
Rsp<T>	getResult()
T	getValue()
void	receiveResponse(java.lang.Object response_value, Address sender, boolean is_exception) Callback (called by RequestCorrelator or Transport).
boolean	responseReceived()
protected boolean	responsesComplete()
protected void	sendRequest(Message request_msg)
void	siteUnreachable(java.lang.String site)
void	suspect(Address suspected_member) Callback (called by RequestCorrelator or Transport).
java.lang.String	toString()
void	transportClosed()
void	viewChange(View view) If the target address is not a member of the new view, we'll mark the response as not received and unblock the caller of execute()

Methods inherited from class org.jgroups.blocks.Request

cancel, checkCompletion, corrDone, execute, getResponsesComplete, isCancelled, isDone, isMet, requestId, requestId, responsesComplete, setListener, setResponseFilter, waitForResults

Methods inherited from class java.lang.Object

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

Field Detail

result

protected final Rsp<T> result

target

protected final Address target

num_received

protected int num_received

Constructor Detail

UnicastRequest

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

Method Detail

sendRequest

protected void sendRequest(Message request_msg)
                    throws java.lang.Exception

Specified by:

sendRequest in class Request

Throws:

java.lang.Exception

receiveResponse

public void receiveResponse(java.lang.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

responseReceived

public boolean responseReceived()

suspect

public void suspect(Address suspected_member)

Callback (called by RequestCorrelator or Transport). Report to GroupRequest that a member is reported as faulty (suspected). This method would probably be called when getting a suspect message from a failure detector (where available). It is used to exclude faulty members from the response list.

Specified by:

suspect in class Request

siteUnreachable

public void siteUnreachable(java.lang.String site)

Specified by:

siteUnreachable in class Request

viewChange

public void viewChange(View view)

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

Specified by:

viewChange in class Request

transportClosed

public void transportClosed()

Specified by:

transportClosed in class Request

getResult

public Rsp<T> getResult()

getValue

public T getValue()
           throws java.util.concurrent.ExecutionException

Throws:

java.util.concurrent.ExecutionException

get

public T get()
      throws java.lang.InterruptedException,
             java.util.concurrent.ExecutionException

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

get

public T get(long timeout,
             java.util.concurrent.TimeUnit unit)
      throws java.lang.InterruptedException,
             java.util.concurrent.ExecutionException,
             java.util.concurrent.TimeoutException

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

java.util.concurrent.TimeoutException

toString

public java.lang.String toString()

Overrides:

toString in class Request

responsesComplete

protected boolean responsesComplete()

Specified by:

responsesComplete in class Request