diff options
Diffstat (limited to 'weed/cluster/lock_manager/distributed_lock_manager.go')
| -rw-r--r-- | weed/cluster/lock_manager/distributed_lock_manager.go | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/weed/cluster/lock_manager/distributed_lock_manager.go b/weed/cluster/lock_manager/distributed_lock_manager.go index b78c62b00..7577fb830 100644 --- a/weed/cluster/lock_manager/distributed_lock_manager.go +++ b/weed/cluster/lock_manager/distributed_lock_manager.go @@ -6,6 +6,8 @@ import ( "time" ) +var NoLockServerError = fmt.Errorf("no lock server found") + type DistributedLockManager struct { lockManager *LockManager LockRing *LockRing @@ -21,7 +23,7 @@ func NewDistributedLockManager() *DistributedLockManager { func (dlm *DistributedLockManager) Lock(host pb.ServerAddress, key string, expiredAtNs int64, token string) (renewToken string, movedTo pb.ServerAddress, err error) { servers := dlm.LockRing.GetSnapshot() if servers == nil { - err = fmt.Errorf("no lock server found") + err = NoLockServerError return } @@ -37,7 +39,7 @@ func (dlm *DistributedLockManager) Lock(host pb.ServerAddress, key string, expir func (dlm *DistributedLockManager) Unlock(host pb.ServerAddress, key string, token string) (movedTo pb.ServerAddress, err error) { servers := dlm.LockRing.GetSnapshot() if servers == nil { - err = fmt.Errorf("no lock server found") + err = NoLockServerError return } |