Uses of Class
org.jgroups.util.Digest
-
Packages that use Digest Package Description 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.pbcast
Fields in org.jgroups.protocols.pbcast declared as Digest Modifier and Type Field Description protected DigestJoinRsp. digestprotected DigestMergeData. digestprotected DigestStreamingStateTransfer.StateHeader. digestprotected DigestSTATE_TRANSFER.StateHeader. my_digestprotected DigestNAKACK2. rebroadcast_digestFields in org.jgroups.protocols.pbcast with type parameters of type Digest Modifier and Type Field Description protected ResponseCollector<Digest>Merger. digest_collectorFor GET_DIGEST / DIGEST_RSP correlationMethods in org.jgroups.protocols.pbcast that return Digest Modifier and Type Method Description protected DigestMerger. 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.DigestGMS. getDigest()Grabs the current digest from NAKACK{2}DigestJoinRsp. getDigest()DigestMergeData. getDigest()DigestNAKACK2. getDigest()Returns a message digest: for each member P the highest delivered and received seqno is addedDigestNAKACK2. getDigest(Address mbr)protected DigestSTABLE. getDigest()DigestSTATE_TRANSFER.StateHeader. getDigest()DigestStreamingStateTransfer.StateHeader. getDigest()protected static DigestFLUSH. maxSeqnos(View view, java.util.List<Digest> digests)Returns a digest which contains, for all members of view, the highest delivered and received seqno of all digestsprotected DigestSTABLE. readDigest(byte[] buffer, int offset, int length)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<java.util.Collection<? extends Address>,Digest>FLUSH. readParticipantsAndDigest(byte[] buffer, int offset, int length)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 voidGMS. 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 shortGMS. determineFlags(View view, Digest digest)protected voidSTATE_TRANSFER. getStateFromApplication(Address requester, Digest digest)protected java.lang.ObjectSTABLE. handle(STABLE.StableHeader hdr, Address sender, Digest digest)voidGmsImpl. handleDigestResponse(Address sender, Digest digest)voidMerger. handleDigestResponse(Address sender, Digest digest)voidServerGmsImpl. handleDigestResponse(Address sender, Digest digest)protected voidSTABLE. handleStabilityMessage(Digest stable_digest, Address sender, ViewId view_id)protected voidSTABLE. 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 voidSTATE_TRANSFER. handleStateRsp(Digest digest, Address sender, byte[] state)Set the digest and the send the state up to the applicationprotected voidSTABLE. handleUpEvent(STABLE.StableHeader hdr, Address sender, Digest digest)voidGmsImpl. handleViewChange(View new_view, Digest digest)voidParticipantGmsImpl. handleViewChange(View view, Digest digest)voidServerGmsImpl. handleViewChange(View view, Digest digest)Called by the GMS when a VIEW is received.voidGMS. installView(View new_view, Digest digest)Sets the new view and sends a VIEW_CHANGE event up and down the stack.protected static booleanNAKACK2. isGreaterThanOrEqual(Digest first, Digest other)Returns true if all senders of the current digest have their seqnos >= the ones from otherprotected static BufferFLUSH. marshal(java.util.Collection<? extends Address> participants, Digest digest)protected static BufferGMS. marshal(View view, Digest digest)static BufferSTABLE. marshal(Digest digest)voidGMS. mergeDigest(Digest d)Send down a MERGE_DIGEST eventprotected voidNAKACK2. mergeDigest(Digest digest)For all members of the digest, adjust the retransmit buffers in xmit_table.protected voidNAKACK2. overwriteDigest(Digest digest)Overwrites existing entries, but does NOT remove entries not found in the digestprotected java.lang.StringSTABLE. printDigest(Digest digest)protected voidMerger. sendMergeResponse(Address sender, View view, Digest digest, MergeId merge_id)Send back a response containing view and digest to senderprotected voidSTABLE. sendStabilityMessage(Digest d, ViewId view_id)Sends a stability message to all members except self.voidGMS. setDigest(Digest d)Send down a SET_DIGEST eventprotected voidNAKACK2. setDigest(Digest digest)Creates a retransmit buffer for each sender in the digest according to the sender's seqno.protected voidNAKACK2. setDigest(Digest digest, boolean merge)Sets or merges the digest.protected voidNAKACK2. stable(Digest digest)Garbage collect messages that have been seen by all members.protected voidSTABLE. updateLocalDigest(Digest d, Address sender)Update my own digest from a digest received by somebody else.protected static booleanGMS. writeAddresses(View view, Digest digest)Method parameters in org.jgroups.protocols.pbcast with type arguments of type Digest Modifier and Type Method Description protected static DigestFLUSH. maxSeqnos(View view, java.util.List<Digest> digests)Returns a digest which contains, for all members of view, the highest delivered and received seqno of all digestsprotected static booleanFLUSH. same(java.util.List<Digest> digests)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 classMutableDigestA mutable version of Digest.Methods in org.jgroups.util that return Digest Modifier and Type Method Description DigestDigest. 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()Methods in org.jgroups.util with parameters of type Digest Modifier and Type Method Description MutableDigestMutableDigest. merge(Digest digest)Adds a digest to this digest.MutableDigestMutableDigest. set(Digest digest)java.lang.StringDigest. 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
-