| /forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/file/ |
| H A D | Log.java | 170 private final List<LogCursor<K, V>> openCursors = new CopyOnWriteArrayList<LogCursor<K, V>>();
438 LogCursor<K, V> cursor = null;
446 cursor = new LogCursor<K, V>(this);
501 LogCursor<K, V> cursor = null;
509 cursor = new LogCursor<K, V>(this);
759 final List<Pair<LogCursor<K, V>, CursorState<K, V>>> cursorsOnHead = disableOpenedCursorsOnHead();
830 private void updateOpenedCursorsOnHeadAfterRotation(List<Pair<LogCursor<K, V>, CursorState<K, V>>> cursors)
833 for (Pair<LogCursor<K, V>, CursorState<K, V>> pair : cursors)
842 final LogCursor<
895 registerCursor(final LogCursor<K, V> cursor) argument
900 unregisterCursor(final LogCursor<K, V> cursor) argument
970 private static class LogCursor<K extends Comparable<K>, V> implements RepositionableCursor<K, V> class in class:Log
986 private LogCursor(final Log<K, V> log) throws ChangelogException method in class:Log.LogCursor
[all...] |
| /forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/file/ |
| H A D | Log.java | 170 private final List<LogCursor<K, V>> openCursors = new CopyOnWriteArrayList<LogCursor<K, V>>();
438 LogCursor<K, V> cursor = null;
446 cursor = new LogCursor<K, V>(this);
501 LogCursor<K, V> cursor = null;
509 cursor = new LogCursor<K, V>(this);
759 final List<Pair<LogCursor<K, V>, CursorState<K, V>>> cursorsOnHead = disableOpenedCursorsOnHead();
830 private void updateOpenedCursorsOnHeadAfterRotation(List<Pair<LogCursor<K, V>, CursorState<K, V>>> cursors)
833 for (Pair<LogCursor<K, V>, CursorState<K, V>> pair : cursors)
842 final LogCursor<
895 registerCursor(final LogCursor<K, V> cursor) argument
900 unregisterCursor(final LogCursor<K, V> cursor) argument
970 private static class LogCursor<K extends Comparable<K>, V> implements RepositionableCursor<K, V> class in class:Log
986 private LogCursor(final Log<K, V> log) throws ChangelogException method in class:Log.LogCursor
[all...] |
| /forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/ |
| H A D | Log.java | 1143 private void unregisterCursor(final LogCursor<K, V> cursor) argument
1227 private static abstract class LogCursor<K extends Comparable<K>, V> implements RepositionableCursor<K, V> class in class:Log
1248 private static class InternalLogCursor<K extends Comparable<K>, V> extends LogCursor<K, V>
1428 private static final class AbortedLogCursor<K extends Comparable<K>, V> extends LogCursor<K, V>
1509 private static class AbortableLogCursor<K extends Comparable<K>, V> extends LogCursor<K, V>
1515 private LogCursor<K, V> delegate;
1520 private AbortableLogCursor(Log<K,V> log, LogCursor<K, V> delegate)
|
| /glassfish-3.1.2/transaction/jts/src/main/java/com/sun/jts/CosTransactions/ |
| H A D | LogCursor.java | 43 // Module: LogCursor.java
84 class LogCursor { class
85 private static final StringManager sm = StringManager.getManager(LogCursor.class);
94 LogCursor blockValid;
114 LogCursor( LogControl control, method in class:LogCursor
|
| H A D | LogFile.java | 307 LogCursor logCursor;
|
| H A D | LogHandle.java | 1463 synchronized LogCursor openCursor( LogLSN startLSN,
1485 LogCursor cursor = new LogCursor(logControl,this,startLSN,endLSN);
1501 * @param LogCursor The cursor to be closed.
1509 synchronized void closeCursor( LogCursor cursor )
1954 LogCursor logCuDP; // ptr to cursor descriptor
1973 logCuDP = (LogCursor)curs.next();
|