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 Digest |
MergeData.digest |
protected Digest |
StreamingStateTransfer.StateHeader.my_digest |
protected Digest |
STATE_TRANSFER.StateHeader.my_digest |
Modifier and Type | Field and Description |
---|---|
protected BoundedList<Digest> |
NAKACK.stability_msgs
BoundedList
|
Modifier and Type | Method and Description |
---|---|
Digest |
StreamingStateTransfer.StateHeader.getDigest() |
Digest |
STATE_TRANSFER.StateHeader.getDigest() |
Digest |
NAKACK.getDigest()
Returns a message digest: for each member P the highest delivered and received seqno is added
|
Digest |
MergeData.getDigest() |
Digest |
JoinRsp.getDigest() |
Digest |
GMS.getDigest()
Sends down a GET_DIGEST event and waits for the GET_DIGEST_OK response, or
timeout, whichever occurs first
|
Digest |
NAKACK.getDigest(Address mbr) |
Modifier and Type | Method and Description |
---|---|
Tuple<View,Digest> |
GMS.getViewAndDigest()
Returns the current view and digest
|
Modifier and Type | Method and Description |
---|---|
void |
FLUSH.FlushHeader.addDigest(Digest digest) |
void |
GMS.castViewChangeWithDest(View new_view,
Digest digest,
JoinRsp jr,
Collection<Address> newMembers)
Broadcasts the new view and digest, and waits for acks from all members in the list given as argument.
|
protected void |
STATE_TRANSFER.getStateFromApplication(Address requester,
Digest digest) |
void |
ServerGmsImpl.handleDigestResponse(Address sender,
Digest digest) |
void |
Merger.handleDigestResponse(Address sender,
Digest digest) |
void |
GmsImpl.handleDigestResponse(Address sender,
Digest digest) |
void |
ParticipantGmsImpl.handleViewChange(View new_view,
Digest digest)
If we are leaving, we have to wait for the view change (last msg in the current view) that
excludes us before we can leave.
|
void |
GmsImpl.handleViewChange(View new_view,
Digest digest) |
void |
CoordGmsImpl.handleViewChange(View new_view,
Digest digest)
Called by the GMS when a VIEW is received.
|
void |
GMS.installView(View new_view,
Digest digest)
Sets the new view and sends a VIEW_CHANGE event up and down the stack.
|
void |
GMS.mergeDigest(Digest d)
Send down a MERGE_DIGEST event
|
void |
GMS.setDigest(Digest d)
Send down a SET_DIGEST event
|
protected void |
StreamingStateTransfer.setStateInApplication(Address provider,
InputStream in,
Digest digest) |
Constructor and Description |
---|
JoinRsp(View v,
Digest d) |
MergeData(Address sender,
View view,
Digest digest) |
MergeData(Address sender,
View view,
Digest digest,
boolean merge_rejected) |
STABLE.StableHeader(int type,
Digest digest) |
STATE_TRANSFER.StateHeader(byte type,
Digest digest) |
StreamingStateTransfer.StateHeader(byte type,
Digest digest) |
StreamingStateTransfer.StateHeader(byte type,
IpAddress bind_addr,
Digest digest) |
Modifier and Type | Class and Description |
---|---|
class |
MutableDigest
A mutable version of Digest.
|
Modifier and Type | Method and Description |
---|---|
Digest |
Digest.copy() |
Digest |
Digest.difference(Digest other) |
Digest |
Digest.highestSequence(Digest other) |
Modifier and Type | Method and Description |
---|---|
void |
MutableDigest.add(Digest digest) |
void |
MutableDigest.add(Digest digest,
boolean replace) |
boolean |
Digest.containsAll(Digest other)
Returns true if our 'members' array contains all of the elements in other.members
|
Digest |
Digest.difference(Digest other) |
Digest |
Digest.highestSequence(Digest other) |
boolean |
Digest.isGreaterThanOrEqual(Digest other)
Returns true if all senders of the current digest have their seqnos >= the ones from other
|
void |
MutableDigest.merge(Digest digest)
Adds a digest to this digest.
|
void |
MutableDigest.replace(Digest d) |
boolean |
Digest.sameSenders(Digest other)
Compares two digests and returns true if the senders are the same, otherwise false.
|
Constructor and Description |
---|
Digest(Digest digest) |
MutableDigest(Digest digest) |
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.