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

Trigger piece request order changes on connections in a few spots 

The client was requesting already obtained data in certain circumstances. This fixes it.
This commit is contained in:
Matt Joiner 2016-02-11 17:57:57 +11:00
parent 65fd332afd
commit b514434581
2 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
client.go
View File

@ -2497,7 +2497,9 @@ func (me *Client) pieceChanged(t *torrent, piece int) {
} else {
me.onFailedPiece(t, piece)
}
t.updatePiecePriority(piece)
if t.updatePiecePriority(piece) {
t.piecePriorityChanged(piece)
}
t.publishPieceChange(piece)
}

6
torrent.go
View File

@ -860,6 +860,8 @@ func (t *torrent) updatePiecePriority(piece int) bool {
return true
}
// Update all piece priorities in one hit. This function should have the same
// output as updatePiecePriority, but across all pieces.
func (t *torrent) updatePiecePriorities() {
newPrios := make([]piecePriority, t.numPieces())
t.pendingPieces.IterTyped(func(piece int) (more bool) {
@ -875,8 +877,10 @@ func (t *torrent) updatePiecePriorities() {
}
return true
})
// TODO: Do I need a pass suppressing stuff that we already have?
for i, prio := range newPrios {
if t.pieceComplete(i) {
prio = PiecePriorityNone
}
if prio != t.Pieces[i].priority {
t.Pieces[i].priority = prio
t.piecePriorityChanged(i)