Skip to content

Commit 6e3df27

Browse files
committed
fix readers leaks
1 parent 6c3c48a commit 6e3df27

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

server/torrfs/torrfile.go

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@ package torrfs
22

33
import (
44
"io/fs"
5+
sets "server/settings"
56
"server/torr"
67
"server/torr/storage/torrstor"
78
"time"
@@ -45,6 +46,9 @@ func (f *TorrFile) Open(name string) (fs.File, error) {
4546
if r == nil {
4647
return nil, fs.ErrInvalid
4748
}
49+
if sets.BTsets.ResponsiveMode {
50+
r.SetResponsive()
51+
}
4852
return &TorrFileHandle{TorrFile: f, r: r}, nil
4953
}
5054

@@ -75,6 +79,6 @@ func (h *TorrFileHandle) Seek(off int64, whence int) (int64, error) {
7579
}
7680

7781
func (h *TorrFileHandle) Close() error {
78-
h.r.Close()
82+
h.torr.CloseReader(h.r)
7983
return nil
8084
}

0 commit comments

Comments
 (0)