/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | ReplicationTestCase.java | 175 * Retrieves the domain associated to the baseDn, and the value of the generationId 177 * value of the generationId corresponding to test backend with its default 180 * @param baseDn The baseDn for which we want the generationId 181 * @return The value of the generationId. 185 // This is the value of the generationId computed by the server when the 213 * providing the generationId. 218 long generationId) 222 port, timeout, emptyOldChanges, generationId, null); 227 * providing the generationId. 232 long generationId, ReplicationDomai 215 openReplicationSession( final DN baseDn, int serverId, int window_size, int port, int timeout, boolean emptyOldChanges, long generationId) argument 229 openReplicationSession( final DN baseDn, int serverId, int window_size, int port, int timeout, boolean emptyOldChanges, long generationId, ReplicationDomain replicationDomain) argument 315 openReplicationSession( final DN baseDn, int serverId, int window_size, int port, int timeout, ServerState state, long generationId) argument [all...] |
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | StateMachineTest.java | 325 ServerState state, long generationId, int window) 329 state, EXAMPLE_DN, dsId, 100, generationId, 0, 344 ServerState state, long generationId) 347 return createReplicationBroker(dsId, state, generationId, 100); 324 createReplicationBroker(int dsId, ServerState state, long generationId, int window) argument 343 createReplicationBroker(int dsId, ServerState state, long generationId) argument
|
H A D | AssuredReplicationPluginTest.java | 267 private long generationId = -1L; field in class:AssuredReplicationPluginTest.FakeReplicationServer 438 generationId = serverStartMsg.getGenerationId(); 446 generationId, sslEncryption, 483 RSInfo rsInfo = new RSInfo(serverId, "localhost:" + port, generationId, groupId, 1);
|
H A D | FractionalReplicationTest.java | 448 private void createFakeReplicationDomain(boolean firstBackend, long generationId) argument 455 (firstBackend ? TEST_ROOT_DN_STRING : TEST2_ROOT_DN_STRING), DS2_ID, replicationServers, 100, 1000, generationId); 686 long generationId) throws ConfigException 689 generationID = generationId; 1162 long generationId = readGenIdFromSuffixRootEntry(TEST2_ROOT_DN_STRING); 1163 assertTrue(generationId != 0L); 1164 createFakeReplicationDomain(false, generationId); 1176 "ds-sync-generation-id: " + generationId + "\n"; 1406 long generationId = readGenIdFromSuffixRootEntry(TEST2_ROOT_DN_STRING); 1407 assertTrue(generationId ! 680 FakeReplicationDomain( String serviceID, int serverID, Collection<String> replicationServers, int window, long heartbeatInterval, long generationId) argument [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/je/ |
H A D | ReplicationDbEnv.java | 287 final long generationId = toLong(str[1]); 291 debug("has read generationId: baseDN=" + baseDN + " generationId=" 292 + generationId); 294 result.setDomainGenerationId(baseDN, generationId); 434 * @param generationId 435 * The generationId associated to this domain. 440 public Database getOrAddReplicationDB(int serverId, DN baseDN, long generationId) argument 446 + generationId + ")"); 462 putInChangelogStateDBIfNotExist(toGenIdEntry(baseDN, generationId)); 499 toGenIdEntry(DN baseDN, long generationId) argument [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/ |
H A D | GenerationIdTest.java | 624 + " Test that the generationId is written in the DB in the root entry on DS1"); 628 debugInfo(testCase + " Test that the generationId is set on RS1"); 689 "generationId is expected to have the same value" + 1065 * Check : nothing is broken - no generationId generated 1108 long generationId = 1000+i; 1109 broker = openReplicationSession(server2ID, replServer1, generationId); 1113 assertEquals(rsGenId, generationId); 1126 protected ReplicationBroker openReplicationSession(int serverId, ReplicationServer replServer, long generationId) argument 1129 return openReplicationSession(baseDN, serverId, 100, replServer.getReplicationPort(), 1000, generationId);
|
H A D | ReplicationTestCase.java | 175 * Retrieves the domain associated to the baseDN, and the value of the generationId 177 * value of the generationId corresponding to test backend with its default 180 * @param baseDN The baseDN for which we want the generationId 181 * @return The value of the generationId. 193 // This is the value of the generationId computed by the server when the 211 /** Open a replicationServer session to the local ReplicationServer providing the generationId. */ 214 long generationId) throws Exception 218 return openReplicationSession(config, port, timeout, generationId); 222 int port, int timeout, long generationId) throws Exception 225 new DummyReplicationDomain(generationId), ne 212 openReplicationSession(final DN baseDN, int serverId, int windowSize, int port, int timeout, long generationId) argument 221 openReplicationSession(ReplicationDomainCfg config, int port, int timeout, long generationId) argument [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/ |
H A D | StateMachineTest.java | 225 ServerState state, long generationId) throws Exception 233 new DummyReplicationDomain(generationId), state, fakeCfg, security); 224 createReplicationBroker(int dsId, ServerState state, long generationId) argument
|
H A D | AssuredReplicationPluginTest.java | 289 private long generationId = -1L; field in class:AssuredReplicationPluginTest.FakeReplicationServer 437 generationId = serverStartMsg.getGenerationId(); 444 serverURL, baseDN, windowSize, serverState, generationId, sslEncryption, 474 RSInfo rsInfo = new RSInfo(serverId, "localhost:" + port, generationId, groupId, 1);
|
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | AssuredReplicationPluginTest.java | 267 private long generationId = -1L; field in class:AssuredReplicationPluginTest.FakeReplicationServer 438 generationId = serverStartMsg.getGenerationId(); 446 generationId, sslEncryption, 483 RSInfo rsInfo = new RSInfo(serverId, "localhost:" + port, generationId, groupId, 1);
|
H A D | FractionalReplicationTest.java | 448 private void createFakeReplicationDomain(boolean firstBackend, long generationId) argument 455 (firstBackend ? TEST_ROOT_DN_STRING : TEST2_ROOT_DN_STRING), DS2_ID, replicationServers, 100, 1000, generationId); 686 long generationId) throws ConfigException 689 generationID = generationId; 1162 long generationId = readGenIdFromSuffixRootEntry(TEST2_ROOT_DN_STRING); 1163 assertTrue(generationId != 0L); 1164 createFakeReplicationDomain(false, generationId); 1176 "ds-sync-generation-id: " + generationId + "\n"; 1406 long generationId = readGenIdFromSuffixRootEntry(TEST2_ROOT_DN_STRING); 1407 assertTrue(generationId ! 680 FakeReplicationDomain( String serviceID, int serverID, Collection<String> replicationServers, int window, long heartbeatInterval, long generationId) argument [all...] |
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | ReplicationTestCase.java | 173 * Retrieves the domain associated to the baseDN, and the value of the generationId 175 * value of the generationId corresponding to test backend with its default 178 * @param baseDN The baseDN for which we want the generationId 179 * @return The value of the generationId. 183 // This is the value of the generationId computed by the server when the 211 * providing the generationId. 215 long generationId) throws Exception 219 return openReplicationSession(config, port, timeout, generationId); 223 int port, int timeout, long generationId) throws Exception 226 new DummyReplicationDomain(generationId), ne 213 openReplicationSession(final DN baseDN, int serverId, int windowSize, int port, int timeout, long generationId) argument 222 openReplicationSession(ReplicationDomainCfg config, int port, int timeout, long generationId) argument [all...] |
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | AssuredReplicationPluginTest.java | 294 private long generationId = -1L; field in class:AssuredReplicationPluginTest.FakeReplicationServer 465 generationId = serverStartMsg.getGenerationId(); 472 serverURL, baseDN, windowSize, serverState, generationId, sslEncryption, 503 RSInfo rsInfo = new RSInfo(serverId, "localhost:" + port, generationId, groupId, 1);
|
H A D | FractionalReplicationTest.java | 369 long generationId) throws Exception 374 replicationDomain = new FakeReplicationDomain(baseDN, DS2_ID, replicationServers, 1000, generationId); 894 long generationId = readGenIdFromSuffixRootEntry(TEST2_ROOT_DN_STRING); 895 assertTrue(generationId != 0L); 896 createFakeReplicationDomain(false, generationId); 908 "ds-sync-generation-id: " + generationId + "\n"; 1132 long generationId = readGenIdFromSuffixRootEntry(TEST2_ROOT_DN_STRING); 1133 assertTrue(generationId != 0L); 1134 createFakeReplicationDomain(false, generationId); 1146 "ds-sync-generation-id: " + generationId 368 createFakeReplicationDomain(boolean firstBackend, long generationId) argument [all...] |
/forgerock/opendj2/src/server/org/opends/server/replication/server/ |
H A D | ServerHandler.java | 144 protected long generationId = -1; field in class:ServerHandler 475 * Returns the value of generationId for that handler. 476 * @return The value of the generationId. 480 return generationId; 552 attributes.add(Attributes.create("generation-id", String.valueOf(generationId))); 899 * @param generationId The new generation ID 902 public void setGenerationId(long generationId) argument 904 this.generationId = generationId; 1010 return new RSInfo(serverId, serverURL, generationId, groupI [all...] |
/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/file/ |
H A D | ReplicationEnvironment.java | 268 * @param generationId 269 * The generationId associated to this domain. 274 Log<CSN, UpdateMsg> getOrCreateReplicaDB(final DN domainDN, final int serverId, final long generationId) argument 279 debug("ReplicationEnvironment.getOrCreateReplicaDB(" + domainDN + ", " + serverId + ", " + generationId + ")"); 299 final File generationIdPath = getGenerationIdPath(domainId, generationId); 301 changelogState.setDomainGenerationId(domainDN, generationId); 309 ERR_CHANGELOG_UNABLE_TO_CREATE_REPLICA_DB.get(domainDN.toString(), serverId, generationId), e); 388 * Reset the generationId to the default value used when there is no 562 final String generationId = retrieveGenerationId(domainDirectory); 563 if (generationId ! 742 getGenerationIdPath(final String domainId, final long generationId) argument [all...] |
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | AssuredReplicationPluginTest.java | 267 private long generationId = -1L; field in class:AssuredReplicationPluginTest.FakeReplicationServer 438 generationId = serverStartMsg.getGenerationId(); 446 generationId, sslEncryption, 483 RSInfo rsInfo = new RSInfo(serverId, "localhost:" + port, generationId, groupId, 1);
|
H A D | FractionalReplicationTest.java | 448 private void createFakeReplicationDomain(boolean firstBackend, long generationId) argument 455 (firstBackend ? TEST_ROOT_DN_STRING : TEST2_ROOT_DN_STRING), DS2_ID, replicationServers, 100, 1000, generationId); 686 long generationId) throws ConfigException 689 generationID = generationId; 1162 long generationId = readGenIdFromSuffixRootEntry(TEST2_ROOT_DN_STRING); 1163 assertTrue(generationId != 0L); 1164 createFakeReplicationDomain(false, generationId); 1176 "ds-sync-generation-id: " + generationId + "\n"; 1406 long generationId = readGenIdFromSuffixRootEntry(TEST2_ROOT_DN_STRING); 1407 assertTrue(generationId ! 680 FakeReplicationDomain( String serviceID, int serverID, Collection<String> replicationServers, int window, long heartbeatInterval, long generationId) argument [all...] |
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | ReplicationTestCase.java | 173 * Retrieves the domain associated to the baseDN, and the value of the generationId 175 * value of the generationId corresponding to test backend with its default 178 * @param baseDN The baseDN for which we want the generationId 179 * @return The value of the generationId. 183 // This is the value of the generationId computed by the server when the 211 * providing the generationId. 215 long generationId) throws Exception 219 return openReplicationSession(config, port, timeout, generationId); 223 int port, int timeout, long generationId) throws Exception 226 new DummyReplicationDomain(generationId), ne 213 openReplicationSession(final DN baseDN, int serverId, int windowSize, int port, int timeout, long generationId) argument 222 openReplicationSession(ReplicationDomainCfg config, int port, int timeout, long generationId) argument [all...] |
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | AssuredReplicationPluginTest.java | 294 private long generationId = -1L; field in class:AssuredReplicationPluginTest.FakeReplicationServer 465 generationId = serverStartMsg.getGenerationId(); 472 serverURL, baseDN, windowSize, serverState, generationId, sslEncryption, 503 RSInfo rsInfo = new RSInfo(serverId, "localhost:" + port, generationId, groupId, 1);
|
H A D | FractionalReplicationTest.java | 369 long generationId) throws Exception 374 replicationDomain = new FakeReplicationDomain(baseDN, DS2_ID, replicationServers, 1000, generationId); 894 long generationId = readGenIdFromSuffixRootEntry(TEST2_ROOT_DN_STRING); 895 assertTrue(generationId != 0L); 896 createFakeReplicationDomain(false, generationId); 908 "ds-sync-generation-id: " + generationId + "\n"; 1132 long generationId = readGenIdFromSuffixRootEntry(TEST2_ROOT_DN_STRING); 1133 assertTrue(generationId != 0L); 1134 createFakeReplicationDomain(false, generationId); 1146 "ds-sync-generation-id: " + generationId 368 createFakeReplicationDomain(boolean firstBackend, long generationId) argument [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/ |
H A D | ServerHandler.java | 144 protected long generationId = -1; field in class:ServerHandler 475 * Returns the value of generationId for that handler. 476 * @return The value of the generationId. 480 return generationId; 552 attributes.add(Attributes.create("generation-id", String.valueOf(generationId))); 899 * @param generationId The new generation ID 902 public void setGenerationId(long generationId) argument 904 this.generationId = generationId; 1010 return new RSInfo(serverId, serverURL, generationId, groupI [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/file/ |
H A D | ReplicationEnvironment.java | 268 * @param generationId 269 * The generationId associated to this domain. 274 Log<CSN, UpdateMsg> getOrCreateReplicaDB(final DN domainDN, final int serverId, final long generationId) argument 279 debug("ReplicationEnvironment.getOrCreateReplicaDB(" + domainDN + ", " + serverId + ", " + generationId + ")"); 299 final File generationIdPath = getGenerationIdPath(domainId, generationId); 301 changelogState.setDomainGenerationId(domainDN, generationId); 309 ERR_CHANGELOG_UNABLE_TO_CREATE_REPLICA_DB.get(domainDN.toString(), serverId, generationId), e); 388 * Reset the generationId to the default value used when there is no 562 final String generationId = retrieveGenerationId(domainDirectory); 563 if (generationId ! 742 getGenerationIdPath(final String domainId, final long generationId) argument [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/ |
H A D | ServerHandler.java | 142 protected long generationId = -1; field in class:ServerHandler 459 * Returns the value of generationId for that handler. 460 * @return The value of the generationId. 464 return generationId; 536 attributes.add(Attributes.create("generation-id", String.valueOf(generationId))); 862 * @param generationId The new generation ID 865 public void setGenerationId(long generationId) argument 867 this.generationId = generationId; 987 return new RSInfo(serverId, serverURL, generationId, groupI [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/ |
H A D | ReplicationEnvironment.java | 346 * @param generationId 347 * The generationId associated to this domain. 352 Log<CSN, UpdateMsg> getOrCreateReplicaDB(final DN domainDN, final int serverId, final long generationId) argument 357 logger.trace("ReplicationEnvironment.getOrCreateReplicaDB(%s, %s, %s)", domainDN, serverId, generationId); 377 final File generationIdPath = getGenerationIdPath(domainId, generationId); 379 changelogState.setDomainGenerationId(domainDN, generationId); 388 ERR_CHANGELOG_UNABLE_TO_CREATE_REPLICA_DB.get(domainDN.toString(), serverId, generationId), e); 470 * Reset the generationId to the default value used when there is no 659 final String generationId = retrieveGenerationId(domainDirectory); 660 if (generationId ! 876 getGenerationIdPath(final String domainId, final long generationId) argument [all...] |