Package org.jgroups.util
Class AckTable
- java.lang.Object
-
- org.jgroups.util.AckTable
-
public class AckTable extends java.lang.Object
Manages ACKs from receivers inNAKACK4
- Since:
- 5.4
- Author:
- Bela Ban
-
-
Constructor Summary
Constructors Constructor Description AckTable()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description long[]
ack(Address sender, long seqno)
Adds an ACK from a sender to the map.AckTable
adjust(java.util.List<Address> mbrs)
Removes left members from and adds new members to the mapAckTable
clear()
protected long
computeMin()
long
min()
int
size()
java.lang.String
toString()
-
-
-
Field Detail
-
acks
protected final java.util.Map<Address,java.lang.Long> acks
-
lock
protected final java.util.concurrent.locks.Lock lock
-
min
protected volatile long min
-
-
Method Detail
-
min
public long min()
-
ack
public long[] ack(Address sender, long seqno)
Adds an ACK from a sender to the map. Returns the old and new minimum
-
adjust
public AckTable adjust(java.util.List<Address> mbrs)
Removes left members from and adds new members to the map
-
clear
public AckTable clear()
-
size
public int size()
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
computeMin
protected long computeMin()
-
-