Uses of Class
org.jgroups.util.Digest
-
Packages that use Digest Package Description org.jgroups.protocols Provides implementations of transport protocols which are responsible for sending and receiving messages to/from the network.org.jgroups.protocols.pbcast org.jgroups.util Provides useful functionality which cannot be assigned to any particular other package. -
-
Uses of Digest in org.jgroups.protocols
Methods in org.jgroups.protocols that return Digest Modifier and Type Method Description Digest
ReliableMulticast. getDigest()
Returns a message digest: for each member P the highest delivered and received seqno is addedDigest
ReliableMulticast. getDigest(Address mbr)
Methods in org.jgroups.protocols with parameters of type Digest Modifier and Type Method Description protected void
ReliableMulticast. mergeDigest(Digest digest)
For all members of the digest, adjust the retransmit buffers in xmit_table.protected void
ReliableMulticast. overwriteDigest(Digest digest)
Overwrites existing entries, but does NOT remove entries not found in the digestprotected void
ReliableMulticast. setDigest(Digest digest)
Creates a retransmit buffer for each sender in the digest according to the sender's seqno.protected void
ReliableMulticast. setDigest(Digest digest, boolean merge)
Sets or merges the digest.protected void
NAKACK4. stable(Digest digest)
protected void
ReliableMulticast. stable(Digest digest)
Garbage collect messages that have been seen by all members. -
Uses of Digest in org.jgroups.protocols.pbcast
Fields in org.jgroups.protocols.pbcast declared as Digest Modifier and Type Field Description protected Digest
JoinRsp. digest
protected Digest
MergeData. digest
protected Digest
StreamingStateTransfer.StateHeader. digest
protected Digest
STATE_TRANSFER.StateHeader. my_digest
Fields in org.jgroups.protocols.pbcast with type parameters of type Digest Modifier and Type Field Description protected ResponseCollector<Digest>
Merger. digest_collector
For GET_DIGEST / DIGEST_RSP correlationMethods in org.jgroups.protocols.pbcast that return Digest Modifier and Type Method Description 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.Digest
GMS. getDigest()
Grabs the current digest from NAKACK{2}Digest
JoinRsp. getDigest()
Digest
MergeData. getDigest()
Digest
NAKACK2. getDigest()
Returns a message digest: for each member P the highest delivered and received seqno is addedDigest
NAKACK2. getDigest(Address mbr)
protected Digest
STABLE. getDigest()
Digest
STATE_TRANSFER.StateHeader. getDigest()
Digest
StreamingStateTransfer.StateHeader. getDigest()
Methods in org.jgroups.protocols.pbcast that return types with arguments of type Digest Modifier and Type Method Description static Tuple<View,Digest>
GMS. _readViewAndDigest(byte[] buffer, int offset, int length)
Tuple<View,Digest>
GMS. getViewAndDigest()
Returns the current view and digest.protected Tuple<View,Digest>
GMS. readViewAndDigest(byte[] buffer, int offset, int length)
Methods in org.jgroups.protocols.pbcast with parameters of type Digest Modifier and Type Method Description void
GMS. castViewChangeAndSendJoinRsps(View new_view, Digest digest, java.util.Collection<Address> expected_acks, java.util.Collection<Address> joiners, JoinRsp jr)
Broadcasts the new view and digest as VIEW messages, possibly sends JOIN-RSP messages to joiners and then waits for acks from expected_acksprotected static short
GMS. determineFlags(View view, Digest digest)
protected void
STATE_TRANSFER. getStateFromApplication(Address requester, Digest digest)
protected java.lang.Object
STABLE. handle(STABLE.StableHeader hdr, Address sender, Digest digest)
void
GmsImpl. handleDigestResponse(Address sender, Digest digest)
void
Merger. handleDigestResponse(Address sender, Digest digest)
void
ServerGmsImpl. handleDigestResponse(Address sender, Digest digest)
protected void
STABLE. handleStabilityMessage(Digest stable_digest, Address sender, ViewId view_id)
protected void
STABLE. handleStableMessage(Digest d, Address sender, ViewId view_id)
Digest d contains (a) the highest seqnos deliverable for each sender and (b) the highest seqnos seen for each member.protected void
STATE_TRANSFER. handleStateRsp(Digest digest, Address sender, byte[] state)
Set the digest and the send the state up to the applicationvoid
GmsImpl. handleViewChange(View new_view, Digest digest)
void
ParticipantGmsImpl. handleViewChange(View view, Digest digest)
void
ServerGmsImpl. handleViewChange(View 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.protected static ByteArray
GMS. marshal(View view, Digest digest)
void
GMS. mergeDigest(Digest d)
Send down a MERGE_DIGEST eventprotected void
NAKACK2. mergeDigest(Digest digest)
For all members of the digest, adjust the retransmit buffers in xmit_table.protected void
NAKACK2. overwriteDigest(Digest digest)
Overwrites existing entries, but does NOT remove entries not found in the digestprotected java.lang.String
STABLE. printDigest(Digest digest)
protected void
Merger. sendMergeResponse(Address sender, View view, Digest digest, MergeId merge_id)
Send back a response containing view and digest to senderprotected void
STABLE. sendStabilityMessage(Digest d, ViewId view_id)
Sends a stability message to all members except self.void
GMS. setDigest(Digest d)
Send down a SET_DIGEST eventprotected void
NAKACK2. setDigest(Digest digest)
Creates a retransmit buffer for each sender in the digest according to the sender's seqno.protected void
NAKACK2. setDigest(Digest digest, boolean merge)
Sets or merges the digest.protected void
NAKACK2. stable(Digest digest)
Garbage collect messages that have been seen by all members.protected void
STABLE. updateLocalDigest(Digest d, Address sender)
Update my own digest from a digest received by somebody else.protected static boolean
GMS. writeAddresses(View view, Digest digest)
Constructors in org.jgroups.protocols.pbcast with parameters of type Digest Constructor Description JoinRsp(View v, Digest d)
MergeData(Address sender, View view, Digest digest)
MergeData(Address sender, View view, Digest digest, boolean merge_rejected)
StateHeader(byte type, Digest digest)
StateHeader(byte type, IpAddress bind_addr, Digest digest)
StateHeader(byte type, Digest digest)
-
Uses of Digest in org.jgroups.util
Subclasses of Digest in org.jgroups.util Modifier and Type Class Description class
MutableDigest
A mutable version of Digest.Methods in org.jgroups.util that return Digest Modifier and Type Method Description Digest
Digest. copy()
Methods in org.jgroups.util that return types with arguments of type Digest Modifier and Type Method Description java.util.function.Supplier<? extends Digest>
Digest. create()
java.util.function.Supplier<? extends Digest>
MutableDigest. create()
Methods in org.jgroups.util with parameters of type Digest Modifier and Type Method Description MutableDigest
MutableDigest. merge(Digest digest)
Adds a digest to this digest.MutableDigest
MutableDigest. set(Digest digest)
java.lang.String
Digest. toString(Digest order)
Constructors in org.jgroups.util with parameters of type Digest Constructor Description Digest(Digest digest)
Only used for testingMutableDigest(Digest digest)
Only used for testing
-