diff --git a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalKeyValueDatabase.java b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalKeyValueDatabase.java index d7e7100..ee6d634 100644 --- a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalKeyValueDatabase.java +++ b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalKeyValueDatabase.java @@ -1108,7 +1108,7 @@ public class LLLocalKeyValueDatabase implements LLKeyValueDatabase { try { ensureOpen(); var snapshotHandle = snapshotsHandles.get(snapshot.getSequenceNumber()); - ensureOwned(snapshotHandle); + //ensureOwned(snapshotHandle); return snapshotHandle; } finally { closeLock.unlockRead(closeReadSnapLock); diff --git a/src/main/java/it/cavallium/dbengine/database/disk/RocksIterWithReadOpts.java b/src/main/java/it/cavallium/dbengine/database/disk/RocksIterWithReadOpts.java index ce4a39b..ca2194d 100644 --- a/src/main/java/it/cavallium/dbengine/database/disk/RocksIterWithReadOpts.java +++ b/src/main/java/it/cavallium/dbengine/database/disk/RocksIterWithReadOpts.java @@ -8,7 +8,7 @@ public record RocksIterWithReadOpts(ReadOptions readOptions, RocksIteratorObj it @Override public void close() { - if (readOptions != null) { + if (readOptions != null && readOptions.isAccessible()) { readOptions.close(); } iter.close();