From 7990eef91dea30486e0b438f949d8482ccc0f6d0 Mon Sep 17 00:00:00 2001
From: Matt Joiner <anacrolix@gmail.com>
Date: Mon, 15 Feb 2021 15:53:32 +1100
Subject: [PATCH] Use io.ReadFull in fs reads

---
 fs/file_handle.go | 17 ++++++++++++-----
 1 file changed, 12 insertions(+), 5 deletions(-)

diff --git a/fs/file_handle.go b/fs/file_handle.go
index 41517296..0ba6d2e8 100644
--- a/fs/file_handle.go
+++ b/fs/file_handle.go
@@ -3,6 +3,7 @@ package torrentfs
 import (
 	"context"
 	"io"
+	"log"
 
 	"bazil.org/fuse"
 	"bazil.org/fuse/fs"
@@ -26,7 +27,8 @@ func (me fileHandle) Read(ctx context.Context, req *fuse.ReadRequest, resp *fuse
 	if req.Dir {
 		panic("read on directory")
 	}
-	pos, err := me.r.Seek(req.Offset, io.SeekStart)
+	r := me.r
+	pos, err := r.Seek(req.Offset, io.SeekStart)
 	if err != nil {
 		panic(err)
 	}
@@ -44,10 +46,15 @@ func (me fileHandle) Read(ctx context.Context, req *fuse.ReadRequest, resp *fuse
 		me.fn.FS.event.Broadcast()
 		me.fn.FS.mu.Unlock()
 		var n int
-		r := missinggo.ContextedReader{me.r, ctx}
-		n, readErr = r.Read(resp.Data)
-		if readErr == io.EOF {
-			readErr = nil
+		r := missinggo.ContextedReader{r, ctx}
+		log.Printf("reading %v bytes at %v", len(resp.Data), req.Offset)
+		if true {
+			n, readErr = io.ReadFull(r, resp.Data)
+		} else {
+			n, readErr = r.Read(resp.Data)
+			if readErr == io.EOF {
+				readErr = nil
+			}
 		}
 		resp.Data = resp.Data[:n]
 	}()
-- 
2.44.0