Searched defs:localServerId (Results 1 - 18 of 18) sorted by relevance

/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/session/blacklist/
H A DCTSSessionBlacklist.java93 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 DCTSBlacklist.java91 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 DComputeBestServerTest.java1794 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 DComputeBestServerTest.java1794 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 DClusterStateService.java168 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 DClusterStateService.java173 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 DComputeBestServerTest.java1325 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 DComputeBestServerTest.java1324 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 DComputeBestServerTest.java1325 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 DInteractionConfig.java143 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 DComputeBestServerTest.java1321 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 DInteractionConfig.java143 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 DReplicationBroker.java1525 * @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 DReplicationBroker.java1256 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 DReplicationBroker.java1515 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 DReplicationBroker.java1525 * @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 DReplicationBroker.java1256 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 DReplicationBroker.java1235 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...]

Completed in 90 milliseconds