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

Do not release cached searcher

Browse Source
This commit is contained in:
Andrea Cavalli 2021-09-24 02:47:52 +02:00
parent 23fa46c775
commit 996165c3cc
1 changed files with 1 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
src/main/java/it/cavallium/dbengine/database/disk/LLIndexSearcher.java
View File

@ -3,21 +3,16 @@ package it.cavallium.dbengine.database.disk;
import io.net5.buffer.api.Drop;
import io.net5.buffer.api.Owned;
import it.cavallium.dbengine.database.LiveResourceSupport;
import java.io.IOException;
import org.apache.lucene.index.IndexReader;
import org.apache.lucene.search.IndexSearcher;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class LLIndexSearcher extends LiveResourceSupport<LLIndexSearcher, LLIndexSearcher> {
private static final Logger logger = LoggerFactory.getLogger(LLIndexSearcher.class);
private IndexSearcher indexSearcher;
private final boolean decRef;
public LLIndexSearcher(IndexSearcher indexSearcher, boolean decRef, Drop<LLIndexSearcher> drop) {
super(new CloseOnDrop(drop));
super(drop);
this.indexSearcher = indexSearcher;
this.decRef = decRef;
}
@ -51,26 +46,4 @@ public class LLIndexSearcher extends LiveResourceSupport<LLIndexSearcher, LLInde
this.indexSearcher = null;
}
private static class CloseOnDrop implements Drop<LLIndexSearcher> {
private final Drop<LLIndexSearcher> delegate;
public CloseOnDrop(Drop<LLIndexSearcher> drop) {
if (drop instanceof CloseOnDrop closeOnDrop) {
this.delegate = closeOnDrop.delegate;
} else {
this.delegate = drop;
}
}
@Override
public void drop(LLIndexSearcher obj) {
try {
obj.indexSearcher.getIndexReader().decRef();
} catch (IOException ex) {
logger.error("Failed to drop IndexReader", ex);
}
delegate.drop(obj);
}
}
}