OPENDJ-1705 File based changelog: handle concurrency between purge and cursors

Nicolas Capponi

11.53.2015 b877a7554a1fa1c47a2982541972efe780dfad9a

 opendj-server-legacy/src/main/java/org/opends/server/replication/server/MessageHandler.java

@@ -239,8 +239,10 @@
   * @param sendToServerId
   *          serverId of the replica where changes will be sent
   * @return The next update that must be sent to the consumer, or {@code null} when queue is empty
   * @throws ChangelogException
   *            If a problem occurs when reading the changelog
   */
  protected UpdateMsg getNextMessage(int sendToServerId)
  protected UpdateMsg getNextMessage(int sendToServerId) throws ChangelogException
  {
    while (activeConsumer)
    {
@@ -371,7 +373,7 @@
   * Fills the late queue with the most recent changes, accepting only the
   * messages from provided replica ids.
   */
  private void fillLateQueue(int sendToServerId)
  private void fillLateQueue(int sendToServerId) throws ChangelogException
  {
    try (DBCursor<UpdateMsg> cursor = replicationServerDomain.getCursorFrom(serverState);)
    {
@@ -384,10 +386,6 @@
        }
      }
    }
    catch (ChangelogException e)
    {
      logger.traceException(e);
    }
  }

  private boolean isLateQueueBelowThreshold()