diff options
| author | Chris Lu <chrislusf@users.noreply.github.com> | 2025-07-19 23:56:17 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2025-07-19 23:56:17 -0700 |
| commit | 530b6e5ef1e7ddea00e7c3a9949d2665024a3075 (patch) | |
| tree | e7b26e42d6230f623965eaa0ff260722ae800232 /weed/cluster/lock_manager/lock_ring.go | |
| parent | 12f50d37fa52444a43ad6ff4cc3d156db4035528 (diff) | |
| download | seaweedfs-530b6e5ef1e7ddea00e7c3a9949d2665024a3075.tar.xz seaweedfs-530b6e5ef1e7ddea00e7c3a9949d2665024a3075.zip | |
add CORS tests (#7001)
* add CORS tests
* parallel tests
* Always attempt compaction when compactSnapshots is called
* start servers
* fix port
* revert
* debug ports
* fix ports
* debug
* Update s3tests.yml
* Update s3tests.yml
* Update s3tests.yml
* Update s3tests.yml
* Update s3tests.yml
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 |