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

reuse file buffer

Browse Source
This commit is contained in:
kimchy 2010-07-09 03:24:31 +03:00
parent d531d82cfb
commit 6cdd6a015c
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
modules/elasticsearch/src/main/java/org/elasticsearch/index/translog/fs/FsSnapshot.java
View File

@ -50,6 +50,8 @@ public class FsSnapshot implements Translog.Snapshot {
private int position = 0;
private byte[] cachedData;
public FsSnapshot(ShardId shardId, long id, RafReference raf, long length) throws FileNotFoundException {
this.shardId = shardId;
this.id = id;
@ -83,9 +85,13 @@ public class FsSnapshot implements Translog.Snapshot {
return false;
}
position += opSize;
byte[] data = new byte[opSize];
dis.readFully(data);
lastOperationRead = TranslogStreams.readTranslogOperation(new BytesStreamInput(data));
if (cachedData == null) {
cachedData = new byte[opSize];
} else if (cachedData.length < opSize) {
cachedData = new byte[opSize];
}
dis.readFully(cachedData, 0, opSize);
lastOperationRead = TranslogStreams.readTranslogOperation(new BytesStreamInput(cachedData, 0, opSize));
return true;
} catch (Exception e) {
return false;