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

Clean queues

Browse Source
This commit is contained in:
Andrea Cavalli 2021-10-25 01:44:12 +02:00
parent 7a01b6a2a4
commit f9b656986c
2 changed files with 16 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/main/java/it/cavallium/dbengine/lucene/LMDBArray.java
View File

@ -244,6 +244,14 @@ public class LMDBArray<V> implements IArray<V>, Closeable {
public void close() throws IOException { public void close() throws IOException {
if (closed.compareAndSet(false, true)) { if (closed.compareAndSet(false, true)) {
ensureThread(); ensureThread();
for (ByteBuf toWriteKey : toWriteKeys) {
toWriteKey.release();
}
for (ByteBuf toWriteValue : toWriteValues) {
toWriteValue.release();
}
toWriteKeys.clear();
toWriteValues.clear();
if (rwTxn != null) { if (rwTxn != null) {
rwTxn.close(); rwTxn.close();
} }

8
src/main/java/it/cavallium/dbengine/lucene/LMDBPriorityQueue.java
View File

@ -498,6 +498,14 @@ public class LMDBPriorityQueue<T> implements PriorityQueue<T>, Reversable<Revers
public void close() throws IOException { public void close() throws IOException {
if (closed.compareAndSet(false, true)) { if (closed.compareAndSet(false, true)) {
ensureThread(); ensureThread();
for (ByteBuf toWriteKey : toWriteKeys) {
toWriteKey.release();
}
for (ByteBuf toWriteValue : toWriteValues) {
toWriteValue.release();
}
toWriteKeys.clear();
toWriteValues.clear();
if (cur != null) { if (cur != null) {
cur.close(); cur.close();
} }