Check status unsafe

This commit is contained in:
Andrea Cavalli 2024-10-02 00:15:07 +02:00
parent 6a68c8452b
commit 591963f630
2 changed files with 5 additions and 0 deletions

View File

@ -225,6 +225,7 @@ public class RocksDBFile implements Comparable<RocksDBFile> {
} }
return new RocksDBFileIterationStateBegin(meta); return new RocksDBFileIterationStateBegin(meta);
} else { } else {
rocksIterator.statusUnsafe();
rawKey = rocksIterator.keyBuf().copy(); rawKey = rocksIterator.keyBuf().copy();
rawValue = rocksIterator.valueBuf().copy(); rawValue = rocksIterator.valueBuf().copy();
rocksIterator.next(); rocksIterator.next();

View File

@ -168,6 +168,10 @@ public abstract class RocksIteratorObj extends SimpleResource {
rocksIterator.next(); rocksIterator.next();
} }
public synchronized void statusUnsafe() throws RocksDBException {
rocksIterator.status();
}
public synchronized void seekToLast() throws RocksDBException { public synchronized void seekToLast() throws RocksDBException {
ensureOpen(); ensureOpen();
startedIterSeek.increment(); startedIterSeek.increment();