OPENDJ-1116 Introduce abstraction for the changelog DB

Matthew Swift

07.32.2013 ffa2b6d64ffa66e288e462c7714f01f1c5d8c6b5

 opendj-sdk/opends/src/server/org/opends/server/replication/server/ReplicationServerDomain.java

@@ -205,9 +205,6 @@
  public void put(UpdateMsg update, ServerHandler sourceHandler)
    throws IOException
  {
    CSN csn = update.getCSN();
    int serverId = csn.getServerId();

    sourceHandler.updateServerState(update);
    sourceHandler.incrementInCount();
    setGenerationIdIfUnset(sourceHandler.getGenerationId());
@@ -264,7 +261,7 @@
      }
    }

    if (!publishUpdateMsg(update, serverId))
    if (!publishUpdateMsg(update))
    {
      return;
    }
@@ -284,6 +281,7 @@
        // The following timer will time out and send an timeout ack to the
        // requester if the acks are not received in time. The timer will also
        // remove the object from this map.
        CSN csn = update.getCSN();
        waitingAcks.put(csn, preparedAssuredInfo.expectedAcksInfo);

        // Arm timer for this assured update message (wait for acks until it
@@ -402,11 +400,11 @@
    }
  }

  private boolean publishUpdateMsg(UpdateMsg updateMsg, int serverId)
  private boolean publishUpdateMsg(UpdateMsg updateMsg)
  {
    try
    {
      if (this.domainDB.publishUpdateMsg(baseDN, serverId, updateMsg))
      if (this.domainDB.publishUpdateMsg(baseDN, updateMsg))
      {
        /*
         * JNR: Matt and I had a hard time figuring out where to put this