Searched defs:openCursors (Results 1 - 3 of 3) sorted by relevance
| /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>>(); field in class:Log
650 if (!openCursors.isEmpty())
725 if (!openCursors.isEmpty())
728 ERR_CHANGELOG_CURSOR_OPENED_WHILE_CLOSING_LOG.get(logPath.getPath(), openCursors.size()));
850 for (LogCursor<K, V> cursor : openCursors)
854 openCursors.clear();
869 for (LogCursor<K, V> cursor : openCursors)
897 openCursors.add(cursor);
902 openCursors.remove(cursor);
|
| /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>>(); field in class:Log
650 if (!openCursors.isEmpty())
725 if (!openCursors.isEmpty())
728 ERR_CHANGELOG_CURSOR_OPENED_WHILE_CLOSING_LOG.get(logPath.getPath(), openCursors.size()));
850 for (LogCursor<K, V> cursor : openCursors)
854 openCursors.clear();
869 for (LogCursor<K, V> cursor : openCursors)
897 openCursors.add(cursor);
902 openCursors.remove(cursor);
|
| /forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/ |
| H A D | Log.java | 169 private final List<AbortableLogCursor<K, V>> openCursors = new CopyOnWriteArrayList<>(); field in class:Log
787 for (AbortableLogCursor<K, V> cursor : openCursors)
814 if (!openCursors.isEmpty())
959 if (!openCursors.isEmpty())
961 logger.error(ERR_CHANGELOG_CURSOR_OPENED_WHILE_CLOSING_LOG.get(logPath.getPath(), openCursors.size()));
1092 for (AbortableLogCursor<K, V> cursor : openCursors)
1112 for (AbortableLogCursor<K, V> cursor : openCursors)
1140 openCursors.add(cursor);
1145 openCursors.remove(cursor);
|
Completed in 38 milliseconds