Searched defs:csns (Results 1 - 17 of 17) sorted by relevance

/forgerock/opendj2/src/server/org/opends/server/replication/protocol/
H A DByteArrayBuilder.java422 public static int csns(int nbFields) method in class:ByteArrayBuilder
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/file/
H A DFileReplicaDBTest.java93 CSN[] csns = generateCSNs(1, 0, 2);
95 { new DeleteMsg(TEST_ROOT_DN, csns[0], "uid") },
96 { new DeleteMsg(TEST_ROOT_DN, csns[1], "uid") },
124 CSN[] csns = generateCSNs(1, 0, 1);
125 replicaDB.add(new DeleteMsg(TEST_ROOT_DN, csns[0], "uid"));
128 assertFoundInOrder(replicaDB, csns[0]);
148 CSN[] csns = generateCSNs(1, 0, 5);
149 replicaDB.add(new DeleteMsg(TEST_ROOT_DN, csns[0], "uid"));
150 replicaDB.add(new DeleteMsg(TEST_ROOT_DN, csns[1], "uid"));
151 replicaDB.add(new DeleteMsg(TEST_ROOT_DN, csns[
568 assertFoundInOrder(FileReplicaDB replicaDB, CSN... csns) argument
579 assertFoundInOrder(FileReplicaDB replicaDB, final PositionStrategy positionStrategy, CSN... csns) argument
[all...]
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/je/
H A DJEReplicaDBTest.java113 // create 7 csns
116 CSN middleCsn = sevenCsns[3]; // will be between csns[1] and csns[2]
126 final CSN[] csns = usedCsns.toArray(new CSN[4]);
130 { csns, beforeCsn, EQUAL_TO_KEY, ON_MATCHING_KEY, -1, -1 },
131 { csns, csns[0], EQUAL_TO_KEY, ON_MATCHING_KEY, 0, 3 },
132 { csns, csns[1], EQUAL_TO_KEY, ON_MATCHING_KEY, 1, 3 },
133 { csns, middleCs
189 testGenerateCursor(CSN[] csns, CSN startCsn, KeyMatchingStrategy matchingStrategy, PositionStrategy positionStrategy, int startIndex, int endIndex) argument
334 advanceCursorUpTo(DBCursor<UpdateMsg> cursor, CSN[] csns, int startIndex, int endIndex) argument
352 assertThatCursorCanBeFullyRead(DBCursor<UpdateMsg> cursor, CSN[] csns, int startIndex, int endIndex) argument
359 assertThatCursorCanBeFullyReadFromStart(DBCursor<UpdateMsg> cursor, CSN[] csns, int startIndex, int endIndex) argument
535 assertFoundInOrder(JEReplicaDB replicaDB, CSN... csns) argument
546 assertFoundInOrder(JEReplicaDB replicaDB, final PositionStrategy positionStrategy, CSN... csns) argument
[all...]
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/file/
H A DFileReplicaDBTest.java93 CSN[] csns = generateCSNs(1, 0, 2);
95 { new DeleteMsg(TEST_ROOT_DN, csns[0], "uid") },
96 { new DeleteMsg(TEST_ROOT_DN, csns[1], "uid") },
124 CSN[] csns = generateCSNs(1, 0, 1);
125 replicaDB.add(new DeleteMsg(TEST_ROOT_DN, csns[0], "uid"));
128 assertFoundInOrder(replicaDB, csns[0]);
148 CSN[] csns = generateCSNs(1, 0, 5);
149 replicaDB.add(new DeleteMsg(TEST_ROOT_DN, csns[0], "uid"));
150 replicaDB.add(new DeleteMsg(TEST_ROOT_DN, csns[1], "uid"));
151 replicaDB.add(new DeleteMsg(TEST_ROOT_DN, csns[
568 assertFoundInOrder(FileReplicaDB replicaDB, CSN... csns) argument
579 assertFoundInOrder(FileReplicaDB replicaDB, final PositionStrategy positionStrategy, CSN... csns) argument
[all...]
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/je/
H A DJEReplicaDBTest.java113 // create 7 csns
116 CSN middleCsn = sevenCsns[3]; // will be between csns[1] and csns[2]
126 final CSN[] csns = usedCsns.toArray(new CSN[4]);
130 { csns, beforeCsn, EQUAL_TO_KEY, ON_MATCHING_KEY, -1, -1 },
131 { csns, csns[0], EQUAL_TO_KEY, ON_MATCHING_KEY, 0, 3 },
132 { csns, csns[1], EQUAL_TO_KEY, ON_MATCHING_KEY, 1, 3 },
133 { csns, middleCs
189 testGenerateCursor(CSN[] csns, CSN startCsn, KeyMatchingStrategy matchingStrategy, PositionStrategy positionStrategy, int startIndex, int endIndex) argument
334 advanceCursorUpTo(DBCursor<UpdateMsg> cursor, CSN[] csns, int startIndex, int endIndex) argument
352 assertThatCursorCanBeFullyRead(DBCursor<UpdateMsg> cursor, CSN[] csns, int startIndex, int endIndex) argument
359 assertThatCursorCanBeFullyReadFromStart(DBCursor<UpdateMsg> cursor, CSN[] csns, int startIndex, int endIndex) argument
535 assertFoundInOrder(JEReplicaDB replicaDB, CSN... csns) argument
546 assertFoundInOrder(JEReplicaDB replicaDB, final PositionStrategy positionStrategy, CSN... csns) argument
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/
H A DByteArrayBuilder.java422 public static int csns(int nbFields) method in class:ByteArrayBuilder
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/
H A DByteArrayBuilder.java422 public static int csns(int nbFields) method in class:ByteArrayBuilder
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/changelog/file/
H A DFileReplicaDBTest.java87 CSN[] csns = generateCSNs(1, 0, 2);
89 { new DeleteMsg(TEST_ROOT_DN, csns[0], "uid") },
90 { new DeleteMsg(TEST_ROOT_DN, csns[1], "uid") },
118 CSN[] csns = generateCSNs(1, 0, 1);
119 replicaDB.add(new DeleteMsg(TEST_ROOT_DN, csns[0], "uid"));
122 assertFoundInOrder(replicaDB, csns[0]);
142 CSN[] csns = generateCSNs(1, 0, 5);
143 replicaDB.add(new DeleteMsg(TEST_ROOT_DN, csns[0], "uid"));
144 replicaDB.add(new DeleteMsg(TEST_ROOT_DN, csns[1], "uid"));
145 replicaDB.add(new DeleteMsg(TEST_ROOT_DN, csns[
556 assertFoundInOrder(FileReplicaDB replicaDB, CSN... csns) argument
567 assertFoundInOrder(FileReplicaDB replicaDB, final PositionStrategy positionStrategy, CSN... csns) argument
[all...]
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplicationServerTest.java314 private ServerState newServerState(CSN... csns) argument
317 for (CSN csn : csns)
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/service/
H A DComputeBestServerTest.java90 private ServerState newServerState(CSN... csns) argument
93 for (CSN csn : csns)
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplicationServerTest.java314 private ServerState newServerState(CSN... csns) argument
317 for (CSN csn : csns)
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/service/
H A DComputeBestServerTest.java90 private ServerState newServerState(CSN... csns) argument
93 for (CSN csn : csns)
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/
H A DReplicationServerTest.java311 private ServerState newServerState(CSN... csns) argument
314 for (CSN csn : csns)
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/service/
H A DComputeBestServerTest.java85 private ServerState newServerState(CSN... csns) argument
88 for (CSN csn : csns)
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/backends/
H A DChangelogBackendTestCase.java256 final CSN[] csns = generateAndPublishUpdateMsgForEachOperationType(test, true);
257 final String[] cookies = buildCookiesFromCsns(csns);
265 assertDelEntry(searchEntries.get(0), test + 1, test + "uuid1", CHANGENUMBER_ZERO, csns[0], cookies[0]);
266 assertAddEntry(searchEntries.get(1), test + 2, USER1_ENTRY_UUID, CHANGENUMBER_ZERO, csns[1], cookies[1]);
267 assertModEntry(searchEntries.get(2), test + 3, test + "uuid3", CHANGENUMBER_ZERO, csns[2], cookies[2]);
269 csns[3], cookies[3]);
284 final CSN[] csns = generateAndPublishUpdateMsgForEachOperationType(test, true);
285 final String[] cookies = buildCookiesFromCsns(csns);
292 assertAddEntry(searchEntries.get(0), test + 2, USER1_ENTRY_UUID, CHANGENUMBER_ZERO, csns[1], cookies[1]);
293 assertModEntry(searchEntries.get(1), test + 3, test + "uuid3", CHANGENUMBER_ZERO, csns[
939 assertEntriesContainsCSNsAndReadLastCookie(String test, List<SearchResultEntry> entries, LDIFWriter ldifWriter, CSN... csns) argument
1029 buildCookiesFromCsns(CSN[] csns) argument
1039 searchChangesForEachOperationTypeUsingDraftMode(long firstChangeNumber, CSN[] csns, String testName) argument
1344 assertEntriesForEachOperationType(List<SearchResultEntry> entries, long firstChangeNumber, String testName, String entryUUID, CSN... csns) argument
[all...]
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/backends/
H A DChangelogBackendTestCase.java256 final CSN[] csns = generateAndPublishUpdateMsgForEachOperationType(test, true);
257 final String[] cookies = buildCookiesFromCsns(csns);
265 assertDelEntry(searchEntries.get(0), test + 1, test + "uuid1", CHANGENUMBER_ZERO, csns[0], cookies[0]);
266 assertAddEntry(searchEntries.get(1), test + 2, USER1_ENTRY_UUID, CHANGENUMBER_ZERO, csns[1], cookies[1]);
267 assertModEntry(searchEntries.get(2), test + 3, test + "uuid3", CHANGENUMBER_ZERO, csns[2], cookies[2]);
269 csns[3], cookies[3]);
284 final CSN[] csns = generateAndPublishUpdateMsgForEachOperationType(test, true);
285 final String[] cookies = buildCookiesFromCsns(csns);
292 assertAddEntry(searchEntries.get(0), test + 2, USER1_ENTRY_UUID, CHANGENUMBER_ZERO, csns[1], cookies[1]);
293 assertModEntry(searchEntries.get(1), test + 3, test + "uuid3", CHANGENUMBER_ZERO, csns[
939 assertEntriesContainsCSNsAndReadLastCookie(String test, List<SearchResultEntry> entries, LDIFWriter ldifWriter, CSN... csns) argument
1029 buildCookiesFromCsns(CSN[] csns) argument
1039 searchChangesForEachOperationTypeUsingDraftMode(long firstChangeNumber, CSN[] csns, String testName) argument
1344 assertEntriesForEachOperationType(List<SearchResultEntry> entries, long firstChangeNumber, String testName, String entryUUID, CSN... csns) argument
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/backends/
H A DChangelogBackendTestCase.java270 final CSN[] csns = generateAndPublishUpdateMsgForEachOperationType(test, true);
278 assertDelEntry(searchEntries.get(0), test + 1, test + "uuid1", CHANGENUMBER_ZERO, csns[0]);
279 assertAddEntry(searchEntries.get(1), test + 2, USER1_ENTRY_UUID, CHANGENUMBER_ZERO, csns[1]);
280 assertModEntry(searchEntries.get(2), test + 3, test + "uuid3", CHANGENUMBER_ZERO, csns[2]);
281 assertModDNEntry(searchEntries.get(3), test + 4, test + "new4", test + "uuid4", CHANGENUMBER_ZERO, csns[3]);
282 assertResultsContainCookieControl(searchOp, newArrayList(buildCookiesFromCsns(csns)));
296 final CSN[] csns = generateAndPublishUpdateMsgForEachOperationType(test, true);
297 final String[] cookies = buildCookiesFromCsns(csns);
304 assertAddEntry(searchEntries.get(0), test + 2, USER1_ENTRY_UUID, CHANGENUMBER_ZERO, csns[1]);
305 assertModEntry(searchEntries.get(1), test + 3, test + "uuid3", CHANGENUMBER_ZERO, csns[
955 assertEntriesContainsCSNsAndReadLastCookie(String test, List<SearchResultEntry> entries, LDIFWriter ldifWriter, CSN... csns) argument
1033 buildCookiesFromCsns(CSN[] csns) argument
1043 searchChangesForEachOperationTypeUsingChangeNumberMode(long firstChangeNumber, CSN[] csns, String testName) argument
1370 assertEntriesForEachOperationType(List<SearchResultEntry> entries, long firstChangeNumber, String testName, String entryUUID, CSN... csns) argument
[all...]

Completed in 49 milliseconds