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

Jean-Noel Rouvignac
05.50.2013 caef6ed626aa6ab49fa569a61307d0febdc798b6
opendj-sdk/opends/src/server/org/opends/server/replication/server/changelog/je/JEChangelogDB.java
@@ -397,7 +397,10 @@
      synchronized (domainMap)
      {
        it.remove();
        innerShutdownDomain(domainMap);
        for (JEReplicaDB replicaDB : domainMap.values())
        {
          replicaDB.shutdown();
        }
      }
    }
@@ -513,37 +516,6 @@
  /** {@inheritDoc} */
  @Override
  public void shutdownDomain(DN baseDN)
  {
    if (this.shutdown.get())
    { // shutdown has already been initiated
      return;
    }
    final Map<Integer, JEReplicaDB> domainMap = domainToReplicaDBs.get(baseDN);
    if (domainMap != null)
    {
      synchronized (domainMap)
      {
        innerShutdownDomain(domainToReplicaDBs.remove(baseDN));
      }
    }
  }
  /**
   * This method assumes the domainMap is synchronized by calling code and that
   * the domainMap is not null.
   */
  private void innerShutdownDomain(final Map<Integer, JEReplicaDB> domainMap)
  {
    for (JEReplicaDB replicaDB : domainMap.values())
    {
      replicaDB.shutdown();
    }
  }
  /** {@inheritDoc} */
  @Override
  public ServerState getDomainOldestCSNs(DN baseDN)
  {
    final ServerState result = new ServerState();