aboutsummaryrefslogtreecommitdiff
path: root/weed/cluster/lock_manager/distributed_lock_manager.go
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2023-06-25 14:17:58 -0700
committerchrislu <chris.lu@gmail.com>2023-06-25 14:17:58 -0700
commit26eff062c88581cad9e1a784c985535f7a897ba0 (patch)
tree851a3b141277637119e2a789b2b6c31504a9b0f1 /weed/cluster/lock_manager/distributed_lock_manager.go
parent464a71a37359e4b7ce5e101431ecbbdfe199f209 (diff)
downloadseaweedfs-26eff062c88581cad9e1a784c985535f7a897ba0.tar.xz
seaweedfs-26eff062c88581cad9e1a784c985535f7a897ba0.zip
refactor
Diffstat (limited to 'weed/cluster/lock_manager/distributed_lock_manager.go')
-rw-r--r--weed/cluster/lock_manager/distributed_lock_manager.go8
1 files changed, 4 insertions, 4 deletions
diff --git a/weed/cluster/lock_manager/distributed_lock_manager.go b/weed/cluster/lock_manager/distributed_lock_manager.go
index 0bcc7b02d..a76de9e4a 100644
--- a/weed/cluster/lock_manager/distributed_lock_manager.go
+++ b/weed/cluster/lock_manager/distributed_lock_manager.go
@@ -15,7 +15,7 @@ func NewDistributedLockManager() *DistributedLockManager {
}
func (dlm *DistributedLockManager) Lock(host pb.ServerAddress, key string, expiredAtNs int64, token string, servers []pb.ServerAddress) (renewToken string, movedTo pb.ServerAddress, err error) {
- server := HashKeyToServer(key, servers)
+ server := hashKeyToServer(key, servers)
if server != host {
movedTo = server
return
@@ -25,7 +25,7 @@ func (dlm *DistributedLockManager) Lock(host pb.ServerAddress, key string, expir
}
func (dlm *DistributedLockManager) Unlock(host pb.ServerAddress, key string, token string, servers []pb.ServerAddress) (movedTo pb.ServerAddress, err error) {
- server := HashKeyToServer(key, servers)
+ server := hashKeyToServer(key, servers)
if server != host {
movedTo = server
return
@@ -41,10 +41,10 @@ func (dlm *DistributedLockManager) InsertLock(key string, expiredAtNs int64, tok
}
func (dlm *DistributedLockManager) SelectNotOwnedLocks(host pb.ServerAddress, servers []pb.ServerAddress) (locks []*Lock) {
return dlm.lockManager.SelectLocks(func(key string) bool {
- server := HashKeyToServer(key, servers)
+ server := hashKeyToServer(key, servers)
return server != host
})
}
func (dlm *DistributedLockManager) CalculateTargetServer(key string, servers []pb.ServerAddress) pb.ServerAddress {
- return HashKeyToServer(key, servers)
+ return hashKeyToServer(key, servers)
}