Package | Description |
---|---|
org.jgroups.protocols.pbcast |
Supports probabilistic broadcasts.
|
Modifier and Type | Method and Description |
---|---|
Digest |
Digest.copy() |
Digest |
GMS.getDigest()
Sends down a GET_DIGEST event and waits for the GET_DIGEST_OK response, or
timeout, whichever occurs first
|
Digest |
MergeData.getDigest() |
Digest |
STATE_TRANSFER.StateHeader.getDigest() |
Digest |
STREAMING_STATE_TRANSFER.StateHeader.getDigest() |
Modifier and Type | Method and Description |
---|---|
void |
Digest.add(Digest d) |
void |
GMS.castViewChange(View new_view,
Digest digest) |
void |
GMS.castViewChangeWithDest(View new_view,
Digest digest,
java.util.List members)
Broadcasts the new view and digest, and waits for acks from all members in the list given as argument.
|
abstract void |
GmsImpl.handleViewChange(View new_view,
Digest digest) |
void |
ClientGmsImpl.handleViewChange(View new_view,
Digest digest)
Does nothing.
|
void |
CoordGmsImpl.handleViewChange(View new_view,
Digest digest)
Called by the GMS when a VIEW is received.
|
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 |
GMS.installView(View new_view,
Digest digest)
Sets the new view and sends a VIEW_CHANGE event up and down the stack.
|
void |
Digest.merge(Digest d)
Adds a digest to this digest.
|
void |
GMS.mergeDigest(Digest d)
Send down a MERGE_DIGEST event
|
void |
Digest.replace(Digest d) |
boolean |
Digest.sameSenders(Digest other)
Compares two digests and returns true if the senders are the same, otherwise false.
|
void |
GMS.setDigest(Digest d)
Send down a SET_DIGEST event
|
void |
MergeData.setDigest(Digest d) |
Constructor and Description |
---|
Gossip(Address obj,
long id,
Digest d,
java.util.Vector not_seen) |
JoinRsp(View v,
Digest d) |
MergeData(Address sender,
View view,
Digest digest) |
STABLE.StableHeader(int type,
Digest digest) |
STATE_TRANSFER.StateHeader(byte type,
Address sender,
long id,
Digest digest) |
STATE_TRANSFER.StateHeader(byte type,
Address sender,
long id,
Digest digest,
java.lang.String state_id) |
STREAMING_STATE_TRANSFER.StateHeader(byte type,
Address sender,
IpAddress bind_addr,
Digest digest,
java.lang.String state_id) |
STREAMING_STATE_TRANSFER.StateHeader(byte type,
Address sender,
long id,
Digest digest) |
Copyright ? 1998-2006 Bela Ban. All Rights Reserved.