Searched defs:generationId (Results 76 - 100 of 131) sorted by relevance

123456

/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DReplicationTestCase.java175 * 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 DStateMachineTest.java325 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 DAssuredReplicationPluginTest.java267 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 DFractionalReplicationTest.java448 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 DReplicationDbEnv.java287 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 DGenerationIdTest.java624 + " 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 DReplicationTestCase.java175 * 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 DStateMachineTest.java225 ServerState state, long generationId) throws Exception
233 new DummyReplicationDomain(generationId), state, fakeCfg, security);
224 createReplicationBroker(int dsId, ServerState state, long generationId) argument
H A DAssuredReplicationPluginTest.java289 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 DAssuredReplicationPluginTest.java267 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 DFractionalReplicationTest.java448 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 DReplicationTestCase.java173 * 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 DAssuredReplicationPluginTest.java294 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 DFractionalReplicationTest.java369 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 DServerHandler.java144 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 DReplicationEnvironment.java268 * @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 DAssuredReplicationPluginTest.java267 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 DFractionalReplicationTest.java448 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 DReplicationTestCase.java173 * 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 DAssuredReplicationPluginTest.java294 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 DFractionalReplicationTest.java369 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 DServerHandler.java144 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 DReplicationEnvironment.java268 * @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 DServerHandler.java142 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 DReplicationEnvironment.java346 * @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...]

Completed in 111 milliseconds

123456