/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/file/ |
H A D | ReplicationEnvironmentTest.java | 56 private static final int SERVER_ID_1 = 1; field in class:ReplicationEnvironmentTest 99 replicaDB = environment.getOrCreateReplicaDB(domainDN, SERVER_ID_1, 1); 105 assertThat(state.getDomainToServerIds().get(domainDN)).containsOnly(SERVER_ID_1, SERVER_ID_2); 168 replicaDB = environment.getOrCreateReplicaDB(domainDN, SERVER_ID_1, 1); 171 CSN offlineCSN = new CSN(TimeThread.getTime(), 0, SERVER_ID_1); 198 replicaDB = environment.getOrCreateReplicaDB(domainDN, SERVER_ID_1, 1); 223 replicaDB = environment.getOrCreateReplicaDB(domainDN, SERVER_ID_1, 1); 226 CSNGenerator csnGenerator = new CSNGenerator(SERVER_ID_1, 100); 254 replicaDB = environment.getOrCreateReplicaDB(domainDN, SERVER_ID_1, 1); 257 environment.notifyReplicaOffline(domainDN, new CSN(TimeThread.getTime(), 0, SERVER_ID_1)); [all...] |
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/file/ |
H A D | ReplicationEnvironmentTest.java | 56 private static final int SERVER_ID_1 = 1; field in class:ReplicationEnvironmentTest 99 replicaDB = environment.getOrCreateReplicaDB(domainDN, SERVER_ID_1, 1); 105 assertThat(state.getDomainToServerIds().get(domainDN)).containsOnly(SERVER_ID_1, SERVER_ID_2); 168 replicaDB = environment.getOrCreateReplicaDB(domainDN, SERVER_ID_1, 1); 171 CSN offlineCSN = new CSN(TimeThread.getTime(), 0, SERVER_ID_1); 198 replicaDB = environment.getOrCreateReplicaDB(domainDN, SERVER_ID_1, 1); 223 replicaDB = environment.getOrCreateReplicaDB(domainDN, SERVER_ID_1, 1); 226 CSNGenerator csnGenerator = new CSNGenerator(SERVER_ID_1, 100); 254 replicaDB = environment.getOrCreateReplicaDB(domainDN, SERVER_ID_1, 1); 257 environment.notifyReplicaOffline(domainDN, new CSN(TimeThread.getTime(), 0, SERVER_ID_1)); [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/changelog/file/ |
H A D | ReplicationEnvironmentTest.java | 59 private static final int SERVER_ID_1 = 1; field in class:ReplicationEnvironmentTest 102 replicaDB = environment.getOrCreateReplicaDB(domainDN, SERVER_ID_1, 1); 108 assertThat(state.getDomainToServerIds().get(domainDN)).containsOnly(SERVER_ID_1, SERVER_ID_2); 171 replicaDB = environment.getOrCreateReplicaDB(domainDN, SERVER_ID_1, 1); 174 CSN offlineCSN = new CSN(TimeThread.getTime(), 0, SERVER_ID_1); 201 replicaDB = environment.getOrCreateReplicaDB(domainDN, SERVER_ID_1, 1); 226 replicaDB = environment.getOrCreateReplicaDB(domainDN, SERVER_ID_1, 1); 229 CSNGenerator csnGenerator = new CSNGenerator(SERVER_ID_1, 100); 257 replicaDB = environment.getOrCreateReplicaDB(domainDN, SERVER_ID_1, 1); 260 environment.notifyReplicaOffline(domainDN, new CSN(TimeThread.getTime(), 0, SERVER_ID_1)); [all...] |
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/backends/ |
H A D | ChangelogBackendTestCase.java | 125 private static final int SERVER_ID_1 = 1201; field in class:ChangelogBackendTestCase 322 final CSN[] csns = generateCSNs(3, SERVER_ID_1); 333 publishUpdateMessages(test, DN_OTEST, SERVER_ID_1, false, new ResetGenerationIdMsg(23657)); 375 CSN csn1 = new CSN(time, seqNum++, SERVER_ID_1); 378 CSN csn4 = new CSN(time, seqNum++, SERVER_ID_1); 400 CSN csn5 = new CSN(time, seqNum++, SERVER_ID_1); 498 replication1 = enableReplication(DN_OTEST, SERVER_ID_1, replicationServerPort, brokerSessionTimeout); 502 CSN csn1 = new CSN(time, 1, SERVER_ID_1); 596 CSN csn = new CSN(TimeThread.getTime(), 10, SERVER_ID_1); 968 CSN[] csns = generateCSNs(4, SERVER_ID_1); [all...] |
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/backends/ |
H A D | ChangelogBackendTestCase.java | 125 private static final int SERVER_ID_1 = 1201; field in class:ChangelogBackendTestCase 322 final CSN[] csns = generateCSNs(3, SERVER_ID_1); 333 publishUpdateMessages(test, DN_OTEST, SERVER_ID_1, false, new ResetGenerationIdMsg(23657)); 375 CSN csn1 = new CSN(time, seqNum++, SERVER_ID_1); 378 CSN csn4 = new CSN(time, seqNum++, SERVER_ID_1); 400 CSN csn5 = new CSN(time, seqNum++, SERVER_ID_1); 498 replication1 = enableReplication(DN_OTEST, SERVER_ID_1, replicationServerPort, brokerSessionTimeout); 502 CSN csn1 = new CSN(time, 1, SERVER_ID_1); 596 CSN csn = new CSN(TimeThread.getTime(), 10, SERVER_ID_1); 968 CSN[] csns = generateCSNs(4, SERVER_ID_1); [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/backends/ |
H A D | ChangelogBackendTestCase.java | 131 private static final int SERVER_ID_1 = 1201; field in class:ChangelogBackendTestCase 163 server1 = ReplicaId.of(DN_OTEST, SERVER_ID_1); 1359 assertAttributeValue(resultEntry, "replicaidentifier", SERVER_ID_1);
|