Author: frm
Date: Wed Dec 6 14:28:36 2017
New Revision: 1817297
URL: http://svn.apache.org/viewvc?rev=1817297&view=rev
Log:
OAK-7031 - Don't use the FileChannel to get the size of the spool file
Modified:
jackrabbit/oak/trunk/oak-segment-tar/src/main/java/org/apache/jackrabbit/oak/segment/standby/codec/ResponseDecoder.java
Modified:
jackrabbit/oak/trunk/oak-segment-tar/src/main/java/org/apache/jackrabbit/oak/segment/standby/codec/ResponseDecoder.java
URL:
http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-segment-tar/src/main/java/org/apache/jackrabbit/oak/segment/standby/codec/ResponseDecoder.java?rev=1817297&r1=1817296&r2=1817297&view=diff
==============================================================================
---
jackrabbit/oak/trunk/oak-segment-tar/src/main/java/org/apache/jackrabbit/oak/segment/standby/codec/ResponseDecoder.java
(original)
+++
jackrabbit/oak/trunk/oak-segment-tar/src/main/java/org/apache/jackrabbit/oak/segment/standby/codec/ResponseDecoder.java
Wed Dec 6 14:28:36 2017
@@ -167,8 +167,7 @@ public class ResponseDecoder extends Byt
log.debug("Received entire blob {}", blobId);
if (blobLength == tempFile.length()) {
- FileInputStream fis = new
DeleteOnCloseFileInputStream(tempFile);
- out.add(new GetBlobResponse(null, blobId, fis,
fis.getChannel().size()));
+ out.add(new GetBlobResponse(null, blobId, new
DeleteOnCloseFileInputStream(tempFile), blobLength));
} else {
log.debug("Blob {} discarded due to size mismatch. Expected
size: {}, actual size: {} ", blobId,
blobLength, tempFile.length());