quic: inbound connection-level flow control
Track the peer's connection level flow control window.
Update the window with MAX_DATA frames as data is consumed by the user.
Adjust shouldUpdateFlowControl so that we can use the same algorithm
for both stream-level and connection-level flow control.
The new algorithm is to send an update when doing so extends the
peer's window by at least 1/8 of the maximum window size.
For golang/go#58547
Change-Id: I2d8d82d06f0cb4b2ac25b3396c3cf4126a96e9cc
Reviewed-on: https://go-review.googlesource.com/c/net/+/526716
LUCI-TryBot-Result: Go LUCI <golang-scoped@luci-project-accounts.iam.gserviceaccount.com>
Reviewed-by: Jonathan Amsterdam <jba@google.com>
diff --git a/internal/quic/config_test.go b/internal/quic/config_test.go
index b99ffef..d292854 100644
--- a/internal/quic/config_test.go
+++ b/internal/quic/config_test.go
@@ -10,6 +10,7 @@
func TestConfigTransportParameters(t *testing.T) {
const (
+ wantInitialMaxData = int64(1)
wantInitialMaxStreamData = int64(2)
wantInitialMaxStreamsBidi = int64(3)
wantInitialMaxStreamsUni = int64(4)
@@ -18,12 +19,16 @@
c.MaxBidiRemoteStreams = wantInitialMaxStreamsBidi
c.MaxUniRemoteStreams = wantInitialMaxStreamsUni
c.MaxStreamReadBufferSize = wantInitialMaxStreamData
+ c.MaxConnReadBufferSize = wantInitialMaxData
})
tc.handshake()
if tc.sentTransportParameters == nil {
t.Fatalf("conn didn't send transport parameters during handshake")
}
p := tc.sentTransportParameters
+ if got, want := p.initialMaxData, wantInitialMaxData; got != want {
+ t.Errorf("initial_max_data = %v, want %v", got, want)
+ }
if got, want := p.initialMaxStreamDataBidiLocal, wantInitialMaxStreamData; got != want {
t.Errorf("initial_max_stream_data_bidi_local = %v, want %v", got, want)
}
