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

Bugfix

Browse Source
This commit is contained in:
Andrea Cavalli 2022-07-23 14:36:40 +02:00
parent b9ffa1dd49
commit bca768a4b8
1 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/main/java/it/cavallium/dbengine/database/LLUtils.java
View File

@ -647,7 +647,12 @@ public class LLUtils {
} }
public static Mono<Void> finalizeResource(Resource<?> resource) { public static Mono<Void> finalizeResource(Resource<?> resource) {
return Mono.fromRunnable(() -> LLUtils.finalizeResourceNow(resource)); Mono<Void> runnable = Mono.fromRunnable(() -> LLUtils.finalizeResourceNow(resource));
if (resource instanceof LuceneCloseable) {
return runnable.transform(LuceneUtils::scheduleLucene);
} else {
return runnable;
}
} }
public static Mono<Void> finalizeResource(SafeCloseable resource) { public static Mono<Void> finalizeResource(SafeCloseable resource) {
@ -956,7 +961,11 @@ public class LLUtils {
send.close(); send.close();
} if (next instanceof SafeCloseable closeable) { } if (next instanceof SafeCloseable closeable) {
if (manual || closeable instanceof DiscardingCloseable) { if (manual || closeable instanceof DiscardingCloseable) {
closeable.close(); if (!manual && !LuceneUtils.isLuceneThread() && closeable instanceof LuceneCloseable luceneCloseable) {
luceneScheduler().schedule(() -> luceneCloseable.close());
} else {
closeable.close();
}
} }
} else if (next instanceof Resource<?> resource && resource.isAccessible()) { } else if (next instanceof Resource<?> resource && resource.isAccessible()) {
resource.close(); resource.close();