golang
diff --git a/Collapse file
‎internal/quic/conn_flow.go‎
Copy file name to clipboardExpand all lines: internal/quic/conn_flow.go
+1Lines changed: 1 addition & 0 deletions b/Collapse file
‎internal/quic/conn_flow.go‎
Copy file name to clipboardExpand all lines: internal/quic/conn_flow.go
+1Lines changed: 1 addition & 0 deletions
diff --git a/Collapse file
‎internal/quic/conn_flow_test.go‎
Copy file name to clipboardExpand all lines: internal/quic/conn_flow_test.go
+10Lines changed: 10 additions & 0 deletions b/Collapse file
‎internal/quic/conn_flow_test.go‎
Copy file name to clipboardExpand all lines: internal/quic/conn_flow_test.go
+10Lines changed: 10 additions & 0 deletions
@@ -106,6 +106,7 @@ func (c *Conn) appendMaxDataFrame(w *packetWriter, pnum packetNumber, pto bool)
 		if !w.appendMaxDataFrame(c.streams.inflow.newLimit) {
 			return false
 		}
+		c.streams.inflow.sentLimit += c.streams.inflow.newLimit
 		c.streams.inflow.sent.setSent(pnum)
 	}
 	return true
 
@@ -35,6 +35,16 @@ func TestConnInflowReturnOnRead(t *testing.T) {
 		packetType1RTT, debugFrameMaxData{
 			max: 128,
 		})
+	// Peer can write up to the new limit.
+	tc.writeFrames(packetType1RTT, debugFrameStream{
+		id:   s.id,
+		off:  64,
+		data: make([]byte, 64),
+	})
+	tc.wantIdle("connection is idle")
+	if n, err := s.ReadContext(ctx, make([]byte, 64)); n != 64 || err != nil {
+		t.Fatalf("offset 64: s.Read() = %v, %v; want %v, nil", n, err, 64)
+	}
 }
 
 func TestConnInflowReturnOnRacingReads(t *testing.T) {
Original file line number	Diff line number	Diff line change
`@@ -106,6 +106,7 @@ func (c Conn) appendMaxDataFrame(w packetWriter, pnum packetNumber, pto bool)`
`106`	`106`	`if !w.appendMaxDataFrame(c.streams.inflow.newLimit) {`
`107`	`107`	`return false`
`108`	`108`	`}`
	`109`	`+ c.streams.inflow.sentLimit += c.streams.inflow.newLimit`
`109`	`110`	`c.streams.inflow.sent.setSent(pnum)`
`110`	`111`	`}`
`111`	`112`	`return true`