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

pgamba
29.32.2009 f70c357d82774ce2462755e5798e31f553e85610
opends/src/server/org/opends/server/replication/server/DataServerHandler.java
@@ -59,6 +59,10 @@
 */
public class DataServerHandler extends ServerHandler
{
  // Temporay generationId received in handshake/phase1,
  // and used after handshake/phase2
  long tmpGenerationId;
  // Status of this DS (only used if this server handler represents a DS)
  private ServerStatus status = ServerStatus.INVALID_STATUS;
@@ -409,7 +413,7 @@
  public boolean processStartFromRemote(ServerStartMsg serverStartMsg)
  throws DirectoryException
  {
    generationId = serverStartMsg.getGenerationId();
    tmpGenerationId = serverStartMsg.getGenerationId();
    protocolVersion = ProtocolVersion.minWithCurrent(
        serverStartMsg.getVersion());
    serverId = serverStartMsg.getServerId();
@@ -474,6 +478,9 @@
      boolean sessionInitiatorSSLEncryption =
        processStartFromRemote(inServerStartMsg);
      // lock with no timeout
      lockDomain(false);
      localGenerationId = replicationServerDomain.getGenerationId();
      oldGenerationId = localGenerationId;
@@ -490,9 +497,6 @@
        return;
      }
      // lock with no timeout
      lockDomain(false);
      //
      ReplServerStartMsg outReplServerStartMsg = null;
      try
@@ -652,6 +656,7 @@
     *   (unsaved yet on disk . will be set with the 1rst change
     * received)
     */
    generationId = tmpGenerationId;
    if (localGenerationId > 0)
    {
      if (generationId != localGenerationId)