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

Code cleanup

Browse Source
This commit is contained in:
Andrea Cavalli 2022-05-22 00:56:32 +02:00
parent bff4d87164
commit fe31f9b1c7
2 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/main/java/it/cavallium/dbengine/database/collections/DatabaseMapDictionary.java
View File

@ -484,10 +484,11 @@ public class DatabaseMapDictionary<T, U> extends DatabaseMapDictionaryDeep<T, U,
if (keyMin == null && keyMax == null) { if (keyMin == null && keyMax == null) {
return getAllStages(snapshot, smallRange); return getAllStages(snapshot, smallRange);
} else { } else {
Mono<LLRange> boundedRangeMono = Mono.usingWhen(rangeMono, Mono<LLRange> boundedRangeMono = rangeMono.map(range -> {
range -> Mono.fromCallable(() -> getPatchedRange(range, keyMin, keyMax)), try (range) {
range -> Mono.fromRunnable(range::close) return getPatchedRange(range, keyMin, keyMax);
); }
});
return getAllStages(snapshot, boundedRangeMono, reverse, smallRange); return getAllStages(snapshot, boundedRangeMono, reverse, smallRange);
} }
} }

1
src/main/java/it/cavallium/dbengine/database/disk/OptimisticRocksDBColumn.java
View File

@ -128,6 +128,7 @@ public final class OptimisticRocksDBColumn extends AbstractRocksDBColumn<Optimis
prevDataToSendToUpdater = null; prevDataToSendToUpdater = null;
} }
try { try {
assert newData == null || !newData.isAccessible();
newData = updater.apply(prevDataToSendToUpdater); newData = updater.apply(prevDataToSendToUpdater);
} finally { } finally {
if (prevDataToSendToUpdater != null && prevDataToSendToUpdater.isAccessible()) { if (prevDataToSendToUpdater != null && prevDataToSendToUpdater.isAccessible()) {