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

Nicolas Capponi
07.06.2014 c01c421b26e6409febd6af1db1c9db11b7b347a4
opendj3-server-dev/src/server/org/opends/server/replication/plugin/LDAPReplicationDomain.java
@@ -22,7 +22,7 @@
 *
 *
 *      Copyright 2006-2010 Sun Microsystems, Inc.
 *      Portions Copyright 2011-2013 ForgeRock AS
 *      Portions Copyright 2011-2014 ForgeRock AS
 */
package org.opends.server.replication.plugin;
@@ -1151,7 +1151,7 @@
    PreOperationAddOperation addOperation, boolean performFiltering)
  {
    return fractionalRemoveAttributesFromEntry(fractionalConfig,
      addOperation.getEntryDN().getRDN(), addOperation.getObjectClasses(),
      addOperation.getEntryDN().rdn(), addOperation.getObjectClasses(),
      addOperation.getUserAttributes(), performFiltering);
  }
@@ -1201,7 +1201,7 @@
     */
    boolean inconsistentOperation = false;
    RDN rdn = modifyDNOperation.getEntryDN().getRDN();
    RDN rdn = modifyDNOperation.getEntryDN().rdn();
    RDN newRdn = modifyDNOperation.getNewRDN();
    // Go through each attribute of the old RDN
@@ -2255,7 +2255,7 @@
     {
       DN entryDN = entryToRename.getDN();
       ModifyDNOperation newOp = renameEntry(
           entryDN, freedDN.getRDN(), freedDN.getParent(), false);
           entryDN, freedDN.rdn(), freedDN.parent(), false);
       ResultCode res = newOp.getResultCode();
       if (res != ResultCode.SUCCESS)
@@ -2751,7 +2751,7 @@
      RDN currentRDN;
      if (currentDN != null)
      {
        currentRDN = currentDN.getRDN();
        currentRDN = currentDN.rdn();
      }
      else
      {
@@ -2907,7 +2907,7 @@
  }
  else
  {
    newSuperior = entryDN.getParent();
    newSuperior = entryDN.parent();
  }
  //If we could not find the new parent entry, we missed this entry
@@ -2917,12 +2917,12 @@
  // stop the processing.
  if (newSuperior == null)
  {
    markConflictEntry(op, currentDN, currentDN.getParent().concat(newRDN));
    markConflictEntry(op, currentDN, currentDN.parent().child(newRDN));
    numUnresolvedNamingConflicts.incrementAndGet();
    return true;
  }
  DN newDN = newSuperior.concat(newRDN);
  DN newDN = newSuperior.child(newRDN);
  if (currentDN == null)
  {
@@ -3032,8 +3032,8 @@
        addConflict(msg);
        String conflictRDN =
            generateConflictRDN(entryUUID, op.getEntryDN().getRDN().toString());
        msg.setDN(DN.decode(conflictRDN + "," + getBaseDNString()));
            generateConflictRDN(entryUUID, op.getEntryDN().rdn().toString());
        msg.setDN(DN.valueOf(conflictRDN + "," + getBaseDNString()));
        // reset the parent entryUUID so that the check done is the
        // handleConflict phase does not fail.
        msg.setParentEntryUUID(null);
@@ -3041,7 +3041,7 @@
      }
      else
      {
        msg.setDN(DN.decode(msg.getDN().getRDN() + "," + parentDn));
        msg.setDN(DN.valueOf(msg.getDN().rdn() + "," + parentDn));
        numResolvedNamingConflicts.incrementAndGet();
      }
      return false;
@@ -3067,7 +3067,7 @@
        addConflict(msg);
        String conflictRDN =
            generateConflictRDN(entryUUID, msg.getDN().toNormalizedString());
        msg.setDN(DN.decode(conflictRDN));
        msg.setDN(DN.valueOf(conflictRDN));
        numUnresolvedNamingConflicts.incrementAndGet();
        return false;
      }
@@ -3282,7 +3282,7 @@
   */
  private RDN generateDeleteConflictDn(String entryUUID, DN dn)
  {
    String newRDN =  "entryuuid=" + entryUUID + "+" + dn.getRDN();
    String newRDN =  "entryuuid=" + entryUUID + "+" + dn.rdn();
    try
    {
      return RDN.decode(newRDN);
@@ -4151,7 +4151,7 @@
  {
    try
    {
      DN eclConfigEntryDN = DN.decode("cn=external changeLog," + config.dn());
      DN eclConfigEntryDN = DN.valueOf("cn=external changeLog," + config.dn());
      if (DirectoryServer.getConfigHandler().entryExists(eclConfigEntryDN))
      {
        DirectoryServer.getConfigHandler().deleteEntry(eclConfigEntryDN, null);
@@ -4190,7 +4190,7 @@
        {
          // no ECL config provided hence create a default one
          // create the default one
          DN eclConfigEntryDN = DN.decode("cn=external changelog," + configDn);
          DN eclConfigEntryDN = DN.valueOf("cn=external changelog," + configDn);
          if (!DirectoryServer.getConfigHandler().entryExists(eclConfigEntryDN))
          {
            // no entry exist yet for the ECL config for this domain