com.fr.third.jgroups.blocks

类 GroupRequest<T>

java.lang.Object

com.fr.third.jgroups.blocks.Request

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

所有已实现的接口:

RspCollector, NotifyingFuture, java.util.concurrent.Future

public class GroupRequest<T>
extends Request

Sends a message to all members of the group and waits for all responses (or timeout). Returns a boolean value (success or failure). Results (if any) can be retrieved when done.

The supported transport to send requests is currently either a RequestCorrelator or a generic Transport. One of them has to be given in the constructor. It will then be used to send a request. When a message is received by either one, the receiveResponse() of this class has to be called (this class does not actively receive requests/responses itself). Also, when a view change or suspicion is received, the methods viewChange() or suspect() of this class have to be called.

When started, an array of responses, correlating to the membership, is created. Each response is added to the corresponding field in the array. When all fields have been set, the algorithm terminates. This algorithm can optionally use a suspicion service (failure detector) to detect (and exclude from the membership) fauly members. If no suspicion service is available, timeouts can be used instead (see execute()). When done, a list of suspected members can be retrieved.

Because a channel might deliver requests, and responses to different requests, the GroupRequest class cannot itself receive and process requests/responses from the channel. A mechanism outside this class has to do this; it has to determine what the responses are for the message sent by the execute() method and call receiveResponse() to do so.

Requirements: lossless delivery, e.g. acknowledgment-based message confirmation.

作者:

Bela Ban

字段概要

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

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

构造器概要

构造器

构造器和说明
GroupRequest(Message msg, RequestCorrelator corr, Address target, RequestOptions options)
GroupRequest(Message msg, RequestCorrelator corr, java.util.Collection<Address> targets, RequestOptions options)

方法概要

方法

限定符和类型	方法和说明
RspList<T>	get()
RspList<T>	get(long timeout, java.util.concurrent.TimeUnit unit)
boolean	getAnycasting()
RspList<T>	getResults() Returns the results as a RspList
void	receiveResponse(java.lang.Object response_value, Address sender, boolean is_exception) Callback (called by RequestCorrelator or Transport).
protected boolean	responsesComplete()
void	sendRequest()
void	setAnycasting(boolean anycasting)
void	siteUnreachable(java.lang.String site)
void	suspect(Address suspected_member) Callback (called by RequestCorrelator or Transport).
java.lang.String	toString()
void	transportClosed() Marks all responses with an exception (unless a response was already marked as done)
void	viewChange(View new_view) Any member of 'membership' that is not in the new view is flagged as SUSPECTED.

从类继承的方法 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

构造器详细资料

GroupRequest

public GroupRequest(Message msg,
            RequestCorrelator corr,
            java.util.Collection<Address> targets,
            RequestOptions options)

参数:

msg - The message to be sent

corr - The request correlator to be used. A request correlator sends requests tagged with a unique ID and notifies the sender when matching responses are received. The reason GroupRequest uses it instead of a Transport is that multiple requests/responses might be sent/received concurrently

targets - The targets, which are supposed to receive the message. Any receiver not in this set will discard the message. Targets are always a subset of the current membership

options - The request options to be used for this call

GroupRequest

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

方法详细资料

getAnycasting

public boolean getAnycasting()

setAnycasting

public void setAnycasting(boolean anycasting)

sendRequest

public 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

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)

Any member of 'membership' that is not in the new view is flagged as SUSPECTED. Any member in the new view that is not in the membership (ie, the set of responses expected for the current RPC) will not be added to it. If we did this we might run into the following problem:

• Membership is {A,B}
• A sends a synchronous group RPC (which sleeps for 60 secs in the invocation handler)
• C joins while A waits for responses from A and B
• If this would generate a new view {A,B,C} and if this expanded the response set to {A,B,C}, A would wait forever on C's response because C never received the request in the first place, therefore won't send a response.

指定者:

viewChange 在接口中 RspCollector

指定者:

viewChange 在类中 Request

transportClosed

public void transportClosed()

Marks all responses with an exception (unless a response was already marked as done)

getResults

public RspList<T> getResults()

Returns the results as a RspList

get

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

抛出:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

get

public RspList<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