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());


Reply via email to