]> Sergey Matveev's repositories - btrtrc.git/commitdiff
Remove unused conn piece inclinations
authorMatt Joiner <anacrolix@gmail.com>
Mon, 1 Nov 2021 00:49:27 +0000 (11:49 +1100)
committerMatt Joiner <anacrolix@gmail.com>
Mon, 1 Nov 2021 00:49:27 +0000 (11:49 +1100)
torrent.go

index 93d7d5f4a5795155adf548a71cc7dea7d634fd05..1db0d4010602c4132b3601470ab271a37aa44f2e 100644 (file)
@@ -8,7 +8,6 @@ import (
        "errors"
        "fmt"
        "io"
-       "math/rand"
        "net/http"
        "net/url"
        "sort"
@@ -139,11 +138,6 @@ type Torrent struct {
        activePieceHashes         int
        initialPieceCheckDisabled bool
 
-       // A pool of piece priorities []int for assignment to new connections.
-       // These "inclinations" are used to give connections preference for
-       // different pieces.
-       connPieceInclinationPool sync.Pool
-
        // Count of each request across active connections.
        pendingRequests pendingRequests
        // Chunks we've written to since the corresponding piece was last checked.
@@ -1222,21 +1216,6 @@ func (t *Torrent) openNewConns() (initiated int) {
        return
 }
 
-func (t *Torrent) getConnPieceInclination() []int {
-       _ret := t.connPieceInclinationPool.Get()
-       if _ret == nil {
-               pieceInclinationsNew.Add(1)
-               return rand.Perm(int(t.numPieces()))
-       }
-       pieceInclinationsReused.Add(1)
-       return *_ret.(*[]int)
-}
-
-func (t *Torrent) putPieceInclination(pi []int) {
-       t.connPieceInclinationPool.Put(&pi)
-       pieceInclinationsPut.Add(1)
-}
-
 func (t *Torrent) updatePieceCompletion(piece pieceIndex) bool {
        p := t.piece(piece)
        uncached := t.pieceCompleteUncached(piece)