Mirror/MarginaliaSearch
1
0
Fork 0
mirror of https://github.com/MarginaliaSearch/MarginaliaSearch.git synced 2025-02-24 05:18:58 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

(index) Explicitly free LongQueryBuffers

Browse Source
This commit is contained in:
Viktor Lofgren 2024-04-16 19:23:00 +02:00
parent adf846bfd2
commit df75e8f4aa
2 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
code/index/java/nu/marginalia/index/IndexGrpcService.java
View File

@ -9,7 +9,6 @@ import io.prometheus.client.Histogram;
import it.unimi.dsi.fastutil.longs.LongArrayList; import it.unimi.dsi.fastutil.longs.LongArrayList;
import lombok.SneakyThrows; import lombok.SneakyThrows;
import nu.marginalia.api.searchquery.*; import nu.marginalia.api.searchquery.*;
import nu.marginalia.api.searchquery.model.compiled.CompiledQuery;
import nu.marginalia.api.searchquery.model.compiled.CompiledQueryLong; import nu.marginalia.api.searchquery.model.compiled.CompiledQueryLong;
import nu.marginalia.api.searchquery.model.compiled.CqDataInt; import nu.marginalia.api.searchquery.model.compiled.CqDataInt;
import nu.marginalia.api.searchquery.model.query.SearchSpecification; import nu.marginalia.api.searchquery.model.query.SearchSpecification;
@ -335,6 +334,8 @@ public class IndexGrpcService extends IndexApiGrpc.IndexApiImplBase {
} }
} }
buffer.dispose();
if (!results.isEmpty()) { if (!results.isEmpty()) {
enqueueResults(new CombinedDocIdList(results)); enqueueResults(new CombinedDocIdList(results));
} }

5
code/libraries/array/java/nu/marginalia/array/buffer/LongQueryBuffer.java
View File

@ -51,6 +51,11 @@ public class LongQueryBuffer {
return copy; return copy;
} }
/** Dispose of the buffer and release resources */
public void dispose() {
data.close();
}
public boolean isEmpty() { public boolean isEmpty() {
return end == 0; return end == 0;
} }