Searched defs:filePosition (Results 1 - 10 of 10) sorted by relevance

/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/file/
H A DBlockLogReader.java180 * @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 DLogFile.java545 private LogFileCursor(LogFile<K, V> logFile, Record<K, V> record, long filePosition) throws ChangelogException argument
550 reader.seekToPosition(filePosition);
H A DLog.java843 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 DBlockLogReader.java180 * @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 DLogFile.java545 private LogFileCursor(LogFile<K, V> logFile, Record<K, V> record, long filePosition) throws ChangelogException argument
550 reader.seekToPosition(filePosition);
H A DLog.java843 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/replication/server/changelog/file/
H A DBlockLogReader.java178 * @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 DLogFile.java563 private LogFileCursor(LogFile<K, V> logFile, Record<K, V> record, long filePosition) throws ChangelogException argument
571 reader.seekToPosition(filePosition);
H A DLog.java1084 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;
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/backends/pluggable/
H A DOnDiskMergeImporter.java1405 private final AtomicLong filePosition = new AtomicLong(); field in class:OnDiskMergeImporter.ExternalSortChunk
1516 final long startOffset = filePosition.getAndAdd(chunk.size());

Completed in 148 milliseconds