apps/core
1
0
Fork 0
mirror of https://github.com/datarhei/core.git synced 2025-12-24 13:07:56 +08:00
Code Issues Packages Projects Releases Wiki Activity

Unlock before purging

Browse Source
This commit is contained in:
Ingo Oppermann
2025-07-23 14:16:06 +02:00
parent 46810bf64d
commit f1c0e7d796
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
restream/fs/fs.go
View File

@@ -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)
}