public class AckCollector extends Object
Modifier and Type | Field and Description |
---|---|
protected Promise<Boolean> |
all_acks_received |
protected int |
expected_acks |
protected List<Address> |
missing_acks
List of members from whom we haven't received an ACK yet
|
protected List<Address> |
suspected_mbrs |
Constructor and Description |
---|
AckCollector() |
AckCollector(Address... members) |
AckCollector(Collection<Address> members) |
Modifier and Type | Method and Description |
---|---|
void |
ack(Address member) |
protected void |
addAll(Address... members) |
protected void |
addAll(Collection<Address> members) |
void |
destroy() |
int |
expectedAcks() |
String |
printMissing() |
String |
printSuspected() |
void |
reset(Collection<Address> members) |
boolean |
retainAll(Collection<Address> members) |
int |
size() |
void |
suspect(Address member) |
String |
toString() |
boolean |
waitForAllAcks() |
boolean |
waitForAllAcks(long timeout) |
protected final List<Address> missing_acks
protected int expected_acks
public AckCollector()
public AckCollector(Collection<Address> members)
public AckCollector(Address... members)
public void reset(Collection<Address> members)
public void destroy()
public int size()
public int expectedAcks()
public void ack(Address member)
public void suspect(Address member)
public boolean retainAll(Collection<Address> members)
public boolean waitForAllAcks()
public boolean waitForAllAcks(long timeout) throws TimeoutException
TimeoutException
public String printMissing()
public String printSuspected()
protected void addAll(Address... members)
protected void addAll(Collection<Address> members)
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.