Searched defs:cursors (Results 1 - 7 of 7) sorted by relevance

/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/je/
H A DCompositeDBCursor.java42 * cursors.
62 * These cursors are considered exhausted because they had no new changes the
63 * last time {@link DBCursor#next()} was called on them. Exhausted cursors
69 * The cursors are sorted based on the current change of each cursor to
70 * consider the next change across all available cursors.
72 * New cursors for this Map must be created from the same thread that will
77 private final TreeMap<DBCursor<UpdateMsg>, T> cursors = field in class:CompositeDBCursor
101 // To keep consistent the cursors' order in the SortedSet, it is necessary
104 state != UNINITIALIZED ? cursors.pollFirstEntry() : null;
113 return !cursors
143 removeCursor(Map<DBCursor<UpdateMsg>, T> cursors, T dataToFind) argument
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/je/
H A DCompositeDBCursor.java42 * cursors.
62 * These cursors are considered exhausted because they had no new changes the
63 * last time {@link DBCursor#next()} was called on them. Exhausted cursors
69 * The cursors are sorted based on the current change of each cursor to
70 * consider the next change across all available cursors.
72 * New cursors for this Map must be created from the same thread that will
77 private final TreeMap<DBCursor<UpdateMsg>, T> cursors = field in class:CompositeDBCursor
101 // To keep consistent the cursors' order in the SortedSet, it is necessary
104 state != UNINITIALIZED ? cursors.pollFirstEntry() : null;
113 return !cursors
143 removeCursor(Map<DBCursor<UpdateMsg>, T> cursors, T dataToFind) argument
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/
H A DCompositeDBCursor.java44 * cursors.
60 * These cursors are considered exhausted because they had no new changes the
61 * last time {@link DBCursor#next()} was called on them. Exhausted cursors
66 * The cursors are sorted based on the current change of each cursor to
67 * consider the next change across all available cursors.
69 * New cursors for this Map must be created from the same thread that will
74 private final TreeMap<DBCursor<UpdateMsg>, T> cursors = new TreeMap<>( field in class:CompositeDBCursor
110 // To keep consistent the cursors' order in the SortedSet, it is necessary
113 state != UNINITIALIZED ? cursors.pollFirstEntry() : null;
122 return !cursors
151 removeCursor(Map<DBCursor<UpdateMsg>, T> cursors, T dataToFind) argument
[all...]
H A DLog.java166 * The list of non-empty cursors opened on this log. Opened cursors may have
781 * Abort all cursors opened on the provided log file.
799 * All cursors open on the log are aborted.
802 * If cursors are opened on this log, or if a problem occurs during
816 // All open cursors are aborted, which means the change number indexer thread
986 * All cursors opened on this log are temporarily disabled (closing underlying resources)
992 // Temporarily disable cursors opened on head, saving their state
1003 // Re-enable cursors previously opened on head, with the saved state
1068 * Update the cursors tha
1071 updateOpenedCursorsOnHeadAfterRotation(List<Pair<AbortableLogCursor<K, V>, CursorState<K, V>>> cursors) argument
[all...]
/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/file/
H A DLog.java167 * The list of non-empty cursors opened on this log. Opened cursors may have
638 * If cursors are opened on this log, or if a problem occurs during
652 // Allow opened cursors at this point, but turn them into empty cursors.
753 * All cursors opened on this log are temporarily disabled (closing underlying resources)
758 // Temporarily disable cursors opened on head, saving their state
769 // Re-enable cursors previously opened on head, with the saved state
829 /** Update the cursors that were pointing to head after a rotation of the head log file. */
830 private void updateOpenedCursorsOnHeadAfterRotation(List<Pair<LogCursor<K, V>, CursorState<K, V>>> cursors) argument
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/file/
H A DLog.java167 * The list of non-empty cursors opened on this log. Opened cursors may have
638 * If cursors are opened on this log, or if a problem occurs during
652 // Allow opened cursors at this point, but turn them into empty cursors.
753 * All cursors opened on this log are temporarily disabled (closing underlying resources)
758 // Temporarily disable cursors opened on head, saving their state
769 // Re-enable cursors previously opened on head, with the saved state
829 /** Update the cursors that were pointing to head after a rotation of the head log file. */
830 private void updateOpenedCursorsOnHeadAfterRotation(List<Pair<LogCursor<K, V>, CursorState<K, V>>> cursors) argument
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/backends/pluggable/
H A DOnDiskMergeImporter.java2074 /** Provides a globally sorted cursor from multiple sorted cursors. */
2077 /** Contains the non empty and sorted cursors ordered in regards of their current key. */
2085 CompositeCursor(String metricName, Collection<MeteredCursor<K, V>> cursors) argument
2094 // Never return 0. Otherwise both cursors are considered equal and only one of them is kept by this set
2100 for (MeteredCursor<K, V> cursor : cursors)

Completed in 37 milliseconds