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

gbellato
12.23.2006 f0f4caa7b330807252d8a86d8ff499e16f9ddd33
opendj-sdk/opends/src/server/org/opends/server/synchronization/MultimasterSynchronization.java
@@ -67,12 +67,8 @@
  private static Map<DN, SynchronizationDomain> domains =
    new HashMap<DN, SynchronizationDomain>() ;
 /**
   * InitializePlugin function.
   * called at server initialization time
   * @param configEntry the Entry that contains configuration
   * @throws ConfigException if config is invalid
  /**
   * {@inheritDoc}
   */
  public void initializeSynchronizationProvider(ConfigEntry configEntry)
  throws ConfigException
@@ -210,8 +206,7 @@
  }
  /**
   * Post-Operation method, called by server when processing is complete.
   * @param modifyDNOperation Operation for which the post-operation is called
   * {@inheritDoc}
   */
  public void doPostOperation(ModifyDNOperation modifyDNOperation)
  {
@@ -220,9 +215,9 @@
  }
  /**
   * Post-Operation method, called by server when processing is complete.
   * @param modifyOperation Operation for which the post-operation is called
   * {@inheritDoc}
   */
  @Override
  public void doPostOperation(ModifyOperation modifyOperation)
  {
    DN dn = modifyOperation.getEntryDN();
@@ -230,12 +225,9 @@
  }
  /**
   * Handle the conflict resolution.
   * Called by the core server after locking the entry and before
   * starting the actual modification.
   * @param modifyOperation the operation
   * @return code indicating is operation must proceed
   * {@inheritDoc}
   */
  @Override
  public SynchronizationProviderResult handleConflictResolution(
                                                ModifyOperation modifyOperation)
  {
@@ -246,13 +238,9 @@
    return domain.handleConflictResolution(modifyOperation);
  }
  /**
   * Pre-operation processing.
   * Called after operation has been processed by the core server
   * but before being committed to the backend
   * Generate the Change number and update the historical information
   * @param modifyOperation the current operation
   * @return code indicating if operation must be processed
   * {@inheritDoc}
   */
  @Override
  public SynchronizationProviderResult
@@ -277,12 +265,7 @@
  }
  /**
   * Pre-operation processing.
   * Called after operation has been processed by the core server
   * but before being committed to the backend
   * Generate the Change number and update the historical information
   * @param addOperation the current operation
   * @return code indicating if operation must be processed
   * {@inheritDoc}
   */
  @Override
  public SynchronizationProviderResult doPreOperation(AddOperation addOperation)
@@ -300,6 +283,7 @@
   * Called after operation has been processed by the core server
   * but before being committed to the backend
   * Generate the Change number and update the historical information
   *
   * @param deleteOperation the current operation
   * @return code indicating if operation must be processed
   */
@@ -321,6 +305,7 @@
   * Called after operation has been processed by the core server
   * but before being committed to the backend
   * Generate the Change number and update the historical information
   *
   * @param modifyDNOperation the current operation
   * @return code indicating if operation must be processed
   */
@@ -394,12 +379,14 @@
      return;
    domain.synchronize(operation);
    return;
  }
  /**
   * Get the ServerState associated to the SynchronizationDomain
   * with a given DN.
   *
   * @param baseDn The DN of the Synchronization Domain for which the
   *               ServerState must be returned.
   * @return the ServerState associated to the SynchronizationDomain
@@ -410,6 +397,7 @@
    SynchronizationDomain domain = findDomain(baseDn);
    return domain.getServerState();
  }
}