/forgerock/opendj2/src/server/org/opends/server/replication/protocol/ |
H A D | ByteArrayBuilder.java | 422 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 D | FileReplicaDBTest.java | 93 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 D | JEReplicaDBTest.java | 113 // 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 D | FileReplicaDBTest.java | 93 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 D | JEReplicaDBTest.java | 113 // 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 D | ByteArrayBuilder.java | 422 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 D | ByteArrayBuilder.java | 422 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 D | FileReplicaDBTest.java | 87 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 D | ReplicationServerTest.java | 314 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 D | ComputeBestServerTest.java | 90 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 D | ReplicationServerTest.java | 314 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 D | ComputeBestServerTest.java | 90 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 D | ReplicationServerTest.java | 311 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 D | ComputeBestServerTest.java | 85 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 D | ChangelogBackendTestCase.java | 256 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 D | ChangelogBackendTestCase.java | 256 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 D | ChangelogBackendTestCase.java | 270 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...] |