Compare commits

...

2 Commits

Author SHA1 Message Date
Andrea Cavalli 3b35c18517 Update maven 2023-09-25 02:11:27 +02:00
Andrea Cavalli e4ec49e9aa More checks 2023-09-20 00:56:21 +02:00
2 changed files with 16 additions and 6 deletions

View File

@ -388,7 +388,7 @@
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.8.1</version>
<version>3.11.0</version>
<configuration>
<release>17</release>
<annotationProcessorPaths>

View File

@ -50,6 +50,7 @@ public class RocksIteratorObj extends SimpleResource {
public synchronized void seek(byte[] seekArray) throws RocksDBException {
ensureOpen();
rocksIterator.status();
startedIterSeek.increment();
try {
iterSeekTime.record(() -> rocksIterator.seek(seekArray));
@ -84,10 +85,14 @@ public class RocksIteratorObj extends SimpleResource {
/**
* Useful for reverse iterations
*/
public synchronized void seekFrom(Buf key) {
public synchronized void seekFrom(Buf key) throws RocksDBException {
ensureOpen();
var keyArray = LLUtils.asArray(key);
rocksIterator.seekForPrev(keyArray);
try {
rocksIterator.seekForPrev(keyArray);
} finally {
}
rocksIterator.status();
// This is useful to retain the key buffer in memory and avoid deallocations
this.seekingFrom = keyArray;
}
@ -95,12 +100,17 @@ public class RocksIteratorObj extends SimpleResource {
/**
* Useful for forward iterations
*/
public synchronized void seekTo(Buf key) {
public synchronized void seekTo(Buf key) throws RocksDBException {
ensureOpen();
rocksIterator.status();
var keyArray = LLUtils.asArray(key);
startedIterSeek.increment();
iterSeekTime.record(() -> rocksIterator.seek(keyArray));
endedIterSeek.increment();
try {
iterSeekTime.record(() -> rocksIterator.seek(keyArray));
} finally {
endedIterSeek.increment();
}
rocksIterator.status();
// This is useful to retain the key buffer in memory and avoid deallocations
this.seekingTo = keyArray;
}