rnhmjoj/magnetico
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 1 Wiki Activity

a more sensible buffer (10) for newTorrents and add &then flush

Browse Source
This commit is contained in:
Bora M. Alper 2017-08-15 18:14:47 +03:00
parent cab372c504
commit 09d1a57a87
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/magneticod/persistence.go
View File

@ -77,7 +77,9 @@ func NewDatabase(rawurl string) (*Database, error) {
// AddNewTorrent adds a new torrent to the *queue* to be flushed to the persistent database. // AddNewTorrent adds a new torrent to the *queue* to be flushed to the persistent database.
func (db *Database) AddNewTorrent(torrent bittorrent.Metadata) error { func (db *Database) AddNewTorrent(torrent bittorrent.Metadata) error {
if len(db.newTorrents) >= 1 { db.newTorrents = append(db.newTorrents, torrent)
if len(db.newTorrents) >= 10 {
zap.L().Sugar().Debugf("newTorrents queue is full, attempting to commit %d torrents...", zap.L().Sugar().Debugf("newTorrents queue is full, attempting to commit %d torrents...",
len(db.newTorrents)) len(db.newTorrents))
if err := db.commitNewTorrents(); err != nil { if err := db.commitNewTorrents(); err != nil {
@ -85,7 +87,6 @@ func (db *Database) AddNewTorrent(torrent bittorrent.Metadata) error {
} }
} }
db.newTorrents = append(db.newTorrents, torrent)
return nil return nil
} }