github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-24 06:37:19 -04:00
Code Issues Projects Releases Packages Wiki Activity

Fix FD leak in FileCheckpointIO, closes #7150

Browse source 
Fixes #7151
This commit is contained in:
Armin 2017-05-18 18:19:22 +02:00 • committed by Armin Braun
parent b00b7f9656
commit 64397c66e3
1 changed files with 8 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

12
logstash-core/src/main/java/org/logstash/ackedqueue/io/FileCheckpointIO.java
View file

@ -6,8 +6,8 @@ import org.logstash.common.io.BufferedChecksumStreamOutput;
import org.logstash.common.io.ByteArrayStreamOutput;
import org.logstash.common.io.InputStreamStreamInput;
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.nio.file.Files;
import java.nio.file.OpenOption;
import java.nio.file.Path;
@ -46,9 +46,13 @@ public class FileCheckpointIO implements CheckpointIO {
@Override
public Checkpoint read(String fileName) throws IOException {
Path path = Paths.get(dirPath, fileName);
InputStream is = Files.newInputStream(path);
return read(new BufferedChecksumStreamInput(new InputStreamStreamInput(is)));
return read(
new BufferedChecksumStreamInput(
new InputStreamStreamInput(
new ByteArrayInputStream(Files.readAllBytes(Paths.get(dirPath, fileName)))
)
)
);
}
@Override