Fix typos in comment, as well as refactor multi-line comments into blocks, ...

Ludovic Poitou

07.18.2013 4d16c61ea811a5ffdab2f832d1cecbec3f25988b

Fix typos in comment, as well as refactor multi-line comments into blocks, and remove unused param from method.

 opends/src/server/org/opends/server/replication/service/ReplicationBroker.java

@@ -183,7 +183,7 @@
   * received, it is incremented. When it reaches 2, we run the checking
   * algorithm to see if we must reconnect to another best replication server.
   * Then we reset the value to 0. But when a topology message is received, the
   * integer is reseted to 0. This ensures that we wait at least one monitoring
   * integer is reset to 0. This ensures that we wait at least one monitoring
   * publisher period before running the algorithm, but also that we wait at
   * least for a monitoring period after the last received topology message
   * (topology stabilization).
@@ -331,7 +331,7 @@
  /**
   * Sets the locally configured flag for the passed ReplicationServerInfo
   * object, analyzing the local configuration.
   * @param
   * @param replicationServerInfo the Replication server to check and update
   */
  private void updateRSInfoLocallyConfiguredStatus(
    ReplicationServerInfo replicationServerInfo)
@@ -859,17 +859,24 @@
   */
  private void connectAsDataServer()
  {
    // May have created a broker with null replication domain for
    // unit test purpose.
    /*
    May have created a broker with null replication domain for
    unit test purpose.
    */
    if (domain != null)
    {
      // If a first connect or a connection failure occur, we go through here.
      // force status machine to NOT_CONNECTED_STATUS so that monitoring can
      // see that we are not connected.
      /*
      If a first connect or a connection failure occur, we go through here.
      force status machine to NOT_CONNECTED_STATUS so that monitoring can
      see that we are not connected.
      */
      domain.toNotConnectedStatus();
    }

    // Stop any existing poller and heartbeat monitor from a previous session.
    /*
    Stop any existing heartbeat monitor and changeTime publisher
    from a previous session.
    */
    stopRSHeartBeatMonitoring();
    stopChangeTimeHeartBeatPublishing();
    mustRunBestServerCheckingAlgorithm = 0;
@@ -894,7 +901,7 @@
      {
        // At least one server answered, find the best one.
        electedRsInfo = computeBestReplicationServer(true, -1, state,
          replicationServerInfos, serverId, baseDn, groupId, getGenerationID());
          replicationServerInfos, serverId, groupId, getGenerationID());

        // Best found, now initialize connection to this one (handshake phase 1)
        if (debugEnabled())
@@ -906,8 +913,10 @@

        if (electedRsInfo != null)
        {
          // Update replication server info with potentially more up to date
          // data (server state for instance may have changed)
          /*
          Update replication server info with potentially more up to date
          data (server state for instance may have changed)
          */
          replicationServerInfos
              .put(electedRsInfo.getServerId(), electedRsInfo);

@@ -933,7 +942,9 @@

      } // Reached some servers

      if (connected)
      // connected is set by connectToReplicationServer()
      // and electedRsInfo isn't null then. Check anyway
      if (electedRsInfo != null && connected)
      {
        connectPhaseLock.notify();

@@ -1008,10 +1019,12 @@

      receiveTopo(topologyMsg);

      // Log a message to let the administrator know that the failure
      // was resolved.
      // Wakeup all the thread that were waiting on the window
      // on the previous connection.
      /*
      Log a message to let the administrator know that the failure
      was resolved.
      Wake up all the thread that were waiting on the window
      on the previous connection.
      */
      connectionError = false;
      if (sendWindow != null)
      {
@@ -1037,8 +1050,10 @@
      rcvWindow = maxRcvWindow;
      connected = true;

      // May have created a broker with null replication domain for
      // unit test purpose.
      /*
      May have created a broker with null replication domain for
      unit test purpose.
      */
      if (domain != null)
      {
        domain.sessionInitiated(initStatus, rsInfo.getServerState(), rsInfo
@@ -1047,9 +1062,11 @@

      if (getRsGroupId() != groupId)
      {
        // Connected to replication server with wrong group id:
        // warn user and start poller to recover when a server with
        // right group id arrives...
        /*
        Connected to replication server with wrong group id:
        warn user and start heartbeat monitor to recover when a server
        with the right group id shows up.
        */
        Message message =
            WARN_CONNECTED_TO_SERVER_WITH_WRONG_GROUP_ID.get(Byte
                .toString(groupId), Integer.toString(rsServerId), rsInfo
@@ -1074,7 +1091,7 @@
    }
    finally
    {
      if (connected == false)
      if (!connected)
      {
        ProtocolSession localSession = session;
        if (localSession != null)
@@ -1107,15 +1124,17 @@
    {
      if (rsGenId == dsGenId)
      {
        // DS and RS have same generation id
        /*
        DS and RS have same generation id

        // Determine if we are late or not to replay changes. RS uses a
        // threshold value for pending changes to be replayed by a DS to
        // determine if the DS is in normal status or in degraded status.
        // Let's compare the local and remote server state using  this threshold
        // value to determine if we are late or not
        Determine if we are late or not to replay changes. RS uses a
        threshold value for pending changes to be replayed by a DS to
        determine if the DS is in normal status or in degraded status.
        Let's compare the local and remote server state using  this threshold
        value to determine if we are late or not
        */

        ServerStatus initStatus = ServerStatus.INVALID_STATUS;
        ServerStatus initStatus;
        int nChanges = ServerState.diffChanges(rsState, state);

        if (debugEnabled())
@@ -1125,11 +1144,13 @@
            Integer.toString(nChanges) + " changes late.");
        }

        // Check status to know if it is relevant to change the status. Do not
        // take RSD lock to test. If we attempt to change the status whereas
        // we are in a status that do not allows that, this will be noticed by
        // the changeStatusFromStatusAnalyzer method. This allows to take the
        // lock roughly only when needed versus every sleep time timeout.
        /*
        Check status to know if it is relevant to change the status. Do not
        take RSD lock to test. If we attempt to change the status whereas
        we are in a status that do not allows that, this will be noticed by
        the changeStatusFromStatusAnalyzer method. This allows to take the
        lock roughly only when needed versus every sleep time timeout.
        */
        if (degradedStatusThreshold > 0)
        {
          if (nChanges >= degradedStatusThreshold)
@@ -1141,8 +1162,10 @@
          }
        } else
        {
          // 0 threshold value means no degrading system used (no threshold):
          // force normal status
          /*
          0 threshold value means no degrading system used (no threshold):
          force normal status
          */
          initStatus = ServerStatus.NORMAL_STATUS;
        }

@@ -1341,7 +1364,6 @@
   * reply message from the replication server.
   *
   * @param server Server we are connecting with.
   * @param initStatus The status we are starting with
   * @return The ReplServerStartMsg the server replied. Null if could not
   *         get an answer.
   */
@@ -1470,6 +1492,7 @@
   *
   * Note: this method is static for test purpose (access from unit tests)
   *
   *
   * @param firstConnection True if we run this method for the very first
   * connection of the broker. False if we run this method to determine if the
   * replication server we are currently connected to is still the best or not.
@@ -1479,7 +1502,6 @@
   * @param rsInfos The list of available replication servers and their
   * associated information (choice will be made among them).
   * @param localServerId The server id for the suffix we are working for.
   * @param baseDn The suffix for which we are working for.
   * @param groupId The groupId we prefer being connected to if possible
   * @param generationId The generation id we are using
   * @return The computed best replication server. If the returned value is
@@ -1488,9 +1510,9 @@
   * one). Null can only be returned when firstConnection is false.
   */
  public static ReplicationServerInfo computeBestReplicationServer(
    boolean firstConnection, int rsServerId, ServerState myState,
    Map<Integer, ReplicationServerInfo> rsInfos, int localServerId,
    String baseDn, byte groupId, long generationId)
      boolean firstConnection, int rsServerId, ServerState myState,
      Map<Integer, ReplicationServerInfo> rsInfos, int localServerId,
      byte groupId, long generationId)
  {

    // Shortcut, if only one server, this is the best
@@ -1510,15 +1532,16 @@
     * - replication server in the same VM as local DS one
     */
    Map<Integer, ReplicationServerInfo> bestServers = rsInfos;
    // The list of best replication servers is filtered with each criteria. At
    // each criteria, the list is replaced with the filtered one if there
    // are some servers from the filtering, otherwise, the list is left as is
    // and the new filtering for the next criteria is applied and so on.
    /*
    The list of best replication servers is filtered with each criteria. At
    each criteria, the list is replaced with the filtered one if there
    are some servers from the filtering, otherwise, the list is left as is
    and the new filtering for the next criteria is applied and so on.


    // Use only servers locally configured: those are servers declared in
    // the local configuration. When the current method is called, for
    // sure, at least one server from the list is locally configured
    Use only servers locally configured: those are servers declared in
    the local configuration. When the current method is called, for
    sure, at least one server from the list is locally configured
    */
    bestServers =
        keepBest(filterServersLocallyConfigured(bestServers), bestServers);
    // Some servers with same group id ?
@@ -1550,9 +1573,11 @@
        return computeBestServerForWeight(bestServers, -1, -1);
      } else
      {
        // We are already connected to a RS: compute the best RS as far as the
        // weights is concerned. If this is another one, some DS must
        // disconnect.
        /*
        We are already connected to a RS: compute the best RS as far as the
        weights is concerned. If this is another one, some DS must
        disconnect.
        */
        return computeBestServerForWeight(bestServers, rsServerId,
          localServerId);
      }
@@ -1843,14 +1868,14 @@
      int rsWeight = replicationServerInfo.getWeight();
      //  load goal = rs weight / sum of weights
      BigDecimal loadGoalBd = BigDecimal.valueOf(rsWeight).divide(
        BigDecimal.valueOf(sumOfWeights), mathContext);
          BigDecimal.valueOf(sumOfWeights), mathContext);
      BigDecimal currentLoadBd = BigDecimal.ZERO;
      if (sumOfConnectedDSs != 0)
      {
        // current load = number of connected DSs / total number of DSs
        int connectedDSs = replicationServerInfo.getConnectedDSNumber();
        currentLoadBd = BigDecimal.valueOf(connectedDSs).divide(
          BigDecimal.valueOf(sumOfConnectedDSs), mathContext);
            BigDecimal.valueOf(sumOfConnectedDSs), mathContext);
      }
      // load distance = load goal - current load
      BigDecimal loadDistanceBd =
@@ -1910,12 +1935,14 @@
        loadDistances.get(currentRsServerId).floatValue();
      if (currentLoadDistance < 0)
      {
        // Too much DSs connected to the current RS, compared with its load
        // goal:
        // Determine the potential number of DSs to disconnect from the current
        // RS and see if the local DS is part of them: the DSs that must
        // disconnect are those with the lowest server id.
        // Compute the sum of the distances of the load goals of the other RSs
        /*
        Too much DSs connected to the current RS, compared with its load
        goal:
        Determine the potential number of DSs to disconnect from the current
        RS and see if the local DS is part of them: the DSs that must
        disconnect are those with the lowest server id.
        Compute the sum of the distances of the load goals of the other RSs
        */
        BigDecimal sumOfLoadDistancesOfOtherRSsBd = BigDecimal.ZERO;
        for (Integer rsId : bestServers.keySet())
        {
@@ -1928,20 +1955,22 @@

        if (sumOfLoadDistancesOfOtherRSsBd.floatValue() > 0)
        {
          // The average distance of the other RSs shows a lack of DSs.
          // Compute the number of DSs to disconnect from the current RS,
          // rounding to the nearest integer number. Do only this if there is
          // no risk of yoyo effect: when the exact balance cannot be
          // established due to the current number of DSs connected, do not
          // disconnect a DS. A simple example where the balance cannot be
          // reached is:
          // - RS1 has weight 1 and 2 DSs
          // - RS2 has weight 1 and 1 DS
          // => disconnecting a DS from RS1 to reconnect it to RS2 would have no
          // sense as this would lead to the reverse situation. In that case,
          // the perfect balance cannot be reached and we must stick to the
          // current situation, otherwise the DS would keep move between the 2
          // RSs
          /*
          The average distance of the other RSs shows a lack of DSs.
          Compute the number of DSs to disconnect from the current RS,
          rounding to the nearest integer number. Do only this if there is
          no risk of yoyo effect: when the exact balance cannot be
          established due to the current number of DSs connected, do not
          disconnect a DS. A simple example where the balance cannot be
          reached is:
          - RS1 has weight 1 and 2 DSs
          - RS2 has weight 1 and 1 DS
          => disconnecting a DS from RS1 to reconnect it to RS2 would have no
          sense as this would lead to the reverse situation. In that case,
          the perfect balance cannot be reached and we must stick to the
          current situation, otherwise the DS would keep move between the 2
          RSs
          */
          float notRoundedOverloadingDSsNumber = sumOfLoadDistancesOfOtherRSsBd.
            multiply(BigDecimal.valueOf(sumOfConnectedDSs), mathContext)
                .floatValue();
@@ -1980,17 +2009,19 @@
            // What would be the new load distance for the other RSs ?
            BigDecimal additionalDsLoadBd =
                BigDecimal.ONE.divide(
                  BigDecimal.valueOf(sumOfConnectedDSs),mathContext);
                    BigDecimal.valueOf(sumOfConnectedDSs), mathContext);
            BigDecimal potentialNewSumOfLoadDistancesOfOtherRSsBd =
              sumOfLoadDistancesOfOtherRSsBd.subtract(additionalDsLoadBd,
                    mathContext);

            // Now compare both values: we must no disconnect the DS if this
            // is for going in a situation where the load distance of the other
            // RSs is the opposite of the future load distance of the local RS
            // or we would evaluate that we should disconnect just after being
            // arrived on the new RS. But we should disconnect if we reach the
            // perfect balance (both values are 0).
            /*
            Now compare both values: we must no disconnect the DS if this
            is for going in a situation where the load distance of the other
            RSs is the opposite of the future load distance of the local RS
            or we would evaluate that we should disconnect just after being
            arrived on the new RS. But we should disconnect if we reach the
            perfect balance (both values are 0).
            */
            MathContext roundMc =
              new MathContext(6, RoundingMode.DOWN);
            BigDecimal potentialCurrentRsNewLoadDistanceBdRounded =
@@ -2114,8 +2145,6 @@
    while (true)
    {
      // Synchronize inside the loop in order to allow shutdown.
      boolean needSleep = false;

      synchronized (startStopLock)
      {
        if (connected || shutdown)
@@ -2141,19 +2170,14 @@
          break;
        }

        needSleep = true;
      }

      if (needSleep)
      try
      {
        try
        {
          Thread.sleep(500);
        }
        catch (InterruptedException e)
        {
          // ignore
        }
      }
      catch (InterruptedException e)
      {
        // ignore
      }
    }

@@ -2209,11 +2233,13 @@
    {
      if (connectionError)
      {
        // It was not possible to connect to any replication server.
        // Since the operation was already processed, we have no other
        // choice than to return without sending the ReplicationMsg
        // and relying on the resend procedure of the connect phase to
        // fix the problem when we finally connect.
        /*
        It was not possible to connect to any replication server.
        Since the operation was already processed, we have no other
        choice than to return without sending the ReplicationMsg
        and relying on the resend procedure of the connect phase to
        fix the problem when we finally connect.
        */

        if (debugEnabled())
        {
@@ -2230,22 +2256,26 @@
        ProtocolSession current_session;
        Semaphore currentWindowSemaphore;

        // save the session at the time when we acquire the
        // sendwindow credit so that we can make sure later
        // that the session did not change in between.
        // This is necessary to make sure that we don't publish a message
        // on a session with a credit that was acquired from a previous
        // session.
        /*
        save the session at the time when we acquire the
        sendwindow credit so that we can make sure later
        that the session did not change in between.
        This is necessary to make sure that we don't publish a message
        on a session with a credit that was acquired from a previous
        session.
        */
        synchronized (connectPhaseLock)
        {
          current_session = session;
          currentWindowSemaphore = sendWindow;
        }

        // If the Replication domain has decided that there is a need to
        // recover some changes then it is not allowed to send this
        // change but it will be the responsibility of the recovery thread to
        // do it.
        /*
        If the Replication domain has decided that there is a need to
        recover some changes then it is not allowed to send this
        change but it will be the responsibility of the recovery thread to
        do it.
        */
        if (!recoveryMsg & connectRequiresRecovery)
        {
          return false;
@@ -2253,9 +2283,11 @@

        if (msg instanceof UpdateMsg)
        {
          // Acquiring the window credit must be done outside of the
          // connectPhaseLock because it can be blocking and we don't
          // want to hold off reconnection in case the connection dropped.
          /*
          Acquiring the window credit must be done outside of the
          connectPhaseLock because it can be blocking and we don't
          want to hold off reconnection in case the connection dropped.
          */
          credit =
            currentWindowSemaphore.tryAcquire(500, TimeUnit.MILLISECONDS);
        } else
@@ -2266,12 +2298,13 @@
        {
          synchronized (connectPhaseLock)
          {
            // session may have been set to null in the connection phase
            // when restarting the broker for example.
            /*
            session may have been set to null in the connection phase
            when restarting the broker for example.
            Check the session. If it has changed, some disconnection or
            reconnection happened and we need to restart from scratch.
            */

            // check the session. If it has changed, some
            // deconnection/reconnection happened and we need to restart from
            // scratch.
            if ((session != null) &&
                (session == current_session))
            {
@@ -2284,10 +2317,12 @@
        {
          synchronized (connectPhaseLock)
          {
            // the window is still closed.
            // Send a WindowProbeMsg message to wakeup the receiver in case the
            // window update message was lost somehow...
            // then loop to check again if connection was closed.
            /*
            the window is still closed.
            Send a WindowProbeMsg message to wake up the receiver in case the
            window update message was lost somehow...
            then loop to check again if connection was closed.
            */
            if (session != null) {
              session.publish(new WindowProbeMsg());
            }
@@ -2330,7 +2365,7 @@

  /**
   * Receive a message.
   * This method is not multithread safe and should either always be
   * This method is not thread-safe and should either always be
   * called in a single thread or protected by a locking mechanism
   * before being called. This is a wrapper to the method with a boolean version
   * so that we do not have to modify existing tests.
@@ -2346,7 +2381,7 @@

  /**
   * Receive a message.
   * This method is not multithread safe and should either always be
   * This method is not thread-safe and should either always be
   * called in a single thread or protected by a locking mechanism
   * before being called.
   *
@@ -2457,10 +2492,12 @@
            }
          }

          // Now if it is allowed, compute the best replication server to see if
          // it is still the one we are currently connected to. If not,
          // disconnect properly and let the connection algorithm re-connect to
          // best replication server
          /*
          Now if it is allowed, compute the best replication server to see if
          it is still the one we are currently connected to. If not,
          disconnect properly and let the connection algorithm re-connect to
          best replication server
          */
          if (reconnectToTheBestRS)
          {
            mustRunBestServerCheckingAlgorithm++;
@@ -2470,7 +2507,7 @@
              // best server checking.
              ReplicationServerInfo bestServerInfo =
                computeBestReplicationServer(false, rsServerId, state,
                replicationServerInfos, serverId, baseDn, groupId,
                replicationServerInfos, serverId, groupId,
                generationID);

              if ((rsServerId != -1) && ((bestServerInfo == null) ||
@@ -2876,10 +2913,12 @@

    if (rsServerId == rsId)
    {
      // If we are computing connected DSs for the RS we are connected
      // to, we should count the local DS as the DSInfo of the local DS is not
      // sent by the replication server in the topology message. We must count
      // ourself as a connected server.
      /*
      If we are computing connected DSs for the RS we are connected
      to, we should count the local DS as the DSInfo of the local DS is not
      sent by the replication server in the topology message. We must count
      ourselves as a connected server.
      */
      connectedDSs.add(serverId);
    }


 opends/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ComputeBestServerTest.java

@@ -23,6 +23,7 @@
 *
 *
 *      Copyright 2008-2010 Sun Microsystems, Inc.
 *      Portions Copyright 2013 ForgeRock AS.
 */
package org.opends.server.replication.plugin;

@@ -112,7 +113,7 @@
    rsInfos.put(11, ReplicationServerInfo.newInstance(replServerStartMsg));

    ReplicationServerInfo bestServer =
      computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, " ", (byte)1, 0L);
      computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, (byte)1, 0L);

    assertEquals(bestServer.getServerURL(),
      WINNER, "Wrong best replication server.");
@@ -162,7 +163,7 @@
    rsInfos.put(11, ReplicationServerInfo.newInstance(replServerStartMsg));

    ReplicationServerInfo bestServer =
      computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, " ", (byte)1, 0L);
      computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, (byte)1, 0L);

    assertEquals(bestServer.getServerURL(),
      WINNER, "Wrong best replication server.");
@@ -214,7 +215,7 @@
    rsInfos.put(11, ReplicationServerInfo.newInstance(replServerStartMsg));

    ReplicationServerInfo bestServer =
      computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, " ", (byte)1, 0L);
      computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, (byte)1, 0L);

    assertEquals(bestServer.getServerURL(),
      WINNER, "Wrong best replication server.");
@@ -266,7 +267,7 @@
    rsInfos.put(11, ReplicationServerInfo.newInstance(replServerStartMsg));

    ReplicationServerInfo bestServer =
      computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, " ", (byte)1, 0L);
      computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, (byte)1, 0L);

    assertEquals(bestServer.getServerURL(),
      WINNER, "Wrong best replication server.");
@@ -332,7 +333,7 @@
    rsInfos.put(12, ReplicationServerInfo.newInstance(replServerStartMsg));

    ReplicationServerInfo bestServer =
      computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, " ", (byte)1, 0L);
      computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, (byte)1, 0L);

    assertEquals(bestServer.getServerURL(),
      WINNER, "Wrong best replication server.");
@@ -400,7 +401,7 @@
    rsInfos.put(12, ReplicationServerInfo.newInstance(replServerStartMsg));

    ReplicationServerInfo bestServer =
      computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, " ", (byte)1, 0L);
      computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, (byte)1, 0L);

    assertEquals(bestServer.getServerURL(),
      WINNER, "Wrong best replication server.");
@@ -466,7 +467,7 @@
    rsInfos.put(12, ReplicationServerInfo.newInstance(replServerStartMsg));

    ReplicationServerInfo bestServer =
      computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, " ", (byte)1, 0L);
      computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, (byte)1, 0L);

    assertEquals(bestServer.getServerURL(),
      WINNER, "Wrong best replication server.");
@@ -546,7 +547,7 @@
    rsInfos.put(13, ReplicationServerInfo.newInstance(replServerStartMsg));

    ReplicationServerInfo bestServer =
      computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, " ", (byte)1, 0L);
      computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, (byte)1, 0L);

    assertEquals(bestServer.getServerURL(),
      WINNER, "Wrong best replication server.");
