diff options
| author | chrislu <chris.lu@gmail.com> | 2024-05-05 14:16:26 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-05-05 14:16:26 -0700 |
| commit | 658d302aa4ecd43e1463f9ff54bdc0f29954b7d3 (patch) | |
| tree | a0f8d048109958dc8bbbeaa56a04b6900e70371f | |
| parent | a5645d50a70a5663d0671ec5677af3ce392c3ddb (diff) | |
| download | seaweedfs-658d302aa4ecd43e1463f9ff54bdc0f29954b7d3.tar.xz seaweedfs-658d302aa4ecd43e1463f9ff54bdc0f29954b7d3.zip | |
init candidate servers when setting a starting snapshot
| -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) |