lsm/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2025-05-03 13:07:48 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

log

Browse Source
This commit is contained in:
chrislu 2024-05-05 12:19:31 -07:00
parent f5f3b60a13
commit 253ec73a17
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
weed/cluster/lock_manager/lock_ring.go
View File

@ -1,6 +1,7 @@
package lock_manager package lock_manager
import ( import (
"github.com/seaweedfs/seaweedfs/weed/glog"
"github.com/seaweedfs/seaweedfs/weed/pb" "github.com/seaweedfs/seaweedfs/weed/pb"
"github.com/seaweedfs/seaweedfs/weed/util" "github.com/seaweedfs/seaweedfs/weed/util"
"sort" "sort"
@ -39,9 +40,11 @@ func (r *LockRing) SetTakeSnapshotCallback(onTakeSnapshot func(snapshot []pb.Ser
// AddServer adds a server to the ring // AddServer adds a server to the ring
// if the previous snapshot passed the snapshot interval, create a new snapshot // if the previous snapshot passed the snapshot interval, create a new snapshot
func (r *LockRing) AddServer(server pb.ServerAddress) { func (r *LockRing) AddServer(server pb.ServerAddress) {
glog.V(0).Infof("add server %v", server)
r.Lock() r.Lock()
if _, found := r.candidateServers[server]; found { if _, found := r.candidateServers[server]; found {
glog.V(0).Infof("add server: already exists %v", server)
r.Unlock() r.Unlock()
return return
} }
@ -53,6 +56,8 @@ func (r *LockRing) AddServer(server pb.ServerAddress) {
} }
func (r *LockRing) RemoveServer(server pb.ServerAddress) { func (r *LockRing) RemoveServer(server pb.ServerAddress) {
glog.V(0).Infof("remove server %v", server)
r.Lock() r.Lock()
if _, found := r.candidateServers[server]; !found { if _, found := r.candidateServers[server]; !found {