Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -571,7 +571,8 @@ public IteratorParametersBuilder copy() {
.marshallerMappingFileStoreDir(marshallerMappingFileStoreDir)
.from(lowBound)
.to(highBound)
.filter(filter);
.filter(filter)
.strictBoundsCheck(strictBoundsCheck);
}

/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -174,7 +174,7 @@ private static void strictCheck(List<FileDescriptor> walFiles, FileWALPointer lo
}

if (idx == walFiles.size())
throw new IgniteCheckedException("Wal segments not in bounds. loBoundIndex=" + lowBound.index() +
throw new StrictBoundsCheckException("Wal segments not in bounds. loBoundIndex=" + lowBound.index() +
", indexes=" + printIndexes(walFiles));

long curWalSegmIdx = walFiles.get(idx).idx();
Expand All @@ -185,11 +185,11 @@ private static void strictCheck(List<FileDescriptor> walFiles, FileWALPointer lo
assert desc != null;

if (curWalSegmIdx != desc.idx())
throw new IgniteCheckedException("Wal segment " + curWalSegmIdx + " not found in files " + printIndexes(walFiles));
throw new StrictBoundsCheckException("Wal segment " + curWalSegmIdx + " not found in files " + printIndexes(walFiles));
}

if (highBound.index() < Long.MAX_VALUE && curWalSegmIdx <= highBound.index())
throw new IgniteCheckedException("Wal segments not in bounds. hiBoundIndex=" + highBound.index() +
throw new StrictBoundsCheckException("Wal segments not in bounds. hiBoundIndex=" + highBound.index() +
", indexes=" + printIndexes(walFiles));
}

Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,18 @@
package org.apache.ignite.internal.processors.cache.persistence.wal.reader;

import org.apache.ignite.IgniteCheckedException;

/**
* This exception is used in checking boundaries (StandaloneWalRecordsIterator).
*/
public class StrictBoundsCheckException extends IgniteCheckedException {
/** */
private static final long serialVersionUID = 0L;

/**
* @param mesg Message.
*/
public StrictBoundsCheckException(String mesg) {
super(mesg);
}
}