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 info

Browse Source
This commit is contained in:
YouROK
2021-02-20 12:37:30 +03:00
parent 782d3e854e
commit aaaa805183
1 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
server/torr/torrent.go
View File

@@ -155,17 +155,17 @@ func (t *Torrent) progressEvent() {
t.muTorrent.Lock() t.muTorrent.Lock()
if t.Torrent != nil && t.Torrent.Info() != nil { if t.Torrent != nil && t.Torrent.Info() != nil {
st := t.Torrent.Stats() st := t.Torrent.Stats()
deltaDlBytes := st.BytesReadUsefulData.Int64() - t.BytesReadUsefulData deltaDlBytes := st.BytesRead.Int64() - t.BytesReadUsefulData
deltaUpBytes := st.BytesWrittenData.Int64() - t.BytesWrittenData deltaUpBytes := st.BytesWritten.Int64() - t.BytesWrittenData
deltaTime := time.Since(t.lastTimeSpeed).Seconds() deltaTime := time.Since(t.lastTimeSpeed).Seconds()
t.DownloadSpeed = float64(deltaDlBytes) / deltaTime t.DownloadSpeed = float64(deltaDlBytes) / deltaTime
t.UploadSpeed = float64(deltaUpBytes) / deltaTime t.UploadSpeed = float64(deltaUpBytes) / deltaTime
t.BytesWrittenData = st.BytesWrittenData.Int64() t.BytesReadUsefulData = st.BytesRead.Int64()
t.BytesReadUsefulData = st.BytesReadUsefulData.Int64() t.BytesWrittenData = st.BytesWritten.Int64()
t.PreloadedBytes = t.Torrent.BytesCompleted() t.PreloadedBytes = t.cache.GetState().Filled
} else { } else {
t.DownloadSpeed = 0 t.DownloadSpeed = 0
t.UploadSpeed = 0 t.UploadSpeed = 0
@@ -288,7 +288,8 @@ func (t *Torrent) Preload(index int, size int64) {
if t.Torrent == nil { if t.Torrent == nil {
return return
} }
t.PreloadedBytes = t.Torrent.BytesCompleted()
t.PreloadedBytes = t.cache.GetState().Filled
t.muTorrent.Unlock() t.muTorrent.Unlock()
stat := fmt.Sprint(file.Torrent().InfoHash().HexString(), " ", utils2.Format(float64(t.PreloadedBytes)), "/", utils2.Format(float64(t.PreloadSize)), " Speed:", utils2.Format(t.DownloadSpeed), " Peers:[", t.Torrent.Stats().ConnectedSeeders, "]", t.Torrent.Stats().ActivePeers, "/", t.Torrent.Stats().TotalPeers) stat := fmt.Sprint(file.Torrent().InfoHash().HexString(), " ", utils2.Format(float64(t.PreloadedBytes)), "/", utils2.Format(float64(t.PreloadSize)), " Speed:", utils2.Format(t.DownloadSpeed), " Peers:[", t.Torrent.Stats().ConnectedSeeders, "]", t.Torrent.Stats().ActivePeers, "/", t.Torrent.Stats().TotalPeers)