/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/service/ |
H A D | FakeReplicationDomain.java | 68 private FakeReplicationDomain(DN baseDN, int serverID, argument 72 super(newConfig(baseDN, serverID, replicationServers, window, heartbeatInterval), generationId); 77 private static DomainFakeCfg newConfig(DN baseDN, int serverID, argument 80 DomainFakeCfg fakeCfg = new DomainFakeCfg(baseDN, serverID, replicationServers); 87 public FakeReplicationDomain(DN baseDN, int serverID, argument 91 this(baseDN, serverID, replicationServers, 100, heartbeatInterval, generationId); 94 FakeReplicationDomain(DN baseDN, int serverID, argument 98 this(baseDN, serverID, replicationServers, window, heartbeatInterval, 1); 102 FakeReplicationDomain(DN baseDN, int serverID, argument 107 this(baseDN, serverID, replicationServer [all...] |
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/ |
H A D | EntryMsg.java | 68 * @param serverID The sender of this message. 76 int serverID, 83 super(serverID, i); 75 EntryMsg( int serverID, int i, byte[] entryBytes, int pos, int length, int msgId) argument
|
H A D | InitializeTargetMsg.java | 45 // Specifies the serverID of the server that requested this export 57 * @param serverID The serverID of the server that sends this message. 63 public InitializeTargetMsg(String baseDN, int serverID, argument 66 super(serverID, target); 146 * Get the serverID of the server that initiated the export. 150 * @return the serverID
|
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/service/ |
H A D | FakeReplicationDomain.java | 72 int serverID, 78 super(serviceID, serverID, 100); 86 int serverID, 94 super(serviceID, serverID, 100); 70 FakeReplicationDomain( String serviceID, int serverID, Collection<String> replicationServers, int window, long heartbeatInterval, BlockingQueue<UpdateMsg> queue) argument 84 FakeReplicationDomain( String serviceID, int serverID, Collection<String> replicationServers, int window, long heartbeatInterval, String exportString, StringBuilder importString, int exportedEntryCount) argument
|
H A D | FakeStressReplicationDomain.java | 59 int serverID, 65 super(serviceID, serverID, 100); 57 FakeStressReplicationDomain( String serviceID, int serverID, Collection<String> replicationServers, int window, long heartbeatInterval, BlockingQueue<UpdateMsg> queue) argument
|
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/service/ |
H A D | FakeReplicationDomain.java | 68 private FakeReplicationDomain(DN baseDN, int serverID, argument 72 super(newConfig(baseDN, serverID, replicationServers, window, heartbeatInterval), generationId); 77 private static DomainFakeCfg newConfig(DN baseDN, int serverID, argument 80 DomainFakeCfg fakeCfg = new DomainFakeCfg(baseDN, serverID, replicationServers); 87 public FakeReplicationDomain(DN baseDN, int serverID, argument 91 this(baseDN, serverID, replicationServers, 100, heartbeatInterval, generationId); 94 FakeReplicationDomain(DN baseDN, int serverID, argument 98 this(baseDN, serverID, replicationServers, window, heartbeatInterval, 1); 102 FakeReplicationDomain(DN baseDN, int serverID, argument 107 this(baseDN, serverID, replicationServer [all...] |
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/service/ |
H A D | FakeReplicationDomain.java | 72 int serverID, 78 super(serviceID, serverID, 100); 86 int serverID, 94 super(serviceID, serverID, 100); 70 FakeReplicationDomain( String serviceID, int serverID, Collection<String> replicationServers, int window, long heartbeatInterval, BlockingQueue<UpdateMsg> queue) argument 84 FakeReplicationDomain( String serviceID, int serverID, Collection<String> replicationServers, int window, long heartbeatInterval, String exportString, StringBuilder importString, int exportedEntryCount) argument
|
H A D | FakeStressReplicationDomain.java | 59 int serverID, 65 super(serviceID, serverID, 100); 57 FakeStressReplicationDomain( String serviceID, int serverID, Collection<String> replicationServers, int window, long heartbeatInterval, BlockingQueue<UpdateMsg> queue) argument
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/ |
H A D | EntryMsg.java | 68 * @param serverID The sender of this message. 76 int serverID, 83 super(serverID, i); 75 EntryMsg( int serverID, int i, byte[] entryBytes, int pos, int length, int msgId) argument
|
H A D | InitializeTargetMsg.java | 45 // Specifies the serverID of the server that requested this export 57 * @param serverID The serverID of the server that sends this message. 63 public InitializeTargetMsg(String baseDN, int serverID, argument 66 super(serverID, target); 146 * Get the serverID of the server that initiated the export. 150 * @return the serverID
|
/forgerock/openam-v13/openam-core/src/main/java/com/iplanet/services/ldap/ |
H A D | Server.java | 89 return serverID; 109 serverID = (String) atts.get(DSConfigMgr.NAME); 173 String serverID; field in class:Server
|
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/service/ |
H A D | FakeReplicationDomain.java | 68 private FakeReplicationDomain(DN baseDN, int serverID, argument 72 super(newConfig(baseDN, serverID, replicationServers, window, heartbeatInterval), generationId); 77 private static DomainFakeCfg newConfig(DN baseDN, int serverID, argument 80 DomainFakeCfg fakeCfg = new DomainFakeCfg(baseDN, serverID, replicationServers); 87 public FakeReplicationDomain(DN baseDN, int serverID, argument 91 this(baseDN, serverID, replicationServers, 100, heartbeatInterval, generationId); 94 FakeReplicationDomain(DN baseDN, int serverID, argument 98 this(baseDN, serverID, replicationServers, window, heartbeatInterval, 1); 102 FakeReplicationDomain(DN baseDN, int serverID, argument 107 this(baseDN, serverID, replicationServer [all...] |
/forgerock/openam/openam-core/src/main/java/com/iplanet/services/ldap/ |
H A D | Server.java | 89 return serverID; 109 serverID = (String) atts.get(DSConfigMgr.NAME); 173 String serverID; field in class:Server
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/plugin/ |
H A D | PersistentServerState.java | 124 * All operations with smaller CSN and the same serverID must be committed 469 * @param serverID The server ID. 473 public ChangeNumber getMaxChangeNumber(int serverID) argument 475 return state.getMaxChangeNumber(serverID);
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/plugin/ |
H A D | PersistentServerState.java | 124 * All operations with smaller CSN and the same serverID must be committed 469 * @param serverID The server ID. 473 public ChangeNumber getMaxChangeNumber(int serverID) argument 475 return state.getMaxChangeNumber(serverID);
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/plugin/ |
H A D | PersistentServerState.java | 124 * All operations with smaller CSN and the same serverID must be committed 469 * @param serverID The server ID. 473 public ChangeNumber getMaxChangeNumber(int serverID) argument 475 return state.getMaxChangeNumber(serverID);
|
/forgerock/openam-v13/openam-core/src/main/java/com/iplanet/dpro/session/service/cluster/ |
H A D | MultiServerClusterMonitor.java | 127 public boolean checkServerUp(String serverID) { argument 128 return ((serverID == null) || (serverID.isEmpty())) ? false : clusterStateService.checkServerUp(serverID); 137 String serverID = locateCurrentHostServer(sid); 138 if (serverID == null) { 142 return serverID; 201 for (String serverID : serverIDs) { 202 String serverURL = serverConfig.getServerFromID(serverID); 203 if ((serverID [all...] |
/forgerock/openam-v13/openam-core/src/main/java/com/sun/identity/monitoring/ |
H A D | SSOServerInfo.java | 35 String serverID; field in class:SSOServerInfo 51 serverID = asib.serverID; 65 String serverID; field in class:SSOServerInfo.SSOServerInfoBuilder 78 serverID = svrId;
|
/forgerock/openam/openam-core/src/main/java/com/iplanet/dpro/session/service/cluster/ |
H A D | MultiServerClusterMonitor.java | 118 public boolean checkServerUp(String serverID) { argument 119 return ((serverID == null) || (serverID.isEmpty())) ? false : clusterStateService.checkServerUp(serverID); 127 String serverID = locateCurrentHostServer(sid); 128 if (serverID == null) { 132 return serverID; 188 for (String serverID : serverIDs) { 189 String serverURL = serverConfig.getServerFromID(serverID); 190 if ((serverID [all...] |
/forgerock/openam/openam-core/src/main/java/com/sun/identity/monitoring/ |
H A D | SSOServerInfo.java | 35 String serverID; field in class:SSOServerInfo 51 serverID = asib.serverID; 65 String serverID; field in class:SSOServerInfo.SSOServerInfoBuilder 78 serverID = svrId;
|
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | GenerationIdTest.java | 280 private int receiveImport(ReplicationBroker broker, int serverID, argument 290 debugInfo("Broker " + serverID + " Wait for entry or done msg"); 298 debugInfo("Broker " + serverID + " receives InitializeTargetMessage "); 304 debugInfo("Broker " + serverID + " receives entry " + new String(em.getEntryBytes())); 309 debugInfo("Broker " + serverID + " receives done "); 315 debugInfo("Broker " + serverID + " receives ERROR " 321 debugInfo("Broker " + serverID + " receives and trashes " + msg); 342 * @param changelogId The serverID of the replicationServer to create.
|
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | GenerationIdTest.java | 280 private int receiveImport(ReplicationBroker broker, int serverID, argument 290 debugInfo("Broker " + serverID + " Wait for entry or done msg"); 298 debugInfo("Broker " + serverID + " receives InitializeTargetMessage "); 304 debugInfo("Broker " + serverID + " receives entry " + new String(em.getEntryBytes())); 309 debugInfo("Broker " + serverID + " receives done "); 315 debugInfo("Broker " + serverID + " receives ERROR " 321 debugInfo("Broker " + serverID + " receives and trashes " + msg); 342 * @param changelogId The serverID of the replicationServer to create.
|
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | GenerationIdTest.java | 280 private int receiveImport(ReplicationBroker broker, int serverID, argument 290 debugInfo("Broker " + serverID + " Wait for entry or done msg"); 298 debugInfo("Broker " + serverID + " receives InitializeTargetMessage "); 304 debugInfo("Broker " + serverID + " receives entry " + new String(em.getEntryBytes())); 309 debugInfo("Broker " + serverID + " receives done "); 315 debugInfo("Broker " + serverID + " receives ERROR " 321 debugInfo("Broker " + serverID + " receives and trashes " + msg); 342 * @param changelogId The serverID of the replicationServer to create.
|
/forgerock/openam-v13/openam-core/src/main/java/com/iplanet/dpro/session/service/ |
H A D | SessionServerConfig.java | 211 * Checks if server instance identified by serverID is this OpenAM server. 213 * @param serverID server id, possibly null. 214 * @return true if serverID is the same as local instance, false otherwise. 216 public boolean isLocalServer(String serverID) { argument 217 return localServerID.equals(serverID); 221 * Checks if server instance identified by serverID is the primary server for this OpenAM server's site. 228 public boolean isPrimaryServer(String serverID) { argument 229 return isSiteEnabled() ? getSiteID().equals(serverID) : localServerID.equals(serverID); 258 * Checks if server instance identified by serverID i 316 getServerFromID(String serverID) argument 375 findSecondarySiteIDs(String serverID) argument [all...] |
/forgerock/openam-v13/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...] |