aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2024-02-04 12:47:07 -0800
committerChris Lu <chris.lu@gmail.com>2024-02-04 12:47:07 -0800
commit44b49bec99a4f40eaf890a6aa361716e1cd10ab0 (patch)
tree79adac40aefbedbcf4f96068876ea2eed6bfb73e
parent53612b770c029af3747fd2bc96f854fb3685aadb (diff)
downloadseaweedfs-44b49bec99a4f40eaf890a6aa361716e1cd10ab0.tar.xz
seaweedfs-44b49bec99a4f40eaf890a6aa361716e1cd10ab0.zip
less verbose
-rw-r--r--weed/cluster/lock_client.go4
1 files changed, 2 insertions, 2 deletions
diff --git a/weed/cluster/lock_client.go b/weed/cluster/lock_client.go
index 82d6785a1..57801735c 100644
--- a/weed/cluster/lock_client.go
+++ b/weed/cluster/lock_client.go
@@ -111,12 +111,10 @@ func (lock *LiveLock) retryUntilLocked(lockDuration time.Duration) {
func (lock *LiveLock) AttemptToLock(lockDuration time.Duration) error {
errorMessage, err := lock.doLock(lockDuration)
if err != nil {
- glog.Warningf("lock1 %s: %v", lock.key, err)
time.Sleep(time.Second)
return err
}
if errorMessage != "" {
- glog.Warningf("lock2 %s: %v", lock.key, errorMessage)
time.Sleep(time.Second)
return fmt.Errorf("%v", errorMessage)
}
@@ -167,7 +165,9 @@ func (lock *LiveLock) doLock(lockDuration time.Duration) (errorMessage string, e
}
if resp.LockOwner != "" {
lock.owner = resp.LockOwner
+ // fmt.Printf("lock %s owner: %s\n", lock.key, lock.owner)
} else {
+ // fmt.Printf("lock %s has no owner\n", lock.key)
lock.owner = ""
}
}