Class AckTable

java.lang.Object

org.jgroups.util.AckTable

public class AckTable
extends Object

Manages ACKs from receivers in NAKACK4

Since:

5.4

Author:

Bela Ban

Field Summary

Fields

Modifier and Type	Field	Description
protected final Map<Address,Long>	acks
protected final Lock	lock
protected long	min

Constructor Summary

Constructors

Constructor	Description
AckTable()

Method Summary

Modifier and Type	Method	Description
long[]	ack(Address sender, long seqno)
long[]	ack(Address sender, long seqno, boolean add_if_absent)	Adds an ACK from a sender to the map.
AckTable	adjust(List<Address> mbrs)	Removes left members from and adds new members to the map
AckTable	clear()
protected long	computeMin()
long	min()
long	min(Address mbr)
int	size()
String	toString()

Methods inherited from class Object

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

Field Details

acks

protected final Map<Address,Long> acks

lock

protected final Lock lock

min

protected volatile long min

Constructor Details

AckTable

public AckTable()

Method Details

min

public long min()

min

public long min(Address mbr)

ack

public long[] ack(Address sender,
 long seqno)

ack

public long[] ack(Address sender,
 long seqno,
 boolean add_if_absent)

Adds an ACK from a sender to the map. Returns the old and new minimum

adjust

public AckTable adjust(List<Address> mbrs)

Removes left members from and adds new members to the map

clear

public AckTable clear()

size

public int size()

toString

public String toString()

Overrides:

toString in class Object

computeMin

protected long computeMin()