@ -609,6 +609,7 @@ func (t *http2Server) closeStream(s *Stream) {
|
|||||||
t.mu.Unlock()
|
t.mu.Unlock()
|
||||||
s.mu.Lock()
|
s.mu.Lock()
|
||||||
if s.state == streamDone {
|
if s.state == streamDone {
|
||||||
|
s.mu.Unlock()
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
s.state = streamDone
|
s.state = streamDone
|
||||||
|
Reference in New Issue
Block a user