Lines Matching defs:localServerId
1235 private final int localServerId;
1242 * @param localServerId
1248 RSEvaluations(int localServerId,
1251 this.localServerId = localServerId;
1332 final LocalizableMessage eval = NOTE_BEST_RS.get(bestRSServerId, localServerId);
1357 return NOTE_UNKNOWN_RS.get(rsServerId, localServerId);
1436 * @param localServerId The server id for the suffix we are working for.
1446 Map<Integer, ReplicationServerInfo> rsInfos, int localServerId,
1449 final RSEvaluations evals = new RSEvaluations(localServerId, rsInfos);
1476 filterServersLocallyConfigured(evals, localServerId);
1478 filterServersWithSameGroupId(evals, localServerId, groupId);
1481 filterServersWithSameGenerationId(evals, localServerId, generationId);
1486 filterServersWithAllLocalDSChanges(evals, myState, localServerId);
1489 filterServersOnSameHost(evals, localServerId);
1510 computeBestServerForWeight(evals, rsServerId, localServerId);
1521 int localServerId)
1535 NOTE_RS_NOT_LOCALLY_CONFIGURED.get(rsId, localServerId));
1548 int localServerId, byte groupId)
1562 rsId, rsInfo.getGroupId(), localServerId, groupId));
1580 RSEvaluations evals, long localServerId, long generationId)
1601 generationId, localServerId));
1606 rsId, rsInfo.getGenerationId(), localServerId, generationId));
1633 * @param localServerId The server id to consider for the changes
1636 RSEvaluations evals, ServerState localState, int localServerId)
1639 final CSN localCSN = getCSN(localState, localServerId);
1655 final CSN rsCSN = getCSN(rsInfo.getServerState(), localServerId);
1661 rsId, rsCSN.toStringUI(), localServerId, localCSN.toStringUI()));
1675 rsId, rsCSN.toStringUI(), localServerId, localCSN.toStringUI()));
1685 rejectAllWithRSIsLaterThanBestRS(mostUpToDateEval, localServerId,
1699 rejectAllWithRSIsLaterThanBestRS(mostUpToDateEval, localServerId,
1708 rsId, rsCSN.toStringUI(), localServerId, localCSN.toStringUI()));
1726 final LocalEvaluation eval, int localServerId, CSN localCSN)
1731 getCSN(rsInfo.getServerState(), localServerId).toStringUI();
1734 rsInfo.getServerId(), rsCSN, localServerId, localCSN.toStringUI());
1748 int localServerId)
1769 rejectAllWithRSOnDifferentVMThanDS(eval, localServerId);
1784 localServerId));
1790 localServerId));
1797 int localServerId)
1802 rsInfo.getServerId(), localServerId));
1817 * @param localServerId The server id of the local server. This is not used
1822 int currentRsServerId, int localServerId)
1874 computeBestServerWhenNotConnected(evals, loadDistances, localServerId);
1880 computeBestServerWhenConnected(evals, loadDistances, localServerId,
1886 Map<Integer, BigDecimal> loadDistances, int localServerId)
1927 evals.setBestRS(bestRsId, NOTE_BIGGEST_WEIGHT_RS.get(localServerId,
1932 Map<Integer, BigDecimal> loadDistances, int localServerId,
2034 NOTE_AVOID_YOYO_EFFECT.get(localServerId, currentRsServerId));
2041 if (isServerOverloadingRS(localServerId, currentRsInfo,
2046 localServerId, currentRsServerId));
2053 NOTE_DO_NOT_DISCONNECT_DS_FROM_OVERLOADED_RS.get(localServerId,
2060 NOTE_NO_NEED_TO_REBALANCE_DSS_BETWEEN_RSS.get(localServerId,
2068 NOTE_DO_NOT_DISCONNECT_DS_FROM_ACCEPTABLE_LOAD_RS.get(localServerId,
2097 private static boolean isServerOverloadingRS(int localServerId,
2103 final int idx = serversConnectedToCurrentRS.indexOf(localServerId);