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

Merge branch 'master' into old-engine

Browse Source
This commit is contained in:
nikk gitanes
2023-02-16 21:13:12 +03:00
parent 88dcc2ce0e 109472a88e
commit 00af588470
1 changed files with 2 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
server/rutor/rutor.go
View File

@@ -116,25 +116,16 @@ func loadDB() {
return return
} }
var channel = make(chan *models.TorrentDetails, 0)
go func() {
for torr := range channel {
ftorrs = append(ftorrs, torr)
}
torrs = ftorrs
}()
for dec.More() { for dec.More() {
var torr *models.TorrentDetails var torr *models.TorrentDetails
err = dec.Decode(&torr) err = dec.Decode(&torr)
if err == nil { if err == nil {
channel <- torr ftorrs = append(ftorrs, torr)
} else { } else {
log.TLogln("Error read rutor db:", err) log.TLogln("Error read rutor db:", err)
} }
} }
close(channel) torrs = ftorrs
log.TLogln("Index rutor db") log.TLogln("Index rutor db")
torrsearch.NewIndex(torrs) torrsearch.NewIndex(torrs)
log.TLogln("Torrents count:", len(torrs)) log.TLogln("Torrents count:", len(torrs))