diff options
| -rw-r--r-- | weed/cluster/lock_manager/lock_ring.go | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/weed/cluster/lock_manager/lock_ring.go b/weed/cluster/lock_manager/lock_ring.go index 808f559ee..e7f60e6d2 100644 --- a/weed/cluster/lock_manager/lock_ring.go +++ b/weed/cluster/lock_manager/lock_ring.go @@ -79,6 +79,10 @@ func (r *LockRing) SetSnapshot(servers []pb.ServerAddress) { r.Lock() r.lastUpdateTime = time.Now() + // init candidateServers + for _, server := range servers { + r.candidateServers[server] = struct{}{} + } r.Unlock() r.addOneSnapshot(servers) |