/forgerock/opendj2/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 792 RSEvaluations evals = computeBestReplicationServer(true, -1, state, 798 + evals.getBestRS()); 801 evals.getBestRS().getServerURL(), true); 1473 final RSEvaluations evals = new RSEvaluations(localServerId, rsInfos); 1475 if (evals.foundBestRS()) 1477 return evals; 1500 filterServersLocallyConfigured(evals, localServerId); 1502 filterServersWithSameGroupId(evals, localServerId, groupId); 1505 filterServersWithSameGenerationId(evals, localServerId, generationId); 1510 filterServersWithAllLocalDSChanges(evals, myStat 1544 filterServersLocallyConfigured(RSEvaluations evals, int localServerId) argument 1571 filterServersWithSameGroupId(RSEvaluations evals, int localServerId, byte groupId) argument 1603 filterServersWithSameGenerationId( RSEvaluations evals, long localServerId, long generationId) argument 1657 filterServersWithAllLocalDSChanges( RSEvaluations evals, ServerState localState, int localServerId) argument 1769 filterServersOnSameHost(RSEvaluations evals, int localServerId) argument 1843 computeBestServerForWeight(RSEvaluations evals, int currentRsServerId, int localServerId) argument 1907 computeBestServerWhenNotConnected(RSEvaluations evals, Map<Integer, BigDecimal> loadDistances, int localServerId) argument 1953 computeBestServerWhenConnected(RSEvaluations evals, Map<Integer, BigDecimal> loadDistances, int localServerId, int currentRsServerId, int sumOfWeights, int sumOfConnectedDSs) argument [all...] |
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 932 RSEvaluations evals = computeBestReplicationServer(true, -1, state, 934 electedRsInfo = evals.getBestRS(); 1734 final RSEvaluations evals = new RSEvaluations(localServerId, rsInfos); 1736 if (evals.foundBestRS()) 1738 return evals; 1761 filterServersLocallyConfigured(evals, localServerId); 1763 filterServersWithSameGroupId(evals, localServerId, groupId); 1766 filterServersWithSameGenerationId(evals, localServerId, generationId); 1771 filterServersWithAllLocalDSChanges(evals, myState, localServerId); 1774 filterServersOnSameHost(evals, localServerI 1805 filterServersLocallyConfigured(RSEvaluations evals, int localServerId) argument 1832 filterServersWithSameGroupId(RSEvaluations evals, int localServerId, byte groupId) argument 1864 filterServersWithSameGenerationId( RSEvaluations evals, long localServerId, long generationId) argument 1918 filterServersWithAllLocalDSChanges( RSEvaluations evals, ServerState localState, int localServerId) argument 2033 filterServersOnSameHost(RSEvaluations evals, int localServerId) argument 2117 computeBestServerForWeight(RSEvaluations evals, int currentRsServerId, int localServerId) argument 2181 computeBestServerWhenNotConnected(RSEvaluations evals, Map<Integer, BigDecimal> loadDistances, int localServerId) argument 2227 computeBestServerWhenConnected(RSEvaluations evals, Map<Integer, BigDecimal> loadDistances, int localServerId, int currentRsServerId, int sumOfWeights, int sumOfConnectedDSs) argument [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 792 RSEvaluations evals = computeBestReplicationServer(true, -1, state, 798 + evals.getBestRS()); 801 evals.getBestRS().getServerURL(), true); 1473 final RSEvaluations evals = new RSEvaluations(localServerId, rsInfos); 1475 if (evals.foundBestRS()) 1477 return evals; 1500 filterServersLocallyConfigured(evals, localServerId); 1502 filterServersWithSameGroupId(evals, localServerId, groupId); 1505 filterServersWithSameGenerationId(evals, localServerId, generationId); 1510 filterServersWithAllLocalDSChanges(evals, myStat 1544 filterServersLocallyConfigured(RSEvaluations evals, int localServerId) argument 1571 filterServersWithSameGroupId(RSEvaluations evals, int localServerId, byte groupId) argument 1603 filterServersWithSameGenerationId( RSEvaluations evals, long localServerId, long generationId) argument 1657 filterServersWithAllLocalDSChanges( RSEvaluations evals, ServerState localState, int localServerId) argument 1769 filterServersOnSameHost(RSEvaluations evals, int localServerId) argument 1843 computeBestServerForWeight(RSEvaluations evals, int currentRsServerId, int localServerId) argument 1907 computeBestServerWhenNotConnected(RSEvaluations evals, Map<Integer, BigDecimal> loadDistances, int localServerId) argument 1953 computeBestServerWhenConnected(RSEvaluations evals, Map<Integer, BigDecimal> loadDistances, int localServerId, int currentRsServerId, int sumOfWeights, int sumOfConnectedDSs) argument [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 783 RSEvaluations evals = computeBestReplicationServer(true, -1, state, 789 debugInfo("phase 2 : will perform PhaseOneH with the preferred RS=" + evals.getBestRS()); 793 evals.getBestRS().getServerURL(), true); 1449 final RSEvaluations evals = new RSEvaluations(localServerId, rsInfos); 1451 if (evals.foundBestRS()) 1453 return evals; 1476 filterServersLocallyConfigured(evals, localServerId); 1478 filterServersWithSameGroupId(evals, localServerId, groupId); 1481 filterServersWithSameGenerationId(evals, localServerId, generationId); 1486 filterServersWithAllLocalDSChanges(evals, myStat 1520 filterServersLocallyConfigured(RSEvaluations evals, int localServerId) argument 1547 filterServersWithSameGroupId(RSEvaluations evals, int localServerId, byte groupId) argument 1579 filterServersWithSameGenerationId( RSEvaluations evals, long localServerId, long generationId) argument 1635 filterServersWithAllLocalDSChanges( RSEvaluations evals, ServerState localState, int localServerId) argument 1747 filterServersOnSameHost(RSEvaluations evals, int localServerId) argument 1821 computeBestServerForWeight(RSEvaluations evals, int currentRsServerId, int localServerId) argument 1885 computeBestServerWhenNotConnected(RSEvaluations evals, Map<Integer, BigDecimal> loadDistances, int localServerId) argument 1931 computeBestServerWhenConnected(RSEvaluations evals, Map<Integer, BigDecimal> loadDistances, int localServerId, int currentRsServerId, int sumOfWeights, int sumOfConnectedDSs) argument [all...] |