Package org.jgroups.stack
Class AckReceiverWindow
java.lang.Object
org.jgroups.stack.AckReceiverWindow
Counterpart of AckSenderWindow. Simple FIFO buffer.
Every message received is ACK'ed (even duplicates) and added to a hashmap
keyed by seqno. The next seqno to be received is stored in
Change May 28 2002 (bela): replaced TreeSet with HashMap. Keys do not need to be sorted, and adding a key to a sorted set incurs overhead.
next_to_remove
. When a message with
a seqno less than next_to_remove is received, it will be discarded. The remove()
method removes
and returns a message whose seqno is equal to next_to_remove, or null if not found.Change May 28 2002 (bela): replaced TreeSet with HashMap. Keys do not need to be sorted, and adding a key to a sorted set incurs overhead.
- Version:
- $Id: AckReceiverWindow.java,v 1.25.2.4.2.2 2009/04/28 11:31:50 belaban Exp $
- Author:
- Bela Ban
-
Constructor Details
-
AckReceiverWindow
public AckReceiverWindow(long initial_seqno)
-
-
Method Details
-
getLock
-
add
Adds a new message. Message cannot be null- Returns:
- True if the message was added, false if not (e.g. duplicate, message was already present)
-
remove
Removes a message whose seqno is equal tonext_to_remove
, increments the latter. Returns message that was removed, or null, if no message can be removed. Messages are thus removed in order. -
removeOOBMessage
-
hasMessagesToRemove
public boolean hasMessagesToRemove() -
smallerThanNextToRemove
public boolean smallerThanNextToRemove(long seqno) -
reset
public void reset() -
size
public int size() -
toString
-
printDetails
-