From ab9738868a7c9cf71525337ce866ee24fb0863d3 Mon Sep 17 00:00:00 2001 From: nikk gitanes Date: Thu, 19 Aug 2021 12:12:26 +0300 Subject: [PATCH] fix prioritise --- server/torr/storage/torrstor/cache.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/server/torr/storage/torrstor/cache.go b/server/torr/storage/torrstor/cache.go index 090c6a7..721e30a 100644 --- a/server/torr/storage/torrstor/cache.go +++ b/server/torr/storage/torrstor/cache.go @@ -260,11 +260,13 @@ func (c *Cache) getRemPieces() []*Piece { if !c.pieces[i].Complete { if i == readerPos { c.torrent.Piece(i).SetPriority(torrent.PiecePriorityNow) + } else if i == readerPos + 1 { + c.torrent.Piece(i).SetPriority(torrent.PiecePriorityNext) } else if i > readerPos && i <= readerRAHPos { c.torrent.Piece(i).SetPriority(torrent.PiecePriorityReadahead) - } else if i > readerRAHPos && i <= end/2 && c.torrent.PieceState(i).Priority != torrent.PiecePriorityHigh { + } else if i > readerRAHPos && i <= readerPos + (end - readerPos)/2 && c.torrent.PieceState(i).Priority != torrent.PiecePriorityHigh { c.torrent.Piece(i).SetPriority(torrent.PiecePriorityHigh) - } else if i > end/2 && c.torrent.PieceState(i).Priority != torrent.PiecePriorityNormal { + } else if i > readerPos + (end - readerPos)/2 && c.torrent.PieceState(i).Priority != torrent.PiecePriorityNormal { c.torrent.Piece(i).SetPriority(torrent.PiecePriorityNormal) } limit++