diff --git a/server/filestore.go b/server/filestore.go index 57f61806..8be8ff8e 100644 --- a/server/filestore.go +++ b/server/filestore.go @@ -3509,7 +3509,7 @@ func (fs *fileStore) removeMsg(seq uint64, secure, viaLimits, needFSLock bool) ( } cb := fs.scb - fs.mu.Unlock() + fsUnlock() // Storage updates. if cb != nil {