honeymoose/OpenSearch
1
0
Fork 0
mirror of https://github.com/honeymoose/OpenSearch.git synced 2025-02-17 10:25:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix file handle leak in URLBlobContainer

Browse Source
This commit is contained in:
Igor Motov 2013-11-13 23:19:32 -05:00
parent c324251fc2
commit 0a7c6c9288
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/main/java/org/elasticsearch/common/blobstore/url/AbstractURLBlobContainer.java
View File

@ -96,20 +96,20 @@ public abstract class AbstractURLBlobContainer extends AbstractBlobContainer {
InputStream is = null;
try {
is = new URL(path, blobName).openStream();
} catch (IOException e) {
IOUtils.closeWhileHandlingException(is);
listener.onFailure(e);
return;
}
try {
int bytesRead;
while ((bytesRead = is.read(buffer)) != -1) {
listener.onPartial(buffer, 0, bytesRead);
}
listener.onCompleted();
} catch (IOException e) {
} catch (Throwable t) {
IOUtils.closeWhileHandlingException(is);
listener.onFailure(e);
listener.onFailure(t);
return;
}
try {
IOUtils.closeWhileHandlingException(is);
listener.onCompleted();
} catch (Throwable t) {
listener.onFailure(t);
}
}
});