com.fr.third.jgroups.blocks

类 UnicastRequest<T>

java.lang.Object

com.fr.third.jgroups.blocks.Request

com.fr.third.jgroups.blocks.UnicastRequest<T>

所有已实现的接口:

RspCollector, NotifyingFuture, java.util.concurrent.Future

public class UnicastRequest<T>
extends Request

Sends a request to a single target destination

作者:

Bela Ban

字段概要

字段

限定符和类型	字段和说明
protected int	num_received
protected Rsp<T>	result
protected Address	target

从类继承的字段 com.fr.third.jgroups.blocks.Request

block_for_results, completed, corr, done, listener, lock, log, options, req_id, REQUEST_ID, request_msg

构造器概要

构造器

构造器和说明
UnicastRequest(Message msg, Address target, RequestOptions options)
UnicastRequest(Message msg, RequestCorrelator corr, Address target, RequestOptions options)

方法概要

方法

限定符和类型	方法和说明
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()
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 new_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()

从类继承的方法 com.fr.third.jgroups.blocks.Request

cancel, checkCompletion, execute, getBlockForResults, getRequestId, getResponsesComplete, isCancelled, isDone, responsesComplete, setBlockForResults, setListener, setResponseFilter, waitForResults

从类继承的方法 java.lang.Object

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

字段详细资料

result

protected final Rsp<T> result

target

protected final Address target

num_received

protected int num_received

构造器详细资料

UnicastRequest

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

UnicastRequest

public UnicastRequest(Message msg,
              Address target,
              RequestOptions options)

方法详细资料

sendRequest

protected void sendRequest()
                    throws java.lang.Exception

指定者:

sendRequest 在类中 Request

抛出:

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.

指定者:

receiveResponse 在接口中 RspCollector

指定者:

receiveResponse 在类中 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.

指定者:

suspect 在接口中 RspCollector

指定者:

suspect 在类中 Request

siteUnreachable

public void siteUnreachable(java.lang.String site)

指定者:

siteUnreachable 在接口中 RspCollector

指定者:

siteUnreachable 在类中 Request

viewChange

public void viewChange(View new_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()

指定者:

viewChange 在接口中 RspCollector

指定者:

viewChange 在类中 Request

transportClosed

public void transportClosed()

getResult

public Rsp<T> getResult()

getValue

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

抛出:

java.util.concurrent.ExecutionException

get

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

抛出:

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

抛出:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

java.util.concurrent.TimeoutException

toString

public java.lang.String toString()

覆盖:

toString 在类中 Request

responsesComplete

protected boolean responsesComplete()

指定者:

responsesComplete 在类中 Request