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

fix passing of peer slices by reference

Browse source
This commit is contained in:
Jimmy Zelinskie 2014-06-29 01:23:55 -04:00
parent 3999e35453
commit ac45708bfd
1 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
server/serve_announce.go
View file

@ -227,17 +227,17 @@ func writePeersCompact(w io.Writer, a *models.Announce, u *models.User, t *model
func getPeers(a *models.Announce, u *models.User, t *models.Torrent, peerCount int) (ipv4s, ipv6s []*models.Peer) { func getPeers(a *models.Announce, u *models.User, t *models.Torrent, peerCount int) (ipv4s, ipv6s []*models.Peer) {
if a.Left == 0 { if a.Left == 0 {
// If they're seeding, give them only leechers. // If they're seeding, give them only leechers.
splitPeers(ipv4s, ipv6s, u, t.Leechers, peerCount) splitPeers(&ipv4s, &ipv6s, u, t.Leechers, peerCount)
} else { } else {
// If they're leeching, prioritize giving them seeders. // If they're leeching, prioritize giving them seeders.
count := splitPeers(ipv4s, ipv6s, u, t.Seeders, peerCount) count := splitPeers(&ipv4s, &ipv6s, u, t.Seeders, peerCount)
splitPeers(ipv4s, ipv6s, u, t.Leechers, peerCount-count) splitPeers(&ipv4s, &ipv6s, u, t.Leechers, peerCount-count)
} }
return return
} }
func splitPeers(ipv4s, ipv6s []*models.Peer, u *models.User, peers map[string]models.Peer, peerCount int) (count int) { func splitPeers(ipv4s, ipv6s *[]*models.Peer, u *models.User, peers map[string]models.Peer, peerCount int) (count int) {
for _, peer := range peers { for _, peer := range peers {
if count >= peerCount { if count >= peerCount {
break break
@ -248,9 +248,9 @@ func splitPeers(ipv4s, ipv6s []*models.Peer, u *models.User, peers map[string]mo
} }
if ip := peer.IP.To4(); ip != nil { if ip := peer.IP.To4(); ip != nil {
ipv4s = append(ipv4s, &peer) *ipv4s = append(*ipv4s, &peer)
} else { } else {
ipv6s = append(ipv6s, &peer) *ipv6s = append(*ipv6s, &peer)
} }
count++ count++