aboutsummaryrefslogtreecommitdiff
path: root/weed/cluster/lock_manager/distributed_lock_manager.go
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2024-02-02 15:54:57 -0800
committerchrislu <chris.lu@gmail.com>2024-02-02 15:54:57 -0800
commitd41792461cfaae905808ec5f9a602a81f5e1cb5c (patch)
treeedcf74fe1b3752bb3a9980e163f59efac6be0a6e /weed/cluster/lock_manager/distributed_lock_manager.go
parentd30150dde18c21c3c3af97cd935da27e2213f8cf (diff)
downloadseaweedfs-d41792461cfaae905808ec5f9a602a81f5e1cb5c.tar.xz
seaweedfs-d41792461cfaae905808ec5f9a602a81f5e1cb5c.zip
lock returns host and owner
Diffstat (limited to 'weed/cluster/lock_manager/distributed_lock_manager.go')
-rw-r--r--weed/cluster/lock_manager/distributed_lock_manager.go4
1 files changed, 2 insertions, 2 deletions
diff --git a/weed/cluster/lock_manager/distributed_lock_manager.go b/weed/cluster/lock_manager/distributed_lock_manager.go
index 43e836461..6676c0a67 100644
--- a/weed/cluster/lock_manager/distributed_lock_manager.go
+++ b/weed/cluster/lock_manager/distributed_lock_manager.go
@@ -25,7 +25,7 @@ func NewDistributedLockManager(host pb.ServerAddress) *DistributedLockManager {
}
}
-func (dlm *DistributedLockManager) LockWithTimeout(key string, expiredAtNs int64, token string, owner string) (renewToken string, movedTo pb.ServerAddress, err error) {
+func (dlm *DistributedLockManager) LockWithTimeout(key string, expiredAtNs int64, token string, owner string) (lockOwner string, renewToken string, movedTo pb.ServerAddress, err error) {
movedTo, err = dlm.findLockOwningFiler(key)
if err != nil {
return
@@ -33,7 +33,7 @@ func (dlm *DistributedLockManager) LockWithTimeout(key string, expiredAtNs int64
if movedTo != dlm.Host {
return
}
- renewToken, err = dlm.lockManager.Lock(key, expiredAtNs, token, owner)
+ lockOwner, renewToken, err = dlm.lockManager.Lock(key, expiredAtNs, token, owner)
return
}