Searched refs:cnIndexRecord (Results 1 - 6 of 6) sorted by relevance

/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/file/
H A DFileChangeNumberIndexDB.java331 final ChangeNumberIndexRecord cnIndexRecord = record.getValue();
334 .append(cnIndexRecord.getBaseDN().toString())
336 .append(cnIndexRecord.getCSN().toByteString()).toByteString();
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/file/
H A DFileChangeNumberIndexDB.java331 final ChangeNumberIndexRecord cnIndexRecord = record.getValue();
334 .append(cnIndexRecord.getBaseDN().toString())
336 .append(cnIndexRecord.getCSN().toByteString()).toByteString();
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/backends/
H A DChangelogBackend.java1017 final ChangeNumberIndexRecord cnIndexRecord = cnIndexDBCursor.getRecord();
1020 replicaUpdatesCursor.set(initializeReplicaUpdatesCursor(cnIndexRecord));
1021 initializeCookieForChangeNumberMode(cookie, cnIndexRecord);
1025 cookie.update(cnIndexRecord.getBaseDN(), cnIndexRecord.getCSN());
1027 continueSearch = entrySender.changeNumberIsInRange(cnIndexRecord.getChangeNumber());
1030 final UpdateMsg updateMsg = findReplicaUpdateMessage(replicaUpdatesCursor.get(), cnIndexRecord.getCSN());
1033 continueSearch = entrySender.initialSearchSendEntry(cnIndexRecord, updateMsg, cookie);
1043 MultiDomainServerState cookie, final ChangeNumberIndexRecord cnIndexRecord) throws ChangelogException
1047 CursorOptions options = new CursorOptions(LESS_THAN_OR_EQUAL_TO_KEY, ON_MATCHING_KEY, cnIndexRecord
1042 initializeCookieForChangeNumberMode( MultiDomainServerState cookie, final ChangeNumberIndexRecord cnIndexRecord) argument
1070 updateCookieToMediumConsistencyPoint( MultiDomainServerState cookie, ECLMultiDomainDBCursor cursor, ChangeNumberIndexRecord cnIndexRecord) argument
1090 initializeReplicaUpdatesCursor( final ChangeNumberIndexRecord cnIndexRecord) argument
1656 initialSearchSendEntry(ChangeNumberIndexRecord cnIndexRecord, UpdateMsg updateMsg, MultiDomainServerState cookie) argument
[all...]
/forgerock/opendj2/src/server/org/opends/server/backends/
H A DChangelogBackend.java1189 final ChangeNumberIndexRecord cnIndexRecord = cnIndexDBCursor.getRecord();
1192 replicaUpdatesCursor.set(initializeReplicaUpdatesCursor(cnIndexRecord));
1193 initializeCookieForChangeNumberMode(cookie, cnIndexRecord);
1197 cookie.update(cnIndexRecord.getBaseDN(), cnIndexRecord.getCSN());
1199 continueSearch = params.changeNumberIsInRange(cnIndexRecord.getChangeNumber());
1202 final UpdateMsg updateMsg = findReplicaUpdateMessage(cnIndexRecord, replicaUpdatesCursor.get());
1205 continueSearch = entrySender.initialSearchSendEntry(cnIndexRecord, updateMsg, cookie);
1215 MultiDomainServerState cookie, final ChangeNumberIndexRecord cnIndexRecord) throws ChangelogException
1220 cookie.update(cnIndexRecord
1214 initializeCookieForChangeNumberMode( MultiDomainServerState cookie, final ChangeNumberIndexRecord cnIndexRecord) argument
1234 initializeReplicaUpdatesCursor( final ChangeNumberIndexRecord cnIndexRecord) argument
1259 findReplicaUpdateMessage( final ChangeNumberIndexRecord cnIndexRecord, final MultiDomainDBCursor replicaUpdatesCursor) argument
1789 initialSearchSendEntry(ChangeNumberIndexRecord cnIndexRecord, UpdateMsg updateMsg, MultiDomainServerState cookie) argument
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/backends/
H A DChangelogBackend.java1189 final ChangeNumberIndexRecord cnIndexRecord = cnIndexDBCursor.getRecord();
1192 replicaUpdatesCursor.set(initializeReplicaUpdatesCursor(cnIndexRecord));
1193 initializeCookieForChangeNumberMode(cookie, cnIndexRecord);
1197 cookie.update(cnIndexRecord.getBaseDN(), cnIndexRecord.getCSN());
1199 continueSearch = params.changeNumberIsInRange(cnIndexRecord.getChangeNumber());
1202 final UpdateMsg updateMsg = findReplicaUpdateMessage(cnIndexRecord, replicaUpdatesCursor.get());
1205 continueSearch = entrySender.initialSearchSendEntry(cnIndexRecord, updateMsg, cookie);
1215 MultiDomainServerState cookie, final ChangeNumberIndexRecord cnIndexRecord) throws ChangelogException
1220 cookie.update(cnIndexRecord
1214 initializeCookieForChangeNumberMode( MultiDomainServerState cookie, final ChangeNumberIndexRecord cnIndexRecord) argument
1234 initializeReplicaUpdatesCursor( final ChangeNumberIndexRecord cnIndexRecord) argument
1259 findReplicaUpdateMessage( final ChangeNumberIndexRecord cnIndexRecord, final MultiDomainDBCursor replicaUpdatesCursor) argument
1789 initialSearchSendEntry(ChangeNumberIndexRecord cnIndexRecord, UpdateMsg updateMsg, MultiDomainServerState cookie) argument
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/
H A DFileChangeNumberIndexDB.java411 final ChangeNumberIndexRecord cnIndexRecord = record.getValue();
414 .appendUtf8(cnIndexRecord.getBaseDN().toString())
416 .appendBytes(cnIndexRecord.getCSN().toByteString())

Completed in 73 milliseconds