/forgerock/openam/openam-core/src/main/java/com/iplanet/dpro/session/service/ |
H A D | SessionServerConfig.java | 209 * Checks if server instance identified by serverID is this OpenAM server. 211 * @param serverID server id, possibly null. 212 * @return true if serverID is the same as local instance, false otherwise. 214 public boolean isLocalServer(String serverID) { argument 215 return localServerID.equals(serverID); 219 * Checks if server instance identified by serverID is the primary server for this OpenAM server's site. 226 public boolean isPrimaryServer(String serverID) { argument 227 return isSiteEnabled() ? getSiteID().equals(serverID) : localServerID.equals(serverID); 262 * Checks if server instance identified by serverID i 324 getServerFromID(String serverID) argument 383 findSecondarySiteIDs(String serverID) argument [all...] |
/forgerock/openam/openam-federation/openam-federation-library/src/main/java/com/sun/identity/common/ |
H A D | SystemConfigurationUtil.java | 310 String serverID = (String)serverToIdTable.get(server); 311 if (serverID == null) { 316 return serverID; 591 * Checks whether the given serverID is a really existing serverid in the 594 * @param serverID 595 * true if the given serverID is a valid serverID. 597 public static boolean isValidServerId(String serverID) { argument 598 if (isSiteId(serverID)) { 601 return idToServerTable.containsKey(serverID); [all...] |
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | InitOnLineTest.java | 492 * @param senderID The serverID of this broker. 531 void receiveUpdatedEntries(ReplicationBroker broker, int serverID, argument 541 log("Broker " + serverID + " Wait for entry or done msg"); 549 log("Broker " + serverID + " receives InitializeTargetMessage "); 555 log("Broker " + serverID + " receives entry " + new String(em.getEntryBytes())); 560 log("Broker " + serverID + " receives done "); 566 log("Broker " + serverID + " receives ERROR " 572 log("Broker " + serverID + " receives and trashes " + msg); 622 * @param changelogId The serverID of the replicationServer to create. 1056 // Scope containing a serverID absen [all...] |
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | GenerationIdTest.java | 265 private int receiveImport(ReplicationBroker broker, int serverID, String[] updatedEntries) throws Exception argument 271 debugInfo("Broker " + serverID + " Wait for entry or done msg"); 280 debugInfo("Broker " + serverID + " receives InitializeTargetMessage "); 286 debugInfo("Broker " + serverID + " receives entry " + new String(em.getEntryBytes())); 291 debugInfo("Broker " + serverID + " receives done "); 296 debugInfo("Broker " + serverID + " receives ERROR " + msg); 301 debugInfo("Broker " + serverID + " receives and trashes " + msg); 315 * @param replServerId The serverID of the replicationServer to create.
|
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | InitOnLineTest.java | 492 * @param senderID The serverID of this broker. 531 void receiveUpdatedEntries(ReplicationBroker broker, int serverID, argument 541 log("Broker " + serverID + " Wait for entry or done msg"); 549 log("Broker " + serverID + " receives InitializeTargetMessage "); 555 log("Broker " + serverID + " receives entry " + new String(em.getEntryBytes())); 560 log("Broker " + serverID + " receives done "); 566 log("Broker " + serverID + " receives ERROR " 572 log("Broker " + serverID + " receives and trashes " + msg); 622 * @param changelogId The serverID of the replicationServer to create. 1056 // Scope containing a serverID absen [all...] |
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | GenerationIdTest.java | 265 private int receiveImport(ReplicationBroker broker, int serverID, String[] updatedEntries) throws Exception argument 271 debugInfo("Broker " + serverID + " Wait for entry or done msg"); 280 debugInfo("Broker " + serverID + " receives InitializeTargetMessage "); 286 debugInfo("Broker " + serverID + " receives entry " + new String(em.getEntryBytes())); 291 debugInfo("Broker " + serverID + " receives done "); 296 debugInfo("Broker " + serverID + " receives ERROR " + msg); 301 debugInfo("Broker " + serverID + " receives and trashes " + msg); 315 * @param replServerId The serverID of the replicationServer to create.
|
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | InitOnLineTest.java | 492 * @param senderID The serverID of this broker. 531 void receiveUpdatedEntries(ReplicationBroker broker, int serverID, argument 541 log("Broker " + serverID + " Wait for entry or done msg"); 549 log("Broker " + serverID + " receives InitializeTargetMessage "); 555 log("Broker " + serverID + " receives entry " + new String(em.getEntryBytes())); 560 log("Broker " + serverID + " receives done "); 566 log("Broker " + serverID + " receives ERROR " 572 log("Broker " + serverID + " receives and trashes " + msg); 622 * @param changelogId The serverID of the replicationServer to create. 1056 // Scope containing a serverID absen [all...] |
/forgerock/openam-v13/openam-core/src/main/java/com/iplanet/dpro/session/ |
H A D | SessionID.java | 364 String serverID = null; 392 serverID = extensions.getSiteID(); 393 if (serverID != null) { 394 setServerID(serverID); 398 debug.error("Invalid sessionid format:["+serverID+"]", e); 399 throw new IllegalArgumentException("Invalid sessionid format:["+serverID+"]" + e); 730 private SessionID(String sid, String serverID, String domain) { argument 732 setServerID(serverID);
|
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/ |
H A D | GenerationIdTest.java | 270 private int receiveImport(ReplicationBroker broker, int serverID, String[] updatedEntries) throws Exception argument 276 debugInfo("Broker " + serverID + " Wait for entry or done msg"); 285 debugInfo("Broker " + serverID + " receives InitializeTargetMessage "); 291 debugInfo("Broker " + serverID + " receives entry " + new String(em.getEntryBytes())); 296 debugInfo("Broker " + serverID + " receives done "); 301 debugInfo("Broker " + serverID + " receives ERROR " + msg); 306 debugInfo("Broker " + serverID + " receives and trashes " + msg); 320 * @param replServerId The serverID of the replicationServer to create.
|
/forgerock/openam/openam-core/src/main/java/com/iplanet/dpro/session/ |
H A D | SessionID.java | 368 String serverID = null; 396 serverID = extensions.getSiteID(); 397 if (serverID != null) { 398 setServerID(serverID); 755 private SessionID(String sid, String serverID, String domain) { argument 757 setServerID(serverID);
|
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | FractionalReplicationTest.java | 682 int serverID, 688 super(serviceID, serverID, 100); 680 FakeReplicationDomain( String serviceID, int serverID, Collection<String> replicationServers, int window, long heartbeatInterval, long generationId) argument
|
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | FractionalReplicationTest.java | 682 int serverID, 688 super(serviceID, serverID, 100); 680 FakeReplicationDomain( String serviceID, int serverID, Collection<String> replicationServers, int window, long heartbeatInterval, long generationId) argument
|
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | FractionalReplicationTest.java | 682 int serverID, 688 super(serviceID, serverID, 100); 680 FakeReplicationDomain( String serviceID, int serverID, Collection<String> replicationServers, int window, long heartbeatInterval, long generationId) argument
|
/forgerock/openam-v13/openam-core/src/main/java/com/iplanet/services/naming/ |
H A D | WebtopNaming.java | 183 * @param serverID The ID that needs to be checked. 186 public static boolean isServer(String serverID) { argument 187 return config.getServerIDs().contains(serverID); 674 String serverID = null; 677 serverID = getValueFromTable(config.getServerIDTable(), server); 679 if (serverID == null) { 682 serverID = getValueFromTable(config.getServerIDTable(), 686 if (serverID == null) { 689 serverID = getValueFromTable(config.getServerIDTable(), 695 if (( serverID 748 getServerFromID(String serverID) argument [all...] |
/forgerock/openam/openam-core/src/main/java/com/iplanet/services/naming/ |
H A D | WebtopNaming.java | 187 * @param serverID The ID that needs to be checked. 190 public static boolean isServer(String serverID) { argument 191 return config.getServerIDs().contains(serverID); 595 for (String serverID : serverIDs) { 596 String url = WebtopNaming.getServerFromID(serverID); 750 String serverID = null; 753 serverID = getValueFromTable(config.getServerIDTable(), server); 755 if (serverID == null) { 758 serverID = getValueFromTable(config.getServerIDTable(), 762 if (serverID 824 getServerFromID(String serverID) argument [all...] |
/forgerock/openam-v13/openam-core/src/main/java/com/iplanet/dpro/session/service/ |
H A D | SessionService.java | 1193 * Actively check if server identified by serverID is up 1195 * @param serverID server id 1198 public boolean checkServerUp(String serverID) { argument 1200 return getClusterMonitor().checkServerUp(serverID); 1202 sessionDebug.error("Failed to check Server Up for {0}", serverID, e);
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/ |
H A D | ReplicationDomain.java | 131 private final int serverID; field in class:ReplicationDomain 304 * @param serverID The identifier of the server that is participating 310 public ReplicationDomain(String serviceID, int serverID,int initWindow) argument 313 this.serverID = serverID; 316 this.generator = new ChangeNumberGenerator(serverID, state); 326 * @param serverID The identifier of the server that is participating 331 public ReplicationDomain(String serviceID, int serverID) argument 334 this.serverID = serverID; 353 ReplicationDomain(String serviceID, int serverID, ServerState serverState) argument [all...] |
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
H A D | AssuredReplicationServerTest.java | 619 * @param serverID our server id 632 int serverID, 642 super(serviceID, serverID, serverState); 651 gen = new ChangeNumberGenerator(serverID, 0L); 630 FakeReplicationDomain( String serviceID, int serverID, long generationId, byte groupId, boolean assured, AssuredMode assuredMode, byte safeDataLevel, long assuredTimeout, int scenario, ServerState serverState) argument
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/ |
H A D | ReplicationDomain.java | 132 private final int serverID; field in class:ReplicationDomain 305 * @param serverID The identifier of the server that is participating 311 public ReplicationDomain(String serviceID, int serverID,int initWindow) argument 314 this.serverID = serverID; 317 this.generator = new ChangeNumberGenerator(serverID, state); 327 * @param serverID The identifier of the server that is participating 332 public ReplicationDomain(String serviceID, int serverID) argument 335 this.serverID = serverID; 354 ReplicationDomain(String serviceID, int serverID, ServerState serverState) argument [all...] |
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
H A D | AssuredReplicationServerTest.java | 619 * @param serverID our server id 632 int serverID, 642 super(serviceID, serverID, serverState); 651 gen = new ChangeNumberGenerator(serverID, 0L); 630 FakeReplicationDomain( String serviceID, int serverID, long generationId, byte groupId, boolean assured, AssuredMode assuredMode, byte safeDataLevel, long assuredTimeout, int scenario, ServerState serverState) argument
|
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
H A D | AssuredReplicationServerTest.java | 619 * @param serverID our server id 632 int serverID, 642 super(serviceID, serverID, serverState); 651 gen = new ChangeNumberGenerator(serverID, 0L); 630 FakeReplicationDomain( String serviceID, int serverID, long generationId, byte groupId, boolean assured, AssuredMode assuredMode, byte safeDataLevel, long assuredTimeout, int scenario, ServerState serverState) argument
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/ |
H A D | ReplicationDomain.java | 131 private final int serverID; field in class:ReplicationDomain 304 * @param serverID The identifier of the server that is participating 310 public ReplicationDomain(String serviceID, int serverID,int initWindow) argument 313 this.serverID = serverID; 316 this.generator = new ChangeNumberGenerator(serverID, state); 326 * @param serverID The identifier of the server that is participating 331 public ReplicationDomain(String serviceID, int serverID) argument 334 this.serverID = serverID; 353 ReplicationDomain(String serviceID, int serverID, ServerState serverState) argument [all...] |