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

fix always preload

Browse Source
This commit is contained in:
YouROK
2021-03-17 09:28:14 +03:00
parent cfc67398e2
commit 212f6e7ca7
1 changed files with 9 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
server/torr/torrent.go
View File

@@ -279,13 +279,13 @@ func (t *Torrent) Preload(index int, size int64) {
} }
if t.Info() != nil { if t.Info() != nil {
pl := t.Info().PieceLength pieceLength := t.Info().PieceLength
mb5 := int64(5 * 1024 * 1024) mb5 := int64(5 * 1024 * 1024)
pieceFileStart := int(file.Offset() / pl) pieceFileStart := int(file.Offset() / pieceLength)
pieceFileEnd := int((file.Offset() + file.Length()) / pl) pieceFileEnd := int((file.Offset() + file.Length()) / pieceLength)
readerPieceBefore := int((file.Offset() + size - mb5) / pl) readerPieceBefore := int((file.Offset() + size - mb5) / pieceLength)
readerPieceAfter := int((file.Offset() + file.Length() - mb5) / pl) readerPieceAfter := int((file.Offset() + file.Length() - mb5) / pieceLength)
lastStat := time.Now().Add(-time.Second) lastStat := time.Now().Add(-time.Second)
@@ -325,6 +325,10 @@ func (t *Torrent) Preload(index int, size int64) {
} }
} }
} }
if t.PreloadedBytes >= size-pieceLength {
isComplete = true
}
t.AddExpiredTime(time.Second * time.Duration(settings.BTsets.TorrentDisconnectTimeout)) t.AddExpiredTime(time.Second * time.Duration(settings.BTsets.TorrentDisconnectTimeout))
if isComplete { if isComplete {
break break