| | |
| | | |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | import org.opends.server.replication.common.ServerState; |
| | | import org.opends.server.replication.protocol.UpdateMessage; |
| | | import org.opends.server.replication.protocol.UpdateMsg; |
| | | import org.opends.server.types.DN; |
| | | import org.opends.server.types.DirectoryException; |
| | | import org.opends.server.types.operation.PluginOperation; |
| | |
| | | { |
| | | private ChangeNumber changeNumber; |
| | | private boolean committed; |
| | | private UpdateMessage msg; |
| | | private UpdateMsg msg; |
| | | private PluginOperation op; |
| | | private ServerState dependencyState = null; |
| | | private DN targetDN = null; |
| | |
| | | */ |
| | | public PendingChange(ChangeNumber changeNumber, |
| | | PluginOperation op, |
| | | UpdateMessage msg) |
| | | UpdateMsg msg) |
| | | { |
| | | this.changeNumber = changeNumber; |
| | | this.committed = false; |
| | |
| | | * @return the message if operation was a replication operation |
| | | * null if the operation was a local operation |
| | | */ |
| | | public UpdateMessage getMsg() |
| | | public UpdateMsg getMsg() |
| | | { |
| | | return msg; |
| | | } |
| | |
| | | * Set the message associated to the PendingChange. |
| | | * @param msg the message |
| | | */ |
| | | public void setMsg(UpdateMessage msg) |
| | | public void setMsg(UpdateMsg msg) |
| | | { |
| | | this.msg = msg; |
| | | } |
| | |
| | | } |
| | | |
| | | /** |
| | | * Set the operation asociated to this PendingChange. |
| | | * Set the operation associated to this PendingChange. |
| | | * @param op The operation associated to this PendingChange. |
| | | */ |
| | | public void setOp(PluginOperation op) |