1
0
mirror of https://github.com/rancher/steve.git synced 2025-09-18 08:20:36 +00:00

Merge pull request #47 from jakefhyde/37353-backport-panic

[2.5] Prevent write on closed channel
This commit is contained in:
Caleb Bron
2022-04-13 16:12:23 -07:00
committed by GitHub

View File

@@ -80,6 +80,7 @@ func (s *SummaryCache) OnInboundRelationshipChange(ctx context.Context, schema *
s.cbs[id] = cb
go func() {
defer close(ret)
for rel := range cb {
if rel.Kind == kind &&
rel.APIVersion == apiVersion &&
@@ -94,7 +95,6 @@ func (s *SummaryCache) OnInboundRelationshipChange(ctx context.Context, schema *
s.Lock()
defer s.Unlock()
close(cb)
defer close(ret)
delete(s.cbs, id)
}()