status-im
/
torrent
mirror of
2
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Few slices name changes

This commit is contained in:
Matt Joiner 2016-07-12 17:49:00 +10:00
parent a1ba463750
commit 29844b8b6c
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
torrent.go
View File

@ -441,7 +441,7 @@ func (t *Torrent) writeStatus(w io.Writer, cl *Client) {
func() {
tw := tabwriter.NewWriter(w, 0, 0, 2, ' ', 0)
fmt.Fprintf(tw, " URL\tNext announce\tLast announce\n")
for _, ta := range slices.Sort(slices.FromElems(t.trackerAnnouncers), func(l, r *trackerScraper) bool {
for _, ta := range slices.Sort(slices.FromMapElems(t.trackerAnnouncers), func(l, r *trackerScraper) bool {
return l.url < r.url
}).([]*trackerScraper) {
fmt.Fprintf(tw, " %s\n", ta.statusLine())
@ -749,7 +749,7 @@ func (t *Torrent) extentPieces(off, _len int64) (pieces []int) {
// pieces, or has been in worser half of the established connections for more
// than a minute.
func (t *Torrent) worstBadConn() *connection {
wcs := slices.AsHeap(t.worstUnclosedConns(), worseConn)
wcs := slices.HeapInterface(t.worstUnclosedConns(), worseConn)
for wcs.Len() != 0 {
c := heap.Pop(wcs).(*connection)
if c.UnwantedChunksReceived >= 6 && c.UnwantedChunksReceived > c.UsefulChunksReceived {
@ -1339,7 +1339,7 @@ func (t *Torrent) SetMaxEstablishedConns(max int) (oldMax int) {
defer t.cl.mu.Unlock()
oldMax = t.maxEstablishedConns
t.maxEstablishedConns = max
wcs := slices.AsHeap(append([]*connection(nil), t.conns...), worseConn)
wcs := slices.HeapInterface(append([]*connection(nil), t.conns...), worseConn)
for len(t.conns) > t.maxEstablishedConns && wcs.Len() > 0 {
t.dropConnection(wcs.Pop().(*connection))
}