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

/forgerock/opendj2/src/server/org/opends/server/backends/
H A DChangelogBackend.java188 private static final String ENTRY_SENDER_ATTACHMENT = OID_ECL_COOKIE_EXCHANGE_CONTROL + ".entrySender";
449 final CookieEntrySender entrySender = searchOp.getAttachment(ENTRY_SENDER_ATTACHMENT);
450 entrySender.persistentSearchSendEntry(baseDN, updateMsg);
496 final ChangeNumberEntrySender entrySender = searchOp.getAttachment(ENTRY_SENDER_ATTACHMENT);
497 entrySender.persistentSearchSendEntry(changeNumber, changeNumberEntry);
987 final CookieEntrySender entrySender;
990 entrySender = searchOperation.getAttachment(ENTRY_SENDER_ATTACHMENT);
994 entrySender = new CookieEntrySender(searchOperation, SearchPhase.INITIAL);
996 entrySender.setCookie(searchParams.cookie);
1011 final boolean continueSearch = sendCookieEntriesFromCursor(entrySender, replicaUpdatesCurso
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
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/backends/
H A DChangelogBackend.java188 private static final String ENTRY_SENDER_ATTACHMENT = OID_ECL_COOKIE_EXCHANGE_CONTROL + ".entrySender";
449 final CookieEntrySender entrySender = searchOp.getAttachment(ENTRY_SENDER_ATTACHMENT);
450 entrySender.persistentSearchSendEntry(baseDN, updateMsg);
496 final ChangeNumberEntrySender entrySender = searchOp.getAttachment(ENTRY_SENDER_ATTACHMENT);
497 entrySender.persistentSearchSendEntry(changeNumber, changeNumberEntry);
987 final CookieEntrySender entrySender;
990 entrySender = searchOperation.getAttachment(ENTRY_SENDER_ATTACHMENT);
994 entrySender = new CookieEntrySender(searchOperation, SearchPhase.INITIAL);
996 entrySender.setCookie(searchParams.cookie);
1011 final boolean continueSearch = sendCookieEntriesFromCursor(entrySender, replicaUpdatesCurso
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
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/backends/
H A DChangelogBackend.java181 private static final String ENTRY_SENDER_ATTACHMENT = OID_ECL_COOKIE_EXCHANGE_CONTROL + ".entrySender";
410 final CookieEntrySender entrySender = searchOp.getAttachment(ENTRY_SENDER_ATTACHMENT);
411 entrySender.persistentSearchSendEntry(baseDN, updateMsg);
458 final ChangeNumberEntrySender entrySender = searchOp.getAttachment(ENTRY_SENDER_ATTACHMENT);
459 entrySender.persistentSearchSendEntry(changeNumber, changeNumberEntry);
821 private void initialSearchFromCookie(final CookieEntrySender entrySender) argument
824 if (!sendBaseChangelogEntry(entrySender.searchOp))
832 replicationDomainDB.getCursorFrom(entrySender.cookie, options, entrySender.excludedBaseDNs);
835 if (sendCookieEntriesFromCursor(entrySender, replicaUpdatesCurso
857 sendCookieEntriesFromCursor(final CookieEntrySender entrySender, final ECLMultiDomainDBCursor replicaUpdatesCursor) argument
973 initialSearchFromChangeNumber(final ChangeNumberEntrySender entrySender) argument
1009 sendChangeNumberEntriesFromCursors(final ChangeNumberEntrySender entrySender, DBCursor<ChangeNumberIndexRecord> cnIndexDBCursor, AtomicReference<MultiDomainDBCursor> replicaUpdatesCursor, MultiDomainServerState cookie) argument
[all...]

Completed in 38 milliseconds