@@ -628,7 +629,7 @@
    rsInfos.put(13, ReplicationServerInfo.newInstance(replServerStartMsg));

    ReplicationServerInfo bestServer =
      computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, " ", (byte)1, 0L);
      computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, (byte)1, 0L);

    assertEquals(bestServer.getServerURL(),
      WINNER, "Wrong best replication server.");
@@ -680,7 +681,7 @@
    rsInfos.put(11, ReplicationServerInfo.newInstance(replServerStartMsg));

    ReplicationServerInfo bestServer =
      computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, " ", (byte)1, 0L);
      computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, (byte)1, 0L);

    assertEquals(bestServer.getServerURL(),
      WINNER, "Wrong best replication server.");
@@ -802,7 +803,7 @@
      ReplicationServer.onlyForTestsAddlocalReplicationServer(LOOSER2);

    ReplicationServerInfo bestServer =
      computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, " ", (byte) 1,
      computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, (byte) 1,
      0L);

    ReplicationServer.onlyForTestsClearLocalReplicationServerList();
@@ -895,7 +896,7 @@
      ReplicationServer.onlyForTestsAddlocalReplicationServer(LOOSER2);

    ReplicationServerInfo bestServer =
      computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, " ", (byte) 1,
      computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, (byte) 1,
      0L);

    ReplicationServer.onlyForTestsClearLocalReplicationServerList();