Package | Description |
---|---|
org.jgroups.protocols.pbcast |
Supports probabilistic broadcasts.
|
org.jgroups.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
Modifier and Type | Field and Description |
---|---|
protected MergeId |
GMS.GmsHeader.merge_id |
protected MergeId |
Merger.merge_id |
protected MergeId |
Merger.MergeKiller.my_merge_id |
Modifier and Type | Field and Description |
---|---|
protected BoundedList<MergeId> |
Merger.merge_id_history |
Modifier and Type | Method and Description |
---|---|
MergeId |
GMS._getMergeId() |
MergeId |
GMS.GmsHeader.getMergeId() |
MergeId |
Merger.getMergeId() |
MergeId |
CoordGmsImpl.getMergeId() |
Modifier and Type | Method and Description |
---|---|
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 |
ServerGmsImpl.handleMergeCancelled(MergeId merge_id) |
void |
Merger.handleMergeCancelled(MergeId merge_id) |
void |
GmsImpl.handleMergeCancelled(MergeId merge_id) |
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 |
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 |
GmsImpl.handleMergeRequest(Address sender,
MergeId merge_id,
java.util.Collection<? extends Address> mbrs) |
void |
ServerGmsImpl.handleMergeResponse(MergeData data,
MergeId merge_id) |
void |
Merger.handleMergeResponse(MergeData data,
MergeId merge_id) |
void |
GmsImpl.handleMergeResponse(MergeData data,
MergeId merge_id) |
void |
ServerGmsImpl.handleMergeView(MergeData data,
MergeId merge_id)
If merge_id is not equal to this.merge_id then discard.
|
void |
Merger.handleMergeView(MergeData data,
MergeId merge_id)
If merge_id is not equal to this.merge_id then discard.
|
void |
GmsImpl.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 |
Merger.sendMergeRejectedResponse(Address sender,
MergeId merge_id) |
protected void |
GmsImpl.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 coordinors in coords.
|
void |
GMS.GmsHeader.setMergeId(MergeId merge_id) |
boolean |
Merger.setMergeId(MergeId expected,
MergeId new_value) |
Modifier and Type | Method and Description |
---|---|
static MergeId |
MergeId.create(Address addr) |
Copyright © 1998-2020 Red Hat. All Rights Reserved.