]> Sergey Matveev's repositories - btrtrc.git/commitdiff
Apply unconvert linter
authorMatt Joiner <anacrolix@gmail.com>
Mon, 4 Apr 2016 05:28:25 +0000 (15:28 +1000)
committerMatt Joiner <anacrolix@gmail.com>
Mon, 4 Apr 2016 05:28:25 +0000 (15:28 +1000)
client.go
torrent.go

index 5444cea25fcc469e84f547e740190893f40b8f7d..6ecfb13baf27fdb5c33abed2e793a3948169acaa 100644 (file)
--- a/client.go
+++ b/client.go
@@ -118,8 +118,8 @@ func (cl *Client) queuePieceCheck(t *Torrent, pieceIndex int) {
                return
        }
        piece.QueuedForHash = true
-       t.publishPieceChange(int(pieceIndex))
-       go cl.verifyPiece(t, int(pieceIndex))
+       t.publishPieceChange(pieceIndex)
+       go cl.verifyPiece(t, pieceIndex)
 }
 
 // Queue a piece check if one isn't already queued, and the piece has never
@@ -1377,7 +1377,7 @@ func (me *Client) connectionLoop(t *Torrent, c *connection) error {
                                                for i, cp := range pexMsg.Added {
                                                        p := Peer{
                                                                IP:     make([]byte, 4),
-                                                               Port:   int(cp.Port),
+                                                               Port:   cp.Port,
                                                                Source: peerSourcePEX,
                                                        }
                                                        if i < len(pexMsg.AddedFlags) && pexMsg.AddedFlags[i]&0x01 != 0 {
@@ -1958,12 +1958,12 @@ func (cl *Client) announceTorrentDHT(t *Torrent, impliedPort bool) {
                                        }
                                        addPeers = append(addPeers, Peer{
                                                IP:     cp.IP[:],
-                                               Port:   int(cp.Port),
+                                               Port:   cp.Port,
                                                Source: peerSourceDHT,
                                        })
                                        key := (&net.UDPAddr{
                                                IP:   cp.IP[:],
-                                               Port: int(cp.Port),
+                                               Port: cp.Port,
                                        }).String()
                                        allAddrs[key] = struct{}{}
                                }
@@ -2228,7 +2228,7 @@ func (me *Client) pieceHashed(t *Torrent, piece int, correct bool) {
                }
        }
        p.EverHashed = true
-       touchers := me.reapPieceTouches(t, int(piece))
+       touchers := me.reapPieceTouches(t, piece)
        if correct {
                err := p.Storage().MarkComplete()
                if err != nil {
@@ -2241,7 +2241,7 @@ func (me *Client) pieceHashed(t *Torrent, piece int, correct bool) {
                        me.dropConnection(t, c)
                }
        }
-       me.pieceChanged(t, int(piece))
+       me.pieceChanged(t, piece)
 }
 
 func (me *Client) onCompletedPiece(t *Torrent, piece int) {
index ae1a10d32ddc0a473548029167a0380a6d754990..4e0082a6c0eb049df752ddb631102e1662cdccbf 100644 (file)
@@ -351,7 +351,7 @@ func (t *Torrent) newMetadataExtensionMessage(c *connection, msgType int, piece
        }
        return pp.Message{
                Type:            pp.Extended,
-               ExtendedID:      byte(c.PeerExtensionIDs["ut_metadata"]),
+               ExtendedID:      c.PeerExtensionIDs["ut_metadata"],
                ExtendedPayload: append(p, data...),
        }
 }
@@ -643,7 +643,7 @@ func (t *Torrent) pieceLength(piece int) (len_ pp.Integer) {
        if piece < 0 || piece >= t.info.NumPieces() {
                return
        }
-       if int(piece) == t.numPieces()-1 {
+       if piece == t.numPieces()-1 {
                len_ = pp.Integer(t.length % t.info.PieceLength)
        }
        if len_ == 0 {