/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/session/blacklist/ |
H A D | CTSSessionBlacklist.java | 93 private final String localServerId; field in class:CTSSessionBlacklist 106 this.localServerId = serverConfig.getLocalServerID(); 118 token.setAttribute(SERVER_ID_FIELD, localServerId); 183 not(equalTo(SERVER_ID_FIELD, localServerId))))
|
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/blacklist/ |
H A D | CTSBlacklist.java | 91 private final String localServerId; field in class:CTSBlacklist 102 String localServerId; 104 localServerId = serverConfig.getAMServerID(); 107 localServerId = ""; 109 this.localServerId = localServerId; 120 token.setAttribute(SERVER_ID_FIELD, localServerId); 185 not(equalTo(SERVER_ID_FIELD, localServerId))))
|
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | ComputeBestServerTest.java | 1794 int localServerId, String winnerUrl) 1802 computeBestServerForWeight(servers, currentRsServerId, localServerId); 1792 testComputeBestServerForWeight( Map<Integer, ReplicationServerInfo> servers, int currentRsServerId, int localServerId, String winnerUrl) argument
|
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | ComputeBestServerTest.java | 1794 int localServerId, String winnerUrl) 1802 computeBestServerForWeight(servers, currentRsServerId, localServerId); 1792 testComputeBestServerForWeight( Map<Integer, ReplicationServerInfo> servers, int currentRsServerId, int localServerId, String winnerUrl) argument
|
/forgerock/openam-v13/openam-core/src/main/java/com/iplanet/dpro/session/service/cluster/ |
H A D | ClusterStateService.java | 168 private static String localServerId = null; field in class:ClusterStateService 213 return localServerId; 222 return (serverId != null && serverId.equalsIgnoreCase(localServerId)); 227 * @param localServerId id of the server instance in which this 235 protected ClusterStateService(SessionService sessionService, String localServerId, argument 238 if ( (localServerId == null)||(localServerId.isEmpty()) ) 247 this.localServerId = localServerId; 368 if (serverId.equalsIgnoreCase(localServerId)) { [all...] |
/forgerock/openam/openam-core/src/main/java/com/iplanet/dpro/session/service/cluster/ |
H A D | ClusterStateService.java | 173 private static String localServerId = null; field in class:ClusterStateService 215 return localServerId; 224 return (serverId != null && serverId.equalsIgnoreCase(localServerId)); 229 * @param localServerId id of the server instance in which this ClusterStateService instance is running 236 protected ClusterStateService(String localServerId, argument 239 if ( (localServerId == null)||(localServerId.isEmpty()) ) 247 this.localServerId = localServerId; 366 if (serverId.equalsIgnoreCase(localServerId)) { [all...] |
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/service/ |
H A D | ComputeBestServerTest.java | 1325 int localServerId, String winnerUrl) 1331 final RSEvaluations evals = new RSEvaluations(localServerId, servers); 1332 computeBestServerForWeight(evals, currentRsServerId, localServerId); 1323 testComputeBestServerForWeight( Map<Integer, ReplicationServerInfo> servers, int currentRsServerId, int localServerId, String winnerUrl) argument
|
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/service/ |
H A D | ComputeBestServerTest.java | 1324 int localServerId, String winnerUrl) 1330 final RSEvaluations evals = new RSEvaluations(localServerId, servers); 1331 computeBestServerForWeight(evals, currentRsServerId, localServerId); 1322 testComputeBestServerForWeight( Map<Integer, ReplicationServerInfo> servers, int currentRsServerId, int localServerId, String winnerUrl) argument
|
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/service/ |
H A D | ComputeBestServerTest.java | 1325 int localServerId, String winnerUrl) 1331 final RSEvaluations evals = new RSEvaluations(localServerId, servers); 1332 computeBestServerForWeight(evals, currentRsServerId, localServerId); 1323 testComputeBestServerForWeight( Map<Integer, ReplicationServerInfo> servers, int currentRsServerId, int localServerId, String winnerUrl) argument
|
/forgerock/openam-v13/openam-federation/openam-federation-library/src/main/java/com/sun/identity/liberty/ws/interaction/ |
H A D | InteractionConfig.java | 143 protected String localServerId = null; field in class:InteractionConfig 262 return localServerId; 316 sb.append(":localServerId=" 317 + localServerId); 592 localServerId = null; 597 localServerId = key; 602 if (localServerId == null) {
|
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/service/ |
H A D | ComputeBestServerTest.java | 1321 int localServerId, String winnerUrl) 1327 final RSEvaluations evals = new RSEvaluations(localServerId, servers); 1328 computeBestServerForWeight(evals, currentRsServerId, localServerId); 1319 testComputeBestServerForWeight( Map<Integer, ReplicationServerInfo> servers, int currentRsServerId, int localServerId, String winnerUrl) argument
|
/forgerock/openam/openam-federation/openam-federation-library/src/main/java/com/sun/identity/liberty/ws/interaction/ |
H A D | InteractionConfig.java | 143 protected String localServerId = null; field in class:InteractionConfig 262 return localServerId; 316 sb.append(":localServerId=" 317 + localServerId); 592 localServerId = null; 597 localServerId = key; 602 if (localServerId == null) {
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 1525 * @param localServerId The server id for the suffix we are working for. 1535 Map<Integer, ReplicationServerInfo> rsInfos, int localServerId, 1581 myState, localServerId), sameGenerationId); 1603 localServerId); 1730 * @param localServerId The server id to consider for the changes 1737 int localServerId) 1746 ChangeNumber myChangeNumber = localState.getMaxChangeNumber(localServerId); 1749 myChangeNumber = new ChangeNumber(0, 0, localServerId); 1764 ChangeNumber rsChangeNumber = rsState.getMaxChangeNumber(localServerId); 1767 rsChangeNumber = new ChangeNumber(0, 0, localServerId); 1533 computeBestReplicationServer( boolean firstConnection, int rsServerId, ServerState myState, Map<Integer, ReplicationServerInfo> rsInfos, int localServerId, byte groupId, long generationId) argument 1735 filterServersWithAllLocalDSChanges(Map<Integer, ReplicationServerInfo> bestServers, ServerState localState, int localServerId) argument 1893 computeBestServerForWeight( Map<Integer, ReplicationServerInfo> bestServers, int currentRsServerId, int localServerId) argument [all...] |
/forgerock/opendj2/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 1256 private final int localServerId; field in class:ReplicationBroker.RSEvaluations 1264 * @param localServerId 1270 RSEvaluations(int localServerId, argument 1273 this.localServerId = localServerId; 1354 final Message eval = NOTE_BEST_RS.get(bestRSServerId, localServerId); 1379 return NOTE_UNKNOWN_RS.get(rsServerId, localServerId); 1460 * @param localServerId The server id for the suffix we are working for. 1470 Map<Integer, ReplicationServerInfo> rsInfos, int localServerId, 1473 final RSEvaluations evals = new RSEvaluations(localServerId, rsInfo 1468 computeBestReplicationServer( boolean firstConnection, int rsServerId, ServerState myState, Map<Integer, ReplicationServerInfo> rsInfos, int localServerId, byte groupId, long generationId) argument 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 1747 rejectAllWithRSIsLaterThanBestRS( final LocalEvaluation eval, int localServerId, CSN localCSN) argument 1769 filterServersOnSameHost(RSEvaluations evals, int localServerId) argument 1818 rejectAllWithRSOnDifferentVMThanDS(LocalEvaluation eval, 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 2119 isServerOverloadingRS(int localServerId, ReplicationServerInfo currentRsInfo, int overloadingDSsNumber) argument [all...] |
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 1515 private final int localServerId; field in class:ReplicationBroker.RSEvaluations 1523 * @param localServerId 1529 RSEvaluations(int localServerId, argument 1532 this.localServerId = localServerId; 1613 final Message eval = NOTE_BEST_RS.get(bestRSServerId, localServerId); 1638 return NOTE_UNKNOWN_RS.get(rsServerId, localServerId); 1721 * @param localServerId The server id for the suffix we are working for. 1731 Map<Integer, ReplicationServerInfo> rsInfos, int localServerId, 1734 final RSEvaluations evals = new RSEvaluations(localServerId, rsInfo 1729 computeBestReplicationServer( boolean firstConnection, int rsServerId, ServerState myState, Map<Integer, ReplicationServerInfo> rsInfos, int localServerId, byte groupId, long generationId) argument 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 2011 rejectAllWithRSIsLaterThanBestRS( final LocalEvaluation eval, int localServerId, ChangeNumber localCN) argument 2033 filterServersOnSameHost(RSEvaluations evals, int localServerId) argument 2092 rejectAllWithRSOnDifferentVMThanDS(LocalEvaluation eval, 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 2389 isServerOverloadingRS(int localServerId, ReplicationServerInfo currentRsInfo, int overloadingDSsNumber) argument [all...] |
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 1525 * @param localServerId The server id for the suffix we are working for. 1535 Map<Integer, ReplicationServerInfo> rsInfos, int localServerId, 1581 myState, localServerId), sameGenerationId); 1603 localServerId); 1730 * @param localServerId The server id to consider for the changes 1737 int localServerId) 1746 ChangeNumber myChangeNumber = localState.getMaxChangeNumber(localServerId); 1749 myChangeNumber = new ChangeNumber(0, 0, localServerId); 1764 ChangeNumber rsChangeNumber = rsState.getMaxChangeNumber(localServerId); 1767 rsChangeNumber = new ChangeNumber(0, 0, localServerId); 1533 computeBestReplicationServer( boolean firstConnection, int rsServerId, ServerState myState, Map<Integer, ReplicationServerInfo> rsInfos, int localServerId, byte groupId, long generationId) argument 1735 filterServersWithAllLocalDSChanges(Map<Integer, ReplicationServerInfo> bestServers, ServerState localState, int localServerId) argument 1893 computeBestServerForWeight( Map<Integer, ReplicationServerInfo> bestServers, int currentRsServerId, int localServerId) argument [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 1256 private final int localServerId; field in class:ReplicationBroker.RSEvaluations 1264 * @param localServerId 1270 RSEvaluations(int localServerId, argument 1273 this.localServerId = localServerId; 1354 final Message eval = NOTE_BEST_RS.get(bestRSServerId, localServerId); 1379 return NOTE_UNKNOWN_RS.get(rsServerId, localServerId); 1460 * @param localServerId The server id for the suffix we are working for. 1470 Map<Integer, ReplicationServerInfo> rsInfos, int localServerId, 1473 final RSEvaluations evals = new RSEvaluations(localServerId, rsInfo 1468 computeBestReplicationServer( boolean firstConnection, int rsServerId, ServerState myState, Map<Integer, ReplicationServerInfo> rsInfos, int localServerId, byte groupId, long generationId) argument 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 1747 rejectAllWithRSIsLaterThanBestRS( final LocalEvaluation eval, int localServerId, CSN localCSN) argument 1769 filterServersOnSameHost(RSEvaluations evals, int localServerId) argument 1818 rejectAllWithRSOnDifferentVMThanDS(LocalEvaluation eval, 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 2119 isServerOverloadingRS(int localServerId, ReplicationServerInfo currentRsInfo, int overloadingDSsNumber) argument [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 1235 private final int localServerId; field in class:ReplicationBroker.RSEvaluations 1242 * @param localServerId 1248 RSEvaluations(int localServerId, argument 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, rsInfo 1444 computeBestReplicationServer( boolean firstConnection, int rsServerId, ServerState myState, Map<Integer, ReplicationServerInfo> rsInfos, int localServerId, byte groupId, long generationId) argument 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 1725 rejectAllWithRSIsLaterThanBestRS( final LocalEvaluation eval, int localServerId, CSN localCSN) argument 1747 filterServersOnSameHost(RSEvaluations evals, int localServerId) argument 1796 rejectAllWithRSOnDifferentVMThanDS(LocalEvaluation eval, 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 2097 isServerOverloadingRS(int localServerId, ReplicationServerInfo currentRsInfo, int overloadingDSsNumber) argument [all...] |