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

Jean-Noël Rouvignac
08.46.2016 627a66edb6791bdab5d6e0ef0caf0f56b5b7a35e
opendj-server-legacy/src/main/java/org/opends/server/replication/service/ReplicationBroker.java
@@ -22,7 +22,7 @@
 *
 *
 *      Copyright 2006-2010 Sun Microsystems, Inc.
 *      Portions Copyright 2011-2015 ForgeRock AS
 *      Portions Copyright 2011-2016 ForgeRock AS
 */
package org.opends.server.replication.service;
@@ -39,6 +39,9 @@
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicReference;
import net.jcip.annotations.GuardedBy;
import net.jcip.annotations.Immutable;
import org.forgerock.i18n.LocalizableMessage;
import org.forgerock.i18n.slf4j.LocalizedLogger;
import org.forgerock.util.Utils;
@@ -65,7 +68,7 @@
   * Immutable class containing information about whether the broker is
   * connected to an RS and data associated to this connected RS.
   */
  // @Immutable
  @Immutable
  private static final class ConnectedRS
  {
@@ -205,7 +208,7 @@
   */
  /** Contains the last known state of the replication topology. */
  private final AtomicReference<Topology> topology = new AtomicReference<>(new Topology());
  /** <pre>@GuardedBy("this")</pre>. */
  @GuardedBy("this")
  private volatile int updateDoneCount;
  private volatile boolean connectRequiresRecovery;