Searched defs:cursors (Results 1 - 7 of 7) sorted by relevance
/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/je/ |
H A D | CompositeDBCursor.java | 42 * 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 D | CompositeDBCursor.java | 42 * 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 D | CompositeDBCursor.java | 44 * 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 D | Log.java | 166 * 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 D | Log.java | 167 * 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 D | Log.java | 167 * 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 D | OnDiskMergeImporter.java | 2074 /** 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