diff --git a/transport/http2_server.go b/transport/http2_server.go index 472d5614..f5c590f4 100644 --- a/transport/http2_server.go +++ b/transport/http2_server.go @@ -824,7 +824,6 @@ func (t *http2Server) closeStream(s *Stream) { // goroutines (e.g., bi-directional streaming), cancel needs to be // called to interrupt the potential blocking on other goroutines. s.cancel() - s.mu.Lock() if q := s.fc.resetPendingData(); q > 0 { if w := t.fc.onRead(q); w > 0 {