|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.opends.server.replication.plugin.RemotePendingChanges
public class RemotePendingChanges
This class is used to store the list of remote changes received from a replication server and taht are either currently being replayed or that are waiting for being replayed. It is used to know when the ServerState must be updated and to conpute the dependencies between operations. One of this object is instanciated for each ReplicationDomain.
Constructor Summary | |
---|---|
RemotePendingChanges(ChangeNumberGenerator changeNumberGenerator,
ServerState state)
Creates a new RemotePendingChanges using the provided ServerState. |
Method Summary | |
---|---|
boolean |
checkDependencies(AddOperation op)
Check if the given AddOperation has some dependencies on any currently running previous operation. |
boolean |
checkDependencies(DeleteOperation op)
Check if the given DeleteOperation has some dependencies on any currently running previous operation. |
boolean |
checkDependencies(ModifyDNMsg msg)
Check if the given ModifyDNMsg has some dependencies on any currently running previous operation. |
boolean |
checkDependencies(ModifyOperation op)
Check if the given ModifyOperation has some dependencies on any currently running previous operation. |
void |
commit(ChangeNumber changeNumber)
Mark an update message as committed. |
UpdateMessage |
getNextUpdate()
Get the first update in the list that have some dependencies cleared. |
void |
putRemoteUpdate(UpdateMessage update)
Add a new UpdateMessage that was received from the replication server to the pendingList. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public RemotePendingChanges(ChangeNumberGenerator changeNumberGenerator, ServerState state)
changeNumberGenerator
- The ChangeNumberGenerator that should
be adjusted when changes are received.state
- The ServerState that will be updated when UpdateMessage
have been fully replayed.Method Detail |
---|
public void putRemoteUpdate(UpdateMessage update)
update
- The UpdateMessage that was received from the replication
server and that will be added to the pending list.public void commit(ChangeNumber changeNumber)
changeNumber
- The ChangeNumber of the update message that must be
set as committed.public UpdateMessage getNextUpdate()
public boolean checkDependencies(AddOperation op)
op
- The AddOperation to be checked.
public boolean checkDependencies(ModifyOperation op)
op
- The ModifyOperation to be checked.
public boolean checkDependencies(ModifyDNMsg msg)
msg
- The ModifyDNMsg to be checked.
public boolean checkDependencies(DeleteOperation op)
op
- The DeleteOperation to be checked.
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |