public class Digest extends java.lang.Object implements java.io.Externalizable, Streamable
April 3 2001 (bela): Added high_seqnos_seen member. It is used to disseminate information about the last (highest) message M received from a sender P. Since we might be using a negative acknowledgment message numbering scheme, we would never know if the last message was lost. Therefore we periodically gossip and include the last message seqno. Members who haven't seen it (e.g. because msg was dropped) will request a retransmission. See DESIGN for details.
Modifier and Type | Class and Description |
---|---|
static class |
Digest.Entry
Class keeping track of the lowest and highest sequence numbers delivered, and the highest
sequence numbers received, per member
|
Modifier and Type | Field and Description |
---|---|
protected static org.apache.commons.logging.Log |
log |
Modifier and Type | Method and Description |
---|---|
void |
add(Address sender,
long low_seqno,
long high_seqno) |
void |
add(Address sender,
long low_seqno,
long high_seqno,
long high_seqno_seen) |
void |
add(Digest d) |
void |
clear() |
boolean |
contains(Address sender) |
Digest |
copy() |
boolean |
equals(java.lang.Object obj) |
Digest.Entry |
get(Address sender) |
long |
highSeqnoAt(Address sender) |
long |
highSeqnoSeenAt(Address sender) |
void |
incrementHighSeqno(Address sender)
Increments the sender's high_seqno by 1.
|
long |
lowSeqnoAt(Address sender) |
void |
merge(Address sender,
long low_seqno,
long high_seqno,
long high_seqno_seen)
Similar to add(), but if the sender already exists, its seqnos will be modified (no new entry) as follows:
this.low_seqno=min(this.low_seqno, low_seqno)
this.high_seqno=max(this.high_seqno, high_seqno)
this.high_seqno_seen=max(this.high_seqno_seen, high_seqno_seen)
If the sender doesn not exist, a new entry will be added (provided there is enough space)
|
void |
merge(Digest d)
Adds a digest to this digest.
|
java.lang.String |
printHighSeqnos() |
java.lang.String |
printHighSeqnosSeen() |
void |
readExternal(java.io.ObjectInput in) |
void |
readFrom(java.io.DataInputStream in)
Read the state of the current object (including superclasses) from instream
Note that the input stream must not be closed
|
void |
replace(Digest d) |
void |
resetAt(Address sender)
Resets the seqnos for the sender at 'index' to 0.
|
boolean |
sameSenders(Digest other)
Compares two digests and returns true if the senders are the same, otherwise false.
|
long |
serializedSize() |
boolean |
set(Address sender,
long low_seqno,
long high_seqno,
long high_seqno_seen) |
void |
setHighestDeliveredAndSeenSeqnos(Address sender,
long high_seqno,
long high_seqno_seen) |
void |
setHighSeqnoAt(Address sender,
long high_seqno) |
void |
setHighSeqnoSeenAt(Address sender,
long high_seqno_seen) |
int |
size() |
java.lang.String |
toString() |
void |
writeExternal(java.io.ObjectOutput out) |
void |
writeTo(java.io.DataOutputStream out)
Write the entire state of the current object (including superclasses) to outstream.
|
public boolean equals(java.lang.Object obj)
equals
in class java.lang.Object
public void add(Address sender, long low_seqno, long high_seqno)
public void add(Address sender, long low_seqno, long high_seqno, long high_seqno_seen)
public void add(Digest d)
public void replace(Digest d)
public Digest.Entry get(Address sender)
public boolean set(Address sender, long low_seqno, long high_seqno, long high_seqno_seen)
public void merge(Digest d)
public void merge(Address sender, long low_seqno, long high_seqno, long high_seqno_seen)
public boolean contains(Address sender)
public boolean sameSenders(Digest other)
other
- public void incrementHighSeqno(Address sender)
public int size()
public void resetAt(Address sender)
public void clear()
public long lowSeqnoAt(Address sender)
public long highSeqnoAt(Address sender)
public long highSeqnoSeenAt(Address sender)
public void setHighSeqnoAt(Address sender, long high_seqno)
public void setHighSeqnoSeenAt(Address sender, long high_seqno_seen)
public void setHighestDeliveredAndSeenSeqnos(Address sender, long high_seqno, long high_seqno_seen)
public Digest copy()
public java.lang.String toString()
toString
in class java.lang.Object
public java.lang.String printHighSeqnos()
public java.lang.String printHighSeqnosSeen()
public void writeExternal(java.io.ObjectOutput out) throws java.io.IOException
writeExternal
in interface java.io.Externalizable
java.io.IOException
public void readExternal(java.io.ObjectInput in) throws java.io.IOException, java.lang.ClassNotFoundException
readExternal
in interface java.io.Externalizable
java.io.IOException
java.lang.ClassNotFoundException
public void writeTo(java.io.DataOutputStream out) throws java.io.IOException
Streamable
writeTo
in interface Streamable
java.io.IOException
public void readFrom(java.io.DataInputStream in) throws java.io.IOException, java.lang.IllegalAccessException, java.lang.InstantiationException
Streamable
readFrom
in interface Streamable
java.io.IOException
java.lang.IllegalAccessException
java.lang.InstantiationException
public long serializedSize()
Copyright ? 1998-2006 Bela Ban. All Rights Reserved.