diff options
Diffstat (limited to 'weed/cluster/lock_manager/lock_ring.go')
| -rw-r--r-- | weed/cluster/lock_manager/lock_ring.go | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/weed/cluster/lock_manager/lock_ring.go b/weed/cluster/lock_manager/lock_ring.go index a36c8e222..398f26153 100644 --- a/weed/cluster/lock_manager/lock_ring.go +++ b/weed/cluster/lock_manager/lock_ring.go @@ -138,9 +138,8 @@ func (r *LockRing) compactSnapshots() { r.Lock() defer r.Unlock() - if r.lastCompactTime.After(r.lastUpdateTime) { - return - } + // Always attempt compaction when called, regardless of lastCompactTime + // This ensures proper cleanup even with multiple concurrent compaction requests ts := time.Now() // remove old snapshots |