public class AckSenderWindow extends Object implements Retransmitter.RetransmitCommand
Modifier and Type | Class and Description |
---|---|
static interface |
AckSenderWindow.RetransmitCommand |
Constructor and Description |
---|
AckSenderWindow()
Creates an instance without retransmitter
|
AckSenderWindow(AckSenderWindow.RetransmitCommand com) |
AckSenderWindow(AckSenderWindow.RetransmitCommand com,
Interval interval,
TimeScheduler sched) |
AckSenderWindow(AckSenderWindow.RetransmitCommand com,
Interval interval,
TimeScheduler sched,
Address sender) |
Modifier and Type | Method and Description |
---|---|
void |
ack(long seqno)
Removes all messages less than or equal to seqno from
msgs , and cancels their retransmission |
void |
add(long seqno,
Message msg)
Adds a new message to the retransmission table.
|
void |
addToMessages(long seqno,
Message msg) |
void |
addToRetransmitter(long seqno) |
Message |
get(long seqno) |
long |
getHighest() |
long |
getLowest()
Only to be used for testing purposes
|
Message |
getLowestMessage()
Returns the message with the lowest seqno
|
String |
printDetails() |
void |
reset() |
void |
retransmit(long first_seqno,
long last_seqno,
Address sender)
Get the missing messages between sequence numbers
first_seqno and last_seqno . |
int |
size() |
String |
toString() |
public AckSenderWindow(AckSenderWindow.RetransmitCommand com)
public AckSenderWindow(AckSenderWindow.RetransmitCommand com, Interval interval, TimeScheduler sched)
public AckSenderWindow(AckSenderWindow.RetransmitCommand com, Interval interval, TimeScheduler sched, Address sender)
public AckSenderWindow()
public long getLowest()
public long getHighest()
public void reset()
public Message get(long seqno)
public void add(long seqno, Message msg)
public void addToMessages(long seqno, Message msg)
public void addToRetransmitter(long seqno)
public void ack(long seqno)
msgs
, and cancels their retransmissionpublic Message getLowestMessage()
public int size()
public String printDetails()
public void retransmit(long first_seqno, long last_seqno, Address sender)
Retransmitter.RetransmitCommand
first_seqno
and last_seqno
.
This can either be done by sending a retransmit message to destination sender
(nak-based scheme), or by retransmitting the missing message(s) to sender
(ack-based scheme).retransmit
in interface Retransmitter.RetransmitCommand
first_seqno
- The sequence number of the first missing messagelast_seqno
- The sequence number of the last missing messagesender
- The destination of the member to which the retransmit request will be sent
(nak-based scheme), or to which the message will be retransmitted (ack-based scheme).Copyright © 2012 JBoss by Red Hat. All Rights Reserved.