LBRYCommunity/tracker
1
0
Fork 0
Code Issues 1 Pull requests Projects Releases Packages Wiki Activity

Implement *Reaped stats

Browse source
This commit is contained in:
Justin Li 2014-07-22 01:44:36 -04:00
parent 38d2c91ff1
commit 539a1b3774
1 changed files with 14 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
tracker/memory/conn.go
View file

@ -8,6 +8,7 @@ import (
"runtime" "runtime"
"time" "time"
"github.com/chihaya/chihaya/stats"
"github.com/chihaya/chihaya/tracker" "github.com/chihaya/chihaya/tracker"
"github.com/chihaya/chihaya/tracker/models" "github.com/chihaya/chihaya/tracker/models"
) )
@ -270,12 +271,24 @@ func (c *Conn) PurgeInactivePeers(purgeEmptyTorrents bool, before time.Time) err
for key, peer := range torrent.Seeders { for key, peer := range torrent.Seeders {
if peer.LastAnnounce <= unixtime { if peer.LastAnnounce <= unixtime {
delete(torrent.Seeders, key) delete(torrent.Seeders, key)
if peer.IPv4() {
stats.RecordEvent(stats.ReapedSeedIPv4)
} else {
stats.RecordEvent(stats.ReapedSeedIPv6)
}
} }
} }
for key, peer := range torrent.Leechers { for key, peer := range torrent.Leechers {
if peer.LastAnnounce <= unixtime { if peer.LastAnnounce <= unixtime {
delete(torrent.Leechers, key) delete(torrent.Leechers, key)
if peer.IPv4() {
stats.RecordEvent(stats.ReapedLeechIPv4)
} else {
stats.RecordEvent(stats.ReapedLeechIPv6)
}
} }
} }
@ -284,6 +297,7 @@ func (c *Conn) PurgeInactivePeers(purgeEmptyTorrents bool, before time.Time) err
if purgeEmptyTorrents && peers == 0 { if purgeEmptyTorrents && peers == 0 {
c.PurgeInactiveTorrent(infohash) c.PurgeInactiveTorrent(infohash)
stats.RecordEvent(stats.ReapedTorrent)
} }
} }