Fixes race with unlocked setter. (#5532)

10 months ago · 855607c536
1 changed files with 2 additions and 0 deletions
--- 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)