andreacavalli/CavalliumDBEngine
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Rewind and clear the buffers

Browse Source
This commit is contained in:
Andrea Cavalli 2021-12-30 22:29:17 +01:00
parent 64f21409f1
commit d6244ab18d
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/it/cavallium/dbengine/database/disk/AbstractRocksDBColumn.java
View File

@ -128,7 +128,7 @@ public sealed abstract class AbstractRocksDBColumn<T extends RocksDB> implements
assert resultBuffer.writerOffset() == 0; assert resultBuffer.writerOffset() == 0;
var resultWritable = ((WritableComponent) resultBuffer).writableBuffer(); var resultWritable = ((WritableComponent) resultBuffer).writableBuffer();
var keyMayExist = db.keyMayExist(cfh, keyNioBuffer, resultWritable); var keyMayExist = db.keyMayExist(cfh, readOptions, keyNioBuffer.rewind(), resultWritable.clear());
var keyMayExistState = KeyMayExistWorkaround.getExistenceState(keyMayExist); var keyMayExistState = KeyMayExistWorkaround.getExistenceState(keyMayExist);
int keyMayExistValueLength = KeyMayExistWorkaround.getValueLength(keyMayExist); int keyMayExistValueLength = KeyMayExistWorkaround.getValueLength(keyMayExist);
// At the beginning, size reflects the expected size, then it becomes the real data size // At the beginning, size reflects the expected size, then it becomes the real data size
@ -144,7 +144,7 @@ public sealed abstract class AbstractRocksDBColumn<T extends RocksDB> implements
assert keyMayExistValueLength == 0; assert keyMayExistValueLength == 0;
resultWritable.clear(); resultWritable.clear();
// real data size // real data size
size = db.get(cfh, readOptions, keyNioBuffer.position(0), resultWritable); size = db.get(cfh, readOptions, keyNioBuffer.rewind(), resultWritable.clear());
if (size == RocksDB.NOT_FOUND) { if (size == RocksDB.NOT_FOUND) {
resultBuffer.close(); resultBuffer.close();
return null; return null;
@ -164,7 +164,7 @@ public sealed abstract class AbstractRocksDBColumn<T extends RocksDB> implements
assert resultBuffer.readerOffset() == 0; assert resultBuffer.readerOffset() == 0;
assert resultBuffer.writerOffset() == 0; assert resultBuffer.writerOffset() == 0;
size = db.get(cfh, readOptions, keyNioBuffer.position(0), resultWritable); size = db.get(cfh, readOptions, keyNioBuffer.rewind(), resultWritable.clear());
if (size == RocksDB.NOT_FOUND) { if (size == RocksDB.NOT_FOUND) {
resultBuffer.close(); resultBuffer.close();
return null; return null;