/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/ |
H A D | BlockLogReader.java | 178 * @param filePosition 183 public void seekToPosition(final long filePosition) throws ChangelogException argument 187 reader.seek(filePosition); 191 throw new ChangelogException(ERR_CHANGELOG_UNABLE_TO_SEEK.get(filePosition, file.getPath()), e); 299 final long filePosition = reader.getFilePointer(); 300 if (reader.length() == filePosition) 304 int distanceToBlockStart = getDistanceToNextBlockStart(filePosition, blockSize); 539 * @param filePosition 543 long getClosestBlockStartBeforeOrAtPosition(final long filePosition) argument 545 final int dist = getDistanceToNextBlockStart(filePosition, blockSiz 557 getClosestBlockStartStrictlyAfterPosition(final long filePosition) argument 572 getDistanceToNextBlockStart(final long filePosition, final int blockSize) argument [all...] |
H A D | Log.java | 1084 cursor.reinitializeTo(new CursorState<K, V>(logFile, cursorState.filePosition, cursorState.record)); 1358 currentCursor = currentLogFile.getCursorInitialisedTo(cursorState.record, cursorState.filePosition); 1638 private final long filePosition; field in class:Log.CursorState 1648 filePosition = 0; 1654 private CursorState(final LogFile<K, V> logFile, final long filePosition, final Record<K, V> record) argument 1657 this.filePosition = filePosition;
|
H A D | LogFile.java | 563 private LogFileCursor(LogFile<K, V> logFile, Record<K, V> record, long filePosition) throws ChangelogException argument 571 reader.seekToPosition(filePosition);
|
/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/file/ |
H A D | BlockLogReader.java | 180 * @param filePosition 185 public void seekToPosition(final long filePosition) throws ChangelogException argument 189 reader.seek(filePosition); 193 throw new ChangelogException(ERR_CHANGELOG_UNABLE_TO_SEEK.get(filePosition, file.getPath()), e); 301 final long filePosition = reader.getFilePointer(); 302 int distanceToBlockStart = getDistanceToNextBlockStart(filePosition, blockSize); 549 * @param filePosition 553 long getClosestBlockStartBeforeOrAtPosition(final long filePosition) argument 555 final int dist = getDistanceToNextBlockStart(filePosition, blockSize); 556 return dist == 0 ? filePosition 567 getClosestBlockStartStrictlyAfterPosition(final long filePosition) argument 582 getDistanceToNextBlockStart(final long filePosition, final int blockSize) argument [all...] |
H A D | LogFile.java | 545 private LogFileCursor(LogFile<K, V> logFile, Record<K, V> record, long filePosition) throws ChangelogException argument 550 reader.seekToPosition(filePosition);
|
H A D | Log.java | 843 cursor.reinitializeTo(new CursorState<K, V>(logFile, cursorState.filePosition, cursorState.record)); 1091 currentCursor = currentLogFile.getCursorInitialisedTo(cursorState.record, cursorState.filePosition); 1176 private final long filePosition; field in class:Log.CursorState 1181 private CursorState(final LogFile<K, V> logFile, final long filePosition, final Record<K, V> record) argument 1184 this.filePosition = filePosition;
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/file/ |
H A D | BlockLogReader.java | 180 * @param filePosition 185 public void seekToPosition(final long filePosition) throws ChangelogException argument 189 reader.seek(filePosition); 193 throw new ChangelogException(ERR_CHANGELOG_UNABLE_TO_SEEK.get(filePosition, file.getPath()), e); 301 final long filePosition = reader.getFilePointer(); 302 int distanceToBlockStart = getDistanceToNextBlockStart(filePosition, blockSize); 549 * @param filePosition 553 long getClosestBlockStartBeforeOrAtPosition(final long filePosition) argument 555 final int dist = getDistanceToNextBlockStart(filePosition, blockSize); 556 return dist == 0 ? filePosition 567 getClosestBlockStartStrictlyAfterPosition(final long filePosition) argument 582 getDistanceToNextBlockStart(final long filePosition, final int blockSize) argument [all...] |
H A D | LogFile.java | 545 private LogFileCursor(LogFile<K, V> logFile, Record<K, V> record, long filePosition) throws ChangelogException argument 550 reader.seekToPosition(filePosition);
|
H A D | Log.java | 843 cursor.reinitializeTo(new CursorState<K, V>(logFile, cursorState.filePosition, cursorState.record)); 1091 currentCursor = currentLogFile.getCursorInitialisedTo(cursorState.record, cursorState.filePosition); 1176 private final long filePosition; field in class:Log.CursorState 1181 private CursorState(final LogFile<K, V> logFile, final long filePosition, final Record<K, V> record) argument 1184 this.filePosition = filePosition;
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/backends/pluggable/ |
H A D | OnDiskMergeImporter.java | 1405 private final AtomicLong filePosition = new AtomicLong(); field in class:OnDiskMergeImporter.ExternalSortChunk 1516 final long startOffset = filePosition.getAndAdd(chunk.size());
|