forked from quic-go/quic-go
log stream GC
This commit is contained in:
@@ -641,6 +641,7 @@ func (s *Session) garbageCollectStreams() {
|
|||||||
s.windowUpdateManager.RemoveStream(k)
|
s.windowUpdateManager.RemoveStream(k)
|
||||||
}
|
}
|
||||||
if v.finished() {
|
if v.finished() {
|
||||||
|
utils.Debugf("Garbage-collecting stream %d", k)
|
||||||
atomic.AddUint32(&s.openStreamsCount, ^uint32(0)) // decrement
|
atomic.AddUint32(&s.openStreamsCount, ^uint32(0)) // decrement
|
||||||
s.streams[k] = nil
|
s.streams[k] = nil
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user