org.jgroups.stack

Class Retransmitter

java.lang.Object

org.jgroups.stack.Retransmitter

Direct Known Subclasses:

DefaultRetransmitter, RangeBasedRetransmitter

Deprecated.

@Deprecated
public abstract class Retransmitter
extends java.lang.Object

Abstract class of a retransmitter. Maintains a pool of sequence numbers of messages that need to be retransmitted. Messages are aged and retransmission requests sent according to age (configurable backoff). If a TimeScheduler instance is given to the constructor, it will be used, otherwise Reransmitter will create its own. The retransmit timeouts have to be set first thing after creating an instance. The add() method adds the sequence numbers of messages to be retransmitted. The remove() method removes a sequence number again, cancelling retransmission requests for it. Whenever a message needs to be retransmitted, the RetransmitCommand.retransmit() method is called. It can be used e.g. by an ack-based scheme (e.g. AckSenderWindow) to retransmit a message to the receiver, or by a nak-based scheme to send a retransmission request to the sender of the missing message.

Author:

Bela Ban

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	Retransmitter.RetransmitCommand Deprecated. Retransmit command (see Gamma et al.) used to retrieve missing messages
protected class	Retransmitter.Task Deprecated.

Field Summary

Fields

Modifier and Type	Field and Description
protected Retransmitter.RetransmitCommand	cmd Deprecated.
protected static Log	log Deprecated.
protected Interval	retransmit_timeouts Deprecated. Default retransmit intervals (ms) - exponential approx.
protected Address	sender Deprecated.
protected TimeScheduler	timer Deprecated.
protected long	xmit_stagger_timeout Deprecated.

Constructor Summary

Constructors

Constructor and Description
Retransmitter(Address sender, Retransmitter.RetransmitCommand cmd, TimeScheduler sched) Deprecated. Create a new Retransmitter associated with the given sender address

Method Summary

Modifier and Type	Method and Description
abstract void	add(long first_seqno, long last_seqno) Deprecated. Add messages from first_seqno to last_seqno for retransmission
long	getXmitStaggerTimeout() Deprecated.
abstract void	remove(long seqno) Deprecated. Remove the given sequence number from retransmission
abstract void	reset() Deprecated. Reset the retransmitter: clear all msgs and cancel all the respective tasks
void	setRetransmitTimeouts(Interval interval) Deprecated.
void	setXmitStaggerTimeout(long xmit_stagger_timeout) Deprecated.
abstract int	size() Deprecated.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

retransmit_timeouts

protected Interval retransmit_timeouts

Deprecated.

Default retransmit intervals (ms) - exponential approx.

sender

protected final Address sender

Deprecated.

cmd

protected final Retransmitter.RetransmitCommand cmd

Deprecated.

timer

protected final TimeScheduler timer

Deprecated.

xmit_stagger_timeout

protected long xmit_stagger_timeout

Deprecated.

log

protected static final Log log

Deprecated.

Constructor Detail

Retransmitter

public Retransmitter(Address sender,
                     Retransmitter.RetransmitCommand cmd,
                     TimeScheduler sched)

Deprecated.

Create a new Retransmitter associated with the given sender address

Parameters:

sender - the address from which retransmissions are expected or to which retransmissions are sent

cmd - the retransmission callback reference

sched - retransmissions scheduler

Method Detail

setRetransmitTimeouts

public void setRetransmitTimeouts(Interval interval)

Deprecated.

getXmitStaggerTimeout

public long getXmitStaggerTimeout()

Deprecated.

setXmitStaggerTimeout

public void setXmitStaggerTimeout(long xmit_stagger_timeout)

Deprecated.

add

public abstract void add(long first_seqno,
                         long last_seqno)

Deprecated.

Add messages from first_seqno to last_seqno for retransmission

remove

public abstract void remove(long seqno)

Deprecated.

Remove the given sequence number from retransmission

reset

public abstract void reset()

Deprecated.

Reset the retransmitter: clear all msgs and cancel all the respective tasks

size

public abstract int size()

Deprecated.