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

 opendj-sdk/opends/src/server/org/opends/server/replication/server/changelog/api/ReplicationDomainDB.java

@@ -213,15 +213,13 @@
   *
   * @param baseDN
   *          the replication domain baseDN
   * @param serverId
   *          the serverId on which to act
   * @param updateMsg
   *          the update message to publish to the replicaDB
   * @return true if a db had to be created to publish this message
   * @throws ChangelogException
   *           If a database problem happened
   */
  boolean publishUpdateMsg(DN baseDN, int serverId, UpdateMsg updateMsg)
  boolean publishUpdateMsg(DN baseDN, UpdateMsg updateMsg)
      throws ChangelogException;

}

 opendj-sdk/opends/src/server/org/opends/server/replication/server/changelog/je/JEChangelogDB.java

@@ -614,11 +614,11 @@

  /** {@inheritDoc} */
  @Override
  public boolean publishUpdateMsg(DN baseDN, int serverId,
      UpdateMsg updateMsg) throws ChangelogException
  public boolean publishUpdateMsg(DN baseDN, UpdateMsg updateMsg)
      throws ChangelogException
  {
    final Pair<JEReplicaDB, Boolean> pair =
        getOrCreateReplicaDB(baseDN, serverId, replicationServer);
    final Pair<JEReplicaDB, Boolean> pair = getOrCreateReplicaDB(baseDN,
        updateMsg.getCSN().getServerId(), replicationServer);
    final JEReplicaDB replicaDB = pair.getFirst();
    final boolean wasCreated = pair.getSecond();