mirror of
https://github.com/golang/net.git
synced 2026-03-31 10:27:08 +09:00
8d297f1cac
This change makes it easier to move x/net/http2 into std. Moving the http2 package into std and importing it from net/http (rather than bundling it as net/http/h2_bundle.go) requires removing the http2->net/http dependency. Moving tests into the http2_test package allows them to continue importing net/http without creating a cycle. Change-Id: If0799a94a6d2c90f02d7f391e352e14e6a6a6964 Reviewed-on: https://go-review.googlesource.com/c/net/+/749280 Auto-Submit: Damien Neil <dneil@google.com> Reviewed-by: Nicholas Husin <husin@google.com> LUCI-TryBot-Result: Go LUCI <golang-scoped@luci-project-accounts.iam.gserviceaccount.com> Reviewed-by: Nicholas Husin <nsh@golang.org>
100 lines
3.2 KiB
Go
100 lines
3.2 KiB
Go
// Copyright 2024 The Go Authors. All rights reserved.
|
|
// Use of this source code is governed by a BSD-style
|
|
// license that can be found in the LICENSE file.
|
|
|
|
package http2_test
|
|
|
|
import (
|
|
"net/http"
|
|
"testing"
|
|
"time"
|
|
|
|
. "golang.org/x/net/http2"
|
|
)
|
|
|
|
func TestConfigServerSettings(t *testing.T) { synctestTest(t, testConfigServerSettings) }
|
|
func testConfigServerSettings(t testing.TB) {
|
|
config := &http.HTTP2Config{
|
|
MaxConcurrentStreams: 1,
|
|
MaxDecoderHeaderTableSize: 1<<20 + 2,
|
|
MaxEncoderHeaderTableSize: 1<<20 + 3,
|
|
MaxReadFrameSize: 1<<20 + 4,
|
|
MaxReceiveBufferPerConnection: 64<<10 + 5,
|
|
MaxReceiveBufferPerStream: 64<<10 + 6,
|
|
}
|
|
const maxHeaderBytes = 4096 + 7
|
|
st := newServerTester(t, nil, func(s *http.Server) {
|
|
s.MaxHeaderBytes = maxHeaderBytes
|
|
s.HTTP2 = config
|
|
})
|
|
st.writePreface()
|
|
st.writeSettings()
|
|
st.wantSettings(map[SettingID]uint32{
|
|
SettingMaxConcurrentStreams: uint32(config.MaxConcurrentStreams),
|
|
SettingHeaderTableSize: uint32(config.MaxDecoderHeaderTableSize),
|
|
SettingInitialWindowSize: uint32(config.MaxReceiveBufferPerStream),
|
|
SettingMaxFrameSize: uint32(config.MaxReadFrameSize),
|
|
SettingMaxHeaderListSize: maxHeaderBytes + (32 * 10),
|
|
})
|
|
}
|
|
|
|
func TestConfigTransportSettings(t *testing.T) { synctestTest(t, testConfigTransportSettings) }
|
|
func testConfigTransportSettings(t testing.TB) {
|
|
config := &http.HTTP2Config{
|
|
MaxConcurrentStreams: 1, // ignored by Transport
|
|
MaxDecoderHeaderTableSize: 1<<20 + 2,
|
|
MaxEncoderHeaderTableSize: 1<<20 + 3,
|
|
MaxReadFrameSize: 1<<20 + 4,
|
|
MaxReceiveBufferPerConnection: 64<<10 + 5,
|
|
MaxReceiveBufferPerStream: 64<<10 + 6,
|
|
}
|
|
const maxHeaderBytes = 4096 + 7
|
|
tc := newTestClientConn(t, func(tr *http.Transport) {
|
|
tr.HTTP2 = config
|
|
tr.MaxResponseHeaderBytes = maxHeaderBytes
|
|
})
|
|
tc.wantSettings(map[SettingID]uint32{
|
|
SettingHeaderTableSize: uint32(config.MaxDecoderHeaderTableSize),
|
|
SettingInitialWindowSize: uint32(config.MaxReceiveBufferPerStream),
|
|
SettingMaxFrameSize: uint32(config.MaxReadFrameSize),
|
|
SettingMaxHeaderListSize: maxHeaderBytes + (32 * 10),
|
|
})
|
|
tc.wantWindowUpdate(0, uint32(config.MaxReceiveBufferPerConnection))
|
|
}
|
|
|
|
func TestConfigPingTimeoutServer(t *testing.T) { synctestTest(t, testConfigPingTimeoutServer) }
|
|
func testConfigPingTimeoutServer(t testing.TB) {
|
|
st := newServerTester(t, func(w http.ResponseWriter, r *http.Request) {
|
|
}, func(s *Server) {
|
|
s.ReadIdleTimeout = 2 * time.Second
|
|
s.PingTimeout = 3 * time.Second
|
|
})
|
|
st.greet()
|
|
|
|
time.Sleep(2 * time.Second)
|
|
_ = readFrame[*PingFrame](t, st)
|
|
time.Sleep(3 * time.Second)
|
|
st.wantClosed()
|
|
}
|
|
|
|
func TestConfigPingTimeoutTransport(t *testing.T) { synctestTest(t, testConfigPingTimeoutTransport) }
|
|
func testConfigPingTimeoutTransport(t testing.TB) {
|
|
tc := newTestClientConn(t, func(tr *Transport) {
|
|
tr.ReadIdleTimeout = 2 * time.Second
|
|
tr.PingTimeout = 3 * time.Second
|
|
})
|
|
tc.greet()
|
|
|
|
req, _ := http.NewRequest("GET", "https://dummy.tld/", nil)
|
|
rt := tc.roundTrip(req)
|
|
tc.wantFrameType(FrameHeaders)
|
|
|
|
time.Sleep(2 * time.Second)
|
|
tc.wantFrameType(FramePing)
|
|
time.Sleep(3 * time.Second)
|
|
err := rt.err()
|
|
if err == nil {
|
|
t.Fatalf("expected connection to close")
|
|
}
|
|
}
|