diff --git a/restream/fs/fs.go b/restream/fs/fs.go index c8d37577..793db9b0 100644 --- a/restream/fs/fs.go +++ b/restream/fs/fs.go @@ -133,7 +133,6 @@ func (rfs *filesystem) UpdateCleanup(id string, newPatterns []Pattern, purge boo newPatterns = rfs.compilePatterns(newPatterns) rfs.cleanupLock.Lock() - defer rfs.cleanupLock.Unlock() currentPatterns := rfs.cleanupPatterns[id] delete(rfs.cleanupPatterns, id) @@ -176,6 +175,8 @@ func (rfs *filesystem) UpdateCleanup(id string, newPatterns []Pattern, purge boo }).Log("Remove pattern") } + rfs.cleanupLock.Unlock() + if purge { rfs.purge(onlyCurrent) }