Apache
/
lucene
mirror of https://github.com/apache/lucene.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Closing IndexInput after every use

This commit is contained in:
expani 2024-10-19 09:53:15 +05:30
parent 4406d75b00
commit dc3d6fc9c1
1 changed files with 6 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
lucene/benchmark-jmh/src/java/org/apache/lucene/benchmark/jmh/DocIdEncodingBenchmark.java
View File

@ -81,8 +81,6 @@ public class DocIdEncodingBenchmark {
private Path tmpDir; private Path tmpDir;
private IndexInput in;
private final int[] scratch = new int[512]; private final int[] scratch = new int[512];
private String decoderInputFile; private String decoderInputFile;
@ -126,8 +124,8 @@ public class DocIdEncodingBenchmark {
Files.delete(tmpDir.resolve(outputFile)); Files.delete(tmpDir.resolve(outputFile));
} }
} else if (methodName.equalsIgnoreCase("decode")) { } else if (methodName.equalsIgnoreCase("decode")) {
try (Directory dir = FSDirectory.open(tmpDir)) { try (Directory dir = FSDirectory.open(tmpDir);
in = dir.openInput(decoderInputFile, IOContext.DEFAULT); IndexInput in = dir.openInput(decoderInputFile, IOContext.DEFAULT)) {
for (int[] docIdSequence : DOC_ID_SEQUENCES) { for (int[] docIdSequence : DOC_ID_SEQUENCES) {
for (int i = 1; i <= INPUT_SCALE_FACTOR; i++) { for (int i = 1; i <= INPUT_SCALE_FACTOR; i++) {
docIdEncoder.decode(in, 0, docIdSequence.length, scratch); docIdEncoder.decode(in, 0, docIdSequence.length, scratch);
@ -309,7 +307,7 @@ public class DocIdEncodingBenchmark {
out.writeLong(packedLong); out.writeLong(packedLong);
} }
for (; i < count; i++) { for (; i < count; i++) {
//out.writeInt(docIds[i]); // out.writeInt(docIds[i]);
out.writeLong(docIds[i]); out.writeLong(docIds[i]);
} }
} }
@ -324,7 +322,7 @@ public class DocIdEncodingBenchmark {
docIDs[i + 2] = (int) (packedLong & BPV_21_MASK); docIDs[i + 2] = (int) (packedLong & BPV_21_MASK);
} }
for (; i < count; i++) { for (; i < count; i++) {
//docIDs[i] = in.readInt(); // docIDs[i] = in.readInt();
docIDs[i] = (int) in.readLong(); docIDs[i] = (int) in.readLong();
} }
} }
@ -365,7 +363,7 @@ public class DocIdEncodingBenchmark {
out.writeLong(packedLong); out.writeLong(packedLong);
} }
for (; i < count; i++) { for (; i < count; i++) {
//out.writeInt(docIds[i]); // out.writeInt(docIds[i]);
out.writeLong(docIds[i]); out.writeLong(docIds[i]);
} }
} }
@ -394,7 +392,7 @@ public class DocIdEncodingBenchmark {
docIDs[i + 2] = (int) (packedLong & BPV_21_MASK); docIDs[i + 2] = (int) (packedLong & BPV_21_MASK);
} }
for (; i < count; i++) { for (; i < count; i++) {
//docIDs[i] = in.readInt(); // docIDs[i] = in.readInt();
docIDs[i] = (int) in.readLong(); docIDs[i] = (int) in.readLong();
} }
} }
@ -543,6 +541,5 @@ public class DocIdEncodingBenchmark {
} catch (IOException e) { } catch (IOException e) {
throw new RuntimeException(e); throw new RuntimeException(e);
} }
} }
} }