From 03374b876adb2dc02ffda317be6a9b07c4225e74 Mon Sep 17 00:00:00 2001 From: yourok <8yourok8@mail.ru> Date: Fri, 14 Feb 2020 12:43:40 +0300 Subject: [PATCH] add TorrentDisconnectTimeout --- src/server/torr/Torrent.go | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/src/server/torr/Torrent.go b/src/server/torr/Torrent.go index c9aaf4f..8767c6a 100644 --- a/src/server/torr/Torrent.go +++ b/src/server/torr/Torrent.go @@ -10,11 +10,12 @@ import ( "server/settings" "server/utils" + "server/torr/reader" + "server/torr/storage/memcache" + "github.com/anacrolix/torrent" "github.com/anacrolix/torrent/metainfo" "github.com/labstack/gommon/bytes" - "server/torr/reader" - "server/torr/storage/memcache" ) type TorrentStatus int @@ -245,7 +246,7 @@ func (t *Torrent) CloseReader(reader *reader.Reader) { t.muReader.Lock() reader.Close() 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() } @@ -309,7 +310,7 @@ func (t *Torrent) Preload(file *torrent.File, size int64) { readerPost.SetReadahead(buff5mb) defer func() { t.CloseReader(readerPost) - t.expiredTime = time.Now().Add(time.Minute * 5) + t.expiredTime = time.Now().Add(time.Second * time.Duration(settings.Get().TorrentDisconnectTimeout)) }() }