Searched refs:entrySender (Results 1 - 3 of 3) sorted by relevance
/forgerock/opendj2/src/server/org/opends/server/backends/ |
H A D | ChangelogBackend.java | 188 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 D | ChangelogBackend.java | 188 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 D | ChangelogBackend.java | 181 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 59 milliseconds