|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.opends.server.replication.server.AckMessageList
public class AckMessageList
This class is used to store the list of acks received for a Given Update Messages. The acks are kept only for the update that are marked, hopefully this should be a limited number of updates and in all cases, LDAP servers operations are going to be blocked waiting for these acks so they won't be able to generate a huge number of such messages. Therefore, the amount of memory used keeping those changes is not a problem,
Constructor Summary | |
---|---|
AckMessageList(ChangeNumber changeNumber,
int numExpectedAcks)
Creates a new AckMessageList for a given ChangeNumber. |
Method Summary | |
---|---|
void |
addAck(short serverId)
Add an ack from a given LDAP server to the ack list. |
boolean |
completed()
This method can be used to check if all acks have been received for the ChangeNumber managed by this list. |
ChangeNumber |
getChangeNumber()
Get the ChangeNumber of this Ack Message List. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public AckMessageList(ChangeNumber changeNumber, int numExpectedAcks)
changeNumber
- The ChangeNumber for which the ack list is created.numExpectedAcks
- The number of acks waited before acking the
original change.Method Detail |
---|
public ChangeNumber getChangeNumber()
public void addAck(short serverId)
serverId
- the identifier of the LDAP server.public boolean completed()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |