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

Jean-Noel Rouvignac
21.33.2013 10b76e3a58346e0b6e2e07e58617b75dc383c249
opends/src/server/org/opends/server/replication/server/ReplicationServerHandler.java
@@ -230,13 +230,11 @@
        logTopoHandshakeSNDandRCV(outTopoMsg, inTopoMsg);
        replicationServerDomain.startMonitoringPublisher();
        /*
        FIXME: i think this should be done for all protocol version !!
        not only those > V1
        */
        registerIntoDomain();
        replicationServerDomain.register(this);
        /*
        Process TopologyMsg sent by remote RS: store matching new info
@@ -376,9 +374,7 @@
        */
      }
      replicationServerDomain.startMonitoringPublisher();
      registerIntoDomain();
      replicationServerDomain.register(this);
      // Process TopologyMsg sent by remote RS: store matching new info
      // (this will also warn our connected DSs of the new received info)
@@ -429,18 +425,6 @@
  }
  /**
   * Registers this handler into its related domain and notifies the domain.
   */
  private void registerIntoDomain()
  {
    // Alright, connected with new RS (either outgoing or incoming
    // connection): store handler.
    Map<Integer, ReplicationServerHandler> connectedRSs =
      replicationServerDomain.getConnectedRSs();
    connectedRSs.put(serverId, this);
  }
  /**
   * Wait receiving the TopologyMsg from the remote RS and process it.
   * @return the topologyMsg received or {@code null} if stop was received.
   * @throws DirectoryException