From 7fdefa923eab5317ec885a9cc7ef6bd66bc847b3 Mon Sep 17 00:00:00 2001 From: YouROK <8yourok8@mail.ru> Date: Tue, 22 Dec 2020 20:41:13 +0300 Subject: [PATCH] change reader close --- src/server/torr/torrent.go | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/src/server/torr/torrent.go b/src/server/torr/torrent.go index 3c58f84..722e2f0 100644 --- a/src/server/torr/torrent.go +++ b/src/server/torr/torrent.go @@ -272,13 +272,16 @@ func (t *Torrent) Preload(index int, size int64) { // Reader for not pieces break in cache without readers readerStart := t.cache.NewReader(file) readerStart.Read(make([]byte, 1)) - defer t.cache.CloseReader(readerStart) + defer t.CloseReader(readerStart) + readerEnd := t.cache.NewReader(file) readerEnd.Seek(-1024, io.SeekEnd) readerEnd.Read(make([]byte, 1)) - defer t.cache.CloseReader(readerEnd) + defer t.CloseReader(readerEnd) + pl := t.Info().PieceLength lastStat := "" + for t.PreloadedBytes < size-pl { t.muTorrent.Lock() if t.Torrent == nil {