程序包 | 说明 |
---|---|
com.fr.third.jgroups.protocols.pbcast |
Supports probabilistic broadcasts.
|
com.fr.third.jgroups.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
限定符和类型 | 字段和说明 |
---|---|
protected MergeId |
GMS.GmsHeader.merge_id |
限定符和类型 | 字段和说明 |
---|---|
protected BoundedList<MergeId> |
Merger.merge_id_history |
限定符和类型 | 方法和说明 |
---|---|
MergeId |
GMS._getMergeId() |
MergeId |
Merger.getMergeId()
Only used for testing, might get removed any time.
|
MergeId |
GMS.GmsHeader.getMergeId() |
MergeId |
CoordGmsImpl.getMergeId() |
限定符和类型 | 方法和说明 |
---|---|
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 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 |
Merger.handleMergeCancelled(MergeId merge_id) |
void |
GmsImpl.handleMergeCancelled(MergeId merge_id) |
void |
CoordGmsImpl.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 |
Merger.handleMergeResponse(MergeData data,
MergeId merge_id) |
void |
GmsImpl.handleMergeResponse(MergeData data,
MergeId merge_id) |
void |
CoordGmsImpl.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.sendMergeRejectedResponse(Address sender,
MergeId merge_id) |
protected void |
GmsImpl.sendMergeRejectedResponse(Address sender,
MergeId merge_id) |
void |
GMS.GmsHeader.setMergeId(MergeId merge_id) |
boolean |
Merger.setMergeId(MergeId expected,
MergeId new_value) |
限定符和类型 | 方法和说明 |
---|---|
static MergeId |
MergeId.create(Address addr) |