From: Matt Joiner <anacrolix@gmail.com>
Date: Fri, 17 Dec 2021 21:58:56 +0000 (+1100)
Subject: gofumpt -extra
X-Git-Tag: v1.40.0~13
X-Git-Url: http://www.git.stargrave.org/?a=commitdiff_plain;h=bdb33ef9f784ed847e285f08da359f02b4e8f91e;p=btrtrc.git

gofumpt -extra
---

diff --git a/client.go b/client.go
index a3f55c6f..a6de6c08 100644
--- a/client.go
+++ b/client.go
@@ -583,7 +583,7 @@ func countDialResult(err error) {
 	}
 }
 
-func reducedDialTimeout(minDialTimeout, max time.Duration, halfOpenLimit int, pendingPeers int) (ret time.Duration) {
+func reducedDialTimeout(minDialTimeout, max time.Duration, halfOpenLimit, pendingPeers int) (ret time.Duration) {
 	ret = max / time.Duration((pendingPeers+halfOpenLimit)/halfOpenLimit)
 	if ret < minDialTimeout {
 		ret = minDialTimeout
diff --git a/client_test.go b/client_test.go
index 86023fb6..cbfe48bb 100644
--- a/client_test.go
+++ b/client_test.go
@@ -647,7 +647,7 @@ func TestSetMaxEstablishedConn(t *testing.T) {
 
 // Creates a file containing its own name as data. Make a metainfo from that, adds it to the given
 // client, and returns a magnet link.
-func makeMagnet(t *testing.T, cl *Client, dir string, name string) string {
+func makeMagnet(t *testing.T, cl *Client, dir, name string) string {
 	os.MkdirAll(dir, 0o770)
 	file, err := os.Create(filepath.Join(dir, name))
 	require.NoError(t, err)
@@ -684,7 +684,7 @@ func TestMultipleTorrentsWithEncryption(t *testing.T) {
 
 // Test that the leecher can download a torrent in its entirety from the seeder. Note that the
 // seeder config is done first.
-func testSeederLeecherPair(t *testing.T, seeder func(*ClientConfig), leecher func(*ClientConfig)) {
+func testSeederLeecherPair(t *testing.T, seeder, leecher func(*ClientConfig)) {
 	cfg := TestingConfig(t)
 	cfg.Seed = true
 	cfg.DataDir = filepath.Join(cfg.DataDir, "server")
diff --git a/misc.go b/misc.go
index 4a6e1deb..139af2d4 100644
--- a/misc.go
+++ b/misc.go
@@ -43,7 +43,7 @@ func newRequestFromMessage(msg *pp.Message) Request {
 }
 
 // The size in bytes of a metadata extension piece.
-func metadataPieceSize(totalSize int, piece int) int {
+func metadataPieceSize(totalSize, piece int) int {
 	ret := totalSize - piece*(1<<14)
 	if ret > 1<<14 {
 		ret = 1 << 14
@@ -99,7 +99,7 @@ func validateInfo(info *metainfo.Info) error {
 	return nil
 }
 
-func chunkIndexSpec(index pp.Integer, pieceLength, chunkSize pp.Integer) ChunkSpec {
+func chunkIndexSpec(index, pieceLength, chunkSize pp.Integer) ChunkSpec {
 	ret := ChunkSpec{pp.Integer(index) * chunkSize, chunkSize}
 	if ret.Begin+ret.Length > pieceLength {
 		ret.Length = pieceLength - ret.Begin
diff --git a/mse/mse.go b/mse/mse.go
index 522612c9..a5477b8f 100644
--- a/mse/mse.go
+++ b/mse/mse.go
@@ -69,7 +69,7 @@ func hash(parts ...[]byte) []byte {
 	return h.Sum(nil)
 }
 
-func newEncrypt(initer bool, s []byte, skey []byte) (c *rc4.Cipher) {
+func newEncrypt(initer bool, s, skey []byte) (c *rc4.Cipher) {
 	c, err := rc4.NewCipher(hash([]byte(func() string {
 		if initer {
 			return "keyA"
@@ -542,7 +542,7 @@ func (h *handshake) Do() (ret io.ReadWriter, method CryptoMethod, err error) {
 }
 
 func InitiateHandshake(
-	rw io.ReadWriter, skey []byte, initialPayload []byte, cryptoProvides CryptoMethod,
+	rw io.ReadWriter, skey, initialPayload []byte, cryptoProvides CryptoMethod,
 ) (
 	ret io.ReadWriter, method CryptoMethod, err error,
 ) {
diff --git a/mse/mse_test.go b/mse/mse_test.go
index c7e3bd57..a38e9cc1 100644
--- a/mse/mse_test.go
+++ b/mse/mse_test.go
@@ -146,7 +146,7 @@ func fillRand(t testing.TB, bs ...[]byte) {
 	}
 }
 
-func readAndWrite(rw io.ReadWriter, r []byte, w []byte) error {
+func readAndWrite(rw io.ReadWriter, r, w []byte) error {
 	var wg sync.WaitGroup
 	wg.Add(1)
 	var wErr error
diff --git a/peer_protocol/handshake.go b/peer_protocol/handshake.go
index c0b0319d..acdc3da5 100644
--- a/peer_protocol/handshake.go
+++ b/peer_protocol/handshake.go
@@ -124,7 +124,7 @@ func Handshake(
 		return res, errors.New("unexpected protocol string")
 	}
 
-	copyExact := func(dst []byte, src []byte) {
+	copyExact := func(dst, src []byte) {
 		if dstLen, srcLen := uint64(len(dst)), uint64(len(src)); dstLen != srcLen {
 			panic("dst len " + strconv.FormatUint(dstLen, 10) + " != src len " + strconv.FormatUint(srcLen, 10))
 		}
diff --git a/peerconn.go b/peerconn.go
index 423d4e8b..4a299714 100644
--- a/peerconn.go
+++ b/peerconn.go
@@ -235,7 +235,7 @@ func (cn *Peer) cumInterest() time.Duration {
 	return ret
 }
 
-func (cn *PeerConn) peerHasAllPieces() (all bool, known bool) {
+func (cn *PeerConn) peerHasAllPieces() (all, known bool) {
 	if cn.peerSentHaveAll {
 		return true, true
 	}
diff --git a/wstracker.go b/wstracker.go
index 396b5aa5..5338ceb9 100644
--- a/wstracker.go
+++ b/wstracker.go
@@ -2,11 +2,12 @@ package torrent
 
 import (
 	"fmt"
+	"net/url"
+	"sync"
+
 	"github.com/anacrolix/log"
 	"github.com/anacrolix/torrent/tracker/http"
 	"github.com/gorilla/websocket"
-	"net/url"
-	"sync"
 
 	"github.com/anacrolix/torrent/tracker"
 	"github.com/anacrolix/torrent/webtorrent"