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

dont preload if reader in begin of file

Browse Source
This commit is contained in:
YouROK
2021-05-05 20:36:47 +03:00
parent eb4176db3f
commit 27bafaead0
1 changed files with 11 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -37,6 +37,8 @@ type Cache struct {
torrent *torrent.Torrent torrent *torrent.Torrent
} }
const FileRangeNotDelete = 5 * 1024 * 1024
func NewCache(capacity int64, storage *Storage) *Cache { func NewCache(capacity int64, storage *Storage) *Cache {
ret := &Cache{ ret := &Cache{
capacity: capacity, capacity: capacity,
@@ -204,6 +206,13 @@ func (c *Cache) getRemPieces() []*Piece {
} }
for r, _ := range c.readers { for r, _ := range c.readers {
notLoadSize := int64(FileRangeNotDelete)
if c.pieceLength > notLoadSize {
notLoadSize = c.pieceLength
}
if r.offset-r.file.Offset() < notLoadSize {
continue
}
pc := r.getReaderPiece() pc := r.getReaderPiece()
end := r.getPiecesRange().End end := r.getPiecesRange().End
limit := 5 limit := 5
@@ -230,9 +239,9 @@ func (c *Cache) getRemPieces() []*Piece {
func (c *Cache) isIdInFileBE(ranges []Range, id int) bool { func (c *Cache) isIdInFileBE(ranges []Range, id int) bool {
for _, rng := range ranges { for _, rng := range ranges {
ss := int(rng.File.Offset() / c.pieceLength) ss := int(rng.File.Offset() / c.pieceLength)
se := int((5*1024*1024 + rng.File.Offset()) / c.pieceLength) se := int((FileRangeNotDelete + rng.File.Offset()) / c.pieceLength)
es := int((rng.File.Offset() + rng.File.Length() - 5*1024*1024) / c.pieceLength) es := int((rng.File.Offset() + rng.File.Length() - FileRangeNotDelete) / c.pieceLength)
ee := int((rng.File.Offset() + rng.File.Length()) / c.pieceLength) ee := int((rng.File.Offset() + rng.File.Length()) / c.pieceLength)
if id >= ss && id <= se || id >= es && id <= ee { if id >= ss && id <= se || id >= es && id <= ee {