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

change load strategy, thx @antibaks

Browse Source
This commit is contained in:
YouROK
2021-03-12 15:50:58 +03:00
parent 576a682aea
commit 4ec66929b0
1 changed files with 16 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
server/torr/storage/torrstor/cache.go
View File

@@ -200,14 +200,26 @@ func (c *Cache) getRemPieces() []*Piece {
if p.Size > 0 && !c.isIdInFileBE(ranges, id) {
piecesRemove = append(piecesRemove, p)
}
} else {
if c.torrent.PieceState(id).Priority == torrent.PiecePriorityNone {
c.torrent.Piece(id).SetPriority(torrent.PiecePriorityNormal)
}
}
}
}
for r, _ := range c.readers {
pc := r.getReaderPiece()
end := r.getPiecesRange().End
limit := 5
for pc <= end && limit > 0 {
if !c.pieces[pc].complete {
if c.torrent.PieceState(pc).Priority == torrent.PiecePriorityNone {
c.torrent.Piece(pc).SetPriority(torrent.PiecePriorityNormal)
}
limit--
}
pc++
}
}
sort.Slice(piecesRemove, func(i, j int) bool {
return piecesRemove[i].accessed < piecesRemove[j].accessed
})