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

some changes with preload

Browse Source
This commit is contained in:
YouROK
2020-12-18 10:31:34 +03:00
parent 8e97922613
commit 13a94f0933
1 changed files with 4 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/server/torr/torrent.go
View File

@@ -153,6 +153,8 @@ func (t *Torrent) progressEvent() {
t.BytesWrittenData = st.BytesWrittenData.Int64() t.BytesWrittenData = st.BytesWrittenData.Int64()
t.BytesReadUsefulData = st.BytesReadUsefulData.Int64() t.BytesReadUsefulData = st.BytesReadUsefulData.Int64()
t.PreloadedBytes = t.Torrent.BytesCompleted()
} else { } else {
t.DownloadSpeed = 0 t.DownloadSpeed = 0
t.UploadSpeed = 0 t.UploadSpeed = 0
@@ -226,16 +228,9 @@ func (t *Torrent) GetCache() *torrstor.Cache {
} }
func (t *Torrent) Preload(index int, size int64) { func (t *Torrent) Preload(index int, size int64) {
if size < 0 { if size <= 0 {
return return
} }
if size == 0 {
size = settings.BTsets.PreloadBufferSize
}
if size == 0 {
return
}
t.PreloadSize = size t.PreloadSize = size
if t.Stat == state.TorrentGettingInfo { if t.Stat == state.TorrentGettingInfo {
@@ -267,7 +262,7 @@ func (t *Torrent) Preload(index int, size int64) {
} }
pieceLength := t.Info().PieceLength pieceLength := t.Info().PieceLength
startPiece := file.Offset() / pieceLength startPiece := file.Offset() / pieceLength
endPiece := int64(float32(file.Offset()+size)/float32(pieceLength) + 0.5) endPiece := (file.Offset() + size) / pieceLength
for i := startPiece; i < endPiece; i++ { for i := startPiece; i < endPiece; i++ {
t.Torrent.Piece(int(i)).SetPriority(torrent.PiecePriorityNormal) t.Torrent.Piece(int(i)).SetPriority(torrent.PiecePriorityNormal)
} }