Searched defs:replicaUpdatesCursor (Results 1 - 3 of 3) sorted by relevance

/forgerock/opendj2/src/server/org/opends/server/backends/
H A DChangelogBackend.java1003 ECLMultiDomainDBCursor replicaUpdatesCursor = null;
1009 replicaUpdatesCursor = new ECLMultiDomainDBCursor(domainPredicate, cursor);
1011 final boolean continueSearch = sendCookieEntriesFromCursor(entrySender, replicaUpdatesCursor);
1015 sendCookieEntriesFromCursor(entrySender, replicaUpdatesCursor);
1021 StaticUtils.close(replicaUpdatesCursor);
1026 final ECLMultiDomainDBCursor replicaUpdatesCursor) throws ChangelogException, DirectoryException
1029 while (continueSearch && replicaUpdatesCursor.next())
1031 final UpdateMsg updateMsg = replicaUpdatesCursor.getRecord();
1032 final DN domainBaseDN = replicaUpdatesCursor.getData();
1160 final AtomicReference<MultiDomainDBCursor> replicaUpdatesCursor
1025 sendCookieEntriesFromCursor(final CookieEntrySender entrySender, final ECLMultiDomainDBCursor replicaUpdatesCursor) argument
1180 sendChangeNumberEntriesFromCursors(final ChangeNumberEntrySender entrySender, final SearchParams params, DBCursor<ChangeNumberIndexRecord> cnIndexDBCursor, AtomicReference<MultiDomainDBCursor> replicaUpdatesCursor, MultiDomainServerState cookie) argument
1259 findReplicaUpdateMessage( final ChangeNumberIndexRecord cnIndexRecord, final MultiDomainDBCursor replicaUpdatesCursor) argument
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/backends/
H A DChangelogBackend.java1003 ECLMultiDomainDBCursor replicaUpdatesCursor = null;
1009 replicaUpdatesCursor = new ECLMultiDomainDBCursor(domainPredicate, cursor);
1011 final boolean continueSearch = sendCookieEntriesFromCursor(entrySender, replicaUpdatesCursor);
1015 sendCookieEntriesFromCursor(entrySender, replicaUpdatesCursor);
1021 StaticUtils.close(replicaUpdatesCursor);
1026 final ECLMultiDomainDBCursor replicaUpdatesCursor) throws ChangelogException, DirectoryException
1029 while (continueSearch && replicaUpdatesCursor.next())
1031 final UpdateMsg updateMsg = replicaUpdatesCursor.getRecord();
1032 final DN domainBaseDN = replicaUpdatesCursor.getData();
1160 final AtomicReference<MultiDomainDBCursor> replicaUpdatesCursor
1025 sendCookieEntriesFromCursor(final CookieEntrySender entrySender, final ECLMultiDomainDBCursor replicaUpdatesCursor) argument
1180 sendChangeNumberEntriesFromCursors(final ChangeNumberEntrySender entrySender, final SearchParams params, DBCursor<ChangeNumberIndexRecord> cnIndexDBCursor, AtomicReference<MultiDomainDBCursor> replicaUpdatesCursor, MultiDomainServerState cookie) argument
1259 findReplicaUpdateMessage( final ChangeNumberIndexRecord cnIndexRecord, final MultiDomainDBCursor replicaUpdatesCursor) argument
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/backends/
H A DChangelogBackend.java833 ECLMultiDomainDBCursor replicaUpdatesCursor = new ECLMultiDomainDBCursor(domainPredicate, cursor))
835 if (sendCookieEntriesFromCursor(entrySender, replicaUpdatesCursor))
838 sendCookieEntriesFromCursor(entrySender, replicaUpdatesCursor);
858 final ECLMultiDomainDBCursor replicaUpdatesCursor) throws ChangelogException, DirectoryException
861 while (continueSearch && replicaUpdatesCursor.next())
863 final UpdateMsg updateMsg = replicaUpdatesCursor.getRecord();
864 final DN domainBaseDN = replicaUpdatesCursor.getData();
981 final AtomicReference<MultiDomainDBCursor> replicaUpdatesCursor = new AtomicReference<>();
986 if (sendChangeNumberEntriesFromCursors(entrySender, cnIndexDBCursor, replicaUpdatesCursor, cookie))
989 sendChangeNumberEntriesFromCursors(entrySender, cnIndexDBCursor, replicaUpdatesCursor, cooki
857 sendCookieEntriesFromCursor(final CookieEntrySender entrySender, final ECLMultiDomainDBCursor replicaUpdatesCursor) argument
1009 sendChangeNumberEntriesFromCursors(final ChangeNumberEntrySender entrySender, DBCursor<ChangeNumberIndexRecord> cnIndexDBCursor, AtomicReference<MultiDomainDBCursor> replicaUpdatesCursor, MultiDomainServerState cookie) argument
1116 findReplicaUpdateMessage(final MultiDomainDBCursor replicaUpdatesCursor, CSN csn) argument
[all...]

Completed in 29 milliseconds