OPENDJ-1487 CR-4580 Prevent opened cursors when cleaning the file-based cha...

Nicolas Capponi

18.16.2014 dcf15ca5e81a513c9183e501430902c040271b15

OPENDJ-1487 CR-4580 Prevent opened cursors when cleaning the file-based changelog

Prevent race condition by proper synchronization in 
FileChangeLogDB#shutdownDB() method

 opends/src/server/org/opends/server/replication/server/changelog/file/FileChangelogDB.java

@@ -373,31 +373,6 @@
      purger.initiateShutdown();
    }

    try
    {
      shutdownChangeNumberIndexDB();
    }
    catch (ChangelogException e)
    {
      firstException = e;
    }

    for (Iterator<ConcurrentMap<Integer, FileReplicaDB>> it =
        this.domainToReplicaDBs.values().iterator(); it.hasNext();)
    {
      final ConcurrentMap<Integer, FileReplicaDB> domainMap = it.next();
      synchronized (domainMap)
      {
        it.remove();
        for (FileReplicaDB replicaDB : domainMap.values())
        {
          replicaDB.shutdown();
        }
      }
    }

    if (replicationEnv != null)
    {
      // wait for shutdown of the threads holding cursors
      try
      {
@@ -415,6 +390,30 @@
        // do nothing: we are already shutting down
      }

    // now we can safely shutdown all DBs
    try
    {
      shutdownChangeNumberIndexDB();
    }
    catch (ChangelogException e)
    {
      firstException = e;
    }
    for (Iterator<ConcurrentMap<Integer, FileReplicaDB>> it =
        this.domainToReplicaDBs.values().iterator(); it.hasNext();)
    {
      final ConcurrentMap<Integer, FileReplicaDB> domainMap = it.next();
      synchronized (domainMap)
      {
        it.remove();
        for (FileReplicaDB replicaDB : domainMap.values())
        {
          replicaDB.shutdown();
        }
      }
    }
    if (replicationEnv != null)
    {
      replicationEnv.shutdown();
    }