Skip to content

Commit

Permalink
little bit of cleanup on candidate lock runner
Browse files Browse the repository at this point in the history
  • Loading branch information
dcarbone committed Aug 1, 2018
1 parent a6360ef commit 9ea9e30
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions candidate/candidate.go
Original file line number Diff line number Diff line change
Expand Up @@ -477,15 +477,13 @@ acquisition:
c.log.Print("Session Update: 2 successive errors seen, will construct new session")
c.session.Stop()
elected = false
updated = c.elected != nil && *c.elected != elected
c.session = nil
}
} else if sessionUpdate.State == session.StateStopped {
sessionStoppedUpdatesSeen++
sessionErrorsSeen = 0

elected = false
updated = c.elected != nil && *c.elected != elected

c.log.Printf("Session Update: Stopped state seen (%d in row): %#v", sessionStoppedUpdatesSeen, sessionUpdate)

Expand All @@ -502,6 +500,8 @@ acquisition:
c.log.Debugf("Session Update: Received %#v", sessionUpdate)
}

updated = c.elected != nil && *c.elected != elected

c.mu.Unlock()

case resigned = <-c.resign:
Expand Down

0 comments on commit 9ea9e30

Please sign in to comment.