github/client-go
1
0
Fork 0
mirror of https://github.com/kubernetes/client-go.git synced 2025-08-13 13:06:03 +00:00
Code Issues Projects Releases Wiki Activity

chore

Browse Source 
Kubernetes-commit: 09ec6f744833fb72a319013ae25cf0286cdd125e
This commit is contained in:
Keisuke Ishigami 2025-07-15 01:07:25 +09:00 committed by Kubernetes Publisher
parent b62c1cc29f
commit 3633ea23d3
1 changed files with 2 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
tools/leaderelection/leaderelection.go
View File

@ -308,8 +308,8 @@ func (le *LeaderElector) renew(ctx context.Context) {
func (le *LeaderElector) release() bool { func (le *LeaderElector) release() bool {
ctx := context.Background() ctx := context.Background()
// 1. obtain the electionRecord // update the resourceVersion of lease
oldLeaderElectionRecord, oldLeaderElectionRawRecord, err := le.config.Lock.Get(ctx) oldLeaderElectionRecord, _, err := le.config.Lock.Get(ctx)
if err != nil { if err != nil {
if !errors.IsNotFound(err) { if !errors.IsNotFound(err) {
klog.Errorf("error retrieving resource lock %v: %v", le.config.Lock.Describe(), err) klog.Errorf("error retrieving resource lock %v: %v", le.config.Lock.Describe(), err)
@ -318,12 +318,6 @@ func (le *LeaderElector) release() bool {
klog.Infof("lease lock not found: %v", le.config.Lock.Describe()) klog.Infof("lease lock not found: %v", le.config.Lock.Describe())
return false return false
} }
// 2. Record obtained, check the Identity & Time
if !bytes.Equal(le.observedRawRecord, oldLeaderElectionRawRecord) {
le.setObservedRecord(oldLeaderElectionRecord)
le.observedRawRecord = oldLeaderElectionRawRecord
}
if !le.IsLeader() { if !le.IsLeader() {
return true return true