diff options
| -rw-r--r-- | internal/streamcache/cache.go | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/internal/streamcache/cache.go b/internal/streamcache/cache.go index 4c1b7c237..22b2969db 100644 --- a/internal/streamcache/cache.go +++ b/internal/streamcache/cache.go @@ -195,6 +195,8 @@ func (c *cache) clean() { } if c.removalCond != nil { + c.removalCond.L.Lock() + defer c.removalCond.L.Unlock() c.removalCond.Broadcast() } }() |