Searched defs:replicaUpdatesCursor (Results 1 - 3 of 3) sorted by relevance
/forgerock/opendj2/src/server/org/opends/server/backends/ |
H A D | ChangelogBackend.java | 1003 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 D | ChangelogBackend.java | 1003 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 D | ChangelogBackend.java | 833 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