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

storage/memorybysubnet: delete empty subnet buckets

Browse source
This commit is contained in:
Jimmy Zelinskie 2017-05-03 21:28:38 -04:00
parent cb6a3be2ac
commit b013106f89
1 changed files with 6 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
storage/memorybysubnet/peer_store.go
View file

@ -547,6 +547,9 @@ func (s *peerStore) collectGarbage(cutoff time.Time) error {
delete(shard.swarms[ih].leechers[subnet], pk) delete(shard.swarms[ih].leechers[subnet], pk)
} }
} }
if len(shard.swarms[ih].leechers[subnet]) == 0 {
delete(shard.swarms[ih].leechers, subnet)
}
} }
for subnet := range shard.swarms[ih].seeders { for subnet := range shard.swarms[ih].seeders {
@ -555,6 +558,9 @@ func (s *peerStore) collectGarbage(cutoff time.Time) error {
delete(shard.swarms[ih].seeders[subnet], pk) delete(shard.swarms[ih].seeders[subnet], pk)
} }
} }
if len(shard.swarms[ih].seeders[subnet]) == 0 {
delete(shard.swarms[ih].seeders, subnet)
}
} }
// TODO(jzelinskie): fix this to sum all peers in all subnets // TODO(jzelinskie): fix this to sum all peers in all subnets