]> Sergey Matveev's repositories - btrtrc.git/blobdiff - fs/file_handle.go
fs: Use a new torrent file reader per handled request
[btrtrc.git] / fs / file_handle.go
index 4759e5257b84700c638100a95168bb4e8614fe2d..2a8fe2ccad5f6a96cefa24b5db687bec26a520e1 100644 (file)
@@ -4,15 +4,16 @@ import (
        "context"
        "io"
 
-       "bazil.org/fuse"
-       "bazil.org/fuse/fs"
+       "github.com/anacrolix/fuse"
+       "github.com/anacrolix/fuse/fs"
        "github.com/anacrolix/missinggo/v2"
+
        "github.com/anacrolix/torrent"
 )
 
 type fileHandle struct {
        fn fileNode
-       r  torrent.Reader
+       tf *torrent.File
 }
 
 var _ interface {
@@ -25,7 +26,8 @@ func (me fileHandle) Read(ctx context.Context, req *fuse.ReadRequest, resp *fuse
        if req.Dir {
                panic("read on directory")
        }
-       r := me.r
+       r := me.tf.NewReader()
+       defer r.Close()
        pos, err := r.Seek(req.Offset, io.SeekStart)
        if err != nil {
                panic(err)
@@ -80,5 +82,5 @@ func (me fileHandle) Read(ctx context.Context, req *fuse.ReadRequest, resp *fuse
 }
 
 func (me fileHandle) Release(context.Context, *fuse.ReleaseRequest) error {
-       return me.r.Close()
+       return nil
 }