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

add TorrentDisconnectTimeout

Browse Source
This commit is contained in:
yourok
2020-02-14 12:43:40 +03:00
parent 559aa95f86
commit 03374b876a
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/server/torr/Torrent.go
View File

@@ -10,11 +10,12 @@ import (
"server/settings" "server/settings"
"server/utils" "server/utils"
"server/torr/reader"
"server/torr/storage/memcache"
"github.com/anacrolix/torrent" "github.com/anacrolix/torrent"
"github.com/anacrolix/torrent/metainfo" "github.com/anacrolix/torrent/metainfo"
"github.com/labstack/gommon/bytes" "github.com/labstack/gommon/bytes"
"server/torr/reader"
"server/torr/storage/memcache"
) )
type TorrentStatus int type TorrentStatus int
@@ -245,7 +246,7 @@ func (t *Torrent) CloseReader(reader *reader.Reader) {
t.muReader.Lock() t.muReader.Lock()
reader.Close() reader.Close()
t.cache.RemReader(reader) t.cache.RemReader(reader)
t.expiredTime = time.Now().Add(time.Minute) t.expiredTime = time.Now().Add(time.Minute * 10) //TODO one minute
t.muReader.Unlock() t.muReader.Unlock()
} }
@@ -309,7 +310,7 @@ func (t *Torrent) Preload(file *torrent.File, size int64) {
readerPost.SetReadahead(buff5mb) readerPost.SetReadahead(buff5mb)
defer func() { defer func() {
t.CloseReader(readerPost) t.CloseReader(readerPost)
t.expiredTime = time.Now().Add(time.Minute * 5) t.expiredTime = time.Now().Add(time.Second * time.Duration(settings.Get().TorrentDisconnectTimeout))
}() }()
} }