From: Tom Bergan Date: Wed, 29 Jun 2016 14:45:23 +0000 (-0700) Subject: crypto/tls: Use the same buffer size in the client and server in the TLS throughput... X-Git-Tag: go1.7rc1~26 X-Git-Url: http://www.git.cypherpunks.su/?a=commitdiff_plain;h=ad82f2cf4b7e8e5f5398b5546b7d834432347355;p=gostls13.git crypto/tls: Use the same buffer size in the client and server in the TLS throughput benchmark I believe it's necessary to use a buffer size smaller than 64KB because (at least some versions of) Window using a TCP receive window less than 64KB. Currently the client and server use buffer sizes of 16KB and 32KB, respectively (the server uses io.Copy, which defaults to 32KB internally). Since the server has been using 32KB, it should be safe for the client to do so as well. Fixes #15899 Change-Id: I36d44b29f2a5022c03fc086213d3c1adf153e983 Reviewed-on: https://go-review.googlesource.com/24581 Reviewed-by: Brad Fitzpatrick Run-TryBot: Brad Fitzpatrick TryBot-Result: Gobot Gobot --- diff --git a/src/crypto/tls/tls_test.go b/src/crypto/tls/tls_test.go index b4b5f4a1c6..48b46a003a 100644 --- a/src/crypto/tls/tls_test.go +++ b/src/crypto/tls/tls_test.go @@ -538,7 +538,12 @@ func throughput(b *testing.B, totalBytes int64, dynamicRecordSizingDisabled bool N := b.N + // Less than 64KB because Windows appears to use a TCP rwin < 64KB. + // See Issue #15899. + const bufsize = 32 << 10 + go func() { + buf := make([]byte, bufsize) for i := 0; i < N; i++ { sconn, err := ln.Accept() if err != nil { @@ -552,7 +557,9 @@ func throughput(b *testing.B, totalBytes int64, dynamicRecordSizingDisabled bool if err := srv.Handshake(); err != nil { panic(fmt.Errorf("handshake: %v", err)) } - io.Copy(srv, srv) + if _, err := io.CopyBuffer(srv, srv, buf); err != nil { + panic(fmt.Errorf("copy buffer: %v", err)) + } } }() @@ -560,7 +567,7 @@ func throughput(b *testing.B, totalBytes int64, dynamicRecordSizingDisabled bool clientConfig := testConfig.clone() clientConfig.DynamicRecordSizingDisabled = dynamicRecordSizingDisabled - buf := make([]byte, 1<<14) + buf := make([]byte, bufsize) chunks := int(math.Ceil(float64(totalBytes) / float64(len(buf)))) for i := 0; i < N; i++ { conn, err := Dial("tcp", ln.Addr().String(), clientConfig)