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

use close helper method to close streams

Browse Source
This commit is contained in:
kimchy 2010-12-30 13:11:20 +02:00
parent 76d042f3c5
commit c4646a2b55
1 changed files with 9 additions and 52 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

61
modules/elasticsearch/src/main/java/org/elasticsearch/common/lucene/Directories.java
View File

@ -25,6 +25,7 @@ import org.apache.lucene.store.Directory;
import org.apache.lucene.store.FSDirectory;
import org.apache.lucene.store.IndexInput;
import org.apache.lucene.store.IndexOutput;
import org.elasticsearch.common.io.Closeables;
import org.elasticsearch.common.unit.ByteSizeValue;
import org.elasticsearch.index.store.support.ForceSyncDirectory;
@ -116,20 +117,8 @@ public class Directories {
os.write(buffer, 0, toRead);
}
} finally {
if (os != null) {
try {
os.close();
} catch (Exception e) {
// ignore
}
}
if (ii != null) {
try {
ii.close();
} catch (Exception e) {
// ignore
}
}
Closeables.closeQuietly(os);
Closeables.closeQuietly(ii);
}
}
@ -148,20 +137,8 @@ public class Directories {
output = dir.createOutput(fileName);
copyToDirectory(is, output);
} finally {
if (is != null) {
try {
is.close();
} catch (IOException e) {
// ignore
}
}
if (output != null) {
try {
output.close();
} catch (IOException e) {
// ignore
}
}
Closeables.closeQuietly(is);
Closeables.closeQuietly(output);
}
}
sync(dir, fileName);
@ -173,20 +150,8 @@ public class Directories {
output = dir.createOutput(fileName);
copyToDirectory(is, output);
} finally {
if (is != null) {
try {
is.close();
} catch (IOException e) {
// ignore
}
}
if (output != null) {
try {
output.close();
} catch (IOException e) {
// ignore
}
}
Closeables.closeQuietly(is);
Closeables.closeQuietly(output);
}
sync(dir, fileName);
}
@ -207,16 +172,8 @@ public class Directories {
io.writeBytes(buffer, len);
}
} finally {
try {
io.close();
} catch (Exception e) {
// ignore
}
try {
is.close();
} catch (Exception e) {
// ignore
}
Closeables.closeQuietly(io);
Closeables.closeQuietly(is);
}
}