diff options
| author | M@ <m@cognusion.com> | 2024-04-25 02:18:28 -0400 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-04-24 23:18:28 -0700 |
| commit | 855607c5360c788959d8a6bfd0225a75b63dc51f (patch) | |
| tree | d32b528888c5c94c9655af00c6b1492b42822c10 | |
| parent | 607927da60081f0b98d22d52f7e4da2bd16ca9ed (diff) | |
| download | seaweedfs-855607c5360c788959d8a6bfd0225a75b63dc51f.tar.xz seaweedfs-855607c5360c788959d8a6bfd0225a75b63dc51f.zip | |
Fixes race with unlocked setter. (#5532)
| -rw-r--r-- | weed/cluster/lock_manager/lock_ring.go | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/weed/cluster/lock_manager/lock_ring.go b/weed/cluster/lock_manager/lock_ring.go index c59aab184..9edee1e96 100644 --- a/weed/cluster/lock_manager/lock_ring.go +++ b/weed/cluster/lock_manager/lock_ring.go @@ -72,7 +72,9 @@ func (r *LockRing) SetSnapshot(servers []pb.ServerAddress) { return servers[i] < servers[j] }) + r.Lock() r.lastUpdateTime = time.Now() + r.Unlock() r.addOneSnapshot(servers) |