mirror of https://github.com/OpenIdentityPlatform/OpenDJ.git

Jean-Noel Rouvignac
28.38.2014 950e5063261dc037e2e9c0152b23baaad0628a6e
PendingChanges.java:
Fixed a typo in the javadoc
1 files modified
27 ■■■■■ changed files
opendj3-server-dev/src/server/org/opends/server/replication/plugin/PendingChanges.java 27 ●●●●● patch | view | raw | blame | history
opendj3-server-dev/src/server/org/opends/server/replication/plugin/PendingChanges.java
@@ -41,18 +41,16 @@
/**
 * This class is used to store the list of local operations currently
 * in progress and not yet committed in the database.
 *
 * It is used to make sure that operations are sent to the Replication
 * Server in the order defined by their CSN.
 * It is also used to update the ServerState at the appropriate time.
 *
 * On object of this class is instantiated for each ReplicationDomain.
 * <p>
 * It is used to make sure that operations are sent to the Replication Server
 * in the order defined by their CSN. It is also used to update the ServerState
 * at the appropriate time.
 * <p>
 * An object of this class is instantiated for each ReplicationDomain.
 */
class PendingChanges
{
  /**
   * A map used to store the pending changes.
   */
  /** A map used to store the pending changes. */
  private final TreeMap<CSN, PendingChange> pendingChanges =
      new TreeMap<CSN, PendingChange>();
@@ -62,9 +60,7 @@
   */
  private final CSNGenerator csnGenerator;
  /**
   * The ReplicationDomain that will be used to send UpdateMsg.
   */
  /** The ReplicationDomain that will be used to send UpdateMsg. */
  private final ReplicationDomain domain;
  private boolean recoveringOldChanges = false;
@@ -106,7 +102,7 @@
   * Mark an update message as committed.
   *
   * @param csn The CSN of the update message that must be set as committed.
   * @param msg          The message associated to the update.
   * @param msg The message associated to the update.
   */
  private synchronized void commit(CSN csn, LDAPUpdateMsg msg)
  {
@@ -120,8 +116,7 @@
  }
  /**
   * Add a new UpdateMsg to the pending list from the provided local
   * operation.
   * Add a new UpdateMsg to the pending list from the provided local operation.
   *
   * @param operation The local operation for which an UpdateMsg must
   *                  be added in the pending list.
@@ -232,7 +227,7 @@
   * change that was sent to the ReplicationServer with the CSN of the last
   * operation that was taken out of the PendingChanges list. If the two match
   * then the recovery is completed and normal procedure can restart. Otherwise
   * the RSUpdate thread must continue to look for older changes and no changes
   * the RSUpdater thread must continue to look for older changes and no changes
   * can be committed from the pendingChanges list.
   *
   * @param recovered