sovonegr/TorrServerJellyfin
1
0
Fork 0
mirror of https://github.com/Ernous/TorrServerJellyfin.git synced 2025-12-20 05:56:10 +05:00
Code Issues Packages Projects Releases Wiki Activity

change close

Browse Source
This commit is contained in:
YouROK
2020-12-18 09:46:22 +03:00
parent 81f89e04c3
commit 06e8cf833d
1 changed files with 16 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
src/server/torr/storage/torrstor/reader.go
View File

@@ -5,6 +5,7 @@ import (
"sync" "sync"
"github.com/anacrolix/torrent" "github.com/anacrolix/torrent"
"server/log"
) )
type Reader struct { type Reader struct {
@@ -60,13 +61,18 @@ func (r *Reader) Seek(offset int64, whence int) (n int64, err error) {
func (r *Reader) Read(p []byte) (n int, err error) { func (r *Reader) Read(p []byte) (n int, err error) {
r.mu.Lock() r.mu.Lock()
defer r.mu.Unlock() defer r.mu.Unlock()
err = io.EOF
if r.isClosed { if r.isClosed {
return 0, io.EOF return
} }
n, err = r.Reader.Read(p) if r.file.Torrent() != nil && r.file.Torrent().Info() != nil {
r.offset += int64(n) n, err = r.Reader.Read(p)
if !r.isPreload { r.offset += int64(n)
go r.preload() if !r.isPreload {
go r.preload()
}
} else {
log.TLogln("Torrent closed and readed")
} }
return return
} }
@@ -86,11 +92,13 @@ func (r *Reader) Readahead() int64 {
return r.readahead return r.readahead
} }
func (r *Reader) Close() error { func (r *Reader) Close() {
// file reader close in gotorrent
// this struct close in cache
// TODO провверить как будут закрываться ридеры
r.mu.Lock() r.mu.Lock()
defer r.mu.Unlock()
r.isClosed = true r.isClosed = true
return r.Reader.Close() r.mu.Unlock()
} }
func (c *Cache) NewReader(file *torrent.File) *Reader { func (c *Cache) NewReader(file *torrent.File) *Reader {