Removing unnecessary change to http2_server
This commit is contained in:
@ -824,7 +824,6 @@ func (t *http2Server) closeStream(s *Stream) {
|
|||||||
// goroutines (e.g., bi-directional streaming), cancel needs to be
|
// goroutines (e.g., bi-directional streaming), cancel needs to be
|
||||||
// called to interrupt the potential blocking on other goroutines.
|
// called to interrupt the potential blocking on other goroutines.
|
||||||
s.cancel()
|
s.cancel()
|
||||||
|
|
||||||
s.mu.Lock()
|
s.mu.Lock()
|
||||||
if q := s.fc.resetPendingData(); q > 0 {
|
if q := s.fc.resetPendingData(); q > 0 {
|
||||||
if w := t.fc.onRead(q); w > 0 {
|
if w := t.fc.onRead(q); w > 0 {
|
||||||
|
Reference in New Issue
Block a user