Switched local var to deepcopy

grpc · Sep 13, 2022 · 9bd4117 · 9bd4117
1 parent 98cddf6
commit 9bd4117
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/internal/transport/http2_client.go b/internal/transport/http2_client.go
@@ -1233,7 +1233,11 @@ func (t *http2Client) handleGoAway(f *http2.GoAwayFrame) {
 		upperLimit = math.MaxUint32 // Kill all streams after the GoAway ID.
 	}
 
-	activeStreams := t.activeStreams
+	activeStreams := make(map[uint32]*Stream)
+	for streamID, stream  := range t.activeStreams {
+		activeStreams[streamID] = stream
+	}
+
 	t.prevGoAwayID = id
 	t.mu.Unlock()
 	for streamID, stream := range activeStreams {