类 com.fr.third.jgroups.util.Digest
的使用

使用Digest的程序包

程序包	说明
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.

com.fr.third.jgroups.protocols.pbcast中Digest的使用

声明为Digest的com.fr.third.jgroups.protocols.pbcast中的字段

限定符和类型	字段和说明
protected Digest	StreamingStateTransfer.StateHeader.digest
protected Digest	MergeData.digest
protected Digest	JoinRsp.digest
protected Digest	STATE_TRANSFER.StateHeader.my_digest
protected Digest	NAKACK2.rebroadcast_digest
protected Digest	STABLE.StabilitySendTask.stability_digest

返回Digest的com.fr.third.jgroups.protocols.pbcast中的方法

限定符和类型	方法和说明
Digest	StreamingStateTransfer.StateHeader.getDigest()
Digest	STATE_TRANSFER.StateHeader.getDigest()
protected Digest	STABLE.getDigest()
Digest	NAKACK2.getDigest() Returns a message digest: for each member P the highest delivered and received seqno is added
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() Grabs the current digest from NAKACK{2}
Digest	NAKACK2.getDigest(Address mbr)
Digest	NAKACK.getDigest(Address mbr)
protected static Digest	FLUSH.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 digests
protected Digest	STABLE.readDigest(byte[] buffer, int offset, int length)

返回变量类型为Digest的类型的com.fr.third.jgroups.protocols.pbcast中的方法

限定符和类型	方法和说明
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)

参数类型为Digest的com.fr.third.jgroups.protocols.pbcast中的方法

限定符和类型	方法和说明
void	GMS.castViewChange(View new_view, Digest digest, java.util.Collection<Address> newMembers) Broadcasts the new view and digest as a VIEW message and waits for acks from existing members
protected static short	GMS.determineFlags(View view, Digest digest)
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)
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 application
protected void	STABLE.handleUpEvent(STABLE.StableHeader hdr, 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.
protected static boolean	NAKACK2.isGreaterThanOrEqual(Digest first, Digest other) Returns true if all senders of the current digest have their seqnos >= the ones from other
protected static boolean	NAKACK.isGreaterThanOrEqual(Digest first, Digest other) Returns true if all senders of the current digest have their seqnos >= the ones from other
protected static Buffer	FLUSH.marshal(java.util.Collection<? extends Address> participants, Digest digest)
static Buffer	STABLE.marshal(Digest digest)
protected static Buffer	GMS.marshal(View view, Digest digest)
protected void	NAKACK2.mergeDigest(Digest digest) For all members of the digest, adjust the retransmit buffers in xmit_table.
void	GMS.mergeDigest(Digest d) Send down a MERGE_DIGEST event
protected void	NAKACK2.overwriteDigest(Digest digest) Overwrites existing entries, but does NOT remove entries not found in the digest
protected java.lang.String	STABLE.printDigest(Digest digest)
protected void	STABLE.sendStabilityMessage(Digest tmp, ViewId view_id) Schedules a stability message to be mcast after a random number of milliseconds (range 1-5 secs).
protected void	NAKACK2.setDigest(Digest digest) Creates a retransmit buffer for each sender in the digest according to the sender's seqno.
void	GMS.setDigest(Digest d) Send down a SET_DIGEST event
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.startStabilityTask(Digest d, ViewId view_id, long delay)
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)

类型变量类型为Digest的com.fr.third.jgroups.protocols.pbcast中的方法参数

限定符和类型	方法和说明
protected static Digest	FLUSH.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 digests
protected static boolean	FLUSH.same(java.util.List<Digest> digests)

参数类型为Digest的com.fr.third.jgroups.protocols.pbcast中的构造器

构造器和说明
JoinRsp(View v, Digest d)
MergeData(Address sender, View view, Digest digest)
MergeData(Address sender, View view, Digest digest, boolean merge_rejected)
STABLE.StabilitySendTask(Digest d, ViewId view_id)
STATE_TRANSFER.StateHeader(byte type, Digest digest)
StreamingStateTransfer.StateHeader(byte type, Digest digest)
StreamingStateTransfer.StateHeader(byte type, IpAddress bind_addr, Digest digest)

com.fr.third.jgroups.util中Digest的使用

com.fr.third.jgroups.util中Digest的子类

限定符和类型	类和说明
class	MutableDigest A mutable version of Digest.

返回Digest的com.fr.third.jgroups.util中的方法

限定符和类型	方法和说明
Digest	Digest.copy()

参数类型为Digest的com.fr.third.jgroups.util中的方法

限定符和类型	方法和说明
MutableDigest	MutableDigest.merge(Digest digest) Adds a digest to this digest.
MutableDigest	MutableDigest.set(Digest digest)
java.lang.String	Digest.toString(Digest order)

参数类型为Digest的com.fr.third.jgroups.util中的构造器

构造器和说明
Digest(Digest digest) Only used for testing
MutableDigest(Digest digest) Only used for testing