]> Sergey Matveev's repositories - btrtrc.git/commitdiff
Infer pp.Decoder.MaxLength from chunk size (#743)
authorAlex Sharov <AskAlexSharov@gmail.com>
Sun, 8 May 2022 01:36:43 +0000 (08:36 +0700)
committerGitHub <noreply@github.com>
Sun, 8 May 2022 01:36:43 +0000 (11:36 +1000)
peerconn.go

index 23f2aa5e377e719d6f1be9b263a0bf82daaea12d..41b3f113f297e2c23d797f0b7e533003732a694a 100644 (file)
@@ -1117,7 +1117,7 @@ func (c *PeerConn) mainReadLoop() (err error) {
 
        decoder := pp.Decoder{
                R:         bufio.NewReaderSize(c.r, 1<<17),
-               MaxLength: 256 * 1024,
+               MaxLength: 4 * pp.Integer(max(int64(t.chunkSize), defaultChunkSize)),
                Pool:      &t.chunkPool,
        }
        for {