protected void |
Merger._handleMergeRequest(Address sender,
MergeId merge_id,
java.util.Collection<? extends Address> mbrs) |
|
protected void |
Merger.MergeTask._run(MergeId new_merge_id,
java.util.Collection<Address> coordsCopy) |
Runs the merge protocol as a leader
|
protected void |
Merger.cancelMerge(MergeId id) |
|
protected Digest |
Merger.fetchDigestsFromAllMembersInSubPartition(View view,
MergeId merge_id) |
Multicasts a GET_DIGEST_REQ to all members of this sub partition and waits for all responses
(GET_DIGEST_RSP) or N ms.
|
protected boolean |
Merger.MergeTask.getMergeDataFromSubgroupCoordinators(java.util.Map<Address,java.util.Collection<Address>> coords,
MergeId new_merge_id,
long timeout) |
Sends a MERGE_REQ to all coords and populates a list of MergeData (in merge_rsps).
|
void |
GmsImpl.handleMergeCancelled(MergeId merge_id) |
|
void |
Merger.handleMergeCancelled(MergeId merge_id) |
|
void |
ServerGmsImpl.handleMergeCancelled(MergeId merge_id) |
|
void |
GmsImpl.handleMergeRequest(Address sender,
MergeId merge_id,
java.util.Collection<? extends Address> mbrs) |
|
void |
Merger.handleMergeRequest(Address sender,
MergeId merge_id,
java.util.Collection<? extends Address> mbrs) |
Get the view and digest and send back both (MergeData) in the form of a MERGE_RSP to the sender.
|
void |
ServerGmsImpl.handleMergeRequest(Address sender,
MergeId merge_id,
java.util.Collection<? extends Address> mbrs) |
Get the view and digest and send back both (MergeData) in the form of a MERGE_RSP to the sender.
|
void |
GmsImpl.handleMergeResponse(MergeData data,
MergeId merge_id) |
|
void |
Merger.handleMergeResponse(MergeData data,
MergeId merge_id) |
|
void |
ServerGmsImpl.handleMergeResponse(MergeData data,
MergeId merge_id) |
|
void |
GmsImpl.handleMergeView(MergeData data,
MergeId merge_id) |
|
void |
Merger.handleMergeView(MergeData data,
MergeId merge_id) |
If merge_id is not equal to this.merge_id then discard.
|
void |
ServerGmsImpl.handleMergeView(MergeData data,
MergeId merge_id) |
|
boolean |
Merger.matchMergeId(MergeId id) |
|
GMS.GmsHeader |
GMS.GmsHeader.mergeId(MergeId merge_id) |
|
protected void |
Merger.sendMergeCancelledMessage(java.util.Collection<Address> coords,
MergeId merge_id) |
|
protected void |
GmsImpl.sendMergeRejectedResponse(Address sender,
MergeId merge_id) |
|
protected void |
Merger.sendMergeRejectedResponse(Address sender,
MergeId merge_id) |
|
protected void |
Merger.sendMergeResponse(Address sender,
View view,
Digest digest,
MergeId merge_id) |
Send back a response containing view and digest to sender
|
protected void |
Merger.sendMergeView(java.util.Collection<Address> coords,
MergeData combined_merge_data,
MergeId merge_id) |
Sends the new view and digest to all subgroup coordinators.
|
GMS.GmsHeader |
GMS.GmsHeader.setMergeId(MergeId merge_id) |
|
boolean |
Merger.setMergeId(MergeId expected,
MergeId new_value) |
|